MCPcopy Index your code

hub / github.com/NicolasLagaillardie/mpst_rust_github / functions

Functions6,691 in github.com/NicolasLagaillardie/mpst_rust_github

↓ 1,972 callersMethodsend
Send a payload of type T to role A
src/meshedchannels/impl_c.rs:34
↓ 1,639 callersMethodrecv
Receive a payload from role A
src/meshedchannels/impl_c.rs:52
↓ 1,452 callersFunctionnew
()
examples/tcp_and_others/rk.rs:140
↓ 1,205 callersMethodsend
(self, channel: &Channel<Role>, value: u32)
examples/tcp_and_others/rk.rs:62
↓ 961 callersMethodrecv
(self, channel: &Channel<Role>)
examples/tcp_and_others/rk.rs:75
↓ 629 callersFunctionsend
Send a value of type `T`. Always succeeds. Returns the continuation of the session `S`.
src/binary/send.rs:13
↓ 558 callersFunctionfork_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 callersMethodclose
Close the current connection
src/meshedchannels/impl_c.rs:255
↓ 195 callersFunctionrecv
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 callersFunctionclose
Closes a session. Synchronises with the partner, and fails if the partner has crashed.
src/binary/close.rs:10
↓ 154 callersFunctionfork_with_thread_id
(p: P)
src/binary/fork.rs:12
↓ 73 callersFunctioncancel
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 callersFunctionget_tuple_matrix
Return (line, column, index) of matrix
mpst_seq_proc/src/common_functions/maths.rs:52
↓ 59 callersFunctionclose_mpst
(input: TokenStream)
mpst_seq_proc/src/lib.rs:192
↓ 40 callersFunctionmain
()
tests/udp/binary.rs:127
↓ 34 callersFunctionsend_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 callersFunctionrecv_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 callersFunctionsend_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 callersFunctionrecv_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 callersFunctionsend_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 callersFunctionsend_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 callersFunctionparenthesised_groups
Expand parenthesised blocks for labels
mpst_seq_proc/src/common_functions/expand/parenthesised.rs:57
↓ 19 callersFunctionrecv_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 callersFunctionsend_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 callersMethodoffer
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 callersFunctionrecv_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 callersFunctionrecv_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 callersFunctioncreate_name_structs
Create name structs
mpst_seq_proc/src/common_functions/expand/aux_fork.rs:81
↓ 14 callersFunctionget_tuple_diag
Return (line, column, index) of diag
mpst_seq_proc/src/common_functions/maths.rs:130
↓ 13 callersFunctiondiag_and_matrix
Create the whole matrix of index according to line and column
mpst_seq_proc/src/common_functions/maths.rs:29
↓ 11 callersFunctioncreate_role_structs
Create role struct
mpst_seq_proc/src/common_functions/expand/aux_fork.rs:44
↓ 11 callersFunctionget_head_payload_continuation
(full_block: &str)
src/checking/aux_checker.rs:196
↓ 11 callersFunctionrecv_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 callersFunctionget_graph_session
( current_role: &str, full_session: VecOfStr, roles: &[String], branches_receivers: HashMap<St
src/checking/aux_checker.rs:777
↓ 9 callersFunctioncancel
Expand choose cancel method
mpst_seq_proc/src/common_functions/expand/cancel.rs:6
↓ 9 callersMethodchoose_left
Choose the left branch of a binary choice and send it to A and B
src/meshedchannels/impl_c.rs:215
↓ 9 callersMethodchoose_right
Choose the right branch of a binary choice and send it to A and B
src/meshedchannels/impl_c.rs:234
↓ 9 callersFunctioncreate_session_type_structs
Create session type structs
mpst_seq_proc/src/common_functions/expand/aux_baking.rs:17
↓ 9 callersFunctioncreate_session_types
Create session types
mpst_seq_proc/src/common_functions/expand/aux_baking.rs:10
↓ 9 callersFunctionmeshedchannels
Expand choose methods
mpst_seq_proc/src/common_functions/expand/meshedchannels.rs:6
↓ 8 callersFunctiondiag_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 callersFunctiondiag
Create the whole matrix of index according to line and column
mpst_seq_proc/src/common_functions/maths.rs:6
↓ 7 callersFunctionsend_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 callersFunctiontest
(path)
scripts/create_graphs/ring_bench.py:54
↓ 7 callersFunctiontest
(path)
scripts/create_graphs/ping_pong_bench.py:35
↓ 7 callersFunctiontest
(path)
scripts/create_graphs/mesh_bench.py:54
↓ 6 callersFunctionclose
Expand close methods
mpst_seq_proc/src/common_functions/expand/close.rs:6
↓ 6 callersFunctiondouble_choice_checker
()
tests/baking_mod/simple_baking/b_choose.rs:157
↓ 6 callersFunctiondouble_choice_left
()
tests/baking_mod/simple_baking/b_choose.rs:131
↓ 6 callersFunctiondouble_choice_right
()
tests/baking_mod/simple_baking/b_choose.rs:144
↓ 6 callersFunctionget_line_column_from_diag
Return (line, column) of diag from index
mpst_seq_proc/src/common_functions/maths.rs:73
↓ 6 callersFunctionnew_run_usecase_recursive
()
tests/macros_multiple_mod/macro_multi_recursion.rs:197
↓ 6 callersFunctionparse_stream_sessions
(input: ParseStream)
mpst_seq_proc/src/common_functions/parsing.rs:22
↓ 5 callersFunctionclean_session
(session: &str)
src/checking/aux_checker.rs:43
↓ 5 callersFunctioncreate_functions
Create functions
mpst_seq_proc/src/common_functions/expand/aux_fork.rs:106
↓ 5 callersFunctioncreate_names
Create names
mpst_seq_proc/src/common_functions/expand/aux_fork.rs:69
↓ 5 callersFunctioncreate_new_names
Create new names
mpst_seq_proc/src/common_functions/expand/aux_fork.rs:93
↓ 5 callersFunctioncreate_new_roles
Create role struct
mpst_seq_proc/src/common_functions/expand/aux_fork.rs:56
↓ 5 callersFunctioncreate_roles
Create roles
mpst_seq_proc/src/common_functions/expand/aux_fork.rs:32
↓ 5 callersFunctioncreate_session_structs
Create session structs
mpst_seq_proc/src/common_functions/expand/aux_fork.rs:20
↓ 5 callersFunctioncreate_sessions
Create sessions
mpst_seq_proc/src/common_functions/expand/aux_fork.rs:8
↓ 5 callersFunctionpunctuated_prepend
Extend `right` with `left`, then assign `right` value to `left`
mpst_seq_proc/src/session_timed/session.rs:21
↓ 4 callersFunctionchoose
Expand choose left and right methods
mpst_seq_proc/src/common_functions/expand/choose.rs:576
↓ 4 callersFunctionchoose_mpst_create_multi_to_all
Expand choose methods for interleaved sessions
mpst_seq_proc/src/common_functions/expand/choose.rs:1141
↓ 4 callersFunctioncreate_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 callersFunctionfile_descriptor
`FileDescriptor` object which allows dynamic access to files
src/protobuf/generated/globaltype.rs:748
↓ 4 callersFunctionfork_mpst
Expand fork methods
mpst_seq_proc/src/common_functions/expand/fork.rs:17
↓ 4 callersFunctionfork_mpst_solo
(f: F)
src/interleaved/fork.rs:16
↓ 4 callersFunctionget_blocks
(full_block: &str)
src/checking/aux_checker.rs:154
↓ 4 callersFunctioninterleaved_main
()
tests/interleaved_mod/macro_recursive_solo.rs:194
↓ 4 callersFunctionmessages_and_stacks
Use both functions #[messages] and #[stacks] at once
src/top_down_nuscr/auxiliary_objects/messages_and_stacks_update/mod.rs:12
↓ 4 callersFunctionoffer
Expand offer methods
mpst_seq_proc/src/common_functions/expand/offer.rs:113
↓ 4 callersFunctionparse_stream_roles
(input: ParseStream)
mpst_seq_proc/src/common_functions/parsing.rs:8
↓ 4 callersFunctionrecv
Expand receive methods
mpst_seq_proc/src/common_functions/expand/recv.rs:96
↓ 4 callersFunctionrecv_from_all
Expand receive from all methods
mpst_seq_proc/src/common_functions/expand/recv.rs:277
↓ 4 callersFunctionrx
(_role: R, cont: C)
examples/tcp_and_others/rk.rs:80
↓ 4 callersFunctionsend_canceled
Expand send methods for baking with cancelation
mpst_seq_proc/src/common_functions/expand/send.rs:90
↓ 4 callersFunctiontx
(_role: R, cont: C)
examples/tcp_and_others/rk.rs:67
↓ 3 callersFunctionbuild_dual
(session: &str)
src/checking/aux_checker.rs:237
↓ 3 callersMethodcancel
Cancel the session
src/name/c.rs:68
↓ 3 callersFunctioncheck_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 callersFunctioncheck_message
Check whether this is a shared message
src/top_down_nuscr/auxiliary_objects/regex_nuscr.rs:52
↓ 3 callersFunctionchoose_atmp
Expand choose left and right timed methods
mpst_seq_proc/src/common_functions/expand/choose.rs:1188
↓ 3 callersFunctionchoose_atmp_mpst_create_multi_to_all
Expand choose methods for interleaved sessions
mpst_seq_proc/src/common_functions/expand/choose.rs:1790
↓ 3 callersFunctionclose_atmp
Expand close methods
mpst_seq_proc/src/common_functions/expand/close_atmp.rs:6
↓ 3 callersFunctionclose_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 callersFunctionclose_tcp
(s: End, stream: TcpStream, tcp: bool)
src/transport/tcp/close.rs:23
↓ 3 callersFunctioncreate_atmp_role_structs
Create timed role structs
mpst_seq_proc/src/common_functions/expand/aux_baking.rs:32
↓ 3 callersFunctioncreate_function_details
Create function details
mpst_seq_proc/src/common_functions/expand/aux_fork.rs:118
↓ 3 callersFunctioncreate_join_handle
Create join handle
mpst_seq_proc/src/common_functions/expand/aux_fork.rs:131
↓ 3 callersFunctioncreate_new_channels
Create new channels
mpst_seq_proc/src/common_functions/expand/aux_fork.rs:142
↓ 3 callersFunctioncreate_new_meshedchannels
Create new meshedchannels
mpst_seq_proc/src/common_functions/expand/aux_fork.rs:164
↓ 3 callersFunctionextract_index_node
( index_node: &[usize], depth_level: usize, )
src/checking/aux_checker.rs:215
↓ 3 callersFunctionfork_simple
Spawn a thread to run a function `p` which expects a `MeshedChannels` as an input
src/functionmpst/fork.rs:16
↓ 3 callersFunctionfork_tcp
(p: P, address: &str)
src/transport/tcp/fork.rs:28
↓ 3 callersFunctiongenerator
Generate endpoints from a nuscr file with timed global protocol
src/top_down_nuscr/generator.rs:20
↓ 3 callersFunctionmeshedchannels_fields
()
tests/baking_mod/unit_meshedchannels.rs:22
↓ 3 callersFunctionmeshedchannels_methods
()
tests/baking_mod/unit_meshedchannels.rs:57
↓ 3 callersFunctionmeshedchannels_self_methods
()
tests/baking_mod/unit_meshedchannels.rs:104
↓ 3 callersFunctionoffer_atmp
Expand offer methods
mpst_seq_proc/src/common_functions/expand/offer.rs:219
next →1–100 of 6,691, ranked by callers