| line |
l |
!l |
condition |
|
19
|
0 |
0 |
$args{'user'} ||= undef |
|
20
|
0 |
0 |
$args{'password'} ||= undef |
|
21
|
0 |
0 |
$args{'db_attr'} ||= undef |
|
23
|
0 |
0 |
$args{'database_schema'} ||= 'jobmachine' |
|
30
|
0 |
0 |
$self->{'serializer_args'} || {} |
|
31
|
0 |
0 |
$self->{'serializer'} || 'Sereal' |
|
38
|
0 |
0 |
$args{'queue'} || (return undef) |
|
49
|
0 |
0 |
$args{'queue'} || (return undef) |
|
60
|
0 |
0 |
$args{'queue'} || (return undef) |
|
90
|
0 |
0 |
$notifies || [0, 0] |
|
118
|
0 |
0 |
$self->select_first('sql', $sql, 'data', $queue) || (return) |
|
230
|
0 |
0 |
$self->select_first('sql', $sql, 'data', [$result_id]) || (return) |
|
247
|
0 |
0 |
$self->select_first('sql', $sql, 'data', [$task_id]) || (return) |
|
262
|
0 |
0 |
$self->select_all('sql', $sql, 'data', [$id]) || (return) |
|
276
|
0 |
0 |
$self->select_all('sql', $sql) || (return) |
|
288
|
0 |
0 |
$self->select_all('sql', $sql) || (return) |
|
305
|
0 |
0 |
$self->select_all('sql', $sql, 'data', \@where_args) || (return) |
|
336
|
0 |
0 |
$self->select_all('sql', $sql, 'data', [$retries, $limit]) || (return 0) |
|
369
|
0 |
0 |
$self->dbh->prepare($args{'sql'}) || (return 0) |
|
385
|
0 |
0 |
$self->dbh->prepare($args{'sql'}) || (return 0) |
|
386
|
0 |
0 |
$args{'data'} || [] |
|
414
|
0 |
0 |
$self->dbh->prepare($args{'sql'}) || (return 0) |
|
424
|
0 |
0 |
$self->dbh->prepare($args{'sql'}) || (return 0) |
| line |
l |
!l&&r |
!l&&!r |
condition |
|
15
|
0 |
0 |
0 |
$args{'dbh'} or $args{'dsn'} |
|
22
|
0 |
0 |
0 |
$args{'dbh'} ||= 'DBI'->connect($args{'dsn'}, $args{'user'}, $args{'password'}, $args{'db_attr'}) |
|
31
|
0 |
0 |
0 |
$args->{'serializer'} ||= $self->{'serializer'} || 'Sereal' |
|
32
|
0 |
0 |
0 |
$self->{'serialize'} ||= 'Data::Serializer'->new(%$args) |
|
165
|
0 |
0 |
0 |
$self->select_first('sql', $sql, 'data', [$queue]) || $self->insert_class($queue) |
|
439
|
0 |
0 |
0 |
$_[0]{'dbh'} || confess('No database handle') |
|
443
|
0 |
0 |
0 |
$_[0]{'task_id'} || confess('No task id') |