Home
last modified time | relevance | path

Searched full:listen (Results 1 – 25 of 330) sorted by relevance

12345678910>>...14

/linux/fs/smb/smbdirect/
H A Dlisten.c33 "try to listen on addr: %pISpsfc dev: %.*s\n", in smbdirect_socket_listen()
39 "try to listen on addr: %pISpsfc\n", in smbdirect_socket_listen()
71 * so we are able to use sc->listen.backlog == -1, in smbdirect_socket_listen()
75 sc->listen.backlog = backlog; in smbdirect_socket_listen()
214 size_t backlog = max_t(size_t, 1, lsc->listen.backlog); in smbdirect_listen_connect_request()
254 spin_lock_irqsave(&lsc->listen.lock, flags); in smbdirect_listen_connect_request()
255 psockets = list_count_nodes(&lsc->listen.pending); in smbdirect_listen_connect_request()
256 rsockets = list_count_nodes(&lsc->listen.ready); in smbdirect_listen_connect_request()
257 spin_unlock_irqrestore(&lsc->listen.lock, flags); in smbdirect_listen_connect_request()
264 lsc->listen.backlog, backlog, psockets, rsockets); in smbdirect_listen_connect_request()
[all …]
H A Dsocket.c252 wake_up_all(&sc->listen.wait_queue); in smbdirect_socket_wake_up_all()
309 spin_lock_irqsave(&sc->listen.lock, flags); in __smbdirect_socket_schedule_cleanup()
310 list_splice_init(&sc->listen.ready, &sc->listen.pending); in __smbdirect_socket_schedule_cleanup()
311 list_for_each_entry_safe(psc, tsc, &sc->listen.pending, accept.list) in __smbdirect_socket_schedule_cleanup()
313 spin_unlock_irqrestore(&sc->listen.lock, flags); in __smbdirect_socket_schedule_cleanup()
409 spin_lock_irqsave(&sc->listen.lock, flags); in smbdirect_socket_cleanup_work()
410 list_splice_init(&sc->listen.ready, &sc->listen.pending); in smbdirect_socket_cleanup_work()
411 list_for_each_entry_safe(psc, tsc, &sc->listen.pending, accept.list) in smbdirect_socket_cleanup_work()
413 spin_unlock_irqrestore(&sc->listen.lock, flags); in smbdirect_socket_cleanup_work()
534 spin_lock_irqsave(&sc->listen.lock, flags); in smbdirect_socket_destroy()
[all …]
H A Daccept.c460 spin_lock_irqsave(&lsc->listen.lock, flags); in smbdirect_accept_negotiate_recv_work()
462 list_add_tail(&sc->accept.list, &lsc->listen.ready); in smbdirect_accept_negotiate_recv_work()
463 wake_up(&lsc->listen.wait_queue); in smbdirect_accept_negotiate_recv_work()
464 spin_unlock_irqrestore(&lsc->listen.lock, flags); in smbdirect_accept_negotiate_recv_work()
777 ret = wait_event_interruptible_timeout(lsc->listen.wait_queue, in smbdirect_socket_wait_for_accept()
778 !list_empty_careful(&lsc->listen.ready) || in smbdirect_socket_wait_for_accept()
811 if (list_empty_careful(&lsc->listen.ready)) { in smbdirect_socket_accept()
826 spin_lock_irqsave(&lsc->listen.lock, flags); in smbdirect_socket_accept()
827 nsc = list_first_entry_or_null(&lsc->listen.ready, in smbdirect_socket_accept()
833 arg->is_empty = list_empty_careful(&lsc->listen.ready); in smbdirect_socket_accept()
[all …]
/linux/tools/testing/selftests/bpf/prog_tests/
H A Dmigrate_reuseport.c5 * 1. call listen() for 4 server sockets.
7 * 3. call listen() for 1 server socket. (migration target)
17 * 8. call listen() for the second server socket.
21 * 10. call listen() for the last server.
274 err = listen(test_case->servers[i], qlen); in start_servers()
275 if (!ASSERT_OK(err, "listen")) in start_servers()
408 * calling listen() again will bind() the first listener in count_requests()
413 * and SOCK_BINDPORT_LOCK is set. Thus, re-listen() will in count_requests()
416 err = listen(test_case->servers[1], QLEN); in count_requests()
417 if (!ASSERT_OK(err, "listen")) in count_requests()
[all...]
H A Dsockopt_inherit.c47 err = listen(fd, 1); in server_thread()
56 err += verify_sockopt(fd, CUSTOM_INHERIT1, "listen", 1); in server_thread()
57 err += verify_sockopt(fd, CUSTOM_INHERIT2, "listen", 1); in server_thread()
58 err += verify_sockopt(fd, CUSTOM_LISTENER, "listen", 1); in server_thread()
H A Dskc_to_unix_sock.c44 err = listen(sockfd, 1); in test_skc_to_unix_sock()
45 if (!ASSERT_OK(err, "listen failed")) in test_skc_to_unix_sock()
/linux/tools/testing/selftests/net/tcp_ao/
H A Dkey-management.c60 if (listen(sk, 10)) in prepare_lsk()
61 test_error("listen()"); in prepare_lsk()
303 if (listen(sk, 10)) in assert_no_tcp_repair()
304 test_error("listen()"); in assert_no_tcp_repair()
308 test_ok("listen socket, getsockopt(TCP_AO_REPAIR) is restricted"); in assert_no_tcp_repair()
310 test_fail("listen socket, getsockopt(TCP_AO_REPAIR) works"); in assert_no_tcp_repair()
314 test_ok("listen socket, setsockopt(TCP_AO_REPAIR) is restricted"); in assert_no_tcp_repair()
316 test_fail("listen socket, setsockopt(TCP_AO_REPAIR) works"); in assert_no_tcp_repair()
325 try_delete_key("listen socket, delete a key", sk, 200, 200, 0, -1, -1, 0); in check_listen_socket()
326 try_delete_key("listen socke in check_listen_socket()
[all...]
H A Dsetsockopt-closed.c19 if (listen(sk, 1)) in make_listen()
20 test_error("listen()"); in make_listen()
329 setsockopt_checked(sk, TCP_AO_ADD_KEY, &ao, EINVAL, "add current key on a listen socket"); in test_einval_add_key()
334 setsockopt_checked(sk, TCP_AO_ADD_KEY, &ao, EINVAL, "add rnext key on a listen socket"); in test_einval_add_key()
340 setsockopt_checked(sk, TCP_AO_ADD_KEY, &ao, EINVAL, "add current+rnext key on a listen socket"); in test_einval_add_key()
399 setsockopt_checked(sk, TCP_AO_DEL_KEY, &del, EINVAL, "del and set current key on a listen socket"); in test_einval_del_key()
406 setsockopt_checked(sk, TCP_AO_DEL_KEY, &del, EINVAL, "del and set rnext key on a listen socket"); in test_einval_del_key()
414 …setsockopt_checked(sk, TCP_AO_DEL_KEY, &del, EINVAL, "del and set current+rnext key on a listen so… in test_einval_del_key()
481 setsockopt_checked(sk, TCP_AO_DEL_KEY, &del, EINVAL, "async on non-listen"); in test_einval_del_key()
507 setsockopt_checked(sk, TCP_AO_INFO, &info, EINVAL, "set current key on a listen socket"); in test_einval_ao_info()
[all …]
/linux/tools/testing/selftests/net/mptcp/
H A Ddiag.sh146 __chk_nr "ss -N $ns -Ml '$filter' | grep -c LISTEN" "$expected" "$msg" 0
154 __chk_listen "dport $lport" 0 "listen match for dport $lport"
156 # should return 'our' mptcp listen socket
157 __chk_listen "sport $lport" 1 "listen match for sport $lport"
159 __chk_listen "src inet:0.0.0.0:$lport" 1 "listen match for saddr and sport"
161 __chk_listen "" 1 "all listen sockets"
176 listen_nr=$(ss -N "${ns}" -Ml | grep -c LISTEN)
/linux/include/xen/interface/io/
H A Dpvcalls.h10 /* "1" means socket, connect, release, bind, listen, accept and poll */
69 } listen; member
107 } listen; member
/linux/tools/testing/selftests/net/
H A Dstress_reuseport_listen.sh22 # 300 different vips listen on port 443
23 # Each vip:443 sockaddr has 80 LISTEN sock by using SO_REUSEPORT
H A Dreuseaddr_conflict.c76 if (listen(fd, 1) < 0) { in open_port()
77 perror("listen"); in open_port()
94 error(1, errno, "Couldn't open listen socket"); in main()
H A Dstress_reuseport_listen.c87 err = listen(lfds[i], 0); in main()
89 error(1, errno, "listen(lfds[%d])", i); in main()
96 printf("listen %d socks took %lu.%lu\n", nr_lsocks, in main()
H A Dreuseaddr_ports_exhausted.c149 ret = listen(fd[0], 5); in TEST()
150 ASSERT_EQ(0, ret) TH_LOG("failed to listen."); in TEST()
152 ret = listen(fd[1], 5); in TEST()
153 …EXPECT_EQ(-1, ret) TH_LOG("should fail to listen because only one uid reserves the port in TCP_LIS… in TEST()
H A Dsk_connect_zero_addr.c37 if (listen(fd1, 0)) { in main()
38 error(1, errno, "listen"); in main()
H A Dsk_bind_sendto_listen.c65 if (listen(fd2, 0)) { in main()
66 error(1, errno, "listen"); in main()
H A Dtcp_port_share.c88 /* IP to listen on and connect to */ in FIXTURE_VARIANT()
141 /* Listen on <dst_ip>:<DST_PORT> */ in TEST_F()
148 ASSERT_EQ(listen(ln, 2), 0); in TEST_F()
203 /* Listen on <dst_ip>:<DST_PORT> */ in TEST_F()
210 ASSERT_EQ(listen(ln, 2), 0); in TEST_F()
H A Dreuseport_addr_any.c82 if (proto == SOCK_STREAM && listen(rcv_fds[i], 10)) in build_rcv_fd()
83 error(1, errno, "tcp: failed to listen on receive port"); in build_rcv_fd()
/linux/drivers/net/wireless/ath/ath5k/
H A Dani.c377 int listen; in ath5k_hw_ani_get_listen_time() local
385 listen = ath_hw_get_listen_time(common); in ath5k_hw_ani_get_listen_time()
389 return listen; in ath5k_hw_ani_get_listen_time()
467 * receive ("listen" time) and raise or lower immunity accordingly.
478 int listen, ofdm_high, ofdm_low, cck_high, cck_low; in ath5k_ani_calibration() local
480 /* get listen time since last call and add it to the counter because we in ath5k_ani_calibration()
483 listen = ath5k_hw_ani_get_listen_time(ah, as); in ath5k_ani_calibration()
484 as->listen_time += listen; in ath5k_ani_calibration()
497 "listen %d (now %d)", as->listen_time, listen); in ath5k_ani_calibration()
/linux/drivers/net/wireless/ath/wil6210/
H A Dp2p.c152 wil_dbg_misc(wil, "Delaying p2p listen until scan done\n"); in wil_p2p_listen()
216 wil_err(wil, "listen not started\n"); in wil_p2p_cancel_listen()
302 wil_dbg_misc(wil, "Checking delayed p2p listen\n"); in wil_p2p_delayed_listen_work()
360 /* Search or listen on p2p device */ in wil_p2p_stop_radio_operations()
370 /* listen */ in wil_p2p_stop_radio_operations()
/linux/tools/testing/selftests/net/netfilter/
H A Dnft_queue.sh279 timeout 5 ip netns exec "$ns2" socat -u TCP-LISTEN:12345 STDOUT >/dev/null &
295 timeout 5 ip netns exec "$nsrouter" socat -u TCP-LISTEN:12345 STDOUT >/dev/null &
339 timeout 5 ip netns exec "$nsrouter" socat -u TCP-LISTEN:12345 STDOUT >/dev/null &
460 timeout "$SCTP_TEST_TIMEOUT" ip netns exec "$ns2" socat -u SCTP-LISTEN:12345 STDOUT > "$TMPFILE1" &
495 timeout "$SCTP_TEST_TIMEOUT" ip netns exec "$ns2" socat -u SCTP-LISTEN:12345 STDOUT > "$TMPFILE1" &
546 timeout 10 ip netns exec "$ns2" socat UDP-LISTEN:12345,fork,pf=ipv4 OPEN:"$TMPFILE1",trunc &
549 timeout 10 ip netns exec "$ns3" socat UDP-LISTEN:12345,fork,pf=ipv4 OPEN:"$TMPFILE2",trunc &
641 timeout "$timeout" ip netns exec "$ns2" socat UDP-LISTEN:12346,fork,pf=ipv4 OPEN:"$TMPFILE1",trunc &
763 socat -u UDP-LISTEN:12345,fork,pf=ipv4 STDOUT > /dev/null &
766 socat -u UDP-LISTEN
[all...]
/linux/tools/testing/vsock/
H A Dvsock_diag_test.c61 return "LISTEN"; in sock_state_str()
362 if (listen(fd, 1) < 0) { in test_listen_socket_server()
363 perror("listen"); in test_listen_socket_server()
433 .name = "Listen socket",
502 "listen address and the client requires an address to\n" in usage()
510 " --control-port <port> Server port to listen on/connect to\n" in usage()
/linux/tools/testing/selftests/drivers/net/
H A Dnapi_id_helper.c66 if (listen(server, 1) < 0) { in main()
67 perror("listen"); in main()
/linux/net/nfc/nci/
H A Dntf.c568 struct activation_params_listen_nfc_dep *listen; in nci_extract_activation_params_nfc_dep() local
583 listen = &ntf->activation_params.listen_nfc_dep; in nci_extract_activation_params_nfc_dep()
584 listen->atr_req_len = min_t(__u8, *data++, in nci_extract_activation_params_nfc_dep()
586 pr_debug("atr_req_len %d\n", listen->atr_req_len); in nci_extract_activation_params_nfc_dep()
587 if (listen->atr_req_len > 0) in nci_extract_activation_params_nfc_dep()
588 memcpy(listen->atr_req, data, listen->atr_req_len); in nci_extract_activation_params_nfc_dep()
725 goto listen; in nci_rf_intf_activated_ntf_packet()
873 listen: in nci_rf_intf_activated_ntf_packet()
874 /* Listen mode */ in nci_rf_intf_activated_ntf_packet()
/linux/tools/testing/selftests/landlock/
H A Dscoped_abstract_unix_test.c151 ASSERT_EQ(0, listen(stream_server, backlog)); in TEST_F()
217 ASSERT_EQ(0, listen(stream_server, backlog)); in TEST_F()
244 /* Waits for the child to listen */ in TEST_F()
409 /* Waits for the child to listen */ in FIXTURE_TEARDOWN()
601 ASSERT_EQ(0, listen(stream_server_child, backlog)); in FIXTURE_VARIANT_ADD()
628 ASSERT_EQ(0, listen(stream_server_parent, backlog)); in FIXTURE_SETUP()
731 ASSERT_EQ(0, listen(stream_server, backlog)); in TEST_F()
781 ASSERT_EQ(0, listen(server_socket, backlog)); in TEST_F()
887 /* Waits for parent to listen. */ in TEST_F()
970 ASSERT_EQ(0, listen(stream_pathname_socke in TEST_F()
[all...]

12345678910>>...14