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
↓ 105 callers
Method
insert_ipv4
(&mut self, ip: &Ipv4Addr, len: usize, gate: u16)
test/lpm-embedded/src/nf.rs:40
↓ 105 callers
Method
insert_ipv4
(&mut self, ip: &Ipv4Addr, len: usize, gate: u16)
test/lpm/src/nf.rs:40
↓ 76 callers
Method
map
Map over a set of header fields. Map and transform primarily differ in map being immutable. Immutability provides some optimization opportunities not
framework/src/operators/mod.rs:117
↓ 73 callers
Method
clone
(&self)
framework/src/headers/mac.rs:44
↓ 72 callers
Method
len
(&self)
framework/src/state/mergeable.rs:93
↓ 49 callers
Method
iter
(&self)
framework/src/state/mergeable.rs:89
↓ 35 callers
Method
parse
Parse the payload as header of type.
framework/src/operators/mod.rs:59
↓ 27 callers
Method
get
(&self, flow: &Flow)
framework/src/state/mergeable.rs:82
↓ 26 callers
Method
add_task
Add a task, and return a handle allowing the task to be run.
framework/src/scheduler/embedded_scheduler.rs:39
↓ 25 callers
Method
send
(&self, pkts: &mut [*mut MBuf])
framework/src/interface/port/mod.rs:33
↓ 21 callers
Method
transform
Transform a header field.
framework/src/operators/mod.rs:108
↓ 19 callers
Function
add_arg
native/init.c:54
↓ 18 callers
Method
add_data
Add data at a given sequence number.
framework/src/state/reordered_buffer/reordered_buffer.rs:362
↓ 17 callers
Method
get_header
(&self)
framework/src/interface/packet.rs:263
↓ 17 callers
Method
get_mut_header
(&mut self)
framework/src/interface/packet.rs:268
↓ 17 callers
Method
stats
Get stats for an RX/TX queue pair.
framework/src/interface/port/phy_port.rs:173
↓ 16 callers
Method
execute
(&mut self)
test/packet_generation/src/nf.rs:54
↓ 16 callers
Function
initialize_system
Initialize the system from a configuration.
framework/src/scheduler/context.rs:216
↓ 15 callers
Method
add_pipeline_to_run
Run a function (which installs a pipeline) on all schedulers in the system.
framework/src/scheduler/context.rs:72
↓ 15 callers
Function
basic_opts
Return a `getopts::Options` struct, preset so that it's ready to parse the configuration flags commonly used during Netbricks examples.
framework/src/config/flag_reader.rs:11
↓ 15 callers
Method
offset
(&self)
framework/src/interface/packet.rs:129
↓ 15 callers
Function
read_matches
Read the commonly used configuration flags parsed by `basic_opts()` into a `NetbricksConfiguration`. Some flags may cause side effects -- for example,
framework/src/config/flag_reader.rs:29
↓ 15 callers
Method
rxqs
Number of configured RXQs.
framework/src/interface/port/phy_port.rs:140
↓ 15 callers
Method
start_schedulers
Boot up all schedulers.
framework/src/scheduler/context.rs:47
↓ 15 callers
Method
swap_addresses
(&mut self)
framework/src/headers/mac.rs:140
↓ 14 callers
Method
compose
Erase type information. This is essential to allow different kinds of types to be collected together, as done for example when merging batches or comp
framework/src/operators/mod.rs:100
↓ 14 callers
Method
offset
(&self)
framework/src/headers/ip.rs:44
↓ 12 callers
Method
insert
(&mut self, ip: u32, len: usize, gate: u16)
test/lpm/src/nf.rs:45
↓ 12 callers
Method
seq
Set the current sequence number for the buffer.
framework/src/state/reordered_buffer/reordered_buffer.rs:349
↓ 10 callers
Method
len
(&self)
framework/src/operators/group_by.rs:98
↓ 10 callers
Method
payload
(&self)
framework/src/interface/packet.rs:234
↓ 9 callers
Method
get_payload
(&self)
framework/src/interface/packet.rs:467
↓ 9 callers
Method
len
(&self)
framework/src/state/ring_buffer.rs:149
↓ 9 callers
Function
merge
(batches: Vec<T>)
framework/src/operators/mod.rs:50
↓ 8 callers
Method
available
(&self)
framework/src/state/reordered_buffer/reordered_buffer.rs:317
↓ 8 callers
Function
create_packet
(mbuf: *mut MBuf, hdr: *mut T, offset: usize)
framework/src/interface/packet.rs:22
↓ 8 callers
Method
get_mbuf_ref
(&mut self)
framework/src/interface/packet.rs:521
↓ 8 callers
Method
is_empty
(&self)
framework/src/state/mergeable.rs:97
↓ 8 callers
Method
read_data
Read data from the buffer. The amount of data read is limited by the amount of in-order data available at the moment.
framework/src/state/reordered_buffer/reordered_buffer.rs:382
↓ 8 callers
Method
schedule_read
(&self)
framework/src/control/mod.rs:36
↓ 7 callers
Method
next
(&self, batch: &mut BatchIterator<Header = T, Metadata = M>)
framework/src/operators/iterator.rs:76
↓ 6 callers
Method
available
(&self)
framework/src/state/ring_buffer.rs:113
↓ 6 callers
Method
header
(&self)
framework/src/interface/packet.rs:117
↓ 6 callers
Method
wrapped_write
Writes data to self.vec[offset..], wrapping around the end of the Vec if necessary. Returns the number of bytes written.
framework/src/state/ring_buffer.rs:57
↓ 5 callers
Method
flow
(&self)
framework/src/headers/ip.rs:71
↓ 5 callers
Method
group_by
( self, groups: usize, group_f: GroupFn<Self::Header, Self::Metadata>, sched:
framework/src/operators/mod.rs:149
↓ 5 callers
Method
payload_offset
(&self)
framework/src/interface/packet.rs:243
↓ 5 callers
Method
payload_size
(&self)
framework/src/interface/packet.rs:258
↓ 5 callers
Function
rdtsc_unsafe
()
framework/src/utils/asm.rs:14
↓ 5 callers
Method
wrapped_read
Reads data from self.vec, wrapping around the end of the Vec if necessary. Returns the number of bytes written.
framework/src/state/ring_buffer.rs:42
↓ 4 callers
Method
add_data_end
(&mut self, len: usize)
framework/src/native/zcsi/mbuf.rs:84
↓ 4 callers
Function
cursec
native/test/test.c:17
↓ 4 callers
Function
mbuf_alloc_bulk
Using AVX for now. Revisit this decision someday */ mbuf_alloc_bulk: Bulk alloc packets. * array: Array to allocate into. * len: Length * cnt: Coun
native/mempool.c:231
↓ 4 callers
Function
mbuf_free
native/mempool.c:221
↓ 4 callers
Method
merge_cache
(&mut self)
framework/src/state/dp_mergeable.rs:41
↓ 4 callers
Method
new_poll_handle
(&self)
framework/src/control/linux/epoll.rs:63
↓ 4 callers
Method
new_virtual_queue
(&self, _queue: i32)
framework/src/interface/port/virt_port.rs:62
↓ 4 callers
Function
packet_from_mbuf_no_increment
(mbuf: *mut MBuf, offset: usize)
framework/src/interface/packet.rs:74
↓ 4 callers
Function
rdtscp_unsafe
()
debugging/rdtscp-test/src/main.rs:3
↓ 4 callers
Method
reset
(mut self)
framework/src/interface/packet.rs:450
↓ 4 callers
Method
src
(&self)
framework/src/headers/ip.rs:101
↓ 3 callers
Method
assert_size
(&self, bit: usize)
framework/src/native/libnuma.rs:118
↓ 3 callers
Method
capacity
(&self)
framework/src/operators/packet_batch.rs:272
↓ 3 callers
Method
clear
Clear the list.
framework/src/state/reordered_buffer/reordered_buffer.rs:274
↓ 3 callers
Method
copy_address
(&mut self, other: &MacAddress)
framework/src/headers/mac.rs:38
↓ 3 callers
Method
data_len
(&self)
framework/src/native/zcsi/mbuf.rs:47
↓ 3 callers
Method
exec_task
Run specified task.
framework/src/scheduler/embedded_scheduler.rs:54
↓ 3 callers
Method
fast_path_insert
(&mut self, data: &[u8])
framework/src/state/reordered_buffer/reordered_buffer.rs:404
↓ 3 callers
Method
find_available_node
(&mut self)
framework/src/state/reordered_buffer/reordered_buffer.rs:73
↓ 3 callers
Function
gather_m128i
native/include/simd.h:23
↓ 3 callers
Method
get_group
(&mut self, group: usize)
framework/src/operators/group_by.rs:102
↓ 3 callers
Method
get_packet_batch
(&mut self)
framework/src/operators/map_batch.rs:92
↓ 3 callers
Method
header_u8
(&self)
framework/src/interface/packet.rs:123
↓ 3 callers
Function
i32_from_bool
(x: bool)
framework/src/interface/port/phy_port.rs:120
↓ 3 callers
Function
init_mempool_core
native/mempool.c:57
↓ 3 callers
Function
init_pmd_port
native/pmd.c:114
↓ 3 callers
Function
init_system_secondary
Initialize the system as a DPDK secondary process with a set of VDEVs. User must specify mempool name to use.
framework/src/interface/dpdk.rs:37
↓ 3 callers
Function
init_thread
Called by each secondary threads on ZCSI, responsible for affinitization, * etc.*/
native/init.c:201
↓ 3 callers
Method
insert_segment
(&mut self, seq: u32, len: u16)
framework/src/state/reordered_buffer/reordered_buffer.rs:177
↓ 3 callers
Function
mbuf_free_bulk
for packets to be processed in the fast path, all packets must: * 1. share the same mempool * 2. single segment * 3. reference counter == 1 * 4. t
native/mempool.c:287
↓ 3 callers
Method
packet_ptr
(&mut self)
framework/src/operators/packet_batch.rs:161
↓ 3 callers
Method
protocol
(&self)
framework/src/headers/ip.rs:134
↓ 3 callers
Function
read_queue
(queue: &Value)
framework/src/config/config_reader.rs:75
↓ 3 callers
Method
remove
(&mut self, flow: &Flow)
framework/src/state/mergeable.rs:137
↓ 3 callers
Method
remove_node
Remove a node.
framework/src/state/reordered_buffer/reordered_buffer.rs:66
↓ 3 callers
Method
reverse_flow
(&self)
framework/src/utils/flow.rs:66
↓ 3 callers
Method
rst_flag
(&self)
framework/src/headers/tcp.rs:256
↓ 3 callers
Function
set_numa_domain
()
framework/src/interface/dpdk.rs:78
↓ 3 callers
Method
set_ttl
(&mut self, ttl: u8)
framework/src/headers/ip.rs:127
↓ 3 callers
Method
syn_flag
(&self)
framework/src/headers/tcp.rs:274
↓ 3 callers
Method
ttl
(&self)
framework/src/headers/ip.rs:121
↓ 3 callers
Method
write_at_tail
(&mut self, data: &[u8])
framework/src/state/ring_buffer.rs:84
↓ 3 callers
Method
write_stack_depth
(&mut self, new_depth: usize)
framework/src/interface/packet.rs:159
↓ 2 callers
Method
act
(&mut self)
framework/src/operators/map_batch.rs:52
↓ 2 callers
Method
add_test_pipeline
(&mut self, run: Arc<T>)
framework/src/scheduler/context.rs:90
↓ 2 callers
Method
add_to_batch
(&mut self, added: usize)
framework/src/operators/packet_batch.rs:181
↓ 2 callers
Method
alloc_packet_batch
(&mut self, len: u16, cnt: i32)
framework/src/operators/packet_batch.rs:186
↓ 2 callers
Function
allocate_cache_line
(size: usize)
framework/src/allocators/cache_aligned.rs:8
↓ 2 callers
Function
bind_to_domain
native/init.c:21
↓ 2 callers
Method
capacity
(&self)
framework/src/operators/map_batch.rs:77
next →
1–100 of 801, ranked by callers