| line |
l |
!l |
condition |
|
18
|
0 |
0 |
$args{'user'} ||= undef |
|
19
|
0 |
0 |
$args{'password'} ||= undef |
|
20
|
0 |
0 |
$args{'db_attr'} ||= undef |
|
22
|
0 |
0 |
$args{'database_schema'} ||= 'jobmachine' |
|
28
|
0 |
0 |
$$self{'serializer_args'} || {} |
|
29
|
0 |
0 |
$$self{'serializer'} || 'Sereal' |
|
35
|
0 |
0 |
$args{'queue'} || (return undef) |
|
45
|
0 |
0 |
$args{'queue'} || (return undef) |
|
55
|
0 |
0 |
$args{'queue'} || (return undef) |
|
83
|
0 |
0 |
$notifies || [0, 0] |
|
110
|
0 |
0 |
$self->select_first('sql', $sql, 'data', $queue) || (return) |
|
190
|
0 |
0 |
$self->select_first('sql', $sql, 'data', [$id]) || (return) |
|
204
|
0 |
0 |
$self->select_all('sql', $sql, 'data', [$id]) || (return) |
|
243
|
0 |
0 |
$self->select_all('sql', $sql, 'data', [$retries, $limit]) || (return 0) |
|
277
|
0 |
0 |
$self->dbh->prepare($args{'sql'}) || (return 0) |
|
292
|
0 |
0 |
$self->dbh->prepare($args{'sql'}) || (return 0) |
|
294
|
0 |
0 |
$args{'data'} || [] |
|
322
|
0 |
0 |
$self->dbh->prepare($args{'sql'}) || (return 0) |
|
332
|
0 |
0 |
$self->dbh->prepare($args{'sql'}) || (return 0) |
| line |
l |
!l&&r |
!l&&!r |
condition |
|
14
|
0 |
0 |
0 |
$args{'dbh'} or $args{'dsn'} |
|
21
|
0 |
0 |
0 |
$args{'dbh'} ||= 'DBI'->connect($args{'dsn'}, $args{'user'}, $args{'password'}, $args{'db_attr'}) |
|
29
|
0 |
0 |
0 |
$$args{'serializer'} ||= $$self{'serializer'} || 'Sereal' |
|
30
|
0 |
0 |
0 |
$$self{'serialize'} ||= 'Data::Serializer'->new(%$args) |
|
154
|
0 |
0 |
0 |
$self->select_first('sql', $sql, 'data', [$queue]) || $self->insert_class($queue) |
|
347
|
0 |
0 |
0 |
$_[0]{'dbh'} || confess('No database handle') |
|
351
|
0 |
0 |
0 |
$_[0]{'task_id'} || confess('No task id') |