kakserpom /
phpdaemon
| @@ 400-406 (lines=7) @@ | ||
| 397 | . bson_encode($o) . (isset($p['fields']) ? bson_encode($p['fields']) : ''), |
|
| 398 | true, |
|
| 399 | null, |
|
| 400 | function ($conn, $reqId = null) use ($p, $cb) { |
|
| 401 | if (!$conn) { |
|
| 402 | !$cb || $cb(['$err' => 'Connection error.']); |
|
| 403 | return; |
|
| 404 | } |
|
| 405 | $conn->requests[$reqId] = [$p['col'], $cb, true]; |
|
| 406 | } |
|
| 407 | ); |
|
| 408 | } catch (\MongoException $e) { |
|
| 409 | Daemon::log('MongoClient exception: ' . $e->getMessage() . ': ' . $e->getTraceAsString()); |
|
| @@ 481-487 (lines=7) @@ | ||
| 478 | . bson_encode($query) . (isset($p['fields']) ? bson_encode($p['fields']) : ''), |
|
| 479 | true, |
|
| 480 | null, |
|
| 481 | function ($conn, $reqId = null) use ($p, $cb) { |
|
| 482 | if (!$conn) { |
|
| 483 | !$cb || $cb(['$err' => 'Connection error.']); |
|
| 484 | return; |
|
| 485 | } |
|
| 486 | $conn->requests[$reqId] = [$p['col'], $cb, true]; |
|
| 487 | } |
|
| 488 | ); |
|
| 489 | } catch (\MongoException $e) { |
|
| 490 | Daemon::log('MongoClient exception: ' . $e->getMessage() . ': ' . $e->getTraceAsString()); |
|
| @@ 530-536 (lines=7) @@ | ||
| 527 | . bson_encode($query) . (isset($p['fields']) ? bson_encode($p['fields']) : ''), |
|
| 528 | true, |
|
| 529 | null, |
|
| 530 | function ($conn, $reqId = null) use ($p, $cb) { |
|
| 531 | if (!$conn) { |
|
| 532 | !$cb || $cb(['$err' => 'Connection error.']); |
|
| 533 | return; |
|
| 534 | } |
|
| 535 | $conn->requests[$reqId] = [$p['dbname'], $cb, true]; |
|
| 536 | } |
|
| 537 | ); |
|
| 538 | } catch (\MongoException $e) { |
|
| 539 | Daemon::log('MongoClient exception: ' . $e->getMessage() . ': ' . $e->getTraceAsString()); |
|
| @@ 575-581 (lines=7) @@ | ||
| 572 | . (isset($p['fields']) ? bson_encode($p['fields']) : ''), |
|
| 573 | true, |
|
| 574 | null, |
|
| 575 | function ($conn, $reqId = null) use ($p, $cb) { |
|
| 576 | if (!$conn) { |
|
| 577 | !$cb || $cb(['$err' => 'Connection error.']); |
|
| 578 | return; |
|
| 579 | } |
|
| 580 | $conn->requests[$reqId] = [$p['dbname'], $cb, true]; |
|
| 581 | } |
|
| 582 | ); |
|
| 583 | } catch (\MongoException $e) { |
|
| 584 | Daemon::log('MongoClient exception: ' . $e->getMessage() . ': ' . $e->getTraceAsString()); |
|
| @@ 667-673 (lines=7) @@ | ||
| 664 | . pack('VV', 0, -1) . bson_encode($params), |
|
| 665 | true, |
|
| 666 | $conn, |
|
| 667 | function ($conn, $reqId = null) use ($db, $cb) { |
|
| 668 | if (!$conn) { |
|
| 669 | !$cb || $cb(['$err' => 'Connection error.']); |
|
| 670 | return; |
|
| 671 | } |
|
| 672 | $conn->requests[$reqId] = [$db, $cb, true]; |
|
| 673 | } |
|
| 674 | ); |
|
| 675 | } catch (\MongoException $e) { |
|
| 676 | Daemon::log('MongoClient exception: ' . $e->getMessage() . ': ' . $e->getTraceAsString()); |
|
| @@ 752-758 (lines=7) @@ | ||
| 749 | . (isset($p['fields']) ? bson_encode($p['fields']) : ''), |
|
| 750 | true, |
|
| 751 | null, |
|
| 752 | function ($conn, $reqId = null) use ($p, $cb) { |
|
| 753 | if (!$conn) { |
|
| 754 | !$cb || $cb(['$err' => 'Connection error.']); |
|
| 755 | return; |
|
| 756 | } |
|
| 757 | $conn->requests[$reqId] = [$p['col'], $cb, true]; |
|
| 758 | } |
|
| 759 | ); |
|
| 760 | } catch (\MongoException $e) { |
|
| 761 | Daemon::log('MongoClient exception: ' . $e->getMessage() . ': ' . $e->getTraceAsString()); |
|
| @@ 808-814 (lines=7) @@ | ||
| 805 | . (isset($p['fields']) ? bson_encode($p['fields']) : ''), |
|
| 806 | true, |
|
| 807 | null, |
|
| 808 | function ($conn, $reqId = null) use ($p, $cb) { |
|
| 809 | if (!$conn) { |
|
| 810 | !$cb || $cb(['$err' => 'Connection error.']); |
|
| 811 | return; |
|
| 812 | } |
|
| 813 | $conn->requests[$reqId] = [$p['db'], $cb, true]; |
|
| 814 | } |
|
| 815 | ); |
|
| 816 | } catch (\MongoException $e) { |
|
| 817 | Daemon::log('MongoClient exception: ' . $e->getMessage() . ': ' . $e->getTraceAsString()); |
|
| @@ 864-870 (lines=7) @@ | ||
| 861 | . (isset($p['fields']) ? bson_encode($p['fields']) : ''), |
|
| 862 | true, |
|
| 863 | null, |
|
| 864 | function ($conn, $reqId = null) use ($p, $cb) { |
|
| 865 | if (!$conn) { |
|
| 866 | !$cb || $cb(['$err' => 'Connection error.']); |
|
| 867 | return; |
|
| 868 | } |
|
| 869 | $conn->requests[$reqId] = [$p['col'], $cb, true]; |
|
| 870 | } |
|
| 871 | ); |
|
| 872 | } |
|
| 873 | ||
| @@ 998-1004 (lines=7) @@ | ||
| 995 | . (isset($p['fields']) ? bson_encode($p['fields']) : ''), |
|
| 996 | true, |
|
| 997 | null, |
|
| 998 | function ($conn, $reqId = null) use ($p, $cb) { |
|
| 999 | if (!$conn) { |
|
| 1000 | !$cb || $cb(['$err' => 'Connection error.']); |
|
| 1001 | return; |
|
| 1002 | } |
|
| 1003 | $conn->requests[$reqId] = [$p['col'], $cb, true]; |
|
| 1004 | } |
|
| 1005 | ); |
|
| 1006 | } catch (\MongoException $e) { |
|
| 1007 | Daemon::log('MongoClient exception: ' . $e->getMessage() . ': ' . $e->getTraceAsString()); |
|
| @@ 1074-1080 (lines=7) @@ | ||
| 1071 | . (isset($p['fields']) ? bson_encode($p['fields']) : ''), |
|
| 1072 | true, |
|
| 1073 | null, |
|
| 1074 | function ($conn, $reqId = null) use ($p, $cb) { |
|
| 1075 | if (!$conn) { |
|
| 1076 | !$cb || $cb(['$err' => 'Connection error.']); |
|
| 1077 | return; |
|
| 1078 | } |
|
| 1079 | $conn->requests[$reqId] = [$p['col'], $cb, false]; |
|
| 1080 | } |
|
| 1081 | ); |
|
| 1082 | } catch (\MongoException $e) { |
|
| 1083 | Daemon::log('MongoClient exception: ' . $e->getMessage() . ': ' . $e->getTraceAsString()); |
|
| @@ 1127-1133 (lines=7) @@ | ||
| 1124 | . bson_encode($query) . (isset($p['fields']) ? bson_encode($p['fields']) : ''), |
|
| 1125 | true, |
|
| 1126 | null, |
|
| 1127 | function ($conn, $reqId = null) use ($p, $cb) { |
|
| 1128 | if (!$conn) { |
|
| 1129 | !$cb || $cb(['$err' => 'Connection error.']); |
|
| 1130 | return; |
|
| 1131 | } |
|
| 1132 | $conn->requests[$reqId] = [$p['col'], $cb, false]; |
|
| 1133 | } |
|
| 1134 | ); |
|
| 1135 | } catch (\MongoException $e) { |
|
| 1136 | Daemon::log('MongoClient exception: ' . $e->getMessage() . ': ' . $e->getTraceAsString()); |
|
| @@ 1599-1605 (lines=7) @@ | ||
| 1596 | pack('V', 0) . $dbname . '.$cmd' . "\x00" . pack('VV', 0, -1) . bson_encode($query), |
|
| 1597 | true, |
|
| 1598 | $conn, |
|
| 1599 | function ($conn, $reqId = null) use ($dbname, $cb) { |
|
| 1600 | if (!$conn) { |
|
| 1601 | !$cb || $cb(['$err' => 'Connection error.']); |
|
| 1602 | return; |
|
| 1603 | } |
|
| 1604 | $conn->requests[$reqId] = [$dbname, $cb, true]; |
|
| 1605 | } |
|
| 1606 | ); |
|
| 1607 | } catch (\MongoException $e) { |
|
| 1608 | Daemon::log('MongoClient exception: ' . $e->getMessage() . ': ' . $e->getTraceAsString()); |
|
