Searched refs:conn_io (Results 1 – 4 of 4) sorted by relevance
| /external/rust/crates/quiche/examples/ |
| D | http3-client.c | 49 struct conn_io { struct
65 static void flush_egress(struct ev_loop *loop, struct conn_io *conn_io) { in flush_egress() argument
69 ssize_t written = quiche_conn_send(conn_io->conn, out, sizeof(out)); in flush_egress()
81 ssize_t sent = send(conn_io->sock, out, written, 0); in flush_egress()
90 double t = quiche_conn_timeout_as_nanos(conn_io->conn) / 1e9f; in flush_egress()
91 conn_io->timer.repeat = t; in flush_egress()
92 ev_timer_again(loop, &conn_io->timer); in flush_egress()
107 struct conn_io *conn_io = w->data; in recv_cb() local
112 ssize_t read = recv(conn_io->sock, buf, sizeof(buf), 0); in recv_cb()
124 ssize_t done = quiche_conn_recv(conn_io->conn, buf, read); in recv_cb()
[all …]
|
| D | http3-server.c | 58 struct conn_io *h;
61 struct conn_io { struct
89 static void flush_egress(struct ev_loop *loop, struct conn_io *conn_io) { in flush_egress() argument
93 ssize_t written = quiche_conn_send(conn_io->conn, out, sizeof(out)); in flush_egress()
105 ssize_t sent = sendto(conn_io->sock, out, written, 0, in flush_egress()
106 (struct sockaddr *) &conn_io->peer_addr, in flush_egress()
107 conn_io->peer_addr_len); in flush_egress()
116 double t = quiche_conn_timeout_as_nanos(conn_io->conn) / 1e9f; in flush_egress()
117 conn_io->timer.repeat = t; in flush_egress()
118 ev_timer_again(loop, &conn_io->timer); in flush_egress()
[all …]
|
| D | client.c | 49 struct conn_io { struct
61 static void flush_egress(struct ev_loop *loop, struct conn_io *conn_io) { in flush_egress() argument
65 ssize_t written = quiche_conn_send(conn_io->conn, out, sizeof(out)); in flush_egress()
77 ssize_t sent = send(conn_io->sock, out, written, 0); in flush_egress()
86 double t = quiche_conn_timeout_as_nanos(conn_io->conn) / 1e9f; in flush_egress()
87 conn_io->timer.repeat = t; in flush_egress()
88 ev_timer_again(loop, &conn_io->timer); in flush_egress()
94 struct conn_io *conn_io = w->data; in recv_cb() local
99 ssize_t read = recv(conn_io->sock, buf, sizeof(buf), 0); in recv_cb()
111 ssize_t done = quiche_conn_recv(conn_io->conn, buf, read); in recv_cb()
[all …]
|
| D | server.c | 58 struct conn_io *h;
61 struct conn_io { struct
86 static void flush_egress(struct ev_loop *loop, struct conn_io *conn_io) { in flush_egress() argument
90 ssize_t written = quiche_conn_send(conn_io->conn, out, sizeof(out)); in flush_egress()
102 ssize_t sent = sendto(conn_io->sock, out, written, 0, in flush_egress()
103 (struct sockaddr *) &conn_io->peer_addr, in flush_egress()
104 conn_io->peer_addr_len); in flush_egress()
113 double t = quiche_conn_timeout_as_nanos(conn_io->conn) / 1e9f; in flush_egress()
114 conn_io->timer.repeat = t; in flush_egress()
115 ev_timer_again(loop, &conn_io->timer); in flush_egress()
[all …]
|