/dports/databases/pecl-mongodb/mongodb-1.9.1/src/MongoDB/ |
H A D | Command.c | 38 int64_t max_await_time_ms; in php_phongo_command_init_max_await_time_ms() local 44 max_await_time_ms = php_array_fetchc_long(options, "maxAwaitTimeMS"); in php_phongo_command_init_max_await_time_ms() 46 if (max_await_time_ms < 0) { in php_phongo_command_init_max_await_time_ms() 47 …D_ARGUMENT, "Expected \"maxAwaitTimeMS\" option to be >= 0, %" PRId64 " given", max_await_time_ms); in php_phongo_command_init_max_await_time_ms() 51 if (max_await_time_ms > UINT32_MAX) { in php_phongo_command_init_max_await_time_ms() 52 …\"maxAwaitTimeMS\" option to be <= %" PRIu32 ", %" PRId64 " given", UINT32_MAX, max_await_time_ms); in php_phongo_command_init_max_await_time_ms() 56 intern->max_await_time_ms = (uint32_t) max_await_time_ms; in php_phongo_command_init_max_await_time_ms() 71 intern->max_await_time_ms = 0; in php_phongo_command_init()
|
H A D | Query.c | 231 int64_t max_await_time_ms; in php_phongo_query_init_max_await_time_ms() local 237 max_await_time_ms = php_array_fetchc_long(options, "maxAwaitTimeMS"); in php_phongo_query_init_max_await_time_ms() 239 if (max_await_time_ms < 0) { in php_phongo_query_init_max_await_time_ms() 240 …D_ARGUMENT, "Expected \"maxAwaitTimeMS\" option to be >= 0, %" PRId64 " given", max_await_time_ms); in php_phongo_query_init_max_await_time_ms() 244 if (max_await_time_ms > UINT32_MAX) { in php_phongo_query_init_max_await_time_ms() 245 …\"maxAwaitTimeMS\" option to be <= %" PRIu32 ", %" PRId64 " given", UINT32_MAX, max_await_time_ms); in php_phongo_query_init_max_await_time_ms() 249 intern->max_await_time_ms = (uint32_t) max_await_time_ms; in php_phongo_query_init_max_await_time_ms() 263 intern->max_await_time_ms = 0; in php_phongo_query_init()
|
/dports/devel/mongo-c-driver/mongo-c-driver-1.8.1/doc/ |
H A D | mongoc_cursor_set_max_await_time_ms.rst | 13 uint32_t max_await_time_ms); 19 * ``max_await_time_ms``: A timeout in milliseconds. 26 The ``max_await_time_ms`` cannot be changed after the first call to :symbol:`mongoc_cursor_next`.
|
/dports/databases/pymongo/pymongo-3.12.0/pymongo/ |
H A D | command_cursor.py | 36 batch_size=0, max_await_time_ms=None, session=None, argument 49 self.__max_await_time_ms = max_await_time_ms 63 if (not isinstance(max_await_time_ms, integer_types) 64 and max_await_time_ms is not None): 303 batch_size=0, max_await_time_ms=None, session=None, argument 316 max_await_time_ms, session, explicit_session)
|
H A D | change_stream.py | 70 max_await_time_ms, batch_size, collation, argument 98 self._max_await_time_ms = max_await_time_ms
|
H A D | cursor.py | 588 def max_await_time_ms(self, max_await_time_ms): member in Cursor 605 if (not isinstance(max_await_time_ms, integer_types) 606 and max_await_time_ms is not None): 612 self.__max_await_time_ms = max_await_time_ms
|
H A D | message.py | 226 def _gen_get_more_command(cursor_id, coll, batch_size, max_await_time_ms): argument 232 if max_await_time_ms is not None: 233 cmd['maxTimeMS'] = max_await_time_ms 387 read_preference, session, client, max_await_time_ms, argument 397 self.max_await_time_ms = max_await_time_ms 424 self.max_await_time_ms)
|
H A D | aggregation.py | 168 max_await_time_ms=self._max_await_time_ms,
|
H A D | database.py | 532 max_await_time_ms=None, batch_size=None, collation=None, argument 619 self, pipeline, full_document, resume_after, max_await_time_ms,
|
H A D | mongo_client.py | 895 max_await_time_ms=None, batch_size=None, collation=None, argument 982 self.admin, pipeline, full_document, resume_after, max_await_time_ms,
|
/dports/devel/mongo-c-driver/mongo-c-driver-1.8.1/src/mongoc/ |
H A D | mongoc-cursor-cursorid.c | 187 int32_t max_await_time_ms; in _mongoc_cursor_prepare_getmore_command() local 219 max_await_time_ms = in _mongoc_cursor_prepare_getmore_command() 221 if (max_await_time_ms) { in _mongoc_cursor_prepare_getmore_command() 225 max_await_time_ms); in _mongoc_cursor_prepare_getmore_command()
|
H A D | mongoc-cursor.h | 77 uint32_t max_await_time_ms);
|
H A D | mongoc-cursor.c | 2112 uint32_t max_await_time_ms) in mongoc_cursor_set_max_await_time_ms() argument 2118 cursor, MONGOC_CURSOR_MAX_AWAIT_TIME_MS, (int64_t) max_await_time_ms); in mongoc_cursor_set_max_await_time_ms()
|
/dports/databases/pecl-mongodb/mongodb-1.9.1/ |
H A D | php_phongo_structs.h | 43 uint32_t max_await_time_ms; member 82 uint32_t max_await_time_ms; member
|
H A D | php_phongo.c | 880 if (query->max_await_time_ms) { in phongo_execute_query() 881 mongoc_cursor_set_max_await_time_ms(cursor, query->max_await_time_ms); in phongo_execute_query() 1042 if (command->max_await_time_ms) { in phongo_execute_command() 1044 bson_append_int64(&cursor_opts, "maxAwaitTimeMS", -1, command->max_await_time_ms); in phongo_execute_command()
|
/dports/databases/pecl-mongodb/mongodb-1.9.1/src/libmongoc/src/libmongoc/src/mongoc/ |
H A D | mongoc-change-stream.c | 321 if (stream->max_await_time_ms > 0) { in _make_cursor() 325 stream->max_await_time_ms); in _make_cursor() 392 stream->max_await_time_ms = -1; in _change_stream_init() 409 stream->max_await_time_ms = stream->opts.maxAwaitTimeMS; in _change_stream_init()
|
H A D | mongoc-change-stream-private.h | 55 int64_t max_await_time_ms; member
|
H A D | mongoc-cursor.h | 76 uint32_t max_await_time_ms);
|
H A D | mongoc-cursor.c | 1519 uint32_t max_await_time_ms) in mongoc_cursor_set_max_await_time_ms() argument 1525 cursor, MONGOC_CURSOR_MAX_AWAIT_TIME_MS, (int64_t) max_await_time_ms); in mongoc_cursor_set_max_await_time_ms() 1695 int64_t max_await_time_ms; in _mongoc_cursor_prepare_getmore_command() local 1726 max_await_time_ms = _mongoc_cursor_get_opt_int64 ( in _mongoc_cursor_prepare_getmore_command() 1728 if (max_await_time_ms) { in _mongoc_cursor_prepare_getmore_command() 1732 max_await_time_ms); in _mongoc_cursor_prepare_getmore_command()
|
/dports/databases/pymongo/pymongo-3.12.0/test/ |
H A D | test_change_stream.py | 129 max_await_time_ms=1000, batch_size=100) as change_stream: 157 with self.change_stream(max_await_time_ms=250) as stream: 181 client, max_await_time_ms=250) as stream: 238 client, max_await_time_ms=250, batch_size=23) as stream: 319 with self.change_stream(max_await_time_ms=250) as change_stream: 331 with self.change_stream(max_await_time_ms=250) as change_stream: 418 max_await_time_ms=250) as change_stream: 438 max_await_time_ms=250) as change_stream:
|
H A D | test_cursor.py | 215 self.assertRaises(TypeError, coll.find().max_await_time_ms, 'foo') 219 coll.find().max_await_time_ms(None) 220 coll.find().max_await_time_ms(long(1)) 225 cursor = coll.find().max_await_time_ms(99) 234 cursor_type=CursorType.TAILABLE_AWAIT).max_await_time_ms(99) 238 cursor_type=CursorType.TAILABLE_AWAIT).max_await_time_ms( 239 10).max_await_time_ms(90) 257 cursor_type=CursorType.TAILABLE_AWAIT).max_await_time_ms(99)) 282 99).max_await_time_ms(99)) 294 list(coll.find(batch_size=1).max_await_time_ms(99)) [all …]
|
/dports/databases/p5-MongoDB/MongoDB-v2.2.2/lib/MongoDB/ |
H A D | Cursor.pm | 208 sub max_await_time_ms { subroutine
|
H A D | Database.pm | 569 ? (max_await_time_ms => delete $options->{maxAwaitTimeMS})
|
/dports/databases/py-motor/motor-1.0/motor/ |
H A D | motor_gridfs.py | 54 max_await_time_ms = MotorCursorChainingMethod() variable in AgnosticGridOutCursor
|
/dports/databases/p5-MongoDB/MongoDB-v2.2.2/t/ |
H A D | cursor.t | 367 ->max_await_time_ms(2000);
|