update

wangzhengquan

2021-02-05 d8e48790913af2e735d34de2c673374f21a2d3eb

update

 src/net/net_mod_socket_wrapper.cpp

@@ -235,10 +235,9 @@


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

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

 src/socket/shm_mod_socket.cpp

@@ -3,15 +3,15 @@
static Logger *logger = LoggerFactory::getLogger();


size_t ShmModSocket::remove_keys(int keys[], size_t length) {
    BusServerSocket::remove_subscripters(keys, length);
    return shm_socket_remove_keys(keys, length);
}
// size_t ShmModSocket::remove_keys(int keys[], size_t length) {
//     BusServerSocket::remove_subscripters(keys, length);
//     return shm_socket_remove_keys(keys, length);
// }

size_t ShmModSocket::remove_keys_exclude(int keys[], size_t length) {
    BusServerSocket::remove_subscripters(keys, length);
    return shm_socket_remove_keys_exclude(keys, length);
}
// size_t ShmModSocket::remove_keys_exclude(int keys[], size_t length) {
//     BusServerSocket::remove_subscripters(keys, length);
//     return shm_socket_remove_keys_exclude(keys, length);
// }

ShmModSocket::ShmModSocket() {
    shm_socket = shm_open_socket(SHM_SOCKET_DGRAM);