libmooshika
|
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) |
Example of usage/most basic test program for mooshika.
Example of usage/most basic test program for mooshika
#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().
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().