| /commonlibrary/c_utils/base/test/unittest/common/ |
| D | utils_rwlock_test.cpp | 75 thread first(bind(&TestRWLock::WriteStr, ref(test), ref(WRITE_IN_1)));
79 thread second(bind(&TestRWLock::ReadStr, ref(test), ref(readOut1)));
80 thread third(bind(&TestRWLock::WriteStr, ref(test), ref(WRITE_IN_2)));
82 thread fourth(bind(&TestRWLock::ReadStr, ref(test), ref(readOut2)));
104 thread first(bind(&TestRWLock::WriteStr, ref(test), ref(WRITE_IN_1)));
108 thread second(bind(&TestRWLock::ReadStr, ref(test), ref(readOut1)));
109 thread third(bind(&TestRWLock::WriteStr, ref(test), ref(WRITE_IN_2)));
111 thread fourth(bind(&TestRWLock::ReadStr, ref(test), ref(readOut2)));
|
| D | utils_thread_pool_test.cpp | 130 auto task = std::bind(TestFuncAddOneTime, i);
136 auto task = std::bind(TestFuncSubOneTime, i);
160 auto task = std::bind(TestFuncAddOneTime, i);
166 auto task = std::bind(TestFuncSubOneTime, i);
208 auto task = std::bind(TestFuncAddWait, i);
214 auto task = std::bind(TestFuncSubWait, i);
246 auto task = std::bind(TestFuncAddWait, i);
252 auto task = std::bind(TestFuncSubWait, i);
300 auto task = std::bind(TestFuncGetName, poolName);
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/benches/ |
| D | ylong_tokio_udp.rs | 45 let sender = UdpSocket::bind(sender_addr).await.unwrap(); in ylong_udp_connect()
65 let sender = tokioUdpSocket::bind(sender_addr).await.unwrap(); in tokio_udp_connect()
97 let sender = UdpSocket::bind(sender_addr).await.unwrap(); in ylong_udp_send_recv()
98 let receiver = UdpSocket::bind(receiver_addr).await.unwrap(); in ylong_udp_send_recv()
138 let sender = tokioUdpSocket::bind(sender_addr.clone()).await.unwrap(); in tokio_udp_send_recv()
139 let receiver = tokioUdpSocket::bind(receiver_addr.clone()).await.unwrap(); in tokio_udp_send_recv()
183 let sender = UdpSocket::bind(sender_addr).await.unwrap(); in ylong_udp_send_to_recv_from()
184 let receiver = UdpSocket::bind(receiver_addr).await.unwrap(); in ylong_udp_send_to_recv_from()
220 let sender = tokioUdpSocket::bind(sender_addr.clone()).await.unwrap(); in tokio_udp_send_to_recv_from()
221 let receiver = tokioUdpSocket::bind(receiver_addr.clone()).await.unwrap(); in tokio_udp_send_to_recv_from()
|
| D | ylong_tokio_tcp.rs | 26 let tcp = tokioTcpListener::bind(addr).await.unwrap();
78 let tcp = TcpListener::bind(addr).await.unwrap();
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/tests/ |
| D | udp_test.rs | 32 let sender = match UdpSocket::bind(sender_addr).await { in sdv_udp_send_recv()
39 let receiver = match UdpSocket::bind(receiver_addr).await { in sdv_udp_send_recv()
88 let sender = match UdpSocket::bind(sender_addr).await { in sdv_udp_send_to_recv_from()
95 let receiver = match UdpSocket::bind(receiver_addr).await { in sdv_udp_send_to_recv_from()
123 let sender = match UdpSocket::bind(sender_addr).await { in sdv_udp_send()
162 let receiver = match UdpSocket::bind(receiver_addr).await { in sdv_udp_recv()
197 let sender = match UdpSocket::bind(sender_addr).await { in sdv_udp_try_recv_from()
204 let receiver = match UdpSocket::bind(receiver_addr).await { in sdv_udp_try_recv_from()
242 let sender = match UdpSocket::bind(sender_addr).await { in sdv_udp_try_send()
284 let receiver = match UdpSocket::bind(receiver_addr).await { in sdv_udp_try_recv()
[all …]
|
| D | tcp_test.rs | 60 let listener = TcpListener::bind(addr).await; in sdv_tcp_global_runtime()
109 let tcp = TcpListener::bind(addr).await.unwrap(); in sdv_tcp_multi_runtime()
149 let tcp = TcpListener::bind("127.0.0.1:8200").await.unwrap(); in sdv_tcp_drop_out_context()
|
| D | async_buf_read.rs | 34 let tcp = TcpListener::bind(addr).await.unwrap(); in sdv_buf_reader_read_until()
78 let tcp = TcpListener::bind(addr).await.unwrap(); in sdv_buf_reader_read_line()
119 let tcp = TcpListener::bind(addr).await.unwrap(); in sdv_buf_reader_split()
158 let tcp = TcpListener::bind(addr).await.unwrap(); in sdv_buf_reader_lines()
|
| D | async_buf_write.rs | 32 let tcp = TcpListener::bind(addr).await.unwrap(); in sdv_buf_writer_write()
71 let tcp = TcpListener::bind(addr).await.unwrap(); in sdv_buf_writer_write_vectored()
|
| D | async_read.rs | 65 let tcp = TcpListener::bind(addr).await.unwrap(); in sdv_buf_reader_read_to_string()
|
| /commonlibrary/rust/ylong_runtime/ylong_io/tests/ |
| D | udp_socket_test.rs | 30 let sender = match UdpSocket::bind(sender_addr) { in test_send_recv()
37 let receiver = match UdpSocket::bind(receiver_addr) { in test_send_recv()
90 let sender = match UdpSocket::bind(sender_addr) { in test_send_to_recv_from()
97 let receiver = match UdpSocket::bind(receiver_addr) { in test_send_to_recv_from()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/ |
| D | udp.rs | 116 pub async fn bind<A: ToSocketAddrs>(addr: A) -> io::Result<Self> { in bind() method
117 super::addr::each_addr(addr, ylong_io::UdpSocket::bind) in bind()
175 let socket = ylong_io::UdpSocket::bind(local_addr)?; in connect()
1469 let sender = UdpSocket::bind(sender_addr).await.unwrap(); in ut_udp_basic_v4()
1470 let receiver = UdpSocket::bind(receiver_addr).await.unwrap(); in ut_udp_basic_v4()
1516 let sender = UdpSocket::bind(sender_addr).await.unwrap(); in ut_udp_basic_v6()
1517 let receiver = UdpSocket::bind(receiver_addr).await.unwrap(); in ut_udp_basic_v6()
1542 let sender = match UdpSocket::bind(sender_addr).await { in test_send_recv_poll()
1549 let receiver = match UdpSocket::bind(receiver_addr).await { in test_send_recv_poll()
1603 let sender = match UdpSocket::bind(sender_addr).await { in test_send_to_recv_from_poll()
[all …]
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/tcp/ |
| D | listener.rs | 71 pub async fn bind<A: ToSocketAddrs>(addr: A) -> io::Result<TcpListener> { in bind() method
72 super::super::addr::each_addr(addr, ylong_io::TcpListener::bind) in bind()
239 let server = TcpListener::bind(addr).await.unwrap(); in ut_tcp_listener_basic()
|
| D | split.rs | 136 let listener = TcpListener::bind(addr).await.unwrap(); in ut_test_borrow_half()
190 let listener = TcpListener::bind(addr).await.unwrap(); in ut_test_owned_half()
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/tcp/ |
| D | socket.rs | 61 pub(crate) fn bind(&self, addr: SocketAddr) -> io::Result<()> { in bind() method
62 use WinSock::bind; in bind()
66 bind(self.socket as _, raw_addr.as_ptr(), raw_addr_length), in bind()
|
| D | listener.rs | 43 pub fn bind(addr: SocketAddr) -> io::Result<TcpListener> { in bind() method
47 socket.bind(addr)?; in bind()
|
| /commonlibrary/c_utils/docs/zh-cn/ |
| D | c-utils-guide-safe_block_queue.md | 94 thread producer(bind(&ProductsLine::Produce, ref(line)));
97 thread consumer(bind(&ProductsLine::Consume, ref(line)));
162 thread producer(bind(&ProductsLine::Produce, ref(line)));
165 thread consumer(bind(&ProductsLine::Consume, ref(line)));
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/linux/udp/ |
| D | socket.rs | 46 pub(crate) fn bind(self, addr: SocketAddr) -> io::Result<UdpSocket> { in bind() method
48 match syscall!(bind(self.socket, raw_addr.as_ptr(), addr_length)) { in bind()
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/udp/ |
| D | socket.rs | 20 bind as win_bind, closesocket, ioctlsocket, socket, ADDRESS_FAMILY, AF_INET, AF_INET6, FIONBIO,
61 pub(crate) fn bind(self, addr: SocketAddr) -> io::Result<net::UdpSocket> { in bind() method
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/linux/tcp/ |
| D | socket.rs | 65 pub(crate) fn bind(&self, addr: SocketAddr) -> io::Result<()> { in bind() method
67 match syscall!(bind(self.socket, raw_addr.as_ptr(), addr_length)) { in bind()
|
| D | listener.rs | 37 pub fn bind(addr: SocketAddr) -> io::Result<TcpListener> { in bind() method
40 socket.bind(addr)?; in bind()
|
| /commonlibrary/c_utils/base/src/ |
| D | timer.cpp | 38 std::thread loop_thread(std::bind(&Timer::MainLoop, this)); in Setup()
82 …uint32_t ret = DoRegister(std::bind(&Timer::OnTimer, this, std::placeholders::_1), interval, once,… in Register()
153 std::function<void(int)> cb = std::bind(&Timer::DoTimerListCallback, this, callback, _1); in DoRegister()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/benches/bin/ |
| D | ylong_tokio_tcp_perf.rs | 114 let listener = TcpListener::bind(addr).await.unwrap(); in main()
158 let listener = tokioTcpListener::bind("127.0.0.1:9082").await.unwrap(); in main()
|
| D | ylong_runtime_tcp_server_perf.rs | 27 let server = match TcpListener::bind(addr).await { in main()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/ |
| D | select.rs | 175 $( ( $index:expr, $($_i:tt)* ) $bind:pat = $fut:expr, if $c:expr => $handle:expr, )+
232 $bind => {
265 … $crate::tuple_form!(($count) with Out::Fail except Out::Finish($bind) at ($($_i)*)) => $handle,
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/examples/ |
| D | ylong_runtime_tcp.rs | 25 let tcp = TcpListener::bind(addr).await.unwrap(); in ylong_tcp_server()
|