Add the heartbeat logic feature.

Fu Juntang

2021-09-17 5c912c70e9333298ff48f7ea15424f72ca977b99

 src/socket/bus_server_socket.h

@@ -18,6 +18,44 @@
typedef std::set<int,  std::less<int>, SHM_STL_Allocator<int> > SHMKeySet;
typedef std::map<SHMString, SHMKeySet *, std::less<SHMString>, SHM_STL_Allocator<std::pair<const SHMString, SHMKeySet *> > > SHMTopicSubMap;

typedef struct _LinkNode
{
  int data;
  int data_fix;
  int count;
    
  _LinkNode *next; 
} LinkNode;

class list
{

private:
 
  LinkNode *head;
 
public:
 
  list() {head = NULL;};
  
  void Insert(int aDate, int bDate);
  
  void Delete(int Data);
  
  int dataFixGet(int data);
  
  int dataGet(int data);
  
  void dataSet(int data, int val);
  
  int NodeNum(void);

  int nodeGet(int index);
  
  LinkNode *getHead() {return head;};
  
};

class BusServerSocket {
private:
   shm_socket_t *shm_socket;
@@ -66,6 +104,7 @@
    * @return 0 成功， 其他值 失败的错误码
   */
   int  start();
    int get_data(int val);

   /**
    * 停止bus
@@ -73,8 +112,9 @@
    * @return 0 成功， 其他值 失败的错误码
   */
   int  stop();
	 

   int check_proc(int val, const void *buf, int len, void **buf_ret, int *len_ret, \
                          const struct timespec *timeout, const int flag);
    void remove_proc(int val);

   /**
    * 获取soket key