line |
true |
false |
branch |
35
|
0 |
1 |
if ($dsn =~ /^DBI:mysql:/i) { } |
|
1 |
0 |
elsif ($dsn =~ /^DBI:SQLite:/i) { } |
|
0 |
0 |
elsif ($dsn =~ /^DBI:Oracle:/i) { } |
|
0 |
0 |
elsif ($dsn =~ /^DBI:Pg:/i) { } |
46
|
1 |
0 |
unless (eval "use $subclass; 1") |
81
|
0 |
0 |
unless my $dbh = 'DBI'->connect($dsn, $args{'dbuser'}, $args{'dbpass'}, {'PrintError', 0}) |
90
|
0 |
0 |
if $sto |
96
|
0 |
0 |
unless my $rdbh = 'DBI'->connect($rootdsn, $args{'dbrootuser'}, $args{'dbrootpass'}, {'PrintError', 0}) |
108
|
0 |
0 |
if $sto |
117
|
0 |
0 |
unless $rdbh->do("CREATE DATABASE IF NOT EXISTS $dbname") |
123
|
0 |
0 |
unless $rdbh->do("GRANT ALL PRIVILEGES ON $dbname.* TO $user\@'%' IDENTIFIED BY ?", undef, $pass) |
126
|
0 |
0 |
unless $rdbh->do("GRANT ALL PRIVILEGES ON $dbname.* TO $user\@'localhost' IDENTIFIED BY ?", undef, $pass) |
140
|
0 |
0 |
if $self->can_insertignore |
141
|
0 |
0 |
if $self->can_replace |
150
|
0 |
0 |
unless &$on_confirm($msg) |
175
|
0 |
0 |
unless $self->can_do_slaves |
188
|
0 |
0 |
if ($ver <= $self->{'slave_list_version'}) |
202
|
0 |
0 |
unless my $sk = 'MogileFS::Config'->server_setting_cached('slave_keys') |
209
|
0 |
0 |
unless ($slave) |
215
|
0 |
0 |
unless (defined $dsn and defined $user and defined $pass) |
228
|
0 |
0 |
unless @temp |
242
|
0 |
0 |
if defined $dead_timeout and $dead_timeout + $dead_retry * $dead_backoff > $now |
244
|
0 |
0 |
if $self->{'connected_slaves'}{$slave_fulldsn->[0]} |
251
|
0 |
0 |
if ($self->check_slave) { } |
256
|
0 |
0 |
unless $dead_backoff > 20 |
265
|
0 |
0 |
unless $self->can_do_slaves |
270
|
0 |
0 |
unless ($full_dsn) |
277
|
0 |
0 |
unless ($self->_slaves_list_changed) |
278
|
0 |
0 |
if ($self->{'slave'} = $self->_pick_slave) |
280
|
0 |
0 |
if $self->check_slave |
284
|
0 |
0 |
if ($self->{'slave'}) |
294
|
0 |
0 |
unless @slaves_list |
298
|
0 |
0 |
unless (defined $slave_skip_filtering and $slave_skip_filtering eq 'on') |
308
|
0 |
0 |
if ($self->{'slave'} = $self->_pick_slave) |
318
|
0 |
0 |
unless $self->can_do_slaves |
320
|
0 |
0 |
if ($self->{'slave_ok'}) |
321
|
0 |
0 |
if (my $slave = $self->get_slave) |
333
|
0 |
0 |
unless ref $coderef eq 'CODE' |
348
|
0 |
0 |
if ($self->{'dbh'}) |
349
|
0 |
0 |
if ($self->{'recheck_done_gen'} != $self->{'recheck_req_gen'}) |
350
|
0 |
0 |
unless $self->{'dbh'}->ping |
355
|
0 |
0 |
if $self->{'max_handles'} and $self->{'handles_left'}-- < 0 and not $self->{'lock_depth'} |
358
|
0 |
0 |
if $self->{'dbh'} |
364
|
0 |
0 |
unless ($self->is_slave) |
366
|
0 |
0 |
if defined $flag and $flag == 0 |
370
|
0 |
0 |
if ($self->{'lock_depth'}) |
386
|
0 |
0 |
if ($@ eq "timeout\n") { } |
|
0 |
0 |
elsif ($@) { } |
392
|
0 |
0 |
if $self->{'max_handles'} |
396
|
0 |
0 |
if $_[0]{'dbh'} |
406
|
0 |
0 |
unless $dbh->err |
409
|
0 |
0 |
if $optmsg |
411
|
0 |
0 |
if ($dbh->{'AutoCommit'} == 0) |
418
|
0 |
0 |
unless $@ or $self->dbh->err |
424
|
0 |
0 |
if scalar(@_) % 2 |
428
|
0 |
0 |
if %uarg |
450
|
0 |
0 |
if $self->was_duplicate_error |
451
|
0 |
0 |
if $@ |
464
|
0 |
0 |
if ($self->can_insertignore) { } |
469
|
0 |
0 |
if ($@ or $dbh->err) |
470
|
0 |
0 |
if $self->was_duplicate_error |
486
|
0 |
0 |
if $tries < 1 |
491
|
0 |
0 |
if $self->was_deadlock_error |
492
|
0 |
0 |
if $@ |
519
|
0 |
0 |
if ($curver == $latestver) |
524
|
0 |
0 |
if ($curver > $latestver) |
528
|
0 |
0 |
if ($curver) |
571
|
0 |
0 |
if $self->table_exists($table) |
576
|
0 |
0 |
unless $dbh->do($sql) |
582
|
0 |
0 |
unless $dbh->do($sql) |
845
|
0 |
0 |
unless ($self->column_type('class', 'replpolicy')) |
852
|
0 |
0 |
unless ($self->column_type('class', 'hashtype')) |
870
|
0 |
0 |
if ($self->domain_has_files($dmid)) { } |
|
0 |
0 |
elsif ($self->domain_has_classes($dmid)) { } |
882
|
0 |
0 |
if $err |
885
|
0 |
0 |
if $err |
893
|
0 |
0 |
$has_a_fid ? : |
909
|
0 |
0 |
$has_a_fid ? : |
922
|
0 |
0 |
if ($classname eq 'default') { } |
933
|
0 |
0 |
if $rv |
935
|
0 |
0 |
if ($@ or $dbh->err) |
936
|
0 |
0 |
if ($self->was_duplicate_error) |
938
|
0 |
0 |
if ($dbh->{'AutoCommit'} == 0) |
943
|
0 |
0 |
if $rv |
955
|
0 |
0 |
if $self->was_duplicate_error |
1004
|
0 |
0 |
unless $self->can_replace |
1007
|
0 |
0 |
if (defined $val) { } |
1014
|
0 |
0 |
if $dbh->err |
1021
|
0 |
0 |
unless defined $val |
1022
|
0 |
0 |
unless $val |
1024
|
0 |
0 |
if $self->dbh->do('UPDATE server_settings SET value=value+? WHERE field=?', undef, $val, $key) > 0 |
1063
|
0 |
0 |
$fid ? : |
1083
|
0 |
0 |
if ($fid) |
1091
|
0 |
0 |
unless ($rv) |
1092
|
0 |
0 |
if $self->was_duplicate_error |
1096
|
0 |
0 |
unless (defined $fid) |
1099
|
0 |
0 |
unless $fid = $dbh->last_insert_id(undef, undef, 'tempfile', 'fid') |
1102
|
0 |
0 |
unless defined $fid and $fid > 0 |
1106
|
0 |
0 |
unless (&$ins_tempfile()) |
1107
|
0 |
0 |
if $explicit_fid_used |
1113
|
0 |
0 |
$exists ? : |
1121
|
0 |
0 |
if $explicit_fid_used |
1135
|
0 |
0 |
unless &$ins_tempfile() |
1173
|
0 |
0 |
unless $self->dbh->selectcol_arrayref('SELECT devid FROM file_on WHERE fid=?', undef, $fidid) |
1206
|
0 |
0 |
unless $rv > 0 |
1213
|
0 |
0 |
unless @keys |
1275
|
0 |
0 |
if $self->class_has_files($dmid, $cid) |
1315
|
0 |
0 |
if $rows_deleted > 0 |
1321
|
0 |
0 |
unless $self->can_replace |
1340
|
0 |
0 |
if ($@ or $dbh->err) |
1342
|
0 |
0 |
if ($self->was_duplicate_error) { } |
1363
|
0 |
0 |
unless $domains |
1379
|
0 |
0 |
if ($self->cached_schema_version >= 10) |
1381
|
0 |
0 |
if ($self->cached_schema_version >= 15) |
1396
|
0 |
0 |
unless $fidid |
1397
|
0 |
0 |
unless $devid |
1404
|
0 |
0 |
if $rv > 0 |
1491
|
0 |
0 |
if ($in) |
1508
|
0 |
0 |
unless $in |
1521
|
0 |
0 |
unless $in |
1525
|
0 |
0 |
if (ref $fidid) { } |
1539
|
0 |
0 |
unless ($self->can_insert_multi and $self->can_replace || $self->can_insertignore) |
1544
|
0 |
0 |
unless $in |
1549
|
0 |
0 |
if (ref $fidids->[0] eq 'ARRAY') { } |
1604
|
0 |
0 |
unless $devid |
1608
|
0 |
0 |
if %o |
1613
|
0 |
0 |
if ($age eq 'old') { } |
|
0 |
0 |
elsif ($age eq 'new') { } |
1614
|
0 |
0 |
if $fidid |
1617
|
0 |
0 |
if $fidid |
1624
|
0 |
0 |
if $fidid |
1657
|
0 |
0 |
if ($self->was_duplicate_error) |
1660
|
0 |
0 |
if $rv |
1667
|
0 |
0 |
unless @keys |
1688
|
0 |
0 |
if $rv |
1697
|
0 |
0 |
unless my $to_repl_map = $self->dbh->selectall_hashref("\n SELECT fid, fromdevid, failcount, flags, nexttry\n FROM file_to_replicate\n WHERE nexttry <= $ut\n ORDER BY nexttry\n LIMIT $limit\n ", 'fid') |
1726
|
0 |
0 |
unless $self->lock_queue($queue) |
1730
|
0 |
0 |
if $extfields |
1742
|
0 |
0 |
if $self->can_for_update |
1750
|
0 |
0 |
unless ($fidlist) |
1754
|
0 |
0 |
if ($self->was_deadlock_error) { } |
1764
|
0 |
0 |
if ($dbh->{'AutoCommit'} == 0) |
1767
|
0 |
0 |
defined $work ? : |
1798
|
0 |
0 |
if $self->get_lock($lockname, 1) |
1897
|
0 |
0 |
unless defined $prefix |
1903
|
0 |
0 |
unless defined $after |
1927
|
0 |
0 |
unless @devfids |
1929
|
0 |
0 |
if (@devfids > 1 and not $self->can_insert_multi) |
1937
|
0 |
0 |
unless $fidid |
1938
|
0 |
0 |
unless $devid |
1959
|
0 |
0 |
unless $self->dbh->selectcol_arrayref("\n SELECT fid\n FROM file_to_delete_later\n WHERE delafter < $ut\n LIMIT 500\n ") |
1973
|
0 |
0 |
if (@fidids > 1 and not $self->can_insert_multi && ($self->can_replace || $self->can_insertignore)) |
1990
|
0 |
0 |
if (@fidids > 1 and not $self->can_insert_multi && ($self->can_replace || $self->can_insertignore)) |
2021
|
0 |
0 |
if defined $lock and $lock == 0 |
2037
|
0 |
0 |
if $lock |
2048
|
0 |
0 |
if %opts |
2093
|
0 |
0 |
if %opts |
2097
|
0 |
0 |
if ($timegte) |
2105
|
0 |
0 |
if ($logr) |
2128
|
0 |
0 |
unless my $sk = 'MogileFS::Config'->server_setting('slave_keys') |
2135
|
0 |
0 |
unless ($slave) |
2141
|
0 |
0 |
unless (defined $dsn and defined $user and defined $pass) |
2148
|
0 |
0 |
unless @slaves |
2158
|
0 |
0 |
if $self->{'lock_depth'} |
2179
|
0 |
0 |
unless $self->can_replace |