bulk_if.c File Reference

#include "lib/types.h"
#include "lib/arith.h"
#include "lib/assert.h"
#include "lib/errno.h"
#include "lib/misc.h"
#include "lib/memory.h"
#include "lib/mutex.h"
#include "ut/ut.h"
#include "net/net_internal.h"
#include "net/ut/tm_provision_ut.c"

Include dependency graph for bulk_if.c:

Go to the source code of this file.

Data Structures
struct	ut_ep
struct	ut_tm_pvt

Macros
#define	KPRN(fmt, ...)
#define	DELAY_MS(ms)   m0_nanosleep(m0_time(0, (ms) * 1000000ULL), NULL)
#define	UT_CB_CALL(_qt)   ut_buffer_event_callback(ev, _qt, true)
#define	QS(x)   KPRN("\t" #x "=%" PRId64 "\n", qs[i].nqs_##x)
#define	QS2(x)   KPRN("\t" #x "=%" PRId64 " [%" PRId64 "]\n", qs[i].nqs_##x, x[i])

Enumerations
enum	{ UT_MAX_BUF_SIZE = 8192, UT_MAX_BUF_SEGMENT_SIZE = 2048, UT_MAX_BUF_SEGMENTS = 4, UT_MAX_BUF_DESC_SIZE = 32 }

Functions
static void	make_desc (struct m0_net_buf_desc *desc)
static int	net_bulk_if_init (void)
static int	ut_dom_init (const struct m0_net_xprt *xprt, struct m0_net_domain *dom)
static void	ut_dom_fini (struct m0_net_domain *dom)
static m0_bcount_t	ut_get_max_buffer_size (const struct m0_net_domain *dom)
static m0_bcount_t	ut_get_max_buffer_segment_size (const struct m0_net_domain *dom)
static int32_t	ut_get_max_buffer_segments (const struct m0_net_domain *dom)
static m0_bcount_t	ut_get_max_buffer_desc_size (const struct m0_net_domain *dom)
static void	ut_end_point_release (struct m0_ref *ref)
static int	ut_end_point_create (struct m0_net_end_point **epp, struct m0_net_transfer_mc *tm, const char *addr)
static int	ut_buf_register (struct m0_net_buffer *nb)
static void	ut_buf_deregister (struct m0_net_buffer *nb)
static int	ut_buf_add (struct m0_net_buffer *nb)
static void	ut_post_del_thread (struct m0_net_buffer *nb)
static void	ut_buf_del (struct m0_net_buffer *nb)
static int	ut_tm_init (struct m0_net_transfer_mc *tm)
static void	ut_tm_fini (struct m0_net_transfer_mc *tm)
static void	ut_post_tm_started_ev_thread (struct m0_net_end_point *ep)
static void	ut_post_state_change_ev_thread (int n)
static int	ut_tm_start (struct m0_net_transfer_mc *tm, const char *addr)
static int	ut_tm_stop (struct m0_net_transfer_mc *tm, bool cancel)
static int	ut_tm_confine (struct m0_net_transfer_mc *tm, const struct m0_bitmap *processors)
static int	ut_bev_deliver_sync (struct m0_net_transfer_mc *tm)
static void	ut_bev_deliver_all (struct m0_net_transfer_mc *tm)
static bool	ut_bev_pending (struct m0_net_transfer_mc *tm)
static void	ut_bev_notify (struct m0_net_transfer_mc *tm, struct m0_chan *chan)
static struct m0_net_buffer *	allocate_buffers (m0_bcount_t buf_size, m0_bcount_t buf_seg_size, int32_t buf_segs)
static void	ut_buffer_event_callback (const struct m0_net_buffer_event *ev, enum m0_net_queue_type qt, bool queue_check)
static void	ut_msg_recv_cb (const struct m0_net_buffer_event *ev)
static void	ut_msg_send_cb (const struct m0_net_buffer_event *ev)
static void	ut_passive_bulk_recv_cb (const struct m0_net_buffer_event *ev)
static void	ut_passive_bulk_send_cb (const struct m0_net_buffer_event *ev)
static void	ut_active_bulk_recv_cb (const struct m0_net_buffer_event *ev)
static void	ut_active_bulk_send_cb (const struct m0_net_buffer_event *ev)
static void	ut_multi_use_cb (const struct m0_net_buffer_event *ev)
void	ut_tm_event_cb (const struct m0_net_tm_event *ev)
static void	test_net_bulk_if (void)

Variables
static struct m0_net_domain	utdom
static struct m0_net_transfer_mc	ut_tm
static struct m0_net_transfer_mc *	ut_evt_tm = &ut_tm
struct {
int   num
}	ut_xprt_pvt
static bool	ut_dom_init_called
static bool	ut_dom_fini_called
static bool	ut_get_max_buffer_segment_size_called
static bool	ut_get_max_buffer_size_called
static bool	ut_get_max_buffer_segments_called
static bool	ut_end_point_create_called
static bool	ut_end_point_release_called
static bool	ut_tm_confine_called
static const struct m0_bitmap *	ut_tm_confine_bm
static bool	ut_buf_register_called
static bool	ut_buf_deregister_called
static bool	ut_buf_del_called
static bool	ut_buf_add_called
static bool	ut_tm_init_called
static bool	ut_tm_fini_called
static bool	ut_tm_start_called
static bool	ut_tm_stop_called
static bool	ut_bev_deliver_sync_called
static bool	ut_bev_deliver_all_called
static bool	ut_bev_pending_called
static int	ut_bev_pending_last
static bool	ut_multi_use_expect_queued
static struct m0_net_buffer *	ut_multi_use_got_buf
static bool	ut_bev_notify_called
static int	ut_tm_event_cb_calls
static struct m0_net_end_point *	ut_last_ep_released
struct m0_thread	ut_del_thread
static struct m0_thread	ut_tm_thread
static struct m0_net_xprt_ops	ut_xprt_ops
static struct m0_net_xprt	ut_xprt
static int	ut_cb_calls [M0_NET_QT_NR]
static uint64_t	num_adds [M0_NET_QT_NR]
static uint64_t	num_dels [M0_NET_QT_NR]
static m0_bcount_t	total_bytes [M0_NET_QT_NR]
static m0_bcount_t	max_bytes [M0_NET_QT_NR]
struct m0_net_tm_callbacks	ut_tm_cb
struct m0_net_buffer_callbacks	ut_buf_cb
struct m0_net_buffer_callbacks	ut_buf_multi_use_cb
struct m0_ut_suite	m0_net_bulk_if_ut

Macro Definition Documentation

DELAY_MS

#define DELAY_MS

(

ms

)

m0_nanosleep(m0_time(0, (ms) * 1000000ULL), NULL)

Definition at line 46 of file bulk_if.c.

KPRN

#define KPRN	(		fmt,
			...
	)

Definition at line 43 of file bulk_if.c.

QS

#define QS

(

x

)

KPRN("\t" #x "=%" PRId64 "\n", qs[i].nqs_##x)

QS2

#define QS2

(

x

)

KPRN("\t" #x "=%" PRId64 " [%" PRId64 "]\n", qs[i].nqs_##x, x[i])

UT_CB_CALL

#define UT_CB_CALL

(

_qt

)

ut_buffer_event_callback(ev, _qt, true)

Definition at line 543 of file bulk_if.c.

Enumeration Type Documentation

anonymous enum

anonymous enum

Enumerator
UT_MAX_BUF_SIZE
UT_MAX_BUF_SEGMENT_SIZE
UT_MAX_BUF_SEGMENTS
UT_MAX_BUF_DESC_SIZE

Definition at line 138 of file bulk_if.c.

Function Documentation

allocate_buffers()

static struct m0_net_buffer* allocate_buffers ( m0_bcount_t  buf_size, m0_bcount_t  buf_seg_size, int32_t  buf_segs  )

static

Definition at line 455 of file bulk_if.c.

Here is the call graph for this function:

Here is the caller graph for this function:

make_desc()

static void make_desc ( struct m0_net_buf_desc *  desc )

static

Definition at line 486 of file bulk_if.c.

Here is the call graph for this function:

Here is the caller graph for this function:

net_bulk_if_init()

static int net_bulk_if_init ( void  )

static

Definition at line 83 of file bulk_if.c.

test_net_bulk_if()

static void test_net_bulk_if ( void  )

static

Definition at line 626 of file bulk_if.c.

Here is the call graph for this function:

ut_active_bulk_recv_cb()

static void ut_active_bulk_recv_cb ( const struct m0_net_buffer_event *  ev )

static

Definition at line 564 of file bulk_if.c.

ut_active_bulk_send_cb()

static void ut_active_bulk_send_cb ( const struct m0_net_buffer_event *  ev )

static

Definition at line 569 of file bulk_if.c.

ut_bev_deliver_all()

static void ut_bev_deliver_all ( struct m0_net_transfer_mc *  tm )

static

Definition at line 402 of file bulk_if.c.

Here is the call graph for this function:

ut_bev_deliver_sync()

static int ut_bev_deliver_sync ( struct m0_net_transfer_mc *  tm )

static

Definition at line 395 of file bulk_if.c.

Here is the call graph for this function:

Here is the caller graph for this function:

ut_bev_notify()

static void ut_bev_notify ( struct m0_net_transfer_mc *  tm, struct m0_chan *  chan  )

static

Definition at line 417 of file bulk_if.c.

Here is the call graph for this function:

ut_bev_pending()

static bool ut_bev_pending ( struct m0_net_transfer_mc *  tm )

static

Definition at line 409 of file bulk_if.c.

Here is the call graph for this function:

ut_buf_add()

static int ut_buf_add ( struct m0_net_buffer *  nb )

static

Definition at line 240 of file bulk_if.c.

Here is the call graph for this function:

ut_buf_del()

static void ut_buf_del ( struct m0_net_buffer *  nb )

static

Definition at line 273 of file bulk_if.c.

Here is the call graph for this function:

ut_buf_deregister()

static void ut_buf_deregister ( struct m0_net_buffer *  nb )

static

Definition at line 233 of file bulk_if.c.

Here is the call graph for this function:

ut_buf_register()

static int ut_buf_register ( struct m0_net_buffer *  nb )

static

Definition at line 226 of file bulk_if.c.

Here is the call graph for this function:

ut_buffer_event_callback()

static void ut_buffer_event_callback ( const struct m0_net_buffer_event *  ev, enum m0_net_queue_type  qt, bool  queue_check  )

static

Definition at line 502 of file bulk_if.c.

Here is the call graph for this function:

Here is the caller graph for this function:

ut_dom_fini()

static void ut_dom_fini ( struct m0_net_domain *  dom )

static

Definition at line 130 of file bulk_if.c.

Here is the call graph for this function:

ut_dom_init()

static int ut_dom_init ( const struct m0_net_xprt *  xprt, struct m0_net_domain *  dom  )

static

Definition at line 114 of file bulk_if.c.

Here is the call graph for this function:

ut_end_point_create()

static int ut_end_point_create ( struct m0_net_end_point **  epp, struct m0_net_transfer_mc *  tm, const char *  addr  )

static

Definition at line 191 of file bulk_if.c.

Here is the call graph for this function:

ut_end_point_release()

static void ut_end_point_release ( struct m0_ref *  ref )

static

Definition at line 175 of file bulk_if.c.

Here is the call graph for this function:

Here is the caller graph for this function:

ut_get_max_buffer_desc_size()

static m0_bcount_t ut_get_max_buffer_desc_size ( const struct m0_net_domain *  dom )

static

Definition at line 164 of file bulk_if.c.

ut_get_max_buffer_segment_size()

static m0_bcount_t ut_get_max_buffer_segment_size ( const struct m0_net_domain *  dom )

static

Definition at line 151 of file bulk_if.c.

ut_get_max_buffer_segments()

static int32_t ut_get_max_buffer_segments ( const struct m0_net_domain *  dom )

static

Definition at line 158 of file bulk_if.c.

ut_get_max_buffer_size()

static m0_bcount_t ut_get_max_buffer_size ( const struct m0_net_domain *  dom )

static

Definition at line 145 of file bulk_if.c.

ut_msg_recv_cb()

static void ut_msg_recv_cb ( const struct m0_net_buffer_event *  ev )

static

Definition at line 544 of file bulk_if.c.

ut_msg_send_cb()

static void ut_msg_send_cb ( const struct m0_net_buffer_event *  ev )

static

Definition at line 549 of file bulk_if.c.

ut_multi_use_cb()

static void ut_multi_use_cb ( const struct m0_net_buffer_event *  ev )

static

Definition at line 574 of file bulk_if.c.

Here is the call graph for this function:

ut_passive_bulk_recv_cb()

static void ut_passive_bulk_recv_cb ( const struct m0_net_buffer_event *  ev )

static

Definition at line 554 of file bulk_if.c.

ut_passive_bulk_send_cb()

static void ut_passive_bulk_send_cb ( const struct m0_net_buffer_event *  ev )

static

Definition at line 559 of file bulk_if.c.

ut_post_del_thread()

static void ut_post_del_thread ( struct m0_net_buffer *  nb )

static

Definition at line 257 of file bulk_if.c.

Here is the call graph for this function:

Here is the caller graph for this function:

ut_post_state_change_ev_thread()

static void ut_post_state_change_ev_thread ( int  n )

static

Definition at line 329 of file bulk_if.c.

Here is the call graph for this function:

Here is the caller graph for this function:

ut_post_tm_started_ev_thread()

static void ut_post_tm_started_ev_thread ( struct m0_net_end_point *  ep )

static

Definition at line 313 of file bulk_if.c.

Here is the call graph for this function:

Here is the caller graph for this function:

ut_tm_confine()

static int ut_tm_confine ( struct m0_net_transfer_mc *  tm, const struct m0_bitmap *  processors  )

static

Definition at line 386 of file bulk_if.c.

Here is the call graph for this function:

Here is the caller graph for this function:

ut_tm_event_cb()

void ut_tm_event_cb

(

const struct m0_net_tm_event *

ev

)

Definition at line 586 of file bulk_if.c.

ut_tm_fini()

static void ut_tm_fini ( struct m0_net_transfer_mc *  tm )

static

Definition at line 301 of file bulk_if.c.

Here is the call graph for this function:

ut_tm_init()

static int ut_tm_init ( struct m0_net_transfer_mc *  tm )

static

Definition at line 290 of file bulk_if.c.

Here is the call graph for this function:

ut_tm_start()

static int ut_tm_start ( struct m0_net_transfer_mc *  tm, const char *  addr  )

static

Definition at line 344 of file bulk_if.c.

Here is the call graph for this function:

ut_tm_stop()

static int ut_tm_stop ( struct m0_net_transfer_mc *  tm, bool  cancel  )

static

Definition at line 371 of file bulk_if.c.

Here is the call graph for this function:

Here is the caller graph for this function:

Variable Documentation

m0_net_bulk_if_ut

struct m0_ut_suite m0_net_bulk_if_ut

Initial value:

= {
        .ts_name = "net-bulk-if",
        .ts_init = net_bulk_if_init,
        .ts_fini = NULL,
        .ts_tests = {
                { "net_bulk_if", test_net_bulk_if },
                { NULL, NULL }
        }
}

Definition at line 1229 of file bulk_if.c.

max_bytes

m0_bcount_t max_bytes[M0_NET_QT_NR]

static

Definition at line 500 of file bulk_if.c.

num

int num

Definition at line 54 of file bulk_if.c.

num_adds

uint64_t num_adds[M0_NET_QT_NR]

static

Definition at line 497 of file bulk_if.c.

num_dels

uint64_t num_dels[M0_NET_QT_NR]

static

Definition at line 498 of file bulk_if.c.

total_bytes

m0_bcount_t total_bytes[M0_NET_QT_NR]

static

Definition at line 499 of file bulk_if.c.

ut_bev_deliver_all_called

bool ut_bev_deliver_all_called

static

Definition at line 75 of file bulk_if.c.

ut_bev_deliver_sync_called

bool ut_bev_deliver_sync_called

static

Definition at line 74 of file bulk_if.c.

ut_bev_notify_called

bool ut_bev_notify_called

static

Definition at line 80 of file bulk_if.c.

ut_bev_pending_called

bool ut_bev_pending_called

static

Definition at line 76 of file bulk_if.c.

ut_bev_pending_last

int ut_bev_pending_last

static

Definition at line 77 of file bulk_if.c.

ut_buf_add_called

bool ut_buf_add_called

static

Definition at line 69 of file bulk_if.c.

ut_buf_cb

struct m0_net_buffer_callbacks ut_buf_cb

Initial value:

= {
        .nbc_cb = {
                [M0_NET_QT_MSG_RECV]          = ut_msg_recv_cb,
                [M0_NET_QT_MSG_SEND]          = ut_msg_send_cb,
                [M0_NET_QT_PASSIVE_BULK_RECV] = ut_passive_bulk_recv_cb,
                [M0_NET_QT_PASSIVE_BULK_SEND] = ut_passive_bulk_send_cb,
                [M0_NET_QT_ACTIVE_BULK_RECV]  = ut_active_bulk_recv_cb,
                [M0_NET_QT_ACTIVE_BULK_SEND]  = ut_active_bulk_send_cb
        },
}

Definition at line 596 of file bulk_if.c.

ut_buf_del_called

bool ut_buf_del_called

static

Definition at line 68 of file bulk_if.c.

ut_buf_deregister_called

bool ut_buf_deregister_called

static

Definition at line 67 of file bulk_if.c.

ut_buf_multi_use_cb

struct m0_net_buffer_callbacks ut_buf_multi_use_cb

Initial value:

= {
        .nbc_cb = {
                [M0_NET_QT_MSG_RECV]          = ut_multi_use_cb,
                [M0_NET_QT_MSG_SEND]          = ut_multi_use_cb,
                [M0_NET_QT_PASSIVE_BULK_RECV] = ut_multi_use_cb,
                [M0_NET_QT_PASSIVE_BULK_SEND] = ut_multi_use_cb,
                [M0_NET_QT_ACTIVE_BULK_RECV]  = ut_multi_use_cb,
                [M0_NET_QT_ACTIVE_BULK_SEND]  = ut_multi_use_cb,
        },
}

Definition at line 607 of file bulk_if.c.

ut_buf_register_called

bool ut_buf_register_called

static

Definition at line 66 of file bulk_if.c.

ut_cb_calls

int ut_cb_calls[M0_NET_QT_NR]

static

Definition at line 496 of file bulk_if.c.

ut_del_thread

struct m0_thread ut_del_thread

Definition at line 272 of file bulk_if.c.

ut_dom_fini_called

bool ut_dom_fini_called

static

Definition at line 58 of file bulk_if.c.

ut_dom_init_called

bool ut_dom_init_called

static

Definition at line 57 of file bulk_if.c.

ut_end_point_create_called

bool ut_end_point_create_called

static

Definition at line 62 of file bulk_if.c.

ut_end_point_release_called

bool ut_end_point_release_called

static

Definition at line 63 of file bulk_if.c.

ut_evt_tm

struct m0_net_transfer_mc* ut_evt_tm = &ut_tm

static

Definition at line 36 of file bulk_if.c.

ut_get_max_buffer_segment_size_called

bool ut_get_max_buffer_segment_size_called

static

Definition at line 59 of file bulk_if.c.

ut_get_max_buffer_segments_called

bool ut_get_max_buffer_segments_called

static

Definition at line 61 of file bulk_if.c.

ut_get_max_buffer_size_called

bool ut_get_max_buffer_size_called

static

Definition at line 60 of file bulk_if.c.

ut_last_ep_released

struct m0_net_end_point* ut_last_ep_released

static

Definition at line 174 of file bulk_if.c.

ut_multi_use_expect_queued

bool ut_multi_use_expect_queued

static

Definition at line 78 of file bulk_if.c.

ut_multi_use_got_buf

struct m0_net_buffer* ut_multi_use_got_buf

static

Definition at line 79 of file bulk_if.c.

ut_tm

static struct m0_net_transfer_mc ut_tm

static

Initial value:

= {
        .ntm_callbacks = &ut_tm_cb,
        .ntm_state = M0_NET_TM_UNDEFINED
}

Definition at line 35 of file bulk_if.c.

ut_tm_cb

struct m0_net_tm_callbacks ut_tm_cb

Initial value:

= {
        .ntc_event_cb = ut_tm_event_cb
}

Definition at line 592 of file bulk_if.c.

ut_tm_confine_bm

const struct m0_bitmap* ut_tm_confine_bm

static

Definition at line 65 of file bulk_if.c.

ut_tm_confine_called

bool ut_tm_confine_called

static

Definition at line 64 of file bulk_if.c.

ut_tm_event_cb_calls

int ut_tm_event_cb_calls

static

Definition at line 81 of file bulk_if.c.

ut_tm_fini_called

bool ut_tm_fini_called

static

Definition at line 71 of file bulk_if.c.

ut_tm_init_called

bool ut_tm_init_called

static

Definition at line 70 of file bulk_if.c.

ut_tm_start_called

bool ut_tm_start_called

static

Definition at line 72 of file bulk_if.c.

ut_tm_stop_called

bool ut_tm_stop_called

static

Definition at line 73 of file bulk_if.c.

ut_tm_thread

struct m0_thread ut_tm_thread

static

Definition at line 312 of file bulk_if.c.

ut_xprt

struct m0_net_xprt ut_xprt

static

Initial value:

= {
        .nx_name = "ut/bulk",
        .nx_ops  = &ut_xprt_ops
}

Definition at line 448 of file bulk_if.c.

ut_xprt_ops

struct m0_net_xprt_ops ut_xprt_ops

static

Initial value:

= {
        .xo_dom_init                    = ut_dom_init,
        .xo_dom_fini                    = ut_dom_fini,
        .xo_get_max_buffer_size         = ut_get_max_buffer_size,
        .xo_get_max_buffer_segment_size = ut_get_max_buffer_segment_size,
        .xo_get_max_buffer_segments     = ut_get_max_buffer_segments,
        .xo_get_max_buffer_desc_size    = ut_get_max_buffer_desc_size,
        .xo_end_point_create            = ut_end_point_create,
        .xo_buf_register                = ut_buf_register,
        .xo_buf_deregister              = ut_buf_deregister,
        .xo_buf_add                     = ut_buf_add,
        .xo_buf_del                     = ut_buf_del,
        .xo_tm_init                     = ut_tm_init,
        .xo_tm_fini                     = ut_tm_fini,
        .xo_tm_start                    = ut_tm_start,
        .xo_tm_stop                     = ut_tm_stop,
        
        
        .xo_bev_deliver_all             = ut_bev_deliver_all,
        .xo_bev_pending                 = ut_bev_pending,
        .xo_bev_notify                  = ut_bev_notify
}

Definition at line 425 of file bulk_if.c.

ut_xprt_pvt

struct { ... } ut_xprt_pvt

utdom

struct m0_net_domain utdom

static

Definition at line 34 of file bulk_if.c.