kakserpom /
phpdaemon
| @@ 1177-1185 (lines=9) @@ | ||
| 1174 | "\x00\x00\x00\x00" . $col . "\x00" . pack('V', $flags) . bson_encode($cond) . bson_encode($data), |
|
| 1175 | false, |
|
| 1176 | null, |
|
| 1177 | function ($conn, $reqId = null) use ($cb, $col, $params) { |
|
| 1178 | if (!$conn) { |
|
| 1179 | !$cb || $cb(['$err' => 'Connection error.']); |
|
| 1180 | return; |
|
| 1181 | } |
|
| 1182 | if ($cb !== null) { |
|
| 1183 | $this->lastError($col, $cb, $params, $conn); |
|
| 1184 | } |
|
| 1185 | } |
|
| 1186 | ); |
|
| 1187 | } |
|
| 1188 | ||
| @@ 1407-1415 (lines=9) @@ | ||
| 1404 | "\x00\x00\x00\x00" . $col . "\x00" . "\x00\x00\x00\x00" . bson_encode($cond), |
|
| 1405 | false, |
|
| 1406 | null, |
|
| 1407 | function ($conn, $reqId = null) use ($col, $cb, $params) { |
|
| 1408 | if (!$conn) { |
|
| 1409 | !$cb || $cb(['$err' => 'Connection error.']); |
|
| 1410 | return; |
|
| 1411 | } |
|
| 1412 | if ($cb !== null) { |
|
| 1413 | $this->lastError($col, $cb, $params, $conn); |
|
| 1414 | } |
|
| 1415 | } |
|
| 1416 | ); |
|
| 1417 | } catch (\MongoException $e) { |
|
| 1418 | Daemon::log('MongoClient exception: ' . $e->getMessage() . ': ' . $e->getTraceAsString()); |
|
