Home
last modified time | relevance | path

Searched refs:src_port (Results 1 – 25 of 83) sorted by relevance

1234

/external/rust/android-crates-io/crates/virtio-drivers-and-devices/src/device/socket/
Dconnectionmanager.rs71 fn connect(&mut self, destination: VsockAddr, src_port: u32) -> Result; in connect()
74 fn send(&mut self, dest: VsockAddr, src_port: u32, buffer: &[u8]) -> Result; in send()
77 fn update_credit(&mut self, peer: VsockAddr, src_port: u32) -> Result; in update_credit()
80 fn force_close(&mut self, dest: VsockAddr, src_port: u32) -> Result; in force_close()
94 fn shutdown(&mut self, dest: VsockAddr, src_port: u32) -> Result; in shutdown()
97 fn recv(&mut self, peer: VsockAddr, src_port: u32, buffer: &mut [u8]) -> Result<usize>; in recv()
160 pub fn connect(&mut self, destination: VsockAddr, src_port: u32) -> Result { in connect()
162 connection.info.dst == destination && connection.info.src_port == src_port in connect()
168 Connection::new(destination, src_port, self.0.per_connection_buffer_capacity); in connect()
186 pub fn send(&mut self, destination: VsockAddr, src_port: u32, buffer: &[u8]) -> Result { in send()
[all …]
Dprotocol.rs54 pub src_port: U32<LittleEndian>, field
71 src_port: 0.into(), in default()
96 port: self.src_port.get(), in source()
Dvsock.rs32 pub src_port: u32, field
56 pub fn new(destination: VsockAddr, src_port: u32) -> Self { in new()
59 src_port, in new()
93 src_port: self.src_port.into(), in new_header()
120 && self.destination.port == connection_info.src_port in matches_connection()
/external/bcc/examples/networking/tcp_mon_block/src/
Dtcp_mon_block.c27 u16 src_port; member
40 u16 src_port; member
51 u16 src_port; member
83 static void make_verbose_event(verbose_event *v, u32 src_ip, u32 dst_ip, u16 src_port, u16 dst_port… in make_verbose_event() argument
86 v->src_port = src_port; in make_verbose_event()
127 u16 src_port = bpf_ntohs(tcp->source); in handle_egress() local
131 key.src_port = src_port; in handle_egress()
166 key.src_port = args->sport; in TRACEPOINT_PROBE()
179 …ose_event(&v, packet_value->src_ip, packet_value->dst_ip, packet_value->src_port, packet_value->ds… in TRACEPOINT_PROBE()
207 u16 src_port = sk->__sk_common.skc_num; in trace_connect_entry() local
[all …]
/external/linux-kselftest/tools/testing/selftests/netfilter/
Dnft_concat_range.sh532 [ -n "${src_port}" ] && src_port="-us ${src_port}"
537 B sendip -p ipv4 -p udp ${src_addr4} ${src_port} \
540 src_port=
549 if [ -n "${src_port}" ];then
550 __socatbind="${__socatbind}:${src_port}"
560 src_port=
577 [ -n "${src_port}" ] && src_port="-p ${src_port}"
580 "${src_port}" "${dst_addr4}" "${dst_port}"
583 src_port=
609 [ -n "${src_port}" ] && src_port="-us ${src_port}"
[all …]
/external/rust/android-crates-io/crates/virtio-drivers/src/device/socket/
Dconnectionmanager.rs122 pub fn connect(&mut self, destination: VsockAddr, src_port: u32) -> Result { in connect()
124 connection.info.dst == destination && connection.info.src_port == src_port in connect()
130 Connection::new(destination, src_port, self.per_connection_buffer_capacity); in connect()
139 pub fn send(&mut self, destination: VsockAddr, src_port: u32, buffer: &[u8]) -> Result { in send()
140 let (_, connection) = get_connection(&mut self.connections, destination, src_port)?; in send()
237 pub fn recv(&mut self, peer: VsockAddr, src_port: u32, buffer: &mut [u8]) -> Result<usize> { in recv()
238 let (connection_index, connection) = get_connection(&mut self.connections, peer, src_port)?; in recv()
259 pub fn recv_buffer_available_bytes(&mut self, peer: VsockAddr, src_port: u32) -> Result<usize> { in recv_buffer_available_bytes()
260 let (_, connection) = get_connection(&mut self.connections, peer, src_port)?; in recv_buffer_available_bytes()
265 pub fn update_credit(&mut self, peer: VsockAddr, src_port: u32) -> Result { in update_credit()
[all …]
Dvsock.rs31 pub src_port: u32, field
55 pub fn new(destination: VsockAddr, src_port: u32) -> Self { in new()
58 src_port, in new()
92 src_port: self.src_port.into(), in new_header()
119 && self.destination.port == connection_info.src_port in matches_connection()
Dprotocol.rs54 pub src_port: U32<LittleEndian>, field
71 src_port: 0.into(), in default()
96 port: self.src_port.get(), in source()
/external/openthread/tests/scripts/thread-cert/
Dtest_ipv6.py174 def any_udp_payload(src_port, dst_port, payload, checksum): argument
176 …return bytearray([(src_port >> 8) & 0xff, src_port & 0xff, (dst_port >> 8) & 0xff, dst_port & 0xff,
412 src_port = any_port()
417 udp_header = UDPHeader(src_port, dst_port, payload_length, checksum)
423 self.assertEqual(src_port, struct.unpack("!H", data[0:2])[0])
430 src_port = any_port()
435 data = struct.pack("!H", src_port) + struct.pack("!H", dst_port) + \
442 self.assertEqual(src_port, udp_header.src_port)
550 UDPHeader(src_port=19788, dst_port=19788),
678 src_port = any_port()
[all …]
Dcommon.py97 def src_port(self): member in MessageInfo
100 @src_port.setter
101 def src_port(self, value): member in MessageInfo
Dipv6.py482 def __init__(self, src_port, dst_port, payload_length=0, checksum=0): argument
483 self.src_port = src_port
502 data = struct.pack(">H", self.src_port)
511 src_port = struct.unpack(">H", data.read(2))[0]
516 return cls(src_port, dst_port, payload_length, checksum)
1061 if message_info.src_port in self._factories:
1062 factory = self._factories[message_info.src_port]
1088 message_info.src_port = header.src_port
/external/bcc/examples/networking/http_filter/
Dhttp-parse-complete.c11 unsigned short src_port; //source port member
79 key.src_port = tcp->src_port; in http_filter()
/external/linux-kselftest/tools/testing/selftests/net/forwarding/
Dpedit_l4port.sh171 do_test_pedit_l4port "dev $swp1 ingress" udp sport src_port
172 do_test_pedit_l4port "dev $swp2 egress" udp sport src_port
183 do_test_pedit_l4port "dev $swp1 ingress" tcp sport src_port
184 do_test_pedit_l4port "dev $swp2 egress" tcp sport src_port
/external/rust/android-crates-io/crates/grpcio-sys/grpc/tools/run_tests/xds_k8s_test_driver/framework/infrastructure/
Dtraffic_director.py417 def create_url_map(self, src_host: str, src_port: int) -> GcpResource:
429 def patch_url_map(self, src_host: str, src_port: int,
461 src_port: int,
557 src_port = random.randint(lo, hi)
558 if not self.compute.exists_forwarding_rule(src_port):
559 return src_port
563 def create_forwarding_rule(self, src_port: int):
565 src_port = int(src_port)
568 name, self.network, src_port, self.target_proxy.url)
569 resource = self.compute.create_forwarding_rule(name, src_port,
[all …]
/external/linux-kselftest/tools/testing/selftests/drivers/net/mlxsw/
Drif_mac_profiles.sh113 flower skip_sw ip_proto udp src_port 12345 dst_port 54321 \
119 flower skip_sw src_mac $smac ip_proto udp src_port 12345 \
148 flower skip_sw ip_proto udp src_port 54321 dst_port 12345 \
152 flower skip_sw src_mac $rp1_mac ip_proto udp src_port 54321 \
/external/linux-kselftest/tools/testing/selftests/bpf/
Dtest_sock.c94 offsetof(struct bpf_sock, src_port)),
207 offsetof(struct bpf_sock, src_port)),
237 offsetof(struct bpf_sock, src_port)),
267 offsetof(struct bpf_sock, src_port)),
298 offsetof(struct bpf_sock, src_port)),
329 offsetof(struct bpf_sock, src_port)),
Dtest_flow_dissector.sh109 udp src_port 9 action drop
153 udp src_port 8-10 action drop
167 udp src_port 9 action drop
/external/tcpdump/
Dprint-vsock.c101 nd_uint32_t src_port; member
114 nd_uint32_t src_port; member
213 hdr_src_port = GET_LE_U_4(hdr->src_port); in vsock_hdr_print()
/external/perfetto/src/traced/probes/ftrace/test/data/android_raven_AOSP.MASTER_5.10.43/events/vsock/virtio_transport_alloc_pkt/
Dformat10 field:__u32 src_port; offset:12; size:4; signed:0;
18 print fmt: "%u:%u -> %u:%u len=%u type=%s op=%s flags=%#x", REC->src_cid, REC->src_port, REC->dst_c…
/external/perfetto/src/traced/probes/ftrace/test/data/android_raven_AOSP.MASTER_5.10.43/events/vsock/virtio_transport_recv_pkt/
Dformat10 field:__u32 src_port; offset:12; size:4; signed:0;
20 …%u type=%s op=%s flags=%#x buf_alloc=%u fwd_cnt=%u", REC->src_cid, REC->src_port, REC->dst_cid, RE…
/external/linux-kselftest/tools/testing/selftests/bpf/progs/
Dtest_sock_fields.c75 dst->src_port = src->src_port; in skcpy()
144 if (sk->src_port == bpf_ntohs(srv_sa6.sin6_port)) { in egress_read_sock_fields()
232 sk->src_port != bpf_ntohs(srv_sa6.sin6_port)) in ingress_read_sock_fields()
/external/openthread/tests/toranj/ncp/
Dwpan.py692 src_port = src[1]
695 src_port = random.randint(49152, 65535)
711 return AsyncSender(self, src_addr, src_port, dst_addr, dst_port, msg, count, mcast_hops)
733 receiver._add_sender(sender.src_addr, sender.src_port, sender.msg, sender.count)
780 def __init__(self, node, src_addr, src_port, dst_addr, dst_port, msg, count, mcast_hops=None): argument
783 self._src_port = src_port
805 src_sock_addr = _create_socket_address(src_addr + '%' + node.interface_name, src_port)
807 src_sock_addr = _create_socket_address(src_addr, src_port)
823 def src_port(self): member in AsyncSender
972 src_port = src_sock_addr[1]
[all …]
/external/rust/crates/vhost-device-vsock/src/
Dthread_backend.rs222 let key = ConnMapKey::new(pkt.dst_port(), pkt.src_port()); in send_pkt()
317 pkt.src_port(), in add_new_guest_conn()
324 .insert(stream_fd, ConnMapKey::new(pkt.dst_port(), pkt.src_port())); in add_new_guest_conn()
327 .insert(ConnMapKey::new(pkt.dst_port(), pkt.src_port()), conn); in add_new_guest_conn()
329 .push_back(ConnMapKey::new(pkt.dst_port(), pkt.src_port())); in add_new_guest_conn()
/external/rust/android-crates-io/crates/virtio-vsock/src/
Dpacket.rs112 src_port: Le32, field
262 pub fn src_port(&self) -> u32 { in src_port() method
263 self.header.src_port.into() in src_port()
268 set_header_field!(self, src_port, SRC_PORT_OFFSET, port); in set_src_port()
964 src_port: SRC_PORT.into(), in test_from_tx_virtq_chain()
1018 src_port: SRC_PORT.into(), in test_from_tx_virtq_chain()
1042 src_port: SRC_PORT.into(), in test_from_tx_virtq_chain()
1203 assert_eq!(packet.src_port(), SRC_PORT); in test_header_set_get()
1211 src_port: SRC_PORT.into(), in test_header_set_get()
1312 src_port: SRC_PORT.into(), in test_set_header_from_raw()
/external/crosvm/devices/src/virtio/vsock/sys/windows/
Dvsock.rs371 guest: header.src_port.to_native(), in from_tx_header()
604 src_port: Le32::from(port.host), in process_rx_queue()
816 guest_port: header.src_port, in handle_vsock_connection_request()
1098 src_port: { header.dst_port }, in handle_tx_packet()
1099 dst_port: { header.src_port }, in handle_tx_packet()
1142 src_port: { header.dst_port }, in handle_tx_packet()
1143 dst_port: { header.src_port }, in handle_tx_packet()
1255 src_port: { header.dst_port }, in send_vsock_credit_update()
1256 dst_port: { header.src_port }, in send_vsock_credit_update()
1296 src_port: { header.dst_port }, in send_vsock_reset()
[all …]

1234