Lines Matching defs:pinger
70 pinger_t* pinger = (pinger_t*) handle->data;
72 ASSERT_EQ(NUM_PINGS, pinger->pongs);
74 if (handle == (uv_handle_t*) &pinger->stream.tcp) {
75 free(pinger); /* also frees handle */
77 uv_close((uv_handle_t*) &pinger->stream.tcp, ponger_on_close);
92 static void pinger_write_ping(pinger_t* pinger) {
98 stream = (uv_stream_t*) &pinger->stream.tcp;
100 if (!pinger->vectored_writes) {
125 pinger_t* pinger;
127 pinger = (pinger_t*) stream->data;
142 ASSERT_EQ(buf->base[i], pinger->pong[pinger->state]);
143 pinger->state = (pinger->state + 1) % strlen(pinger->pong);
145 if (pinger->state != 0)
148 printf("PONG %d\n", pinger->pongs);
149 pinger->pongs++;
151 if (pinger->pongs < NUM_PINGS) {
152 pinger_write_ping(pinger);
196 pinger_t* pinger = (pinger_t*) req->handle->data;
206 pinger_write_ping(pinger);
218 pinger_t* pinger;
222 pinger = malloc(sizeof(*pinger));
223 ASSERT_NOT_NULL(pinger);
224 pinger->vectored_writes = vectored_writes;
225 pinger->state = 0;
226 pinger->pongs = 0;
227 pinger->pong = PING;
230 r = uv_tcp_init(uv_default_loop(), &pinger->stream.tcp);
231 pinger->stream.tcp.data = pinger;
236 r = uv_tcp_connect(&pinger->connect_req,
237 &pinger->stream.tcp,
250 pinger_t* pinger;
253 pinger = malloc(sizeof(*pinger));
254 ASSERT_NOT_NULL(pinger);
255 pinger->vectored_writes = vectored_writes;
256 pinger->state = 0;
257 pinger->pongs = 0;
258 pinger->pong = PING;
261 r = uv_tcp_init(uv_default_loop(), &pinger->stream.tcp);
262 pinger->stream.tcp.data = pinger;
267 r = uv_tcp_connect(&pinger->connect_req,
268 &pinger->stream.tcp,
280 pinger_t* pinger;
282 pinger = malloc(sizeof(*pinger));
283 ASSERT_NOT_NULL(pinger);
284 pinger->vectored_writes = vectored_writes;
285 pinger->state = 0;
286 pinger->pongs = 0;
287 pinger->pong = PING;
290 r = uv_pipe_init(uv_default_loop(), &pinger->stream.pipe, 0);
291 pinger->stream.pipe.data = pinger;
296 uv_pipe_connect(&pinger->connect_req, &pinger->stream.pipe, TEST_PIPENAME,
305 pinger_t* pinger;
309 pinger = malloc(sizeof(*pinger));
310 ASSERT_NOT_NULL(pinger);
311 pinger->vectored_writes = vectored_writes;
312 pinger->state = 0;
313 pinger->pongs = 0;
314 pinger->pong = PONG;
325 ASSERT_OK(uv_tcp_init(uv_default_loop(), &pinger->stream.tcp));
326 pinger->stream.pipe.data = pinger;
327 ASSERT_OK(uv_tcp_open(&pinger->stream.tcp, fds[1]));
335 pinger_write_ping(pinger);
337 ASSERT_OK(uv_read_start((uv_stream_t*) &pinger->stream.tcp,
348 pinger_t* pinger;
361 pinger = malloc(sizeof(*pinger));
362 ASSERT_NOT_NULL(pinger);
363 pinger->vectored_writes = vectored_writes;
364 pinger->state = 0;
365 pinger->pongs = 0;
366 pinger->pong = PING;
367 ASSERT_OK(uv_pipe_init(uv_default_loop(), &pinger->stream.pipe, 0));
368 ASSERT_OK(uv_pipe_open(&pinger->stream.pipe, fds[1]));
369 pinger->stream.pipe.data = pinger; /* record for close_cb */
370 ponger->data = pinger; /* record for read_cb */
372 pinger_write_ping(pinger);