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
↓ 2 callers
Function
chain_nf
(parent: T)
test/chain-test/src/nf.rs:6
↓ 2 callers
Method
clear
(&mut self)
framework/src/native/libnuma.rs:129
↓ 2 callers
Function
cpuid
()
debugging/rdtscp-test/src/main.rs:33
↓ 2 callers
Function
current_pframe_pool
Get mempool for calling thread's socket */
native/mempool.c:49
↓ 2 callers
Method
data_address
(&self, offset: usize)
framework/src/native/zcsi/mbuf.rs:34
↓ 2 callers
Method
data_base
(&self)
framework/src/interface/packet.rs:248
↓ 2 callers
Method
data_len
(&self)
framework/src/interface/packet.rs:253
↓ 2 callers
Method
deallocate_batch
(&mut self)
framework/src/operators/packet_batch.rs:63
↓ 2 callers
Function
do_fork
()
scripts/tuning/pmqos-static.py:36
↓ 2 callers
Method
done
(&mut self)
framework/src/operators/map_batch.rs:66
↓ 2 callers
Method
dst
(&self)
framework/src/headers/ip.rs:111
↓ 2 callers
Method
enqueue_mbufs
(&self, start: usize, enqueue: usize, mbufs: &[*mut MBuf])
framework/src/queues/mpsc_mbuf_queue.rs:56
↓ 2 callers
Method
enqueue_one
(&self, mbuf: *mut MBuf)
framework/src/queues/mpsc_mbuf_queue.rs:170
↓ 2 callers
Method
execute
Start scheduling pipelines.
framework/src/scheduler/context.rs:156
↓ 2 callers
Method
execute_internal
(&mut self, begin: u64)
framework/src/scheduler/standalone_scheduler.rs:127
↓ 2 callers
Method
execute_loop
Run the scheduling loop.
framework/src/scheduler/standalone_scheduler.rs:150
↓ 2 callers
Method
filter
Filter out packets, any packets for which `filter_f` returns false are dropped from the batch.
framework/src/operators/mod.rs:125
↓ 2 callers
Method
fin_flag
(&self)
framework/src/headers/tcp.rs:292
↓ 2 callers
Method
free_packet_batch
(&mut self)
framework/src/operators/packet_batch.rs:203
↓ 2 callers
Function
free_pmd_port
native/pmd.c:187
↓ 2 callers
Method
get_mbuf
(mut self)
framework/src/interface/packet.rs:516
↓ 2 callers
Function
get_mempool_for_core
native/mempool.c:93
↓ 2 callers
Function
get_pframe_pool
native/mempool.c:81
↓ 2 callers
Function
get_rte_eth_dev_info
native/pmd.c:63
↓ 2 callers
Method
get_task_dependencies
(&self)
framework/src/operators/map_batch.rs:97
↓ 2 callers
Method
get_token_noblock
(&mut self)
framework/src/control/linux/epoll.rs:92
↓ 2 callers
Method
handle_hup
(&mut self)
test/sctp-test/src/control.rs:56
↓ 2 callers
Method
handle_read_ready
(&mut self)
test/sctp-test/src/control.rs:23
↓ 2 callers
Method
handle_request
(&mut self, request: SchedulerCommand)
framework/src/scheduler/standalone_scheduler.rs:92
↓ 2 callers
Method
handle_write_ready
(&mut self)
test/sctp-test/src/control.rs:52
↓ 2 callers
Method
hash
(&self, state: &mut H)
framework/src/headers/mac.rs:63
↓ 2 callers
Method
in_range
(&self, address: u32)
framework/src/utils/flow.rs:44
↓ 2 callers
Function
init_eal
native/init.c:62
↓ 2 callers
Function
init_system_whitelisted
native/init.c:173
↓ 2 callers
Function
init_system_wl
Initialize the system, whitelisting some set of NICs.
framework/src/interface/dpdk.rs:31
↓ 2 callers
Function
init_system_wl_with_mempool
Initialize the system, whitelisting some set of NICs and allocating mempool of given size.
framework/src/interface/dpdk.rs:9
↓ 2 callers
Function
init_timer
native/init.c:152
↓ 2 callers
Method
insert_before_node
(&mut self, next: isize, seq: u32, len: u16)
framework/src/state/reordered_buffer/reordered_buffer.rs:85
↓ 2 callers
Function
ipv4_extract_flow
(bytes: &[u8])
framework/src/utils/flow.rs:53
↓ 2 callers
Method
ipv4_stamp_flow
(&self, bytes: &mut [u8])
framework/src/utils/flow.rs:77
↓ 2 callers
Function
kill_daemon
(force = False)
scripts/tuning/pmqos-static.py:105
↓ 2 callers
Method
listen
(&mut self)
framework/src/control/sctp.rs:62
↓ 2 callers
Function
lpm
( parent: T, s: &mut S, )
test/lpm-embedded/src/nf.rs:101
↓ 2 callers
Function
main
(inp)
scripts/read-target.py:8
↓ 2 callers
Method
merge_at_idx
(&mut self, idx: isize)
framework/src/state/reordered_buffer/reordered_buffer.rs:138
↓ 2 callers
Method
metadata
( self, generator: MetadataFn<Self::Header, Self::Metadata, M>, )
framework/src/operators/mod.rs:66
↓ 2 callers
Method
new_io_fd
(&self, fd: RawFd, token: Token)
framework/src/control/linux/epoll.rs:44
↓ 2 callers
Method
new_io_port
This assumes file is already set to be non-blocking. This must also be called only the first time round.
framework/src/control/linux/epoll.rs:40
↓ 2 callers
Function
new_mpsc_queue_pair
()
framework/src/queues/mpsc_mbuf_queue.rs:263
↓ 2 callers
Function
open_shared
(name: &str, size: usize)
framework/src/shared_state/mod.rs:29
↓ 2 callers
Method
out_of_order_insert
(&mut self, seq: u32, data: &[u8])
framework/src/state/reordered_buffer/reordered_buffer.rs:457
↓ 2 callers
Method
psh_flag
(&self)
framework/src/headers/tcp.rs:238
↓ 2 callers
Method
push_header
(mut self, header: &T2)
framework/src/interface/packet.rs:303
↓ 2 callers
Function
read_configuration
Read a configuration file and create a `NetbricksConfiguration` structure. `filename` should be TOML formatted file.
framework/src/config/config_reader.rs:258
↓ 2 callers
Method
read_data_common
(&mut self, data: &mut [u8])
framework/src/state/reordered_buffer/reordered_buffer.rs:530
↓ 2 callers
Method
read_from_head
(&mut self, data: &mut [u8])
framework/src/state/ring_buffer.rs:133
↓ 2 callers
Method
read_metadata
(&self)
framework/src/interface/packet.rs:273
↓ 2 callers
Method
read_offset
(&self)
framework/src/interface/packet.rs:229
↓ 2 callers
Function
read_payload
(rb: &mut ReorderedBuffer, to_read: usize, flow: Flow, payload_cache: &mut HashMap<Flow, Vec<u8>>)
test/tcp_payload/src/nf.rs:17
↓ 2 callers
Method
read_stack_depth
(&self)
framework/src/interface/packet.rs:154
↓ 2 callers
Method
recv
(&mut self, port: &Rx)
framework/src/operators/packet_batch.rs:78
↓ 2 callers
Method
recv
Call periodically to drain the queue.
framework/src/state/cp_mergeable.rs:65
↓ 2 callers
Function
recv_pkts
native/pmd.c:192
↓ 2 callers
Method
reference_producers
(&self)
framework/src/queues/mpsc_mbuf_queue.rs:51
↓ 2 callers
Method
reinterpret_metadata
(mut self)
framework/src/interface/packet.rs:295
↓ 2 callers
Method
remove_data_end
(&mut self, len: usize)
framework/src/native/zcsi/mbuf.rs:107
↓ 2 callers
Method
reset
Reset the packet pointer to 0. This is identical to composition except for using static dispatch.
framework/src/operators/mod.rs:133
↓ 2 callers
Function
round_to_power_of_2
(mut size: usize)
framework/src/utils/mod.rs:16
↓ 2 callers
Method
schedule_read_rawfd
(&self, fd: RawFd, token: Token)
framework/src/control/linux/epoll.rs:19
↓ 2 callers
Method
schedule_write_rawfd
(&self, fd: RawFd, token: Token)
framework/src/control/linux/epoll.rs:31
↓ 2 callers
Method
seek_tail
(&mut self, increment_by: usize)
framework/src/state/ring_buffer.rs:156
↓ 2 callers
Function
send_pkts
native/pmd.c:204
↓ 2 callers
Method
seq_num
(&self)
framework/src/headers/tcp.rs:116
↓ 2 callers
Method
set_etype
(&mut self, etype: u16)
framework/src/headers/mac.rs:135
↓ 2 callers
Function
set_mempool
native/mempool.c:143
↓ 2 callers
Method
stop
Stop all schedulers, safely shutting down the system.
framework/src/scheduler/context.rs:189
↓ 2 callers
Function
test
(ports: Vec<T>, sched: &mut S)
test/lpm/src/main.rs:22
↓ 2 callers
Function
test
(ports: Vec<T>, sched: &mut S, delay_arg: u64)
test/delay-test/src/main.rs:23
↓ 2 callers
Function
test_func
(id: &str)
test/embedded-scheduler-test/src/main.rs:9
↓ 2 callers
Method
update_ptrs
(&mut self, header: *mut u8, offset: usize)
framework/src/interface/packet.rs:210
↓ 2 callers
Method
write_metadata
(&mut self, metadata: &M2)
framework/src/interface/packet.rs:282
↓ 1 callers
Function
FindStruct
(node, name)
3rdparty/translate.py:4
↓ 1 callers
Function
PrintTypes
(scursor)
3rdparty/translate.py:14
↓ 1 callers
Method
accept_connection
(&mut self, available: Available)
framework/src/control/sctp.rs:79
↓ 1 callers
Method
accept_connection
(&mut self, available: Available)
framework/src/control/tcp.rs:80
↓ 1 callers
Method
ack_flag
(&self)
framework/src/headers/tcp.rs:220
↓ 1 callers
Function
acl_match
(parent: T, acls: Vec<Acl>)
test/acl-fw/src/nf.rs:40
↓ 1 callers
Method
act
(&mut self)
framework/src/operators/merge_batch.rs:44
↓ 1 callers
Method
act
(&mut self)
framework/src/operators/send_batch.rs:66
↓ 1 callers
Method
add_head_to_seg_list
(&mut self)
framework/src/state/reordered_buffer/reordered_buffer.rs:421
↓ 1 callers
Method
add_parent_task
(&mut self, task: usize)
framework/src/operators/packet_batch.rs:33
↓ 1 callers
Function
attach_pmd_device
Attach a device with a given name (useful when attaching virtual devices). Returns either the port number of the device or an error if not found
native/pmd.c:246
↓ 1 callers
Method
available
(&self)
framework/src/operators/packet_batch.rs:72
↓ 1 callers
Method
buf_len
(&self)
framework/src/native/zcsi/mbuf.rs:41
↓ 1 callers
Method
capacity
(&self)
framework/src/operators/filter_batch.rs:80
↓ 1 callers
Function
chain
( parent: T, len: u32, pos: u32, )
test/chain-test/src/nf.rs:27
↓ 1 callers
Method
clear
(&mut self)
framework/src/state/ring_buffer.rs:161
↓ 1 callers
Method
clear_packets
(&mut self)
framework/src/operators/act.rs:24
↓ 1 callers
Method
clone
(&self)
framework/src/queues/mpsc_mbuf_queue.rs:221
↓ 1 callers
Function
close_fds
()
scripts/tuning/pmqos-static.py:41
← previous
next →
101–200 of 801, ranked by callers