Home
last modified time | relevance | path

Searched refs:addr (Results 1 - 25 of 59) sorted by relevance

123

/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/
H A Dsocket_addr.rs32 pub(crate) fn socket_addr_trans(addr: &SocketAddr) -> (SocketAddrLibC, socklen_t) {
33 match addr {
34 SocketAddr::V4(ref addr) => {
37 sin_port: addr.port().to_be(),
39 s_addr: u32::from_ne_bytes(addr.ip().octets()),
52 SocketAddr::V6(ref addr) => {
54 s6_addr: addr.ip().octets(),
59 sin6_port: addr.port().to_be(),
61 sin6_flowinfo: addr.flowinfo(),
62 sin6_scope_id: addr
[all...]
/commonlibrary/rust/ylong_runtime/ylong_runtime/benches/
H A Dylong_tokio_uds.rs26 pub async fn $server(addr: String) {
27 let uds = tokioUnixListener::bind(addr).unwrap();
39 pub async fn $client(addr: String) {
40 let mut uds = tokioUnixStream::connect(addr.clone()).await;
42 uds = tokioUnixStream::connect(addr.clone()).await;
61 let addr = $path.to_owned() + &i.to_string();
62 handlers.push(runtime.spawn($server(addr.clone())));
63 handlers.push(runtime.spawn($client(addr.clone())));
69 let addr = $path.to_owned() + &i.to_string();
70 std::fs::remove_file(addr)
[all...]
H A Dylong_tokio_tcp.rs25 pub async fn $server(addr: String) {
26 let tcp = tokioTcpListener::bind(addr).await.unwrap();
38 pub async fn $client(addr: String) {
39 let mut tcp = tokioTcpStream::connect(addr.clone()).await;
41 tcp = tokioTcpStream::connect(addr.clone()).await;
62 let addr = basic_addr.to_owned() + &*(port + i).to_string();
63 handlers.push(runtime.spawn($server(addr.clone())));
64 handlers.push(runtime.spawn($client(addr.clone())));
77 pub async fn $server(addr: SocketAddr) {
78 let tcp = TcpListener::bind(addr)
[all...]
/commonlibrary/rust/ylong_runtime/ylong_runtime/tests/
H A Dtcp_test.rs32 let addr = listener.local_addr().unwrap(); in sdv_tcp_ipv6_connect()
35 let mut stream = TcpStream::connect(addr).await; in sdv_tcp_ipv6_connect()
37 stream = TcpStream::connect(addr).await; in sdv_tcp_ipv6_connect()
83 let addr = listener.local_addr().unwrap(); in sdv_tcp_stream_try()
86 let mut stream = TcpStream::connect(addr).await; in sdv_tcp_stream_try()
88 stream = TcpStream::connect(addr).await; in sdv_tcp_stream_try()
118 let addr = listener.local_addr().unwrap(); in sdv_tcp_stream_basic()
121 let mut stream = TcpStream::connect(addr).await; in sdv_tcp_stream_basic()
123 stream = TcpStream::connect(addr).await; in sdv_tcp_stream_basic()
127 assert_eq!(stream.peer_addr().unwrap(), addr); in sdv_tcp_stream_basic()
[all...]
H A Dasync_buf_read.rs33 let addr = "127.0.0.1:8180"; in sdv_buf_reader_read_until()
34 let tcp = TcpListener::bind(addr).await.unwrap(); in sdv_buf_reader_read_until()
49 let addr = "127.0.0.1:8180"; in sdv_buf_reader_read_until()
50 let mut tcp = TcpStream::connect(addr).await; in sdv_buf_reader_read_until()
52 tcp = TcpStream::connect(addr).await; in sdv_buf_reader_read_until()
77 let addr = "127.0.0.1:8181"; in sdv_buf_reader_read_line()
78 let tcp = TcpListener::bind(addr).await.unwrap(); in sdv_buf_reader_read_line()
91 let addr = "127.0.0.1:8181"; in sdv_buf_reader_read_line()
92 let mut tcp = TcpStream::connect(addr).await; in sdv_buf_reader_read_line()
94 tcp = TcpStream::connect(addr) in sdv_buf_reader_read_line()
[all...]
H A Dasync_buf_write.rs31 let addr = "127.0.0.1:8184"; in sdv_buf_writer_write()
32 let tcp = TcpListener::bind(addr).await.unwrap(); in sdv_buf_writer_write()
42 let addr = "127.0.0.1:8184"; in sdv_buf_writer_write()
43 let mut tcp = TcpStream::connect(addr).await; in sdv_buf_writer_write()
45 tcp = TcpStream::connect(addr).await; in sdv_buf_writer_write()
70 let addr = "127.0.0.1:8185"; in sdv_buf_writer_write_vectored()
71 let tcp = TcpListener::bind(addr).await.unwrap(); in sdv_buf_writer_write_vectored()
81 let addr = "127.0.0.1:8185"; in sdv_buf_writer_write_vectored()
82 let mut tcp = TcpStream::connect(addr).await; in sdv_buf_writer_write_vectored()
84 tcp = TcpStream::connect(addr) in sdv_buf_writer_write_vectored()
[all...]
H A Dasync_read.rs64 let addr = "127.0.0.1:8186"; in sdv_buf_reader_read_to_string()
65 let tcp = TcpListener::bind(addr).await.unwrap(); in sdv_buf_reader_read_to_string()
75 let addr = "127.0.0.1:8186"; in sdv_buf_reader_read_to_string()
76 let mut tcp = TcpStream::connect(addr).await; in sdv_buf_reader_read_to_string()
78 tcp = TcpStream::connect(addr).await; in sdv_buf_reader_read_to_string()
H A Dudp_test.rs82 let (len, addr) = receiver.recv_from(&mut recv_buf[..]).await.unwrap(); in sdv_udp_send_to_recv_from()
84 assert_eq!(addr, sender_addr); in sdv_udp_send_to_recv_from()
399 let addr = ylong_runtime::futures::poll_fn(|cx| receiver.poll_recv_from(cx, &mut read)) in sdv_udp_send_to_recv_from_poll()
403 assert_eq!(addr, sender_addr); in sdv_udp_send_to_recv_from_poll()
432 let addr = ylong_runtime::futures::poll_fn(|cx| receiver.poll_peek_from(cx, &mut read)) in sdv_udp_send_to_peek_from_poll()
436 assert_eq!(addr, sender_addr); in sdv_udp_send_to_peek_from_poll()
503 let addr = std::net::Ipv4Addr::new(224, 0, 0, i); in sdv_udp_basic_v4()
504 if sender.join_multicast_v4(&addr, &interface).is_ok() { in sdv_udp_basic_v4()
505 multi_addr = Some(addr); in sdv_udp_basic_v4()
510 if let Some(addr) in sdv_udp_basic_v4()
[all...]
/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/
H A Dsocket_addr.rs34 pub(crate) fn socket_addr_trans(addr: &SocketAddr) -> (SocketAddrWin, i32) {
35 match addr {
36 SocketAddr::V4(ref addr) => {
39 in_addr_0.S_addr = u32::from_ne_bytes(addr.ip().octets());
45 sin_port: addr.port().to_be(),
56 SocketAddr::V6(ref addr) => {
59 u.Byte = addr.ip().octets();
65 si0.sin6_scope_id = addr.scope_id();
71 sin6_port: addr.port().to_be(),
72 sin6_flowinfo: addr
[all...]
/commonlibrary/memory_utils/libpurgeablemem/cpp/src/
H A Dux_page_table.cpp28 UxPageTable::UxPageTable(uint64_t addr, size_t len) in UxPageTable() argument
34 PMState err = InitUxPageTable(uxpt_, addr, len); /* dataPtr is aligned */ in UxPageTable()
56 void UxPageTable::GetUxpte(uint64_t addr, size_t len) in GetUxpte() argument
58 UxpteGet(uxpt_, addr, len); in GetUxpte()
61 void UxPageTable::PutUxpte(uint64_t addr, size_t len) in PutUxpte() argument
63 UxptePut(uxpt_, addr, len); in PutUxpte()
67 bool UxPageTable::CheckPresent(uint64_t addr, size_t len) in CheckPresent() argument
69 return UxpteIsPresent(uxpt_, addr, len); in CheckPresent()
/commonlibrary/memory_utils/libpurgeablemem/common/src/
H A Dux_page_table_c.c139 static void GetUxpteAt(UxPageTableStruct *upt, uint64_t addr);
140 static void PutUxpteAt(UxPageTableStruct *upt, uint64_t addr);
141 static bool IsPresentAt(UxPageTableStruct *upt, uint64_t addr);
142 static PMState UxpteOps(UxPageTableStruct *upt, uint64_t addr, size_t len, enum UxpteOp op);
193 PMState InitUxPageTable(UxPageTableStruct *upt, uint64_t addr, size_t len) in InitUxPageTable() argument
203 upt->dataAddr = addr; in InitUxPageTable()
209 UxpteClear(upt, addr, len); in InitUxPageTable()
238 void UxpteGet(UxPageTableStruct *upt, uint64_t addr, size_t len) in UxpteGet() argument
243 UxpteOps(upt, addr, len, UPT_GET); in UxpteGet()
246 void UxptePut(UxPageTableStruct *upt, uint64_t addr, size_ argument
254 UxpteClear(UxPageTableStruct *upt, uint64_t addr, size_t len) UxpteClear() argument
262 UxpteIsPresent(UxPageTableStruct *upt, uint64_t addr, size_t len) UxpteIsPresent() argument
327 GetUxpteAt(UxPageTableStruct *upt, uint64_t addr) GetUxpteAt() argument
340 PutUxpteAt(UxPageTableStruct *upt, uint64_t addr) PutUxpteAt() argument
353 ClearUxpteAt(UxPageTableStruct *upt, uint64_t addr) ClearUxpteAt() argument
363 IsPresentAt(UxPageTableStruct *upt, uint64_t addr) IsPresentAt() argument
373 UxpteOps(UxPageTableStruct *upt, uint64_t addr, size_t len, enum UxpteOp op) UxpteOps() argument
454 InitUxPageTable(UxPageTableStruct *upt, uint64_t addr, size_t len) InitUxPageTable() argument
464 UxpteGet(UxPageTableStruct *upt, uint64_t addr, size_t len) UxpteGet() argument
466 UxptePut(UxPageTableStruct *upt, uint64_t addr, size_t len) UxptePut() argument
468 UxpteIsPresent(UxPageTableStruct *upt, uint64_t addr, size_t len) UxpteIsPresent() argument
[all...]
/commonlibrary/rust/ylong_runtime/ylong_runtime/examples/
H A Dylong_runtime_tcp.rs24 async fn ylong_tcp_server(addr: SocketAddr) {
25 let tcp = TcpListener::bind(addr).await.unwrap();
37 async fn ylong_tcp_client(addr: SocketAddr) {
38 let mut tcp = TcpStream::connect(addr).await;
40 tcp = TcpStream::connect(addr).await;
58 let addr = (basic_addr.to_owned() + &*(port + i).to_string()) in ylong_tcp_send_recv()
61 handlers.push(ylong_runtime::spawn(ylong_tcp_server(addr))); in ylong_tcp_send_recv()
62 handlers.push(ylong_runtime::spawn(ylong_tcp_client(addr))); in ylong_tcp_send_recv()
/commonlibrary/memory_utils/libpurgeablemem/common/include/
H A Dux_page_table_c.h36 PMState InitUxPageTable(UxPageTableStruct *upt, uint64_t addr, size_t len);
39 void UxpteGet(UxPageTableStruct *upt, uint64_t addr, size_t len);
40 void UxptePut(UxPageTableStruct *upt, uint64_t addr, size_t len);
41 void UxpteClear(UxPageTableStruct *upt, uint64_t addr, size_t len);
42 bool UxpteIsPresent(UxPageTableStruct *upt, uint64_t addr, size_t len);
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/
H A Dudp.rs45 /// let (len, addr) = receiver.recv_from(&mut buf).await?;
46 /// println!("{:?} bytes received from {:?}", len, addr);
109 /// let addr = "127.0.0.1:8080";
110 /// let mut sock = UdpSocket::bind(addr).await?;
114 pub async fn bind<A: ToSocketAddrs>(addr: A) -> io::Result<Self> {
115 super::addr::each_addr(addr, ylong_io::UdpSocket::bind)
164 pub async fn connect<A: ToSocketAddrs>(self, addr: A) -> io::Result<ConnectedUdpSocket> {
168 let addrs = addr.to_socket_addrs().await?;
172 for addr i
[all...]
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/util/
H A Dslab.rs188 if let Some((addr, val)) = Page::allocate(page) { in allocate()
189 return Some((addr, val)); in allocate()
213 pub fn get(&mut self, addr: Address) -> Option<&T> { in get()
214 let page_idx = addr.page(); in get()
215 let slot_idx = self.pages[page_idx].slot(addr); in get()
306 fn slot(&self, addr: Address) -> usize { in slot()
307 addr.0 - self.prev_len in slot()
311 fn addr(&self, slot: usize) -> Address { in addr() functions
349 Some((me.addr(idx), slot.gen_ref(me))) in allocate()
372 Some((me.addr(id in allocate()
[all...]
/commonlibrary/rust/ylong_runtime/ylong_io/examples/
H A Dylong_io_tcp_client.rs25 let addr = "127.0.0.1:1234".parse().unwrap(); in main()
27 let mut stream = match TcpStream::connect(addr) { in main()
32 Ok(addr) => addr, in main()
/commonlibrary/rust/ylong_http/ylong_http_client/tests/tcp_server/
H A Dmod.rs23 pub addr: String,
77 let addr = server.local_addr().expect("failed to get server address !");
79 addr: addr.to_string(),
96 format!("{} http://{}{} {}{}", $method, addr.to_string().as_str(), $path, $req_version, crlf)
103 let host = format_header_str("host", addr.to_string().as_str());
180 let addr = server.local_addr().expect("failed to get server address !");
206 let host = format_header_str("host", addr.to_string().as_str());
243 addr: addr
[all...]
/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/tcp/
H A Dlistener.rs37 pub fn bind(addr: SocketAddr) -> io::Result<TcpListener> { in bind()
38 let socket = TcpSocket::new_socket(addr)?; in bind()
43 socket.bind(addr)?; in bind()
57 let mut addr: MaybeUninit<sockaddr_storage> = MaybeUninit::uninit(); in accept() variables
63 addr.as_mut_ptr().cast::<_>(), in accept()
76 addr.as_mut_ptr() as *mut _, in accept()
86 let ret = unsafe { trans_addr_2_socket(addr.as_ptr()) }; in accept()
101 /// let addr = "127.0.0.1:1234".parse().unwrap();
102 /// let mut server = TcpListener::bind(addr).unwrap();
116 /// let addr
[all...]
/commonlibrary/rust/ylong_runtime/ylong_io/tests/
H A Dtcp_test.rs28 let addr: SocketAddr = "127.0.0.1:0".parse().unwrap(); in sdv_tcp_server()
29 let server = TcpListener::bind(addr).unwrap(); in sdv_tcp_server()
30 let addr = server.local_addr().unwrap(); in sdv_tcp_server()
73 let tcp = net::TcpStream::connect(addr); in sdv_tcp_server()
98 let addr: SocketAddr = "127.0.0.1:0".parse().unwrap(); in sdv_tcp_server_vectored()
99 let server = TcpListener::bind(addr).unwrap(); in sdv_tcp_server_vectored()
100 let addr = server.local_addr().unwrap(); in sdv_tcp_server_vectored()
147 let tcp = net::TcpStream::connect(addr); in sdv_tcp_server_vectored()
/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/tcp/
H A Dlistener.rs40 /// let addr = "127.0.0.1:1234".parse().unwrap();
41 /// let server = TcpListener::bind(addr).unwrap();
43 pub fn bind(addr: SocketAddr) -> io::Result<TcpListener> { in bind()
44 let socket = TcpSocket::new_socket(addr)?; in bind()
47 socket.bind(addr)?; in bind()
68 /// let addr = "127.0.0.1:1234".parse().unwrap();
69 /// let mut server = TcpListener::bind(addr).unwrap();
75 .map(|(stream, addr)| (TcpStream::from_std(stream), addr)) in accept()
85 /// let addr
[all...]
/commonlibrary/memory_utils/libpurgeablemem/cpp/include/
H A Dux_page_table.h34 void GetUxpte(uint64_t addr, size_t len);
35 void PutUxpte(uint64_t addr, size_t len);
36 bool CheckPresent(uint64_t addr, size_t len);
/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/udp/
H A Dsocket.rs29 pub(crate) fn new_socket(addr: SocketAddr) -> io::Result<UdpSock> {
30 if addr.is_ipv4() {
44 pub(crate) fn bind(self, addr: SocketAddr) -> io::Result<UdpSocket> {
48 let (raw_addr, addr_length) = socket_addr_trans(&addr);
/commonlibrary/rust/ylong_runtime/ylong_runtime/benches/bin/
H A Dylong_runtime_tcp_server_perf.rs26 let addr = "127.0.0.1:8080"; in main()
27 let server = match TcpListener::bind(addr).await { in main()
34 Ok((stream, addr)) => (stream, addr), in main()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/tcp/
H A Dsplit.rs136 let addr = listener.local_addr().unwrap(); in poll_flush()
139 let mut stream = TcpStream::connect(addr).await; in poll_flush()
141 stream = TcpStream::connect(addr).await; in poll_flush()
182 let addr = listener.local_addr().unwrap(); in poll_flush()
185 let mut stream = TcpStream::connect(addr).await; in poll_flush()
187 stream = TcpStream::connect(addr).await; in poll_flush()
229 let addr = listener.local_addr().unwrap(); in poll_flush()
232 let mut stream = TcpStream::connect(addr).await; in poll_flush()
234 stream = TcpStream::connect(addr).await; in poll_flush()
279 let addr in poll_flush()
[all...]
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/
H A Dtest_utils.rs19 pub addr: String,
38 Addr: $addr: expr,
48 .url(format!("http://{}{}",$addr, $path).as_str())
83 let addr = server.local_addr().expect("failed to get server address !");
85 addr: addr.to_string(),

Completed in 8 milliseconds

123