Motr  M0
klnet_ut.c File Reference
#include <linux/version.h>
#include <linux/module.h>
#include <linux/proc_fs.h>
#include "net/lnet/ut/lnet_drv_ut.h"
#include "net/lnet/linux_kernel/klnet_core.h"
Include dependency graph for klnet_ut.c:

Go to the source code of this file.

Macros

#define UT_BUFVEC_ALLOC(v, n)
 
#define UT_BUFVEC_FREE(v)
 
#define EXP_SEG_COUNT(ptr, segsize, expcount)
 
#define TEST_HDR_DATA_ENCODE(_p, _t)
 
#define KEB(b)
 
#define USER_HELPER_WAIT(id)
 

Enumerations

enum  { UT_PROC_WRITE_SIZE = 8, UT_SYNC_DELAY_SEC = 5 }
 
enum  { UT_KMSG_OPS = 4 }
 

Functions

static ssize_t read_lnet_ut (struct file *file, char __user *buffer, size_t len, loff_t *offset)
 
static ssize_t write_lnet_ut (struct file *file, const char __user *buffer, size_t count, loff_t *offset)
 
static int open_lnet_ut (struct inode *inode, struct file *file)
 
static int close_lnet_ut (struct inode *inode, struct file *file)
 
static int ktest_lnet_init (void)
 
static void ktest_lnet_fini (void)
 
static bool ut_bufvec_alloc (struct m0_bufvec *bv, size_t n)
 
static void ktest_buf_shape (void)
 
static void ktest_buf_reg (void)
 
static void ktest_core_ep_addr (void)
 
static void ktest_enc_dec (void)
 
static int ut_ktest_msg_LNetMDAttach (struct nlx_kcore_transfer_mc *kctm, struct nlx_core_buffer *lcbuf, struct nlx_kcore_buffer *kcb, lnet_md_t *umd)
 
static int ut_ktest_msg_LNetPut (struct nlx_kcore_transfer_mc *kctm, struct nlx_core_buffer *lcbuf, struct nlx_kcore_buffer *kcb, lnet_md_t *umd)
 
int ut_ktest_msg_buf_event_wait (struct nlx_core_domain *lcdom, struct nlx_core_transfer_mc *lctm, m0_time_t timeout)
 
static int ut_ktest_msg_ep_create (struct m0_net_end_point **epp, struct m0_net_transfer_mc *tm, const struct nlx_core_ep_addr *cepa)
 
static void ut_ktest_msg_put_event (struct nlx_kcore_buffer *kcb, unsigned mlength, unsigned offset, int status, int unlinked, struct nlx_core_ep_addr *addr)
 
static void ut_ktest_msg_send_event (struct nlx_kcore_buffer *kcb, unsigned mlength, int status)
 
static void ut_ktest_ack_event (struct nlx_kcore_buffer *kcb)
 
static lnet_kiov_t * ut_ktest_kiov_mem_dup (const lnet_kiov_t *kiov, size_t len)
 
static void ut_ktest_kiov_mem_free (lnet_kiov_t *kiov)
 
static bool ut_ktest_kiov_eq (const lnet_kiov_t *k1, const lnet_kiov_t *k2, size_t len)
 
static unsigned ut_ktest_kiov_count (const lnet_kiov_t *k, size_t len)
 
static void ktest_msg_body (struct ut_data *td)
 
static void ktest_msg (void)
 
static int ut_ktest_bulk_LNetMDAttach (struct nlx_kcore_transfer_mc *kctm, struct nlx_core_buffer *lcbuf, struct nlx_kcore_buffer *kcb, lnet_md_t *umd)
 
static int ut_ktest_bulk_LNetGet (struct nlx_kcore_transfer_mc *kctm, struct nlx_core_buffer *lcbuf, struct nlx_kcore_buffer *kcb, lnet_md_t *umd)
 
static int ut_ktest_bulk_LNetPut (struct nlx_kcore_transfer_mc *kctm, struct nlx_core_buffer *lcbuf, struct nlx_kcore_buffer *kcb, lnet_md_t *umd)
 
static void ut_ktest_bulk_put_event (struct nlx_kcore_buffer *kcb, unsigned mlength, int status)
 
static void ut_ktest_bulk_get_event (struct nlx_kcore_buffer *kcb, unsigned mlength, int status)
 
static void ut_ktest_bulk_send_event (struct nlx_kcore_buffer *kcb, unsigned mlength, int status, int unlinked, int threshold)
 
static void ut_ktest_bulk_reply_event (struct nlx_kcore_buffer *kcb, unsigned mlength, int status, int unlinked, int threshold)
 
static void ut_ktest_bulk_unlink_event (struct nlx_kcore_buffer *kcb)
 
static void ktest_bulk_body (struct ut_data *td)
 
static void ktest_bulk (void)
 
static int ut_kcore_core_dom_init (struct nlx_kcore_domain *kd, struct nlx_core_domain *cd)
 
static void ut_kcore_core_dom_fini (struct nlx_kcore_domain *kd, struct nlx_core_domain *cd)
 
static int ut_kcore_tm_start (struct nlx_kcore_domain *kd, struct nlx_core_transfer_mc *ctm, struct nlx_kcore_transfer_mc *ktm)
 
static void ut_kcore_tm_stop (struct nlx_core_transfer_mc *ctm, struct nlx_kcore_transfer_mc *ktm)
 
static int ut_dev_open (struct inode *inode, struct file *file)
 
int ut_dev_close (struct inode *inode, struct file *file)
 
bool user_helper_wait (int id)
 
static void ktest_dev (void)
 

Variables

static struct proc_dir_entry * proc_lnet_ut
 
static struct m0_mutex ktest_mutex
 
static struct m0_cond ktest_cond
 
static struct m0_semaphore ktest_sem
 
static int ktest_id
 
static bool ktest_user_failed
 
static bool ktest_done
 
static struct file_operations proc_lnet_fops
 
static bool ut_ktest_msg_LNetMDAttach_called
 
static bool ut_ktest_msg_LNetPut_called
 
static struct m0_net_end_pointut_ktest_msg_LNetPut_ep
 
static struct m0_atomic64 ut_ktest_msg_buf_event_wait_stall
 
static struct m0_chanut_ktest_msg_buf_event_wait_delay_chan
 
static struct m0_atomic64 ut_ktest_msg_ep_create_fail
 
static struct m0_atomic64 ut_ktest_bulk_fake_LNetMDAttach
 
static bool ut_ktest_bulk_LNetMDAttach_called
 
static bool ut_ktest_bulk_LNetGet_called
 
static bool ut_ktest_bulk_LNetPut_called
 
static int ut_dev_opens
 
static int ut_dev_closes
 
static int ut_dev_cleanups
 
static int ut_dev_dom_inits
 
static int ut_dev_dom_finis
 
static int ut_dev_tm_starts
 
static int ut_dev_tm_stops
 
static struct nlx_kcore_ops ut_kcore_ops
 

Macro Definition Documentation

◆ EXP_SEG_COUNT

#define EXP_SEG_COUNT (   ptr,
  segsize,
  expcount 
)
Value:
bv1.ov_buf[0] = (ptr); \
bv1.ov_vec.v_count[0] = (segsize); \
num_pages = bufvec_seg_page_count(&bv1, 0); \
M0_UT_ASSERT(num_pages == (expcount))
static void ptr(struct m0_addb2__context *ctx, const uint64_t *v, char *buf)
Definition: dump.c:440
static unsigned bufvec_seg_page_count(const struct m0_bufvec *bvec, unsigned n)
Definition: klnet_vec.c:65

◆ KEB

#define KEB (   b)
Value:
nlx_kcore_num_kiov_entries_for_bytes((lnet_kiov_t *) umd.start, \
umd.length, (b), &last)
static size_t nlx_kcore_num_kiov_entries_for_bytes(const lnet_kiov_t *kiov, size_t kiov_len, m0_bcount_t bytes, unsigned *last_len)
Definition: klnet_vec.c:302
static struct m0_addb2_frame_header last
Definition: storage.c:93

◆ TEST_HDR_DATA_ENCODE

#define TEST_HDR_DATA_ENCODE (   _p,
  _t 
)
Value:
ktm.ktm_addr.cepa_tmid = (_t); \
ktm.ktm_addr.cepa_portal = (_p); \
nlx_kcore_hdr_data_decode(nlx_kcore_hdr_data_encode(&ktm), \
&portal, &tmid); \
M0_UT_ASSERT(portal == (_p)); \
M0_UT_ASSERT(tmid == (_t))
static uint64_t nlx_kcore_hdr_data_encode(struct nlx_kcore_transfer_mc *kctm)
Definition: klnet_utils.c:212

◆ USER_HELPER_WAIT

#define USER_HELPER_WAIT (   id)
Value:
({ \
ok = user_helper_wait((id)); \
if (!ok) \
goto restore_fops; \
})
bool user_helper_wait(int id)
Definition: klnet_ut.c:2137

◆ UT_BUFVEC_ALLOC

#define UT_BUFVEC_ALLOC (   v,
  n 
)
Value:
if (!ut_bufvec_alloc(&v,n)) { \
M0_IMPOSSIBLE("no memory");\
return; \
}
static bool ut_bufvec_alloc(struct m0_bufvec *bv, size_t n)
Definition: klnet_ut.c:211
uint64_t n
Definition: fops.h:107

Definition at line 223 of file klnet_ut.c.

◆ UT_BUFVEC_FREE

#define UT_BUFVEC_FREE (   v)
Value:
m0_free(v.ov_vec.v_count); \
m0_free(v.ov_buf)
void m0_free(void *data)
Definition: memory.c:146

Definition at line 229 of file klnet_ut.c.

Enumeration Type Documentation

◆ anonymous enum

anonymous enum
Enumerator
UT_PROC_WRITE_SIZE 

max size of data to write to proc file

UT_SYNC_DELAY_SEC 

delay for user program to sync

Definition at line 36 of file klnet_ut.c.

◆ anonymous enum

anonymous enum
Enumerator
UT_KMSG_OPS 

Definition at line 478 of file klnet_ut.c.

Function Documentation

◆ close_lnet_ut()

static int close_lnet_ut ( struct inode inode,
struct file file 
)
static

Definition at line 164 of file klnet_ut.c.

◆ ktest_buf_reg()

static void ktest_buf_reg ( void  )
static

Definition at line 278 of file klnet_ut.c.

Here is the call graph for this function:

◆ ktest_buf_shape()

static void ktest_buf_shape ( void  )
static

Definition at line 233 of file klnet_ut.c.

Here is the call graph for this function:

◆ ktest_bulk()

static void ktest_bulk ( void  )
static

Definition at line 1989 of file klnet_ut.c.

Here is the call graph for this function:

◆ ktest_bulk_body()

static void ktest_bulk_body ( struct ut_data td)
static

Definition at line 1400 of file klnet_ut.c.

Here is the call graph for this function:
Here is the caller graph for this function:

◆ ktest_core_ep_addr()

static void ktest_core_ep_addr ( void  )
static

Definition at line 370 of file klnet_ut.c.

Here is the call graph for this function:

◆ ktest_dev()

static void ktest_dev ( void  )
static

Definition at line 2154 of file klnet_ut.c.

Here is the call graph for this function:

◆ ktest_enc_dec()

static void ktest_enc_dec ( void  )
static

Definition at line 444 of file klnet_ut.c.

Here is the call graph for this function:

◆ ktest_lnet_fini()

static void ktest_lnet_fini ( void  )
static

Definition at line 201 of file klnet_ut.c.

Here is the call graph for this function:
Here is the caller graph for this function:

◆ ktest_lnet_init()

static int ktest_lnet_init ( void  )
static

Definition at line 179 of file klnet_ut.c.

Here is the call graph for this function:
Here is the caller graph for this function:

◆ ktest_msg()

static void ktest_msg ( void  )
static

Definition at line 1184 of file klnet_ut.c.

Here is the call graph for this function:

◆ ktest_msg_body()

static void ktest_msg_body ( struct ut_data td)
static

Definition at line 685 of file klnet_ut.c.

Here is the call graph for this function:
Here is the caller graph for this function:

◆ open_lnet_ut()

static int open_lnet_ut ( struct inode inode,
struct file file 
)
static

Definition at line 159 of file klnet_ut.c.

◆ read_lnet_ut()

static ssize_t read_lnet_ut ( struct file file,
char __user *  buffer,
size_t  len,
loff_t *  offset 
)
static

Definition at line 51 of file klnet_ut.c.

Here is the call graph for this function:
Here is the caller graph for this function:

◆ user_helper_wait()

bool user_helper_wait ( int  id)

Definition at line 2137 of file klnet_ut.c.

Here is the call graph for this function:

◆ ut_bufvec_alloc()

static bool ut_bufvec_alloc ( struct m0_bufvec bv,
size_t  n 
)
static

Definition at line 211 of file klnet_ut.c.

Here is the call graph for this function:

◆ ut_dev_close()

int ut_dev_close ( struct inode inode,
struct file file 
)

Definition at line 2114 of file klnet_ut.c.

Here is the call graph for this function:
Here is the caller graph for this function:

◆ ut_dev_open()

static int ut_dev_open ( struct inode inode,
struct file file 
)
static

Definition at line 2091 of file klnet_ut.c.

Here is the call graph for this function:
Here is the caller graph for this function:

◆ ut_kcore_core_dom_fini()

static void ut_kcore_core_dom_fini ( struct nlx_kcore_domain kd,
struct nlx_core_domain cd 
)
static

Definition at line 2027 of file klnet_ut.c.

Here is the call graph for this function:

◆ ut_kcore_core_dom_init()

static int ut_kcore_core_dom_init ( struct nlx_kcore_domain kd,
struct nlx_core_domain cd 
)
static

Definition at line 2015 of file klnet_ut.c.

Here is the call graph for this function:

◆ ut_kcore_tm_start()

static int ut_kcore_tm_start ( struct nlx_kcore_domain kd,
struct nlx_core_transfer_mc ctm,
struct nlx_kcore_transfer_mc ktm 
)
static

Definition at line 2037 of file klnet_ut.c.

Here is the call graph for this function:

◆ ut_kcore_tm_stop()

static void ut_kcore_tm_stop ( struct nlx_core_transfer_mc ctm,
struct nlx_kcore_transfer_mc ktm 
)
static

Definition at line 2060 of file klnet_ut.c.

Here is the call graph for this function:

◆ ut_ktest_ack_event()

static void ut_ktest_ack_event ( struct nlx_kcore_buffer kcb)
static

Definition at line 627 of file klnet_ut.c.

Here is the call graph for this function:
Here is the caller graph for this function:

◆ ut_ktest_bulk_get_event()

static void ut_ktest_bulk_get_event ( struct nlx_kcore_buffer kcb,
unsigned  mlength,
int  status 
)
static

Definition at line 1334 of file klnet_ut.c.

Here is the call graph for this function:
Here is the caller graph for this function:

◆ ut_ktest_bulk_LNetGet()

static int ut_ktest_bulk_LNetGet ( struct nlx_kcore_transfer_mc kctm,
struct nlx_core_buffer lcbuf,
struct nlx_kcore_buffer kcb,
lnet_md_t *  umd 
)
static

Definition at line 1257 of file klnet_ut.c.

Here is the call graph for this function:
Here is the caller graph for this function:

◆ ut_ktest_bulk_LNetMDAttach()

static int ut_ktest_bulk_LNetMDAttach ( struct nlx_kcore_transfer_mc kctm,
struct nlx_core_buffer lcbuf,
struct nlx_kcore_buffer kcb,
lnet_md_t *  umd 
)
static

Definition at line 1205 of file klnet_ut.c.

Here is the call graph for this function:
Here is the caller graph for this function:

◆ ut_ktest_bulk_LNetPut()

static int ut_ktest_bulk_LNetPut ( struct nlx_kcore_transfer_mc kctm,
struct nlx_core_buffer lcbuf,
struct nlx_kcore_buffer kcb,
lnet_md_t *  umd 
)
static

Definition at line 1288 of file klnet_ut.c.

Here is the call graph for this function:
Here is the caller graph for this function:

◆ ut_ktest_bulk_put_event()

static void ut_ktest_bulk_put_event ( struct nlx_kcore_buffer kcb,
unsigned  mlength,
int  status 
)
static

Definition at line 1318 of file klnet_ut.c.

Here is the call graph for this function:
Here is the caller graph for this function:

◆ ut_ktest_bulk_reply_event()

static void ut_ktest_bulk_reply_event ( struct nlx_kcore_buffer kcb,
unsigned  mlength,
int  status,
int  unlinked,
int  threshold 
)
static

Definition at line 1370 of file klnet_ut.c.

Here is the call graph for this function:
Here is the caller graph for this function:

◆ ut_ktest_bulk_send_event()

static void ut_ktest_bulk_send_event ( struct nlx_kcore_buffer kcb,
unsigned  mlength,
int  status,
int  unlinked,
int  threshold 
)
static

Definition at line 1351 of file klnet_ut.c.

Here is the call graph for this function:
Here is the caller graph for this function:

◆ ut_ktest_bulk_unlink_event()

static void ut_ktest_bulk_unlink_event ( struct nlx_kcore_buffer kcb)
static

Definition at line 1389 of file klnet_ut.c.

Here is the call graph for this function:
Here is the caller graph for this function:

◆ ut_ktest_kiov_count()

static unsigned ut_ktest_kiov_count ( const lnet_kiov_t *  k,
size_t  len 
)
static

Definition at line 674 of file klnet_ut.c.

Here is the caller graph for this function:

◆ ut_ktest_kiov_eq()

static bool ut_ktest_kiov_eq ( const lnet_kiov_t *  k1,
const lnet_kiov_t *  k2,
size_t  len 
)
static

Definition at line 660 of file klnet_ut.c.

Here is the caller graph for this function:

◆ ut_ktest_kiov_mem_dup()

static lnet_kiov_t* ut_ktest_kiov_mem_dup ( const lnet_kiov_t *  kiov,
size_t  len 
)
static

Definition at line 639 of file klnet_ut.c.

Here is the caller graph for this function:

◆ ut_ktest_kiov_mem_free()

static void ut_ktest_kiov_mem_free ( lnet_kiov_t *  kiov)
static

Definition at line 655 of file klnet_ut.c.

Here is the call graph for this function:
Here is the caller graph for this function:

◆ ut_ktest_msg_buf_event_wait()

int ut_ktest_msg_buf_event_wait ( struct nlx_core_domain lcdom,
struct nlx_core_transfer_mc lctm,
m0_time_t  timeout 
)

Definition at line 555 of file klnet_ut.c.

Here is the call graph for this function:
Here is the caller graph for this function:

◆ ut_ktest_msg_ep_create()

static int ut_ktest_msg_ep_create ( struct m0_net_end_point **  epp,
struct m0_net_transfer_mc tm,
const struct nlx_core_ep_addr cepa 
)
static

Definition at line 573 of file klnet_ut.c.

Here is the call graph for this function:
Here is the caller graph for this function:

◆ ut_ktest_msg_LNetMDAttach()

static int ut_ktest_msg_LNetMDAttach ( struct nlx_kcore_transfer_mc kctm,
struct nlx_core_buffer lcbuf,
struct nlx_kcore_buffer kcb,
lnet_md_t *  umd 
)
static

Definition at line 482 of file klnet_ut.c.

Here is the call graph for this function:
Here is the caller graph for this function:

◆ ut_ktest_msg_LNetPut()

static int ut_ktest_msg_LNetPut ( struct nlx_kcore_transfer_mc kctm,
struct nlx_core_buffer lcbuf,
struct nlx_kcore_buffer kcb,
lnet_md_t *  umd 
)
static

Definition at line 518 of file klnet_ut.c.

Here is the call graph for this function:
Here is the caller graph for this function:

◆ ut_ktest_msg_put_event()

static void ut_ktest_msg_put_event ( struct nlx_kcore_buffer kcb,
unsigned  mlength,
unsigned  offset,
int  status,
int  unlinked,
struct nlx_core_ep_addr addr 
)
static

Definition at line 584 of file klnet_ut.c.

Here is the call graph for this function:
Here is the caller graph for this function:

◆ ut_ktest_msg_send_event()

static void ut_ktest_msg_send_event ( struct nlx_kcore_buffer kcb,
unsigned  mlength,
int  status 
)
static

Definition at line 608 of file klnet_ut.c.

Here is the call graph for this function:
Here is the caller graph for this function:

◆ write_lnet_ut()

static ssize_t write_lnet_ut ( struct file file,
const char __user *  buffer,
size_t  count,
loff_t *  offset 
)
static

Synchronize with user space program, updates ktest_id and signals main UT thread about each transition.

Definition at line 107 of file klnet_ut.c.

Here is the call graph for this function:
Here is the caller graph for this function:

Variable Documentation

◆ ktest_cond

struct m0_cond ktest_cond
static

Definition at line 44 of file klnet_ut.c.

◆ ktest_done

bool ktest_done
static

Definition at line 48 of file klnet_ut.c.

◆ ktest_id

int ktest_id
static

Definition at line 46 of file klnet_ut.c.

◆ ktest_mutex

struct m0_mutex ktest_mutex
static

Definition at line 43 of file klnet_ut.c.

◆ ktest_sem

struct m0_semaphore ktest_sem
static

Definition at line 45 of file klnet_ut.c.

◆ ktest_user_failed

bool ktest_user_failed
static

Definition at line 47 of file klnet_ut.c.

◆ proc_lnet_fops

struct file_operations proc_lnet_fops
static
Initial value:
= {
.owner = THIS_MODULE,
.open = open_lnet_ut,
.release = close_lnet_ut,
.read = read_lnet_ut,
.write = write_lnet_ut,
.llseek = default_llseek,
}
static ssize_t write_lnet_ut(struct file *file, const char __user *buffer, size_t count, loff_t *offset)
Definition: klnet_ut.c:107
static int close_lnet_ut(struct inode *inode, struct file *file)
Definition: klnet_ut.c:164
static int open_lnet_ut(struct inode *inode, struct file *file)
Definition: klnet_ut.c:159
static ssize_t read_lnet_ut(struct file *file, char __user *buffer, size_t len, loff_t *offset)
Definition: klnet_ut.c:51

Definition at line 169 of file klnet_ut.c.

◆ proc_lnet_ut

struct proc_dir_entry* proc_lnet_ut
static

Definition at line 41 of file klnet_ut.c.

◆ ut_dev_cleanups

int ut_dev_cleanups
static

Definition at line 2009 of file klnet_ut.c.

◆ ut_dev_closes

int ut_dev_closes
static

Definition at line 2008 of file klnet_ut.c.

◆ ut_dev_dom_finis

int ut_dev_dom_finis
static

Definition at line 2011 of file klnet_ut.c.

◆ ut_dev_dom_inits

int ut_dev_dom_inits
static

Definition at line 2010 of file klnet_ut.c.

◆ ut_dev_opens

int ut_dev_opens
static

Definition at line 2007 of file klnet_ut.c.

◆ ut_dev_tm_starts

int ut_dev_tm_starts
static

Definition at line 2012 of file klnet_ut.c.

◆ ut_dev_tm_stops

int ut_dev_tm_stops
static

Definition at line 2013 of file klnet_ut.c.

◆ ut_kcore_ops

struct nlx_kcore_ops ut_kcore_ops
static
Initial value:
= {
.ko_dom_init = ut_kcore_core_dom_init,
.ko_dom_fini = ut_kcore_core_dom_fini,
.ko_buf_register = nlx_kcore_buf_register,
.ko_buf_deregister = nlx_kcore_buf_deregister,
.ko_tm_start = ut_kcore_tm_start,
.ko_tm_stop = ut_kcore_tm_stop,
.ko_buf_msg_recv = nlx_kcore_buf_msg_recv,
.ko_buf_msg_send = nlx_kcore_buf_msg_send,
.ko_buf_active_recv = nlx_kcore_buf_active_recv,
.ko_buf_active_send = nlx_kcore_buf_active_send,
.ko_buf_passive_recv = nlx_kcore_buf_passive_recv,
.ko_buf_passive_send = nlx_kcore_buf_passive_send,
.ko_buf_del = nlx_kcore_LNetMDUnlink,
.ko_buf_event_wait = nlx_kcore_buf_event_wait,
}
static int nlx_kcore_buf_passive_send(struct nlx_kcore_transfer_mc *ktm, struct nlx_core_buffer *cb, struct nlx_kcore_buffer *kb)
Definition: klnet_core.c:1587
static void ut_kcore_tm_stop(struct nlx_core_transfer_mc *ctm, struct nlx_kcore_transfer_mc *ktm)
Definition: klnet_ut.c:2060
static int ut_kcore_core_dom_init(struct nlx_kcore_domain *kd, struct nlx_core_domain *cd)
Definition: klnet_ut.c:2015
static void nlx_kcore_buf_deregister(struct nlx_core_buffer *cb, struct nlx_kcore_buffer *kb)
Definition: klnet_core.c:1282
static int nlx_kcore_buf_passive_recv(struct nlx_kcore_transfer_mc *ktm, struct nlx_core_buffer *cb, struct nlx_kcore_buffer *kb)
Definition: klnet_core.c:1538
static int nlx_kcore_buf_msg_recv(struct nlx_kcore_transfer_mc *ktm, struct nlx_core_buffer *cb, struct nlx_kcore_buffer *kb)
Definition: klnet_core.c:1348
static void ut_kcore_core_dom_fini(struct nlx_kcore_domain *kd, struct nlx_core_domain *cd)
Definition: klnet_ut.c:2027
static int ut_kcore_tm_start(struct nlx_kcore_domain *kd, struct nlx_core_transfer_mc *ctm, struct nlx_kcore_transfer_mc *ktm)
Definition: klnet_ut.c:2037
static int nlx_kcore_buf_register(struct nlx_kcore_domain *kd, nlx_core_opaque_ptr_t buffer_id, struct nlx_core_buffer *cb, struct nlx_kcore_buffer *kb)
Definition: klnet_core.c:1251
static int nlx_kcore_buf_event_wait(struct nlx_core_transfer_mc *ctm, struct nlx_kcore_transfer_mc *ktm, m0_time_t timeout)
Definition: klnet_core.c:1658
static int nlx_kcore_buf_active_send(struct nlx_kcore_transfer_mc *ktm, struct nlx_core_buffer *cb, struct nlx_kcore_buffer *kb)
Definition: klnet_core.c:1488
static int nlx_kcore_buf_msg_send(struct nlx_kcore_transfer_mc *ktm, struct nlx_core_buffer *cb, struct nlx_kcore_buffer *kb)
Definition: klnet_core.c:1394
static int nlx_kcore_buf_active_recv(struct nlx_kcore_transfer_mc *ktm, struct nlx_core_buffer *cb, struct nlx_kcore_buffer *kb)
Definition: klnet_core.c:1438
static int nlx_kcore_LNetMDUnlink(struct nlx_kcore_transfer_mc *kctm, struct nlx_kcore_buffer *kcb)
Definition: klnet_utils.c:433

Definition at line 2074 of file klnet_ut.c.

◆ ut_ktest_bulk_fake_LNetMDAttach

struct m0_atomic64 ut_ktest_bulk_fake_LNetMDAttach
static

Definition at line 1203 of file klnet_ut.c.

◆ ut_ktest_bulk_LNetGet_called

bool ut_ktest_bulk_LNetGet_called
static

Definition at line 1256 of file klnet_ut.c.

◆ ut_ktest_bulk_LNetMDAttach_called

bool ut_ktest_bulk_LNetMDAttach_called
static

Definition at line 1204 of file klnet_ut.c.

◆ ut_ktest_bulk_LNetPut_called

bool ut_ktest_bulk_LNetPut_called
static

Definition at line 1287 of file klnet_ut.c.

◆ ut_ktest_msg_buf_event_wait_delay_chan

struct m0_chan* ut_ktest_msg_buf_event_wait_delay_chan
static

Definition at line 554 of file klnet_ut.c.

◆ ut_ktest_msg_buf_event_wait_stall

struct m0_atomic64 ut_ktest_msg_buf_event_wait_stall
static

Definition at line 553 of file klnet_ut.c.

◆ ut_ktest_msg_ep_create_fail

struct m0_atomic64 ut_ktest_msg_ep_create_fail
static

Definition at line 572 of file klnet_ut.c.

◆ ut_ktest_msg_LNetMDAttach_called

bool ut_ktest_msg_LNetMDAttach_called
static

Definition at line 481 of file klnet_ut.c.

◆ ut_ktest_msg_LNetPut_called

bool ut_ktest_msg_LNetPut_called
static

Definition at line 516 of file klnet_ut.c.

◆ ut_ktest_msg_LNetPut_ep

struct m0_net_end_point* ut_ktest_msg_LNetPut_ep
static

Definition at line 517 of file klnet_ut.c.