bench_rdma.c File Reference

spams rdma read or write to check speed. More...

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

Macros
#define	CHUNK_SIZE   1024*1024
#define	SEND_COUNT   10000
#define	RECV_NUM   2
#define	msk_post_RW   msk_post_read

Functions
void	callback_send (msk_trans_t *trans, msk_data_t *data, void *arg)
void	callback_disconnect (msk_trans_t *trans)
void	callback_recv (msk_trans_t *trans, msk_data_t *data, void *arg)
void	callback_read (msk_trans_t *trans, msk_data_t *data, void *arg)
void	print_help (char **argv)
int	main (int argc, char **argv)

Detailed Description

spams rdma read or write to check speed.

spams rdma read or write to check speed.

Macro Definition Documentation

#define CHUNK_SIZE   1024*1024

Referenced by main().

#define msk_post_RW   msk_post_read

Referenced by callback_read(), and main().

#define RECV_NUM   2

Referenced by main().

#define SEND_COUNT   10000

Referenced by callback_read(), and main().

Function Documentation

void callback_disconnect

(

msk_trans_t *

trans

)

void callback_read	(	msk_trans_t *	trans,
		msk_data_t *	data,
		void *	arg
	)

References msk_post_RW, SEND_COUNT, msk_trans::state, and TEST_Z.

Referenced by main().

void callback_recv	(	msk_trans_t *	trans,
		msk_data_t *	data,
		void *	arg
	)

Referenced by main().

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

int main	(	int	argc,
		char **	argv
	)

Todo:

wait till last work request is done. cannot use wait_send because the other will get the send before we get our ack, so they might disconnect and our threads might fail before we get our WC that would unstuck us.

References callback_read(), callback_recv(), CHUNK_SIZE, msk_data::data, msk_trans_attr::debug, ERROR_LOG, msk_data::max_size, msk_data::mr, msk_bind_server(), msk_connect(), msk_dereg_mr(), msk_destroy_trans(), msk_finalize_accept(), msk_finalize_connect(), msk_init(), msk_make_rloc(), msk_post_RW, msk_reg_mr(), msk_trans_attr::node, msk_trans_attr::port, print_help(), msk_rloc::raddr, RECV_NUM, msk_rloc::rkey, msk_trans_attr::rq_depth, SEND_COUNT, msk_trans::server, msk_trans_attr::server, msk_data::size, msk_rloc::size, msk_trans_attr::sq_depth, TEST_NZ, and TEST_Z.

void print_help

(

char **

argv

)

Referenced by main().