Home
last modified time | relevance | path

Searched refs:listener (Results 1 – 25 of 38) sorted by relevance

12

/linux/drivers/s390/char/
H A Dsclp_sd.c105 static void sclp_sd_listener_add(struct sclp_sd_listener *listener) in sclp_sd_listener_add() argument
108 list_add_tail(&listener->list, &sclp_sd_queue); in sclp_sd_listener_add()
116 static void sclp_sd_listener_remove(struct sclp_sd_listener *listener) in sclp_sd_listener_remove() argument
119 list_del(&listener->list); in sclp_sd_listener_remove()
132 static void sclp_sd_listener_init(struct sclp_sd_listener *listener, u32 id) in sclp_sd_listener_init() argument
134 memset(listener, 0, sizeof(*listener)); in sclp_sd_listener_init()
135 listener->id = id; in sclp_sd_listener_init()
136 init_completion(&listener->completion); in sclp_sd_listener_init()
148 struct sclp_sd_listener *listener; in sclp_sd_receiver() local
153 list_for_each_entry(listener, &sclp_sd_queue, list) { in sclp_sd_receiver()
[all …]
/linux/drivers/infiniband/hw/irdma/
H A Dtrace_cm.h42 TP_PROTO(struct irdma_cm_listener *listener, void *caller),
43 TP_ARGS(listener, caller),
51 TP_fast_assign(__entry->iwdev = listener->iwdev;
52 __entry->lport = listener->loc_port;
53 __entry->ipv4 = listener->ipv4;
55 listener->loc_addr, 4);
66 TP_PROTO(struct irdma_cm_listener *listener),
67 TP_ARGS(listener),
76 TP_fast_assign(__entry->iwdev = listener->iwdev;
77 __entry->lport = listener->loc_port;
[all …]
H A Dcm.c1850 struct irdma_cm_listener *listener, in irdma_reset_list_prep() argument
1857 if (cm_node->listener == listener && in irdma_reset_list_prep()
1872 struct irdma_cm_listener *listener, in irdma_dec_refcnt_listen() argument
1884 trace_irdma_dec_refcnt_listen(listener, __builtin_return_address(0)); in irdma_dec_refcnt_listen()
1889 irdma_reset_list_prep(cm_core, listener, &reset_list); in irdma_dec_refcnt_listen()
1915 if (refcount_dec_and_test(&listener->refcnt)) { in irdma_dec_refcnt_listen()
1917 list_del(&listener->list); in irdma_dec_refcnt_listen()
1921 irdma_del_apbvt(listener->iwdev, in irdma_dec_refcnt_listen()
1922 listener->apbvt_entry); in irdma_dec_refcnt_listen()
1923 memcpy(nfo.loc_addr, listener->loc_addr, sizeof(nfo.loc_addr)); in irdma_dec_refcnt_listen()
[all …]
/linux/samples/seccomp/
H A Duser-trap.c109 struct seccomp_notif_resp *resp, int listener) in handle_req() argument
149 if (ioctl(listener, SECCOMP_IOCTL_NOTIF_ID_VALID, &req->id) < 0) { in handle_req()
207 int sk_pair[2], ret = 1, status, listener; in main() local
222 listener = user_trap_syscall(__NR_mount, in main()
224 if (listener < 0) { in main()
241 if (send_fd(sk_pair[1], listener) < 0) in main()
243 close(listener); in main()
277 listener = recv_fd(sk_pair[0]); in main()
278 if (listener < 0) in main()
313 if (ioctl(listener, SECCOMP_IOCTL_NOTIF_RECV, req)) { in main()
[all …]
/linux/tools/perf/bench/
H A Dsched-seccomp-notify.c68 static void user_notification_sync_loop(int listener) in user_notification_sync_loop() argument
76 if (ioctl(listener, SECCOMP_IOCTL_NOTIF_RECV, &req)) in user_notification_sync_loop()
86 if (ioctl(listener, SECCOMP_IOCTL_NOTIF_SEND, &resp)) in user_notification_sync_loop()
99 int status, listener; in bench_sched_seccomp_notify() local
108 listener = user_notif_syscall(__NR_gettid, in bench_sched_seccomp_notify()
110 if (listener < 0) in bench_sched_seccomp_notify()
129 if (ioctl(listener, SECCOMP_IOCTL_NOTIF_SET_FLAGS, in bench_sched_seccomp_notify()
134 user_notification_sync_loop(listener); in bench_sched_seccomp_notify()
/linux/tools/testing/selftests/seccomp/
H A Dseccomp_bpf.c3383 int status, listener; in TEST() local
3423 listener = user_notif_syscall(__NR_getppid, in TEST()
3425 ASSERT_GE(listener, 0); in TEST()
3441 pollfd.fd = listener; in TEST()
3451 ret = ioctl(listener, SECCOMP_IOCTL_NOTIF_RECV, &req); in TEST()
3457 EXPECT_EQ(ioctl(listener, SECCOMP_IOCTL_NOTIF_RECV, &req), 0); in TEST()
3460 pollfd.fd = listener; in TEST()
3474 EXPECT_EQ(ioctl(listener, SECCOMP_IOCTL_NOTIF_SEND, &resp), -1); in TEST()
3478 EXPECT_EQ(ioctl(listener, SECCOMP_IOCTL_NOTIF_SEND, &resp), 0); in TEST()
3512 int listener; in TEST() local
[all …]
/linux/drivers/infiniband/hw/qedr/
H A Dqedr_iw_cm.c106 struct qedr_iw_listener *listener = (struct qedr_iw_listener *)context; in qedr_iw_mpa_request() local
107 struct qedr_dev *dev = listener->dev; in qedr_iw_mpa_request()
135 listener->cm_id->event_handler(listener->cm_id, &event); in qedr_iw_mpa_request()
661 struct qedr_iw_listener *listener; in qedr_iw_create_listen() local
675 listener = kzalloc(sizeof(*listener), GFP_KERNEL); in qedr_iw_create_listen()
676 if (!listener) in qedr_iw_create_listen()
679 listener->dev = dev; in qedr_iw_create_listen()
681 listener->cm_id = cm_id; in qedr_iw_create_listen()
682 listener->backlog = backlog; in qedr_iw_create_listen()
684 iparams.cb_context = listener; in qedr_iw_create_listen()
[all …]
/linux/net/vmw_vsock/
H A Daf_vsock.c370 void vsock_add_pending(struct sock *listener, struct sock *pending) in vsock_add_pending() argument
375 vlistener = vsock_sk(listener); in vsock_add_pending()
379 sock_hold(listener); in vsock_add_pending()
384 void vsock_remove_pending(struct sock *listener, struct sock *pending) in vsock_remove_pending() argument
389 sock_put(listener); in vsock_remove_pending()
394 void vsock_enqueue_accept(struct sock *listener, struct sock *connected) in vsock_enqueue_accept() argument
399 vlistener = vsock_sk(listener); in vsock_enqueue_accept()
403 sock_hold(listener); in vsock_enqueue_accept()
583 static struct sock *vsock_dequeue_accept(struct sock *listener) in vsock_dequeue_accept() argument
588 vlistener = vsock_sk(listener); in vsock_dequeue_accept()
[all …]
H A Dvmci_transport.c479 struct sock *listener, in vmci_transport_get_pending() argument
489 vlistener = vsock_sk(listener); in vmci_transport_get_pending()
1120 vpending->listener = sk; in vmci_transport_recv_listen()
1130 vmci_transport_recv_connecting_server(struct sock *listener, in vmci_transport_recv_connecting_server() argument
1251 vsock_remove_pending(listener, pending); in vmci_transport_recv_connecting_server()
1252 vsock_enqueue_accept(listener, pending); in vmci_transport_recv_connecting_server()
1257 listener->sk_data_ready(listener); in vmci_transport_recv_connecting_server()
/linux/drivers/md/dm-vdo/
H A Dvdo.c643 struct read_only_listener *listener, *next; in free_listeners() local
645 for (listener = vdo_forget(thread->listeners); listener != NULL; listener = next) { in free_listeners()
646 next = vdo_forget(listener->next); in free_listeners()
647 vdo_free(listener); in free_listeners()
987 int vdo_register_read_only_listener(struct vdo *vdo, void *listener, in vdo_register_read_only_listener() argument
1006 .listener = listener, in vdo_register_read_only_listener()
1024 static void notify_vdo_of_read_only_mode(void *listener, struct vdo_completion *parent) in notify_vdo_of_read_only_mode() argument
1026 struct vdo *vdo = listener; in notify_vdo_of_read_only_mode()
1142 struct read_only_listener *listener = completion->parent; in make_thread_read_only() local
1144 if (listener == NULL) { in make_thread_read_only()
[all …]
H A Dvdo.h42 typedef void (*vdo_read_only_notification_fn)(void *listener, struct vdo_completion *parent);
49 void *listener; member
331 int vdo_register_read_only_listener(struct vdo *vdo, void *listener,
/linux/drivers/net/ethernet/qlogic/qed/
H A Dqed_iwarp.c1633 struct qed_iwarp_listener *listener = NULL; in qed_iwarp_get_listener() local
1637 list_for_each_entry(listener, in qed_iwarp_get_listener()
1640 if (listener->port == cm_info->local_port) { in qed_iwarp_get_listener()
1641 if (!memcmp(listener->ip_addr, in qed_iwarp_get_listener()
1647 if (!memcmp(listener->ip_addr, in qed_iwarp_get_listener()
1650 (listener->vlan == cm_info->vlan)) { in qed_iwarp_get_listener()
1659 listener); in qed_iwarp_get_listener()
1660 return listener; in qed_iwarp_get_listener()
2358 struct qed_iwarp_listener *listener; in qed_iwarp_ll2_comp_syn_pkt() local
2396 listener = qed_iwarp_get_listener(p_hwfn, &cm_info); in qed_iwarp_ll2_comp_syn_pkt()
[all …]
/linux/include/net/
H A Daf_vsock.h49 struct sock *listener; member
210 void vsock_add_pending(struct sock *listener, struct sock *pending);
211 void vsock_remove_pending(struct sock *listener, struct sock *pending);
212 void vsock_enqueue_accept(struct sock *listener, struct sock *connected);
H A Daf_unix.h43 struct sock *listener; member
/linux/net/unix/
H A Dgarbage.c116 * the listener indirectly holds the fd's refcnt. in unix_edge_successor()
118 if (edge->successor->listener) in unix_edge_successor()
119 return unix_sk(edge->successor->listener)->vertex; in unix_edge_successor()
273 receiver->listener = NULL; in unix_update_edges()
276 unix_update_graph(unix_sk(receiver->listener)->vertex); in unix_update_edges()
277 receiver->listener = NULL; in unix_update_edges()
398 /* Self-reference or a embryo-listener circle ? */ in unix_scc_cyclic()
/linux/Documentation/accounting/
H A Dtaskstats.rst35 To obtain statistics for tasks which are exiting, the userspace listener
38 registered listener. Using cpumasks allows the data received by one listener
165 When the rate of task exits becomes large, a listener may not be able to keep
176 each listener. In the extreme case, there could be one listener for each cpu.
177 Users may also consider setting the cpu affinity of the listener to the subset
/linux/net/tipc/
H A Dtopsrv.c75 struct socket *listener; member
464 if (!srv->listener) { in tipc_topsrv_accept()
468 lsock = srv->listener; in tipc_topsrv_accept()
522 srv->listener = lsock; in tipc_topsrv_create_listener()
699 struct socket *lsock = srv->listener; in tipc_topsrv_stop()
716 srv->listener = NULL; in tipc_topsrv_stop()
/linux/drivers/net/ethernet/mellanox/mlxsw/
H A Dspectrum_trap.c1441 mlxsw_sp_trap_listener_is_valid(const struct mlxsw_listener *listener) in mlxsw_sp_trap_listener_is_valid() argument
1443 return listener->trap_id != 0; in mlxsw_sp_trap_listener_is_valid()
1580 const struct mlxsw_listener *listener; in mlxsw_sp_trap_init() local
1583 listener = &trap_item->listeners_arr[i]; in mlxsw_sp_trap_init()
1584 if (!mlxsw_sp_trap_listener_is_valid(listener)) in mlxsw_sp_trap_init()
1586 err = mlxsw_core_trap_register(mlxsw_core, listener, trap_ctx); in mlxsw_sp_trap_init()
1606 const struct mlxsw_listener *listener; in mlxsw_sp_trap_fini() local
1608 listener = &trap_item->listeners_arr[i]; in mlxsw_sp_trap_fini()
1609 if (!mlxsw_sp_trap_listener_is_valid(listener)) in mlxsw_sp_trap_fini()
1611 mlxsw_core_trap_unregister(mlxsw_core, listener, trap_ctx); in mlxsw_sp_trap_fini()
[all …]
/linux/drivers/android/binder/
H A Dfreeze.rs291 let Some(listener) = node_refs.freeze_listeners.get_mut(&cookie) else { in clear_freeze_notif()
295 listener.is_clearing = true; in clear_freeze_notif()
296 listener.node.remove_freeze_listener(self); in clear_freeze_notif()
299 if !listener.is_pending { in clear_freeze_notif()
/linux/net/mptcp/
H A Dsubflow.c151 struct mptcp_subflow_context *listener = mptcp_subflow_ctx(sk_listener); in subflow_check_req() local
156 pr_debug("subflow_req=%p, listener=%p\n", subflow_req, listener); in subflow_check_req()
175 if (unlikely(listener->pm_listener)) in subflow_check_req()
184 } else if (unlikely(listener->pm_listener)) { in subflow_check_req()
188 if (opt_mp_capable && listener->request_mptcp) { in subflow_check_req()
219 } else if (opt_mp_join && listener->request_mptcp) { in subflow_check_req()
269 struct mptcp_subflow_context *listener = mptcp_subflow_ctx(sk_listener); in mptcp_subflow_init_cookie_req() local
283 if (opt_mp_capable && listener->request_mptcp) { in mptcp_subflow_init_cookie_req()
294 } else if (opt_mp_join && listener->request_mptcp) { in mptcp_subflow_init_cookie_req()
815 struct mptcp_subflow_context *listener = mptcp_subflow_ctx(sk); in subflow_syn_recv_sock() local
[all …]
/linux/kernel/
H A Dtaskstats.c48 struct listener { struct
114 struct listener *s, *tmp; in send_cpu_listeners()
298 struct listener *s, *tmp, *s2; in add_del_listener()
313 s = kmalloc_node(sizeof(struct listener), in add_del_listener()
H A Dseccomp.c1962 int listener = -1; in seccomp_set_mode_filter() local
1995 listener = get_unused_fd_flags(O_CLOEXEC); in seccomp_set_mode_filter()
1996 if (listener < 0) { in seccomp_set_mode_filter()
1997 ret = listener; in seccomp_set_mode_filter()
2003 put_unused_fd(listener); in seccomp_set_mode_filter()
2043 put_unused_fd(listener); in seccomp_set_mode_filter()
2046 fd_install(listener, listener_f); in seccomp_set_mode_filter()
2047 ret = listener; in seccomp_set_mode_filter()
/linux/tools/testing/selftests/net/packetdrill/
H A Dtcp_md5_md5-only-on-client-ack.pkt19 // The TCP listener refcount should be 2, but on buggy kernels it can be 0:
/linux/include/net/phonet/
H A Dpep.h24 struct sock *listener; member
/linux/Documentation/admin-guide/nfs/
H A Dnfsd-admin-interfaces.rst23 udp and one tcp listener at port 2049 (see nfsd_init_socks).

12