Changeset 24313
- Timestamp:
- Jun 3, 2009, 10:54:16 AM (17 years ago)
- File:
-
- 1 edited
-
trunk/Nebulous-Server/lib/Nebulous/Server.pm (modified) (64 diffs)
Legend:
- Unmodified
- Added
- Removed
-
trunk/Nebulous-Server/lib/Nebulous/Server.pm
r24311 r24313 53 53 my $log = Log::Log4perl::get_logger( "Nebulous::Server" ); 54 54 $log->level($config->trace); 55 $log->debug( "entered - @_" ); 55 56 56 57 my $sql = Nebulous::Server::SQL->new; 57 58 $log->debug( "entered - @_" );59 58 60 59 my $self = bless {}, ref $class || $class; … … 74 73 my ($self, $key) = @_; 75 74 75 my $log = $self->log; 76 $log->debug( "entered - @_" ); 77 76 78 my $config = $self->config; 77 79 … … 87 89 $db_index = unpack("h8", sha1_hex($path)) % $config->n_db; 88 90 91 $log->debug("index is $db_index"); 92 $log->debug("leaving"); 93 89 94 return $db_index; 90 95 } … … 95 100 96 101 my $log = $self->log; 102 $log->debug( "entered - @_" ); 103 97 104 my $sql = $self->sql; 98 105 my $config = $self->config; … … 143 150 $self->{dbs}[$db_index] = $dbh; 144 151 152 $log->debug("leaving"); 153 145 154 return $dbh; 146 155 } … … 164 173 165 174 my $dbh = $self->_db_for_index($db_index); 175 166 176 return $dbh; 167 177 } … … 170 180 { 171 181 my $self = shift; 182 183 my $log = $self->log; 184 $log->debug( "entered - @_" ); 172 185 173 186 my ($key, $vol_name) = validate_pos(@_, … … 188 201 ); 189 202 190 my $log = $self->log;191 203 my $sql = $self->sql; 192 204 … … 199 211 200 212 my $db = $self->db($key); 201 202 $log->debug( "entered - @_" );203 213 204 214 # the key's volume can't be validiated on input for this method so we have … … 307 317 my $self = shift; 308 318 319 my $log = $self->log; 320 $log->debug( "entered - @_" ); 321 309 322 my %p = validate(@_, 310 323 { … … 328 341 my $key = $p{key}; 329 342 330 my $log = $self->log;331 343 my $sql = $self->sql; 332 344 my $db = $self->db($key); 333 334 $log->debug( "entered - @_" );335 345 336 346 # no path means '/', which has a dir_id & parent_id of 1 … … 428 438 my $self = shift; 429 439 440 my $log = $self->log; 441 $log->debug("entered - @_"); 442 430 443 my ($key, $newkey) = validate_pos(@_, 431 444 { … … 444 457 ); 445 458 446 my $log = $self->log;447 459 my $sql = $self->sql; 448 460 … … 458 470 459 471 my $db = $self->db($key); 460 461 $log->debug("entered - @_");462 472 463 473 # XXX this may require database migration in the future … … 504 514 my $self = shift; 505 515 516 my $log = $self->log; 517 $log->debug("entered - @_"); 518 506 519 my ($key1, $key2) = validate_pos(@_, 507 520 { … … 519 532 ); 520 533 521 my $log = $self->log;522 534 my $sql = $self->sql; 523 535 … … 539 551 my $dbh2 = $self->_db_for_index($dbidx2); 540 552 die "different db handles for the same db?" unless ($dbh1 == $dbh2); 541 542 $log->debug("entered - @_");543 553 544 554 # order of operations for the swap with a single db is: … … 631 641 my $self = shift; 632 642 643 my $log = $self->log; 644 $log->debug("entered - @_"); 645 633 646 my ($key, $vol_name) = validate_pos(@_, 634 647 { … … 652 665 ); 653 666 654 my $log = $self->log;655 667 my $sql = $self->sql; 656 668 … … 671 683 672 684 my $db = $self->db($key); 673 674 $log->debug("entered - @_");675 685 676 686 if (defined $vol_name … … 785 795 my $self = shift; 786 796 797 my $log = $self->log; 798 $log->debug( "entered - @_" ); 799 787 800 my ( $key, $type ) = validate_pos( @_, 788 801 { … … 800 813 ); 801 814 802 my $log = $self->log;803 815 my $sql = $self->sql; 804 816 … … 810 822 811 823 my $db = $self->db($key); 812 813 $log->debug( "entered - @_" );814 824 815 825 my $so_id; … … 899 909 my $self = shift; 900 910 911 my $log = $self->log; 912 $log->debug( "entered - @_" ); 913 901 914 my ( $key, $type ) = validate_pos( @_, 902 915 { … … 914 927 ); 915 928 916 my $log = $self->log;917 929 my $sql = $self->sql; 918 930 … … 924 936 925 937 my $db = $self->db($key); 926 927 $log->debug( "entered - @_" );928 938 929 939 my $so_id; … … 1016 1026 my $self = shift; 1017 1027 1028 my $log = $self->log; 1029 $log->debug("entered - @_"); 1030 1018 1031 my ($key, $name, $value, $flags) = validate_pos(@_, 1019 1032 { … … 1041 1054 ); 1042 1055 1043 my $log = $self->log;1044 1056 my $sql = $self->sql; 1045 1057 … … 1051 1063 1052 1064 my $db = $self->db($key); 1053 1054 $log->debug("entered - @_");1055 1065 1056 1066 TRANS: while (1) { … … 1107 1117 my $self = shift; 1108 1118 1119 my $log = $self->log; 1120 $log->debug("entered - @_"); 1121 1109 1122 my ($key, $name) = validate_pos(@_, 1110 1123 { … … 1123 1136 ); 1124 1137 1125 my $log = $self->log;1126 1138 my $sql = $self->sql; 1127 1139 … … 1133 1145 1134 1146 my $db = $self->db($key); 1135 1136 $log->debug("entered - @_");1137 1147 1138 1148 my $value; … … 1171 1181 my $self = shift; 1172 1182 1183 my $log = $self->log; 1184 $log->debug("entered - @_"); 1185 1173 1186 my ($key) = validate_pos(@_, 1174 1187 { … … 1180 1193 ); 1181 1194 1182 my $log = $self->log;1183 1195 my $sql = $self->sql; 1184 1196 … … 1190 1202 1191 1203 my $db = $self->db($key); 1192 1193 $log->debug("entered - @_");1194 1204 1195 1205 my @xattrs; … … 1215 1225 my $self = shift; 1216 1226 1227 my $log = $self->log; 1228 $log->debug("entered - @_"); 1229 1217 1230 my ($key, $name) = validate_pos(@_, 1218 1231 { … … 1231 1244 ); 1232 1245 1233 my $log = $self->log;1234 1246 my $sql = $self->sql; 1235 1247 … … 1241 1253 1242 1254 my $db = $self->db($key); 1243 1244 $log->debug("entered - @_");1245 1255 1246 1256 TRANS: while (1) { … … 1286 1296 my $self = shift; 1287 1297 1298 my $log = $self->log; 1299 $log->debug( "entered - @_" ); 1300 1288 1301 my ($pattern) = validate_pos( @_, 1289 1302 { … … 1293 1306 ); 1294 1307 1295 my $log = $self->log;1296 1308 1297 1309 eval { … … 1299 1311 }; 1300 1312 $log->logdie("$@") if $@; 1301 1302 $log->debug( "entered - @_" );1303 1313 1304 1314 unless (defined $pattern) { … … 1325 1335 1326 1336 my $self = shift; 1337 1338 my $log = $self->log; 1339 $log->debug( "entered - @_" ); 1340 1327 1341 my $index = shift; 1328 1342 my $key = shift; 1329 1343 1330 my $log = $self->log;1331 1344 my $sql = $self->sql; 1332 1345 my $db = $self->_db_for_index($index); 1333 1346 1334 $log->debug( "entered - @_" );1335 1347 1336 1348 # first check to see if the key is an exact match … … 1390 1402 my $self = shift; 1391 1403 1404 my $log = $self->log; 1405 $log->debug("entered - @_"); 1406 1392 1407 my ($key, $vol_name) = validate_pos(@_, 1393 1408 { … … 1410 1425 ); 1411 1426 1412 my $log = $self->log;1413 1427 my $sql = $self->sql; 1414 1428 … … 1421 1435 1422 1436 my $db = $self->db($key); 1423 1424 $log->debug("entered - @_");1425 1437 1426 1438 # the key's volume can't be validiated on input for this method so we have … … 1487 1499 my $self = shift; 1488 1500 1501 my $log = $self->log; 1502 $log->debug( "entered - @_" ); 1503 1489 1504 my ($key, $uri) = validate_pos( @_, 1490 1505 { … … 1499 1514 ); 1500 1515 1501 my $log = $self->log;1502 1516 my $sql = $self->sql; 1503 1517 … … 1509 1523 1510 1524 my $db = $self->db($key); 1511 1512 $log->debug( "entered - @_" );1513 1525 1514 1526 TRANS: while (1) { … … 1591 1603 my $self = shift; 1592 1604 1605 my $log = $self->log; 1606 $log->debug("entered - @_"); 1607 1593 1608 my ( $key ) = validate_pos( @_, 1594 1609 { … … 1600 1615 ); 1601 1616 1602 my $log = $self->log;1603 1617 my $sql = $self->sql; 1604 1618 … … 1610 1624 1611 1625 my $db = $self->db($key); 1612 1613 $log->debug("entered - @_");1614 1626 1615 1627 my $stat; … … 1640 1652 my $self = shift; 1641 1653 1654 my $log = $self->log; 1655 $log->debug("entered - @_"); 1656 1642 1657 validate_pos(@_); 1643 1658 1644 my $log = $self->log;1645 1659 my $sql = $self->sql; 1646 1660 my $db = $self->_db_for_index(0); # XXX fix as above 1647 1648 $log->debug("entered - @_");1649 1661 1650 1662 my $stats; … … 1671 1683 { 1672 1684 my $self = shift; 1685 1686 my $log = $self->log; 1687 $log->debug("entered - @_"); 1673 1688 1674 1689 my ($key, $mode) = validate_pos( @_, … … 1690 1705 ); 1691 1706 1692 my $log = $self->log;1693 1707 my $sql = $self->sql; 1694 1708 … … 1700 1714 1701 1715 my $db = $self->db($key); 1702 1703 $log->debug("entered - @_");1704 1716 1705 1717 # find all instances of this object … … 1744 1756 my $self = shift; 1745 1757 1746 my ($key, $name, $soft_volume) = @_; 1747 1748 my $log = $self->log; 1749 my $sql = $self->sql; 1750 my $db = $self->db($key); 1751 1758 my $log = $self->log; 1752 1759 no warnings qw( uninitialized ); 1753 1760 $log->debug( "entered - @_" ); 1754 1761 use warnings; 1762 1763 my ($key, $name, $soft_volume) = @_; 1764 1765 my $sql = $self->sql; 1766 my $db = $self->db($key); 1755 1767 1756 1768 my ($vol_id, $vol_host, $vol_path, $xattr); … … 1809 1821 my $self = shift; 1810 1822 1811 my $key = shift; 1812 1813 my $log = $self->log; 1814 my $sql = $self->sql; 1815 my $db = $self->db($key); 1816 1823 my $log = $self->log; 1817 1824 no warnings qw( uninitialized ); 1818 1825 $log->debug( "entered - @_" ); 1819 1826 use warnings; 1827 1828 my $key = shift; 1829 1830 my $sql = $self->sql; 1831 my $db = $self->db($key); 1820 1832 1821 1833 my ($vol_id, $vol_host, $vol_path, $xattr); … … 1856 1868 1857 1869 my $log = $self->log; 1870 $log->debug( "entered - @_" ); 1871 1858 1872 my $sql = $self->sql; 1859 1873 … … 1879 1893 1880 1894 if (defined $ext_id) { 1895 $log->debug( "key is valid" ); 1896 $log->debug( "leaving" ); 1881 1897 return 1; 1882 1898 } 1883 1899 1900 $log->debug( "key not found" ); 1901 $log->debug( "leaving" ); 1902 1884 1903 return; 1885 1904 } … … 1891 1910 1892 1911 my $log = $self->log; 1912 $log->debug( "entered - @_" ); 1913 1893 1914 my $sql = $self->sql; 1894 1915 … … 1905 1926 # handle "any" volume 1906 1927 if ($vol_name eq 'any') { 1928 $log->debug( "found volume name $vol_name" ); 1929 $log->debug( "leaving" ); 1907 1930 return 1; 1908 1931 } … … 1919 1942 1920 1943 if (defined $vol_id and defined $vol_path) { 1944 $log->debug( "found volume name $vol_name" ); 1945 $log->debug( "leaving" ); 1921 1946 return 1; 1922 1947 } 1923 1948 1949 $log->debug( "volume name $vol_name not found" ); 1950 $log->debug( "leaving" ); 1951 1924 1952 return; 1925 1953 } … … 1930 1958 my $self = shift; 1931 1959 1960 my $log = $self->log; 1961 $log->debug( "entered - @_" ); 1962 1932 1963 my ($key, $so_id, $ins_id, $vol_path, $xattr) = @_; 1933 1964 1934 my $log = $self->log;1935 1965 my $sql = $self->sql; 1936 1966 my $db = $self->db($key); … … 1974 2004 { 1975 2005 my $self = shift; 2006 2007 my $log = $self->log; 2008 $log->debug( "entered - @_" ); 1976 2009 1977 2010 my ($path) = @_;
Note:
See TracChangeset
for help on using the changeset viewer.
