Searched refs:rx_virtqueue (Results 1 - 8 of 8) sorted by path

/seL4-camkes-master/projects/camkes/apps/picotcp_tcp_echo/components/Echo/src/
H A Dclient.h51 extern virtqueue_driver_t rx_virtqueue;
H A Decho.c16 virtqueue_driver_t rx_virtqueue; variable
81 tx_msg_t *msg = get_msg_from_queue(&rx_virtqueue);
110 error = camkes_virtqueue_driver_init_with_recv(&rx_virtqueue, camkes_virtqueue_get_id_from_name("echo_rx"),
H A Dtcp_echo_socket.c43 if (!virtqueue_add_available_buf(&rx_virtqueue, &handle, ENCODE_DMA_ADDRESS(msg), BUF_SIZE, VQ_RW)) {
107 if (!virtqueue_add_available_buf(&rx_virtqueue, &handle, ENCODE_DMA_ADDRESS(msg), BUF_SIZE, VQ_RW)) {
139 if (!virtqueue_add_available_buf(&rx_virtqueue, &handle, ENCODE_DMA_ADDRESS(buf), sizeof(*buf), VQ_RW)) {
H A Dudp_echo_socket.c20 if (!virtqueue_add_available_buf(&rx_virtqueue, &handle, ENCODE_DMA_ADDRESS(msg), BUF_SIZE, VQ_RW)) {
46 if (!virtqueue_add_available_buf(&rx_virtqueue, &handle, ENCODE_DMA_ADDRESS(msg), BUF_SIZE, VQ_RW)) {
81 if (!virtqueue_add_available_buf(&rx_virtqueue, &handle, ENCODE_DMA_ADDRESS(buf), sizeof(*buf), VQ_RW)) {
/seL4-camkes-master/projects/global-components/remote-drivers/picotcp-ethernet-async/
H A Dclient.c57 virtqueue_driver_t rx_virtqueue; member in struct:state
130 if (!virtqueue_add_available_buf(&state->rx_virtqueue, &handle, ENCODE_DMA_ADDRESS(buf), BUF_SIZE, VQ_RW)) {
144 unsigned next = (state->rx_virtqueue.u_ring_last_seen + 1) & (state->rx_virtqueue.queue_len - 1);
146 if (next == state->rx_virtqueue.used_ring->idx) {
150 handle.first = state->rx_virtqueue.used_ring->ring[next].id;
151 len = state->rx_virtqueue.used_ring->ring[next].len;
157 int more = virtqueue_gather_used(&state->rx_virtqueue, &handle, &buf, &len, &flag);
171 virtqueue_get_used_buf(&state->rx_virtqueue, &handle, &len);
202 int picotcp_ethernet_async_client_init(ps_io_ops_t *io_ops, const char *tx_virtqueue, const char *rx_virtqueue, argument
[all...]
H A Dserver.c34 virtqueue_device_t rx_virtqueue; member in struct:data
68 if (virtqueue_get_available_buf(&state->rx_virtqueue, &handle) == 0) {
77 int more = virtqueue_gather_available(&state->rx_virtqueue, &handle, &buf, &len, &flag);
96 if (!virtqueue_add_used_buf(&state->rx_virtqueue, &handle, 0)) {
107 if (!virtqueue_add_used_buf(&state->rx_virtqueue, &handle, lens[0])) {
195 int picotcp_ethernet_async_server_init(ps_io_ops_t *io_ops, const char *tx_virtqueue, const char *rx_virtqueue, argument
223 error = camkes_virtqueue_device_init_with_recv(&data->rx_virtqueue, camkes_virtqueue_get_id_from_name(rx_virtqueue),
/seL4-camkes-master/projects/global-components/remote-drivers/picotcp-ethernet-async/include/
H A Dpicotcp-ethernet-async.h40 int picotcp_ethernet_async_client_init(ps_io_ops_t *io_ops, const char *tx_virtqueue, const char *rx_virtqueue,
45 int picotcp_ethernet_async_server_init(ps_io_ops_t *io_ops, const char *tx_virtqueue, const char *rx_virtqueue,
/seL4-camkes-master/projects/global-components/remote-drivers/picotcp-socket-sync/server/
H A Dserver.c52 virtqueue_device_t rx_virtqueue; variable
701 if (!virtqueue_add_used_buf(&rx_virtqueue, &handle, len)) {
761 if (virtqueue_get_available_buf(&rx_virtqueue, &handle) == 0) {
767 int more = virtqueue_gather_available(&rx_virtqueue, &handle, &buf, &len, &flag);
871 error = camkes_virtqueue_device_init_with_recv(&rx_virtqueue, (unsigned) rx_virtqueue_id,

Completed in 63 milliseconds