update

wangzhengquan

2021-01-15 0d6000e8e75e45d83dfc5718bd249a11fcce45a3

 src/socket/shm_mod_socket.h

@@ -12,6 +12,7 @@
#include "socket_def.h"

#define BUS_HEAD_SIZE (64 + 2 * sizeof(uint32_t))
class BusServerSocket;

struct bus_head_t
{
@@ -22,14 +23,13 @@


class ShmModSocket {
friend class BusServerSocket;
private:
   shm_socket_t *shm_socket;
  socket_mod_t mod;
  
   std::set<int> *bus_set;

private:
   inline int _recvfrom_(void **buf, int *size, int *key,  struct timespec *timeout, int flags);
    
   int _sub_( char *topic, int size, int key, struct timespec *timeout, int flags);
   int _pub_( char *topic, int topic_size, void *content, int content_size, int key, struct timespec *timeout, int flags);