Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/NetSys/NetBricks
/ functions
Functions
801 in github.com/NetSys/NetBricks
⨍
Functions
801
◇
Types & classes
118
↓ 1 callers
Function
nat
( parent: T, _s: &mut Scheduler, nat_ip: &Ipv4Addr, )
test/nat/src/nf.rs:21
↓ 1 callers
Function
new_mpsc_queue_pair_with_size
(size: usize)
framework/src/queues/mpsc_mbuf_queue.rs:250
↓ 1 callers
Function
new_packet
Allocate a new packet.
framework/src/interface/packet.rs:86
↓ 1 callers
Method
next_payload
(&mut self, idx: usize)
framework/src/operators/map_batch.rs:116
↓ 1 callers
Method
ns_flag
(&self)
framework/src/headers/tcp.rs:149
↓ 1 callers
Function
num_pmd_ports
native/pmd.c:49
↓ 1 callers
Function
numa_bind
(bitmap: &mut Bitmask)
framework/src/native/libnuma.rs:193
↓ 1 callers
Method
offset
(&self)
framework/src/headers/udp.rs:32
↓ 1 callers
Method
offset
(&self)
framework/src/headers/mac.rs:96
↓ 1 callers
Method
offset
(&self)
framework/src/headers/tcp.rs:69
↓ 1 callers
Method
one_segment
(&self)
framework/src/state/reordered_buffer/reordered_buffer.rs:292
↓ 1 callers
Method
parse_header
(mut self)
framework/src/interface/packet.rs:392
↓ 1 callers
Function
pause
()
framework/src/utils/asm.rs:42
↓ 1 callers
Method
payload_size
(&self, _: usize)
framework/src/headers/ip.rs:59
↓ 1 callers
Method
pkt_headroom
(&self)
framework/src/native/zcsi/mbuf.rs:58
↓ 1 callers
Method
pkt_tailroom
(&self)
framework/src/native/zcsi/mbuf.rs:63
↓ 1 callers
Method
pop_offset
(&mut self)
framework/src/interface/packet.rs:192
↓ 1 callers
Function
print_error
(e: &Error)
framework/src/common/mod.rs:7
↓ 1 callers
Method
push_offset
(&mut self, offset: usize)
framework/src/interface/packet.rs:180
↓ 1 callers
Function
read_configuration_from_str
Read a TOML string and create a `NetbricksConfiguration` structure. `configuration` is a TOML formatted string. `filename` is used for error reporting
framework/src/config/config_reader.rs:131
↓ 1 callers
Method
read_from_head_with_increment
(&mut self, data: &mut [u8], increment: usize)
framework/src/state/ring_buffer.rs:124
↓ 1 callers
Method
read_from_offset
(&mut self, offset: usize, data: &mut [u8])
framework/src/state/ring_buffer.rs:78
↓ 1 callers
Method
read_header
(&self)
framework/src/interface/packet.rs:224
↓ 1 callers
Method
read_offset
(&self)
framework/src/state/ring_buffer.rs:118
↓ 1 callers
Function
read_pmqos
(name)
scripts/tuning/read_cpu_dma_latency.py:9
↓ 1 callers
Function
read_port
Read a TOML stub and figure out the port.
framework/src/config/config_reader.rs:17
↓ 1 callers
Method
read_stack_offset
(&mut self, depth: usize)
framework/src/interface/packet.rs:164
↓ 1 callers
Function
reconstruction
( parent: T, sched: &mut S, )
test/tcp_reconstruction/src/nf.rs:15
↓ 1 callers
Function
reconstruction
( parent: T, sched: &mut S, )
test/tcp_payload/src/nf.rs:28
↓ 1 callers
Method
recv_internal
(&mut self, port: &Rx)
framework/src/operators/packet_batch.rs:89
↓ 1 callers
Method
recv_queue
(&self, queue: i32, pkts: *mut *mut MBuf, to_recv: i32)
framework/src/interface/port/phy_port.rs:77
↓ 1 callers
Function
recv_thread
(ports: Vec<PortQueue>, core: i32, delay_arg: u64)
test/sctp-test/control-test/src/main.rs:30
↓ 1 callers
Function
recv_thread
(ports: Vec<CacheAligned<PortQueue>>, core: i32, counter: MergeableStoreDP<isize>)
test/framework-test/src/main.rs:44
↓ 1 callers
Method
reference
(&mut self)
framework/src/native/zcsi/mbuf.rs:123
↓ 1 callers
Function
reference_mbuf
(mbuf: *mut MBuf)
framework/src/interface/packet.rs:51
↓ 1 callers
Method
remove_data_beginning
(&mut self, len: usize)
framework/src/native/zcsi/mbuf.rs:95
↓ 1 callers
Method
remove_head
(&mut self)
framework/src/state/reordered_buffer/reordered_buffer.rs:247
↓ 1 callers
Method
restore_saved_header
(mut self)
framework/src/interface/packet.rs:415
↓ 1 callers
Function
round_to_pages
(buffer_size: usize)
framework/src/utils/mod.rs:10
↓ 1 callers
Function
run_daemon
(options)
scripts/tuning/pmqos-static.py:84
↓ 1 callers
Method
save_header_and_offset
(&mut self)
framework/src/interface/packet.rs:217
↓ 1 callers
Method
schedule
(&mut self)
framework/src/control/sctp.rs:67
↓ 1 callers
Method
schedule
(&mut self)
framework/src/control/tcp.rs:67
↓ 1 callers
Method
send
Send this batch out a particular port and queue.
framework/src/operators/mod.rs:87
↓ 1 callers
Method
send_q
(&mut self, _: &PacketTx)
framework/src/operators/send_batch.rs:82
↓ 1 callers
Method
send_queue
(&self, queue: i32, pkts: *mut *mut MBuf, to_send: i32)
framework/src/interface/port/phy_port.rs:67
↓ 1 callers
Method
set_dst
(&mut self, dst: u32)
framework/src/headers/ip.rs:116
↓ 1 callers
Method
set_ihl
(&mut self, ihl: u8)
framework/src/headers/ip.rs:214
↓ 1 callers
Method
set_length
(&mut self, len: u16)
framework/src/headers/ip.rs:244
↓ 1 callers
Function
set_pmqos
(name, value)
scripts/tuning/pmqos-static.py:62
↓ 1 callers
Method
set_src
(&mut self, src: u32)
framework/src/headers/ip.rs:106
↓ 1 callers
Method
set_version
(&mut self, version: u8)
framework/src/headers/ip.rs:204
↓ 1 callers
Function
sleep_forever
()
scripts/tuning/pmqos-static.py:73
↓ 1 callers
Method
slow_path_insert
(&mut self, seq: u32, data: &[u8])
framework/src/state/reordered_buffer/reordered_buffer.rs:432
↓ 1 callers
Method
start
(&mut self)
framework/src/operators/map_batch.rs:111
↓ 1 callers
Method
start_scheduler
(&mut self, core: i32)
framework/src/scheduler/context.rs:55
↓ 1 callers
Method
sync
(&mut self)
framework/src/state/mergeable.rs:65
↓ 1 callers
Function
tcp_nf
(parent: T)
test/tcp_check/src/nf.rs:5
↓ 1 callers
Function
test
(ports: Vec<T>, sched: &mut S, delay_arg: u64)
test/sctp-test/src/main.rs:30
↓ 1 callers
Function
test
()
test/sctp-test/control-test/ctl/controller.py:4
↓ 1 callers
Function
test
(ports: Vec<T>, sched: &mut S)
test/nat/src/main.rs:23
↓ 1 callers
Function
test
(ports: Vec<T>, sched: &mut S)
test/tcp_check/src/main.rs:22
↓ 1 callers
Function
test
(ports: Vec<CacheAligned<PortQueue>>, sched: &mut S, delay_arg: u64)
test/shutdown-test/src/main.rs:23
↓ 1 callers
Function
test
(ports: Vec<CacheAligned<PortQueue>>, sched: &mut S)
test/tcp_reconstruction/src/main.rs:22
↓ 1 callers
Function
test
(ports: Vec<T>, sched: &mut S)
test/maglev/src/main.rs:23
↓ 1 callers
Function
test
(ports: Vec<T>, sched: &mut S, delay_arg: u64)
test/reset-parse/src/main.rs:23
↓ 1 callers
Function
test
(ports: Vec<CacheAligned<PortQueue>>, sched: &mut S)
test/acl-fw/src/main.rs:23
↓ 1 callers
Function
test
(ports: Vec<CacheAligned<PortQueue>>, sched: &mut S)
test/tcp_payload/src/main.rs:20
↓ 1 callers
Function
test
(ports: Vec<T>, sched: &mut S)
test/macswap/src/main.rs:21
↓ 1 callers
Function
test
(ports: Vec<T>, sched: &mut S, chain_len: u32, chain_pos: u32)
test/chain-test/src/main.rs:22
↓ 1 callers
Function
test
(ports: Vec<T>, sched: &mut S)
test/packet_test/src/main.rs:23
↓ 1 callers
Function
test
(ports: Vec<T>, sched: &mut S)
test/packet_generation/src/main.rs:24
↓ 1 callers
Function
test_func
(id: &str)
test/embedded-scheduler-dependency-test/src/main.rs:31
↓ 1 callers
Method
update
(&mut self, flow: Flow, inc: T)
framework/src/state/mergeable.rs:126
↓ 1 callers
Method
update_internal
(&mut self, v: Vec<(Flow, T)>)
framework/src/state/cp_mergeable.rs:56
↓ 1 callers
Method
urg_flag
(&self)
framework/src/headers/tcp.rs:202
↓ 1 callers
Method
write_at_offset
(&mut self, offset: usize, data: &[u8])
framework/src/state/ring_buffer.rs:72
↓ 1 callers
Method
write_at_offset_from_tail
(&mut self, offset: usize, data: &[u8])
framework/src/state/ring_buffer.rs:98
↓ 1 callers
Method
write_header
(&mut self, header: &T2, offset: usize)
framework/src/interface/packet.rs:379
↓ 1 callers
Function
write_pidfile
()
scripts/tuning/pmqos-static.py:49
↓ 1 callers
Method
write_stack_offset
(&mut self, depth: usize, offset: usize)
framework/src/interface/packet.rs:169
Method
ack_num
(&self)
framework/src/headers/tcp.rs:126
Method
act
(&mut self)
framework/src/operators/transform_batch.rs:70
Method
act
(&mut self)
framework/src/operators/filter_batch.rs:48
Method
act
(&mut self)
framework/src/operators/packet_batch.rs:248
Method
act
(&mut self)
framework/src/operators/add_metadata_mut.rs:72
Method
act
(&mut self)
framework/src/operators/receive_batch.rs:52
Method
act
(&mut self)
framework/src/operators/add_metadata.rs:72
Method
add_data_beginning
(&mut self, len: usize)
framework/src/native/zcsi/mbuf.rs:69
Method
add_pipeline_to_core
Install a pipeline on a particular core.
framework/src/scheduler/context.rs:133
Method
add_task
Add a task to the current scheduler.
framework/src/scheduler/standalone_scheduler.rs:66
Method
add_test_pipeline_to_core
( &mut self, core: i32, run: Arc<T>, )
framework/src/scheduler/context.rs:108
Method
add_to_payload_head
(&mut self, size: usize)
framework/src/interface/packet.rs:344
Method
add_to_payload_tail
(&mut self, size: usize)
framework/src/interface/packet.rs:367
Function
address_inline
()
framework/tests/address.rs:7
Function
alloc_test
()
framework/tests/ring_buffer.rs:5
Method
allocate
(src: T)
framework/src/allocators/cache_aligned.rs:42
Method
allocate_batch_with_size
(&mut self, len: u16)
framework/src/operators/packet_batch.rs:45
Method
allocate_cpu_mask
()
framework/src/native/libnuma.rs:111
Method
allocate_node_mask
()
framework/src/native/libnuma.rs:105
← previous
next →
301–400 of 801, ranked by callers