Searched refs:tx_virtqueue (Results 1 - 8 of 8) sorted by relevance

/seL4-camkes-master/projects/camkes/apps/picotcp_tcp_echo/components/Echo/src/
H A Decho.c15 virtqueue_driver_t tx_virtqueue; variable
66 tx_msg_t *msg = get_msg_from_queue(&tx_virtqueue);
94 tx_virtqueue.notify();
103 int error = camkes_virtqueue_driver_init_with_recv(&tx_virtqueue, camkes_virtqueue_get_id_from_name("echo_tx"),
120 tx_virtqueue.notify();
H A Dclient.h50 extern virtqueue_driver_t tx_virtqueue;
H A Dudp_echo_socket.c30 if (!virtqueue_add_available_buf(&tx_virtqueue, &handle, ENCODE_DMA_ADDRESS(msg), sizeof(*msg), VQ_RW)) {
H A Dtcp_echo_socket.c81 if (!virtqueue_add_available_buf(&tx_virtqueue, &handle, ENCODE_DMA_ADDRESS(msg), sizeof(*msg), VQ_RW)) {
/seL4-camkes-master/projects/global-components/remote-drivers/picotcp-ethernet-async/
H A Dserver.c33 virtqueue_device_t tx_virtqueue; member in struct:data
51 if (!virtqueue_add_used_buf(&state->tx_virtqueue, &handle, BUF_SIZE)) {
143 unsigned next = (state->tx_virtqueue.a_ring_last_seen + 1) & (state->tx_virtqueue.queue_len - 1);
145 if (next == state->tx_virtqueue.avail_ring->idx) {
148 handle.first = state->tx_virtqueue.avail_ring->ring[next];
154 int more = virtqueue_gather_available(&state->tx_virtqueue, &handle, &buf, &len, &flag);
167 virtqueue_get_available_buf(&state->tx_virtqueue, &handle);
182 state->tx_virtqueue.notify();
195 int picotcp_ethernet_async_server_init(ps_io_ops_t *io_ops, const char *tx_virtqueue, cons argument
[all...]
H A Dclient.c56 virtqueue_driver_t tx_virtqueue; member in struct:state
81 if (virtqueue_get_used_buf(&state->tx_virtqueue, &handle, &sent_len) == 0) {
91 int more = virtqueue_gather_used(&state->tx_virtqueue, &handle, &buf, &sent_len, &flag);
104 if (!virtqueue_add_available_buf(&state->tx_virtqueue, &handle, ENCODE_DMA_ADDRESS(buf), len, VQ_RW)) {
185 state->tx_virtqueue.notify();
202 int picotcp_ethernet_async_client_init(ps_io_ops_t *io_ops, const char *tx_virtqueue, const char *rx_virtqueue, argument
212 error = camkes_virtqueue_driver_init_with_recv(&data->tx_virtqueue, camkes_virtqueue_get_id_from_name(tx_virtqueue),
282 data->tx_virtqueue.notify();
/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.c51 virtqueue_device_t tx_virtqueue; variable
559 tx_virtqueue.notify();
569 if (!virtqueue_add_used_buf(&tx_virtqueue, &handle, len)) {
630 if (virtqueue_get_available_buf(&tx_virtqueue, &handle) == 0) {
636 int more = virtqueue_gather_available(&tx_virtqueue, &handle, &buf, &len, &flag);
865 int error = camkes_virtqueue_device_init_with_recv(&tx_virtqueue, (unsigned) tx_virtqueue_id,

Completed in 56 milliseconds