JULEA
Data Structures | Macros | Typedefs | Enumerations | Functions
jnetwork.c File Reference
#include <julea-config.h>
#include <glib.h>
#include <gio/gio.h>
#include <rdma/fi_endpoint.h>
#include <rdma/fi_rma.h>
#include <rdma/fi_cm.h>
#include <netinet/in.h>
#include <jnetwork.h>
#include <jconfiguration.h>
#include <jhelper.h>
#include <jtrace.h>

Data Structures

struct  JNetworkFabricAddr
 
struct  JNetworkFabric
 
struct  JNetworkConnection
 

Macros

#define KEY_MIN   1
 
#define J_NETWORK_CONNECTION_MAX_SEND   2
 
#define J_NETWORK_CONNECTION_MAX_RECV   1
 
#define EXE(cmd, ...)
 
#define CHECK(msg)
 
#define G_CHECK(msg)
 

Typedefs

typedef struct JNetworkFabricAddr JNetworkFabricAddr
 
typedef enum JNetworkFabricSide JNetworkFabricSide
 
typedef enum JNetworkFabricEvents JNetworkFabricEvents
 
typedef enum JNetworkConnectionEvents JNetworkConnectionEvents
 

Enumerations

enum  JNetworkFabricSide { JF_SERVER , JF_CLIENT }
 
enum  JNetworkFabricEvents { J_FABRIC_EVENT_ERROR = 0 , J_FABRIC_EVENT_TIMEOUT , J_FABRIC_EVENT_CONNECTION_REQUEST , J_FABRIC_EVENT_SHUTDOWN }
 
enum  JNetworkConnectionEvents { J_CONNECTION_EVENT_ERROR = 0 , J_CONNECTION_EVENT_TIMEOUT , J_CONNECTION_EVENT_CONNECTED , J_CONNECTION_EVENT_SHUTDOWN }
 

Functions

G_END_DECLS G_BEGIN_DECLS JNetworkFabricj_network_fabric_init_server (JConfiguration *configuration)
 
JNetworkConnectionj_network_connection_init_client (JConfiguration *configuration, JBackendType backend, guint index)
 
JNetworkConnectionj_network_connection_init_server (JNetworkFabric *fabric, GSocketConnection *gconnection)
 
gboolean j_network_connection_send (JNetworkConnection *connection, gpointer data, gsize length)
 
gboolean j_network_connection_recv (JNetworkConnection *connection, gsize length, gpointer data)
 
gboolean j_network_connection_closed (JNetworkConnection *connection)
 
gboolean j_network_connection_wait_for_completion (JNetworkConnection *connection)
 
gboolean j_network_connection_rma_register (JNetworkConnection *connection, gconstpointer data, gsize length, JNetworkConnectionMemory *handle)
 
gboolean j_network_connection_rma_unregister (JNetworkConnection *connection, JNetworkConnectionMemory *handle)
 
gboolean j_network_connection_memory_get_id (JNetworkConnectionMemory *this, JNetworkConnectionMemoryID *id)
 
gboolean j_network_connection_rma_read (JNetworkConnection *connection, JNetworkConnectionMemoryID const *memory_id, gpointer data)
 
gboolean j_network_connection_fini (JNetworkConnection *connection)