High availability
Macros | |
| #define | M0_TRACE_SUBSYSTEM M0_TRACE_SUBSYS_HA |
| #define | HACO_F |
| #define | HACO_P(_hc) |
| #define | M0_TRACE_SUBSYSTEM M0_TRACE_SUBSYS_HA |
| #define | M0_TRACE_SUBSYSTEM M0_TRACE_SUBSYS_HA |
| #define | M0_TRACE_SUBSYSTEM M0_TRACE_SUBSYS_HA |
| #define | M0_TRACE_SUBSYSTEM M0_TRACE_SUBSYS_OTHER |
| #define | M0_TRACE_SUBSYSTEM M0_TRACE_SUBSYS_HA |
| #define | M0_TRACE_SUBSYSTEM M0_TRACE_SUBSYS_HA |
| #define | M0_TRACE_SUBSYSTEM M0_TRACE_SUBSYS_HA |
| #define | M0_TRACE_SUBSYSTEM M0_TRACE_SUBSYS_HA |
| #define | HLTAGS_F |
| #define | HLTAGS_P(_tags) |
| #define | M0_TRACE_SUBSYSTEM M0_TRACE_SUBSYS_HA |
| #define | M0_TRACE_SUBSYSTEM M0_TRACE_SUBSYS_HA |
| #define | M0_TRACE_SUBSYSTEM M0_TRACE_SUBSYS_HA |
| #define | M0_TRACE_SUBSYSTEM M0_TRACE_SUBSYS_HA |
| #define | M0_TRACE_SUBSYSTEM M0_TRACE_SUBSYS_UT |
| #define | M0_TRACE_SUBSYSTEM M0_TRACE_SUBSYS_UT |
| #define | M0_TRACE_SUBSYSTEM M0_TRACE_SUBSYS_UT |
| #define | M0_TRACE_SUBSYSTEM M0_TRACE_SUBSYS_UT |
| #define | M0_TRACE_SUBSYSTEM M0_TRACE_SUBSYS_UT |
| #define | M0_TRACE_SUBSYSTEM M0_TRACE_SUBSYS_UT |
| #define | M0_TRACE_SUBSYSTEM M0_TRACE_SUBSYS_UT |
Typedefs | |
| typedef void(* | m0_ha_client_cb_t) (void *client, const void *data, uint64_t data2) |
Detailed Description
client
- INIT FINI AVAILABLE CANCEL WAIT UNAVAILABLE FILL SEND server
- stateless
constraints
- only 1 outgoing entrypoint request in progress;
- unlimited number of incoming entrypoints requests at the same time;
HA epoch module.
High-availability (HA) sub-system defines "an HA epoch" as a maximal interval in the system history through which no failures are agreed upon.
(Note that the word "epoch" has other meanings.)
When a new failure is detected or previous failure eliminated, the process of developing a consensus about the change in failure state is initiated within the HA sub-system. This process, if successful, culminates in transition to a new epoch.
An epoch is identified by "an epoch number", which is a 64-bit integer. A later epoch has greater number.
Motr operations that depend on failures are tagged by epoch numbers. Typically, rpc items, sent as part of an operation, carry as a field the number of the epoch in which the operation was initiated. If receiver receives a message from an epoch different from the epoch known to the receiver, it has to handle it specially. Possible options include:
- ignore the epoch number difference and process the operation as usual, - move the receiver to the item's epoch (this is only possible if the item's epoch is greater than the receiver epoch, because epoch numbers must increase monotonically), - drop the item on the floor, - send "wrong epoch" reply to the sender.
HA notifies the system about transition to the new epoch by broadcasting special item to all nodes. This item is always processed by moving its receivers to the item's epoch.
- TODO 2 cases TRANSIENT -> ONLINE: if m0d reconnected or it's restarted
- TODO can m0d receive TRANSIENT or FAILED about itself
- TODO race between FAILED about process and systemd restart
- TODO check types of process fid
State transition rules
I. Processes and Services
I.a Process and Service States
- There are 3 process/service states: FAILED, TRANSIENT and ONLINE.
- The only allowed state transitions for processes/services are FAILED <-> TRANSIENT <-> ONLINE, ONLINE -> FAILED.
- At the start every process/service is in FAILED state.
- When process/service starts it's moved to TRANSIENT state and then to ONLINE state.
- When there are signs that process/service is not ONLINE then it's moved to TRANSIENT state.
- When the decision is made that process/service is dead it's moved to FAILED state.
- When a process is permanently removed from the cluster it's going to FAILED state before it's removed from the configuration.
I.b Events
- Processes and services send event messages when they are starting and stopping.
- Before process/service is started it sends STARTING event.
- After process/service is started it sends STARTED event.
- Before process/service initiates stop sequence it sends STOPPING event.
- After process/service initiates stop sequence it sends STOPPED event.
- Events for the same process/service are always sent in the same order: STARTING -> STARTED -> STOPPING -> STOPPED.
I.c Correlation between events and states
- Before process/service is started it should be in FAILED state.
- If process/service dies it's moved to FAILED state.
- After <...> event is sent the process/service is moved to <...> state: STARTING - TRANSIENT STARTED - ONLINE STOPPING - TRANSIENT STOPPED - FAILED.
I.d Use cases
- Process/service start STARTING STARTED FAILED -------—> TRANSIENT -----—> ONLINE
- Process/service stop STOPPING STOPPED ONLINE ---------—> TRANSIENT -------—> FAILED
- Process/service crash the decision has been made that the process crashed ONLINE -------------------------—> FAILED
- Temporary process/service timeout decision that process decision that process may be dead is alive ONLINE --------------------—> TRANSIENT --------------------—> ONLINE
- Permanent process/servise timeout decision that process decision that process may be dead is dead ONLINE --------------------—> TRANSIENT --------------------—> FAILED
I.e Handling process/service state transitions in rpc
- If a process/service is ONLINE the connect timeout is M0_TIME_NEVER and the number of resends is unlimited.
- If a process/service is in TRANSIENT state the connect timeout and the number of resends are limited.
- If a process/service is in FAILED state then no attempt is made to communicate with the process/service and all existing rpc sessions/connections are dropped without timeout.
Reconnect protocol
- Legend
- C1 HA2 is started, HA1 starts (first start after HA2 had started):
- S1 HA1 sends entrypoint request with first_request flag set
- S2 HA2 receives the request
- S3 HA2 looks at the flag and makes new HA link
- S4 HA2 sends entrypoint reply
- S5 HA1 makes new link with the parameters from reply
- C2 HA1 and HA2 restart
- the same as C1
- C3 HA1 restarts, HA2 is alive
- the same as C1. Existing link is totally ignored in C1S3
- C4 HA2 restarts, HA1 is alive
- S1 HA1 considers HA2 dead
- S2 HA1 starts HA link reconnect
- S3 HA1 tries to send entrypoint request to HA2 in infinite loop
- S4 HA1 sends entrypoint request
- S5 HA2 receives entrypoint request
- S7 HA2 sees first_request flag is not set
- S8 HA2 makes HA link with parameters from request
- S9 HA2 sends entrypoint reply
- S10 HA1 ends HA link reconnect
- C5 HA1 is alive, HA2 is alive, HA2 considers HA1 dead due to transient network failure
- S1 C4S1, C4S2, C4S3
- S2 HA2 terminates the process with HA1
- S3 HA2 ensures that process is terminated
- S4 C3
Source structure
- ha/entrypoint_fops.h - entrypoint fops + req <-> req_fop, rep <-> rep_fop
- ha/entrypoint.h - entrypoint client & server (transport)
entrypoint request handling
- func Motr send entrypoint request
- cb HA accept entrypoint request
- func HA reply to the entrypoint request
- cb Motr receive entrypoint reply
m0_ha_link management
- func Motr connect to HA
- cb HA accept incoming connection
- func Motr disconnect from HA
- cb HA node disconnected
- func HA disconnect from Motr
- cb HA node is dead
m0_ha_msg handling
- func both send msg
- cb both recv msg
- func both msg delivered
- cb both msg is delivered
- cb HA undelivered msg
error handling
- cb both ENOMEM
- cb both connection failed
use cases
- normal loop
- Motr entrypoint request
- HA accept request, send reply
- HA reply to the request
- Motr receive entrypoint reply
- Motr connect to HA
- HA accept incoming connection
- main loop
- both send msg
- both recv msg
- both msg delivered
- Motr disconnect from HA
- HA node disconnected
- HA restart
- Motr entrypoint request, reply
- Motr connect to HA
- HA accept incoming connection
- < HA restarts >
- < Motr considers HA dead >
- Motr disconnect from HA
- goto normal loop (but the same incarnation in the entrypoint request)
- Motr restart
- Motr entrypoint request, reply
- Motr connect to HA
- HA accept incoming connection
- < Motr restarts >
- < HA considers Motr dead >
- HA send msg to local link that Motr is dead
- HA receive msg from local link that Motr is dead
- HA (cb) node is dead
- HA disconnect from Motr goto normal loop
- Design Highlights
- halon-interface-msg
- Message Handling
- Entrypoint Request ID
- Lifetime and Ownership
- halon-interface-spec
- State machines
- Threading and Concurrency Model
Design Highlights
- only one m0_halon_interface in a single process address space is supported at the moment;
- user of m0_halon_interface shouldn't care about rpc, reqh or other stuff that is not documented here. Threading constraints should be taken into account though.
Logical Specification
Message Handling
There are 2 kinds of messages: received and sent. Each message is received or sent in context of m0_ha_link.
When a message arrives the msg_received_cb() is executed. The user should call m0_halon_interface_delivered() for each received message. The call means that the message shouldn't be sent again if the current process restarts.
To send a message user calls m0_halon_interface_send(). For each message sent in this way either msg_is_delivered_cb() or msg_is_not_delivered_cb() is called. Exactly one of this functions is called exactly once for each message sent.
msg_is_delivered_cb() means that the message has been successfully delivered to the destination and it is not going to be resent if the destination restarts. msg_is_not_delivered_cb() is called if the message can't be delivered. It may be delivered already but there is no confirmation that it has been delivered.
Message Handling
Each message has a tag. The tag has uint64_t type and it's assigned internally when user tries to send a message (m0_halon_interface_send(), for example). Tag value is unique for all the messages sent or received over a single m0_ha_link. No other assumption about tag value should be used.
Tag is used for message identification when struct m0_ha_msg is not available.
Entrypoint Request ID
Each entrypoint request has an ID. The ID is m0_uint128 and it's assigned internally when a new entrypoint request is received.
Request ID is used to make a mapping between entrypoint request and m0_ha_link.
Lifetime and Ownership
- m0_halon_inteface shouldn't be used before m0_halon_interface_init() and shouldn't be used after m0_halon_interface_fini();
- m0_halon_interface_start()
- local_rpc_endpoint is not used after the function returns;
- callbacks can be executed at any point after the function is called but before m0_halon_interface_stop() returns;
- m0_halon_interface_entrypoint_reply()
- all parameters (except hi) can be freed by the caller after the function returns;
- can be called only after entrypoint_request_cb() is executed;
- should be called exactly once for each entrypoint request;
- m0_halon_interface_send()
- m0_ha_msg is not used after the function returns;
- entrypoint_request_cb()
- remote_rpc_endpoint can be finalised at any moment after the callback returns;
- msg_received_cb()
- msg is owned by the user only before m0_halon_interface_delivered() is called for the message;
- entrypoint request id
- is used by the user in m0_halon_interface_entrypoint_reply() after entrypoint_request_cb() is executed;
- is used by m0_halon_interface in either link_connected_cb() or link_reused_cb();
- is not used after m0_halon_interface_entrypoint_reply() is called and link_connected_cb() or link_reused_cb() executed;
- m0_ha_link
- m0_halon_interface controls m0_ha_link's lifetime;
- m0_ha_link doesn't exist
- before link_connected_cb() is called;
- after link_disconnected_cb() is finished;
- m0_halon_interface_send(), m0_halon_interface_delivered()
- can be used only after link_connected_cb() is executed for the link;
- can't be used after m0_halon_interface_disconnect() is called.
State machines
m0_halon_interface
* * UNINITIALISED * | ^ * init() | | fini() * v | * INITIALISED * | ^ * start() | | stop() * v | * WORKING * *
Entrypoint requrest/reply
* * UNINITIALISED * | * entrypoint_request_cb() | * v * REQUESTED * | * m0_halon_interface_entrypoint_reply() | * v * REPLIED * | * v--------------------v--------------------v * | | | * link_connected_cb() | link_reused_cb() | link_absent_cb() | * | | | * >--------------------v--------------------< * | * v * DONE * *
m0_ha_link
* * UNINITIALISED * ^ | * | | link_connected_cb() * link_disconnected_cb() | | * | | +---+ * | v v | * DISCONNECTED ACTIVE | link_reused_cb() * | | | | * | | +---+ * m0_halon_interface_disconnect() | | * | | link_is_disconnecting_cb() * | v * DISCONNECTING * *
m0_ha_msg send
* * UNINITIALISED * | * | m0_halon_interface_send() * v * SENDING * | | * msg_is_delivered_cb() | | msg_is_not_delivered_cb() * v v * DONE * *
m0_ha_msg recv
* * UNINITIALISED * | * | msg_received_cb() * v * HANDLING * | * | m0_halon_interface_delivered() * v * DONE * *
Threading and Concurrency Model
- thread which calls m0_halon_interface_init() is considered as main thread for m0 instance inside m0_halon_interface;
- m0_halon_interface_start(), m0_halon_interface_stop(), m0_halon_interface_fini() should be called from the exactly the same thread m0_halon_interface_init() is called (main thread);
- if m0_halon_interface is in WORKING state then Motr locality threads are created;
- each callback from m0_halon_interface_start() is executed in the locality thread. The callback function:
- can be called from any locality thread;
- shouldn't wait for network or disk I/O;
- shoudln't wait for another message to come or for a message to be delivered;
- can call m0_halon_interface_entrypoint_reply(), m0_halon_interface_send(), m0_halon_interface_delivered(), m0_halon_interface_disconnect().
- entrypoint_request_cb() can be called from any locality thread at any time regardless of other entrypoint_request_cb() executing;
- msg_received_cb()
- is called sequentially, one by one for the messages from the same link in the same order the sender has sent the messages;
- msg_is_delivered_cb(), msg_is_not_delivered_cb()
- for the same m0_ha_link are called sequentially, in the order m0_halon_interface_send() was called for the messages;
- msg_received_cb(), msg_is_delivered_cb(), msg_is_not_delivered_cb()
- may be called from different threads for the same m0_ha_link;
- if there are links L1 and L2, then callbacks for the messages from the links are not synchronised in any way;
- link_connected_cb(), link_reused_cb(), link_is_disconnecting_cb(), link_disconnected_cb()
- are called sequentially for the same link;
- may be called from different threads for the same link;
- m0_halon_interface_init(), m0_halon_interface_fini(), m0_halon_interface_start(), m0_halon_interface_stop() are blocking calls. After the function returns m0_halon_interface is already moved to the appropriate state;
m0_halon_interface_entrypoint_reply(), m0_halon_interface_send(), m0_halon_interface_delivered(), m0_halon_interface_disconnect() are non-blocking calls. They can be called from:
- main thread;
- locality thread;
- any callback.
send() >–\ /–> recv() -> delivered() >–> transport >–>
wait_delivery(tag) - wait until something is consumed on the other end wait_arrival() - wait until something arrives flush() - wait until all sent messages are consumed
use case: send() -> transport -> recv () -> delivered()
- HA link state machine (m0_ha_link::hln_sm)
* INIT --> FINI * v ^ * START -> STOP * v ^ * +--------------------< IDLE <----------------------------------------<+ * | VVVV>--------------------------------+ | * | |||+---------------------+ | | * | +----------+|+---------+ | | | * v v v v v v | * RECV DELIVERY RPC_FAILED LINK_FAILED LINK_REUSED DISCONNECTING | * v v v v v v ^ * >----------->----------->---------->------------>----------->---------+ * *
- Protocols ** Legend
- L1 - m0_ha_link #1
- L2 - m0_ha_link #2
- P1 - process with L1
- P2 - process with L2
- H1 - supervisor (TODO make better word) in P1, controls L1
- H2 - supervisor in P2, controls L2 ** Typical use case
- P1 is m0d/m0mkfs
- P2 is halond
- H1 and H2 are struct m0_ha ** Connect protocol
- H1 makes new request generation
- H1 sends L1 params request to H2. Request includes generation
- H2 receives the request
- H2 makes new request generation
- H2 makes params for L1 and L2
- makes connection id as concatenation of H1 request generation and H2 request generation
- sets L1 params id_connection
- sets L2 params id_connection to the same value
- makes L1 link id distinct from all other link ids made by P2 during it's lifetime
- makes L2 link id in the same way
- sets L1 params
- id_connection to connection id
- id_local to L1 link id
- id_remote to L2 link id
- XXX tag_even to true or false
- sets L2 params
- id_connection to connection id
- id_local to L2 link id
- id_remote to L1 link id
- XXX tag_even to !(L1 params tag_even)
- H2 calls init() for L2, then start() for L2 with L2 params
- H2 sends L1 params to H1 in params reply
- H1 receives L1 params
- H1 calls init() for L1, then start() for L1 with L1 params
- <now l1="" and="" l2="" can="" start="" m0_ha_msg="" transfer>=""> ** Reconnect protocol in case if L2 exists
- H1 makes new request generation
- H1 reconnec_begin() for L1, gets L1 params
- H1 sends L1 params and request generation to H2 using some transport (not L1 nor L2)
- H2 receives L1 params and request generation
- H2 looks for L2 by L1 params
- H2 successfully finds L2
- H2 reconnect_begin() for L2, gets L2 params
- H2 reconnect_end() for L2 with old L2 params
- H2 sends old L1 params to H1 using some transport (not L1 nor L2)
- H1 receives old L1 params
- H1 reconnect_end() for L1 with old L1 params
- <now l1="" and="" l2="" can="" resume="" m0_ha_msg="" transfer>=""> ** Reconnect protocol in case if L2 doesn't exist
- TODO
HA link queue maintains the queue of m0_ha_msg along with tags. The tags are "pointers" inside the tags range for the queue.
- Tags and queue relationship
* * first message in queue last message in queue * (next to be dequeued) (has been enqeued last) * v v * +-+-+-+ +-+-+-+-+-+ +-+-+-+-+ +-+-+-+ * | | | | ... | | | | | | ... | | | | | | | | | | tag value increase * +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-> * ^ ^ ^ ^ * | | | | * confirmed delivered next assign <-- tags * *
- API
- constructor, destructor, invariant:
- getters/setters for the entire set of tags:
- accessors for the tag values:
- m0_ha_lq_assign()
- m0_ha_lq_next()
- m0_ha_lq_delivered()
- m0_ha_lq_confirmed()
- query information
- m0_ha_lq_has_tag() - it can be a message in the queue with the given tag
- m0_ha_lq_msg() - returns message by tag
- m0_ha_lq_has_next() - there is a message to consume using m0_ha_lq_next()
- m0_ha_lq_is_delivered() - checks if the message with the tag is delivered
- modify the link queue
- m0_ha_lq_enqueue() - adds msg to the queue at the 'assign' position
- m0_ha_lq_next() - returns the message at 'next' position if 'next' != 'assign', advances 'next' if such message exists
- m0_ha_lq_try_unnext() - decreases 'next' if it's != 'delivered', returns if the decrease was successful
- m0_ha_lq_mark_delivered() - advances 'delivered'
- m0_ha_lq_dequeue() - removes a message at 'confirmed' position from the queue, advances 'confirmed', returns 'confirmed' value before the advancement
- Known issues
- there is no special handling for tag values overflow;
- memory allocation failure is not handled properly in m0_ha_lq_enqueue().
This structure is added to support basic queue operations and to support m0_ha_msg pre-allocation for OOM cases (when it's needed).
User is responsible for locking.
TODO static struct m0_sm_trans_descr ha_entrypoint_client_state_trans[] TODO transit to a failed state if rc != 0 in ha_entrypoint_client_replied() TODO handle errors TODO make magics for hes_req tlist TODO print the sm .dot representation to some file in UT for all SMs TODO fix memory leak in m0_ha_entrypoint_req2fop()
TODO handle memory allocation errors;
TODO remove m0_ha_outgoing_session() TODO handle memory allocation errors TODO handle all errors TODO add magics for ha_links TODO take hlcc_rpc_service_fid for incoming connections from HA TODO deal with locking in ha_link_incoming_find() TODO s/container_of/bob_of/g TODO deal with race: m0_ha_connect() with entrypoint client state TODO use ml_name everywhere in ha/ TODO enable process fid assert in m0_ha_process_failed() TODO check fid types
TODO log m0_halon_interface_entrypoint_reply() parameters without SIGSEGV TODO handle const/non-const m0_halon_interface_entrypoint_reply() parameters TODO fix 80 chars in line TODO replace m0_halon_interface_internal with m0_halon_interface TODO fix a race between m0_ha_flush() and m0_ha_disconnect() (rpc can send notification between these calls). TODO refactor common code in accessors TODO change M0_WARN to M0_INFO and make M0_INFO visible
TODO bob_of in ha_link_rpc_wait_cb TODO handle rpc failures in incoming fom (for reply) TODO use m0_module in m0_ha_link TODO reconsider localities for incoming/outgoing foms TODO handle rpc error in HA_LINK_OUTGOING_STATE_CONNECTING state TODO m0_ha_link_cb_disconnecting() and m0_ha_link_cb_reused() - copy-paste
- m0_ha_link outgoing fom state machine
* * INIT FINISH * v ^ * RPC_LINK_INIT RPC_LINK_FINI * v ^ * NOT_CONNECTED * v ^ * CONNECT DISCONNECTING * v ^ * INCOMING_REGISTER INCOMING_DEREGISTER * v ^ * v INCOMING_QUIESCE_WAIT * v ^ * v INCOMING_QUIESCE * v ^ * CONNECTING DISCONNECT * v ^ * IDLE <------+ * v | * SEND | * v | * WAIT_REPLY | * v | * WAIT_RELEASE >--+ * *
Macro Definition Documentation
◆ HACO_F
| #define HACO_F |
◆ HACO_P
| #define HACO_P | ( | _hc | ) |
◆ HLTAGS_F
| #define HLTAGS_F |
Value:
Definition at line 75 of file link_fops.h.
◆ HLTAGS_P
| #define HLTAGS_P | ( | _tags | ) |
Value:
(_tags)->hlt_confirmed, (_tags)->hlt_delivered, \
(_tags)->hlt_next, (_tags)->hlt_assign
Definition at line 77 of file link_fops.h.
◆ M0_TRACE_SUBSYSTEM [1/20]
◆ M0_TRACE_SUBSYSTEM [2/20]
◆ M0_TRACE_SUBSYSTEM [3/20]
◆ M0_TRACE_SUBSYSTEM [4/20]
◆ M0_TRACE_SUBSYSTEM [5/20]
◆ M0_TRACE_SUBSYSTEM [6/20]
◆ M0_TRACE_SUBSYSTEM [7/20]
◆ M0_TRACE_SUBSYSTEM [8/20]
| #define M0_TRACE_SUBSYSTEM M0_TRACE_SUBSYS_HA |
Definition at line 30 of file msg_queue.c.
◆ M0_TRACE_SUBSYSTEM [9/20]
| #define M0_TRACE_SUBSYSTEM M0_TRACE_SUBSYS_UT |
Definition at line 30 of file entrypoint.c.
◆ M0_TRACE_SUBSYSTEM [10/20]
◆ M0_TRACE_SUBSYSTEM [11/20]
| #define M0_TRACE_SUBSYSTEM M0_TRACE_SUBSYS_HA |
Definition at line 30 of file link_fops.c.
◆ M0_TRACE_SUBSYSTEM [12/20]
◆ M0_TRACE_SUBSYSTEM [13/20]
| #define M0_TRACE_SUBSYSTEM M0_TRACE_SUBSYS_UT |
Definition at line 30 of file msg_queue.c.
◆ M0_TRACE_SUBSYSTEM [14/20]
| #define M0_TRACE_SUBSYSTEM M0_TRACE_SUBSYS_HA |
Definition at line 30 of file link_service.c.
◆ M0_TRACE_SUBSYSTEM [15/20]
◆ M0_TRACE_SUBSYSTEM [16/20]
| #define M0_TRACE_SUBSYSTEM M0_TRACE_SUBSYS_HA |
Definition at line 32 of file entrypoint_fops.c.
◆ M0_TRACE_SUBSYSTEM [17/20]
| #define M0_TRACE_SUBSYSTEM M0_TRACE_SUBSYS_HA |
Definition at line 37 of file entrypoint.c.
◆ M0_TRACE_SUBSYSTEM [18/20]
| #define M0_TRACE_SUBSYSTEM M0_TRACE_SUBSYS_HA |
Definition at line 38 of file interface.c.
◆ M0_TRACE_SUBSYSTEM [19/20]
◆ M0_TRACE_SUBSYSTEM [20/20]
Typedef Documentation
◆ m0_ha_client_cb_t
Enumeration Type Documentation
◆ anonymous enum
| anonymous enum |
| Enumerator | |
|---|---|
| ECL_TIMEOUT | |
| ECL_MAX_RPCS_IN_FLIGHT | |
Definition at line 67 of file entrypoint.c.
◆ anonymous enum
| anonymous enum |
| Enumerator | |
|---|---|
| HEC_FOM_INIT | |
| HEC_FOM_FINI | |
Definition at line 398 of file entrypoint.c.
◆ anonymous enum
| anonymous enum |
◆ anonymous enum
| anonymous enum |
| Enumerator | |
|---|---|
| HALON_INTERFACE_EP_BUF | |
| HALON_INTERFACE_NVEC_SIZE_MAX | |
Definition at line 80 of file interface.c.
◆ anonymous enum
| anonymous enum |
◆ anonymous enum
◆ anonymous enum
| anonymous enum |
◆ anonymous enum
| anonymous enum |
| Enumerator | |
|---|---|
| HA_UT_ENTRYPOINT_USECASE_CONFD_NR | |
Definition at line 44 of file entrypoint.c.
◆ anonymous enum
◆ anonymous enum
| anonymous enum |
◆ anonymous enum
| anonymous enum |
◆ anonymous enum
| anonymous enum |
| Enumerator | |
|---|---|
| HA_UT_MSG_QUEUE_NR | |
Definition at line 40 of file msg_queue.c.
◆ ha_link_ctx_type
| enum ha_link_ctx_type |
◆ ha_link_outgoing_fom_state
◆ ha_link_send_type
| enum ha_link_send_type |
◆ m0_ha_entrypoint_client_state
Definition at line 86 of file entrypoint.h.
◆ m0_ha_entrypoint_control
Command passed to the entrypoint consumer side to control entrypoint request flow. Producer side may request consumer to keep querying entrypoint, or stop querying and force process to quit.
| Enumerator | |
|---|---|
| M0_HA_ENTRYPOINT_CONSUME | Entrypoint is good to be consumed |
| M0_HA_ENTRYPOINT_QUIT | Remote consumer requested to quit |
| M0_HA_ENTRYPOINT_QUERY | Remote consumer must query again |
Definition at line 56 of file entrypoint_fops.h.
◆ m0_ha_entrypoint_server_fom_state
| Enumerator | |
|---|---|
| M0_HES_INIT | |
| M0_HES_FINI | |
| M0_HES_REPLY_WAIT | |
Definition at line 62 of file entrypoint.h.
◆ m0_ha_epoch_outcome
| enum m0_ha_epoch_outcome |
Possible return values of m0_ha_epoch_monitor::hem_{past,future}().
◆ m0_ha_level
| enum m0_ha_level |
◆ m0_ha_link_state
| enum m0_ha_link_state |
◆ m0_ha_mod_level
| enum m0_ha_mod_level |
◆ m0_ha_msg_qitem_delivery_state
| Enumerator | |
|---|---|
| M0_HA_MSG_QITEM_NOT_DELIVERED | |
| M0_HA_MSG_QITEM_DELIVERED | |
Definition at line 43 of file msg_queue.h.
◆ m0_ha_msg_type
| enum m0_ha_msg_type |
◆ m0_halon_interface_level
Definition at line 144 of file interface.c.
◆ m0_halon_interface_state
| Enumerator | |
|---|---|
| M0_HALON_INTERFACE_STATE_UNINITIALISED | |
| M0_HALON_INTERFACE_STATE_INITIALISED | |
| M0_HALON_INTERFACE_STATE_WORKING | |
| M0_HALON_INTERFACE_STATE_FINALISED | |
Definition at line 164 of file interface.c.
Function Documentation
◆ default_mon_future()
|
static |
◆ ha_client_release()
|
static |
- Todo:
- : Is it possible to move {m0}_ha_client_* functions to ha/note.[ch] files? Seems that functionality is related to HA notifications.
ha_client::hc_ref release callback
Definition at line 182 of file epoch.c.
Here is the call graph for this function:
Here is the caller graph for this function:
◆ ha_entrypoint_client_fom_fini()
|
static |
◆ ha_entrypoint_client_fom_locality()
|
static |
Definition at line 690 of file entrypoint.c.
◆ ha_entrypoint_client_fom_tick()
|
static |
◆ ha_entrypoint_client_fop_release()
|
static |
Definition at line 501 of file entrypoint.c.
Here is the call graph for this function:
Here is the caller graph for this function:
◆ ha_entrypoint_client_replied()
|
static |
◆ ha_entrypoint_client_rlink_cb()
|
static |
Definition at line 422 of file entrypoint.c.
Here is the call graph for this function:
Here is the caller graph for this function:
◆ ha_entrypoint_client_start_check()
|
static |
Definition at line 738 of file entrypoint.c.
Here is the call graph for this function:
Here is the caller graph for this function:
◆ ha_entrypoint_client_stop_check()
|
static |
Definition at line 754 of file entrypoint.c.
Here is the call graph for this function:
Here is the caller graph for this function:
◆ ha_entrypoint_fom_create()
◆ ha_entrypoint_fom_fini()
|
static |
◆ ha_entrypoint_get_fom_tick()
|
static |
◆ ha_entrypoint_home_locality()
|
static |
Definition at line 856 of file entrypoint.c.
◆ ha_entrypoint_server_deregister()
|
static |
Definition at line 294 of file entrypoint.c.
Here is the call graph for this function:
Here is the caller graph for this function:
◆ ha_entrypoint_server_find()
|
static |
Definition at line 264 of file entrypoint.c.
Here is the call graph for this function:
Here is the caller graph for this function:
◆ ha_entrypoint_server_register()
|
static |
Definition at line 280 of file entrypoint.c.
Here is the call graph for this function:
Here is the caller graph for this function:
◆ ha_entrypoint_service_allocate()
|
static |
◆ ha_entrypoint_service_container()
|
static |
◆ ha_entrypoint_service_fini()
|
static |
◆ ha_entrypoint_service_fop_accept()
|
static |
◆ ha_entrypoint_service_init()
|
static |
Definition at line 79 of file entrypoint.c.
Here is the call graph for this function:
Here is the caller graph for this function:
◆ ha_entrypoint_service_start()
|
static |
◆ ha_entrypoint_service_stop()
|
static |
◆ ha_entrypoint_state_cb()
|
static |
◆ ha_generation_next()
|
static |
◆ ha_global_lock()
|
inlinestatic |
◆ ha_global_unlock()
|
inlinestatic |
◆ ha_level_enter()
|
static |
◆ ha_level_leave()
|
static |
◆ ha_link_backoff_check()
|
static |
◆ ha_link_cb_disconnecting_reused()
|
static |
◆ ha_link_conn_cfg_copy()
|
static |
◆ ha_link_conn_cfg_free()
|
static |
◆ ha_link_conn_cfg_make()
|
static |
◆ ha_link_ctx_fini()
|
static |
◆ ha_link_ctx_init()
|
static |
◆ ha_link_event_cb()
|
static |
◆ ha_link_handle()
|
static |
◆ ha_link_id_next()
|
static |
◆ ha_link_incoming_create()
|
static |
◆ ha_link_incoming_find()
|
static |
◆ ha_link_incoming_fom_container()
|
static |
◆ ha_link_incoming_fom_create()
◆ ha_link_incoming_fom_fini()
|
static |
◆ ha_link_incoming_fom_locality()
|
static |
◆ ha_link_incoming_fom_tick()
|
static |
◆ ha_link_msg_received()
|
static |
◆ ha_link_msg_recv_or_delivery_broadcast()
|
static |
◆ ha_link_outgoing_fom_create()
◆ ha_link_outgoing_fom_fini()
|
static |
◆ ha_link_outgoing_fom_locality()
|
static |
◆ ha_link_outgoing_fom_tick()
|
static |
◆ ha_link_outgoing_fom_wakeup()
|
static |
◆ ha_link_outgoing_fom_wakeup_ast()
|
static |
◆ ha_link_outgoing_fop_release()
|
static |
◆ ha_link_outgoing_fop_replied()
|
static |
◆ ha_link_outgoing_fop_send()
|
static |
◆ ha_link_outgoing_item_replied()
|
static |
◆ ha_link_outgoing_item_sent()
|
static |
◆ ha_link_outgoing_reconnect_timeout()
|
static |
◆ ha_link_q_in_confirm_all()
|
static |
◆ ha_link_quiesce_wait_cb()
|
static |
◆ ha_link_rpc_wait_cb()
|
static |
◆ ha_link_service_allocate()
|
static |
◆ ha_link_service_container()
|
static |
◆ ha_link_service_find()
|
static |
Definition at line 124 of file link_service.c.
Here is the call graph for this function:
Here is the caller graph for this function:
◆ ha_link_service_fini()
|
static |
◆ ha_link_service_fop_accept()
|
static |
◆ ha_link_service_get()
|
static |
Definition at line 143 of file link_service.c.
Here is the call graph for this function:
Here is the caller graph for this function:
◆ ha_link_service_init()
|
static |
Definition at line 79 of file link_service.c.
Here is the call graph for this function:
Here is the caller graph for this function:
◆ ha_link_service_start()
|
static |
◆ ha_link_service_stop()
|
static |
◆ ha_link_stop_cb()
|
static |
◆ ha_link_tags_apply()
|
static |
◆ ha_link_tags_in_out()
|
static |
◆ ha_link_tags_update()
|
static |
◆ ha_link_wait()
|
static |
◆ ha_link_wait_arrival_check()
|
static |
◆ ha_link_wait_confirmation_check()
|
static |
◆ ha_link_wait_delivery_check()
|
static |
◆ ha_lq_tags_invariant()
|
static |
◆ ha_mod_level_enter()
|
static |
◆ ha_mod_level_leave()
|
static |
◆ ha_request_received_cb()
|
static |
◆ ha_ut_entrypoint_client_cb()
|
static |
Definition at line 235 of file entrypoint.c.
Here is the call graph for this function:
Here is the caller graph for this function:
◆ ha_ut_entrypoint_client_start()
|
static |
Definition at line 173 of file entrypoint.c.
Here is the call graph for this function:
Here is the caller graph for this function:
◆ ha_ut_entrypoint_client_stop()
|
static |
Definition at line 192 of file entrypoint.c.
Here is the call graph for this function:
Here is the caller graph for this function:
◆ ha_ut_entrypoint_reply_check()
|
static |
Definition at line 128 of file entrypoint.c.
Here is the call graph for this function:
Here is the caller graph for this function:
◆ ha_ut_entrypoint_reply_fini()
|
static |
Definition at line 116 of file entrypoint.c.
Here is the call graph for this function:
Here is the caller graph for this function:
◆ ha_ut_entrypoint_reply_init()
|
static |
Definition at line 90 of file entrypoint.c.
Here is the call graph for this function:
Here is the caller graph for this function:
◆ ha_ut_entrypoint_request_arrived()
|
static |
Definition at line 62 of file entrypoint.c.
Here is the call graph for this function:
Here is the caller graph for this function:
◆ ha_ut_entrypoint_server_start()
|
static |
Definition at line 147 of file entrypoint.c.
Here is the call graph for this function:
Here is the caller graph for this function:
◆ ha_ut_entrypoint_server_stop()
|
static |
Definition at line 165 of file entrypoint.c.
Here is the call graph for this function:
Here is the caller graph for this function:
◆ ha_ut_ha2usecase_ctx()
|
static |
◆ ha_ut_ha_wait_available()
|
static |
◆ ha_ut_link_cfg_create()
|
static |
◆ ha_ut_link_conn_cfg_create()
|
static |
◆ ha_ut_link_conn_cfg_free()
|
static |
◆ ha_ut_link_fini()
|
static |
◆ ha_ut_link_init()
|
static |
◆ ha_ut_link_msg_transfer()
|
static |
◆ ha_ut_link_mt_thread()
|
static |
◆ ha_ut_link_set_some_msg()
|
static |
◆ ha_ut_links_fini()
|
static |
◆ ha_ut_links_init()
|
static |
◆ ha_ut_usecase_entrypoint_replied()
|
static |
◆ ha_ut_usecase_entrypoint_request()
|
static |
◆ ha_ut_usecase_link_check()
|
static |
◆ ha_ut_usecase_link_connected()
|
static |
◆ ha_ut_usecase_link_disconnected()
|
static |
◆ ha_ut_usecase_link_is_disconnecting()
|
static |
◆ ha_ut_usecase_link_reused()
|
static |
◆ ha_ut_usecase_msg_is_delivered()
|
static |
◆ ha_ut_usecase_msg_is_not_delivered()
|
static |
◆ ha_ut_usecase_msg_received()
|
static |
◆ halon_interface_entrypoint_replied_cb()
|
static |
◆ halon_interface_entrypoint_request_cb()
|
static |
◆ halon_interface_ha2hii()
|
static |
Definition at line 245 of file interface.c.
Here is the call graph for this function:
Here is the caller graph for this function:
◆ halon_interface_is_compatible()
|
static |
Definition at line 201 of file interface.c.
Here is the call graph for this function:
Here is the caller graph for this function:
◆ halon_interface_is_working()
|
static |
Definition at line 1177 of file interface.c.
Here is the call graph for this function:
Here is the caller graph for this function:
◆ halon_interface_level_enter()
|
static |
◆ halon_interface_level_leave()
|
static |
◆ halon_interface_link_absent_cb()
|
static |
◆ halon_interface_link_connected_cb()
|
static |
◆ halon_interface_link_disconnected_cb()
|
static |
◆ halon_interface_link_is_disconnecting_cb()
|
static |
◆ halon_interface_link_reused_cb()
|
static |
◆ halon_interface_msg_is_delivered_cb()
|
static |
◆ halon_interface_msg_is_not_delivered_cb()
|
static |
◆ halon_interface_msg_received_cb()
|
static |
◆ halon_interface_parse_debug_options()
|
static |
Definition at line 229 of file interface.c.
Here is the call graph for this function:
Here is the caller graph for this function:
◆ halon_interface_process_event()
|
static |
Definition at line 646 of file interface.c.
Here is the call graph for this function:
Here is the caller graph for this function:
◆ halon_interface_process_failure_check()
|
static |
Definition at line 256 of file interface.c.
Here is the call graph for this function:
Here is the caller graph for this function:
◆ halon_interface_service_event()
|
static |
Definition at line 656 of file interface.c.
Here is the call graph for this function:
Here is the caller graph for this function:
◆ M0_BASSERT()
| M0_BASSERT | ( | ARRAY_SIZE(ha_link_sm_states) | = =M0_HA_LINK_STATE_NR | ) |
◆ M0_BOB_DEFINE() [1/2]
| M0_BOB_DEFINE | ( | static | inline, |
| & | ha_link_service_bob_type, | ||
| ha_link_service | |||
| ) |
◆ M0_BOB_DEFINE() [2/2]
| M0_BOB_DEFINE | ( | static | , |
| & | halon_interface_bob_type, | ||
| m0_halon_interface_internal | |||
| ) |
◆ m0_ha_client_add()
| M0_INTERNAL int m0_ha_client_add | ( | struct m0_confc * | confc | ) |
Adds new HA client record to HA global context, or increments client's reference counter in case client record already exists.
With this registration the client side is allowed to provide any arbitrary confc instance having cache filled with the conf objects which HA state changes the client side wants to be notified of.
In its turn, HA is to apply recieved HA notifications to every registered confc instance. (see m0_ha_state_accept() implementation)
- Precondition
- confc->cc_cache.ca_lock != NULL
- Note
- Any client is allowed to register any confc instance that suits client's needs in HA subscriptions, taking no care about the instance origins, i.e. no matter if the instance were already registered previously by some other client or not.
Definition at line 191 of file epoch.c.
Here is the call graph for this function:
Here is the caller graph for this function:
◆ m0_ha_client_del()
| M0_INTERNAL int m0_ha_client_del | ( | struct m0_confc * | confc | ) |
◆ m0_ha_clients_iterate()
| M0_INTERNAL void m0_ha_clients_iterate | ( | m0_ha_client_cb_t | iter, |
| const void * | data, | ||
| uint64_t | data2 | ||
| ) |
Global HA client list iteration. Calling back occurs on per-client context basis. Caller provides callback along with data the caller side is to process. Data is to remain non-modified during iteration.
- Note
- Global HA context mutex is expected to be locked in the course of client list iteration.
Definition at line 251 of file epoch.c.
Here is the call graph for this function:
Here is the caller graph for this function:
◆ m0_ha_connect()
| M0_INTERNAL struct m0_ha_link * m0_ha_connect | ( | struct m0_ha * | ha | ) |
◆ m0_ha_cookie_fini()
| M0_INTERNAL void m0_ha_cookie_fini | ( | struct m0_ha_cookie * | hc | ) |
◆ m0_ha_cookie_from_xc()
| M0_INTERNAL void m0_ha_cookie_from_xc | ( | struct m0_ha_cookie * | hc, |
| const struct m0_ha_cookie_xc * | hc_xc | ||
| ) |
◆ m0_ha_cookie_init()
| M0_INTERNAL void m0_ha_cookie_init | ( | struct m0_ha_cookie * | hc | ) |
◆ m0_ha_cookie_is_eq()
| M0_INTERNAL bool m0_ha_cookie_is_eq | ( | const struct m0_ha_cookie * | a, |
| const struct m0_ha_cookie * | b | ||
| ) |
◆ m0_ha_cookie_record()
| M0_INTERNAL void m0_ha_cookie_record | ( | struct m0_ha_cookie * | hc | ) |
◆ m0_ha_cookie_to_xc()
| M0_INTERNAL void m0_ha_cookie_to_xc | ( | const struct m0_ha_cookie * | hc, |
| struct m0_ha_cookie_xc * | hc_xc | ||
| ) |
◆ m0_ha_delivered()
| M0_INTERNAL void m0_ha_delivered | ( | struct m0_ha * | ha, |
| struct m0_ha_link * | hl, | ||
| struct m0_ha_msg * | msg | ||
| ) |
◆ m0_ha_disconnect()
| M0_INTERNAL void m0_ha_disconnect | ( | struct m0_ha * | ha | ) |
◆ m0_ha_disconnect_incoming()
| M0_INTERNAL void m0_ha_disconnect_incoming | ( | struct m0_ha * | ha, |
| struct m0_ha_link * | hl | ||
| ) |
◆ m0_ha_domain_fini()
| M0_INTERNAL void m0_ha_domain_fini | ( | struct m0_ha_domain * | dom | ) |
◆ m0_ha_domain_get_read()
| M0_INTERNAL uint64_t m0_ha_domain_get_read | ( | struct m0_ha_domain * | dom | ) |
Acquires read lock on the domain and returns known epoch.
The known epoch cannot be changed until the lock is released by calling m0_ha_domain_put_read().
Definition at line 119 of file epoch.c.
Here is the call graph for this function:
◆ m0_ha_domain_get_write()
| M0_INTERNAL uint64_t m0_ha_domain_get_write | ( | struct m0_ha_domain * | dom | ) |
Acquires the write lock and returns the known epoch.
The known epoch can be neither modified nor queried until the lock is released by m0_ha_domain_put_write().
Definition at line 130 of file epoch.c.
Here is the call graph for this function:
Here is the caller graph for this function:
◆ m0_ha_domain_init()
| M0_INTERNAL void m0_ha_domain_init | ( | struct m0_ha_domain * | dom, |
| uint64_t | epoch | ||
| ) |
◆ m0_ha_domain_monitor_add()
| M0_INTERNAL void m0_ha_domain_monitor_add | ( | struct m0_ha_domain * | dom, |
| struct m0_ha_epoch_monitor * | mon | ||
| ) |
◆ m0_ha_domain_monitor_del()
| M0_INTERNAL void m0_ha_domain_monitor_del | ( | struct m0_ha_domain * | dom, |
| struct m0_ha_epoch_monitor * | mon | ||
| ) |
◆ m0_ha_domain_put_read()
| M0_INTERNAL void m0_ha_domain_put_read | ( | struct m0_ha_domain * | dom | ) |
Releases the lock acquired by m0_ha_domain_get_read().
Definition at line 125 of file epoch.c.
Here is the call graph for this function:
◆ m0_ha_domain_put_write()
| M0_INTERNAL void m0_ha_domain_put_write | ( | struct m0_ha_domain * | dom, |
| uint64_t | epoch | ||
| ) |
Releases the lock acquired by m0_ha_domain_get_write() and sets the new known epoch.
HA sub-system uses this function to move to the next epoch.
Message receivers use this function to handle M0_HEO_OBEY return from m0_ha_epoch_monitor::hem_future() method.
- Precondition
- epoch >= dom->hdo_epoch
Definition at line 136 of file epoch.c.
Here is the call graph for this function:
Here is the caller graph for this function:
◆ m0_ha_entrypoint_client_chan()
| M0_INTERNAL struct m0_chan * m0_ha_entrypoint_client_chan | ( | struct m0_ha_entrypoint_client * | ecl | ) |
◆ m0_ha_entrypoint_client_fini()
| M0_INTERNAL void m0_ha_entrypoint_client_fini | ( | struct m0_ha_entrypoint_client * | ecl | ) |
Definition at line 464 of file entrypoint.c.
Here is the call graph for this function:
Here is the caller graph for this function:
◆ m0_ha_entrypoint_client_init()
| M0_INTERNAL int m0_ha_entrypoint_client_init | ( | struct m0_ha_entrypoint_client * | ecl, |
| const char * | ep, | ||
| struct m0_ha_entrypoint_client_cfg * | ecl_cfg | ||
| ) |
Definition at line 434 of file entrypoint.c.
Here is the call graph for this function:
Here is the caller graph for this function:
◆ m0_ha_entrypoint_client_request()
| M0_INTERNAL void m0_ha_entrypoint_client_request | ( | struct m0_ha_entrypoint_client * | ecl | ) |
Definition at line 708 of file entrypoint.c.
Here is the call graph for this function:
Here is the caller graph for this function:
◆ m0_ha_entrypoint_client_start()
| M0_INTERNAL void m0_ha_entrypoint_client_start | ( | struct m0_ha_entrypoint_client * | ecl | ) |
Definition at line 727 of file entrypoint.c.
Here is the call graph for this function:
Here is the caller graph for this function:
◆ m0_ha_entrypoint_client_start_sync()
| M0_INTERNAL void m0_ha_entrypoint_client_start_sync | ( | struct m0_ha_entrypoint_client * | ecl | ) |
Definition at line 772 of file entrypoint.c.
Here is the call graph for this function:
Here is the caller graph for this function:
◆ m0_ha_entrypoint_client_state_get()
| M0_INTERNAL enum m0_ha_entrypoint_client_state m0_ha_entrypoint_client_state_get | ( | struct m0_ha_entrypoint_client * | ecl | ) |
- Precondition
- m0_sm_group_is_locked(&ecl->ecl_sm_group)
- Note
- Use m0_sm_state_name() to convert m0_ha_entrypoint_client_state to string. state = m0_ha_entrypoint_client_state_get(ecl);
Definition at line 829 of file entrypoint.c.
Here is the call graph for this function:
Here is the caller graph for this function:
◆ m0_ha_entrypoint_client_stop()
| M0_INTERNAL void m0_ha_entrypoint_client_stop | ( | struct m0_ha_entrypoint_client * | ecl | ) |
Definition at line 785 of file entrypoint.c.
Here is the call graph for this function:
Here is the caller graph for this function:
◆ m0_ha_entrypoint_fop2rep()
| M0_INTERNAL int m0_ha_entrypoint_fop2rep | ( | const struct m0_ha_entrypoint_rep_fop * | rep_fop, |
| struct m0_ha_entrypoint_rep * | rep | ||
| ) |
Definition at line 123 of file entrypoint_fops.c.
Here is the call graph for this function:
Here is the caller graph for this function:
◆ m0_ha_entrypoint_fop2req()
| M0_INTERNAL int m0_ha_entrypoint_fop2req | ( | const struct m0_ha_entrypoint_req_fop * | req_fop, |
| const char * | rpc_endpoint, | ||
| struct m0_ha_entrypoint_req * | req | ||
| ) |
Definition at line 96 of file entrypoint_fops.c.
Here is the call graph for this function:
Here is the caller graph for this function:
◆ m0_ha_entrypoint_fops_fini()
| M0_INTERNAL void m0_ha_entrypoint_fops_fini | ( | void | ) |
Definition at line 68 of file entrypoint_fops.c.
Here is the call graph for this function:
Here is the caller graph for this function:
◆ m0_ha_entrypoint_fops_init()
| M0_INTERNAL void m0_ha_entrypoint_fops_init | ( | void | ) |
◆ m0_ha_entrypoint_mod_fini()
| M0_INTERNAL void m0_ha_entrypoint_mod_fini | ( | void | ) |
Definition at line 850 of file entrypoint.c.
Here is the call graph for this function:
Here is the caller graph for this function:
◆ m0_ha_entrypoint_mod_init()
| M0_INTERNAL int m0_ha_entrypoint_mod_init | ( | void | ) |
Definition at line 835 of file entrypoint.c.
Here is the call graph for this function:
Here is the caller graph for this function:
◆ m0_ha_entrypoint_rep2fop()
| M0_INTERNAL int m0_ha_entrypoint_rep2fop | ( | const struct m0_ha_entrypoint_rep * | rep, |
| struct m0_ha_entrypoint_rep_fop * | rep_fop | ||
| ) |
Definition at line 160 of file entrypoint_fops.c.
Here is the call graph for this function:
Here is the caller graph for this function:
◆ m0_ha_entrypoint_rep_copy()
| M0_INTERNAL int m0_ha_entrypoint_rep_copy | ( | struct m0_ha_entrypoint_rep * | to, |
| struct m0_ha_entrypoint_rep * | from | ||
| ) |
Definition at line 219 of file entrypoint_fops.c.
Here is the call graph for this function:
Here is the caller graph for this function:
◆ m0_ha_entrypoint_rep_free()
| M0_INTERNAL void m0_ha_entrypoint_rep_free | ( | struct m0_ha_entrypoint_rep * | rep | ) |
Definition at line 205 of file entrypoint_fops.c.
Here is the call graph for this function:
Here is the caller graph for this function:
◆ m0_ha_entrypoint_reply()
| M0_INTERNAL void m0_ha_entrypoint_reply | ( | struct m0_ha * | ha, |
| const struct m0_uint128 * | req_id, | ||
| const struct m0_ha_entrypoint_rep * | rep, | ||
| struct m0_ha_link ** | hl_ptr | ||
| ) |
◆ m0_ha_entrypoint_req2fop()
| M0_INTERNAL int m0_ha_entrypoint_req2fop | ( | const struct m0_ha_entrypoint_req * | req, |
| struct m0_ha_entrypoint_req_fop * | req_fop | ||
| ) |
Definition at line 75 of file entrypoint_fops.c.
Here is the call graph for this function:
Here is the caller graph for this function:
◆ m0_ha_entrypoint_req_free()
| M0_INTERNAL void m0_ha_entrypoint_req_free | ( | struct m0_ha_entrypoint_req * | req | ) |
Definition at line 212 of file entrypoint_fops.c.
Here is the call graph for this function:
Here is the caller graph for this function:
◆ m0_ha_entrypoint_server_fini()
| M0_INTERNAL void m0_ha_entrypoint_server_fini | ( | struct m0_ha_entrypoint_server * | hes | ) |
Definition at line 234 of file entrypoint.c.
Here is the call graph for this function:
Here is the caller graph for this function:
◆ m0_ha_entrypoint_server_init()
| M0_INTERNAL int m0_ha_entrypoint_server_init | ( | struct m0_ha_entrypoint_server * | hes, |
| struct m0_ha_entrypoint_server_cfg * | hes_cfg | ||
| ) |
Definition at line 220 of file entrypoint.c.
Here is the call graph for this function:
Here is the caller graph for this function:
◆ m0_ha_entrypoint_server_reply()
| M0_INTERNAL void m0_ha_entrypoint_server_reply | ( | struct m0_ha_entrypoint_server * | hes, |
| const struct m0_uint128 * | req_id, | ||
| const struct m0_ha_entrypoint_rep * | rep | ||
| ) |
Definition at line 306 of file entrypoint.c.
Here is the call graph for this function:
Here is the caller graph for this function:
◆ m0_ha_entrypoint_server_request_find()
| M0_INTERNAL const struct m0_ha_entrypoint_req * m0_ha_entrypoint_server_request_find | ( | struct m0_ha_entrypoint_server * | hes, |
| const struct m0_uint128 * | req_id | ||
| ) |
Definition at line 322 of file entrypoint.c.
Here is the call graph for this function:
Here is the caller graph for this function:
◆ m0_ha_entrypoint_server_start()
| M0_INTERNAL void m0_ha_entrypoint_server_start | ( | struct m0_ha_entrypoint_server * | hes | ) |
Definition at line 241 of file entrypoint.c.
Here is the call graph for this function:
Here is the caller graph for this function:
◆ m0_ha_entrypoint_server_stop()
| M0_INTERNAL void m0_ha_entrypoint_server_stop | ( | struct m0_ha_entrypoint_server * | hes | ) |
Definition at line 258 of file entrypoint.c.
Here is the call graph for this function:
Here is the caller graph for this function:
◆ m0_ha_entrypoint_service_fini()
| M0_INTERNAL void m0_ha_entrypoint_service_fini | ( | struct m0_reqh_service * | he_service | ) |
Definition at line 207 of file entrypoint.c.
Here is the call graph for this function:
Here is the caller graph for this function:
◆ m0_ha_entrypoint_service_init()
| M0_INTERNAL int m0_ha_entrypoint_service_init | ( | struct m0_reqh_service ** | service, |
| struct m0_reqh * | reqh | ||
| ) |
Definition at line 197 of file entrypoint.c.
Here is the call graph for this function:
Here is the caller graph for this function:
◆ m0_ha_epoch_check()
| M0_INTERNAL int m0_ha_epoch_check | ( | const struct m0_rpc_item * | item | ) |
◆ m0_ha_fini()
| M0_INTERNAL void m0_ha_fini | ( | struct m0_ha * | ha | ) |
◆ m0_ha_flush()
| M0_INTERNAL void m0_ha_flush | ( | struct m0_ha * | ha, |
| struct m0_ha_link * | hl | ||
| ) |
◆ m0_ha_global_fini()
| M0_INTERNAL void m0_ha_global_fini | ( | void | ) |
◆ m0_ha_global_init()
| M0_INTERNAL int m0_ha_global_init | ( | void | ) |
◆ m0_ha_init()
◆ m0_ha_link_cb_disconnecting()
| M0_INTERNAL void m0_ha_link_cb_disconnecting | ( | struct m0_ha_link * | hl | ) |
◆ m0_ha_link_cb_reused()
| M0_INTERNAL void m0_ha_link_cb_reused | ( | struct m0_ha_link * | hl | ) |
◆ m0_ha_link_chan()
| M0_INTERNAL struct m0_chan * m0_ha_link_chan | ( | struct m0_ha_link * | hl | ) |
◆ m0_ha_link_delivered()
| M0_INTERNAL void m0_ha_link_delivered | ( | struct m0_ha_link * | hl, |
| struct m0_ha_msg * | msg | ||
| ) |
◆ m0_ha_link_delivered_consume()
| M0_INTERNAL uint64_t m0_ha_link_delivered_consume | ( | struct m0_ha_link * | hl | ) |
◆ m0_ha_link_fini()
| M0_INTERNAL void m0_ha_link_fini | ( | struct m0_ha_link * | hl | ) |
◆ m0_ha_link_flush()
| M0_INTERNAL void m0_ha_link_flush | ( | struct m0_ha_link * | hl | ) |
◆ m0_ha_link_fops_fini()
| M0_INTERNAL void m0_ha_link_fops_fini | ( | void | ) |
Definition at line 98 of file link_fops.c.
Here is the call graph for this function:
Here is the caller graph for this function:
◆ m0_ha_link_fops_init()
| M0_INTERNAL int m0_ha_link_fops_init | ( | void | ) |
◆ m0_ha_link_init()
| M0_INTERNAL int m0_ha_link_init | ( | struct m0_ha_link * | hl, |
| struct m0_ha_link_cfg * | hl_cfg | ||
| ) |
◆ m0_ha_link_mod_fini()
| M0_INTERNAL void m0_ha_link_mod_fini | ( | void | ) |
◆ m0_ha_link_mod_init()
| M0_INTERNAL int m0_ha_link_mod_init | ( | void | ) |
◆ m0_ha_link_msg_is_delivered()
| M0_INTERNAL bool m0_ha_link_msg_is_delivered | ( | struct m0_ha_link * | hl, |
| uint64_t | tag | ||
| ) |
◆ m0_ha_link_not_delivered_consume()
| M0_INTERNAL uint64_t m0_ha_link_not_delivered_consume | ( | struct m0_ha_link * | hl | ) |
◆ m0_ha_link_params_invert()
| M0_INTERNAL void m0_ha_link_params_invert | ( | struct m0_ha_link_params * | dst, |
| const struct m0_ha_link_params * | src | ||
| ) |
◆ m0_ha_link_quiesce()
| M0_INTERNAL void m0_ha_link_quiesce | ( | struct m0_ha_link * | hl | ) |
◆ m0_ha_link_reconnect_begin()
| M0_INTERNAL void m0_ha_link_reconnect_begin | ( | struct m0_ha_link * | hl, |
| struct m0_ha_link_params * | lp | ||
| ) |
◆ m0_ha_link_reconnect_cancel()
| M0_INTERNAL void m0_ha_link_reconnect_cancel | ( | struct m0_ha_link * | hl | ) |
◆ m0_ha_link_reconnect_end()
| M0_INTERNAL void m0_ha_link_reconnect_end | ( | struct m0_ha_link * | hl, |
| const struct m0_ha_link_conn_cfg * | hl_conn_cfg | ||
| ) |
◆ m0_ha_link_reconnect_params()
| M0_INTERNAL void m0_ha_link_reconnect_params | ( | const struct m0_ha_link_params * | lp_alive, |
| struct m0_ha_link_params * | lp_alive_new, | ||
| struct m0_ha_link_params * | lp_dead_new, | ||
| const struct m0_uint128 * | id_alive, | ||
| const struct m0_uint128 * | id_dead, | ||
| const struct m0_uint128 * | id_connection | ||
| ) |
◆ m0_ha_link_recv()
| M0_INTERNAL struct m0_ha_msg * m0_ha_link_recv | ( | struct m0_ha_link * | hl, |
| uint64_t * | tag | ||
| ) |
◆ m0_ha_link_rpc_endpoint()
| M0_INTERNAL void m0_ha_link_rpc_endpoint | ( | struct m0_ha_link * | hl, |
| char * | buf, | ||
| m0_bcount_t | buf_len | ||
| ) |
◆ m0_ha_link_rpc_session()
| M0_INTERNAL struct m0_rpc_session * m0_ha_link_rpc_session | ( | struct m0_ha_link * | hl | ) |
◆ m0_ha_link_send()
| M0_INTERNAL void m0_ha_link_send | ( | struct m0_ha_link * | hl, |
| const struct m0_ha_msg * | msg, | ||
| uint64_t * | tag | ||
| ) |
◆ m0_ha_link_service_deregister()
| M0_INTERNAL void m0_ha_link_service_deregister | ( | struct m0_reqh_service * | service, |
| struct m0_ha_link * | hl | ||
| ) |
Definition at line 235 of file link_service.c.
Here is the call graph for this function:
Here is the caller graph for this function:
◆ m0_ha_link_service_find_get()
| M0_INTERNAL struct m0_ha_link * m0_ha_link_service_find_get | ( | struct m0_reqh_service * | service, |
| const struct m0_uint128 * | link_id, | ||
| struct m0_uint128 * | connection_id | ||
| ) |
Find link by link id and increase the link reference counter
Definition at line 157 of file link_service.c.
Here is the call graph for this function:
Here is the caller graph for this function:
◆ m0_ha_link_service_fini()
| M0_INTERNAL void m0_ha_link_service_fini | ( | struct m0_reqh_service * | hl_service | ) |
Definition at line 298 of file link_service.c.
Here is the call graph for this function:
Here is the caller graph for this function:
◆ m0_ha_link_service_init()
| M0_INTERNAL int m0_ha_link_service_init | ( | struct m0_reqh_service ** | hl_service, |
| struct m0_reqh * | reqh | ||
| ) |
Definition at line 290 of file link_service.c.
Here is the call graph for this function:
Here is the caller graph for this function:
◆ m0_ha_link_service_mod_fini()
| M0_INTERNAL void m0_ha_link_service_mod_fini | ( | void | ) |
Definition at line 310 of file link_service.c.
Here is the call graph for this function:
Here is the caller graph for this function:
◆ m0_ha_link_service_mod_init()
| M0_INTERNAL int m0_ha_link_service_mod_init | ( | void | ) |
Definition at line 305 of file link_service.c.
Here is the call graph for this function:
Here is the caller graph for this function:
◆ m0_ha_link_service_put()
| M0_INTERNAL void m0_ha_link_service_put | ( | struct m0_reqh_service * | service, |
| struct m0_ha_link * | hl | ||
| ) |
Definition at line 176 of file link_service.c.
Here is the call graph for this function:
Here is the caller graph for this function:
◆ m0_ha_link_service_quiesce()
| M0_INTERNAL void m0_ha_link_service_quiesce | ( | struct m0_reqh_service * | service, |
| struct m0_ha_link * | hl, | ||
| struct m0_chan * | chan | ||
| ) |
Definition at line 197 of file link_service.c.
Here is the call graph for this function:
Here is the caller graph for this function:
◆ m0_ha_link_service_register()
| M0_INTERNAL void m0_ha_link_service_register | ( | struct m0_reqh_service * | service, |
| struct m0_ha_link * | hl, | ||
| const struct m0_uint128 * | link_id, | ||
| const struct m0_uint128 * | connection_id | ||
| ) |
Definition at line 215 of file link_service.c.
Here is the call graph for this function:
Here is the caller graph for this function:
◆ m0_ha_link_start()
| M0_INTERNAL void m0_ha_link_start | ( | struct m0_ha_link * | hl, |
| struct m0_ha_link_conn_cfg * | hl_conn_cfg | ||
| ) |
◆ m0_ha_link_state_get()
| M0_INTERNAL enum m0_ha_link_state m0_ha_link_state_get | ( | struct m0_ha_link * | hl | ) |
◆ m0_ha_link_state_name()
| M0_INTERNAL const char * m0_ha_link_state_name | ( | enum m0_ha_link_state | state | ) |
◆ m0_ha_link_stop()
| M0_INTERNAL void m0_ha_link_stop | ( | struct m0_ha_link * | hl, |
| struct m0_clink * | clink | ||
| ) |
◆ m0_ha_link_tags_eq()
| M0_INTERNAL bool m0_ha_link_tags_eq | ( | const struct m0_ha_link_tags * | tags1, |
| const struct m0_ha_link_tags * | tags2 | ||
| ) |
◆ m0_ha_link_tags_initial()
| M0_INTERNAL void m0_ha_link_tags_initial | ( | struct m0_ha_link_tags * | tags, |
| bool | tag_even | ||
| ) |
Definition at line 44 of file link_fops.c.
Here is the call graph for this function:
Here is the caller graph for this function:
◆ m0_ha_link_wait_arrival()
| M0_INTERNAL void m0_ha_link_wait_arrival | ( | struct m0_ha_link * | hl | ) |
◆ m0_ha_link_wait_confirmation()
| M0_INTERNAL void m0_ha_link_wait_confirmation | ( | struct m0_ha_link * | hl, |
| uint64_t | tag | ||
| ) |
◆ m0_ha_link_wait_delivery()
| M0_INTERNAL void m0_ha_link_wait_delivery | ( | struct m0_ha_link * | hl, |
| uint64_t | tag | ||
| ) |
◆ m0_ha_lq_dequeue()
| M0_INTERNAL uint64_t m0_ha_lq_dequeue | ( | struct m0_ha_lq * | lq | ) |
◆ m0_ha_lq_enqueue()
◆ m0_ha_lq_fini()
| M0_INTERNAL void m0_ha_lq_fini | ( | struct m0_ha_lq * | lq | ) |
◆ m0_ha_lq_has_next()
| M0_INTERNAL bool m0_ha_lq_has_next | ( | const struct m0_ha_lq * | lq | ) |
◆ m0_ha_lq_has_tag()
| M0_INTERNAL bool m0_ha_lq_has_tag | ( | const struct m0_ha_lq * | lq, |
| uint64_t | tag | ||
| ) |
◆ m0_ha_lq_init()
| M0_INTERNAL void m0_ha_lq_init | ( | struct m0_ha_lq * | lq, |
| const struct m0_ha_lq_cfg * | lq_cfg | ||
| ) |
◆ m0_ha_lq_invariant()
| M0_INTERNAL bool m0_ha_lq_invariant | ( | const struct m0_ha_lq * | lq | ) |
◆ m0_ha_lq_is_delivered()
| M0_INTERNAL bool m0_ha_lq_is_delivered | ( | const struct m0_ha_lq * | lq, |
| uint64_t | tag | ||
| ) |
◆ m0_ha_lq_mark_delivered()
| M0_INTERNAL void m0_ha_lq_mark_delivered | ( | struct m0_ha_lq * | lq, |
| uint64_t | tag | ||
| ) |
◆ m0_ha_lq_msg()
◆ m0_ha_lq_msg_next()
◆ m0_ha_lq_msg_prev()
◆ m0_ha_lq_next()
◆ m0_ha_lq_tag_assign()
| M0_INTERNAL uint64_t m0_ha_lq_tag_assign | ( | const struct m0_ha_lq * | lq | ) |
◆ m0_ha_lq_tag_confirmed()
| M0_INTERNAL uint64_t m0_ha_lq_tag_confirmed | ( | const struct m0_ha_lq * | lq | ) |
◆ m0_ha_lq_tag_delivered()
| M0_INTERNAL uint64_t m0_ha_lq_tag_delivered | ( | const struct m0_ha_lq * | lq | ) |
◆ m0_ha_lq_tag_next()
| M0_INTERNAL uint64_t m0_ha_lq_tag_next | ( | const struct m0_ha_lq * | lq | ) |
◆ m0_ha_lq_tags_get()
| M0_INTERNAL void m0_ha_lq_tags_get | ( | const struct m0_ha_lq * | lq, |
| struct m0_ha_link_tags * | tags | ||
| ) |
◆ m0_ha_lq_tags_set()
| M0_INTERNAL void m0_ha_lq_tags_set | ( | struct m0_ha_lq * | lq, |
| const struct m0_ha_link_tags * | tags | ||
| ) |
◆ m0_ha_lq_try_unnext()
| M0_INTERNAL bool m0_ha_lq_try_unnext | ( | struct m0_ha_lq * | lq | ) |
◆ m0_ha_mod_fini()
| M0_INTERNAL void m0_ha_mod_fini | ( | void | ) |
◆ m0_ha_mod_init()
| M0_INTERNAL int m0_ha_mod_init | ( | void | ) |
◆ m0_ha_msg_debug_print()
| M0_INTERNAL void m0_ha_msg_debug_print | ( | const struct m0_ha_msg * | msg, |
| const char * | prefix | ||
| ) |
◆ m0_ha_msg_eq()
◆ m0_ha_msg_queue_alloc()
| M0_INTERNAL struct m0_ha_msg_qitem * m0_ha_msg_queue_alloc | ( | struct m0_ha_msg_queue * | mq | ) |
◆ m0_ha_msg_queue_dequeue()
| M0_INTERNAL struct m0_ha_msg_qitem * m0_ha_msg_queue_dequeue | ( | struct m0_ha_msg_queue * | mq | ) |
◆ m0_ha_msg_queue_enqueue()
| M0_INTERNAL void m0_ha_msg_queue_enqueue | ( | struct m0_ha_msg_queue * | mq, |
| struct m0_ha_msg_qitem * | qitem | ||
| ) |
◆ m0_ha_msg_queue_find()
| M0_INTERNAL struct m0_ha_msg_qitem * m0_ha_msg_queue_find | ( | struct m0_ha_msg_queue * | mq, |
| uint64_t | tag | ||
| ) |
Definition at line 97 of file msg_queue.c.
Here is the call graph for this function:
Here is the caller graph for this function:
◆ m0_ha_msg_queue_fini()
| M0_INTERNAL void m0_ha_msg_queue_fini | ( | struct m0_ha_msg_queue * | mq | ) |
◆ m0_ha_msg_queue_free()
| M0_INTERNAL void m0_ha_msg_queue_free | ( | struct m0_ha_msg_queue * | mq, |
| struct m0_ha_msg_qitem * | qitem | ||
| ) |
Definition at line 62 of file msg_queue.c.
Here is the call graph for this function:
Here is the caller graph for this function:
◆ m0_ha_msg_queue_init()
| M0_INTERNAL void m0_ha_msg_queue_init | ( | struct m0_ha_msg_queue * | mq, |
| struct m0_ha_msg_queue_cfg * | cfg | ||
| ) |
◆ m0_ha_msg_queue_is_empty()
| M0_INTERNAL bool m0_ha_msg_queue_is_empty | ( | struct m0_ha_msg_queue * | mq | ) |
Definition at line 91 of file msg_queue.c.
◆ m0_ha_msg_queue_next()
| M0_INTERNAL struct m0_ha_msg_qitem * m0_ha_msg_queue_next | ( | struct m0_ha_msg_queue * | mq, |
| const struct m0_ha_msg_qitem * | cur | ||
| ) |
Definition at line 105 of file msg_queue.c.
Here is the call graph for this function:
Here is the caller graph for this function:
◆ m0_ha_msg_queue_prev()
| M0_INTERNAL struct m0_ha_msg_qitem * m0_ha_msg_queue_prev | ( | struct m0_ha_msg_queue * | mq, |
| const struct m0_ha_msg_qitem * | cur | ||
| ) |
Definition at line 113 of file msg_queue.c.
Here is the call graph for this function:
Here is the caller graph for this function:
◆ m0_ha_msg_queue_push_front()
| M0_INTERNAL void m0_ha_msg_queue_push_front | ( | struct m0_ha_msg_queue * | mq, |
| struct m0_ha_msg_qitem * | qitem | ||
| ) |
Definition at line 85 of file msg_queue.c.
◆ m0_ha_msg_tag()
| M0_INTERNAL uint64_t m0_ha_msg_tag | ( | const struct m0_ha_msg * | msg | ) |
◆ m0_ha_msg_type_get()
| M0_INTERNAL enum m0_ha_msg_type m0_ha_msg_type_get | ( | const struct m0_ha_msg * | msg | ) |
◆ m0_ha_outgoing_link()
| M0_INTERNAL struct m0_ha_link * m0_ha_outgoing_link | ( | struct m0_ha * | ha | ) |
◆ m0_ha_outgoing_session()
| M0_INTERNAL struct m0_rpc_session * m0_ha_outgoing_session | ( | struct m0_ha * | ha | ) |
◆ m0_ha_process_failed()
◆ m0_ha_rpc_endpoint()
| M0_INTERNAL void m0_ha_rpc_endpoint | ( | struct m0_ha * | ha, |
| struct m0_ha_link * | hl, | ||
| char * | buf, | ||
| m0_bcount_t | buf_len | ||
| ) |
◆ m0_ha_send()
| M0_INTERNAL void m0_ha_send | ( | struct m0_ha * | ha, |
| struct m0_ha_link * | hl, | ||
| const struct m0_ha_msg * | msg, | ||
| uint64_t * | tag | ||
| ) |
◆ m0_ha_start()
| M0_INTERNAL int m0_ha_start | ( | struct m0_ha * | ha | ) |
◆ m0_ha_stop()
| M0_INTERNAL void m0_ha_stop | ( | struct m0_ha * | ha | ) |
◆ m0_ha_ut_cookie()
| void m0_ha_ut_cookie | ( | void | ) |
◆ m0_ha_ut_entrypoint_client()
| void m0_ha_ut_entrypoint_client | ( | void | ) |
◆ m0_ha_ut_entrypoint_usecase()
| void m0_ha_ut_entrypoint_usecase | ( | void | ) |
◆ m0_ha_ut_ha_usecase()
| void m0_ha_ut_ha_usecase | ( | void | ) |
◆ m0_ha_ut_link_multithreaded()
| void m0_ha_ut_link_multithreaded | ( | void | ) |
◆ m0_ha_ut_link_reconnect_multiple()
| void m0_ha_ut_link_reconnect_multiple | ( | void | ) |
◆ m0_ha_ut_link_reconnect_simple()
| void m0_ha_ut_link_reconnect_simple | ( | void | ) |
◆ m0_ha_ut_link_usecase()
| void m0_ha_ut_link_usecase | ( | void | ) |
◆ m0_ha_ut_lq()
| void m0_ha_ut_lq | ( | void | ) |
◆ m0_ha_ut_lq_mark_delivered()
| void m0_ha_ut_lq_mark_delivered | ( | void | ) |
◆ m0_ha_ut_msg_queue()
| void m0_ha_ut_msg_queue | ( | void | ) |
◆ m0_ha_ut_rpc_ctx_fini()
| M0_INTERNAL void m0_ha_ut_rpc_ctx_fini | ( | struct m0_ha_ut_rpc_ctx * | ctx | ) |
◆ m0_ha_ut_rpc_ctx_init()
| M0_INTERNAL void m0_ha_ut_rpc_ctx_init | ( | struct m0_ha_ut_rpc_ctx * | ctx | ) |
◆ m0_ha_ut_rpc_session_ctx_fini()
| M0_INTERNAL void m0_ha_ut_rpc_session_ctx_fini | ( | struct m0_ha_ut_rpc_session_ctx * | sctx | ) |
◆ m0_ha_ut_rpc_session_ctx_init()
| M0_INTERNAL void m0_ha_ut_rpc_session_ctx_init | ( | struct m0_ha_ut_rpc_session_ctx * | sctx, |
| struct m0_ha_ut_rpc_ctx * | ctx | ||
| ) |
◆ m0_halon_interface_delivered()
| void m0_halon_interface_delivered | ( | struct m0_halon_interface * | hi, |
| struct m0_ha_link * | hl, | ||
| const struct m0_ha_msg * | msg | ||
| ) |
Notifies remote side that the message is delivered. The remote side will not resend the message if Halon crashes and then m0d reconnects again after this call.
- this function should be called for all messages received in msg_received_cb();
- this function can be called from the msg_received_cb() callback.
Definition at line 1125 of file interface.c.
Here is the call graph for this function:
◆ m0_halon_interface_disconnect()
| void m0_halon_interface_disconnect | ( | struct m0_halon_interface * | hi, |
| struct m0_ha_link * | hl | ||
| ) |
Notifies m0_halon_interface that no m0_halon_interface_send() will be called for this link.
The function should be called after link_is_disconnecting_cb() is called.
Definition at line 1159 of file interface.c.
Here is the call graph for this function:
◆ m0_halon_interface_entrypoint_reply()
| void m0_halon_interface_entrypoint_reply | ( | struct m0_halon_interface * | hi, |
| const struct m0_uint128 * | req_id, | ||
| int | rc, | ||
| uint32_t | confd_nr, | ||
| const struct m0_fid * | confd_fid_data, | ||
| const char ** | confd_eps_data, | ||
| uint32_t | confd_quorum, | ||
| const struct m0_fid * | rm_fid, | ||
| const char * | rm_eps | ||
| ) |
Sends entrypoint reply.
- Parameters
-
req_id request id received in the entrypoint_request_cb() rc return code for the entrypoint. It's delivered to the user confd_nr number of confds confd_fid_data array of confd fids confd_eps_data array of confd endpoints confd_quorum confd quorum for rconfc.
- See also
- m0_rconfc::rc_quorum
- Parameters
-
rm_fid Active RM fid rp_eps Active RM endpoint
- Note
- This function can be called from entrypoint_request_cb().
Definition at line 1059 of file interface.c.
Here is the call graph for this function:
◆ m0_halon_interface_fini()
| void m0_halon_interface_fini | ( | struct m0_halon_interface * | hi | ) |
Finalises everything has been initialised during the init() call. Motr functions shouldn't be used after this call.
- Note
- This function should be called from the exactly the same thread init() has been called.
- See also
- m0_halon_interface_init()
Definition at line 627 of file interface.c.
Here is the call graph for this function:
Here is the caller graph for this function:
◆ m0_halon_interface_init()
| int m0_halon_interface_init | ( | struct m0_halon_interface ** | hi_out, |
| const char * | build_git_rev_id, | ||
| const char * | build_configure_opts, | ||
| const char * | debug_options, | ||
| const char * | node_uuid | ||
| ) |
Motr is ready to work after the call.
This function also compares given version against current library version. It detects if the given version is compatible with the current version.
- Parameters
-
hi this structure should be zeroed. build_git_rev_id
- See also
- m0_build_info::bi_git_rev_id
- Parameters
-
build_configure_opts
- See also
- m0_build_info::bi_configure_opts
- Parameters
-
debug_options options that affect debugging. See below. node_uuid node UUID string.
- See also
- lib/uuid.h.
Debug options (double quotes here are only for clarification):
- "disable-compatibility-check" Don't verify compatibility of Motr and Halon versions.
- "log-entrypoint" Log steps of entrypoint request/reply processing (M0_WARN logging level).
- "log-link" Log life cycle of m0_ha_link (M0_WARN level).
- "log-msg" Log info about sent/received messages, including delivery status (M0_WARN level).
The options can appear anywhere in the string, the code checks if the option is present with strstr(). Example: "log-link, log-msg".
Definition at line 583 of file interface.c.
Here is the call graph for this function:
Here is the caller graph for this function:
◆ m0_halon_interface_reqh()
| struct m0_reqh * m0_halon_interface_reqh | ( | struct m0_halon_interface * | hi | ) |
Returns request handler created during m0_halon_interface_start(). Returns NULL if m0_halon_interface is not in WORKING state.
The reqh should not be used after m0_halon_interface_stop() is called.
- Note
- This function may be removed in the future. It exists only to make m0_reqh available for Spiel.
- See also
- m0_halon_interface_rpc_machine()
Definition at line 1204 of file interface.c.
Here is the call graph for this function:
◆ m0_halon_interface_rpc_machine()
| struct m0_rpc_machine * m0_halon_interface_rpc_machine | ( | struct m0_halon_interface * | hi | ) |
Returns rpc machine created during m0_halon_interface_start(). Returns NULL if m0_halon_interface is not in WORKING state.
The rpc machine should not be used after m0_halon_interface_stop() is called.
- Note
- This function may be removed in the future. It exists only to make m0_rpc_machine available for Spiel.
Definition at line 1188 of file interface.c.
Here is the call graph for this function:
◆ m0_halon_interface_send()
| void m0_halon_interface_send | ( | struct m0_halon_interface * | hi, |
| struct m0_ha_link * | hl, | ||
| const struct m0_ha_msg * | msg, | ||
| uint64_t * | tag | ||
| ) |
Send m0_ha_msg using m0_ha_link.
- Parameters
-
hl m0_ha_link to send msg msg to send tag message tag is returned here.
Definition at line 1099 of file interface.c.
Here is the call graph for this function:
◆ m0_halon_interface_spiel()
| struct m0_spiel * m0_halon_interface_spiel | ( | struct m0_halon_interface * | hi | ) |
Returns spiel instance initialised during m0_halon_interface_start(). Returns NULL if m0_halon_interface is not in WORKING state.
The spiel instance should not be used after m0_halon_interface_stop() is called.
Definition at line 1220 of file interface.c.
Here is the call graph for this function:
◆ m0_halon_interface_start()
| int m0_halon_interface_start | ( | struct m0_halon_interface * | hi, |
| const char * | local_rpc_endpoint, | ||
| const struct m0_fid * | process_fid, | ||
| const struct m0_fid * | ha_service_fid, | ||
| const struct m0_fid * | rm_service_fid, | ||
| void(*)(struct m0_halon_interface *hi, const struct m0_uint128 *req_id, const char *remote_rpc_endpoint, const struct m0_fid *process_fid, const char *git_rev_id, uint64_t pid, bool first_request) | entrypoint_request_cb, | ||
| void(*)(struct m0_halon_interface *hi, struct m0_ha_link *hl, const struct m0_ha_msg *msg, uint64_t tag) | msg_received_cb, | ||
| void(*)(struct m0_halon_interface *hi, struct m0_ha_link *hl, uint64_t tag) | msg_is_delivered_cb, | ||
| void(*)(struct m0_halon_interface *hi, struct m0_ha_link *hl, uint64_t tag) | msg_is_not_delivered_cb, | ||
| void(*)(struct m0_halon_interface *hi, const struct m0_uint128 *req_id, struct m0_ha_link *link) | link_connected_cb, | ||
| void(*)(struct m0_halon_interface *hi, const struct m0_uint128 *req_id, struct m0_ha_link *link) | link_reused_cb, | ||
| void(*)(struct m0_halon_interface *hi, const struct m0_uint128 *req_id) | link_absent_cb, | ||
| void(*)(struct m0_halon_interface *hi, struct m0_ha_link *link) | link_is_disconnecting_cb, | ||
| void(*)(struct m0_halon_interface *hi, struct m0_ha_link *link) | link_disconnected_cb | ||
| ) |
Starts everything needed to handle entrypoint requests and m0_ha_msg send/recv.
- Parameters
-
local_rpc_endpoint the function creates local rpc machine with this endpoint in the current process. All network communications using this m0_halon_interface uses this rpc machine. process_fid process fid of the current process ha_service_fid HA service fid inside the current process rm_service_fid RM service fid inside the current process entrypoint_request_cb this callback is executed when entrypoint request arrives. msg_received_cb this callback is executed when a new message arrives.
- entrypoint_request_cb()
- for each callback the m0_halon_interface_entrypoint_reply() should be called with the same req_id value;
- req_id is assigned by m0_halon_interface;
- remote_rpc_endpoint parameter contains rpc endpoint from which the entrypoint request has been received;
- msg_received_cb()
- it's called when the message is received by the local rpc machine;
- m0_halon_interface_delivered() should be called for each message received.
- msg_is_delivered_cb()
- it's called when the message is delivered to the destination;
- msg_is_not_delivered_cb()
- it's called when the message is not guaranteed to be delivered to the destination.
- link_connected_cb()
- it's called when a new link is established;
- link_reused_cb()
- it's called when an existing link is reused for the entrypoint request made with req_id;
- link_is_disconnecting_cb()
- it's called when link is starting to disconnect from the opposite endpoint. After m0_halon_interface_disconnect() is called for the link and msg_is_delivered_cb() or msg_is_not_delivered_cb() is called for the each message sent over the link link_is_disconnected_cb() is executed;
- link_is_disconnected_cb()
- it's called at the end of m0_ha_link lifetime. m0_halon_interface_send() shouldn't be called for the link after this callback is executed. msg_received_cb(), msg_is_delivered_cb() and msg_is_not_delivered_cb() are not going to be called for the link after the callback is executed.
Definition at line 948 of file interface.c.
Here is the call graph for this function:
Here is the caller graph for this function:
◆ m0_halon_interface_stop()
| void m0_halon_interface_stop | ( | struct m0_halon_interface * | hi | ) |
Stops sending/receiving messages and entrypoint requests.
Definition at line 1040 of file interface.c.
Here is the call graph for this function:
Here is the caller graph for this function:
◆ m0_halon_interface_thread_adopt()
| M0_INTERNAL int m0_halon_interface_thread_adopt | ( | struct m0_halon_interface * | hi, |
| struct m0_thread * | thread | ||
| ) |
◆ m0_halon_interface_thread_shun()
| M0_INTERNAL void m0_halon_interface_thread_shun | ( | void | ) |
◆ M0_TL_DEFINE() [1/6]
| M0_TL_DEFINE | ( | ha_mq | , |
| static | , | ||
| struct m0_ha_msg_qitem | |||
| ) |
◆ M0_TL_DEFINE() [2/6]
| M0_TL_DEFINE | ( | ha_link_svc | , |
| static | , | ||
| struct m0_ha_link | |||
| ) |
◆ M0_TL_DEFINE() [3/6]
| M0_TL_DEFINE | ( | hg_client | , |
| static | , | ||
| struct ha_client | |||
| ) |
◆ M0_TL_DEFINE() [4/6]
| M0_TL_DEFINE | ( | ham | , |
| static | , | ||
| struct m0_ha_epoch_monitor | |||
| ) |
◆ M0_TL_DEFINE() [5/6]
| M0_TL_DEFINE | ( | ha_links | , |
| static | , | ||
| struct ha_link_ctx | |||
| ) |
◆ M0_TL_DEFINE() [6/6]
| M0_TL_DEFINE | ( | hes_req | , |
| static | , | ||
| struct ha_entrypoint_server_fom | |||
| ) |
◆ M0_TL_DESCR_DEFINE() [1/6]
| M0_TL_DESCR_DEFINE | ( | ha_mq | , |
| "m0_ha_msg_queue::mq_queue" | , | ||
| static | , | ||
| struct m0_ha_msg_qitem | , | ||
| hmq_link | , | ||
| hmq_magic | , | ||
| M0_HA_MSG_QITEM_MAGIC | , | ||
| M0_HA_MSG_QUEUE_HEAD_MAGIC | |||
| ) |
◆ M0_TL_DESCR_DEFINE() [2/6]
| M0_TL_DESCR_DEFINE | ( | ha_link_svc | , |
| "ha_link_service::hls_links" | , | ||
| static | , | ||
| struct m0_ha_link | , | ||
| hln_service_link | , | ||
| hln_service_magic | , | ||
| M0_HA_LINK_SERVICE_LINK_MAGIC | , | ||
| M0_HA_LINK_SERVICE_HEAD_MAGIC | |||
| ) |
◆ M0_TL_DESCR_DEFINE() [3/6]
| M0_TL_DESCR_DEFINE | ( | hg_client | , |
| "ha global clients list" | , | ||
| static | , | ||
| struct ha_client | , | ||
| hc_link | , | ||
| hc_magic | , | ||
| M0_HA_CLIENT_MAGIC | , | ||
| M0_HA_CLIENT_HEAD_MAGIC | |||
| ) |
◆ M0_TL_DESCR_DEFINE() [4/6]
| M0_TL_DESCR_DEFINE | ( | ham | , |
| "ha epoch monitor" | , | ||
| static | , | ||
| struct m0_ha_epoch_monitor | , | ||
| hem_linkage | , | ||
| hem_magix | , | ||
| M0_HA_EPOCH_MONITOR_MAGIC | , | ||
| M0_HA_DOMAIN_MAGIC | |||
| ) |
◆ M0_TL_DESCR_DEFINE() [5/6]
| M0_TL_DESCR_DEFINE | ( | ha_links | , |
| "m0_ha::h_links_{incoming,outgoing}" | , | ||
| static | , | ||
| struct ha_link_ctx | , | ||
| hlx_tlink | , | ||
| hlx_magic | , | ||
| 7 | , | ||
| 8 | |||
| ) |
◆ M0_TL_DESCR_DEFINE() [6/6]
| M0_TL_DESCR_DEFINE | ( | hes_req | , |
| "m0_ha_entrypoint_server::hes_requests" | , | ||
| static | , | ||
| struct ha_entrypoint_server_fom | , | ||
| esf_tlink | , | ||
| esf_magic | , | ||
| 10 | , | ||
| 11 | |||
| ) |
◆ M0_UT_THREADS_DEFINE()
| M0_UT_THREADS_DEFINE | ( | ha_ut_link_mt | , |
| & | ha_ut_link_mt_thread | ||
| ) |
◆ M0_XCA_DOMAIN()
| struct m0_ha_cookie_xc M0_XCA_DOMAIN | ( | rpc | ) |
◆ main()
| int main | ( | int | argc, |
| char * | argv[] | ||
| ) |
Variable Documentation
◆ ha_entrypoint_client_fom_ops
|
static |
Initial value:
= {
.fo_fini = ha_entrypoint_client_fom_fini,
.fo_tick = ha_entrypoint_client_fom_tick,
.fo_home_locality = ha_entrypoint_client_fom_locality,
}
static int ha_entrypoint_client_fom_tick(struct m0_fom *fom)
Definition: entrypoint.c:514
static void ha_entrypoint_client_fom_fini(struct m0_fom *fom)
Definition: entrypoint.c:662
static size_t ha_entrypoint_client_fom_locality(const struct m0_fom *fom)
Definition: entrypoint.c:690
Definition at line 701 of file entrypoint.c.
◆ ha_entrypoint_client_fom_states
|
static |
Initial value:
= {
[HEC_FOM_INIT] = {
.sd_flags = M0_SDF_INITIAL,
.sd_name = "HEC_FOM_INIT",
.sd_allowed = M0_BITS(HEC_FOM_FINI),
},
[HEC_FOM_FINI] = {
.sd_flags = M0_SDF_TERMINAL,
.sd_name = "HEC_FOM_FINI",
.sd_allowed = 0,
},
}
Definition: entrypoint.c:399
Definition: entrypoint.c:400
Definition: sm.h:471
Definition: sm.h:450
Definition at line 403 of file entrypoint.c.
◆ ha_entrypoint_client_fom_states_conf
|
static |
Initial value:
= {
.scf_name = "entrypoint client fom",
.scf_nr_states = ARRAY_SIZE(ha_entrypoint_client_fom_states),
.scf_state = ha_entrypoint_client_fom_states,
}
static struct m0_sm_state_descr ha_entrypoint_client_fom_states[]
Definition: entrypoint.c:403
Definition at line 416 of file entrypoint.c.
◆ ha_entrypoint_client_fom_type
|
static |
Definition at line 695 of file entrypoint.c.
◆ ha_entrypoint_client_fom_type_ops
|
static |
Initial value:
Definition at line 697 of file entrypoint.c.
◆ ha_entrypoint_client_item_ops
|
static |
Initial value:
= {
.rio_replied = ha_entrypoint_client_replied,
}
static void ha_entrypoint_client_replied(struct m0_rpc_item *item)
Definition: entrypoint.c:476
Definition at line 497 of file entrypoint.c.
◆ ha_entrypoint_client_states
|
static |
Definition at line 328 of file entrypoint.c.
◆ ha_entrypoint_client_states_conf
|
static |
Initial value:
= {
.scf_name = "m0_ha_entrypoint_client::ecl_sm",
.scf_nr_states = ARRAY_SIZE(ha_entrypoint_client_states),
.scf_state = ha_entrypoint_client_states,
}
static struct m0_sm_state_descr ha_entrypoint_client_states[]
Definition: entrypoint.c:328
Definition at line 392 of file entrypoint.c.
◆ ha_entrypoint_get_fom_ops
| const struct m0_fom_ops ha_entrypoint_get_fom_ops |
Initial value:
= {
.fo_tick = ha_entrypoint_get_fom_tick,
.fo_fini = ha_entrypoint_fom_fini,
.fo_home_locality = ha_entrypoint_home_locality,
}
static int ha_entrypoint_get_fom_tick(struct m0_fom *fom)
Definition: entrypoint.c:872
static size_t ha_entrypoint_home_locality(const struct m0_fom *fom)
Definition: entrypoint.c:856
static void ha_entrypoint_fom_fini(struct m0_fom *fom)
Definition: entrypoint.c:861
Definition at line 914 of file entrypoint.c.
◆ ha_entrypoint_server_fom_states
|
static |
Initial value:
= {
[M0_HES_INIT] = {
.sd_flags = M0_SDF_INITIAL,
.sd_name = "M0_HES_INIT",
.sd_allowed = M0_BITS(M0_HES_REPLY_WAIT),
},
[M0_HES_REPLY_WAIT] = {
.sd_flags = 0,
.sd_name = "M0_HES_REPLY_WAIT",
.sd_allowed = M0_BITS(M0_HES_FINI),
},
[M0_HES_FINI] = {
.sd_flags = M0_SDF_TERMINAL,
.sd_name = "M0_HES_FINI",
.sd_allowed = 0,
},
}
Definition: entrypoint.h:63
Definition: entrypoint.h:64
Definition: sm.h:471
Definition: entrypoint.h:65
Definition: sm.h:450
Definition at line 170 of file entrypoint.c.
◆ ha_entrypoint_service_ops
|
static |
Initial value:
= {
.rso_start = ha_entrypoint_service_start,
.rso_fop_accept = ha_entrypoint_service_fop_accept,
.rso_stop = ha_entrypoint_service_stop,
.rso_fini = ha_entrypoint_service_fini,
}
static int ha_entrypoint_service_start(struct m0_reqh_service *service)
Definition: entrypoint.c:101
static void ha_entrypoint_service_stop(struct m0_reqh_service *service)
Definition: entrypoint.c:114
static int ha_entrypoint_service_fop_accept(struct m0_reqh_service *service, struct m0_fop *fop)
Definition: entrypoint.c:107
static void ha_entrypoint_service_fini(struct m0_reqh_service *service)
Definition: entrypoint.c:89
Definition at line 120 of file entrypoint.c.
◆ ha_entrypoint_stype_ops
|
static |
Initial value:
= {
.rsto_service_allocate = ha_entrypoint_service_allocate,
}
static int ha_entrypoint_service_allocate(struct m0_reqh_service **service, const struct m0_reqh_service_type *stype)
Definition: entrypoint.c:143
Definition at line 131 of file entrypoint.c.
◆ ha_levels
◆ ha_link_incoming_fom_ops
| const struct m0_fom_ops ha_link_incoming_fom_ops |
Initial value:
= {
.fo_tick = &ha_link_incoming_fom_tick,
.fo_fini = &ha_link_incoming_fom_fini,
.fo_home_locality = &ha_link_incoming_fom_locality,
}
static size_t ha_link_incoming_fom_locality(const struct m0_fom *fom)
Definition: link.c:1008
static void ha_link_incoming_fom_fini(struct m0_fom *fom)
Definition: link.c:998
static int ha_link_incoming_fom_tick(struct m0_fom *fom)
Definition: link.c:916
◆ ha_link_outgoing_fom_conf
|
static |
Initial value:
= {
.scf_name = "ha_link_outgoing_fom",
.scf_nr_states = ARRAY_SIZE(ha_link_outgoing_fom_states),
.scf_state = ha_link_outgoing_fom_states,
}
static struct m0_sm_state_descr ha_link_outgoing_fom_states[HA_LINK_OUTGOING_STATE_NR]
Definition: link.c:1082
◆ ha_link_outgoing_fom_ops
| const struct m0_fom_ops ha_link_outgoing_fom_ops |
Initial value:
= {
.fo_tick = &ha_link_outgoing_fom_tick,
.fo_fini = &ha_link_outgoing_fom_fini,
.fo_home_locality = &ha_link_outgoing_fom_locality,
}
static void ha_link_outgoing_fom_fini(struct m0_fom *fom)
Definition: link.c:1665
static size_t ha_link_outgoing_fom_locality(const struct m0_fom *fom)
Definition: link.c:1676
static int ha_link_outgoing_fom_tick(struct m0_fom *fom)
Definition: link.c:1346
◆ ha_link_outgoing_fom_states
|
static |
◆ ha_link_outgoing_fom_type
|
static |
◆ ha_link_outgoing_item_ops
|
static |
Initial value:
= {
.rio_sent = &ha_link_outgoing_item_sent,
.rio_replied = &ha_link_outgoing_item_replied,
}
static void ha_link_outgoing_item_sent(struct m0_rpc_item *item)
Definition: link.c:1133
static void ha_link_outgoing_item_replied(struct m0_rpc_item *item)
Definition: link.c:1144
◆ ha_link_service_bob_type
|
static |
Initial value:
= {
.bt_name = "m0_ha_link_service",
.bt_magix = M0_HALON_INTERFACE_MAGIC,
}
Definition: link_service.c:52
Definition: magic.h:499
Definition at line 61 of file link_service.c.
◆ ha_link_service_ops
|
static |
Initial value:
= {
.rso_start = ha_link_service_start,
.rso_fop_accept = ha_link_service_fop_accept,
.rso_stop = ha_link_service_stop,
.rso_fini = ha_link_service_fini,
}
static int ha_link_service_start(struct m0_reqh_service *service)
Definition: link_service.c:104
static void ha_link_service_fini(struct m0_reqh_service *service)
Definition: link_service.c:90
static void ha_link_service_stop(struct m0_reqh_service *service)
Definition: link_service.c:117
static int ha_link_service_fop_accept(struct m0_reqh_service *service, struct m0_fop *fop)
Definition: link_service.c:110
Definition at line 249 of file link_service.c.
◆ ha_link_sm_conf
|
static |
Initial value:
= {
.scf_name = "m0_ha_link::hln_sm",
.scf_nr_states = ARRAY_SIZE(ha_link_sm_states),
.scf_state = ha_link_sm_states,
}
◆ ha_link_sm_states
|
static |
◆ ha_link_stype_ops
|
static |
Initial value:
= {
.rsto_service_allocate = ha_link_service_allocate,
}
static int ha_link_service_allocate(struct m0_reqh_service **service, const struct m0_reqh_service_type *stype)
Definition: link_service.c:270
Definition at line 259 of file link_service.c.
◆ ha_mod_levels
|
static |
Initial value:
= {
[M0_HA_MOD_LEVEL_ASSIGNS] = {
.ml_name = "M0_HA_MOD_LEVEL_ASSIGNS",
.ml_enter = ha_mod_level_enter,
.ml_leave = ha_mod_level_leave,
},
.ml_name = "M0_HA_MOD_LEVEL_LINK_SERVICE",
.ml_enter = ha_mod_level_enter,
.ml_leave = ha_mod_level_leave,
},
[M0_HA_MOD_LEVEL_LINK] = {
.ml_name = "M0_HA_MOD_LEVEL_LINK",
.ml_enter = ha_mod_level_enter,
.ml_leave = ha_mod_level_leave,
},
.ml_name = "M0_HA_MOD_LEVEL_ENTRYPOINT",
.ml_enter = ha_mod_level_enter,
.ml_leave = ha_mod_level_leave,
},
[M0_HA_MOD_LEVEL_STARTED] = {
.ml_name = "M0_HA_MOD_LEVEL_STARTED",
},
}
Definition: ha.c:878
Definition: ha.c:882
Definition: ha.c:880
Definition: ha.c:881
Definition: ha.c:879
◆ ha_ut
| struct m0_ut_suite ha_ut |
Initial value:
= {
.ts_name = "ha-ut",
.ts_init = NULL,
.ts_fini = NULL,
.ts_tests = {
{ "cookie", &m0_ha_ut_cookie },
{ "msg_queue", &m0_ha_ut_msg_queue },
{ "lq", &m0_ha_ut_lq },
{ "lq-mark_delivered", &m0_ha_ut_lq_mark_delivered },
{ "link-usecase", &m0_ha_ut_link_usecase },
{ "link-multithreaded", &m0_ha_ut_link_multithreaded },
{ "link-reconnect_simple", &m0_ha_ut_link_reconnect_simple },
{ "link-reconnect_multiple",&m0_ha_ut_link_reconnect_multiple },
{ "entrypoint-usecase", &m0_ha_ut_entrypoint_usecase },
{ "entrypoint-client", &m0_ha_ut_entrypoint_client },
{ "ha-usecase", &m0_ha_ut_ha_usecase },
},
}
◆ ha_ut_usecase_ha_ops
|
static |
Initial value:
= {
.hao_entrypoint_request = ha_ut_usecase_entrypoint_request,
.hao_entrypoint_replied = ha_ut_usecase_entrypoint_replied,
.hao_msg_received = ha_ut_usecase_msg_received,
.hao_msg_is_delivered = ha_ut_usecase_msg_is_delivered,
.hao_msg_is_not_delivered = ha_ut_usecase_msg_is_not_delivered,
.hao_link_connected = ha_ut_usecase_link_connected,
.hao_link_reused = ha_ut_usecase_link_reused,
.hao_link_is_disconnecting = ha_ut_usecase_link_is_disconnecting,
.hao_link_disconnected = ha_ut_usecase_link_disconnected,
}
static void ha_ut_usecase_link_disconnected(struct m0_ha *ha, struct m0_ha_link *hl)
Definition: ha.c:178
static void ha_ut_usecase_msg_is_not_delivered(struct m0_ha *ha, struct m0_ha_link *hl, uint64_t tag)
Definition: ha.c:139
static void ha_ut_usecase_msg_is_delivered(struct m0_ha *ha, struct m0_ha_link *hl, uint64_t tag)
Definition: ha.c:133
static void ha_ut_usecase_entrypoint_replied(struct m0_ha *ha, struct m0_ha_entrypoint_rep *rep)
Definition: ha.c:113
static void ha_ut_usecase_link_reused(struct m0_ha *ha, const struct m0_uint128 *req_id, struct m0_ha_link *hl)
Definition: ha.c:156
static void ha_ut_usecase_link_connected(struct m0_ha *ha, const struct m0_uint128 *req_id, struct m0_ha_link *hl)
Definition: ha.c:145
static void ha_ut_usecase_entrypoint_request(struct m0_ha *ha, const struct m0_ha_entrypoint_req *req, const struct m0_uint128 *req_id)
Definition: ha.c:88
static void ha_ut_usecase_link_is_disconnecting(struct m0_ha *ha, struct m0_ha_link *hl)
Definition: ha.c:167
static void ha_ut_usecase_msg_received(struct m0_ha *ha, struct m0_ha_link *hl, struct m0_ha_msg *msg, uint64_t tag)
Definition: ha.c:126
◆ halon_interface_bob_type
|
static |
Initial value:
= {
.bt_name = "halon interface",
hii_magix),
.bt_magix = M0_HALON_INTERFACE_MAGIC,
}
Definition: magic.h:499
Definition: interface.c:171
Definition at line 192 of file interface.c.
◆ halon_interface_ha_ops
|
static |
Initial value:
= {
.hao_entrypoint_request = &halon_interface_entrypoint_request_cb,
.hao_entrypoint_replied = &halon_interface_entrypoint_replied_cb,
.hao_msg_received = &halon_interface_msg_received_cb,
.hao_msg_is_delivered = &halon_interface_msg_is_delivered_cb,
.hao_msg_is_not_delivered = &halon_interface_msg_is_not_delivered_cb,
.hao_link_connected = &halon_interface_link_connected_cb,
.hao_link_reused = &halon_interface_link_reused_cb,
.hao_link_absent = &halon_interface_link_absent_cb,
.hao_link_is_disconnecting = &halon_interface_link_is_disconnecting_cb,
.hao_link_disconnected = &halon_interface_link_disconnected_cb,
}
static void halon_interface_link_connected_cb(struct m0_ha *ha, const struct m0_uint128 *req_id, struct m0_ha_link *hl)
Definition: interface.c:457
static void halon_interface_link_is_disconnecting_cb(struct m0_ha *ha, struct m0_ha_link *hl)
Definition: interface.c:512
static void halon_interface_msg_is_delivered_cb(struct m0_ha *ha, struct m0_ha_link *hl, uint64_t tag)
Definition: interface.c:421
static void halon_interface_entrypoint_replied_cb(struct m0_ha *ha, struct m0_ha_entrypoint_rep *rep)
Definition: interface.c:378
static void halon_interface_link_disconnected_cb(struct m0_ha *ha, struct m0_ha_link *hl)
Definition: interface.c:527
static void halon_interface_link_reused_cb(struct m0_ha *ha, const struct m0_uint128 *req_id, struct m0_ha_link *hl)
Definition: interface.c:477
static void halon_interface_msg_is_not_delivered_cb(struct m0_ha *ha, struct m0_ha_link *hl, uint64_t tag)
Definition: interface.c:439
static void halon_interface_msg_received_cb(struct m0_ha *ha, struct m0_ha_link *hl, struct m0_ha_msg *msg, uint64_t tag)
Definition: interface.c:391
static void halon_interface_link_absent_cb(struct m0_ha *ha, const struct m0_uint128 *req_id)
Definition: interface.c:497
static void halon_interface_entrypoint_request_cb(struct m0_ha *ha, const struct m0_ha_entrypoint_req *req, const struct m0_uint128 *req_id)
Definition: interface.c:347
Definition at line 542 of file interface.c.
◆ halon_interface_levels
|
static |
Definition at line 667 of file interface.c.
◆ halon_interface_sm_conf
|
static |
Initial value:
= {
.scf_name = "m0_halon_interface_internal::hii_sm",
.scf_nr_states = ARRAY_SIZE(halon_interface_states),
.scf_state = halon_interface_states,
}
static struct m0_sm_state_descr halon_interface_states[]
Definition: interface.c:555
Definition at line 577 of file interface.c.
◆ halon_interface_states
|
static |
Initial value:
= {
.sd_flags = M0_SDF_INITIAL,
.sd_name = "M0_HALON_INTERFACE_STATE_UNINITIALISED",
.sd_allowed = M0_BITS(M0_HALON_INTERFACE_STATE_INITIALISED),
},
.sd_name = "M0_HALON_INTERFACE_STATE_INITIALISED",
.sd_allowed = M0_BITS(M0_HALON_INTERFACE_STATE_WORKING,
},
.sd_name = "M0_HALON_INTERFACE_STATE_WORKING",
.sd_allowed = M0_BITS(M0_HALON_INTERFACE_STATE_INITIALISED),
},
.sd_flags = M0_SDF_TERMINAL,
.sd_name = "M0_HALON_INTERFACE_STATE_FINALISED",
.sd_allowed = 0,
},
}
Definition: interface.c:167
Definition: sm.h:471
Definition: sm.h:450
Definition at line 555 of file interface.c.
◆ m0_ha_cookie_no_record [1/2]
| const struct m0_ha_cookie m0_ha_cookie_no_record |
Initial value:
◆ m0_ha_cookie_no_record [2/2]
| const struct m0_ha_cookie m0_ha_cookie_no_record |
◆ m0_ha_entrypoint_fom_type_ops [1/2]
| const struct m0_fom_type_ops m0_ha_entrypoint_fom_type_ops |
Definition at line 959 of file entrypoint.c.
◆ m0_ha_entrypoint_fom_type_ops [2/2]
| const struct m0_fom_type_ops m0_ha_entrypoint_fom_type_ops |
Initial value:
= {
.fto_create = &ha_entrypoint_fom_create,
}
static int ha_entrypoint_fom_create(struct m0_fop *fop, struct m0_fom **m, struct m0_reqh *reqh)
Definition: entrypoint.c:920
Definition at line 959 of file entrypoint.c.
◆ m0_ha_entrypoint_rep_fopt [1/2]
| struct m0_fop_type m0_ha_entrypoint_rep_fopt |
Definition at line 48 of file entrypoint_fops.c.
◆ m0_ha_entrypoint_rep_fopt [2/2]
| struct m0_fop_type m0_ha_entrypoint_rep_fopt |
Definition at line 48 of file entrypoint_fops.c.
◆ m0_ha_entrypoint_req_fopt [1/2]
| struct m0_fop_type m0_ha_entrypoint_req_fopt |
Definition at line 47 of file entrypoint_fops.c.
◆ m0_ha_entrypoint_req_fopt [2/2]
| struct m0_fop_type m0_ha_entrypoint_req_fopt |
Definition at line 47 of file entrypoint_fops.c.
◆ m0_ha_entrypoint_server_fom_states_conf [1/2]
| struct m0_sm_conf m0_ha_entrypoint_server_fom_states_conf |
Initial value:
= {
.scf_name = "entrypoint server fom",
.scf_nr_states = ARRAY_SIZE(ha_entrypoint_server_fom_states),
.scf_state = ha_entrypoint_server_fom_states,
}
static struct m0_sm_state_descr ha_entrypoint_server_fom_states[]
Definition: entrypoint.c:170
Definition at line 188 of file entrypoint.c.
◆ m0_ha_entrypoint_server_fom_states_conf [2/2]
| struct m0_sm_conf m0_ha_entrypoint_server_fom_states_conf |
Definition at line 188 of file entrypoint.c.
◆ m0_ha_entrypoint_service_type [1/2]
| struct m0_reqh_service_type m0_ha_entrypoint_service_type |
Initial value:
= {
.rst_name = "ha-entrypoint-service",
.rst_ops = &ha_entrypoint_stype_ops,
.rst_level = M0_HA_ENTRYPOINT_SVC_LEVEL,
.rst_keep_alive = true,
}
Definition: reqh_service.h:643
static const struct m0_reqh_service_type_ops ha_entrypoint_stype_ops
Definition: entrypoint.c:131
Definition at line 135 of file entrypoint.c.
◆ m0_ha_entrypoint_service_type [2/2]
| struct m0_reqh_service_type m0_ha_entrypoint_service_type |
Definition at line 135 of file entrypoint.c.
◆ M0_HA_EPOCH_NONE [1/2]
◆ M0_HA_EPOCH_NONE [2/2]
| M0_EXTERN const uint64_t M0_HA_EPOCH_NONE |
◆ m0_ha_link_incoming_fom_type_ops [1/2]
| const struct m0_fom_type_ops m0_ha_link_incoming_fom_type_ops |
◆ m0_ha_link_incoming_fom_type_ops [2/2]
| const struct m0_fom_type_ops m0_ha_link_incoming_fom_type_ops |
Initial value:
= {
.fto_create = &ha_link_incoming_fom_create,
}
static int ha_link_incoming_fom_create(struct m0_fop *fop, struct m0_fom **m, struct m0_reqh *reqh)
Definition: link.c:1019
◆ m0_ha_link_msg_fopt [1/2]
| struct m0_fop_type m0_ha_link_msg_fopt |
Definition at line 41 of file link_fops.c.
◆ m0_ha_link_msg_fopt [2/2]
| struct m0_fop_type m0_ha_link_msg_fopt |
Definition at line 41 of file link_fops.c.
◆ m0_ha_link_msg_rep_fopt [1/2]
| struct m0_fop_type m0_ha_link_msg_rep_fopt |
Definition at line 42 of file link_fops.c.
◆ m0_ha_link_msg_rep_fopt [2/2]
| struct m0_fop_type m0_ha_link_msg_rep_fopt |
Definition at line 42 of file link_fops.c.
◆ m0_ha_link_outgoing_fom_type_ops [1/2]
| const struct m0_fom_type_ops m0_ha_link_outgoing_fom_type_ops |
◆ m0_ha_link_outgoing_fom_type_ops [2/2]
| const struct m0_fom_type_ops m0_ha_link_outgoing_fom_type_ops |
Initial value:
= {
.fto_create = &ha_link_outgoing_fom_create,
}
static int ha_link_outgoing_fom_create(struct m0_fop *fop, struct m0_fom **m, struct m0_reqh *reqh)
Definition: link.c:1687
◆ m0_ha_link_service_type [1/2]
| struct m0_reqh_service_type m0_ha_link_service_type |
Definition at line 263 of file link_service.c.
◆ m0_ha_link_service_type [2/2]
| struct m0_reqh_service_type m0_ha_link_service_type |
Initial value:
= {
.rst_name = "ha-link-service",
.rst_ops = &ha_link_stype_ops,
.rst_level = M0_HA_LINK_SVC_LEVEL,
.rst_keep_alive = true,
}
static const struct m0_reqh_service_type_ops ha_link_stype_ops
Definition: link_service.c:259
Definition: reqh_service.h:640
Definition at line 263 of file link_service.c.
◆ M0_XCA_DOMAIN [1/3]
| enum { ... } M0_XCA_DOMAIN |
◆ M0_XCA_DOMAIN [2/3]
| struct ha_link_service M0_XCA_DOMAIN |
◆ M0_XCA_DOMAIN [3/3]
| struct m0_ha_entrypoint_req M0_XCA_DOMAIN |
