Home
last modified time | relevance | path

Searched refs:recv_io (Results 1 – 6 of 6) sorted by relevance

/linux/fs/smb/smbdirect/
H A Daccept.c22 struct smbdirect_recv_io *recv_io; in smbdirect_accept_connect_request() local
69 recv_io = smbdirect_connection_get_recv_io(sc); in smbdirect_accept_connect_request()
70 if (WARN_ON_ONCE(!recv_io)) { in smbdirect_accept_connect_request()
77 recv_io->cqe.done = smbdirect_accept_negotiate_recv_done; in smbdirect_accept_connect_request()
83 sc->recv_io.expected = SMBDIRECT_EXPECT_NEGOTIATE_REQ; in smbdirect_accept_connect_request()
84 ret = smbdirect_connection_post_recv_io(recv_io); in smbdirect_accept_connect_request()
95 recv_io = NULL; in smbdirect_accept_connect_request()
153 if (recv_io) in smbdirect_accept_connect_request()
154 smbdirect_connection_put_recv_io(recv_io); in smbdirect_accept_connect_request()
200 sc->recv_io.credits.target = 1; in smbdirect_accept_init_params()
[all …]
H A Dconnection.c198 INIT_WORK(&sc->recv_io.posted.refill_work, smbdirect_connection_recv_io_refill_work); in smbdirect_connection_negotiation_done()
466 sc->recv_io.mem.cache = kmem_cache_create(name, in smbdirect_connection_create_mem_pools()
471 if (!sc->recv_io.mem.cache) in smbdirect_connection_create_mem_pools()
474 sc->recv_io.mem.pool = mempool_create_slab_pool(sp->recv_credit_max, in smbdirect_connection_create_mem_pools()
475 sc->recv_io.mem.cache); in smbdirect_connection_create_mem_pools()
476 if (!sc->recv_io.mem.pool) in smbdirect_connection_create_mem_pools()
480 struct smbdirect_recv_io *recv_io; in smbdirect_connection_create_mem_pools() local
482 recv_io = mempool_alloc(sc->recv_io.mem.pool, in smbdirect_connection_create_mem_pools()
483 sc->recv_io.mem.gfp_mask); in smbdirect_connection_create_mem_pools()
484 if (!recv_io) in smbdirect_connection_create_mem_pools()
[all …]
H A Dconnect.c380 struct smbdirect_recv_io *recv_io = NULL; in smbdirect_connect_negotiate_start() local
408 recv_io = smbdirect_connection_get_recv_io(sc); in smbdirect_connect_negotiate_start()
409 if (WARN_ON_ONCE(!recv_io)) { in smbdirect_connect_negotiate_start()
416 recv_io->cqe.done = smbdirect_connect_negotiate_recv_done; in smbdirect_connect_negotiate_start()
483 sc->recv_io.expected = SMBDIRECT_EXPECT_NEGOTIATE_REP; in smbdirect_connect_negotiate_start()
484 ret = smbdirect_connection_post_recv_io(recv_io); in smbdirect_connect_negotiate_start()
541 smbdirect_connection_put_recv_io(recv_io); in smbdirect_connect_negotiate_start()
578 struct smbdirect_recv_io *recv_io = in smbdirect_connect_negotiate_recv_done() local
580 struct smbdirect_socket *sc = recv_io->socket; in smbdirect_connect_negotiate_recv_done()
598 if (WARN_ON_ONCE(sc->recv_io.expected != SMBDIRECT_EXPECT_NEGOTIATE_REP)) in smbdirect_connect_negotiate_recv_done()
[all …]
H A Ddebug.c61 sc->recv_io.reassembly.data_length); in smbdirect_connection_legacy_debug_proc_show()
63 sc->recv_io.reassembly.queue_length); in smbdirect_connection_legacy_debug_proc_show()
69 atomic_read(&sc->recv_io.credits.count), in smbdirect_connection_legacy_debug_proc_show()
70 sc->recv_io.credits.target); in smbdirect_connection_legacy_debug_proc_show()
H A Dsocket.c218 sc->recv_io.mem.gfp_mask = gfp_mask; in smbdirect_socket_set_kernel_settings()
257 wake_up_all(&sc->recv_io.reassembly.wait_queue); in smbdirect_socket_wake_up_all()
298 disable_work(&sc->recv_io.posted.refill_work); in __smbdirect_socket_schedule_cleanup()
398 disable_work(&sc->recv_io.posted.refill_work); in smbdirect_socket_cleanup_work()
473 struct smbdirect_recv_io *recv_io; in smbdirect_socket_destroy() local
515 disable_work_sync(&sc->recv_io.posted.refill_work); in smbdirect_socket_destroy()
556 spin_lock_irqsave(&sc->recv_io.reassembly.lock, flags); in smbdirect_socket_destroy()
557 list_splice_tail_init(&sc->recv_io.reassembly.list, &all_list); in smbdirect_socket_destroy()
558 spin_unlock_irqrestore(&sc->recv_io.reassembly.lock, flags); in smbdirect_socket_destroy()
559 list_for_each_entry_safe(recv_io, recv_tmp, &all_list, list) in smbdirect_socket_destroy()
[all …]
/linux/tools/testing/selftests/net/
H A Dreuseport_bpf.c216 struct iovec recv_io = { recv_buf, 8 }; in test_recv_order()
232 msg.msg_iov = &recv_io; in test_recv_order()
215 struct iovec recv_io = { recv_buf, 8 }; test_recv_order() local