vcom_monitor_pre_stat.h

Go to the documentation of this file.

#ifndef _VCOM_MONITOR_H
#define _VCOM_MONITOR_H
#define MSIZE 128
#define FNAME_LEN 256
extern void * stk_mon;
 
struct vc_monitor{
    void * addr;
    int fd;
    int pid;
    int msgl;
    char pre_stat[16];
    char fname[FNAME_LEN];
};
struct vc_monitor vc_mon;
 
static inline int mon_init(char * fname)
{
    vc_mon.fd = -1;
    vc_mon.addr = 0;
    sprintf(vc_mon.pre_stat, "NULL");
 
    if(fname <= 0)
        return 0;
 
    vc_mon.pid  = getpid();
    snprintf(vc_mon.fname, FNAME_LEN, "%s", fname);
 
    vc_mon.fd = open(vc_mon.fname, O_RDWR | O_CREAT | O_TRUNC, S_IRWXO|S_IRWXG|S_IRWXU);
    if(vc_mon.fd < 0){
        printf("create log fail...\n");
        return -1;
    }
 
    ftruncate(vc_mon.fd, MSIZE);
    vc_mon.addr = mmap(0, MSIZE, PROT_READ | PROT_WRITE, MAP_SHARED, vc_mon.fd, 0);
    if(vc_mon.addr == MAP_FAILED){
        printf("mmap fail\n");
        munmap(vc_mon.addr, MSIZE);
        close(vc_mon.fd);
        vc_mon.fd = 0;
        return -1;
    }
 
    stk_mon = &vc_mon;
    return 0;
}
 
static inline int mon_update(struct stk_vc * stk, int sig, char * dbg)
{
    char * ptr;
    char * mem;
    char * msg;
    int msgl;
    int len;
 
    if(vc_mon.fd < 0){
        return 0;
    }
 
    if(stk_empty(stk)){
        printf("stack empty ...\n");
        return -1;
    }
 
    msg = stk_curnt(stk)->name();
    mem = (char *)vc_mon.addr;
    msgl = snprintf(mem, MSIZE, "Pid : %d | State : %s -> %s ",
            vc_mon.pid, vc_mon.pre_stat, msg);
 
    len = MSIZE - msgl;
 
    if(len <= 1){
        printf("%s len <= 1\n", __func__);
        return -1;
    }
 
    snprintf(vc_mon.pre_stat, sizeof(vc_mon.pre_stat), "%s", msg);  
    
    ptr = mem + msgl;
    if(dbg != 0)
        msgl += snprintf(ptr, len, "| E : %s    \n", dbg);
 
    len = MSIZE - msgl;
    ptr = mem + msgl;
    memset(ptr + 1, 0, len - 1);
 
    if(sig){
        msync(mem, MSIZE, MS_SYNC);
        ftruncate(vc_mon.fd, MSIZE);
    }else{
        msync(mem, MSIZE, MS_ASYNC);
    }
 
    return 0;
}
 
#define muc2(a, b)      \
    do{if(stk_mon)          \
        mon_update(a, b, 0);    \
    }while(0)
 
 
#define muc3(a, b, c)       \
    do{if(stk_mon)          \
        mon_update(a, b, c);    \
    }while(0)
 
#define muc_ovrld(_1, _2, _3, func, ...) func
#define mon_update_check(args...) muc_ovrld(args, muc3, muc2,...)(args)
 
#endif