Bulk Node

Collaboration diagram for Bulk Node:

Data Structures
struct	buf_status_errno
struct	buf_status_bulk
struct	buf_status_ping
struct	server_status_bulk
struct	state_transition
struct	node_bulk_ctx

Enumerations
enum	transfer_state {   TS_UNUSED = 0, TS_QUEUED, TS_BD_SENT, TS_CB_LEFT2,   TS_CB_LEFT1, TS_FAILED2, TS_FAILED1, TS_BD_RECEIVED,   TS_SENDING, TS_RECEIVING, TS_BADMSG, TS_FAILED,   TS_TRANSFERRED }

Functions
	M0_TL_DESCR_DEFINE (bsb, "buf_status_bulk", static, struct buf_status_bulk, bsb_tlink, bsb_magic, M0_NET_TEST_BSB_MAGIC, M0_NET_TEST_BSB_HEAD_MAGIC)
	M0_TL_DEFINE (bsb, static, struct buf_status_bulk)
	M0_TL_DESCR_DEFINE (ssb, "server_status_bulk", static, struct server_status_bulk, ssb_tlink, ssb_magic, M0_NET_TEST_SSB_MAGIC, M0_NET_TEST_SSB_HEAD_MAGIC)
	M0_TL_DEFINE (ssb, static, struct server_status_bulk)
	M0_TL_DESCR_DEFINE (bsp, "buf_status_ping", static, struct buf_status_ping, bsp_tlink, bsp_magic, M0_NET_TEST_BSP_MAGIC, M0_NET_TEST_BSP_HEAD_MAGIC)
	M0_TL_DEFINE (bsp, static, struct buf_status_ping)
static void	sd_update (struct node_bulk_ctx *ctx, enum m0_net_test_nh_msg_type type, enum m0_net_test_nh_msg_status status, enum m0_net_test_nh_msg_direction direction)
static void	node_bulk_tm_event_cb (const struct m0_net_tm_event *ev)
static struct node_bulk_ctx *	node_bulk_ctx_from_net_ctx (struct m0_net_test_network_ctx *net_ctx)
static bool	node_bulk_state_change_allowed (enum transfer_state from, enum transfer_state to, const struct state_transition allowed[], size_t allowed_size)
static bool	node_bulk_state_is_final (enum transfer_state state)
static void	node_bulk_state_change (struct node_bulk_ctx *ctx, size_t bs_index, enum transfer_state state)
static void	node_bulk_state_check (const struct state_transition state_list[], size_t state_nr)
static void	node_bulk_state_check_all (void)
static enum transfer_state	node_bulk_state_search (enum transfer_state state, const struct state_transition state_list[], size_t state_nr)
static void	node_bulk_state_change_cb (struct node_bulk_ctx *ctx, size_t bs_index, bool success)
void	node_bulk_state_transition_auto (struct node_bulk_ctx *ctx, size_t bs_index)
void	node_bulk_state_transition_auto_all (struct node_bulk_ctx *ctx)
static void	server_process_unused_ping (struct node_bulk_ctx *ctx)
static struct m0_net_buffer *	net_buf_bulk_get (struct node_bulk_ctx *ctx, size_t buf_bulk_index)
static void	buf_desc_set0 (struct node_bulk_ctx *ctx, size_t buf_bulk_index)
static void	buf_desc_swap (struct node_bulk_ctx *ctx, size_t buf_bulk_index)
static void	buf_desc_server_free (struct node_bulk_ctx *ctx, size_t buf_bulk_index)
static void	buf_desc_client_free (struct node_bulk_ctx *ctx, size_t bs_index)
static m0_bcount_t	buf_desc_deserialize (struct node_bulk_ctx *ctx, size_t buf_bulk_index, size_t buf_ping_index, m0_bcount_t offset)
static m0_bcount_t	node_bulk_server_transfer_start (struct node_bulk_ctx *ctx, size_t buf_ping_index, m0_bcount_t offset)
static void	node_bulk_cb_server (struct node_bulk_ctx *ctx, size_t buf_index, enum m0_net_queue_type q, const struct m0_net_buffer_event *ev)
static void	node_bulk_cb_client (struct node_bulk_ctx *ctx, size_t buf_index, enum m0_net_queue_type q, const struct m0_net_buffer_event *ev)
static bool	node_bulk_is_stopping (struct node_bulk_ctx *ctx)
static void	node_bulk_cb (struct m0_net_test_network_ctx *net_ctx, const uint32_t buf_index, enum m0_net_queue_type q, const struct m0_net_buffer_event *ev)
static size_t	client_server_index (struct node_bulk_ctx *ctx, size_t bs_index)
static int	client_bulk_enqueue (struct node_bulk_ctx *ctx, size_t buf_index)
static void	client_bulk_dequeue (struct node_bulk_ctx *ctx, size_t buf_index)
static void	client_transfer_start (struct node_bulk_ctx *ctx, size_t bs_index)
static void	client_process_unused_bulk (struct node_bulk_ctx *ctx)
static m0_bcount_t	client_bds_serialize2 (struct m0_net_test_network_ctx *net, size_t bsb_index, size_t msg_buf_index, m0_bcount_t offset)
static void	client_bulk_bufs_dequeue (struct node_bulk_ctx *ctx, struct buf_status_bulk *bs)
static void	client_bds_send (struct node_bulk_ctx *ctx, struct server_status_bulk *ss)
static void	client_process_queued_bulk (struct node_bulk_ctx *ctx)
static void	node_bulk_buf_unused (struct node_bulk_ctx *ctx)
static void	node_bulk_buf_dequeue (struct node_bulk_ctx *ctx)
static bool	node_bulk_bufs_unused_all (struct node_bulk_ctx *ctx)
static void	net_bulk_worker_cb (struct node_bulk_ctx *ctx, bool pending)
static void	node_bulk_worker (struct node_bulk_ctx *ctx)
static int	node_bulk_test_init_fini (struct node_bulk_ctx *ctx, const struct m0_net_test_cmd *cmd)
static void *	node_bulk_initfini (void *ctx_, struct m0_net_test_service *svc)
static void *	node_bulk_init (struct m0_net_test_service *svc)
static void	node_bulk_fini (void *ctx_)
static int	node_bulk_step (void *ctx_)
static int	node_bulk_cmd_init (void *ctx_, const struct m0_net_test_cmd *cmd, struct m0_net_test_cmd *reply)
static int	node_bulk_cmd_start (void *ctx_, const struct m0_net_test_cmd *cmd, struct m0_net_test_cmd *reply)
static int	node_bulk_cmd_stop (void *ctx_, const struct m0_net_test_cmd *cmd, struct m0_net_test_cmd *reply)
static int	node_bulk_cmd_status (void *ctx_, const struct m0_net_test_cmd *cmd, struct m0_net_test_cmd *reply)
int	m0_net_test_node_bulk_init (void)
void	m0_net_test_node_bulk_fini (void)

Variables
static const struct m0_net_tm_callbacks	node_bulk_tm_cb
static const struct state_transition	node_bulk_client_success []
static const struct state_transition	node_bulk_client_failure []
static const struct state_transition	node_bulk_server_success []
static const struct state_transition	node_bulk_server_failure []
struct {
const struct state_transition *   nbst_transition
const size_t   nbst_nr
}	node_bulk_state_transitions []
static struct m0_net_test_network_buffer_callbacks	node_bulk_buf_cb
static struct m0_net_test_service_cmd_handler	node_bulk_cmd_handler []
struct m0_net_test_service_ops	m0_net_test_node_bulk_ops

Detailed Description

Bulk node service m0_net_test_service_ops:

• ntso_init
  • allocate bulk node context
• ntso_fini
  • finalize network context if it was initialized;
  • free bulk node context
• ntso_step
  • the same as node_ping
• ntso_cmd_handler
  • M0_NET_TEST_CMD_INIT
    • initialize network context
    • reset statistics
    • send M0_NET_TEST_CMD_INIT_DONE reply
  • M0_NET_TEST_CMD_START
    • the same as node_ping
  • M0_NET_TEST_CMD_STOP
    • the same as node_ping
  • M0_NET_TEST_CMD_STATUS
    • fill and send M0_NET_TEST_CMD_STATUS_DATA reply

Test client:

• bulk-buffer-not-in-net-queue queue
• ping-buffer-not-in-net-queue queue
• enqueue pair <send buf, recv buf> (with m0_net level timeouts)
• max_bd_in_one_message (parameter)
• send bd list to the test server without waiting for reply or delivery confirmation
• number of ping buffers
• number of bulk buffers

Test server:

• number of ping buffers
• number of bulk buffers
• all bulk and ping buffers in recv queue with M0_TIME_NEVER timeout

Enumeration Type Documentation

transfer_state

enum transfer_state

Test message transfer state.

See also

Bulk Test Client Algorithm, Bulk Test Server Algorithm.

Enumerator
TS_UNUSED	client & server state
TS_QUEUED	client state
TS_BD_SENT	client state
TS_CB_LEFT2	client state
TS_CB_LEFT1	client state
TS_FAILED2	client state
TS_FAILED1	client state
TS_BD_RECEIVED	server state
TS_SENDING	server state
TS_RECEIVING	server state
TS_BADMSG	client & server state
TS_FAILED	client & server state
TS_TRANSFERRED	client & server state

Definition at line 89 of file node_bulk.c.

Function Documentation

buf_desc_client_free()

static void buf_desc_client_free ( struct node_bulk_ctx *  ctx, size_t  bs_index  )

static

Definition at line 639 of file node_bulk.c.

Here is the call graph for this function:

Here is the caller graph for this function:

buf_desc_deserialize()

static m0_bcount_t buf_desc_deserialize ( struct node_bulk_ctx *  ctx, size_t  buf_bulk_index, size_t  buf_ping_index, m0_bcount_t  offset  )

static

Definition at line 649 of file node_bulk.c.

Here is the call graph for this function:

Here is the caller graph for this function:

buf_desc_server_free()

static void buf_desc_server_free ( struct node_bulk_ctx *  ctx, size_t  buf_bulk_index  )

static

Definition at line 629 of file node_bulk.c.

Here is the call graph for this function:

Here is the caller graph for this function:

buf_desc_set0()

static void buf_desc_set0 ( struct node_bulk_ctx *  ctx, size_t  buf_bulk_index  )

static

Definition at line 605 of file node_bulk.c.

Here is the call graph for this function:

Here is the caller graph for this function:

buf_desc_swap()

static void buf_desc_swap ( struct node_bulk_ctx *  ctx, size_t  buf_bulk_index  )

static

Swap contents of network buf descriptors for bulk network buffer buf_index and buf_status_bulk.bsb_desc_send for this buffer.

Definition at line 619 of file node_bulk.c.

Here is the call graph for this function:

Here is the caller graph for this function:

client_bds_send()

static void client_bds_send ( struct node_bulk_ctx *  ctx, struct server_status_bulk *  ss  )

static

Definition at line 1060 of file node_bulk.c.

Here is the call graph for this function:

Here is the caller graph for this function:

client_bds_serialize2()

static m0_bcount_t client_bds_serialize2 ( struct m0_net_test_network_ctx *  net, size_t  bsb_index, size_t  msg_buf_index, m0_bcount_t  offset  )

static

Definition at line 1017 of file node_bulk.c.

Here is the call graph for this function:

Here is the caller graph for this function:

client_bulk_bufs_dequeue()

static void client_bulk_bufs_dequeue ( struct node_bulk_ctx *  ctx, struct buf_status_bulk *  bs  )

static

Definition at line 1053 of file node_bulk.c.

Here is the call graph for this function:

Here is the caller graph for this function:

client_bulk_dequeue()

static void client_bulk_dequeue ( struct node_bulk_ctx *  ctx, size_t  buf_index  )

static

Definition at line 952 of file node_bulk.c.

Here is the call graph for this function:

Here is the caller graph for this function:

client_bulk_enqueue()

static int client_bulk_enqueue ( struct node_bulk_ctx *  ctx, size_t  buf_index  )

static

Enqueue passive send/recv buffers for the test client

Definition at line 939 of file node_bulk.c.

Here is the call graph for this function:

Here is the caller graph for this function:

client_process_queued_bulk()

static void client_process_queued_bulk ( struct node_bulk_ctx *  ctx )

static

Definition at line 1182 of file node_bulk.c.

Here is the call graph for this function:

Here is the caller graph for this function:

client_process_unused_bulk()

static void client_process_unused_bulk ( struct node_bulk_ctx *  ctx )

static

Definition at line 988 of file node_bulk.c.

Here is the call graph for this function:

Here is the caller graph for this function:

client_server_index()

static size_t client_server_index ( struct node_bulk_ctx *  ctx, size_t  bs_index  )

static

Get server index for a given bs_index

Definition at line 930 of file node_bulk.c.

Here is the caller graph for this function:

client_transfer_start()

static void client_transfer_start ( struct node_bulk_ctx *  ctx, size_t  bs_index  )

static

Definition at line 959 of file node_bulk.c.

Here is the call graph for this function:

Here is the caller graph for this function:

m0_net_test_node_bulk_fini()

void m0_net_test_node_bulk_fini

(

void

)

Definition at line 1686 of file node_bulk.c.

Here is the caller graph for this function:

m0_net_test_node_bulk_init()

int m0_net_test_node_bulk_init

(

void

)

Definition at line 1680 of file node_bulk.c.

Here is the call graph for this function:

Here is the caller graph for this function:

M0_TL_DEFINE() [1/3]

M0_TL_DEFINE	(	bsb	,
		static	,
		struct buf_status_bulk
	)

M0_TL_DEFINE() [2/3]

M0_TL_DEFINE	(	ssb	,
		static	,
		struct server_status_bulk
	)

M0_TL_DEFINE() [3/3]

M0_TL_DEFINE	(	bsp	,
		static	,
		struct buf_status_ping
	)

M0_TL_DESCR_DEFINE() [1/3]

M0_TL_DESCR_DEFINE	(	bsb	,
		"buf_status_bulk"	,
		static	,
		struct buf_status_bulk	,
		bsb_tlink	,
		bsb_magic	,
		M0_NET_TEST_BSB_MAGIC	,
		M0_NET_TEST_BSB_HEAD_MAGIC
	)

M0_TL_DESCR_DEFINE() [2/3]

M0_TL_DESCR_DEFINE	(	ssb	,
		"server_status_bulk"	,
		static	,
		struct server_status_bulk	,
		ssb_tlink	,
		ssb_magic	,
		M0_NET_TEST_SSB_MAGIC	,
		M0_NET_TEST_SSB_HEAD_MAGIC
	)

M0_TL_DESCR_DEFINE() [3/3]

M0_TL_DESCR_DEFINE	(	bsp	,
		"buf_status_ping"	,
		static	,
		struct buf_status_ping	,
		bsp_tlink	,
		bsp_magic	,
		M0_NET_TEST_BSP_MAGIC	,
		M0_NET_TEST_BSP_HEAD_MAGIC
	)

net_buf_bulk_get()

static struct m0_net_buffer* net_buf_bulk_get ( struct node_bulk_ctx *  ctx, size_t  buf_bulk_index  )

static

Definition at line 598 of file node_bulk.c.

Here is the call graph for this function:

Here is the caller graph for this function:

net_bulk_worker_cb()

static void net_bulk_worker_cb ( struct node_bulk_ctx *  ctx, bool  pending  )

static

Definition at line 1250 of file node_bulk.c.

Here is the call graph for this function:

Here is the caller graph for this function:

node_bulk_buf_dequeue()

static void node_bulk_buf_dequeue ( struct node_bulk_ctx *  ctx )

static

Definition at line 1225 of file node_bulk.c.

Here is the call graph for this function:

Here is the caller graph for this function:

node_bulk_buf_unused()

static void node_bulk_buf_unused ( struct node_bulk_ctx *  ctx )

static

Definition at line 1211 of file node_bulk.c.

Here is the call graph for this function:

Here is the caller graph for this function:

node_bulk_bufs_unused_all()

static bool node_bulk_bufs_unused_all ( struct node_bulk_ctx *  ctx )

static

Definition at line 1240 of file node_bulk.c.

Here is the call graph for this function:

Here is the caller graph for this function:

node_bulk_cb()

static void node_bulk_cb ( struct m0_net_test_network_ctx *  net_ctx, const uint32_t  buf_index, enum m0_net_queue_type  q, const struct m0_net_buffer_event *  ev  )

static

Definition at line 846 of file node_bulk.c.

Here is the call graph for this function:

node_bulk_cb_client()

static void node_bulk_cb_client ( struct node_bulk_ctx *  ctx, size_t  buf_index, enum m0_net_queue_type  q, const struct m0_net_buffer_event *  ev  )

static

Definition at line 809 of file node_bulk.c.

Here is the call graph for this function:

Here is the caller graph for this function:

node_bulk_cb_server()

static void node_bulk_cb_server ( struct node_bulk_ctx *  ctx, size_t  buf_index, enum m0_net_queue_type  q, const struct m0_net_buffer_event *  ev  )

static

Definition at line 749 of file node_bulk.c.

Here is the call graph for this function:

Here is the caller graph for this function:

node_bulk_cmd_init()

static int node_bulk_cmd_init ( void *  ctx_, const struct m0_net_test_cmd *  cmd, struct m0_net_test_cmd *  reply  )

static

Definition at line 1519 of file node_bulk.c.

Here is the call graph for this function:

node_bulk_cmd_start()

static int node_bulk_cmd_start ( void *  ctx_, const struct m0_net_test_cmd *  cmd, struct m0_net_test_cmd *  reply  )

static

Todo:

copy-paste from node_ping.c. refactor it.

Todo:

copy-paste from node_ping.c

Definition at line 1574 of file node_bulk.c.

Here is the call graph for this function:

node_bulk_cmd_status()

static int node_bulk_cmd_status ( void *  ctx_, const struct m0_net_test_cmd *  cmd, struct m0_net_test_cmd *  reply  )

static

Definition at line 1641 of file node_bulk.c.

Here is the call graph for this function:

node_bulk_cmd_stop()

static int node_bulk_cmd_stop ( void *  ctx_, const struct m0_net_test_cmd *  cmd, struct m0_net_test_cmd *  reply  )

static

Todo:

copy-paste from node_ping.c. refactor it.

Definition at line 1610 of file node_bulk.c.

Here is the call graph for this function:

node_bulk_ctx_from_net_ctx()

static struct node_bulk_ctx* node_bulk_ctx_from_net_ctx ( struct m0_net_test_network_ctx *  net_ctx )

static

Definition at line 304 of file node_bulk.c.

Here is the caller graph for this function:

node_bulk_fini()

static void node_bulk_fini ( void *  ctx_ )

static

Definition at line 1508 of file node_bulk.c.

Here is the call graph for this function:

node_bulk_init()

static void* node_bulk_init ( struct m0_net_test_service *  svc )

static

Definition at line 1503 of file node_bulk.c.

Here is the call graph for this function:

node_bulk_initfini()

static void* node_bulk_initfini ( void *  ctx_, struct m0_net_test_service *  svc  )

static

Definition at line 1481 of file node_bulk.c.

Here is the call graph for this function:

Here is the caller graph for this function:

node_bulk_is_stopping()

static bool node_bulk_is_stopping ( struct node_bulk_ctx *  ctx )

static

Definition at line 841 of file node_bulk.c.

Here is the call graph for this function:

Here is the caller graph for this function:

node_bulk_server_transfer_start()

static m0_bcount_t node_bulk_server_transfer_start ( struct node_bulk_ctx *  ctx, size_t  buf_ping_index, m0_bcount_t  offset  )

static

Start network transfer. Take two network buffer descriptors from buf_ping_index in ctx->nbc_net with given offset in buffer.

Returns

number of bytes read.

0 if no free bulk buffer found or deserializing failed.

Definition at line 702 of file node_bulk.c.

Here is the call graph for this function:

Here is the caller graph for this function:

node_bulk_state_change()

static void node_bulk_state_change ( struct node_bulk_ctx *  ctx, size_t  bs_index, enum transfer_state  state  )

static

Definition at line 332 of file node_bulk.c.

Here is the call graph for this function:

Here is the caller graph for this function:

node_bulk_state_change_allowed()

static bool node_bulk_state_change_allowed ( enum transfer_state  from, enum transfer_state  to, const struct state_transition  allowed[], size_t  allowed_size  )

static

Definition at line 310 of file node_bulk.c.

Here is the caller graph for this function:

node_bulk_state_change_cb()

static void node_bulk_state_change_cb ( struct node_bulk_ctx *  ctx, size_t  bs_index, bool  success  )

static

Definition at line 485 of file node_bulk.c.

Here is the call graph for this function:

Here is the caller graph for this function:

node_bulk_state_check()

static void node_bulk_state_check ( const struct state_transition  state_list[], size_t  state_nr  )

static

Check for unique "from" state in the list

Definition at line 444 of file node_bulk.c.

Here is the caller graph for this function:

node_bulk_state_check_all()

static void node_bulk_state_check_all ( void  )

static

Check for unique "from" state in all state transitions

Definition at line 459 of file node_bulk.c.

Here is the call graph for this function:

Here is the caller graph for this function:

node_bulk_state_is_final()

static bool node_bulk_state_is_final ( enum transfer_state  state )

static

Definition at line 327 of file node_bulk.c.

Here is the caller graph for this function:

node_bulk_state_search()

static enum transfer_state node_bulk_state_search ( enum transfer_state  state, const struct state_transition  state_list[], size_t  state_nr  )

static

Definition at line 471 of file node_bulk.c.

Here is the caller graph for this function:

node_bulk_state_transition_auto()

void node_bulk_state_transition_auto	(	struct node_bulk_ctx *	ctx,
		size_t	bs_index
	)

Definition at line 521 of file node_bulk.c.

Here is the call graph for this function:

Here is the caller graph for this function:

node_bulk_state_transition_auto_all()

void node_bulk_state_transition_auto_all

(

struct node_bulk_ctx *

ctx

)

Definition at line 555 of file node_bulk.c.

Here is the call graph for this function:

Here is the caller graph for this function:

node_bulk_step()

static int node_bulk_step ( void *  ctx_ )

static

Definition at line 1514 of file node_bulk.c.

node_bulk_test_init_fini()

static int node_bulk_test_init_fini ( struct node_bulk_ctx *  ctx, const struct m0_net_test_cmd *  cmd  )

static

Definition at line 1331 of file node_bulk.c.

Here is the call graph for this function:

Here is the caller graph for this function:

node_bulk_tm_event_cb()

static void node_bulk_tm_event_cb ( const struct m0_net_tm_event *  ev )

static

Definition at line 294 of file node_bulk.c.

node_bulk_worker()

static void node_bulk_worker ( struct node_bulk_ctx *  ctx )

static

Definition at line 1278 of file node_bulk.c.

Here is the call graph for this function:

Here is the caller graph for this function:

sd_update()

static void sd_update ( struct node_bulk_ctx *  ctx, enum m0_net_test_nh_msg_type  type, enum m0_net_test_nh_msg_status  status, enum m0_net_test_nh_msg_direction  direction  )

static

Wrapper for m0_net_test_nh_sd_update() with smaller name

Definition at line 286 of file node_bulk.c.

Here is the call graph for this function:

Here is the caller graph for this function:

server_process_unused_ping()

static void server_process_unused_ping ( struct node_bulk_ctx *  ctx )

static

Definition at line 571 of file node_bulk.c.

Here is the call graph for this function:

Here is the caller graph for this function:

Variable Documentation

m0_net_test_node_bulk_ops

struct m0_net_test_service_ops m0_net_test_node_bulk_ops

Initial value:

= {
        .ntso_init           = node_bulk_init,
        .ntso_fini           = node_bulk_fini,
        .ntso_step           = node_bulk_step,
        .ntso_cmd_handler    = node_bulk_cmd_handler,
        .ntso_cmd_handler_nr = ARRAY_SIZE(node_bulk_cmd_handler),
}

Definition at line 1672 of file node_bulk.c.

nbst_nr

const size_t nbst_nr

Definition at line 430 of file node_bulk.c.

nbst_transition

const struct state_transition* nbst_transition

Definition at line 429 of file node_bulk.c.

node_bulk_buf_cb

struct m0_net_test_network_buffer_callbacks node_bulk_buf_cb

static

Initial value:

= {
        .ntnbc_cb = {
                [M0_NET_QT_MSG_RECV]            = node_bulk_cb,
                [M0_NET_QT_MSG_SEND]            = node_bulk_cb,
                [M0_NET_QT_PASSIVE_BULK_RECV]   = node_bulk_cb,
                [M0_NET_QT_PASSIVE_BULK_SEND]   = node_bulk_cb,
                [M0_NET_QT_ACTIVE_BULK_RECV]    = node_bulk_cb,
                [M0_NET_QT_ACTIVE_BULK_SEND]    = node_bulk_cb,
        }
}

Definition at line 918 of file node_bulk.c.

node_bulk_client_failure

const struct state_transition node_bulk_client_failure[]

static

Initial value:

= {
        { .sta_from = TS_BD_SENT,       .sta_to = TS_FAILED2 },
        { .sta_from = TS_CB_LEFT2,      .sta_to = TS_FAILED1 },
        { .sta_from = TS_CB_LEFT1,      .sta_to = TS_FAILED },
        { .sta_from = TS_FAILED2,       .sta_to = TS_FAILED1 },
        { .sta_from = TS_FAILED1,       .sta_to = TS_FAILED },
}

Definition at line 412 of file node_bulk.c.

node_bulk_client_success

const struct state_transition node_bulk_client_success[]

static

Initial value:

= {
        { .sta_from = TS_BD_SENT,       .sta_to = TS_CB_LEFT2 },
        { .sta_from = TS_CB_LEFT2,      .sta_to = TS_CB_LEFT1 },
        { .sta_from = TS_CB_LEFT1,      .sta_to = TS_TRANSFERRED },
        { .sta_from = TS_FAILED2,       .sta_to = TS_FAILED1 },
        { .sta_from = TS_FAILED1,       .sta_to = TS_FAILED },
}

Definition at line 405 of file node_bulk.c.

node_bulk_cmd_handler

struct m0_net_test_service_cmd_handler node_bulk_cmd_handler[]

static

Initial value:

= {
        {
                .ntsch_type    = M0_NET_TEST_CMD_INIT,
                .ntsch_handler = node_bulk_cmd_init,
        },
        {
                .ntsch_type    = M0_NET_TEST_CMD_START,
                .ntsch_handler = node_bulk_cmd_start,
        },
        {
                .ntsch_type    = M0_NET_TEST_CMD_STOP,
                .ntsch_handler = node_bulk_cmd_stop,
        },
        {
                .ntsch_type    = M0_NET_TEST_CMD_STATUS,
                .ntsch_handler = node_bulk_cmd_status,
        },
}

Definition at line 1653 of file node_bulk.c.

node_bulk_server_failure

const struct state_transition node_bulk_server_failure[]

static

Initial value:

= {
        { .sta_from = TS_RECEIVING,     .sta_to = TS_FAILED },
        { .sta_from = TS_SENDING,       .sta_to = TS_FAILED },
}

Definition at line 423 of file node_bulk.c.

node_bulk_server_success

const struct state_transition node_bulk_server_success[]

static

Initial value:

= {
        { .sta_from = TS_RECEIVING,     .sta_to = TS_SENDING },
        { .sta_from = TS_SENDING,       .sta_to = TS_TRANSFERRED },
}

Definition at line 419 of file node_bulk.c.

node_bulk_state_transitions

const { ... } node_bulk_state_transitions[]

Initial value:

= {
#define TRANSITION(name) 



        TRANSITION(node_bulk_client_success),
        TRANSITION(node_bulk_client_failure),
        TRANSITION(node_bulk_server_success),
        TRANSITION(node_bulk_server_failure),

}

node_bulk_tm_cb

const struct m0_net_tm_callbacks node_bulk_tm_cb

static

Initial value:

= {
        .ntc_event_cb = node_bulk_tm_event_cb
}

Definition at line 299 of file node_bulk.c.