update

wangzhengquan

2020-11-30 ed012804c8d089a3bca69574b198bdd987318f01

update

 src/queue/shm_mm_wraper.h

 src/queue/shm_mm_wrapper.c

 src/socket/dgram_mod_socket.c

@@ -7,14 +7,7 @@
} dgram_mod_socket_t;


int dgram_mod_remove_keys(int keys[], int length){
    return ShmModSocket::remove_keys(keys, length);
}

int dgram_mod_remove_key(int key){
    int keys[] = {key};
    return ShmModSocket::remove_keys(keys, 1);
}
/**
 * 创建socket
 * @return socket地址

 src/socket/dgram_mod_socket.h

@@ -2,9 +2,7 @@
#define __DGRAM_MOD_SOCKET_H__


#ifdef __cplusplus
extern "C" {
#endif


/**
 * 删除key对应的共享队列，并在bus里删除该key的订阅
@@ -124,8 +122,6 @@
 * 释放存储接收信息的buf
 */
void dgram_mod_free(void *buf) ;
#ifdef __cplusplus
}
#endif


#endif

 src/socket/net_mod_socket_wrapper.c

@@ -215,3 +215,14 @@
     
    return NetModSocket::free_recv_msg_arr(arr, len);
}



int shm_mod_socket_remove_keys(int keys[], int length){
    return ShmModSocket::remove_keys(keys, length);
}

int shm_mod_socket_remove_key(int key){
    int keys[] = {key};
    return ShmModSocket::remove_keys(keys, 1);
}

 src/socket/net_mod_socket_wrapper.h

@@ -12,6 +12,8 @@
    NetModSocket *sockt;
};



/**
 * 创建
 */
@@ -147,6 +149,17 @@
 */
void net_mod_socket_free(void *buf) ;


/**
 * 删除key对应的共享队列，并在bus里删除该key的订阅
 */
int shm_mod_socket_remove_key(int key);

/**
 * 批量删除key对应的共享队列，并在bus里删除该key的订阅
 */
int shm_mod_socket_remove_keys(int keys[], int length);

#ifdef __cplusplus
}
#endif

 src/socket/shm_stream_mod_socket.h

@@ -2,9 +2,7 @@
#define __shm_stream_mod_socket_SOCKET_H__


#ifdef __cplusplus
extern "C" {
#endif


enum socket_mod_t
{
@@ -70,8 +68,6 @@
 */
int shm_stream_mod_socket_get_key(void * _socket);

#ifdef __cplusplus
}
#endif


#endif

 test_net_socket/test_net_mod_socket.c

@@ -29,7 +29,7 @@
  printf("Start net proxy\n");
    void *serverSocket  = net_mod_server_socket_open(port);
    if(net_mod_server_socket_start(serverSocket) != 0) {
        err_msg(errno, "net_mod_server_socket_start");
        err_exit(errno, "net_mod_server_socket_start");
    }
}