---

cm.h

Go to the documentation of this file.

#ifndef __CM__H__
#define __CM__H__

#if defined(FUNCPROTO) || defined(__STDC__) || defined(__cplusplus) || defined(c_plusplus)
#ifndef ARGS
#define ARGS(args) args
#endif
#else
#ifndef ARGS
#define ARGS(args) (/*args*/)
#endif
#endif

#include "io.h"
#include "atl.h"
#ifdef  __cplusplus
extern "C" {
#endif

#ifndef TRUE
#define TRUE 1
#endif
#ifndef FALSE
#define FALSE 0
#endif

typedef struct _CMformat_list {
    char *format_name;
    IOFieldList field_list;
}CMFormatRec;

typedef CMFormatRec *CMFormatList;

struct _CManager;
struct _CMConnection;
struct _CMFormat;

typedef struct _CManager *CManager;

typedef struct _CMConnection *CMConnection;

typedef struct _CMFormat *CMFormat;

typedef struct _CMTaskHandle *CMTaskHandle;

typedef void (*CMHandlerFunc) ARGS((CManager cm, 
                                    CMConnection conn,
                                    void *message, void *client_data,
                                    attr_list attrs));

typedef void (*CMPollFunc) ARGS((CManager cm, void *client_data));

typedef void (*CMCloseHandlerFunc) ARGS((CManager cm, CMConnection conn,
                                         void *client_data));


extern CManager CManager_create();

extern void CManager_close ARGS((CManager cm));

extern int CMfork_comm_thread ARGS((CManager cm));

extern int CMlisten ARGS((CManager cm));

extern int CMlisten_specific ARGS((CManager cm, attr_list listen_info));

extern attr_list
CMget_contact_list ARGS((CManager cm));

extern int
CMcontact_self_check ARGS((CManager cm, attr_list attrs));

extern CMConnection
CMget_conn ARGS((CManager cm, attr_list contact_list));

extern CMConnection
CMinitiate_conn ARGS((CManager cm, attr_list contact_list));

extern void
CMConnection_close ARGS((CMConnection conn));

extern void
CMConnection_add_reference ARGS((CMConnection conn));

extern void
CMconn_register_close_handler ARGS((CMConnection conn, 
                                    CMCloseHandlerFunc func, 
                                    void *client_data));

extern CMFormat
CMregister_format ARGS((CManager cm, char *format_name,
                       IOFieldList field_list, CMFormatList subformat_list));
extern CMFormat CMlookup_format ARGS((CManager cm, IOFieldList field_list));

extern
IOContext CMget_user_type_context ARGS((CManager cm));

extern
void CMfree_user_type_context ARGS((CManager cm, IOContext context));

extern IOFormat
CMregister_user_format ARGS((CManager cm, IOContext context, char *format_name,
                              IOFieldList field_list, CMFormatList subformat_list));

extern IOFormat CMlookup_user_format ARGS((CManager cm, IOFieldList field_list));

extern IOFormat CMget_IOformat_by_name ARGS((CManager cm, IOContext context,
                                             char *name));
extern IOFormat CMget_format_IOcontext ARGS((CManager cm, IOContext context,
                                             void *buffer));
extern IOFormat *CMget_subformats_IOcontext ARGS((CManager cm, 
                                                  IOContext context,
                                                  void *buffer));
extern void
CMset_conversion_IOcontext ARGS((CManager cm, IOContext context,
                                 IOFormat format, IOFieldList field_list,
                                 int native_struct_size));
extern int
CMwrite ARGS((CMConnection conn, CMFormat format, void *data));

extern int
CMwrite_attr ARGS((CMConnection conn, CMFormat format, void *data, 
                   attr_list attrs));

extern void
CMregister_handler ARGS((CMFormat format, CMHandlerFunc handler, 
                        void *client_data));

extern void *CMtake_buffer ARGS((CManager cm, void *data));

extern void CMreturn_buffer ARGS((CManager cm, void *data));

typedef void (*CMNonCMHandler) ARGS((CMConnection conn,
                                     int header));

extern void
CMregister_non_CM_message_handler ARGS((int header, CMNonCMHandler handler));

extern void
CMadd_poll ARGS((CManager cm, CMPollFunc func, void *client_data));

extern CMTaskHandle
CMadd_periodic_task ARGS((CManager cm, int period_sec, int period_usec, 
                          CMPollFunc func, void *client_data));

extern CMTaskHandle
CMadd_delayed_task ARGS((CManager cm, int secs, int usecs, CMPollFunc func,
                         void *client_data));

extern void
CMremove_task ARGS((CMTaskHandle handle));

extern void
CMadd_shutdown_task ARGS((CManager cm, CMPollFunc func, void *client_data));

extern CMTaskHandle
CMadd_periodic ARGS((CManager cm, long period, CMPollFunc func,
                     void *client_data));

extern void
CMremove_periodic ARGS((CMTaskHandle handle));

extern void
CMsleep ARGS((CManager cm, int secs));

extern void
CMusleep ARGS((CManager cm, int usecs));

extern 
void CMpoll_network ARGS((CManager cm));

extern 
void CMrun_network ARGS((CManager cm));

int CMCondition_get ARGS((CManager cm, CMConnection dep));

int CMCondition_wait ARGS((CManager cm, int condition));

void CMCondition_signal ARGS((CManager cm, int condition));

void CMCondition_set_client_data ARGS((CManager cm, int condition,
                                       void *client_data));
void *CMCondition_get_client_data ARGS((CManager cm, int condition));

int CMCondition_has_signaled ARGS((CManager cm, int condition));
int CMCondition_has_failed ARGS((CManager cm, int condition));

extern void* CMrealloc ARGS((void *ptr, int size));
extern void* CMmalloc ARGS((int size));
extern void CMfree ARGS((void *ptr));

extern long CMprobe_latency ARGS((CMConnection conn, int msg_size,
                                  attr_list attrs));

extern long
CMprobe_bandwidth ARGS((CMConnection conn, int size, attr_list attrs));
#define CM_FD ATL_CHAR_CONS('C','S','F','D')

#define CM_THIS_CONN_PORT ATL_CHAR_CONS('C','S','C','P')

#define CM_PEER_CONN_PORT ATL_CHAR_CONS('C','S','P','P')

#define CM_PEER_IP ATL_CHAR_CONS('C','P','I','P')

#define CM_PEER_LISTEN_PORT ATL_CHAR_CONS('C','S','P','L')

#define CM_PEER_HOSTNAME ATL_CHAR_CONS('C','P','H','O')

#define CM_IP_HOSTNAME ATL_CHAR_CONS('C','I','P','H')

#define CM_IP_ADDR ATL_CHAR_CONS('C','I','P','A')

#define CM_IP_PORT ATL_CHAR_CONS('C','I','P','P')

#define CM_UDP_PORT ATL_CHAR_CONS('C','U','P','P')

#define CM_TRANSPORT ATL_CHAR_CONS('C','T','r','a')

#define CM_ATM_ADDRESS ATL_CHAR_CONS('C','A','T','A')

#define CM_ATM_SELECTOR ATL_CHAR_CONS('C','A','T','S')

#define CM_ATM_BHLI ATL_CHAR_CONS('C','A','T','B')

#define CM_ATM_QOS_CLASS ATL_CHAR_CONS('C','A','Q','C')

#define CM_ATM_QOS_PCR ATL_CHAR_CONS('C','A','Q','P')

#define CM_ATM_QOS_SCR ATL_CHAR_CONS('C','A','Q','S')

#define CM_ATM_QOS_MBS ATL_CHAR_CONS('C','A','Q','M')

#define CM_ATM_FD ATL_CHAR_CONS('C','A','F','D')

#define CM_ATM_REMOTE_ADDRESS ATL_CHAR_CONS('C','A','R','A')

#define CM_ATM_REMOTE_SELECTOR ATL_CHAR_CONS('C','A','R','S')

#define CM_ATM_REMOTE_BHLI ATL_CHAR_CONS('C','A','R','B')

#define CM_ATM_CONN_VPI ATL_CHAR_CONS('C','A','C','V')

#define CM_ATM_CONN_VCI ATL_CHAR_CONS('C','A','C','v')

#define CM_MTP_HOSTNAME ATL_CHAR_CONS('C','M','H','o')

#define CM_MTP_ADDR ATL_CHAR_CONS('C','M','A','d')

#define CM_MTP_PORT ATL_CHAR_CONS('C','M','P','o')

#define CM_RECV_ERR ATL_CHAR_CONS('C','R','R','E')

#define CM_SEND_ERR ATL_CHAR_CONS('C','R','S','E')

#define CM_RECV_RATE ATL_CHAR_CONS('C','R','R','R')

#define CM_SEND_RATE ATL_CHAR_CONS('C','R','S','R')

#define CM_RTSEND_RATE ATL_CHAR_CONS('C','R','R','T')

#define CM_QOS ATL_CHAR_CONS('C','Q','O','S')

#define CM_WIN_INC ATL_CHAR_CONS('C','R','W','I')

#define CM_MAX_SEG ATL_CHAR_CONS('C','R','M','S')

#define CM_MARK ATL_CHAR_CONS('C','R','M','a')

#define CM_START_ADAPT ATL_CHAR_CONS('C','R','S','A')

#define CM_ADAPT_DEGREE ATL_CHAR_CONS('C','R','A','D')

#define CM_ADAPT_COND ATL_CHAR_CONS('C','R','A','C')
/* @}*/

#ifdef  __cplusplus
}
#endif

#endif

---