Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Index your code
hub
/
github.com/NicolasLagaillardie/mpst_rust_github
/ functions
Functions
6,691 in github.com/NicolasLagaillardie/mpst_rust_github
⨍
Functions
6,691
◇
Types & classes
3,362
↓ 1,972 callers
Method
send
Send a payload of type T to role A
src/meshedchannels/impl_c.rs:34
↓ 1,639 callers
Method
recv
Receive a payload from role A
src/meshedchannels/impl_c.rs:52
↓ 1,452 callers
Function
new
()
examples/tcp_and_others/rk.rs:140
↓ 1,205 callers
Method
send
(self, channel: &Channel<Role>, value: u32)
examples/tcp_and_others/rk.rs:62
↓ 961 callers
Method
recv
(self, channel: &Channel<Role>)
examples/tcp_and_others/rk.rs:75
↓ 629 callers
Function
send
Send a value of type `T`. Always succeeds. Returns the continuation of the session `S`.
src/binary/send.rs:13
↓ 558 callers
Function
fork_mpst
Creates and returns a tuple of three child processes for three [`MeshedChannels`] linked together. # Example ``` use std::error::Error; use mpstthr
src/functionmpst/fork.rs:123
↓ 549 callers
Method
close
Close the current connection
src/meshedchannels/impl_c.rs:255
↓ 195 callers
Function
recv
Receive a value of type `T`. Can fail. Returns either a pair of the received value and the continuation of the session `S` or an error.
src/binary/recv.rs:12
↓ 181 callers
Function
close
Closes a session. Synchronises with the partner, and fails if the partner has crashed.
src/binary/close.rs:10
↓ 154 callers
Function
fork_with_thread_id
(p: P)
src/binary/fork.rs:12
↓ 73 callers
Function
cancel
Cancels a session. Always succeeds. If the partner calls `recv` or `close` after cancellation, those calls fail. # Example ``` use mpstthree::binary
src/binary/cancel.rs:22
↓ 64 callers
Function
get_tuple_matrix
Return (line, column, index) of matrix
mpst_seq_proc/src/common_functions/maths.rs:52
↓ 59 callers
Function
close_mpst
(input: TokenStream)
mpst_seq_proc/src/lib.rs:192
↓ 40 callers
Function
main
()
tests/udp/binary.rs:127
↓ 34 callers
Function
send_mpst_c_to_a
Send a value of type `T` from C to A. Always succeeds. Returns the continuation of the `MeshedChannels<S1, S2, R, N>`. # Example ``` use mpstthree::
src/functionmpst/send.rs:185
↓ 32 callers
Function
recv_mpst_c_from_a
Receive a value of type `T` on C from A. Can fail. Returns either a pair of the received value and the continuation of the `MeshedChannels<S1, S2, R,
src/functionmpst/recv.rs:244
↓ 25 callers
Function
send_mpst_c_to_b
Send a value of type `T` from C to B. Always succeeds. Returns the continuation of the `MeshedChannels<S1, S2, R, N>`. # Example ``` use mpstthree::
src/functionmpst/send.rs:362
↓ 24 callers
Function
recv_mpst_a_from_b
Receive a value of type `T` on A from B. Can fail. Returns either a pair of the received value and the continuation of the `MeshedChannels<S1, S2, R,
src/functionmpst/recv.rs:98
↓ 22 callers
Function
send_mpst_b_to_a
Send a value of type `T` from B to A. Always succeeds. Returns the continuation of the `MeshedChannels<S1, S2, R, N>`. # Example ``` use mpstthree::
src/functionmpst/send.rs:126
↓ 21 callers
Function
send_mpst_a_to_c
Send a value of type `T` from A to C. Always succeeds. Returns the continuation of the `MeshedChannels<S1, S2, R, N>`. # Example ``` use mpstthree::
src/functionmpst/send.rs:244
↓ 19 callers
Function
parenthesised_groups
Expand parenthesised blocks for labels
mpst_seq_proc/src/common_functions/expand/parenthesised.rs:57
↓ 19 callers
Function
recv_mpst_c_from_b
Receive a value of type `T` on C from B. Can fail. Returns either a pair of the received value and the continuation of the `MeshedChannels<S1, S2, R,
src/functionmpst/recv.rs:463
↓ 19 callers
Function
send_mpst_a_to_b
Send a value of type `T` from A to B. Always succeeds. Returns the continuation `MeshedChannels<S1, S2, R, N>`. # Example ``` use mpstthree::binary:
src/functionmpst/send.rs:67
↓ 18 callers
Method
offer
Receive a binary choice from role A. Be careful: the left and right stacks must be the same.
src/meshedchannels/impl_c.rs:94
↓ 18 callers
Function
recv_mpst_a_from_c
Receive a value of type `T` on A from C. Can fail. Returns either a pair of the received value and the continuation of the `MeshedChannels<S1, S2, R,
src/functionmpst/recv.rs:317
↓ 17 callers
Function
recv_mpst_b_from_a
Receive a value of type `T` on B from A. Can fail. Returns either a pair of the received value and the continuation of the `MeshedChannels<S1, S2, R,
src/functionmpst/recv.rs:171
↓ 14 callers
Function
create_name_structs
Create name structs
mpst_seq_proc/src/common_functions/expand/aux_fork.rs:81
↓ 14 callers
Function
get_tuple_diag
Return (line, column, index) of diag
mpst_seq_proc/src/common_functions/maths.rs:130
↓ 13 callers
Function
diag_and_matrix
Create the whole matrix of index according to line and column
mpst_seq_proc/src/common_functions/maths.rs:29
↓ 11 callers
Function
create_role_structs
Create role struct
mpst_seq_proc/src/common_functions/expand/aux_fork.rs:44
↓ 11 callers
Function
get_head_payload_continuation
(full_block: &str)
src/checking/aux_checker.rs:196
↓ 11 callers
Function
recv_mpst_b_from_c
Receive a value of type `T` on B from C. Can fail. Returns either a pair of the received value and the continuation of the `MeshedChannels<S1, S2, R,
src/functionmpst/recv.rs:390
↓ 10 callers
Function
get_graph_session
( current_role: &str, full_session: VecOfStr, roles: &[String], branches_receivers: HashMap<St
src/checking/aux_checker.rs:777
↓ 9 callers
Function
cancel
Expand choose cancel method
mpst_seq_proc/src/common_functions/expand/cancel.rs:6
↓ 9 callers
Method
choose_left
Choose the left branch of a binary choice and send it to A and B
src/meshedchannels/impl_c.rs:215
↓ 9 callers
Method
choose_right
Choose the right branch of a binary choice and send it to A and B
src/meshedchannels/impl_c.rs:234
↓ 9 callers
Function
create_session_type_structs
Create session type structs
mpst_seq_proc/src/common_functions/expand/aux_baking.rs:17
↓ 9 callers
Function
create_session_types
Create session types
mpst_seq_proc/src/common_functions/expand/aux_baking.rs:10
↓ 9 callers
Function
meshedchannels
Expand choose methods
mpst_seq_proc/src/common_functions/expand/meshedchannels.rs:6
↓ 8 callers
Function
diag_and_matrix_w_offset
Create the whole matrix of index according to line and column
mpst_seq_proc/src/common_functions/maths.rs:106
↓ 7 callers
Function
diag
Create the whole matrix of index according to line and column
mpst_seq_proc/src/common_functions/maths.rs:6
↓ 7 callers
Function
send_mpst_b_to_c
Send a value of type `T` from B to C. Always succeeds. Returns the continuation of the `MeshedChannels<S1, S2, R, N>`. # Example ``` use mpstthree::
src/functionmpst/send.rs:303
↓ 7 callers
Function
test
(path)
scripts/create_graphs/ring_bench.py:54
↓ 7 callers
Function
test
(path)
scripts/create_graphs/ping_pong_bench.py:35
↓ 7 callers
Function
test
(path)
scripts/create_graphs/mesh_bench.py:54
↓ 6 callers
Function
close
Expand close methods
mpst_seq_proc/src/common_functions/expand/close.rs:6
↓ 6 callers
Function
double_choice_checker
()
tests/baking_mod/simple_baking/b_choose.rs:157
↓ 6 callers
Function
double_choice_left
()
tests/baking_mod/simple_baking/b_choose.rs:131
↓ 6 callers
Function
double_choice_right
()
tests/baking_mod/simple_baking/b_choose.rs:144
↓ 6 callers
Function
get_line_column_from_diag
Return (line, column) of diag from index
mpst_seq_proc/src/common_functions/maths.rs:73
↓ 6 callers
Function
new_run_usecase_recursive
()
tests/macros_multiple_mod/macro_multi_recursion.rs:197
↓ 6 callers
Function
parse_stream_sessions
(input: ParseStream)
mpst_seq_proc/src/common_functions/parsing.rs:22
↓ 5 callers
Function
clean_session
(session: &str)
src/checking/aux_checker.rs:43
↓ 5 callers
Function
create_functions
Create functions
mpst_seq_proc/src/common_functions/expand/aux_fork.rs:106
↓ 5 callers
Function
create_names
Create names
mpst_seq_proc/src/common_functions/expand/aux_fork.rs:69
↓ 5 callers
Function
create_new_names
Create new names
mpst_seq_proc/src/common_functions/expand/aux_fork.rs:93
↓ 5 callers
Function
create_new_roles
Create role struct
mpst_seq_proc/src/common_functions/expand/aux_fork.rs:56
↓ 5 callers
Function
create_roles
Create roles
mpst_seq_proc/src/common_functions/expand/aux_fork.rs:32
↓ 5 callers
Function
create_session_structs
Create session structs
mpst_seq_proc/src/common_functions/expand/aux_fork.rs:20
↓ 5 callers
Function
create_sessions
Create sessions
mpst_seq_proc/src/common_functions/expand/aux_fork.rs:8
↓ 5 callers
Function
punctuated_prepend
Extend `right` with `left`, then assign `right` value to `left`
mpst_seq_proc/src/session_timed/session.rs:21
↓ 4 callers
Function
choose
Expand choose left and right methods
mpst_seq_proc/src/common_functions/expand/choose.rs:576
↓ 4 callers
Function
choose_mpst_create_multi_to_all
Expand choose methods for interleaved sessions
mpst_seq_proc/src/common_functions/expand/choose.rs:1141
↓ 4 callers
Function
create_and_save_fig
(name_file, title_graph, list_ampst, list_atmp, list_mpst, list_binary, list_crossbeam, scale, localisation)
scripts/create_graphs/examples_literature_atmp_check_build_release.py:196
↓ 4 callers
Function
file_descriptor
`FileDescriptor` object which allows dynamic access to files
src/protobuf/generated/globaltype.rs:748
↓ 4 callers
Function
fork_mpst
Expand fork methods
mpst_seq_proc/src/common_functions/expand/fork.rs:17
↓ 4 callers
Function
fork_mpst_solo
(f: F)
src/interleaved/fork.rs:16
↓ 4 callers
Function
get_blocks
(full_block: &str)
src/checking/aux_checker.rs:154
↓ 4 callers
Function
interleaved_main
()
tests/interleaved_mod/macro_recursive_solo.rs:194
↓ 4 callers
Function
messages_and_stacks
Use both functions #[messages] and #[stacks] at once
src/top_down_nuscr/auxiliary_objects/messages_and_stacks_update/mod.rs:12
↓ 4 callers
Function
offer
Expand offer methods
mpst_seq_proc/src/common_functions/expand/offer.rs:113
↓ 4 callers
Function
parse_stream_roles
(input: ParseStream)
mpst_seq_proc/src/common_functions/parsing.rs:8
↓ 4 callers
Function
recv
Expand receive methods
mpst_seq_proc/src/common_functions/expand/recv.rs:96
↓ 4 callers
Function
recv_from_all
Expand receive from all methods
mpst_seq_proc/src/common_functions/expand/recv.rs:277
↓ 4 callers
Function
rx
(_role: R, cont: C)
examples/tcp_and_others/rk.rs:80
↓ 4 callers
Function
send_canceled
Expand send methods for baking with cancelation
mpst_seq_proc/src/common_functions/expand/send.rs:90
↓ 4 callers
Function
tx
(_role: R, cont: C)
examples/tcp_and_others/rk.rs:67
↓ 3 callers
Function
build_dual
(session: &str)
src/checking/aux_checker.rs:237
↓ 3 callers
Method
cancel
Cancel the session
src/name/c.rs:68
↓ 3 callers
Function
check_global
Check whether the input is the first line of any new nuscrT protocol
src/top_down_nuscr/auxiliary_objects/regex_nuscr.rs:37
↓ 3 callers
Function
check_message
Check whether this is a shared message
src/top_down_nuscr/auxiliary_objects/regex_nuscr.rs:52
↓ 3 callers
Function
choose_atmp
Expand choose left and right timed methods
mpst_seq_proc/src/common_functions/expand/choose.rs:1188
↓ 3 callers
Function
choose_atmp_mpst_create_multi_to_all
Expand choose methods for interleaved sessions
mpst_seq_proc/src/common_functions/expand/choose.rs:1790
↓ 3 callers
Function
close_atmp
Expand close methods
mpst_seq_proc/src/common_functions/expand/close_atmp.rs:6
↓ 3 callers
Function
close_mpst
Closes a [`MeshedChannels`]. Synchronises with all partners, and fails if one of the partners has crashed. # Example ``` use mpstthree::binary::str
src/functionmpst/close.rs:58
↓ 3 callers
Function
close_tcp
(s: End, stream: TcpStream, tcp: bool)
src/transport/tcp/close.rs:23
↓ 3 callers
Function
create_atmp_role_structs
Create timed role structs
mpst_seq_proc/src/common_functions/expand/aux_baking.rs:32
↓ 3 callers
Function
create_function_details
Create function details
mpst_seq_proc/src/common_functions/expand/aux_fork.rs:118
↓ 3 callers
Function
create_join_handle
Create join handle
mpst_seq_proc/src/common_functions/expand/aux_fork.rs:131
↓ 3 callers
Function
create_new_channels
Create new channels
mpst_seq_proc/src/common_functions/expand/aux_fork.rs:142
↓ 3 callers
Function
create_new_meshedchannels
Create new meshedchannels
mpst_seq_proc/src/common_functions/expand/aux_fork.rs:164
↓ 3 callers
Function
extract_index_node
( index_node: &[usize], depth_level: usize, )
src/checking/aux_checker.rs:215
↓ 3 callers
Function
fork_simple
Spawn a thread to run a function `p` which expects a `MeshedChannels` as an input
src/functionmpst/fork.rs:16
↓ 3 callers
Function
fork_tcp
(p: P, address: &str)
src/transport/tcp/fork.rs:28
↓ 3 callers
Function
generator
Generate endpoints from a nuscr file with timed global protocol
src/top_down_nuscr/generator.rs:20
↓ 3 callers
Function
meshedchannels_fields
()
tests/baking_mod/unit_meshedchannels.rs:22
↓ 3 callers
Function
meshedchannels_methods
()
tests/baking_mod/unit_meshedchannels.rs:57
↓ 3 callers
Function
meshedchannels_self_methods
()
tests/baking_mod/unit_meshedchannels.rs:104
↓ 3 callers
Function
offer_atmp
Expand offer methods
mpst_seq_proc/src/common_functions/expand/offer.rs:219
next →
1–100 of 6,691, ranked by callers