Searched refs:retry_server_stream (Results 1 – 3 of 3) sorted by relevance
1669 mongoc_server_stream_t *retry_server_stream = NULL; in _mongoc_client_retryable_write_command_with_stream() local1708 if (retry_server_stream) { in _mongoc_client_retryable_write_command_with_stream()1715 if (retry_server_stream && in _mongoc_client_retryable_write_command_with_stream()1716 retry_server_stream->sd->max_wire_version >= in _mongoc_client_retryable_write_command_with_stream()1724 if (retry_server_stream) { in _mongoc_client_retryable_write_command_with_stream()1745 mongoc_server_stream_t *retry_server_stream = NULL; in _mongoc_client_retryable_read_command_with_stream() local1774 if (retry_server_stream) { in _mongoc_client_retryable_read_command_with_stream()1778 retry_server_stream = in _mongoc_client_retryable_read_command_with_stream()1785 if (retry_server_stream && in _mongoc_client_retryable_read_command_with_stream()1786 retry_server_stream->sd->max_wire_version >= in _mongoc_client_retryable_read_command_with_stream()[all …]
460 mongoc_server_stream_t *retry_server_stream = NULL; in _mongoc_write_opmsg() local610 if (retry_server_stream) { in _mongoc_write_opmsg()611 mongoc_server_stream_cleanup (retry_server_stream); in _mongoc_write_opmsg()614 retry_server_stream = mongoc_cluster_stream_for_writes ( in _mongoc_write_opmsg()617 if (retry_server_stream && in _mongoc_write_opmsg()618 retry_server_stream->sd->max_wire_version >= in _mongoc_write_opmsg()620 parts.assembled.server_stream = retry_server_stream; in _mongoc_write_opmsg()651 if (retry_server_stream) { in _mongoc_write_opmsg()656 mongoc_server_description_id (retry_server_stream->sd); in _mongoc_write_opmsg()658 mongoc_server_stream_cleanup (retry_server_stream); in _mongoc_write_opmsg()
3189 mongoc_server_stream_t *retry_server_stream = NULL; in mongoc_collection_find_and_modify_with_opts() local3377 retry_server_stream = mongoc_cluster_stream_for_writes ( in mongoc_collection_find_and_modify_with_opts()3380 if (retry_server_stream && in mongoc_collection_find_and_modify_with_opts()3381 retry_server_stream->sd->max_wire_version >= in mongoc_collection_find_and_modify_with_opts()3383 parts.assembled.server_stream = retry_server_stream; in mongoc_collection_find_and_modify_with_opts()3412 mongoc_server_stream_cleanup (retry_server_stream); in mongoc_collection_find_and_modify_with_opts()