| /dports/databases/p5-MongoDB/MongoDB-v2.2.2/lib/MongoDB/ |
| H A D | _Protocol.pm | 388 my ($len, $request_id, $response_to, $op_code)
395 0, $request_id, $response_to, OP_COMPRESSED,
410 my ($len, $request_id, $response_to, $op_code, $orig_op_code, $orig_len, $comp_id)
423 pack(P_HEADER, $orig_len, $request_id, $response_to, $orig_op_code)
645 $len, $msg_id, $response_to, $opcode, $bitflags, $cursor_id, $starting_from,
662 if ( $response_to != $request_id ) {
664 "response ID ($response_to) did not match request ID ($request_id)");
669 || ( $response_to != $request_id );
687 $len, $msg_id, $response_to, $opcode, $bitflags, $cursor_id, $starting_from,
|
| /dports/devel/mongo-c-driver/mongo-c-driver-1.8.1/tests/ |
| H A D | test-mongoc-rpc.c | 114 rpc.header.response_to = -1; in test_mongoc_rpc_delete_gather()
166 rpc.header.response_to = -1; in test_mongoc_rpc_get_more_gather()
194 ASSERT (rpc.header.response_to == -1); in test_mongoc_rpc_get_more_scatter()
225 rpc.header.response_to = -1; in test_mongoc_rpc_insert_gather()
293 rpc.header.response_to = -1; in test_mongoc_rpc_kill_cursors_gather()
341 rpc.header.response_to = -1; in test_mongoc_rpc_msg_gather()
366 ASSERT (rpc.header.response_to == -1); in test_mongoc_rpc_msg_scatter()
387 rpc.header.response_to = -1; in test_mongoc_rpc_query_gather()
454 rpc.header.response_to = -1; in test_mongoc_rpc_reply_gather()
575 rpc.header.response_to = -1; in test_mongoc_rpc_update_gather()
[all …]
|
| /dports/databases/pecl-mongodb/mongodb-1.9.1/src/libmongoc/src/libmongoc/src/mongoc/ |
| H A D | mongoc-cursor-legacy.c | 145 rpc.header.response_to = 0; in _mongoc_cursor_op_getmore()
189 if (response->rpc.header.response_to != request_id) { in _mongoc_cursor_op_getmore()
195 response->rpc.header.response_to); in _mongoc_cursor_op_getmore()
497 rpc.header.response_to = 0; in _mongoc_cursor_op_query_find()
554 if (response->rpc.header.response_to != request_id) { in _mongoc_cursor_op_query_find()
560 response->rpc.header.response_to); in _mongoc_cursor_op_query_find()
|
| H A D | op-header.def | 5 INT32_FIELD(response_to)
|
| H A D | op-msg.def | 5 INT32_FIELD(response_to)
|
| H A D | op-kill-cursors.def | 5 INT32_FIELD(response_to)
|
| H A D | op-insert.def | 5 INT32_FIELD(response_to)
|
| H A D | op-compressed.def | 5 INT32_FIELD(response_to)
|
| H A D | op-delete.def | 5 INT32_FIELD(response_to)
|
| H A D | op-reply-header.def | 5 INT32_FIELD(response_to)
|
| H A D | op-get-more.def | 5 INT32_FIELD(response_to)
|
| H A D | op-reply.def | 5 INT32_FIELD(response_to)
|
| H A D | op-update.def | 5 INT32_FIELD(response_to)
|
| H A D | op-query.def | 5 INT32_FIELD(response_to)
|
| /dports/databases/pymongo/pymongo-3.12.0/pymongo/ |
| H A D | network.py | 195 length, _, response_to, op_code = _UNPACK_HEADER(
199 if request_id != response_to:
201 "%r" % (response_to, request_id))
|
| /dports/devel/mongo-c-driver/mongo-c-driver-1.8.1/src/mongoc/ |
| H A D | op-header.def | 5 INT32_FIELD(response_to)
|
| H A D | op-msg.def | 5 INT32_FIELD(response_to)
|
| H A D | op-kill-cursors.def | 5 INT32_FIELD(response_to)
|
| H A D | op-insert.def | 5 INT32_FIELD(response_to)
|
| H A D | op-delete.def | 5 INT32_FIELD(response_to)
|
| H A D | op-reply-header.def | 5 INT32_FIELD(response_to)
|
| H A D | op-compressed.def | 5 INT32_FIELD(response_to)
|
| H A D | op-get-more.def | 5 INT32_FIELD(response_to)
|
| H A D | op-update.def | 5 INT32_FIELD(response_to)
|
| H A D | op-reply.def | 5 INT32_FIELD(response_to)
|