sd_send_not.c File Reference

#include "lib/trace.h"
#include "lib/memory.h"
#include "lib/types.h"
#include "rpc/conn_pool_internal.h"
#include "rpc/packet_internal.h"
#include "rpc/rpc_machine_internal.h"
#include "ut/ut.h"
#include "fdmi/fdmi.h"
#include "fdmi/fops.h"
#include "fdmi/service.h"
#include "fdmi/source_dock_internal.h"
#include "fdmi/ut/sd_common.h"

Include dependency graph for sd_send_not.c:

Go to the source code of this file.

Macros
#define	M0_TRACE_SUBSYSTEM   M0_TRACE_SUBSYS_FDMI

Functions
static int	send_notif_packet_ready (struct m0_rpc_packet *p)
static int	filterc_send_notif_start (struct m0_filterc_ctx *ctx, struct m0_reqh *reqh)
static void	filterc_send_notif_stop (struct m0_filterc_ctx *ctx)
static int	filterc_send_notif_open (struct m0_filterc_ctx *ctx, enum m0_fdmi_rec_type_id rec_type_id, struct m0_filterc_iter *iter)
static int	filterc_send_notif_get_next (struct m0_filterc_iter *iter, struct m0_conf_fdmi_filter **out)
static void	filterc_send_notif_close (struct m0_filterc_iter *iter)
static int	test_fs_node_eval (struct m0_fdmi_src_rec *src_rec, struct m0_fdmi_flt_var_node *value_desc, struct m0_fdmi_flt_operand *value)
static int	test_fs_encode (struct m0_fdmi_src_rec *src_rec, struct m0_buf *buf)
static void	test_fs_get (struct m0_fdmi_src_rec *src_rec)
static void	test_fs_put (struct m0_fdmi_src_rec *src_rec)
static void	test_fs_begin (struct m0_fdmi_src_rec *src_rec)
static void	test_fs_end (struct m0_fdmi_src_rec *src_rec)
static struct m0_fdmi_src *	src_alloc ()
static void	check_fop_content (struct m0_rpc_item *item)
void	fdmi_sd_send_notif (void)

Variables
static struct m0_semaphore	g_sem1
static struct m0_semaphore	g_sem2
static struct m0_semaphore	g_sem3
static char	g_fdmi_data [] = "hello, FDMI"
static struct m0_fdmi_src_rec	g_src_rec
static struct test_rpc_env	g_rpc_env
static struct m0_rpc_packet *	g_sent_rpc_packet
static bool	inc_ref_passed
static int	dec_ref_count
static bool	first_filter
static int	refcount
static const struct m0_fid	g_fid = M0_FID_INIT(0xFA11, 0x11AF)
static const struct m0_rpc_frm_ops	send_notif_frm_ops
static struct m0_conf_fdmi_filter	g_conf_filter
static char *	g_var_str
const struct m0_filterc_ops	filterc_send_notif_ops

Macro Definition Documentation

M0_TRACE_SUBSYSTEM

#define M0_TRACE_SUBSYSTEM   M0_TRACE_SUBSYS_FDMI

Definition at line 23 of file sd_send_not.c.

Function Documentation

check_fop_content()

static void check_fop_content ( struct m0_rpc_item *  item )

static

Definition at line 222 of file sd_send_not.c.

Here is the call graph for this function:

Here is the caller graph for this function:

fdmi_sd_send_notif()

void fdmi_sd_send_notif

(

void

)

Definition at line 246 of file sd_send_not.c.

Here is the call graph for this function:

filterc_send_notif_close()

static void filterc_send_notif_close ( struct m0_filterc_iter *  iter )

static

Definition at line 137 of file sd_send_not.c.

Here is the call graph for this function:

filterc_send_notif_get_next()

static int filterc_send_notif_get_next ( struct m0_filterc_iter *  iter, struct m0_conf_fdmi_filter **  out  )

static

Definition at line 104 of file sd_send_not.c.

Here is the call graph for this function:

filterc_send_notif_open()

static int filterc_send_notif_open ( struct m0_filterc_ctx *  ctx, enum m0_fdmi_rec_type_id  rec_type_id, struct m0_filterc_iter *  iter  )

static

Definition at line 97 of file sd_send_not.c.

filterc_send_notif_start()

static int filterc_send_notif_start ( struct m0_filterc_ctx *  ctx, struct m0_reqh *  reqh  )

static

Definition at line 87 of file sd_send_not.c.

filterc_send_notif_stop()

static void filterc_send_notif_stop ( struct m0_filterc_ctx *  ctx )

static

Definition at line 93 of file sd_send_not.c.

send_notif_packet_ready()

static int send_notif_packet_ready ( struct m0_rpc_packet *  p )

static

Definition at line 237 of file sd_send_not.c.

Here is the call graph for this function:

src_alloc()

static struct m0_fdmi_src* src_alloc ( )

static

Definition at line 205 of file sd_send_not.c.

Here is the call graph for this function:

Here is the caller graph for this function:

test_fs_begin()

static void test_fs_begin ( struct m0_fdmi_src_rec *  src_rec )

static

Overwrite source dock FOM client connection to check FOP content.

Definition at line 185 of file sd_send_not.c.

Here is the call graph for this function:

Here is the caller graph for this function:

test_fs_encode()

static int test_fs_encode ( struct m0_fdmi_src_rec *  src_rec, struct m0_buf *  buf  )

static

Definition at line 156 of file sd_send_not.c.

Here is the caller graph for this function:

test_fs_end()

static void test_fs_end ( struct m0_fdmi_src_rec *  src_rec )

static

Definition at line 197 of file sd_send_not.c.

Here is the call graph for this function:

Here is the caller graph for this function:

test_fs_get()

static void test_fs_get ( struct m0_fdmi_src_rec *  src_rec )

static

Definition at line 167 of file sd_send_not.c.

Here is the caller graph for this function:

test_fs_node_eval()

static int test_fs_node_eval ( struct m0_fdmi_src_rec *  src_rec, struct m0_fdmi_flt_var_node *  value_desc, struct m0_fdmi_flt_operand *  value  )

static

Definition at line 143 of file sd_send_not.c.

Here is the call graph for this function:

Here is the caller graph for this function:

test_fs_put()

static void test_fs_put ( struct m0_fdmi_src_rec *  src_rec )

static

Definition at line 175 of file sd_send_not.c.

Here is the call graph for this function:

Here is the caller graph for this function:

Variable Documentation

dec_ref_count

int dec_ref_count

static

Definition at line 48 of file sd_send_not.c.

filterc_send_notif_ops

const struct m0_filterc_ops filterc_send_notif_ops

Initial value:

= {
        .fco_start    = filterc_send_notif_start,
        .fco_stop     = filterc_send_notif_stop,
        .fco_open     = filterc_send_notif_open,
        .fco_get_next = filterc_send_notif_get_next,
        .fco_close    = filterc_send_notif_close
}

Definition at line 79 of file sd_send_not.c.

first_filter

bool first_filter

static

Definition at line 49 of file sd_send_not.c.

g_conf_filter

struct m0_conf_fdmi_filter g_conf_filter

static

Definition at line 62 of file sd_send_not.c.

g_fdmi_data

char g_fdmi_data[] = "hello, FDMI"

static

Definition at line 42 of file sd_send_not.c.

g_fid

const struct m0_fid g_fid = M0_FID_INIT(0xFA11, 0x11AF)

static

Definition at line 52 of file sd_send_not.c.

g_rpc_env

struct test_rpc_env g_rpc_env

static

Definition at line 44 of file sd_send_not.c.

g_sem1

struct m0_semaphore g_sem1

static

Definition at line 39 of file sd_send_not.c.

g_sem2

struct m0_semaphore g_sem2

static

Definition at line 40 of file sd_send_not.c.

g_sem3

struct m0_semaphore g_sem3

static

Definition at line 41 of file sd_send_not.c.

g_sent_rpc_packet

struct m0_rpc_packet* g_sent_rpc_packet

static

Definition at line 45 of file sd_send_not.c.

g_src_rec

struct m0_fdmi_src_rec g_src_rec

static

Definition at line 43 of file sd_send_not.c.

g_var_str

char* g_var_str

static

Definition at line 63 of file sd_send_not.c.

inc_ref_passed

bool inc_ref_passed

static

Definition at line 47 of file sd_send_not.c.

refcount

int refcount

static

Definition at line 50 of file sd_send_not.c.

send_notif_frm_ops

const struct m0_rpc_frm_ops send_notif_frm_ops

static

Initial value:

= {
        .fo_packet_ready = send_notif_packet_ready
}

Definition at line 56 of file sd_send_not.c.