Home
last modified time | relevance | path

Searched refs:listener (Results 1 – 25 of 42) 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/uio/
H A Duio.c479 struct uio_listener *listener; in uio_open() local
497 listener = kmalloc_obj(*listener); in uio_open()
498 if (!listener) { in uio_open()
503 listener->dev = idev; in uio_open()
504 listener->event_count = atomic_read(&idev->event); in uio_open()
505 filep->private_data = listener; in uio_open()
523 kfree(listener); in uio_open()
537 struct uio_listener *listener = filep->private_data; in uio_fasync() local
538 struct uio_device *idev = listener->dev; in uio_fasync()
546 struct uio_listener *listener = filep->private_data; in uio_release() 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_obj(*listener); 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.c471 void vsock_add_pending(struct sock *listener, struct sock *pending) in vsock_add_pending() argument
476 vlistener = vsock_sk(listener); in vsock_add_pending()
480 sock_hold(listener); in vsock_add_pending()
485 void vsock_remove_pending(struct sock *listener, struct sock *pending) in vsock_remove_pending() argument
490 sock_put(listener); in vsock_remove_pending()
495 void vsock_enqueue_accept(struct sock *listener, struct sock *connected) in vsock_enqueue_accept() argument
500 vlistener = vsock_sk(listener); in vsock_enqueue_accept()
504 sock_hold(listener); in vsock_enqueue_accept()
684 static struct sock *vsock_dequeue_accept(struct sock *listener) in vsock_dequeue_accept() argument
689 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()
1128 vpending->listener = sk; in vmci_transport_recv_listen()
1138 vmci_transport_recv_connecting_server(struct sock *listener, in vmci_transport_recv_connecting_server() argument
1259 vsock_remove_pending(listener, pending); in vmci_transport_recv_connecting_server()
1260 vsock_enqueue_accept(listener, pending); in vmci_transport_recv_connecting_server()
1265 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/mellanox/mlxsw/
H A Dcore.c2522 const struct mlxsw_listener *listener, in mlxsw_core_listener_register() argument
2525 if (listener->is_event) { in mlxsw_core_listener_register()
2528 &listener->event_listener, in mlxsw_core_listener_register()
2532 &listener->rx_listener, in mlxsw_core_listener_register()
2538 const struct mlxsw_listener *listener, in mlxsw_core_listener_unregister() argument
2541 if (listener->is_event) in mlxsw_core_listener_unregister()
2543 &listener->event_listener); in mlxsw_core_listener_unregister()
2546 &listener->rx_listener); in mlxsw_core_listener_unregister()
2550 const struct mlxsw_listener *listener, void *priv) in mlxsw_core_trap_register() argument
2560 err = mlxsw_core_listener_register(mlxsw_core, listener, priv, in mlxsw_core_trap_register()
[all …]
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/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.h50 struct sock *listener;
211 void vsock_add_pending(struct sock *listener, struct sock *pending);
212 void vsock_remove_pending(struct sock *listener, struct sock *pending);
213 void vsock_enqueue_accept(struct sock *listener, struct sock *connected);
49 struct sock *listener; global() member
H A Daf_unix.h43 struct sock *listener; member
/linux/net/unix/
H A Dgarbage.c118 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()
/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/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()
813 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()
/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

12