Lines Matching refs:ASSERT
49 ASSERT(r == 0); in startup()
59 ASSERT(sock != INVALID_SOCKET); in create_tcp_socket()
61 ASSERT(sock >= 0); in create_tcp_socket()
69 ASSERT(r == 0); in create_tcp_socket()
84 ASSERT(r == 0); in close_socket()
92 ASSERT(suggested_size <= sizeof(slab)); in alloc_cb()
105 ASSERT(req == &shutdown_req); in shutdown_cb()
106 ASSERT(status == 0); in shutdown_cb()
117 ASSERT(nread == 4); in read_cb()
118 ASSERT(memcmp("PING", buf->base, nread) == 0); in read_cb()
121 ASSERT(nread == UV_EOF); in read_cb()
133 ASSERT(buf->base[i] == 'P'); in read1_cb()
135 ASSERT(nread == UV_EOF); in read1_cb()
147 ASSERT(0); in write_cb()
160 ASSERT(shutdown_cb_called); in write1_cb()
169 ASSERT(r == 0); in write1_cb()
180 ASSERT(r == 0); in timer_cb()
190 ASSERT(req == &connect_req); in connect_cb()
191 ASSERT(status == 0); in connect_cb()
197 ASSERT(r == 0); in connect_cb()
201 ASSERT(r == 0); in connect_cb()
205 ASSERT(r == 0); in connect_cb()
214 ASSERT(req == &connect_req); in connect1_cb()
215 ASSERT(status == 0); in connect1_cb()
221 ASSERT(r == 0); in connect1_cb()
224 ASSERT(r == 0); in connect1_cb()
228 ASSERT(r == 0); in connect1_cb()
232 ASSERT(r == 0); in connect1_cb()
242 ASSERT(0 == uv_ip4_addr("127.0.0.1", TEST_PORT, &addr)); in TEST_IMPL()
248 ASSERT(r == 0); in TEST_IMPL()
251 ASSERT(r == 0); in TEST_IMPL()
257 ASSERT(r == 0); in TEST_IMPL()
262 ASSERT(r == 0); in TEST_IMPL()
265 ASSERT(r == UV_EEXIST); in TEST_IMPL()
275 ASSERT(shutdown_cb_called == 1); in TEST_IMPL()
276 ASSERT(connect_cb_called == 1); in TEST_IMPL()
277 ASSERT(write_cb_called == 1); in TEST_IMPL()
278 ASSERT(close_cb_called == 1); in TEST_IMPL()
295 ASSERT(r == 0); in TEST_IMPL()
298 ASSERT(r == 0); in TEST_IMPL()
301 ASSERT(r == UV_EBUSY); in TEST_IMPL()
320 ASSERT(0 == uv_ip4_addr("127.0.0.1", TEST_PORT, &addr)); in TEST_IMPL()
322 ASSERT(0 == uv_tcp_init(uv_default_loop(), &server)); in TEST_IMPL()
324 ASSERT(0 == bind(sock, (struct sockaddr*) &addr, sizeof(addr))); in TEST_IMPL()
326 ASSERT(0 == uv_tcp_open(&server, sock)); in TEST_IMPL()
328 ASSERT(0 == uv_listen((uv_stream_t*) &server, 128, NULL)); in TEST_IMPL()
341 ASSERT(0 == uv_ip4_addr("127.0.0.1", TEST_PORT, &addr)); in TEST_IMPL()
346 ASSERT(0 == connect(sock, (struct sockaddr*) &addr, sizeof(addr))); in TEST_IMPL()
348 ASSERT(0 == uv_tcp_init(uv_default_loop(), &client)); in TEST_IMPL()
350 ASSERT(0 == uv_tcp_open(&client, sock)); in TEST_IMPL()
352 ASSERT(0 == uv_write(&write_req, (uv_stream_t*) &client, &buf, 1, write_cb)); in TEST_IMPL()
354 ASSERT(0 == uv_shutdown(&shutdown_req, (uv_stream_t*) &client, shutdown_cb)); in TEST_IMPL()
356 ASSERT(0 == uv_read_start((uv_stream_t*) &client, alloc_cb, read_cb)); in TEST_IMPL()
360 ASSERT(shutdown_cb_called == 1); in TEST_IMPL()
361 ASSERT(write_cb_called == 1); in TEST_IMPL()
362 ASSERT(close_cb_called == 1); in TEST_IMPL()
374 ASSERT(0 == uv_ip4_addr("127.0.0.1", TEST_PORT, &addr)); in TEST_IMPL()
380 ASSERT(r == 0); in TEST_IMPL()
383 ASSERT(r == 0); in TEST_IMPL()
389 ASSERT(r == 0); in TEST_IMPL()
393 ASSERT(shutdown_cb_called == 1); in TEST_IMPL()
394 ASSERT(shutdown_requested == 1); in TEST_IMPL()
395 ASSERT(connect_cb_called == 1); in TEST_IMPL()
396 ASSERT(write_cb_called > 0); in TEST_IMPL()
397 ASSERT(close_cb_called == 1); in TEST_IMPL()