Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/QuiltOS/QuiltNet
/ functions
Functions
341 in github.com/QuiltOS/QuiltNet
⨍
Functions
341
◇
Types & classes
61
Function
empty_readable_lens
()
transport/tcp/src/ring_buf.rs:197
Method
fmt
(&self, f: &mut fmt::Formatter)
transport/tcp/src/packet.rs:311
Method
fmt
(&self, f: &mut fmt::Formatter)
transport/tcp/src/lib.rs:114
Method
fmt
(&self, f: &mut fmt::Formatter)
transport/tcp/src/listener.rs:133
Method
fmt
(&self, f: &mut fmt::Formatter)
transport/tcp/src/connection/mod.rs:59
Method
fmt
(&self, f: &mut fmt::Formatter)
transport/tcp/src/connection/manager/recv.rs:127
Method
fmt
(&self, f: &mut fmt::Formatter)
transport/tcp/src/connection/manager/packet_buffer.rs:306
Method
fmt
(&self, f: &mut fmt::Formatter)
network/src/ipv4/mod.rs:23
Method
fmt
(&self, f: &mut fmt::Formatter)
network/src/ipv4/packet.rs:326
Method
from
(external: E)
data_link/interface/src/lib.rs:26
Method
from
(e: dl::Error<E>)
network/src/ipv4/send.rs:20
Method
from_error
(e: ipv4::send::Error)
transport/tcp/src/send.rs:26
Method
from_str
(s: &str)
network/src/ipv4/mod.rs:32
Method
generate_isn
Generates a pseudorandom u32 - used to set ISN
transport/tcp/src/connection/handshaking.rs:240
Method
get_end_seq
(&self)
transport/tcp/src/connection/manager/packet_buffer.rs:40
Method
get_flags_fragment_offset
(&self)
network/src/ipv4/packet.rs:242
Method
get_identification
(& self)
network/src/ipv4/packet.rs:238
Method
get_ix
(&self, seq: u32)
transport/tcp/src/connection/manager/packet_buffer.rs:48
Method
get_mut_payload
Returns TCP payload as mut slice
transport/tcp/src/packet.rs:233
Method
get_next_consume_seq
(&self)
transport/tcp/src/connection/packet_buf/vec_queue.rs:167
Method
get_next_consume_seq
(&self)
transport/tcp/src/connection/packet_buf/dummy.rs:19
Method
get_or_init
(tcp: &Table, us: Port)
transport/tcp/src/lib.rs:144
Method
get_or_init
(&self, k: K, init: || -> V)
transport/tcp/src/concurrent_hash_map.rs:46
Method
get_payload
(&self)
network/src/ipv4/packet.rs:285
Function
get_per_port
(tcp_table: &'s RWLockReadGuard<'s, ::Table>, local_port: Port)
transport/tcp/src/access.rs:16
Method
get_status
(&self)
data_link/udp_mock/src/lib.rs:182
Method
get_type_of_service
(&self)
network/src/ipv4/packet.rs:227
Method
get_window
(&self)
transport/tcp/src/connection/mod.rs:49
Method
get_window
(&self)
transport/tcp/src/connection/established/mod.rs:192
Method
get_window
Returns the socket's (send, receive) windows
transport/tcp/src/connection/established/tcb/mod.rs:79
Method
get_window
Returns (send, receive) window sizes for this connection
transport/tcp/src/capability/c.rs:79
Method
hack
(ip_packet: &packet::V)
transport/tcp/src/packet.rs:57
Method
hack_mut
(ip_packet: &mut packet::V)
transport/tcp/src/packet.rs:61
Method
init
(elements: I)
transport/brown_rip/src/lib.rs:53
Method
init
(elements: I)
transport/static_routing/src/lib.rs:28
Method
init_and_register
(ip: Arc<ipv4::State<A>>)
transport/tcp/src/lib.rs:95
Method
iter_all
(&self)
transport/tcp/src/connection/manager/packet_buffer.rs:137
Function
iter_empty
()
transport/tcp/src/connection/packet_buf/vec_queue.rs:283
Method
iter_to
(&self, seq: u32)
transport/tcp/src/connection/manager/packet_buffer.rs:120
Method
listen
(state: &Arc<::State<A>>, us: Port)
transport/tcp/src/capability/l.rs:36
Method
lookup
(&self, ip: ipv4::Addr)
transport/static_routing/src/lib.rs:24
Function
make_ip_to_wait
(interfaces: Vec<InterfaceRow<'st, E>>, neighbors: InterfaceTable, msg: &'st str, barrier: Arc<Barrie
network/tests/ipv4.rs:32
Function
make_receive_callback
(state: Arc<super::State<'a, A, E>>)
network/src/ipv4/receive.rs:105
Function
many_buf
()
transport/tcp/src/connection/packet_buf/vec_queue.rs:305
Method
monitor
(state: Arc<ipv4::State<RipTable>>)
transport/brown_rip/src/lib.rs:67
Method
monitor
(_state: Arc<ipv4::State<'a, StaticTable, E>>)
transport/static_routing/src/lib.rs:34
Function
mut_iter
()
transport/tcp/src/connection/packet_buf/vec_queue.rs:367
Method
new
(listen_addr: A, num_threads: usize)
data_link/udp_mock/src/lib.rs:40
Method
new
(ip_packet: packet::V)
transport/tcp/src/packet.rs:53
Method
new
Returns new Ring Buffer of given (fixed) size
transport/tcp/src/ring_buf.rs:18
Method
new
()
transport/tcp/src/concurrent_hash_map.rs:24
Method
new
Only takes State arc because we are temporarily doing one timeout thread / connection Do not propigate this arc further
transport/tcp/src/connection/handshaking.rs:130
Method
new
(seq_num: u32, vec: Vec<u8>, start_off: uint)
transport/tcp/src/connection/packet_buf/vec_queue.rs:57
Method
new
(_init_seq_num: u32)
transport/tcp/src/connection/packet_buf/dummy.rs:12
Method
new
(init_seq_num: u32)
transport/tcp/src/connection/packet_buf/ring.rs:17
Method
new
(state: &::State<A>, us: ::ConAddr, them: ::ConAddr,
transport/tcp/src/connection/established/mod.rs:148
Method
new
TODO: initialize all these variables from handshake!!!
transport/tcp/src/connection/established/tcb/mod.rs:42
Method
new
()
transport/tcp/src/connection/established/tcb/timer/mod.rs:40
Method
new
()
transport/tcp/src/connection/manager/send.rs:6
Method
new
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/recv.rs:114
Method
new
Methods Kernel Calls *********//
transport/tcp/src/connection/manager/packet_buffer.rs:76
Method
new
(interfaces: Vec<InterfaceRow<'a, DE>>, neighbors: InterfaceTable)
network/src/ipv4/mod.rs:96
Method
new
(buf: Vec<u8>)
network/src/ipv4/packet.rs:18
Method
new
(initial_state: S, initial_transitions: Transitions<S, I>)
misc/src/state_machine.rs:15
Method
new
(sender: Sender<T>)
misc/src/lib.rs:48
Method
new_loopback
(num_threads: usize)
data_link/udp_mock/src/lib.rs:86
Method
new_mut
(buf: &mut [u8])
network/src/ipv4/packet.rs:199
Method
new_with_builder
(ip: Addr, protocol: u8, expected_body_size: Option<u16>, builder:
network/src/ipv4/packet.rs:59
Method
new_with_header
NOT CHECKSUMED!
network/src/ipv4/packet.rs:23
Method
next
(self, state: &::State<A>, packet: TcpPacket)
transport/tcp/src/connection/syn_received.rs:29
Method
next
(&mut self)
transport/tcp/src/connection/packet_buf/vec_queue.rs:194
Method
next
Call to next: - Checks first packet to see if it is contiguous - if so - read as much as we need, if whole packet, pop it
transport/tcp/src/connection/manager/packet_buffer.rs:149
Function
no_wrap
()
cyclic_order/src/linked_list.rs:53
Function
one_buf
()
transport/tcp/src/connection/packet_buf/vec_queue.rs:290
Function
overlapping_buf
()
transport/tcp/src/connection/packet_buf/vec_queue.rs:323
Function
parse_invalid
()
transport/brown_rip/src/packet.rs:147
Function
parse_request
()
transport/brown_rip/src/packet.rs:165
Function
parse_response
()
transport/brown_rip/src/packet.rs:170
Method
partial_cmp
(&self, other: &TcpPacket)
transport/tcp/src/packet.rs:305
Function
passive_new
(state: &::State<A>, handler: OnConnectionAttempt, local_p
transport/tcp/src/listener.rs:112
Method
passive_new
(state: &::State<A>, us: ::ConAddr, // already expects specific port
transport/tcp/src/connection/syn_received.rs:72
Function
random_insertion
(elems: Vec<u8>)
cyclic_order/src/linked_list.rs:91
Method
raw_new
Used to implement double connect, otherwise use `passive_new`
transport/tcp/src/connection/syn_received.rs:96
Function
read
Blocking read TODO: mutate TCB state?
transport/tcp/src/connection/manager/packet_buffer.rs:208
Method
read
non-blocking, returns how much was written to caller's buffer
transport/tcp/src/connection/established/mod.rs:171
Method
read
Read as many bytes as we can into buf from received TCP data until we get to n bytes, starting from the next unconsumed sequence number. Returns the
transport/tcp/src/connection/established/tcb/mod.rs:203
Method
read
Userland API *******// Blocking read TODO: mutate TCB state?
transport/tcp/src/connection/manager/recv.rs:38
Method
read_nonblock
Convenience wrapper. If you always are going to do non-blocking, use the async API instead. `None` means no connection / closed. `Some(n)` is n numbe
transport/tcp/src/capability/c.rs:62
Function
read_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/packet_buffer.rs:242
Function
reserve_connection_mut
(subtable: &'s mut RWLockWriteGuard<'s, ::SubTable>, foreign_addr: ::ConAddr)
transport/tcp/src/access.rs:45
Function
reserve_per_port_mut
(tcp_table: &'s mut RWLockWriteGuard<'s, ::Table>, local_port: Port)
transport/tcp/src/access.rs:29
Method
send
(&self, packet: dl::Packet)
data_link/udp_mock/src/lib.rs:137
Method
set_identification
(&mut self, v: u16)
network/src/ipv4/packet.rs:239
Method
set_protocol
(&mut self, v: u8)
network/src/ipv4/packet.rs:258
Method
set_total_length
(&mut self, v: u16)
network/src/ipv4/packet.rs:224
Function
shift_nxt
Returns sequence number of last byte of contiguous block of data starting at usr_NXT NOTE: could pop off all intermediate packets and put them in a us
transport/tcp/src/connection/manager/packet_buffer.rs:286
Method
shift_nxt
Returns sequence number of last byte of contiguous block of data starting at usr_NXT NOTE: could pop off all intermediate packets and put them in a us
transport/tcp/src/connection/manager/recv.rs:107
Function
short
()
transport/tcp/src/packet.rs:337
Function
simple
()
transport/tcp/src/ring_buf.rs:210
Function
simple_consuming
()
transport/tcp/src/ring_buf.rs:279
← previous
next →
201–300 of 341, ranked by callers