Lines Matching defs:pinger
64 pinger_t* pinger;
66 pinger = (pinger_t*)handle->data;
69 pinger->pongs / (TIME / 1000));
72 completed_pings += pinger->pongs;
74 free(pinger);
77 static void pinger_write_ping(pinger_t* pinger) {
82 r = uv_udp_try_send(&pinger->udp, &buf, 1,
83 (const struct sockaddr*) &pinger->server_addr);
94 pinger_t* pinger;
95 pinger = (pinger_t*)udp->data;
102 ASSERT_EQ(buf->base[i], PING[pinger->state]);
103 pinger->state = (pinger->state + 1) % (sizeof(PING) - 1);
104 if (pinger->state == 0) {
105 pinger->pongs++;
110 pinger_write_ping(pinger);
119 pinger_t* pinger = malloc(sizeof(*pinger));
122 ASSERT_OK(uv_ip4_addr("127.0.0.1", TEST_PORT, &pinger->server_addr));
123 pinger->state = 0;
124 pinger->pongs = 0;
127 r = uv_udp_init(loop, &pinger->udp);
129 r = uv_udp_bind(&pinger->udp, (const struct sockaddr*) &pinger->server_addr, 0);
132 pinger->udp.data = pinger;
135 if (0 != uv_udp_recv_start(&pinger->udp, buf_alloc, pinger_read_cb)) {
138 pinger_write_ping(pinger);