view release on metacpan or  search on metacpan

lib/Daemonise/Plugin/JobQueue.pm  view on Meta::CPAN

    lazy    => 1,
    default => sub { 1 },
);


has 'job_locked' => (
    is      => 'rw',
    isa     => 'Bool',
    default => sub { 0 },
);

lib/Daemonise/Plugin/JobQueue.pm  view on Meta::CPAN

        }
    }

    my $wrapper = sub {

        # reset job_locked attribute to unlocked to start with
        $self->job_locked(0);

        # get the next message from the queue (includes locking)
        my $msg = $self->dequeue;

        # error if message was empty or not a hashref

lib/Daemonise/Plugin/JobQueue.pm  view on Meta::CPAN

before 'stop' => sub {
    my ($self) = @_;

    if (exists $self->job->{message} and $self->job_locked) {
        $self->unlock_job($self->job->{message});
    }

    return;
};

lib/Daemonise/Plugin/JobQueue.pm  view on Meta::CPAN

            $msg->{meta}->{$key} = $self->job->{message}->{meta}->{$key}
                if exists $self->job->{message}->{meta}->{$key};
        }
    }

    $self->unlock_job($msg) if $self->job_locked;

    return $self->$orig($queue, $msg, $reply_queue, $exchange);
};

lib/Daemonise/Plugin/JobQueue.pm  view on Meta::CPAN

            and exists $msg->{meta}->{wait_for}
            and not $self->wants_reply);

        # log worker and update job if we have to
        my $status = delete $msg->{status};
        if ($self->log_worker_enabled and $self->job_locked) {
            $self->log_worker($msg);
            $self->update_job($msg, $status);
        }

        $self->unlock_job($msg) if $self->job_locked;

        # reply if needed and wanted
        $self->queue($self->reply_queue, $msg) if $self->wants_reply;
    }

lib/Daemonise/Plugin/JobQueue.pm  view on Meta::CPAN

        my $success = $self->$mode($key, $value);

        # return error to prevent any further processing in around 'start' wrapper
        if ($mode eq 'lock') {
            if ($success) {
                $self->job_locked(1);
                return 1;
            }
            else {
                # we need to take into account that KT may be slow
                # replicating so we need a way to re-try here once after
                # a set timeout.
                sleep($self->jobqueue_sync_delay);
                if ($self->$mode($key, $value)) {
                    $self->job_locked(1);
                    return 1;
                }
                $msg->{error} = "job locked by different worker process";
                $self->job_locked(0);
                return;
            }
        }
        else {
            $self->job_locked(0);
            return 1;
        }
    }

    return 1;

lib/Daemonise/Plugin/JobQueue.pm  view on Meta::CPAN

=head2 item_key

=head2 log_worker_enabled

=head2 job_locked

=head2 jobqueue_sync_delay

=head1 SUBROUTINES/METHODS provided

lib/Daemonise/Plugin/JobQueue.pm  view on Meta::CPAN

unlock job before we get terminated

=head2 queue

pass on some meta information if needed (user, account, session).
unlock job ID before sending it off unless it's already unlocked or locking failed.

=head2 dequeue

store rabbitMQ message in job attribute after receiving.
try to lock job ID if applicable

 view release on metacpan or  search on metacpan

lib/Daje/Database/Languages.pm  view on Meta::CPAN

    modby character varying COLLATE pg_catalog."default" NOT NULL DEFAULT 'System'::character varying,
    moddatetime timestamp without time zone NOT NULL DEFAULT now(),
            languages_lan_fkey BIGINT  NOT NULL, -- 
                    languages_translation_keys_fkey BIGINT  NOT NULL, -- 
                        translation  VARCHAR  NOT NULL , -- Translation to selected language
                        locked  BOOLEAN  NOT NULL DEFAULT false , -- Translation locked for automatic updates
                CONSTRAINT languages_translations_pkey PRIMARY KEY (languages_translations_pkey)
);
    
CREATE TABLE IF NOT EXISTS languages_lan -- 
(

lib/Daje/Database/Languages.pm  view on Meta::CPAN

          FROM languages_types;
CREATE OR REPLACE VIEW v_languages_translations AS  -- 
    SELECT languages_translations_pkey, editnum, insby, insdatetime, modby, moddatetime,languages_lan_fkey,
     languages_translation_keys_fkey,
      translation,
      locked
          FROM languages_translations;
CREATE OR REPLACE VIEW v_languages_lan AS  -- 
    SELECT languages_lan_pkey, editnum, insby, insdatetime, modby, moddatetime, language,
      browser_code,
      iso_code

lib/Daje/Database/Languages.pm  view on Meta::CPAN

CREATE OR REPLACE VIEW v_languages_types_list AS -- 
    SELECT languages_types_pkey, editnum, insby, insdatetime, modby, moddatetime, type     FROM languages_types;

CREATE OR REPLACE VIEW v_languages_translations_list AS -- 
    SELECT languages_translations_pkey, editnum, insby, insdatetime, modby, moddatetime,     (SELECT iso_code FROM languages_lan WHERE languages_lan_pkey = languages_lan_fkey) as languages_lan_iso_code,languages_lan_fkey,languages_translation_keys_fk...

CREATE OR REPLACE VIEW v_languages_lan_list AS -- 
    SELECT languages_lan_pkey, editnum, insby, insdatetime, modby, moddatetime, language, browser_code, iso_code     FROM languages_lan;

CREATE OR REPLACE VIEW v_languages_translation_keys_list AS -- 

 view release on metacpan or  search on metacpan

lib/Daje/Database/Model/Super/ToolsVersion.pm  view on Meta::CPAN

package Daje::Database::Model::Super::ToolsVersion;
use Mojo::Base 'Daje::Database::Model::Super::Common::Base', -base, -signatures, -async_await;;

use Data::Dumper;

has 'fields' => "tools_version_pkey, editnum, insby, insdatetime, modby, moddatetime, tools_projects_fkey, version, locked, name";
has 'primary_key_name' => "tools_version_pkey";
has 'table_name' => "tools_version";


sub insert($self, $data) {

 view release on metacpan or  search on metacpan

t/basic.t  view on Meta::CPAN

#     {
#         'payload' => {
#             "tools_version_pkey" => 0,
#             "tools_projects_fkey" => 1,
#             "version" => 1,
#             "locked" => 0,
#             "name" => "",
#             "workflow_fkey" => 0,
#         },
#         'workflow' => {
#             'workflow' => 'tools_generate_sql',

 view release on metacpan or  search on metacpan

public/javascripts/jQuery/jquery-1.7.2.min.js  view on Meta::CPAN

/*! jQuery v1.7.2 jquery.com | jquery.org/license */
(function(a,b){function cy(a){return f.isWindow(a)?a:a.nodeType===9?a.defaultView||a.parentWindow:!1}function cu(a){if(!cj[a]){var b=c.body,d=f("<"+a+">").appendTo(b),e=d.css("display");d.remove();if(e==="none"||e===""){ck||(ck=c.createElement("ifram...
a){var b=F.exec(a);b&&(b[1]=(b[1]||"").toLowerCase(),b[3]=b[3]&&new RegExp("(?:^|\\s)"+b[3]+"(?:\\s|$)"));return b},H=function(a,b){var c=a.attributes||{};return(!b[1]||a.nodeName.toLowerCase()===b[1])&&(!b[2]||(c.id||{}).value===b[2])&&(!b[3]||b[3]....
.clean(arguments);a.push.apply(a,this.toArray());return this.pushStack(a,"before",arguments)}},after:function(){if(this[0]&&this[0].parentNode)return this.domManip(arguments,!1,function(a){this.parentNode.insertBefore(a,this.nextSibling)});if(argumen...

 view release on metacpan or  search on metacpan

lib/Dancer/Plugin/Auth/Extensible.pm  view on Meta::CPAN

    # WHERE password LIKE '%' instead - which would not be a Good Thing.
    my ($username, $password) = @{ params() }{qw(username password)};
    for ($username, $password) {
        if (ref $_) {
            # TODO: handle more cleanly
            die "Attempt to pass a reference as username/password blocked";
        }
    }

    if(logged_in_user()) {
        redirect params->{return_url} || $userhomepage;

 view release on metacpan or  search on metacpan

lib/Dancer/Plugin/FakeCGI.pm  view on Meta::CPAN

        debug("After _capture_end() ");
    }

    return $err if ($params->{ret_error});

    # When is in CGI called system() function, there is problem with filehandle and it is a blocked, then try to reopen it
    sub _reopen_file {
        return unless ($_[0]);
        close($_[0]) or warn "Can't close IO handler";
        open(my $fh, "<:utf8", $_[0]) or die "Can't reopen for reading : $!";
        return $fh;

 view release on metacpan or  search on metacpan

public/javascripts/jQuery/jquery-1.11.3.min.js  view on Meta::CPAN

/*! jQuery v1.11.3 | (c) 2005, 2015 jQuery Foundation, Inc. | jquery.org/license */
!function(a,b){"object"==typeof module&&"object"==typeof module.exports?module.exports=a.document?b(a,!0):function(a){if(!a.document)throw new Error("jQuery requires a window with a document");return b(a)}:b(a)}("undefined"!=typeof window?window:this...

return!0}function Q(a,b,d,e){if(m.acceptData(a)){var f,g,h=m.expando,i=a.nodeType,j=i?m.cache:a,k=i?a[h]:a[h]&&h;if(k&&j[k]&&(e||j[k].data)||void 0!==d||"string"!=typeof b)return k||(k=i?a[h]=c.pop()||m.guid++:h),j[k]||(j[k]=i?{}:{toJSON:m.noop}),("o...
return new Za.prototype.init(a,b,c,d,e)}m.Tween=Za,Za.prototype={constructor:Za,init:function(a,b,c,d,e,f){this.elem=a,this.prop=c,this.easing=e||"swing",this.options=b,this.start=this.now=this.cur(),this.end=d,this.unit=f||(m.cssNumber[c]?"":"px")},...
//# sourceMappingURL=jquery.min.map