MCPcopy Create free account

hub / github.com/QuiltOS/QuiltNet / functions

Functions341 in github.com/QuiltOS/QuiltNet

⨍ Functions 341◇ Types & classes 61
↓ 81 callersFunctionnew
(state: &Arc<::State<A>>, con: Weak<RWLock<::connection::Connection>>, rd_rx
transport/tcp/src/capability/c.rs:163
↓ 41 callersMethodlen
(&self)
transport/tcp/src/connection/packet_buf/vec_queue.rs:74
↓ 32 callersMethoditer
(&'a self)
transport/tcp/src/ring_buf.rs:139
↓ 24 callersFunctionnew
Returns a new RecvMgr, complete with: - An empty priority queue, ready to sort TcpPackets based on beginning sequence number - Pointer to the next seq
transport/tcp/src/connection/manager/packet_buffer.rs:293
↓ 23 callersMethodas_slice
(&'a self)
transport/tcp/src/connection/packet_buf/vec_queue.rs:95
↓ 18 callersMethodwrite
Writes as many bytes as possible from buf, returns number of bytes written
transport/tcp/src/ring_buf.rs:95
↓ 16 callersMethodborrow
(&self)
network/src/ipv4/packet.rs:93
↓ 13 callersMethodadd_slice
(&mut self, seq_num: u32, buf: &[u8])
transport/tcp/src/connection/packet_buf/vec_queue.rs:169
↓ 12 callersMethodcyclic_cmp
(&self, them: &N, other: &N)
cyclic_order/src/impls.rs:22
↓ 12 callersMethodinsert_cyclic
(&mut self, elt: T)
cyclic_order/src/linked_list.rs:17
↓ 12 callersMethodread
Reads as many bytes as possible into buf, returns number of bytes read
transport/tcp/src/ring_buf.rs:58
↓ 11 callersMethodas_slice
(&self)
network/src/ipv4/packet.rs:178
↓ 11 callersMethodcontains
(&self, seq: u32)
transport/tcp/src/connection/manager/packet_buffer.rs:32
↓ 11 callersMethodget
(&self, k: &Q)
transport/tcp/src/concurrent_hash_map.rs:35
↓ 10 callersFunctionantisymmetry
(a: &T, b: &T, c: &T)
cyclic_order/src/lib.rs:43
↓ 10 callersFunctioncyclicity
(a: &T, b: &T, c: &T)
cyclic_order/src/lib.rs:39
↓ 10 callersMethodrecv
Receive logic for TCP packet
transport/tcp/src/connection/established/tcb/mod.rs:84
↓ 10 callersMethodtail
(&self)
transport/tcp/src/connection/packet_buf/vec_queue.rs:86
↓ 10 callersFunctiontransitivity
(a: &T, b: &T, c: &T, d: &T)
cyclic_order/src/lib.rs:47
↓ 9 callersMethodcast_h_mut
(&mut self)
network/src/ipv4/packet.rs:190
↓ 9 callersMethodcheck_invariants
(&self)
transport/tcp/src/ring_buf.rs:27
↓ 9 callersMethodhdr_bytes
(&self)
network/src/ipv4/packet.rs:221
↓ 9 callersMethodis_clockwise
(&self, them: &N, other: &N)
cyclic_order/src/impls.rs:13
↓ 9 callersMethodwrite
non-blocking, returns how much was read from caller's buffer
transport/tcp/src/connection/established/mod.rs:182
↓ 8 callersMethodborrow_mut
(&mut self)
network/src/ipv4/packet.rs:95
↓ 8 callersMethodget_seq_num
Sequence Number Ops
transport/tcp/src/packet.rs:191
↓ 8 callersMethodget_total_length
(& self)
network/src/ipv4/packet.rs:223
↓ 8 callersMethodtcp_hdr
Returns immutable slice containing TCP packet header NOTE: assumes no TCP options
transport/tcp/src/packet.rs:127
↓ 8 callersMethodtcp_hdr_mut
Returns mutable slice containing TCP packet header NOTE: assumes no TCP options
transport/tcp/src/packet.rs:133
↓ 7 callersMethodcast_h
(&self)
network/src/ipv4/packet.rs:186
↓ 7 callersMethodget_payload
Returns TCP payload as slice
transport/tcp/src/packet.rs:224
↓ 7 callersMethodget_tcp
Returns slice containing TCP packet
transport/tcp/src/packet.rs:116
↓ 7 callersMethodnext
returns false if terminating
misc/src/state_machine.rs:26
↓ 6 callersMethodflags
Control Flags
transport/tcp/src/packet.rs:163
↓ 6 callersMethodget_next_consume_seq
(&self)
transport/tcp/src/connection/packet_buf/ring.rs:24
↓ 6 callersFunctionget_next_write_seq
seq number for the head of continuous data
transport/tcp/src/connection/packet_buf/mod.rs:42
↓ 6 callersMethodget_src_addr
4-tuple info
transport/tcp/src/packet.rs:143
↓ 6 callersMethodhead
(&self)
transport/tcp/src/connection/packet_buf/vec_queue.rs:80
↓ 6 callersFunctionsend
(state: &'st super::State<'a, A, DE>, dst: super::Addr, protocol:
network/src/ipv4/send.rs:28
↓ 6 callersMethodsend
(&self, buf: &[u8], start: u32, n: uint)
transport/tcp/src/connection/manager/send.rs:10
↓ 5 callersMethodcall_mut
(&mut self, args: Args)
misc/src/lib.rs:30
↓ 5 callersMethodget_dst_port
(&self)
transport/tcp/src/packet.rs:155
↓ 5 callersMethodget_src_port
(&self)
transport/tcp/src/packet.rs:146
↓ 5 callersMethoditer
(&'a self)
transport/tcp/src/connection/packet_buf/vec_queue.rs:257
↓ 5 callersMethodlen
(&self)
transport/tcp/src/connection/manager/packet_buffer.rs:23
↓ 5 callersFunctionsuper_trait_cohesion
(a: &T, b: &T, c: &T)
cyclic_order/src/lib.rs:103
↓ 5 callersFunctiontotality
(a: &T, b: &T, c: &T)
cyclic_order/src/lib.rs:94
↓ 5 callersFunctionwrite_addr
(Addr(slice): Addr)
network/src/ipv4/mod.rs:60
↓ 4 callersMethodget_destination
(&self)
network/src/ipv4/packet.rs:273
↓ 4 callersMethodget_dst_addr
(&self)
transport/tcp/src/packet.rs:152
↓ 4 callersMethodget_window_size
Recv Window size
transport/tcp/src/packet.rs:173
↓ 4 callersMethoditer
(&'a self)
transport/tcp/src/connection/packet_buf/ring.rs:68
↓ 4 callersFunctionpropagate
This method is the sole method of sending a "response" packet. The `key_rows` are written to packets, one per each interface / neighbor. Entries lear
transport/brown_rip/src/comm.rs:84
↓ 3 callersMethodas_mut_slice
(&mut self)
network/src/ipv4/packet.rs:182
↓ 3 callersMethodas_mut_vec
(&mut self)
transport/tcp/src/packet.rs:107
↓ 3 callersMethodflags_mut
(&mut self)
transport/tcp/src/packet.rs:167
↓ 3 callersMethodinvoke_handler
(mut self, situ: Situation)
transport/tcp/src/connection/established/mod.rs:124
↓ 3 callersFunctionmod_in_interval
(s: u32, e: u32, n: u32)
transport/tcp/src/connection/established/tcb/mod.rs:331
↓ 3 callersMethodreadable_len
(&self)
transport/tcp/src/ring_buf.rs:48
↓ 3 callersFunctionsend
(ip_state: &'ip ipv4::State<A>, //connection: &'tcp Connection, src_addr: Op
transport/tcp/src/send.rs:31
↓ 3 callersFunctionsend_manual
For anybody that wants to do their own routing and set their own checksum
network/src/ipv4/send.rs:94
↓ 3 callersMethodtry_clone
(&self)
data_link/udp_mock/src/lib.rs:100
↓ 3 callersMethodwritable_len
(&self)
transport/tcp/src/ring_buf.rs:40
↓ 2 callersMethodadd_slice
(&mut self, seq_num: u32, buf: &[u8])
transport/tcp/src/connection/packet_buf/ring.rs:30
↓ 2 callersFunctioncast_slice
Adjusts len
network/src/ipv4/packet.rs:433
↓ 2 callersMethodcheckup
(self, state: &::State<A>, interval: &mut Duration)
transport/tcp/src/connection/handshaking.rs:64
↓ 2 callersMethodclose
(self, _state: &::State<A>)
transport/tcp/src/connection/handshaking.rs:54
↓ 2 callersMethodcmp
(&self, other: &TcpPacket)
transport/tcp/src/packet.rs:299
↓ 2 callersMethodconsume_iter
(&'a mut self)
transport/tcp/src/connection/packet_buf/vec_queue.rs:267
↓ 2 callersMethodconsume_iter
(&'a mut self)
transport/tcp/src/connection/packet_buf/ring.rs:73
↓ 2 callersMethodflush_transmit_queue
Iterate through bytes to be sent, packaging them into packets and sending them off
transport/tcp/src/connection/established/tcb/mod.rs:259
↓ 2 callersMethodget_body_len
Returns length of the TCP body
transport/tcp/src/packet.rs:138
↓ 2 callersMethodget_interface
Returns dl::Interface struct for the requested interface
network/src/ipv4/mod.rs:162
↓ 2 callersMethodget_protocol
(& self)
network/src/ipv4/packet.rs:257
↓ 2 callersMethodget_source
(&self)
network/src/ipv4/packet.rs:263
↓ 2 callersMethodget_tcp_mut
Returns mutable slice containing TCP packet body
transport/tcp/src/packet.rs:121
↓ 2 callersMethodget_version
(&self)
network/src/ipv4/packet.rs:205
↓ 2 callersMethodis_clockwise
(&self, them: &Tagged, other: &Tagged)
transport/tcp/src/connection/packet_buf/vec_queue.rs:37
↓ 2 callersFunctionlog_trace
(tcp_packet: &TcpPacket, is_recv: bool)
transport/tcp/src/trace.rs:10
↓ 2 callersFunctionmake_checksum
assumes and returns native byte order
network/src/ipv4/packet.rs:413
↓ 2 callersFunctionmake_con_handler
()
transport/tcp/src/capability/c.rs:182
↓ 2 callersMethodmake_header_checksum
returns native endian
transport/tcp/src/packet.rs:238
↓ 2 callersMethodmake_header_checksum
returns native endian
network/src/ipv4/packet.rs:304
↓ 2 callersFunctionmk_callback
(barrier: Arc<Barrier>, msg: &'static str)
data_link/udp_mock/tests/two-node.rs:59
↓ 2 callersMethodnext
(self, state: &::State<A>, packet: TcpPacket)
transport/tcp/src/connection/handshaking.rs:41
↓ 2 callersFunctionnow_millis
Hopefully returns timestamp of now in milliseconds
transport/tcp/src/connection/established/tcb/timer/mod.rs:114
↓ 2 callersFunctionparse_addr_unsafe
(b: &[u8])
network/src/ipv4/mod.rs:54
↓ 2 callersMethodread
(&mut self, mut buf: &mut [u8])
transport/tcp/src/capability/c.rs:93
↓ 2 callersMethodread_top
Tries to copy n bytes from next packet in receive queue Pops packet off queue if fully consumed Resets self.packet_offset appropriately
transport/tcp/src/connection/manager/recv.rs:63
↓ 2 callersFunctionregister_protocol_handler
(ip_state: &'a super::State<'st, A, E>, proto_number: u8, handler: super::Handler<'st>)
network/src/ipv4/control.rs:32
↓ 2 callersFunctionresolve_route
looks up route for interface and packet src address
network/src/ipv4/send.rs:72
↓ 2 callersMethodsend
(&mut self, state: &::State<A>, us: Port, // already expects specific port
transport/tcp/src/connection/handshaking.rs:181
↓ 2 callersFunctionsending
(state: &ipv4::State<'st, R, E>, dst: ipv4::Addr, msg: &'static str)
network/tests/ipv4.rs:53
↓ 2 callersMethodset_ack_num
(&mut self, ack_num: u32)
transport/tcp/src/packet.rs:208
↓ 2 callersMethodset_seq_num
(&mut self, seq_num: u32)
transport/tcp/src/packet.rs:195
↓ 2 callersMethodset_source
(&mut self, a: Addr)
network/src/ipv4/packet.rs:264
↓ 2 callersMethodset_window_size
(&mut self, window_size: u16)
transport/tcp/src/packet.rs:176
↓ 2 callersFunctiontalk_to_self_callback_helper
(num_threads: usize)
data_link/udp_mock/tests/two-node.rs:58
↓ 2 callersFunctiontalk_to_self_channel_helper
(num_threads: usize)
data_link/udp_mock/tests/two-node.rs:22
↓ 2 callersMethodto_vec
(self)
transport/tcp/src/packet.rs:111
next →1–100 of 341, ranked by callers