Changeset 1913 for pjproject/trunk/pjnath/src/pjturn-srv/turn.h

Timestamp:

Apr 9, 2008 9:38:12 AM (15 years ago)

Author:

bennylp

Message:

More ticket #485: huge changeset to support TURN TCP. Please see ticket #485 for the details

File:

• pjproject/trunk/pjnath/src/pjturn-srv/turn.h (modified) (12 diffs)

pjproject/trunk/pjnath/src/pjturn-srv/turn.h

@@ -23 +23 @@
 #include <pjnath.h>
 
-typedef struct pj_turn_relay_res            pj_turn_relay_res;
+typedef struct pj_turn_relay_res    pj_turn_relay_res;
 typedef struct pj_turn_listener     pj_turn_listener;
-typedef struct pj_turn_permission    pj_turn_permission;
-typedef struct pj_turn_allocation    pj_turn_allocation;
+typedef struct pj_turn_transport    pj_turn_transport;
+typedef struct pj_turn_permission   pj_turn_permission;
+typedef struct pj_turn_allocation   pj_turn_allocation;
 typedef struct pj_turn_srv          pj_turn_srv;
 typedef struct pj_turn_pkt          pj_turn_pkt;
@@ -133 +134 @@
     pj_lock_t           *lock;
 
-    /** TURN listener. */
-    pj_turn_listener    *listener;
-
-    /** Client socket, if connection to client is using TCP. */
-    pj_sock_t           clt_sock;
+    /** Server instance. */
+    pj_turn_srv         *server;
+
+    /** Transport to send/receive packets to/from client. */
+    pj_turn_transport   *transport;
 
     /** The relay resource for this allocation. */
@@ -181 +182 @@
     /** Hash table key */
     pj_turn_permission_key hkey;
-
-    /** Transport socket. If TCP is used, the value will be the actual
-     *  TCP socket. If UDP is used, the value will be the relay address
-     */
-    pj_sock_t           sock;
 
     /** TURN allocation that owns this permission/channel */
@@ -202 +198 @@
  * Create new allocation.
  */
-PJ_DECL(pj_status_t) pj_turn_allocation_create(pj_turn_listener *listener,
-                                              const pj_sockaddr_t *src_addr,
-                                              unsigned src_addr_len,
-                                              const pj_stun_rx_data *rdata,
-                                              pj_stun_session *srv_sess,
-                                              pj_turn_allocation **p_alloc);
+PJ_DECL(pj_status_t) pj_turn_allocation_create(pj_turn_transport *transport,
+                                               const pj_sockaddr_t *src_addr,
+                                               unsigned src_addr_len,
+                                               const pj_stun_rx_data *rdata,
+                                               pj_stun_session *srv_sess,
+                                               pj_turn_allocation **p_alloc);
 /**
  * Destroy allocation.
@@ -218 +214 @@
  */
 PJ_DECL(void) pj_turn_allocation_on_rx_client_pkt(pj_turn_allocation *alloc,
-                                                 pj_turn_pkt *pkt);
+                                                  pj_turn_pkt *pkt);
+
+/**
+ * Handle transport closure.
+ */
+PJ_DECL(void) pj_turn_allocation_on_transport_closed(pj_turn_allocation *alloc,
+                                                     pj_turn_transport *tp);
 
 /****************************************************************************/
@@ -258 +260 @@
     unsigned            flags;
 
+    /** Destroy handler */
+    pj_status_t         (*destroy)(pj_turn_listener*);
+};
+
+
+/**
+ * This structure describes TURN transport socket which is used to send and
+ * receive packets towards client.
+ */
+struct pj_turn_transport
+{
+    /** Object name/identification */
+    char                *obj_name;
+
+    /** Slightly longer info about this listener */
+    char                *info;
+
+    /** Listener instance */
+    pj_turn_listener    *listener;
+
     /** Sendto handler */
-    pj_status_t         (*sendto)(pj_turn_listener *listener,
+    pj_status_t         (*sendto)(pj_turn_transport *tp,
                                   const void *packet,
                                   pj_size_t size,
@@ -266 +288 @@
                                   int addr_len);
 
-    /** Destroy handler */
-    pj_status_t         (*destroy)(pj_turn_listener*);
+    /** Addref handler */
+    void                (*add_ref)(pj_turn_transport *tp,
+                                   pj_turn_allocation *alloc);
+
+    /** Decref handler */
+    void                (*dec_ref)(pj_turn_transport *tp,
+                                   pj_turn_allocation *alloc);
+
 };
 
@@ -279 +307 @@
     pj_pool_t               *pool;
 
-    /** Listener that owns this. */
-    pj_turn_listener        *listener;
+    /** Transport where the packet was received. */
+    pj_turn_transport       *transport;
 
     /** Packet buffer (must be 32bit aligned). */
@@ -300 +328 @@
 
 /**
- * Create a new listener on the specified port.
+ * Create a UDP listener on the specified port.
  */
 PJ_DECL(pj_status_t) pj_turn_listener_create_udp(pj_turn_srv *srv,
-                                                int af,
-                                                const pj_str_t *bound_addr,
-                                                unsigned port,
-                                                unsigned concurrency_cnt,
-                                                unsigned flags,
-                                                pj_turn_listener **p_listener);
-
-/**
- * Send packet with this listener.
- */
-PJ_DECL(pj_status_t) pj_turn_listener_sendto(pj_turn_listener *listener,
-                                            const void *packet,
-                                            pj_size_t size,
-                                            unsigned flag,
-                                            const pj_sockaddr_t *addr,
-                                            int addr_len);
+                                                 int af,
+                                                 const pj_str_t *bound_addr,
+                                                 unsigned port,
+                                                 unsigned concurrency_cnt,
+                                                 unsigned flags,
+                                                 pj_turn_listener **p_lis);
+
+/**
+ * Create a TCP listener on the specified port.
+ */
+PJ_DECL(pj_status_t) pj_turn_listener_create_tcp(pj_turn_srv *srv,
+                                                 int af,
+                                                 const pj_str_t *bound_addr,
+                                                 unsigned port,
+                                                 unsigned concurrency_cnt,
+                                                 unsigned flags,
+                                                 pj_turn_listener **p_lis);
 
 /**
@@ -324 +353 @@
  */
 PJ_DECL(pj_status_t) pj_turn_listener_destroy(pj_turn_listener *listener);
+
+
+/**
+ * Add a reference to a transport.
+ */
+PJ_DECL(void) pj_turn_transport_add_ref(pj_turn_transport *transport,
+                                        pj_turn_allocation *alloc);
+
+
+/**
+ * Decrement transport reference counter.
+ */
+PJ_DECL(void) pj_turn_transport_dec_ref(pj_turn_transport *transport,
+                                        pj_turn_allocation *alloc);
+
 
 
@@ -361 +405 @@
         pj_turn_listener **listener;
 
-        /** Array of STUN sessions, one for each listeners. */
-        pj_stun_session **stun_sess;
+        /** STUN session to handle initial Allocate request. */
+        pj_stun_session *stun_sess;
 
         /** Number of worker threads. */
@@ -457 +501 @@
  */
 PJ_DECL(void) pj_turn_srv_on_rx_pkt(pj_turn_srv *srv, 
-                                   pj_turn_pkt *pkt);
+                                    pj_turn_pkt *pkt);