| line |
true |
false |
branch |
|
33
|
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) { } |
|
44
|
1 |
0 |
unless (eval "use $subclass; 1") |
|
78
|
0 |
0 |
unless my $dbh = 'DBI'->connect($dsn, $args{'dbuser'}, $args{'dbpass'}, {'PrintError', 0}) |
|
88
|
0 |
0 |
if $sto |
|
93
|
0 |
0 |
unless my $rdbh = 'DBI'->connect($rootdsn, $args{'dbrootuser'}, $args{'dbrootpass'}, {'PrintError', 0}) |
|
106
|
0 |
0 |
if $sto |
|
115
|
0 |
0 |
unless $rdbh->do("CREATE DATABASE IF NOT EXISTS $dbname") |
|
121
|
0 |
0 |
unless $rdbh->do("GRANT ALL PRIVILEGES ON $dbname.* TO $user\@'%' IDENTIFIED BY ?", undef, $pass) |
|
124
|
0 |
0 |
unless $rdbh->do("GRANT ALL PRIVILEGES ON $dbname.* TO $user\@'localhost' IDENTIFIED BY ?", undef, $pass) |
|
138
|
0 |
0 |
if $self->can_insertignore |
|
139
|
0 |
0 |
if $self->can_replace |
|
148
|
0 |
0 |
unless &$on_confirm($msg) |
|
173
|
0 |
0 |
unless $self->can_do_slaves |
|
186
|
0 |
0 |
if ($ver <= $$self{'slave_list_version'}) |
|
200
|
0 |
0 |
unless my $sk = 'MogileFS::Config'->server_setting_cached('slave_keys') |
|
207
|
0 |
0 |
unless ($slave) |
|
213
|
0 |
0 |
unless (defined $dsn and defined $user and defined $pass) |
|
226
|
0 |
0 |
unless @temp |
|
240
|
0 |
0 |
if defined $dead_timeout and $dead_timeout + $dead_retry * $dead_backoff > $now |
|
242
|
0 |
0 |
if $$self{'connected_slaves'}{$$slave_fulldsn[0]} |
|
249
|
0 |
0 |
if ($self->check_slave) { } |
|
254
|
0 |
0 |
unless $dead_backoff > 20 |
|
263
|
0 |
0 |
unless $self->can_do_slaves |
|
268
|
0 |
0 |
unless ($full_dsn) |
|
275
|
0 |
0 |
unless ($self->_slaves_list_changed) |
|
276
|
0 |
0 |
if ($$self{'slave'} = $self->_pick_slave) |
|
278
|
0 |
0 |
if $self->check_slave |
|
282
|
0 |
0 |
if ($$self{'slave'}) |
|
292
|
0 |
0 |
unless @slaves_list |
|
296
|
0 |
0 |
unless (defined $slave_skip_filtering and $slave_skip_filtering eq 'on') |
|
306
|
0 |
0 |
if ($$self{'slave'} = $self->_pick_slave) |
|
316
|
0 |
0 |
unless $self->can_do_slaves |
|
318
|
0 |
0 |
if ($$self{'slave_ok'}) |
|
319
|
0 |
0 |
if (my $slave = $self->get_slave) |
|
331
|
0 |
0 |
unless ref $coderef eq 'CODE' |
|
346
|
0 |
0 |
if ($$self{'dbh'}) |
|
347
|
0 |
0 |
if ($$self{'recheck_done_gen'} != $$self{'recheck_req_gen'}) |
|
348
|
0 |
0 |
unless $$self{'dbh'}->ping |
|
352
|
0 |
0 |
if $$self{'max_handles'} and $$self{'handles_left'}-- < 0 and not $$self{'lock_depth'} |
|
356
|
0 |
0 |
if $$self{'dbh'} |
|
362
|
0 |
0 |
unless ($self->is_slave) |
|
364
|
0 |
0 |
if defined $flag and $flag == 0 |
|
368
|
0 |
0 |
if ($$self{'lock_depth'}) |
|
384
|
0 |
0 |
if ($@ eq "timeout\n") { } |
|
|
0 |
0 |
elsif ($@) { } |
|
390
|
0 |
0 |
if $$self{'max_handles'} |
|
394
|
0 |
0 |
if $_[0]{'dbh'} |
|
404
|
0 |
0 |
unless $dbh->err |
|
407
|
0 |
0 |
if $optmsg |
|
409
|
0 |
0 |
if ($$dbh{'AutoCommit'} == 0) |
|
416
|
0 |
0 |
unless $@ or $self->dbh->err |
|
422
|
0 |
0 |
if scalar(@_) % 2 |
|
426
|
0 |
0 |
if %uarg |
|
448
|
0 |
0 |
if $self->was_duplicate_error |
|
449
|
0 |
0 |
if $@ |
|
462
|
0 |
0 |
if ($self->can_insertignore) { } |
|
467
|
0 |
0 |
if ($@ or $dbh->err) |
|
468
|
0 |
0 |
if $self->was_duplicate_error |
|
484
|
0 |
0 |
if $tries < 1 |
|
489
|
0 |
0 |
if $self->was_deadlock_error |
|
490
|
0 |
0 |
if $@ |
|
517
|
0 |
0 |
if ($curver == $latestver) |
|
522
|
0 |
0 |
if ($curver > $latestver) |
|
526
|
0 |
0 |
if ($curver) |
|
568
|
0 |
0 |
if $self->table_exists($table) |
|
573
|
0 |
0 |
unless $dbh->do($sql) |
|
579
|
0 |
0 |
unless $dbh->do($sql) |
|
842
|
0 |
0 |
unless ($self->column_type('class', 'replpolicy')) |
|
849
|
0 |
0 |
unless ($self->column_type('class', 'hashtype')) |
|
867
|
0 |
0 |
if ($self->domain_has_files($dmid)) { } |
|
|
0 |
0 |
elsif ($self->domain_has_classes($dmid)) { } |
|
879
|
0 |
0 |
if $err |
|
882
|
0 |
0 |
if $err |
|
890
|
0 |
0 |
$has_a_fid ? : |
|
906
|
0 |
0 |
$has_a_fid ? : |
|
919
|
0 |
0 |
if ($classname eq 'default') { } |
|
930
|
0 |
0 |
if $rv |
|
932
|
0 |
0 |
if ($@ or $dbh->err) |
|
933
|
0 |
0 |
if ($self->was_duplicate_error) |
|
935
|
0 |
0 |
if ($$dbh{'AutoCommit'} == 0) |
|
940
|
0 |
0 |
if $rv |
|
952
|
0 |
0 |
if $self->was_duplicate_error |
|
1001
|
0 |
0 |
unless $self->can_replace |
|
1004
|
0 |
0 |
if (defined $val) { } |
|
1011
|
0 |
0 |
if $dbh->err |
|
1018
|
0 |
0 |
unless defined $val |
|
1019
|
0 |
0 |
unless $val |
|
1021
|
0 |
0 |
if $self->dbh->do('UPDATE server_settings SET value=value+? WHERE field=?', undef, $val, $key) > 0 |
|
1060
|
0 |
0 |
$fid ? : |
|
1080
|
0 |
0 |
if ($fid) |
|
1088
|
0 |
0 |
unless ($rv) |
|
1089
|
0 |
0 |
if $self->was_duplicate_error |
|
1093
|
0 |
0 |
unless (defined $fid) |
|
1096
|
0 |
0 |
unless $fid = $dbh->last_insert_id(undef, undef, 'tempfile', 'fid') |
|
1099
|
0 |
0 |
unless defined $fid and $fid > 0 |
|
1103
|
0 |
0 |
unless (&$ins_tempfile()) |
|
1104
|
0 |
0 |
if $explicit_fid_used |
|
1110
|
0 |
0 |
$exists ? : |
|
1118
|
0 |
0 |
if $explicit_fid_used |
|
1132
|
0 |
0 |
unless &$ins_tempfile() |
|
1170
|
0 |
0 |
unless $self->dbh->selectcol_arrayref('SELECT devid FROM file_on WHERE fid=?', undef, $fidid) |
|
1203
|
0 |
0 |
unless $rv > 0 |
|
1210
|
0 |
0 |
unless @keys |
|
1244
|
0 |
0 |
unless $self->can_replace |
|
1267
|
0 |
0 |
if $self->class_has_files($dmid, $cid) |
|
1307
|
0 |
0 |
if $rows_deleted > 0 |
|
1313
|
0 |
0 |
unless $self->can_replace |
|
1332
|
0 |
0 |
if ($@ or $dbh->err) |
|
1334
|
0 |
0 |
if ($self->was_duplicate_error) { } |
|
1355
|
0 |
0 |
unless $domains |
|
1371
|
0 |
0 |
if ($self->cached_schema_version >= 10) |
|
1373
|
0 |
0 |
if ($self->cached_schema_version >= 15) |
|
1388
|
0 |
0 |
unless $fidid |
|
1389
|
0 |
0 |
unless $devid |
|
1396
|
0 |
0 |
if $rv > 0 |
|
1483
|
0 |
0 |
if ($in) |
|
1500
|
0 |
0 |
unless $in |
|
1513
|
0 |
0 |
unless $in |
|
1517
|
0 |
0 |
if (ref $fidid) { } |
|
1531
|
0 |
0 |
unless ($self->can_insert_multi and $self->can_replace || $self->can_insertignore) |
|
1536
|
0 |
0 |
unless $in |
|
1541
|
0 |
0 |
if (ref $$fidids[0] eq 'ARRAY') { } |
|
1596
|
0 |
0 |
unless $devid |
|
1600
|
0 |
0 |
if %o |
|
1605
|
0 |
0 |
if ($age eq 'old') { } |
|
|
0 |
0 |
elsif ($age eq 'new') { } |
|
1606
|
0 |
0 |
if $fidid |
|
1609
|
0 |
0 |
if $fidid |
|
1616
|
0 |
0 |
if $fidid |
|
1649
|
0 |
0 |
if ($self->was_duplicate_error) |
|
1652
|
0 |
0 |
if $rv |
|
1659
|
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 |