@@ -101,8 +101,8 @@ test_get_max_msg_size (void)
101
101
char *error_message = bson_strdup_printf ( \
102
102
"Failed to read 4 bytes from socket within %d milliseconds.", \
103
103
socket_timeout_ms); \
104
- BSON_ASSERT (!future_get_bool (future)); \
105
- BSON_ASSERT (mongoc_cursor_error (cursor, &error)); \
104
+ assert (!future_get_bool (future)); \
105
+ assert (mongoc_cursor_error (cursor, &error)); \
106
106
ASSERT_CMPINT (error.domain, ==, MONGOC_ERROR_STREAM); \
107
107
ASSERT_CMPINT (error.code, ==, MONGOC_ERROR_STREAM_SOCKET); \
108
108
ASSERT_CMPSTR (error.message, error_message); \
@@ -112,14 +112,13 @@ test_get_max_msg_size (void)
112
112
113
113
#define START_QUERY (client_port_variable ) do { \
114
114
cursor = mongoc_collection_find (collection, \
115
- MONGOC_QUERY_NONE, \
116
- 0, 0, 0, tmp_bson ("{}"), \
117
- NULL, NULL); \
115
+ MONGOC_QUERY_NONE, \
116
+ 0, 0, 0, tmp_bson ("{}"), \
117
+ NULL, NULL); \
118
118
future = future_cursor_next (cursor, &doc); \
119
119
request = mock_server_receives_query (server, "test.test", \
120
- MONGOC_QUERY_SLAVE_OK, 0, 0, \
121
- "{}", NULL); \
122
- BSON_ASSERT (request); \
120
+ MONGOC_QUERY_SLAVE_OK, 0, 0, \
121
+ "{}", NULL); \
123
122
client_port_variable = request_get_client_port (request); \
124
123
} while (0)
125
124
0 commit comments