MCPcopy Create free account

hub / github.com/QuiltOS/QuiltNet / functions

Functions341 in github.com/QuiltOS/QuiltNet

⨍ Functions 341◇ Types & classes 61
↓ 2 callersMethodto_vec
(self)
network/src/ipv4/packet.rs:91
↓ 2 callersFunctiontrans
(listener: &mut Option<Listener>, state: &Arc<::State<A>>, packet: TcpPac
transport/tcp/src/listener.rs:84
↓ 2 callersFunctionupdate
Go through a bunch of entries, update the table, propigate changes
transport/brown_rip/src/comm.rs:137
↓ 2 callersMethodupdate_checksum
(&mut self)
network/src/ipv4/packet.rs:319
↓ 2 callersFunctionvalidate
(buf: &[u8])
network/src/ipv4/packet.rs:369
↓ 2 callersMethodwrite
(&mut self, mut buf: &[u8])
transport/tcp/src/capability/c.rs:137
↓ 1 callersMethodadd_vec
(&mut self, seq_num: u32, vec: Vec<u8>, start_off: uint)
transport/tcp/src/connection/packet_buf/vec_queue.rs:174
↓ 1 callersMethodadd_vec
(&mut self, seq_num: u32, vec: Vec<u8>, start_off: uint)
transport/tcp/src/connection/packet_buf/ring.rs:26
↓ 1 callersMethodas_mut_vec
(&mut self)
network/src/ipv4/packet.rs:89
↓ 1 callersMethodas_vec
(&self)
transport/tcp/src/packet.rs:103
↓ 1 callersFunctioncalc_rtt
TODO: smooth using ALPHA
transport/tcp/src/connection/established/tcb/timer/mod.rs:109
↓ 1 callersMethodcall_once
(mut self, args: Args)
misc/src/lib.rs:23
↓ 1 callersFunctioncheckup
(e: &mut Connection, s: &::State<A>, interval: &mut Duration)
transport/tcp/src/connection/mod.rs:112
↓ 1 callersFunctioncollector_garbage
(state: &ipv4::State<RipTable>)
transport/brown_rip/src/periodic.rs:54
↓ 1 callersMethodconnect
(state: &Arc<::State<A>>, us: Port, them: ::ConAddr)
transport/tcp/src/capability/c.rs:44
↓ 1 callersMethodconsume_iter
(&'a mut self)
transport/tcp/src/ring_buf.rs:145
↓ 1 callersMethodcovers
TODO: mod??
transport/tcp/src/connection/manager/packet_buffer.rs:28
↓ 1 callersMethodcyclic_cmp
(&self, them: &Tagged, other: &Tagged)
transport/tcp/src/connection/packet_buf/vec_queue.rs:45
↓ 1 callersMethoddisable
(&mut self)
data_link/udp_mock/src/lib.rs:171
↓ 1 callersMethoddump
(&self)
transport/tcp/src/concurrent_hash_map.rs:66
↓ 1 callersMethodenable
(&mut self)
data_link/udp_mock/src/lib.rs:160
↓ 1 callersMethodfind_ix
TODO: Binary search using OrdSlicePrelude Finds index where given entry belongs in sorted sequence if it is not a duplicate
transport/tcp/src/connection/manager/packet_buffer.rs:104
↓ 1 callersFunctionforward
Forwards a packet back into the network after rewriting its headers Result status is whether packet was able to be forwarded
network/src/ipv4/receive.rs:75
↓ 1 callersMethodget_ack_num
Acknowledgement Number Ops
transport/tcp/src/packet.rs:201
↓ 1 callersMethodget_checksum
Checksum Ops
transport/tcp/src/packet.rs:215
↓ 1 callersMethodget_cur_ix
(&self)
transport/tcp/src/connection/manager/packet_buffer.rs:44
↓ 1 callersMethodget_hdr_size
AKA data offset: 4 bytes
transport/tcp/src/packet.rs:182
↓ 1 callersMethodget_header_checksum
(& self)
network/src/ipv4/packet.rs:260
↓ 1 callersMethodget_header_length
(&self)
network/src/ipv4/packet.rs:213
↓ 1 callersMethodget_or_init
(per_port: &::PerPort, them: ::ConAddr)
transport/tcp/src/connection/mod.rs:43
↓ 1 callersMethodget_payload_mut
(&mut self)
network/src/ipv4/packet.rs:293
↓ 1 callersMethodget_payload_offset
(&self)
transport/tcp/src/packet.rs:228
↓ 1 callersMethodget_rtt_estimate
(&mut self)
transport/tcp/src/connection/established/tcb/timer/mod.rs:74
↓ 1 callersMethodget_time_to_live
(& self)
network/src/ipv4/packet.rs:254
↓ 1 callersFunctionhandle
(state: &ipv4::State<RipTable>, packet: ipv4::packet::V)
transport/brown_rip/src/comm.rs:18
↓ 1 callersFunctionhandle
(state: &Arc<::State<A>>, packet: ipv4::packet::V)
transport/tcp/src/receive.rs:18
↓ 1 callersMethodhandle
(&mut self, state: &Arc<::State<A>>, packet: TcpPacket)
transport/tcp/src/listener.rs:42
↓ 1 callersFunctionhandshake_2
(state: &::State<A>, us: ::ConAddr, // already expects specific port
transport/tcp/src/connection/syn_received.rs:109
↓ 1 callersFunctioninner
()
data_link/udp_mock/tests/two-node.rs:98
↓ 1 callersFunctionis_packet_dst_local
Determine whether packet is destined for this node
network/src/ipv4/receive.rs:95
↓ 1 callersMethoditer
(&'a self)
transport/tcp/src/connection/packet_buf/dummy.rs:33
↓ 1 callersMethodlookup
(&self, ip: ipv4::Addr)
transport/brown_rip/src/lib.rs:47
↓ 1 callersMethodmod_leq
(&self, n: u32, m: u32)
transport/tcp/src/connection/established/tcb/mod.rs:323
↓ 1 callersMethodnext
(&mut self)
transport/brown_rip/src/packet.rs:54
↓ 1 callersMethodnext
(self, state: &::State<A>, packet: TcpPacket)
transport/tcp/src/connection/established/mod.rs:40
↓ 1 callersMethodnext_helper
(&mut self)
transport/brown_rip/src/packet.rs:42
↓ 1 callersMethodnext_raii
(mut self, state: &::State<A>, packet: TcpPacket)
transport/tcp/src/connection/handshaking.rs:79
↓ 1 callersMethodnext_raii
(self, _state: &::State<A>, packet: TcpPacket)
transport/tcp/src/connection/syn_received.rs:47
↓ 1 callersMethodnext_raii
(mut self, state: &::State<A>, packet: TcpPacket)
transport/tcp/src/connection/established/mod.rs:77
↓ 1 callersFunctionon_timeout
(est: &mut Established, state: &::State<A>, interval: &mut Duration)
transport/tcp/src/connection/established/tcb/timer/mod.rs:119
↓ 1 callersFunctionparse
(buf: &'a [u8])
transport/brown_rip/src/packet.rs:32
↓ 1 callersFunctionparse_addr
(&[a, b, c, d]: &[u8; 4])
network/src/ipv4/mod.rs:49
↓ 1 callersFunctionparse_helper
(buf: &'a [u8])
transport/brown_rip/src/packet.rs:60
↓ 1 callersFunctionraw_make_iter
(data: &'a Vec<u8>, head: uint, tail: uint)
transport/tcp/src/ring_buf.rs:167
↓ 1 callersFunctionreceive
Called upon receipt of an IP packet: If packet is destined for this node, deliver it to appropriate handlers If packet is destined elsewhere, fix pack
network/src/ipv4/receive.rs:15
↓ 1 callersFunctionregister
Registers protocol handler for incomming RIP packets.
transport/brown_rip/src/comm.rs:60
↓ 1 callersFunctionregister
Registers protocol handler for incomming RIP packets.
transport/tcp/src/receive.rs:65
↓ 1 callersMethodsend
Write as many bytes as we can into our TCP send buffer from buf, starting with `start` Returning the number of bytes we were able to successfully wri
transport/tcp/src/connection/established/tcb/mod.rs:234
↓ 1 callersMethodset_checksum
(&mut self, checksum: u16)
transport/tcp/src/packet.rs:218
↓ 1 callersMethodset_destination
(&mut self, a: Addr)
network/src/ipv4/packet.rs:274
↓ 1 callersMethodset_dst_port
(&mut self, port: u16)
transport/tcp/src/packet.rs:158
↓ 1 callersMethodset_flags_fragment_offset
(&mut self, flags: IpFlags, offset: u16)
network/src/ipv4/packet.rs:248
↓ 1 callersMethodset_hdr_size
FIXME: way to ensure this always gets called
transport/tcp/src/packet.rs:186
↓ 1 callersMethodset_header_checksum
(&mut self, v: u16)
network/src/ipv4/packet.rs:261
↓ 1 callersMethodset_header_length
(&mut self, hl: u8)
network/src/ipv4/packet.rs:214
↓ 1 callersMethodset_src_port
(&mut self, port: u16)
transport/tcp/src/packet.rs:149
↓ 1 callersMethodset_time_to_live
(&mut self, v: u8)
network/src/ipv4/packet.rs:255
↓ 1 callersMethodset_type_of_service
(&mut self, prec: Precedence, flags: ServiceFlags)
network/src/ipv4/packet.rs:233
↓ 1 callersMethodset_version
(&mut self, v: u8)
network/src/ipv4/packet.rs:206
↓ 1 callersFunctionspawn_garbage_collector
(state: Arc<ipv4::State<RipTable>>)
transport/brown_rip/src/periodic.rs:41
↓ 1 callersFunctionspawn_updater
(state: Arc<ipv4::State<RipTable>>)
transport/brown_rip/src/periodic.rs:17
↓ 1 callersFunctionstart_timer
(state: &Arc<::State<A>>, weak: &Arc<RWLock<super::Connection>>)
transport/tcp/src/connection/timer.rs:11
↓ 1 callersFunctionupdate
(state: &ipv4::State<RipTable>)
transport/brown_rip/src/periodic.rs:29
↓ 1 callersMethodupdate_checksum
(&mut self)
transport/tcp/src/packet.rs:291
↓ 1 callersMethodupdate_recv_handler
(&'b self, on_recv: dl::Handler<'a>)
data_link/udp_mock/src/lib.rs:153
↓ 1 callersMethodupdate_rtt_from_ack
(&mut self, ack_num: u32)
transport/tcp/src/connection/established/tcb/timer/mod.rs:78
↓ 1 callersMethodupdate_with_interval
Adds a new interval to the queue, popping off one of it is now expired
transport/tcp/src/connection/established/tcb/timer/mod.rs:53
↓ 1 callersMethodvalidate_packet_state
TODO
transport/tcp/src/connection/established/tcb/mod.rs:183
↓ 1 callersFunctionwrite_response
iterator must yield at least one entry, or assertion will fall
transport/brown_rip/src/packet.rs:93
Methodaccept
(&self)
transport/tcp/src/capability/l.rs:66
Methodadd_packet
(&mut self, packet: TcpPacket)
transport/tcp/src/connection/manager/recv.rs:31
Methodadd_packet
(&mut self, seq: u32, offset: u32, data: Vec<u8>)
transport/tcp/src/connection/manager/packet_buffer.rs:89
Methodadd_slice
(&mut self, _seq_num: u32, _buf: &[u8])
transport/tcp/src/connection/packet_buf/dummy.rs:17
Methodadd_vec
(&mut self, _seq_num: u32, _vec: Vec<u8>, _start_off: uint)
transport/tcp/src/connection/packet_buf/dummy.rs:16
Methodas_vec
(&self)
network/src/ipv4/packet.rs:87
Functionbyte
()
transport/tcp/src/packet.rs:331
Methodcall
(&self, args: Args)
misc/src/lib.rs:37
Methodcheckup
(mut self, state: &::State<A>, interval: &mut Duration)
transport/tcp/src/connection/established/mod.rs:60
Functionclose
(e: &mut Connection, s: &::State<A>)
transport/tcp/src/connection/mod.rs:96
Methodclose
(self, _state: &::State<A>)
transport/tcp/src/connection/established/mod.rs:53
Methodconsume_iter
(&'a mut self)
transport/tcp/src/connection/packet_buf/dummy.rs:37
Methodconsume_to
(&mut self, seq: u32)
transport/tcp/src/connection/manager/packet_buffer.rs:129
Methoddefault
()
transport/tcp/src/lib.rs:134
Methoddefault
()
transport/tcp/src/connection/mod.rs:37
Functiondirect_two_nodes
()
network/tests/ipv4.rs:88
Functiondisable_then_cant_send
()
data_link/udp_mock/tests/two-node.rs:96
Functiondown
Disables the given interface
network/src/ipv4/control.rs:20
Methoddump
(&self)
transport/brown_rip/src/lib.rs:74
Methoddump
(&self)
transport/static_routing/src/lib.rs:38
Methoddump_tcp
(&self)
transport/tcp/src/lib.rs:105
← previousnext →101–200 of 341, ranked by callers