Lines Matching defs:pinger
80 pinger_t* pinger;
82 pinger = (pinger_t*)handle->data;
83 fprintf(stderr, "ping_pongs: %d roundtrips/s\n", (1000 * pinger->pongs) / TIME);
86 free(pinger);
99 static void pinger_write_ping(pinger_t* pinger) {
106 if (uv_write(req, (uv_stream_t*) &pinger->tcp, &buf, 1, pinger_write_cb)) {
128 pinger_t* pinger;
130 pinger = (pinger_t*)tcp->data;
147 ASSERT_EQ(buf->base[i], PING[pinger->state]);
148 pinger->state = (pinger->state + 1) % (sizeof(PING) - 1);
149 if (pinger->state == 0) {
150 pinger->pongs++;
152 uv_shutdown(&pinger->shutdown_req,
157 pinger_write_ping(pinger);
167 pinger_t *pinger = (pinger_t*)req->handle->data;
171 pinger_write_ping(pinger);
182 pinger_t *pinger;
187 pinger = malloc(sizeof(*pinger));
188 pinger->state = 0;
189 pinger->pongs = 0;
192 r = uv_tcp_init(loop, &pinger->tcp);
195 pinger->tcp.data = pinger;
197 ASSERT_OK(uv_tcp_bind(&pinger->tcp,
201 r = uv_tcp_connect(&pinger->connect_req,
202 &pinger->tcp,