MCPcopy Create free account
hub / github.com/axboe/liburing / recv_error

Function recv_error

examples/proxy.c:1383–1396  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

1381}
1382
1383static int recv_error(struct error_handler *err, struct io_uring *ring,
1384 struct io_uring_cqe *cqe)
1385{
1386 struct conn *c = cqe_to_conn(cqe);
1387 struct conn_dir *cd = cqe_to_conn_dir(c, cqe);
1388
1389 cd->pending_recv = 0;
1390
1391 if (cqe->res != -ENOBUFS)
1392 return default_error(err, ring, cqe);
1393
1394 recv_enobufs(ring, c, cd, other_dir_fd(c, cqe_to_fd(cqe)));
1395 return 0;
1396}
1397
1398static void submit_send(struct io_uring *ring, struct conn *c,
1399 struct conn_dir *cd, int fd, void *data, int len,

Callers

nothing calls this directly

Calls 6

cqe_to_connFunction · 0.85
cqe_to_conn_dirFunction · 0.85
default_errorFunction · 0.85
recv_enobufsFunction · 0.85
other_dir_fdFunction · 0.85
cqe_to_fdFunction · 0.85

Tested by

no test coverage detected