libmooshika
Macros | Functions
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 
)
static void callback_recv ( msk_trans_t trans,
msk_data_t pdata,
void *  arg 
)
void callback_send ( msk_trans_t trans,
msk_data_t pdata,
void *  arg 
)

Referenced by main().

void* handle_trans ( void *  arg)
int main ( int  argc,
char **  argv 
)
void post_recvs ( msk_trans_t trans,
struct thread_arg *  thread_arg 
)
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 
)