umdsdmonmsgs.h

Go to the documentation of this file.

#define UMDS_DSTATTYPE_INVALID          0

#define UMDS_DSTATTYPE_CFG                      1

#define UMDS_DSTATTYPE_MALLINFO         2

#define UMDS_DSTATTYPE_CONNSUMMARY      3

#define UMDS_DSTATTYPE_CLIENTPERMS      4

#define UMDS_DSTATTYPE_CLIENTATTRS      5

#define UMDS_DSTATTYPE_PERTOPIC         6

#define UMDS_DSTATTYPE_TOPICTOTALS      7

#define UMDS_DSTATTYPE_SOURCE           8

#define UMDS_DSTATTYPE_RECEIVER         9

#define UMDS_DSTATTYPE_SMARTHEAP        10

#define UMDS_DSTATTYPE_WORKER       11


#define LBM_UMDSD_DMON_VERSION 0

typedef struct umdsd_dstat_msg_hdr_t_stct {
        lbm_uint16_t magic;
        lbm_uint16_t type;
        lbm_uint16_t version;
        lbm_uint16_t length;
        lbm_uint32_t tv_sec;
        lbm_uint32_t tv_usec;
        lbm_uint32_t workerId;
        lbm_uint32_t connId;
} umdsd_dstat_msg_hdr_t;

#define LBM_UMDS_DMON_MAGIC 0x4542

#define LBM_UMDS_DMON_ANTIMAGIC 0x4245


/***************************************************************************************************************************************************************/

typedef struct umdsd_dstat_worker_record_stct {
        lbm_uint32_t workerId;
        lbm_uint32_t num_connections;
} umdsd_dstat_worker_record_t;

typedef struct umdsd_dstat_worker_msg_stct {
        umdsd_dstat_msg_hdr_t hdr;
        umdsd_dstat_worker_record_t record;
} umdsd_dstat_worker_msg_t;

#define UMDS_DSTAT_WORKER_NA -1

#define UMDS_DSTAT_CONN_NA -1

#if (LBM_UMDSD_DMON_VERSION == 0)
#define UMDS_DSTAT_CFG_EL_NAME_SZ       32                      // = CFG_EL_NAME_SZ
#define UMDS_DSTAT_LBM_MAX_TOPIC_NAME_LEN 256   // = LBM_MAX_TOPIC_NAME_LEN

#define UMDS_DSTAT_MAX_ATTR_NAME_SZ 32
#define UMDS_DSTAT_NUM_CLIENT_ATTRS 13                  // = UMDS_NUM_CLIENT_ATTRS
#define UMDS_DSTAT_NUM_CLIENT_PERMS 3                   // = UMDS_NUM_CLIENT_PERMS
#define UMDS_DSTAT_DAEMON_INFO_STRLEN 256               // = DAEMON_INFO_STRLEN
#endif

/***************************************/

typedef struct umdsd_dstat_connection_summary_record_stct {
        lbm_uint64_t                    data_msgs_rcvd;
        lbm_uint64_t                    req_msgs_rcvd;                  
        lbm_uint64_t                    resp_msgs_rcvd;         
        lbm_uint64_t                    control_msgs_rcvd;
        lbm_uint64_t                    total_msgs_rcvd;
        lbm_uint64_t                    data_bytes_rcvd;                
        lbm_uint64_t                    req_bytes_rcvd;         
        lbm_uint64_t                    resp_bytes_rcvd;
        lbm_uint64_t                    control_bytes_rcvd;     
        lbm_uint64_t                    total_bytes_rcvd;
        lbm_uint64_t                    data_msgs_sent;
        lbm_uint64_t                    req_msgs_sent;                  
        lbm_uint64_t                    resp_msgs_sent;                 
        lbm_uint64_t                    control_msgs_sent;
        lbm_uint64_t                    total_msgs_sent;
        lbm_uint64_t                    data_bytes_sent;                
        lbm_uint64_t                    req_bytes_sent;         
        lbm_uint64_t                    resp_bytes_sent;
        lbm_uint64_t                    control_bytes_sent;     
        lbm_uint64_t                    total_bytes_sent;
        lbm_uint64_t                    user_msgs_tossed_for_age;
        lbm_uint64_t                    user_msgs_tossed_for_size;      
        lbm_uint64_t                    msgs_lost;
        lbm_uint32_t                    id;
        char                                    user_name[ UMDS_DSTAT_CFG_EL_NAME_SZ + 1 ];
        char                                    appl_name[ UMDS_DSTAT_CFG_EL_NAME_SZ + 1 ];
        char                                    net_ip[ 20 ];

        lbm_uint64_t                            user_bytes_tossed_for_total_size;
        lbm_uint64_t                            user_msgs_tossed_for_total_size;
} umdsd_dstat_connection_summary_record_t;

typedef struct umdsd_dstat_connection_summary_msg_stct {
        umdsd_dstat_msg_hdr_t hdr;
        umdsd_dstat_connection_summary_record_t record;
} umdsd_dstat_connection_summary_msg_t;


/***************************************/

typedef struct umdsd_dstat_connection_pertopic_record_stct {
        lbm_uint64_t    data_msgs_ever_enq;
        lbm_uint64_t    loss_msgs_ever_enq;
        lbm_uint64_t    req_msgs_ever_enq;
        lbm_uint64_t    resp_msgs_ever_enq;
        lbm_uint64_t    control_msgs_ever_enq;
        lbm_uint64_t    total_msgs_ever_enq;
        lbm_uint64_t    data_bytes_ever_enq;
        lbm_uint64_t    req_bytes_ever_enq;
        lbm_uint64_t    resp_bytes_ever_enq;
        lbm_uint64_t    control_bytes_ever_enq;
        lbm_uint64_t    total_bytes_ever_enq;
        lbm_uint64_t    data_msgs_cur_enq;
        lbm_uint64_t    loss_msgs_cur_enq;
        lbm_uint64_t    req_msgs_cur_enq;
        lbm_uint64_t    resp_msgs_cur_enq;
        lbm_uint64_t    control_msgs_cur_enq;
        lbm_uint64_t    total_msgs_cur_enq;
        lbm_uint64_t    data_bytes_cur_enq;
        lbm_uint64_t    req_bytes_cur_enq;
        lbm_uint64_t    resp_bytes_cur_enq;
        lbm_uint64_t    control_bytes_cur_enq;
        lbm_uint64_t    total_bytes_cur_enq;
        lbm_uint64_t    user_msgs_tossed_for_age;
        lbm_uint64_t    user_msgs_tossed_for_size;
        lbm_uint64_t    msgs_lost;
        lbm_uint32_t    quota;
        char                    topic_name[ UMDS_DSTAT_LBM_MAX_TOPIC_NAME_LEN ];
} umdsd_dstat_connection_pertopic_record_t;

typedef struct umdsd_dstat_connection_pertopic_msg_stct {
        umdsd_dstat_msg_hdr_t hdr;
        umdsd_dstat_connection_pertopic_record_t record;
} umdsd_dstat_connection_pertopic_msg_t;


/***************************************/


typedef struct umdsd_dstat_connection_totaltopic_record_stct {
        lbm_uint64_t            tot_data_msgs_ever_enq;
        lbm_uint64_t            tot_loss_msgs_ever_enq;
        lbm_uint64_t            tot_req_msgs_ever_enq;
        lbm_uint64_t            tot_resp_msgs_ever_enq;
        lbm_uint64_t            tot_control_msgs_ever_enq;
        lbm_uint64_t            total_msgs_ever_enq;
        lbm_uint64_t            tot_data_bytes_ever_enq;
        lbm_uint64_t            tot_req_bytes_ever_enq;
        lbm_uint64_t            tot_resp_bytes_ever_enq;
        lbm_uint64_t            tot_control_bytes_ever_enq;
        lbm_uint64_t            total_bytes_ever_enq;
        lbm_uint64_t            tot_data_msgs_cur_enq;
        lbm_uint64_t            tot_loss_msgs_cur_enq;
        lbm_uint64_t            tot_req_msgs_cur_enq;
        lbm_uint64_t            tot_resp_msgs_cur_enq;
        lbm_uint64_t            tot_control_msgs_cur_enq;
        lbm_uint64_t            total_msgs_cur_enq;
        lbm_uint64_t            total_user_msgs_tossed_for_age;
        lbm_uint64_t            total_user_msgs_tossed_for_size;
        lbm_uint64_t            total_msgs_lost;
} umdsd_dstat_connection_totaltopic_record_t;

typedef struct umdsd_dstat_connection_totaltopic_msg_stct {
        umdsd_dstat_msg_hdr_t hdr;
        umdsd_dstat_connection_totaltopic_record_t record;
} umdsd_dstat_connection_totaltopic_msg_t;

/***************************************/

typedef struct umdsd_dstat_connection_receiver_record_stct {
        lbm_uint32_t                    topicQ_id;
        char                                    topic[ UMDS_DSTAT_LBM_MAX_TOPIC_NAME_LEN ];
} umdsd_dstat_connection_receiver_record_t;

typedef struct umdsd_dstat_connection_receiver_msg_stct {
        umdsd_dstat_msg_hdr_t hdr;
        umdsd_dstat_connection_receiver_record_t record;
} umdsd_dstat_connection_receiver_msg_t;

/***************************************/

typedef struct umdsd_dstat_connection_source_record_stct {      
        lbm_uint32_t                    topicQ_id;
        char                                    topic[ UMDS_DSTAT_LBM_MAX_TOPIC_NAME_LEN ];
} umdsd_dstat_connection_source_record_t;

typedef struct umdsd_dstat_connection_source_msg_stct { 
        umdsd_dstat_msg_hdr_t hdr;
        umdsd_dstat_connection_source_record_t record;
} umdsd_dstat_connection_source_msg_t;

/***************************************/


typedef struct umdsd_dstat_connection_attribute_record_stct {
        lbm_uint64_t            val;
        char                            attribute_name[UMDS_DSTAT_MAX_ATTR_NAME_SZ];
} umdsd_dstat_connection_attribute_record_t;

typedef struct umdsd_dstat_connection_attribute_msg_stct {
        umdsd_dstat_msg_hdr_t hdr;
        umdsd_dstat_connection_attribute_record_t attr[UMDS_DSTAT_NUM_CLIENT_ATTRS];
} umdsd_dstat_connection_attribute_msg_t;

/***************************************/

typedef struct umdsd_dstat_connection_permission_record_stct {
        lbm_uint64_t            val;
        char                            permission_name[UMDS_DSTAT_DAEMON_INFO_STRLEN ];
} umdsd_dstat_connection_permission_record_t;

typedef struct umdsd_dstat_connection_permission_msg_stct {
        umdsd_dstat_msg_hdr_t hdr;
        umdsd_dstat_connection_permission_record_t perms[UMDS_DSTAT_NUM_CLIENT_PERMS];
} umdsd_dstat_connection_permission_msg_t;


/***************************************/
typedef struct umdsd_dstat_mallinfo_record_stct {
        lbm_uint32_t arena;
        lbm_uint32_t ordblks;
        lbm_uint32_t hblks;
        lbm_uint32_t hblkhd;
        lbm_uint32_t uordblks;
        lbm_uint32_t fordblks;
}umdsd_dstat_mallinfo_record_t;

typedef struct umdsd_dstat_mallinfo_msg_stct {
        umdsd_dstat_msg_hdr_t hdr;
        umdsd_dstat_mallinfo_record_t record;
} umdsd_dstat_mallinfo_msg_t;


/***************************************/
typedef struct umdsd_dstat_smartheap_record_stct {
        lbm_uint64_t poolcount;
        lbm_uint64_t smallblocksize;
        lbm_uint64_t pagesize;
        lbm_uint64_t poolsize;
        lbm_uint32_t maj_ver;
        lbm_uint32_t min_ver;
        lbm_uint32_t upd_ver;
}umdsd_dstat_smartheap_record_t;

typedef struct umdsd_dstat_smartheap_msg_stct {
        umdsd_dstat_msg_hdr_t hdr;
        umdsd_dstat_smartheap_record_t record;
} umdsd_dstat_smartheap_msg_t;


/***************************************/

typedef struct umdsd_dstat_config_record_stct {
        char data;
} umdsd_dstat_config_record_t;

typedef struct umdsd_dstat_config_msg_stct {
        umdsd_dstat_msg_hdr_t hdr;
        umdsd_dstat_config_record_t record;
} umdsd_dstat_config_msg_t;

/***************************************/