Home
last modified time | relevance | path

Searched refs:listener (Results 1 – 25 of 40) 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.c3389 int status, listener; in TEST() local
3429 listener = user_notif_syscall(__NR_getppid, in TEST()
3431 ASSERT_GE(listener, 0); 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_SEND, &resp), -1); in TEST()
3484 EXPECT_EQ(ioctl(listener, SECCOMP_IOCTL_NOTIF_SEND, &resp), 0); in TEST()
3518 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_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/tools/testing/selftests/net/
H A Dipv6_flowlabel_mgr.c108 static void tcp_connect(int listener, uint32_t flowlabel, in tcp_connect() argument
128 afd = accept(listener, NULL, NULL); in tcp_connect()
460 int listener, cfd, afd, err; in TEST_F() local
462 listener = tcp_listen(); in TEST_F()
463 tcp_connect(listener, 7, &cfd, &afd); in TEST_F()
472 EXPECT_EQ(0, close(listener)); in TEST_F()
510 int listener, cfd, afd, err; in TEST_F() local
516 listener = tcp_listen(); in TEST_F()
517 err = setsockopt(listener, SOL_IPV6, IPV6_FLOWLABEL_MGR, in TEST_F()
521 tcp_connect(listener, 8, &cfd, &afd); in TEST_F()
[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. Once the connection is accepted,
55 * lock_sock(listener);
69 * and the listener socket's pending list and connected queue) ensures a
505 void vsock_add_pending(struct sock *listener, struct sock *pending) in vsock_add_pending() argument
510 vlistener = vsock_sk(listener); in vsock_add_pending()
520 vsock_remove_pending(struct sock * listener,struct sock * pending) vsock_remove_pending() argument
531 vsock_pending_to_accept(struct sock * listener,struct sock * pending) vsock_pending_to_accept() argument
541 vsock_enqueue_accept(struct sock * listener,struct sock * connected) vsock_enqueue_accept() argument
745 vsock_dequeue_accept(struct sock * listener) vsock_dequeue_accept() argument
792 struct sock *listener; vsock_pending_work() local
1893 struct sock *listener; vsock_accept() local
[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()
1149 vpending->listener = sk; in vmci_transport_recv_listen()
1159 vmci_transport_recv_connecting_server(struct sock *listener, in vmci_transport_recv_connecting_server() argument
1280 vsock_pending_to_accept(listener, pending); in vmci_transport_recv_connecting_server()
1285 listener->sk_data_ready(listener); in vmci_transport_recv_connecting_server()
/linux/drivers/md/dm-vdo/
H A Dvdo.c713 struct read_only_listener *listener, *next; in free_listeners() local
715 for (listener = vdo_forget(thread->listeners); listener != NULL; listener = next) { in free_listeners()
716 next = vdo_forget(listener->next); in free_listeners()
717 vdo_free(listener); in free_listeners()
1121 int vdo_register_read_only_listener(struct vdo *vdo, void *listener, in vdo_register_read_only_listener() argument
1139 .listener = listener, in vdo_register_read_only_listener()
1157 static void notify_vdo_of_read_only_mode(void *listener, struct vdo_completion *parent) in notify_vdo_of_read_only_mode() argument
1159 struct vdo *vdo = listener; in notify_vdo_of_read_only_mode()
1275 struct read_only_listener *listener = completion->parent; in make_thread_read_only() local
1277 if (listener == NULL) { in make_thread_read_only()
[all …]
/linux/include/net/
H A Daf_vsock.h50 struct sock *listener; member
217 void vsock_add_pending(struct sock *listener, struct sock *pending);
218 void vsock_remove_pending(struct sock *listener, struct sock *pending);
219 void vsock_enqueue_accept(struct sock *listener, struct sock *connected);
220 void vsock_pending_to_accept(struct sock *listener, struct sock *pending);
H A Daf_unix.h43 struct sock *listener; member
/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/drivers/hid/
H A Dhid-asus.c171 struct asus_hid_listener listener; member
740 static void asus_kbd_backlight_set(struct asus_hid_listener *listener, int brightness) in asus_kbd_backlight_set() argument
742 struct asus_drvdata *drvdata = container_of(listener, struct asus_drvdata, listener); in asus_kbd_backlight_set()
972 drvdata->listener.brightness_set = asus_kbd_backlight_set; in asus_kbd_register_leds()
973 ret = asus_hid_register_listener(&drvdata->listener); in asus_kbd_register_leds()
976 drvdata->listener.brightness_set = NULL; in asus_kbd_register_leds()
1372 if (drvdata->listener.brightness_set) in asus_resume()
1373 asus_kbd_backlight_set(&drvdata->listener, drvdata->kbd_backlight_brightness); in asus_resume()
1539 if (drvdata->listener.brightness_set) in asus_probe()
1540 asus_hid_unregister_listener(&drvdata->listener); in asus_probe()
[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/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()
274 receiver->listener = NULL; in unix_update_edges()
277 unix_update_graph(unix_sk(receiver->listener)->vertex); in unix_update_edges()
278 receiver->listener = NULL; in unix_update_edges()
/linux/net/tipc/
H A Dtopsrv.c58 * @idr_lock: protect the connection identifier set and listener
64 * @listener: topsrv listener socket
75 struct socket *listener; member
221 if (!s->listener) { in tipc_conn_lookup()
312 if (!srv->listener) {
352 if (srv->listener) { in tipc_conn_write_space()
377 if (srv->listener) { in tipc_conn_rcv_sub()
452 if (!srv->listener) { in tipc_conn_data_ready()
487 if (srv->listener) { in tipc_topsrv_accept()
[all...]
/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/net/mptcp/
H A Dsubflow.c152 struct mptcp_subflow_context *listener = mptcp_subflow_ctx(sk_listener); in subflow_check_req() local
157 pr_debug("subflow_req=%p, listener=%p\n", subflow_req, listener); in subflow_check_req()
177 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
280 if (opt_mp_capable && listener->request_mptcp) { in mptcp_subflow_init_cookie_req()
291 } 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/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:
H A Dtcp_advmss_pmtu_ipv4.pkt37 // Close connection 1 and listener
H A Dtcp_advmss_pmtu_ipv6.pkt37 // Close connection 1 and listener
/linux/include/net/phonet/
H A Dpep.h24 struct sock *listener; member
/linux/fs/smb/smbdirect/
H A Dlisten.c284 nsc->accept.listener = lsc; in smbdirect_listen_connect_request()
296 nsc->accept.listener = NULL; in smbdirect_listen_connect_request()

12