Module libp2p_yamux_session

Behaviours: gen_server.

Data Types

flags()


flags() = non_neg_integer()
0 (bit combo of ?SYN ?ACK ?FIN ?RST)

header() = #header{type = non_neg_integer(), flags = flags(), stream_id = stream_id(), length = non_neg_integer()}

stream_id()


stream_id() = non_neg_integer()

Function Index

handle_call/3
handle_cast/2
handle_info/2
header_data/3
header_length/1
header_update/3
init/1
send_data/3
send_data/4
send_header/2
send_header/3
start_client/3
start_server/4
terminate/2

Function Details

handle_call/3

handle_call(Msg, From, State) -> any()

handle_cast/2

handle_cast(Msg, State) -> any()

handle_info/2

handle_info(Msg, State) -> any()

header_data/3


header_data(StreamID::stream_id(), Flags::flags(), Length::non_neg_integer()) -> header()


header_length/1


header_length(Header::header()) -> non_neg_integer()


header_update/3


header_update(Flags::flags(), StreamID::stream_id(), Length::non_neg_integer()) -> header()


init/1

init(X1) -> any()

send_data/3


send_data(Pid::pid(), Header::header(), Data::binary()) -> ok | {error, term()}


send_data/4


send_data(Pid::pid(), Header::header(), Data::binary(), Timeout::non_neg_integer()) -> ok | {error, term()}


send_header/2


send_header(Pid::pid(), Header::header()) -> ok | {error, term()}


send_header/3


send_header(Pid::pid(), Header::header(), Timeout::non_neg_integer()) -> ok | {error, term()}


start_client/3


start_client(Connection::libp2p_connection:connection(), Path::string(), TID::ets:tab()) -> {ok, pid()}


start_server/4


start_server(Connection::libp2p_connection:connection(), Path::string(), TID::ets:tab(), X4::[]) -> no_return()


terminate/2

terminate(Reason, State) -> any()