commit -a

wangzhengquan

2020-07-17 3afe38168c44b59f1732f2d55ec08b8f81d879bc

commit -a

 include/usgcommon/logger.h

@@ -8,29 +8,28 @@
    std::string configFile;
    int level;

    void dolog(const char *fmt, va_list ap)
    {
  void dolog(const char *fmt, va_list ap) {
        char    buf[MAXBUF];
        vsnprintf(buf, MAXBUF-1, fmt, ap);

    struct timeval tv;
    struct tm *info;
    gettimeofday(&tv, NULL);
    info = localtime(&tv.tv_sec);
    strftime(buf, MAXLINE - 1, "%Y-%d-%m %H:%M:%S ", info);
    snprintf(buf + strlen(buf), MAXLINE - strlen(buf) - 1, "(%ld) ", tv.tv_sec * 1000000 + tv.tv_usec);

    vsnprintf(buf + strlen(buf), MAXLINE - strlen(buf) - 1, fmt, ap);
        strcat(buf, "\n");
        fflush(stdout);        /* in case stdout and stderr are the same */
        fputs(buf, stdout);
        fflush(NULL);        /* flushes all stdio output streams */
    }

public:
    enum {
        ALL ,
        DEBUG ,
        INFO ,
        WARN ,
        ERROR ,
        FATAL ,
        OFF
    };
  enum { ALL, DEBUG, INFO, WARN, ERROR, FATAL, OFF };

    Logger(int l = INFO): level(l) {}
    Logger(std::string cf);
	

    void log(int _level,  const char *fmt,  ...);


 include/usgcommon/usg_common.h

@@ -59,14 +59,18 @@
#include <fstream>
#include <sstream>
#include <string>

#include <cstdlib>
#include <atomic>
#include <algorithm>
#include <iomanip>
#include <limits>
#include <map>

#include <initializer_list>
#include <vector>
#include <map>
#include <set>

#include <thread>
 
#endif

 lib/libusgcommon.a

Binary files differ

 lib/libusgcommon.so

Binary files differ

 queue/include/mod_socket.h

New file
@@ -0,0 +1,27 @@
#ifndef __MOD_SOCKET_H__
#define __MOD_SOCKET_H__

#include "shm_socket.h"
#ifdef __cplusplus
extern "C" {
#endif

enum shm_mod_t
{
    PULL_PUSH = 1,
    REQ_REP = 2,
    PAIR = 3,
    PUB_SUB = 4,
    SURVEY = 5,
    BUS = 6
	
};




#ifdef __cplusplus
}
#endif

#endif

 queue/include/shm_socket.h

File was renamed from queue/include/socket.h
@@ -9,21 +9,10 @@
#include "mem_pool.h"
#include "hashtable.h"
#include "sem_util.h"

#ifdef __cplusplus
extern "C" {
#endif

enum shm_mod_t
{
    PULL_PUSH = 1,
    REQ_REP = 2,
    PAIR = 3,
    PUB_SUB = 4,
    SURVEY = 5,
    BUS = 6
	
};


enum shm_msg_type_t
{

 queue/libshm_queue.a

Binary files differ

 queue/mod_socket.c

New file
@@ -0,0 +1,2 @@
#include "mod_socket.h"


 queue/shm_socket.c

File was renamed from queue/socket.c
@@ -1,9 +1,10 @@

#include "socket.h"
#include "shm_socket.h"
#include "logger_factory.h"
#include <map>



static Logger logger = LoggerFactory::getLogger();

void print_msg(char *head, shm_msg_t& msg) {
    //err_msg(0, "%s: port=%d, type=%d\n", head, msg.port, msg.type);

 test/communication

Binary files differ