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