Home
last modified time | relevance | path

Searched refs:max_await_time_ms (Results 1 – 25 of 30) sorted by relevance

12

/dports/databases/pecl-mongodb/mongodb-1.9.1/src/MongoDB/
H A DCommand.c38 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 DQuery.c231 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 Dmongoc_cursor_set_max_await_time_ms.rst13 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 Dcommand_cursor.py36 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 Dchange_stream.py70 max_await_time_ms, batch_size, collation, argument
98 self._max_await_time_ms = max_await_time_ms
H A Dcursor.py588 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 Dmessage.py226 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 Daggregation.py168 max_await_time_ms=self._max_await_time_ms,
H A Ddatabase.py532 max_await_time_ms=None, batch_size=None, collation=None, argument
619 self, pipeline, full_document, resume_after, max_await_time_ms,
H A Dmongo_client.py895 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 Dmongoc-cursor-cursorid.c187 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 Dmongoc-cursor.h77 uint32_t max_await_time_ms);
H A Dmongoc-cursor.c2112 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 Dphp_phongo_structs.h43 uint32_t max_await_time_ms; member
82 uint32_t max_await_time_ms; member
H A Dphp_phongo.c880 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 Dmongoc-change-stream.c321 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 Dmongoc-change-stream-private.h55 int64_t max_await_time_ms; member
H A Dmongoc-cursor.h76 uint32_t max_await_time_ms);
H A Dmongoc-cursor.c1519 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 Dtest_change_stream.py129 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 Dtest_cursor.py215 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 DCursor.pm208 sub max_await_time_ms { subroutine
H A DDatabase.pm569 ? (max_await_time_ms => delete $options->{maxAwaitTimeMS})
/dports/databases/py-motor/motor-1.0/motor/
H A Dmotor_gridfs.py54 max_await_time_ms = MotorCursorChainingMethod() variable in AgnosticGridOutCursor
/dports/databases/p5-MongoDB/MongoDB-v2.2.2/t/
H A Dcursor.t367 ->max_await_time_ms(2000);

12