rcat.c File Reference

Example of usage/most basic test program for mooshika. More...

#include <netinet/in.h>
#include <arpa/inet.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <netdb.h>
#include <getopt.h>
#include <errno.h>
#include <poll.h>
#include <inttypes.h>
#include "utils.h"
#include "mooshika.h"

Macros
#define	DEFAULT_BLOCK_SIZE   1024*1024
#define	DEFAULT_RECV_NUM   4
#define	RDMABUF_SIZE   (thread_arg->recv_num+2)*thread_arg->block_size

Functions
void	callback_send (msk_trans_t *trans, msk_data_t *pdata, void *arg)
void	callback_disconnect (msk_trans_t *trans)
void	callback_error (msk_trans_t *trans, msk_data_t *pdata, void *arg)
void	callback_recv (msk_trans_t *trans, msk_data_t *pdata, void *arg)
void	print_help (char **argv)
void *	handle_trans (void *arg)
void	post_recvs (msk_trans_t *trans, struct thread_arg *thread_arg)
int	setup_recv (msk_trans_t *trans, struct thread_arg *thread_arg)
int	main (int argc, char **argv)

Detailed Description

Example of usage/most basic test program for mooshika.

Example of usage/most basic test program for mooshika

Macro Definition Documentation

#define DEFAULT_BLOCK_SIZE   1024*1024

Referenced by main(), and print_help().

#define DEFAULT_RECV_NUM   4

Referenced by main(), and print_help().

#define RDMABUF_SIZE   (thread_arg->recv_num+2)*thread_arg->block_size

Referenced by post_recvs().

Function Documentation

void callback_disconnect

(

msk_trans_t *

trans

)

References msk_trans::private_data.

Referenced by main().

void callback_error	(	msk_trans_t *	trans,
		msk_data_t *	pdata,
		void *	arg
	)

References msk_trans::debug, INFO_LOG, and msk_trans::state.

Referenced by callback_recv(), main(), and post_recvs().

static void callback_recv	(	msk_trans_t *	trans,
		msk_data_t *	pdata,
		void *	arg
	)

References callback_error(), msk_data::data, ERROR_LOG, msk_trans::private_data, and msk_data::size.

Referenced by main(), and post_recvs().

void callback_send	(	msk_trans_t *	trans,
		msk_data_t *	pdata,
		void *	arg
	)

Referenced by main().

void* handle_trans

(

void *

arg

)

References msk_data::data, msk_data::max_size, msk_data::mr, msk_dereg_mr(), msk_destroy_trans(), msk_finalize_accept(), msk_finalize_connect(), msk_reg_mr(), msk_stats::nsec_callback, msk_stats::nsec_compevent, NSEC_IN_SEC, msk_trans::private_data, msk_stats::rx_bytes, msk_stats::rx_err, msk_stats::rx_pkt, msk_trans::server, msk_data::size, msk_trans::state, msk_trans::stats, TEST_NZ, TEST_Z, msk_stats::tx_bytes, msk_stats::tx_err, and msk_stats::tx_pkt.

Referenced by main().

int main	(	int	argc,
		char **	argv
	)

References callback_disconnect(), msk_trans_attr::debug, DEFAULT_BLOCK_SIZE, DEFAULT_RECV_NUM, msk_trans_attr::disconnect_callback, ERROR_LOG, handle_trans(), INFO_LOG, msk_bind_server(), msk_connect(), MSK_DEBUG_SPEED, msk_dereg_mr(), msk_destroy_trans(), msk_init(), msk_trans_attr::node, msk_trans_attr::port, print_help(), msk_trans::private_data, msk_trans_attr::rq_depth, msk_trans::server, msk_trans_attr::server, set_size, setup_recv(), msk_trans_attr::stats_prefix, TEST_NZ, TEST_Z, msk_trans_attr::use_srq, and msk_trans_attr::worker_count.

void post_recvs	(	msk_trans_t *	trans,
		struct thread_arg *	thread_arg
	)

References callback_error(), callback_recv(), msk_reg_mr(), RDMABUF_SIZE, TEST_NZ, and TEST_Z.

Referenced by setup_recv().

void print_help

(

char **

argv

)

References DEFAULT_BLOCK_SIZE, and DEFAULT_RECV_NUM.

Referenced by main().

int setup_recv	(	msk_trans_t *	trans,
		struct thread_arg *	thread_arg
	)

References msk_getpd(), msk_pd::pd, post_recvs(), msk_pd::private, msk_trans::srq, and TEST_NZ.

Referenced by main().