peer.h

   1 #ifndef _DRAGONNET_PEER_H_
   2 #define _DRAGONNET_PEER_H_
   3
   4 #include <dragonnet/addr.h>
   5 #include <dragontype/number.h>
   6 #include <pthread.h>
   7 #include <stdbool.h>
   8
   9 typedef enum {
  10         DRAGONNET_PEER_CREATED,
  11         DRAGONNET_PEER_ACTIVE,
  12         DRAGONNET_PEER_CLOSED
  13 } DragonnetPeerState;
  14
  15 typedef struct dragonnet_peer {
  16         int sock;
  17         DragonnetAddr laddr, raddr;
  18         DragonnetPeerState state;
  19         pthread_t recv_thread;
  20
  21         bool (*on_recv)(struct dragonnet_peer *, u16, void *);
  22         void (**on_recv_type)(struct dragonnet_peer *, void *);
  23
  24         pthread_rwlock_t mu;
  25 } DragonnetPeer;
  26
  27 DragonnetPeer *dragonnet_connect(char *addr);
  28 void dragonnet_peer_set_recv_hook(DragonnetPeer *p, u16 type_id,
  29                 void (*on_recv)(struct dragonnet_peer *, void *));
  30 void dragonnet_peer_run(DragonnetPeer *p);
  31 void dragonnet_peer_close(DragonnetPeer *p);
  32 void dragonnet_peer_delete(DragonnetPeer *p);
  33
  34 #endif