Home
last modified time | relevance | path

Searched full:listener (Results 1 – 25 of 130) sorted by relevance

123456

/linux/drivers/s390/char/
H A Dsclp_sd.c65 * struct sclp_sd_listener - Listener for asynchronous Store Data response
102 * sclp_sd_listener_add() - Add listener for Store Data responses
103 * @listener: Listener to add
105 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()
113 * sclp_sd_listener_remove() - Remove listener for Store Data responses
114 * @listener: Listener to remove
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()
124 * sclp_sd_listener_init() - Initialize a Store Data response listener
[all …]
/linux/fs/smb/server/
H A Dtransport_rdma.c299 static int smb_direct_new_connection(struct smb_direct_listener *listener, in smb_direct_new_connection() argument
314 listener->port); in smb_direct_new_connection()
329 struct smb_direct_listener *listener = (struct smb_direct_listener *)p; in smb_direct_listener_kthread_fn() local
336 if (!listener->socket) in smb_direct_listener_kthread_fn()
338 client_sc = smbdirect_socket_accept(listener->socket, timeo, &arg); in smb_direct_listener_kthread_fn()
345 smb_direct_new_connection(listener, client_sc); in smb_direct_listener_kthread_fn()
352 static void smb_direct_listener_destroy(struct smb_direct_listener *listener) in smb_direct_listener_destroy() argument
356 if (listener->socket) in smb_direct_listener_destroy()
357 smbdirect_socket_shutdown(listener->socket); in smb_direct_listener_destroy()
359 if (listener->thread) { in smb_direct_listener_destroy()
[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.c1461 * @dst_addr: listener ip addr
1463 * @dst_port: listener tcp port num
1687 ibdev_dbg(&iwdev->ibdev, "CM: Allocating child listener %p\n", in irdma_add_mqh_6()
1690 ibdev_dbg(&iwdev->ibdev, "CM: listener memory allocation\n"); in irdma_add_mqh_6()
1771 "CM: Allocating child CM Listener forIP=%pI4, vlan_id=%d, MAC=%pM\n", in irdma_add_mqh_4()
1776 ibdev_dbg(&iwdev->ibdev, "CM: Allocating child listener %p\n", in irdma_add_mqh_4()
1779 ibdev_dbg(&iwdev->ibdev, "CM: listener memory allocation\n"); in irdma_add_mqh_4()
1846 * @listener: pointer to listener node
1850 struct irdma_cm_listener *listener, in irdma_reset_list_prep() argument
1857 if (cm_node->listener == listener && in irdma_reset_list_prep()
[all …]
/linux/tools/testing/selftests/net/
H A Damt.sh7 # There are four network-namespaces, LISTENER, SOURCE, GATEWAY, RELAY.
8 # The role of LISTENER is to listen multicast traffic.
10 # The role of SOURCE is to send multicast traffic to listener.
16 # | LISTENER netns |
78 readonly LISTENER=$(mktemp -u listener-XXXXXXXX)
102 ip netns add "${LISTENER}" || exit_cleanup
103 ip netns add "${GATEWAY}" || exit_cleanup "${LISTENER}"
104 ip netns add "${RELAY}" || exit_cleanup "${LISTENER}" "${GATEWAY}"
105 ip netns add "${SOURCE}" || exit_cleanup "${LISTENER}" "${GATEWAY}" \
113 exit_cleanup "${LISTENER}" "${GATEWAY}" "${RELAY}" "${SOURCE}"
[all …]
/linux/samples/seccomp/
H A Duser-trap.c109 struct seccomp_notif_resp *resp, int listener) in handle_req() argument
142 * ask the listener fd this as follows. in handle_req()
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()
238 * Send the listener to the parent; also serves as in main()
241 if (send_fd(sk_pair[1], listener) < 0) in main()
243 close(listener); in main()
275 * Get the listener from the child. in main()
[all …]
/linux/tools/testing/selftests/seccomp/
H A Dseccomp_bpf.c3389 int status, listener; in TEST()
3410 /* Check that we get -ENOSYS with no listener attached */ in TEST()
3429 listener = user_notif_syscall(__NR_getppid, in TEST()
3431 ASSERT_GE(listener, 0); in TEST()
3433 /* Installing a second listener in the chain should EBUSY */ in TEST()
3447 pollfd.fd = listener; in TEST()
3457 ret = ioctl(listener, SECCOMP_IOCTL_NOTIF_RECV, &req); in TEST()
3463 EXPECT_EQ(ioctl(listener, SECCOMP_IOCTL_NOTIF_RECV, &req), 0); in TEST()
3466 pollfd.fd = listener; in TEST()
3480 EXPECT_EQ(ioctl(listener, SECCOMP_IOCTL_NOTIF_SEN in TEST()
3383 int status, listener; TEST() local
3512 int listener; TEST() local
3567 int status, listener, sk_pair[2]; TEST() local
3642 int status, listener; TEST() local
3677 int status, listener; TEST() local
3718 int status, listener; TEST() local
3795 int status, listener; TEST() local
3846 int status, listener; TEST() local
3951 int listener; TEST() local
4005 int listener; TEST() local
4063 int listener, status; TEST() local
4137 int status, listener, memfd, fd, nextfd; TEST() local
4299 int status, listener, memfd; TEST() local
4374 int status, listener; TEST() local
4538 int i, status, listener; TEST() local
4642 int listener, status, sk_pair[2]; TEST() local
4714 int listener, status, sk_pair[2]; TEST() local
4789 int listener, status; TEST() local
4839 int listener, status; TEST() local
[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/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
673 "Create Listener address: %pISpc\n", &cm_id->local_addr); in qedr_iw_create_listen()
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()
[all …]
/linux/drivers/android/binder/
H A Dfreeze.rs24 /// Represents a listener for changes to the frozen state of a process.
28 /// The cookie of this freeze listener.
47 /// Is it okay to create a new listener with the same cookie as this one for the provided node?
49 /// Under some scenarios, userspace may delete a freeze listener and immediately recreate it
51 /// we allow this only if the new listener is for the same node, and we also require that the
52 /// old listener has already been cleared.
111 // The primary freeze listener was deleted, so convert a pending duplicate back in do_work()
291 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()
[all …]
/linux/tools/testing/selftests/net/mptcp/
H A Duserspace_pm.sh574 # Attempt to add a listener at 10.0.2.2:<subflow-port>
592 # Delete the listener from the client ns, if one was created
611 # Attempt to add a listener at dead:beef:2::2:<subflow-port>
631 # Delete the listener from the client ns, if one was created
650 # Attempt to add a listener at 10.0.2.2:<new-port>
670 # Delete the listener from the client ns, if one was created
690 # Attempt to add a listener at 10.0.2.1:<subflow-port>
708 # Delete the listener from the server ns, if one was created
726 # Attempt to add a listener at dead:beef:2::1:<subflow-port>
747 # Delete the listener fro
[all...]
/linux/net/vmw_vsock/
H A Daf_vsock.c30 * - "Server" sockets are referred to as listener sockets throughout this
34 * sockets are placed on the pending connection list of the listener socket.
35 * When future packets are received for the address the listener socket is
39 * from the listener socket's pending list and enqueued in the listener
41 * from the listener socket's accept queue. If the socket cannot be accepted
58 * lock_sock(listener);
72 * and the listener socket's pending list and connected queue) ensures a
475 void vsock_add_pending(struct sock *listener, struct sock *pending) in vsock_add_pending() argument
480 vlistener = vsock_sk(listener); in vsock_add_pending()
484 sock_hold(listener); in vsock_add_pending()
[all …]
/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/fs/smb/smbdirect/
H A Dsocket.c304 * In case we were a listener we need to in __smbdirect_socket_schedule_cleanup()
404 * In case we were a listener we need to in smbdirect_socket_cleanup_work()
497 * The listener should clear this before we reach this in smbdirect_socket_destroy()
499 WARN_ONCE(sc->accept.listener, in smbdirect_socket_destroy()
529 * In case we were a listener we need to in smbdirect_socket_destroy()
539 if (sc->listen.backlog != -1) /* was a listener */ in smbdirect_socket_destroy()
544 psc->accept.listener = NULL; in smbdirect_socket_destroy()
547 if (sc->listen.backlog != -1) /* was a listener */ in smbdirect_socket_destroy()
553 if (sc->listen.backlog == -1) /* was not a listener */ in smbdirect_socket_destroy()
563 if (sc->listen.backlog == -1) /* was not a listener */ in smbdirect_socket_destroy()
[all …]
/linux/drivers/net/ethernet/mellanox/mlxsw/
H A Dcore.c2490 * listener for it. in mlxsw_core_event_listener_register()
2522 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
[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()
1658 DP_VERBOSE(p_hwfn, QED_MSG_RDMA, "listener found = %p\n", in qed_iwarp_get_listener()
1659 listener); in qed_iwarp_get_listener()
1660 return listener; in qed_iwarp_get_listener()
1663 DP_VERBOSE(p_hwfn, QED_MSG_RDMA, "listener not found\n"); in qed_iwarp_get_listener()
[all …]
/linux/net/ipv4/
H A Dtcp_fastopen.c20 * listener is closed before the child is accepted.
23 * (or aborted) and the child socket has been accepted (or listener closed).
32 * both its child socket through fastopen_rsk, and a listener socket through
34 * lock per listener "icsk->icsk_accept_queue.fastopenq->lock" is created.
35 * only in the rare case when both the listener and the child locks are held,
41 * from the listener. But first socket lock is difficult to use. It is not
45 * acquire a child's lock while holding listener's socket lock.
48 * treq->tfo_listener is used by the listener so it is protected by the
67 /* If the listener has been closed don't bother with the in reqsk_fastopen_remove()
382 * and queues the child into listener accept queue. in tcp_fastopen_create_child()
[all …]
/linux/net/rds/
H A Drdma_transport.c40 /* Global IPv4 and IPv6 RDS RDMA listener cm_id */
208 printk(KERN_ERR "RDS/RDMA: failed to setup listener, " in rds_rdma_listen_init_common()
219 printk(KERN_ERR "RDS/RDMA: failed to setup listener, " in rds_rdma_listen_init_common()
226 printk(KERN_ERR "RDS/RDMA: failed to setup listener, " in rds_rdma_listen_init_common()
275 rdsdebug("Cannot set up IPv6 RDMA listener\n"); in rds_rdma_listen_init()
/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/arch/m68k/mac/
H A Diop.c43 * of device names to the listener functions ala the interrupt
142 struct listener { struct
162 static struct listener iop_listeners[NUM_IOPS][NUM_IOP_CHAN]; argument
303 * Register or unregister a listener for a specific IOP and channel
305 * If the handler pointer is NULL the current listener (if any) is
306 * unregistered. Otherwise the new listener is registered provided
307 * there is no existing listener registered.
431 /* If there is a listener, call it now. Otherwise complete */ in iop_handle_recv()
/linux/net/tipc/
H A Dtopsrv.c64 * @listener: topsrv listener socket
75 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/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()
447 /* Self-reference or a embryo-listener circle ? */ in unix_scc_cyclic()
/linux/tools/testing/selftests/bpf/prog_tests/
H A Dmigrate_reuseport.c381 * to the last listener based on eBPF. in migrate_dance()
403 /* Note that we use the second listener instead of the in migrate_dance()
406 * The fist listener is bind()ed with port 0 and,
408 * calling listen() again will bind() the first listener in count_requests()
414 * resurrect the listener on the existing reuseport group. in count_requests()
420 /* Migrate from the last listener to the second one. in count_requests()
/linux/tools/testing/selftests/drivers/net/mlxsw/
H A Ddevlink_trap_control.sh277 # MLD Multicast Listener Query (Type 130)
278 devlink_trap_stats_test "MLD Multicast Listener Query" "mld_query" \
285 # MLD Version 1 Multicast Listener Report (Type 131)
286 devlink_trap_stats_test "MLD Version 1 Multicast Listener Report" \
293 # MLD Version 2 Multicast Listener Report (Type 143)
294 devlink_trap_stats_test "MLD Version 2 Multicast Listener Report" \
301 # MLD Version 1 Multicast Listener Done (Type 132)
302 devlink_trap_stats_test "MLD Version 1 Multicast Listener Done" \

123456