Home
last modified time | relevance | path

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

12

/linux-6.12.1/drivers/s390/char/
Dsclp_sd.c108 static void sclp_sd_listener_add(struct sclp_sd_listener *listener) in sclp_sd_listener_add() argument
111 list_add_tail(&listener->list, &sclp_sd_queue); in sclp_sd_listener_add()
119 static void sclp_sd_listener_remove(struct sclp_sd_listener *listener) in sclp_sd_listener_remove() argument
122 list_del(&listener->list); in sclp_sd_listener_remove()
135 static void sclp_sd_listener_init(struct sclp_sd_listener *listener, u32 id) in sclp_sd_listener_init() argument
137 memset(listener, 0, sizeof(*listener)); in sclp_sd_listener_init()
138 listener->id = id; in sclp_sd_listener_init()
139 init_completion(&listener->completion); in sclp_sd_listener_init()
151 struct sclp_sd_listener *listener; in sclp_sd_receiver() local
156 list_for_each_entry(listener, &sclp_sd_queue, list) { in sclp_sd_receiver()
[all …]
/linux-6.12.1/drivers/infiniband/hw/irdma/
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 …]
Dcm.c1849 struct irdma_cm_listener *listener, in irdma_reset_list_prep() argument
1856 if (cm_node->listener == listener && in irdma_reset_list_prep()
1871 struct irdma_cm_listener *listener, in irdma_dec_refcnt_listen() argument
1883 trace_irdma_dec_refcnt_listen(listener, __builtin_return_address(0)); in irdma_dec_refcnt_listen()
1888 irdma_reset_list_prep(cm_core, listener, &reset_list); in irdma_dec_refcnt_listen()
1914 if (refcount_dec_and_test(&listener->refcnt)) { in irdma_dec_refcnt_listen()
1916 list_del(&listener->list); in irdma_dec_refcnt_listen()
1920 irdma_del_apbvt(listener->iwdev, in irdma_dec_refcnt_listen()
1921 listener->apbvt_entry); in irdma_dec_refcnt_listen()
1922 memcpy(nfo.loc_addr, listener->loc_addr, sizeof(nfo.loc_addr)); in irdma_dec_refcnt_listen()
[all …]
/linux-6.12.1/samples/seccomp/
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-6.12.1/tools/perf/bench/
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-6.12.1/tools/testing/selftests/seccomp/
Dseccomp_bpf.c3366 int status, listener; in TEST() local
3406 listener = user_notif_syscall(__NR_getppid, in TEST()
3408 ASSERT_GE(listener, 0); in TEST()
3424 pollfd.fd = listener; in TEST()
3434 ret = ioctl(listener, SECCOMP_IOCTL_NOTIF_RECV, &req); in TEST()
3440 EXPECT_EQ(ioctl(listener, SECCOMP_IOCTL_NOTIF_RECV, &req), 0); in TEST()
3443 pollfd.fd = listener; in TEST()
3457 EXPECT_EQ(ioctl(listener, SECCOMP_IOCTL_NOTIF_SEND, &resp), -1); in TEST()
3461 EXPECT_EQ(ioctl(listener, SECCOMP_IOCTL_NOTIF_SEND, &resp), 0); in TEST()
3495 int listener; in TEST() local
[all …]
/linux-6.12.1/drivers/uio/
Duio.c479 struct uio_listener *listener; in uio_open() local
497 listener = kmalloc(sizeof(*listener), GFP_KERNEL); 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-6.12.1/drivers/infiniband/hw/qedr/
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-6.12.1/net/vmw_vsock/
Daf_vsock.c365 void vsock_add_pending(struct sock *listener, struct sock *pending) in vsock_add_pending() argument
370 vlistener = vsock_sk(listener); in vsock_add_pending()
374 sock_hold(listener); in vsock_add_pending()
379 void vsock_remove_pending(struct sock *listener, struct sock *pending) in vsock_remove_pending() argument
384 sock_put(listener); in vsock_remove_pending()
389 void vsock_enqueue_accept(struct sock *listener, struct sock *connected) in vsock_enqueue_accept() argument
394 vlistener = vsock_sk(listener); in vsock_enqueue_accept()
398 sock_hold(listener); in vsock_enqueue_accept()
535 static struct sock *vsock_dequeue_accept(struct sock *listener) in vsock_dequeue_accept() argument
540 vlistener = vsock_sk(listener); in vsock_dequeue_accept()
[all …]
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-6.12.1/drivers/md/dm-vdo/
Dvdo.c650 struct read_only_listener *listener, *next; in free_listeners() local
652 for (listener = vdo_forget(thread->listeners); listener != NULL; listener = next) { in free_listeners()
653 next = vdo_forget(listener->next); in free_listeners()
654 vdo_free(listener); in free_listeners()
993 int vdo_register_read_only_listener(struct vdo *vdo, void *listener, in vdo_register_read_only_listener() argument
1012 .listener = listener, in vdo_register_read_only_listener()
1030 static void notify_vdo_of_read_only_mode(void *listener, struct vdo_completion *parent) in notify_vdo_of_read_only_mode() argument
1032 struct vdo *vdo = listener; in notify_vdo_of_read_only_mode()
1148 struct read_only_listener *listener = completion->parent; in make_thread_read_only() local
1150 if (listener == NULL) { in make_thread_read_only()
[all …]
Dvdo.h42 typedef void (*vdo_read_only_notification_fn)(void *listener, struct vdo_completion *parent);
49 void *listener; member
329 int vdo_register_read_only_listener(struct vdo *vdo, void *listener,
/linux-6.12.1/drivers/net/ethernet/mellanox/mlxsw/
Dcore.c2523 const struct mlxsw_listener *listener, in mlxsw_core_listener_register() argument
2526 if (listener->is_event) { in mlxsw_core_listener_register()
2529 &listener->event_listener, in mlxsw_core_listener_register()
2533 &listener->rx_listener, in mlxsw_core_listener_register()
2539 const struct mlxsw_listener *listener, in mlxsw_core_listener_unregister() argument
2542 if (listener->is_event) in mlxsw_core_listener_unregister()
2544 &listener->event_listener); in mlxsw_core_listener_unregister()
2547 &listener->rx_listener); in mlxsw_core_listener_unregister()
2551 const struct mlxsw_listener *listener, void *priv) in mlxsw_core_trap_register() argument
2561 err = mlxsw_core_listener_register(mlxsw_core, listener, priv, in mlxsw_core_trap_register()
[all …]
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-6.12.1/include/net/
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);
/linux-6.12.1/drivers/net/ethernet/qlogic/qed/
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-6.12.1/net/unix/
Dgarbage.c109 if (edge->successor->listener) in unix_edge_successor()
110 return unix_sk(edge->successor->listener)->vertex; in unix_edge_successor()
261 receiver->listener = NULL; in unix_update_edges()
264 unix_update_graph(unix_sk(receiver->listener)->vertex); in unix_update_edges()
265 receiver->listener = NULL; in unix_update_edges()
/linux-6.12.1/Documentation/accounting/
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
163 When the rate of task exits becomes large, a listener may not be able to keep
174 each listener. In the extreme case, there could be one listener for each cpu.
175 Users may also consider setting the cpu affinity of the listener to the subset
/linux-6.12.1/net/tipc/
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()
714 srv->listener = NULL; in tipc_topsrv_stop()
/linux-6.12.1/net/mptcp/
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()
268 struct mptcp_subflow_context *listener = mptcp_subflow_ctx(sk_listener); in mptcp_subflow_init_cookie_req() local
282 if (opt_mp_capable && listener->request_mptcp) { in mptcp_subflow_init_cookie_req()
293 } else if (opt_mp_join && listener->request_mptcp) { in mptcp_subflow_init_cookie_req()
817 struct mptcp_subflow_context *listener = mptcp_subflow_ctx(sk); in subflow_syn_recv_sock() local
[all …]
/linux-6.12.1/kernel/
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()
Dseccomp.c1925 int listener = -1; in seccomp_set_mode_filter() local
1958 listener = get_unused_fd_flags(O_CLOEXEC); in seccomp_set_mode_filter()
1959 if (listener < 0) { in seccomp_set_mode_filter()
1960 ret = listener; in seccomp_set_mode_filter()
1966 put_unused_fd(listener); in seccomp_set_mode_filter()
2006 put_unused_fd(listener); in seccomp_set_mode_filter()
2009 fd_install(listener, listener_f); in seccomp_set_mode_filter()
2010 ret = listener; in seccomp_set_mode_filter()
/linux-6.12.1/tools/testing/selftests/net/packetdrill/
Dtcp_md5_md5-only-on-client-ack.pkt19 // The TCP listener refcount should be 2, but on buggy kernels it can be 0:
/linux-6.12.1/include/net/phonet/
Dpep.h24 struct sock *listener; member
/linux-6.12.1/fs/notify/fanotify/
DKconfig10 an open file descriptor to the userspace listener along with

12