gnunet-svn
[Top][All Lists]
Advanced

[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

[GNUnet-SVN] r8822 - in gnunet/src: core include transport util


From: gnunet
Subject: [GNUnet-SVN] r8822 - in gnunet/src: core include transport util
Date: Sun, 9 Aug 2009 02:25:59 -0600

Author: durner
Date: 2009-08-09 02:25:58 -0600 (Sun, 09 Aug 2009)
New Revision: 8822

Modified:
   gnunet/src/core/core_api.c
   gnunet/src/core/gnunet-service-core.c
   gnunet/src/include/gnunet_client_lib.h
   gnunet/src/include/gnunet_network_lib.h
   gnunet/src/include/gnunet_server_lib.h
   gnunet/src/transport/plugin_transport_tcp.c
   gnunet/src/transport/transport_api.c
   gnunet/src/util/client.c
   gnunet/src/util/network.c
   gnunet/src/util/server.c
   gnunet/src/util/test_network.c
   gnunet/src/util/test_network_addressing.c
   gnunet/src/util/test_network_receive_cancel.c
   gnunet/src/util/test_network_timeout.c
   gnunet/src/util/test_network_timeout_no_connect.c
   gnunet/src/util/test_network_transmit_cancel.c
Log:
rename NETWORK_socket API to NETWORK_connection (to make room for the new 
actual NET API)

Modified: gnunet/src/core/core_api.c
===================================================================
--- gnunet/src/core/core_api.c  2009-08-08 14:10:24 UTC (rev 8821)
+++ gnunet/src/core/core_api.c  2009-08-09 08:25:58 UTC (rev 8822)
@@ -836,7 +836,7 @@
 GNUNET_CORE_disconnect (struct GNUNET_CORE_Handle *handle)
 {
   if (handle->th != NULL)
-    GNUNET_NETWORK_notify_transmit_ready_cancel (handle->th);
+    GNUNET_NETWORK_connection_notify_transmit_ready_cancel (handle->th);
   if (handle->reconnect_task != GNUNET_SCHEDULER_NO_TASK)
     GNUNET_SCHEDULER_cancel (handle->sched, handle->reconnect_task);
   GNUNET_CLIENT_disconnect (handle->client);

Modified: gnunet/src/core/gnunet-service-core.c
===================================================================
--- gnunet/src/core/gnunet-service-core.c       2009-08-08 14:10:24 UTC (rev 
8821)
+++ gnunet/src/core/gnunet-service-core.c       2009-08-09 08:25:58 UTC (rev 
8822)
@@ -1021,7 +1021,7 @@
           else
             prev->next = pos->next;
           if (pos->th != NULL)
-            GNUNET_NETWORK_notify_transmit_ready_cancel (pos->th);
+            GNUNET_NETWORK_connection_notify_transmit_ready_cancel (pos->th);
          while (NULL != (e = pos->event_head))
            {
              pos->event_head = e->next;

Modified: gnunet/src/include/gnunet_client_lib.h
===================================================================
--- gnunet/src/include/gnunet_client_lib.h      2009-08-08 14:10:24 UTC (rev 
8821)
+++ gnunet/src/include/gnunet_client_lib.h      2009-08-09 08:25:58 UTC (rev 
8822)
@@ -109,7 +109,7 @@
  * @param notify_cls closure for notify
  * @return NULL if someone else is already waiting to be notified
  *         non-NULL if the notify callback was queued (can be used to cancel
- *         using GNUNET_NETWORK_notify_transmit_ready_cancel)
+ *         using GNUNET_NETWORK_connection_notify_transmit_ready_cancel)
  */
 struct GNUNET_NETWORK_TransmitHandle
   *GNUNET_CLIENT_notify_transmit_ready (struct GNUNET_CLIENT_Connection *sock,

Modified: gnunet/src/include/gnunet_network_lib.h
===================================================================
--- gnunet/src/include/gnunet_network_lib.h     2009-08-08 14:10:24 UTC (rev 
8821)
+++ gnunet/src/include/gnunet_network_lib.h     2009-08-09 08:25:58 UTC (rev 
8822)
@@ -44,9 +44,9 @@
 #define GNUNET_NETWORK_CONNECT_RETRY_TIMEOUT GNUNET_TIME_relative_multiply 
(GNUNET_TIME_UNIT_SECONDS, 5)
 
 /**
- * @brief handle for a network socket
+ * @brief handle for a network connection
  */
-struct GNUNET_NETWORK_SocketHandle;
+struct GNUNET_NETWORK_ConnectionHandle;
 
 
 /**
@@ -93,8 +93,8 @@
  *        0 for sockets that need no write buffers, such as listen sockets)
  * @return the boxed socket handle
  */
-struct GNUNET_NETWORK_SocketHandle
-  *GNUNET_NETWORK_socket_create_from_existing (struct GNUNET_SCHEDULER_Handle
+struct GNUNET_NETWORK_ConnectionHandle
+  *GNUNET_NETWORK_connection_create_from_existing (struct 
GNUNET_SCHEDULER_Handle
                                                *sched, int osSocket,
                                                size_t maxbuf);
 
@@ -111,8 +111,8 @@
  *        0 for sockets that need no write buffers, such as listen sockets)
  * @return the socket handle, NULL on error (for example, access refused)
  */
-struct GNUNET_NETWORK_SocketHandle
-  *GNUNET_NETWORK_socket_create_from_accept (struct GNUNET_SCHEDULER_Handle
+struct GNUNET_NETWORK_ConnectionHandle
+  *GNUNET_NETWORK_connection_create_from_accept (struct GNUNET_SCHEDULER_Handle
                                              *sched,
                                              GNUNET_NETWORK_AccessCheck
                                              access, void *access_cls,
@@ -131,8 +131,8 @@
  *        0 for sockets that need no write buffers, such as listen sockets)
  * @return the socket handle
  */
-struct GNUNET_NETWORK_SocketHandle
-  *GNUNET_NETWORK_socket_create_from_connect (struct GNUNET_SCHEDULER_Handle
+struct GNUNET_NETWORK_ConnectionHandle
+  *GNUNET_NETWORK_connection_create_from_connect (struct 
GNUNET_SCHEDULER_Handle
                                               *sched, const char *hostname,
                                               uint16_t port, size_t maxbuf);
 
@@ -151,8 +151,8 @@
  *        0 for sockets that need no write buffers, such as listen sockets)
  * @return the socket handle
  */
-struct GNUNET_NETWORK_SocketHandle
-  *GNUNET_NETWORK_socket_create_from_sockaddr (struct GNUNET_SCHEDULER_Handle
+struct GNUNET_NETWORK_ConnectionHandle
+  *GNUNET_NETWORK_connection_create_from_sockaddr (struct 
GNUNET_SCHEDULER_Handle
                                                *sched, int af_family,
                                                const struct sockaddr
                                                *serv_addr, socklen_t addrlen,
@@ -166,7 +166,7 @@
  * @param sock socket to check
  * @return GNUNET_YES if valid, GNUNET_NO otherwise
  */
-int GNUNET_NETWORK_socket_check (struct GNUNET_NETWORK_SocketHandle *sock);
+int GNUNET_NETWORK_connection_check (struct GNUNET_NETWORK_ConnectionHandle 
*sock);
 
 
 /**
@@ -177,7 +177,7 @@
  * @param addrlen where to store the length of the address
  * @return GNUNET_OK on success
  */
-int GNUNET_NETWORK_socket_get_address (struct GNUNET_NETWORK_SocketHandle
+int GNUNET_NETWORK_connection_get_address (struct 
GNUNET_NETWORK_ConnectionHandle
                                        *sock, void **addr, size_t * addrlen);
 
 /**
@@ -187,7 +187,7 @@
  *
  * @param sock socket to destroy
  */
-void GNUNET_NETWORK_socket_destroy (struct GNUNET_NETWORK_SocketHandle *sock);
+void GNUNET_NETWORK_connection_destroy (struct GNUNET_NETWORK_ConnectionHandle 
*sock);
 
 
 /**
@@ -205,7 +205,7 @@
  * @return scheduler task ID used for receiving, GNUNET_SCHEDULER_NO_TASK on 
error
  */
 GNUNET_SCHEDULER_TaskIdentifier
-GNUNET_NETWORK_receive (struct GNUNET_NETWORK_SocketHandle *sock,
+GNUNET_NETWORK_connection_receive (struct GNUNET_NETWORK_ConnectionHandle 
*sock,
                         size_t max,
                         struct GNUNET_TIME_Relative timeout,
                         GNUNET_NETWORK_Receiver receiver, void *receiver_cls);
@@ -220,7 +220,7 @@
  * @param task task identifier returned from the receive call
  * @return closure of the original receiver callback
  */
-void *GNUNET_NETWORK_receive_cancel (struct GNUNET_NETWORK_SocketHandle *sock,
+void *GNUNET_NETWORK_connection_receive_cancel (struct 
GNUNET_NETWORK_ConnectionHandle *sock,
                                      GNUNET_SCHEDULER_TaskIdentifier task);
 
 
@@ -275,7 +275,7 @@
  *         NULL if we are already going to notify someone else (busy)
  */
 struct GNUNET_NETWORK_TransmitHandle
-  *GNUNET_NETWORK_notify_transmit_ready (struct GNUNET_NETWORK_SocketHandle
+  *GNUNET_NETWORK_connection_notify_transmit_ready (struct 
GNUNET_NETWORK_ConnectionHandle
                                          *sock, size_t size,
                                          struct GNUNET_TIME_Relative timeout,
                                          GNUNET_NETWORK_TransmitReadyNotify
@@ -289,7 +289,7 @@
  * @param h handle for notification to cancel
  */
 void
-GNUNET_NETWORK_notify_transmit_ready_cancel (struct
+GNUNET_NETWORK_connection_notify_transmit_ready_cancel (struct
                                              GNUNET_NETWORK_TransmitHandle
                                              *h);
 

Modified: gnunet/src/include/gnunet_server_lib.h
===================================================================
--- gnunet/src/include/gnunet_server_lib.h      2009-08-08 14:10:24 UTC (rev 
8821)
+++ gnunet/src/include/gnunet_server_lib.h      2009-08-09 08:25:58 UTC (rev 
8822)
@@ -175,7 +175,7 @@
  * @param callback_cls closure for callback
  * @return non-NULL if the notify callback was queued; can be used
  *           to cancel the request using
- *           GNUNET_NETWORK_notify_transmit_ready_cancel.
+ *           GNUNET_NETWORK_connection_notify_transmit_ready_cancel.
  *         NULL if we are already going to notify someone else (busy)
  */
 struct GNUNET_NETWORK_TransmitHandle
@@ -238,7 +238,7 @@
                                                            GNUNET_SERVER_Handle
                                                            *server,
                                                            struct
-                                                           
GNUNET_NETWORK_SocketHandle
+                                                           
GNUNET_NETWORK_ConnectionHandle
                                                            *connection);
 
 

Modified: gnunet/src/transport/plugin_transport_tcp.c
===================================================================
--- gnunet/src/transport/plugin_transport_tcp.c 2009-08-08 14:10:24 UTC (rev 
8821)
+++ gnunet/src/transport/plugin_transport_tcp.c 2009-08-09 08:25:58 UTC (rev 
8822)
@@ -357,7 +357,7 @@
   /**
    * The listen socket.
    */
-  struct GNUNET_NETWORK_SocketHandle *lsock;
+  struct GNUNET_NETWORK_ConnectionHandle *lsock;
 
   /**
    * List of open TCP sessions.
@@ -652,7 +652,7 @@
                                       const void *addr, size_t addrlen)
 {
   struct GNUNET_SERVER_Client *client;
-  struct GNUNET_NETWORK_SocketHandle *conn;
+  struct GNUNET_NETWORK_ConnectionHandle *conn;
   struct Session *session;
   int af;
 
@@ -665,7 +665,7 @@
       GNUNET_break_op (0);
       return NULL;              /* invalid address */
     }
-  conn = GNUNET_NETWORK_socket_create_from_sockaddr (plugin->env->sched,
+  conn = GNUNET_NETWORK_connection_create_from_sockaddr (plugin->env->sched,
                                                      af,
                                                      addr,
                                                      addrlen,
@@ -796,7 +796,7 @@
   /* clean up state */
   if (session->transmit_handle != NULL)
     {
-      GNUNET_NETWORK_notify_transmit_ready_cancel (session->transmit_handle);
+      GNUNET_NETWORK_connection_notify_transmit_ready_cancel 
(session->transmit_handle);
       session->transmit_handle = NULL;
     }
   while (NULL != (pm = session->pending_messages))
@@ -877,7 +877,7 @@
 {
   struct Plugin *plugin;
 
-  struct GNUNET_NETWORK_SocketHandle *sa;
+  struct GNUNET_NETWORK_ConnectionHandle *sa;
 
   struct PendingMessage *welcome;
 
@@ -923,7 +923,7 @@
     {
       cc->welcome = create_welcome (addrlen, addr, cc->plugin);
       cc->sa =
-        GNUNET_NETWORK_socket_create_from_sockaddr (cc->plugin->env->sched,
+        GNUNET_NETWORK_connection_create_from_sockaddr (cc->plugin->env->sched,
                                                     af, addr, addrlen,
                                                     
GNUNET_SERVER_MAX_MESSAGE_SIZE);
 #if DEBUG_TCP

Modified: gnunet/src/transport/transport_api.c
===================================================================
--- gnunet/src/transport/transport_api.c        2009-08-08 14:10:24 UTC (rev 
8821)
+++ gnunet/src/transport/transport_api.c        2009-08-09 08:25:58 UTC (rev 
8822)
@@ -1573,7 +1573,7 @@
 #endif
           if (h->network_handle != NULL)
             {
-              GNUNET_NETWORK_notify_transmit_ready_cancel (h->network_handle);
+              GNUNET_NETWORK_connection_notify_transmit_ready_cancel 
(h->network_handle);
               h->network_handle = NULL;
               h->transmission_scheduled = GNUNET_NO;
              th = h->connect_ready_head;
@@ -1964,7 +1964,7 @@
   h = th->handle;
   if ((h->connect_ready_head == NULL) && (h->network_handle != NULL))
     {
-      GNUNET_NETWORK_notify_transmit_ready_cancel (h->network_handle);
+      GNUNET_NETWORK_connection_notify_transmit_ready_cancel 
(h->network_handle);
       h->network_handle = NULL;
       h->transmission_scheduled = GNUNET_NO;
     }

Modified: gnunet/src/util/client.c
===================================================================
--- gnunet/src/util/client.c    2009-08-08 14:10:24 UTC (rev 8821)
+++ gnunet/src/util/client.c    2009-08-09 08:25:58 UTC (rev 8822)
@@ -48,7 +48,7 @@
   /**
    * the socket handle, NULL if not live
    */
-  struct GNUNET_NETWORK_SocketHandle *sock;
+  struct GNUNET_NETWORK_ConnectionHandle *sock;
 
   /**
    * Our scheduler.
@@ -127,7 +127,7 @@
                        const struct GNUNET_CONFIGURATION_Handle *cfg)
 {
   struct GNUNET_CLIENT_Connection *ret;
-  struct GNUNET_NETWORK_SocketHandle *sock;
+  struct GNUNET_NETWORK_ConnectionHandle *sock;
   char *hostname;
   unsigned long long port;
 
@@ -147,7 +147,7 @@
                   service_name);
       return NULL;
     }
-  sock = GNUNET_NETWORK_socket_create_from_connect (sched,
+  sock = GNUNET_NETWORK_connection_create_from_connect (sched,
                                                     hostname,
                                                     port,
                                                     
GNUNET_SERVER_MAX_MESSAGE_SIZE);
@@ -184,7 +184,7 @@
 GNUNET_CLIENT_disconnect (struct GNUNET_CLIENT_Connection *sock)
 {
   GNUNET_assert (sock->sock != NULL);
-  GNUNET_NETWORK_socket_destroy (sock->sock);
+  GNUNET_NETWORK_connection_destroy (sock->sock);
   sock->sock = NULL;
   sock->receiver_handler = NULL;
   GNUNET_SCHEDULER_add_after (sock->sched,
@@ -331,7 +331,7 @@
                                                       GNUNET_SCHEDULER_NO_TASK,
                                                       &receive_task, sock);
   else
-    sock->receiver_task = GNUNET_NETWORK_receive (sock->sock,
+    sock->receiver_task = GNUNET_NETWORK_connection_receive (sock->sock,
                                                   
GNUNET_SERVER_MAX_MESSAGE_SIZE,
                                                   timeout,
                                                   &receive_helper, sock);
@@ -362,7 +362,7 @@
 void
 GNUNET_CLIENT_service_shutdown (struct GNUNET_CLIENT_Connection *sock)
 {
-  GNUNET_NETWORK_notify_transmit_ready (sock->sock,
+  GNUNET_NETWORK_connection_notify_transmit_ready (sock->sock,
                                         sizeof (struct GNUNET_MessageHeader),
                                         GNUNET_TIME_UNIT_FOREVER_REL,
                                         &write_shutdown, NULL);
@@ -478,7 +478,7 @@
   conn->test_cb = task;
   conn->test_cb_cls = task_cls;
   if (NULL ==
-      GNUNET_NETWORK_notify_transmit_ready (conn->sock,
+      GNUNET_NETWORK_connection_notify_transmit_ready (conn->sock,
                                             sizeof (struct
                                                     GNUNET_MessageHeader),
                                             timeout, &write_test, NULL))
@@ -515,7 +515,7 @@
                                      GNUNET_NETWORK_TransmitReadyNotify
                                      notify, void *notify_cls)
 {
-  return GNUNET_NETWORK_notify_transmit_ready (sock->sock,
+  return GNUNET_NETWORK_connection_notify_transmit_ready (sock->sock,
                                                size,
                                                timeout, notify, notify_cls);
 }

Modified: gnunet/src/util/network.c
===================================================================
--- gnunet/src/util/network.c   2009-08-08 14:10:24 UTC (rev 8821)
+++ gnunet/src/util/network.c   2009-08-09 08:25:58 UTC (rev 8822)
@@ -66,7 +66,7 @@
   /**
    * Our socket handle.
    */
-  struct GNUNET_NETWORK_SocketHandle *sh;
+  struct GNUNET_NETWORK_ConnectionHandle *sh;
 
   /**
    * Timeout for receiving (in absolute time).
@@ -89,7 +89,7 @@
 /**
  * @brief handle for a network socket
  */
-struct GNUNET_NETWORK_SocketHandle
+struct GNUNET_NETWORK_ConnectionHandle
 {
 
   /**
@@ -167,7 +167,7 @@
   GNUNET_SCHEDULER_TaskIdentifier write_task;
 
   /**
-   * The handle we return for GNUNET_NETWORK_notify_transmit_ready.
+   * The handle we return for GNUNET_NETWORK_connection_notify_transmit_ready.
    */
   struct GNUNET_NETWORK_TransmitHandle nth;
 
@@ -217,13 +217,13 @@
  *        0 for sockets that need no write buffers, such as listen sockets)
  * @return the boxed socket handle
  */
-struct GNUNET_NETWORK_SocketHandle *
-GNUNET_NETWORK_socket_create_from_existing (struct GNUNET_SCHEDULER_Handle
+struct GNUNET_NETWORK_ConnectionHandle *
+GNUNET_NETWORK_connection_create_from_existing (struct GNUNET_SCHEDULER_Handle
                                             *sched, int osSocket,
                                             size_t maxbuf)
 {
-  struct GNUNET_NETWORK_SocketHandle *ret;
-  ret = GNUNET_malloc (sizeof (struct GNUNET_NETWORK_SocketHandle) + maxbuf);
+  struct GNUNET_NETWORK_ConnectionHandle *ret;
+  ret = GNUNET_malloc (sizeof (struct GNUNET_NETWORK_ConnectionHandle) + 
maxbuf);
   ret->write_buffer = (char *) &ret[1];
   ret->write_buffer_size = maxbuf;
   ret->sock = osSocket;
@@ -244,14 +244,14 @@
  *        0 for sockets that need no write buffers, such as listen sockets)
  * @return the socket handle, NULL on error
  */
-struct GNUNET_NETWORK_SocketHandle *
-GNUNET_NETWORK_socket_create_from_accept (struct GNUNET_SCHEDULER_Handle
+struct GNUNET_NETWORK_ConnectionHandle *
+GNUNET_NETWORK_connection_create_from_accept (struct GNUNET_SCHEDULER_Handle
                                           *sched,
                                           GNUNET_NETWORK_AccessCheck access,
                                           void *access_cls, int lsock,
                                           size_t maxbuf)
 {
-  struct GNUNET_NETWORK_SocketHandle *ret;
+  struct GNUNET_NETWORK_ConnectionHandle *ret;
   char addr[32];
   socklen_t addrlen;
   int fd;
@@ -320,7 +320,7 @@
              _("Accepting connection from `%s'\n"),
              GNUNET_a2s(uaddr, addrlen));
 #endif
-  ret = GNUNET_malloc (sizeof (struct GNUNET_NETWORK_SocketHandle) + maxbuf);
+  ret = GNUNET_malloc (sizeof (struct GNUNET_NETWORK_ConnectionHandle) + 
maxbuf);
   ret->write_buffer = (char *) &ret[1];
   ret->write_buffer_size = maxbuf;
   ret->addr = uaddr;
@@ -339,7 +339,7 @@
  * @return GNUNET_OK on success
  */
 int
-GNUNET_NETWORK_socket_get_address (struct GNUNET_NETWORK_SocketHandle *sock,
+GNUNET_NETWORK_connection_get_address (struct GNUNET_NETWORK_ConnectionHandle 
*sock,
                                    void **addr, size_t * addrlen)
 {
   if ((sock->addr == NULL) || (sock->addrlen == 0))
@@ -414,7 +414,7 @@
  * families as specified in the "address_families" array.
  */
 static void
-try_lookup (struct GNUNET_NETWORK_SocketHandle *sock)
+try_lookup (struct GNUNET_NETWORK_ConnectionHandle *sock)
 {
   struct addrinfo hints;
   int ec;
@@ -446,7 +446,7 @@
  * @return GNUNET_SYSERR error (no more addresses to try)
  */
 static int
-try_connect (struct GNUNET_NETWORK_SocketHandle *sock)
+try_connect (struct GNUNET_NETWORK_ConnectionHandle *sock)
 {
   int s;
 
@@ -536,7 +536,7 @@
 connect_continuation (void *cls,
                       const struct GNUNET_SCHEDULER_TaskContext *tc)
 {
-  struct GNUNET_NETWORK_SocketHandle *sock = cls;
+  struct GNUNET_NETWORK_ConnectionHandle *sock = cls;
   unsigned int len;
   int error;
 
@@ -605,14 +605,14 @@
  *        0 for sockets that need no write buffers, such as listen sockets)
  * @return the socket handle
  */
-struct GNUNET_NETWORK_SocketHandle *
-GNUNET_NETWORK_socket_create_from_connect (struct GNUNET_SCHEDULER_Handle
+struct GNUNET_NETWORK_ConnectionHandle *
+GNUNET_NETWORK_connection_create_from_connect (struct GNUNET_SCHEDULER_Handle
                                            *sched, const char *hostname,
                                            uint16_t port, size_t maxbuf)
 {
-  struct GNUNET_NETWORK_SocketHandle *ret;
+  struct GNUNET_NETWORK_ConnectionHandle *ret;
 
-  ret = GNUNET_malloc (sizeof (struct GNUNET_NETWORK_SocketHandle) + maxbuf);
+  ret = GNUNET_malloc (sizeof (struct GNUNET_NETWORK_ConnectionHandle) + 
maxbuf);
   ret->sock = -1;
   ret->sched = sched;
   ret->write_buffer = (char *) &ret[1];
@@ -652,14 +652,14 @@
  *        0 for sockets that need no write buffers, such as listen sockets)
  * @return the socket handle
  */
-struct GNUNET_NETWORK_SocketHandle *
-GNUNET_NETWORK_socket_create_from_sockaddr (struct GNUNET_SCHEDULER_Handle
+struct GNUNET_NETWORK_ConnectionHandle *
+GNUNET_NETWORK_connection_create_from_sockaddr (struct GNUNET_SCHEDULER_Handle
                                             *sched, int af_family,
                                             const struct sockaddr *serv_addr,
                                             socklen_t addrlen, size_t maxbuf)
 {
   int s;
-  struct GNUNET_NETWORK_SocketHandle *ret;
+  struct GNUNET_NETWORK_ConnectionHandle *ret;
 
   s = SOCKET (af_family, SOCK_STREAM, 0);
   if (s == -1)
@@ -691,7 +691,7 @@
       GNUNET_break (0 == CLOSE (s));
       return NULL;
     }
-  ret = GNUNET_NETWORK_socket_create_from_existing (sched, s, maxbuf);
+  ret = GNUNET_NETWORK_connection_create_from_existing (sched, s, maxbuf);
   ret->addr = GNUNET_malloc (addrlen);
   memcpy (ret->addr, serv_addr, addrlen);
   ret->addrlen = addrlen;
@@ -708,7 +708,7 @@
  * @return GNUNET_YES if valid, GNUNET_NO otherwise
  */
 int
-GNUNET_NETWORK_socket_check (struct GNUNET_NETWORK_SocketHandle *sock)
+GNUNET_NETWORK_connection_check (struct GNUNET_NETWORK_ConnectionHandle *sock)
 {
   if (sock->ai != NULL)
     return GNUNET_YES;          /* still trying to connect */
@@ -724,7 +724,7 @@
 destroy_continuation (void *cls,
                       const struct GNUNET_SCHEDULER_TaskContext *tc)
 {
-  struct GNUNET_NETWORK_SocketHandle *sock = cls;
+  struct GNUNET_NETWORK_ConnectionHandle *sock = cls;
   GNUNET_NETWORK_TransmitReadyNotify notify;
 
   if (sock->write_task != GNUNET_SCHEDULER_NO_TASK)
@@ -780,7 +780,7 @@
  * @param sock socket to destroy
  */
 void
-GNUNET_NETWORK_socket_destroy (struct GNUNET_NETWORK_SocketHandle *sock)
+GNUNET_NETWORK_connection_destroy (struct GNUNET_NETWORK_ConnectionHandle 
*sock)
 {
   if (sock->write_buffer_off == 0)
     sock->ai_pos = NULL;        /* if we're still trying to connect and have
@@ -797,7 +797,7 @@
  * Tell the receiver callback that a timeout was reached.
  */
 static void
-signal_timeout (struct GNUNET_NETWORK_SocketHandle *sh)
+signal_timeout (struct GNUNET_NETWORK_ConnectionHandle *sh)
 {
   GNUNET_NETWORK_Receiver receiver;
 
@@ -815,7 +815,7 @@
  * Tell the receiver callback that we had an IO error.
  */
 static void
-signal_error (struct GNUNET_NETWORK_SocketHandle *sh, int errcode)
+signal_error (struct GNUNET_NETWORK_ConnectionHandle *sh, int errcode)
 {
   GNUNET_NETWORK_Receiver receiver;
   GNUNET_assert (NULL != (receiver = sh->receiver));
@@ -831,7 +831,7 @@
 static void
 receive_ready (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc)
 {
-  struct GNUNET_NETWORK_SocketHandle *sh = cls;
+  struct GNUNET_NETWORK_ConnectionHandle *sh = cls;
   struct GNUNET_TIME_Absolute now;
   char buffer[sh->max];
   ssize_t ret;
@@ -904,7 +904,7 @@
 static void
 receive_again (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc)
 {
-  struct GNUNET_NETWORK_SocketHandle *sh = cls;
+  struct GNUNET_NETWORK_ConnectionHandle *sh = cls;
   struct GNUNET_TIME_Absolute now;
 
   sh->read_task = GNUNET_SCHEDULER_NO_TASK;
@@ -968,7 +968,7 @@
  * @return scheduler task ID used for receiving, GNUNET_SCHEDULER_NO_TASK on 
error
  */
 GNUNET_SCHEDULER_TaskIdentifier
-GNUNET_NETWORK_receive (struct GNUNET_NETWORK_SocketHandle *sock,
+GNUNET_NETWORK_connection_receive (struct GNUNET_NETWORK_ConnectionHandle 
*sock,
                         size_t max,
                         struct GNUNET_TIME_Relative timeout,
                         GNUNET_NETWORK_Receiver receiver, void *receiver_cls)
@@ -999,7 +999,7 @@
  * @return closure of the original receiver callback
  */
 void *
-GNUNET_NETWORK_receive_cancel (struct GNUNET_NETWORK_SocketHandle *sock,
+GNUNET_NETWORK_connection_receive_cancel (struct 
GNUNET_NETWORK_ConnectionHandle *sock,
                                GNUNET_SCHEDULER_TaskIdentifier task)
 {
   GNUNET_assert (sock->read_task == task);
@@ -1018,7 +1018,7 @@
  * @return GNUNET_YES if we were able to call notify
  */
 static int
-process_notify (struct GNUNET_NETWORK_SocketHandle *sock)
+process_notify (struct GNUNET_NETWORK_ConnectionHandle *sock)
 {
   size_t used;
   size_t avail;
@@ -1067,7 +1067,7 @@
 static void
 transmit_timeout (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc)
 {
-  struct GNUNET_NETWORK_SocketHandle *sock = cls;
+  struct GNUNET_NETWORK_ConnectionHandle *sock = cls;
   GNUNET_NETWORK_TransmitReadyNotify notify;
 
 #if DEBUG_NETWORK
@@ -1080,7 +1080,7 @@
 
 
 static void
-transmit_error (struct GNUNET_NETWORK_SocketHandle *sock)
+transmit_error (struct GNUNET_NETWORK_ConnectionHandle *sock)
 {
   if (sock->nth.notify_ready == NULL)
     return;                     /* nobody to tell about it */
@@ -1101,7 +1101,7 @@
 static void
 transmit_ready (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc)
 {
-  struct GNUNET_NETWORK_SocketHandle *sock = cls;
+  struct GNUNET_NETWORK_ConnectionHandle *sock = cls;
   ssize_t ret;
   size_t have;
 
@@ -1221,7 +1221,7 @@
  *         NULL if we are already going to notify someone else (busy)
  */
 struct GNUNET_NETWORK_TransmitHandle *
-GNUNET_NETWORK_notify_transmit_ready (struct GNUNET_NETWORK_SocketHandle
+GNUNET_NETWORK_connection_notify_transmit_ready (struct 
GNUNET_NETWORK_ConnectionHandle
                                       *sock, size_t size,
                                       struct GNUNET_TIME_Relative timeout,
                                       GNUNET_NETWORK_TransmitReadyNotify
@@ -1285,7 +1285,7 @@
  * notification.
  */
 void
-GNUNET_NETWORK_notify_transmit_ready_cancel (struct
+GNUNET_NETWORK_connection_notify_transmit_ready_cancel (struct
                                              GNUNET_NETWORK_TransmitHandle *h)
 {
   GNUNET_assert (h->notify_ready != NULL);

Modified: gnunet/src/util/server.c
===================================================================
--- gnunet/src/util/server.c    2009-08-08 14:10:24 UTC (rev 8821)
+++ gnunet/src/util/server.c    2009-08-09 08:25:58 UTC (rev 8822)
@@ -312,7 +312,7 @@
                        const struct GNUNET_SCHEDULER_TaskContext *tc)
 {
   struct GNUNET_SERVER_Handle *server = cls;
-  struct GNUNET_NETWORK_SocketHandle *sock;
+  struct GNUNET_NETWORK_ConnectionHandle *sock;
   struct GNUNET_SERVER_Client *client;
   fd_set r;
 
@@ -329,7 +329,7 @@
     }
   GNUNET_assert (FD_ISSET (server->listen_socket, tc->read_ready));
   GNUNET_assert (!FD_ISSET (server->shutpipe[0], tc->read_ready));
-  sock = GNUNET_NETWORK_socket_create_from_accept (tc->sched,
+  sock = GNUNET_NETWORK_connection_create_from_accept (tc->sched,
                                                    server->access,
                                                    server->access_cls,
                                                    server->listen_socket,
@@ -867,20 +867,20 @@
               struct GNUNET_TIME_Relative timeout,
               GNUNET_NETWORK_Receiver receiver, void *receiver_cls)
 {
-  return GNUNET_NETWORK_receive (cls, max, timeout, receiver, receiver_cls);
+  return GNUNET_NETWORK_connection_receive (cls, max, timeout, receiver, 
receiver_cls);
 }
 
 
 /**
  * Wrapper to cancel receiving from a socket.
  * 
- * @param cls handle to the GNUNET_NETWORK_SocketHandle to cancel
- * @param tc task ID that was returned by GNUNET_NETWORK_receive
+ * @param cls handle to the GNUNET_NETWORK_ConnectionHandle to cancel
+ * @param tc task ID that was returned by GNUNET_NETWORK_connection_receive
  */
 static void
 sock_receive_cancel (void *cls, GNUNET_SCHEDULER_TaskIdentifier ti)
 {
-  GNUNET_NETWORK_receive_cancel (cls, ti);
+  GNUNET_NETWORK_connection_receive_cancel (cls, ti);
 }
 
 
@@ -894,7 +894,7 @@
                             GNUNET_NETWORK_TransmitReadyNotify notify,
                             void *notify_cls)
 {
-  return GNUNET_NETWORK_notify_transmit_ready (cls, size, timeout, notify,
+  return GNUNET_NETWORK_connection_notify_transmit_ready (cls, size, timeout, 
notify,
                                                notify_cls);
 }
 
@@ -905,7 +905,7 @@
 static void
 sock_notify_transmit_ready_cancel (void *cls, void *h)
 {
-  GNUNET_NETWORK_notify_transmit_ready_cancel (h);
+  GNUNET_NETWORK_connection_notify_transmit_ready_cancel (h);
 }
 
 
@@ -918,7 +918,7 @@
 static int
 sock_check (void *cls)
 {
-  return GNUNET_NETWORK_socket_check (cls);
+  return GNUNET_NETWORK_connection_check (cls);
 }
 
 
@@ -930,7 +930,7 @@
 static void
 sock_destroy (void *cls)
 {
-  GNUNET_NETWORK_socket_destroy (cls);
+  GNUNET_NETWORK_connection_destroy (cls);
 }
 
 
@@ -950,7 +950,7 @@
 GNUNET_SERVER_connect_socket (struct
                               GNUNET_SERVER_Handle
                               *server,
-                              struct GNUNET_NETWORK_SocketHandle *connection)
+                              struct GNUNET_NETWORK_ConnectionHandle 
*connection)
 {
   struct GNUNET_SERVER_Client *client;
 
@@ -1064,7 +1064,7 @@
 {
   if (client->receive != &sock_receive)
     return GNUNET_SYSERR;       /* not a network client */
-  return GNUNET_NETWORK_socket_get_address (client->client_closure,
+  return GNUNET_NETWORK_connection_get_address (client->client_closure,
                                             addr, addrlen);
 }
 
@@ -1127,7 +1127,7 @@
  * @param callback_cls closure for callback
  * @return non-NULL if the notify callback was queued; can be used
  *           to cancel the request using
- *           GNUNET_NETWORK_notify_transmit_ready_cancel.
+ *           GNUNET_NETWORK_connection_notify_transmit_ready_cancel.
  *         NULL if we are already going to notify someone else (busy)
  */
 struct GNUNET_NETWORK_TransmitHandle *

Modified: gnunet/src/util/test_network.c
===================================================================
--- gnunet/src/util/test_network.c      2009-08-08 14:10:24 UTC (rev 8821)
+++ gnunet/src/util/test_network.c      2009-08-09 08:25:58 UTC (rev 8822)
@@ -32,11 +32,11 @@
 #define PORT 12435
 
 
-static struct GNUNET_NETWORK_SocketHandle *csock;
+static struct GNUNET_NETWORK_ConnectionHandle *csock;
 
-static struct GNUNET_NETWORK_SocketHandle *asock;
+static struct GNUNET_NETWORK_ConnectionHandle *asock;
 
-static struct GNUNET_NETWORK_SocketHandle *lsock;
+static struct GNUNET_NETWORK_ConnectionHandle *lsock;
 
 static size_t sofar;
 
@@ -88,7 +88,7 @@
 #if VERBOSE
       GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Receive needs more data\n");
 #endif
-      GNUNET_NETWORK_receive (asock,
+      GNUNET_NETWORK_connection_receive (asock,
                               1024,
                               GNUNET_TIME_relative_multiply
                               (GNUNET_TIME_UNIT_SECONDS, 5), &receive_check,
@@ -101,7 +101,7 @@
                   "Receive closes accepted socket\n");
 #endif
       *ok = 0;
-      GNUNET_NETWORK_socket_destroy (asock);
+      GNUNET_NETWORK_connection_destroy (asock);
     }
 }
 
@@ -112,19 +112,19 @@
 #if VERBOSE
   GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Test accepts connection\n");
 #endif
-  asock = GNUNET_NETWORK_socket_create_from_accept (tc->sched,
+  asock = GNUNET_NETWORK_connection_create_from_accept (tc->sched,
                                                     NULL, NULL, ls, 1024);
   GNUNET_assert (asock != NULL);
-  GNUNET_assert (GNUNET_YES == GNUNET_NETWORK_socket_check (asock));
+  GNUNET_assert (GNUNET_YES == GNUNET_NETWORK_connection_check (asock));
 #if VERBOSE
   GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Test destroys listen socket\n");
 #endif
-  GNUNET_NETWORK_socket_destroy (lsock);
+  GNUNET_NETWORK_connection_destroy (lsock);
 #if VERBOSE
   GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
               "Test asks to receive on accepted socket\n");
 #endif
-  GNUNET_NETWORK_receive (asock,
+  GNUNET_NETWORK_connection_receive (asock,
                           1024,
                           GNUNET_TIME_relative_multiply
                           (GNUNET_TIME_UNIT_SECONDS, 5), &receive_check, cls);
@@ -146,23 +146,23 @@
 task (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc)
 {
   ls = open_listen_socket ();
-  lsock = GNUNET_NETWORK_socket_create_from_existing (tc->sched, ls, 0);
+  lsock = GNUNET_NETWORK_connection_create_from_existing (tc->sched, ls, 0);
   GNUNET_assert (lsock != NULL);
-  csock = GNUNET_NETWORK_socket_create_from_connect (tc->sched,
+  csock = GNUNET_NETWORK_connection_create_from_connect (tc->sched,
                                                      "localhost", PORT, 1024);
   GNUNET_assert (csock != NULL);
 #if VERBOSE
   GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Test asks for write notification\n");
 #endif
   GNUNET_assert (NULL !=
-                 GNUNET_NETWORK_notify_transmit_ready (csock,
+                 GNUNET_NETWORK_connection_notify_transmit_ready (csock,
                                                        12,
                                                        
GNUNET_TIME_UNIT_SECONDS,
                                                        &make_hello, NULL));
 #if VERBOSE
   GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Test destroys client socket\n");
 #endif
-  GNUNET_NETWORK_socket_destroy (csock);
+  GNUNET_NETWORK_connection_destroy (csock);
 #if VERBOSE
   GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Test prepares to accept\n");
 #endif

Modified: gnunet/src/util/test_network_addressing.c
===================================================================
--- gnunet/src/util/test_network_addressing.c   2009-08-08 14:10:24 UTC (rev 
8821)
+++ gnunet/src/util/test_network_addressing.c   2009-08-09 08:25:58 UTC (rev 
8822)
@@ -32,11 +32,11 @@
 #define PORT 12435
 
 
-static struct GNUNET_NETWORK_SocketHandle *csock;
+static struct GNUNET_NETWORK_ConnectionHandle *csock;
 
-static struct GNUNET_NETWORK_SocketHandle *asock;
+static struct GNUNET_NETWORK_ConnectionHandle *asock;
 
-static struct GNUNET_NETWORK_SocketHandle *lsock;
+static struct GNUNET_NETWORK_ConnectionHandle *lsock;
 
 static size_t sofar;
 
@@ -82,7 +82,7 @@
     sofar += available;
   if (sofar < 12)
     {
-      GNUNET_NETWORK_receive (asock,
+      GNUNET_NETWORK_connection_receive (asock,
                               1024,
                               GNUNET_TIME_relative_multiply
                               (GNUNET_TIME_UNIT_SECONDS, 5), &receive_check,
@@ -91,7 +91,7 @@
   else
     {
       *ok = 0;
-      GNUNET_NETWORK_socket_destroy (asock);
+      GNUNET_NETWORK_connection_destroy (asock);
     }
 }
 
@@ -104,12 +104,12 @@
   struct sockaddr_in *v4;
   struct sockaddr_in expect;
 
-  asock = GNUNET_NETWORK_socket_create_from_accept (tc->sched,
+  asock = GNUNET_NETWORK_connection_create_from_accept (tc->sched,
                                                     NULL, NULL, ls, 1024);
   GNUNET_assert (asock != NULL);
-  GNUNET_assert (GNUNET_YES == GNUNET_NETWORK_socket_check (asock));
+  GNUNET_assert (GNUNET_YES == GNUNET_NETWORK_connection_check (asock));
   GNUNET_assert (GNUNET_OK ==
-                 GNUNET_NETWORK_socket_get_address (asock, &addr, &alen));
+                 GNUNET_NETWORK_connection_get_address (asock, &addr, &alen));
   GNUNET_assert (alen == sizeof (struct sockaddr_in));
   v4 = addr;
   memset (&expect, 0, sizeof (expect));
@@ -118,8 +118,8 @@
   expect.sin_addr.s_addr = htonl (INADDR_LOOPBACK);
   GNUNET_assert (0 == memcmp (&expect, v4, alen));
   GNUNET_free (addr);
-  GNUNET_NETWORK_socket_destroy (lsock);
-  GNUNET_NETWORK_receive (asock,
+  GNUNET_NETWORK_connection_destroy (lsock);
+  GNUNET_NETWORK_connection_receive (asock,
                           1024,
                           GNUNET_TIME_relative_multiply
                           (GNUNET_TIME_UNIT_SECONDS, 5), &receive_check, cls);
@@ -138,24 +138,24 @@
 {
   struct sockaddr_in v4;
   ls = open_listen_socket ();
-  lsock = GNUNET_NETWORK_socket_create_from_existing (tc->sched, ls, 0);
+  lsock = GNUNET_NETWORK_connection_create_from_existing (tc->sched, ls, 0);
   GNUNET_assert (lsock != NULL);
 
   v4.sin_family = AF_INET;
   v4.sin_port = htons (PORT);
   v4.sin_addr.s_addr = htonl (INADDR_LOOPBACK);
-  csock = GNUNET_NETWORK_socket_create_from_sockaddr (tc->sched,
+  csock = GNUNET_NETWORK_connection_create_from_sockaddr (tc->sched,
                                                       AF_INET,
                                                       (const struct sockaddr
                                                        *) &v4, sizeof (v4),
                                                       1024);
   GNUNET_assert (csock != NULL);
   GNUNET_assert (NULL !=
-                 GNUNET_NETWORK_notify_transmit_ready (csock,
+                 GNUNET_NETWORK_connection_notify_transmit_ready (csock,
                                                        12,
                                                        
GNUNET_TIME_UNIT_SECONDS,
                                                        &make_hello, NULL));
-  GNUNET_NETWORK_socket_destroy (csock);
+  GNUNET_NETWORK_connection_destroy (csock);
   GNUNET_SCHEDULER_add_read (tc->sched,
                              GNUNET_NO,
                              GNUNET_SCHEDULER_PRIORITY_HIGH,

Modified: gnunet/src/util/test_network_receive_cancel.c
===================================================================
--- gnunet/src/util/test_network_receive_cancel.c       2009-08-08 14:10:24 UTC 
(rev 8821)
+++ gnunet/src/util/test_network_receive_cancel.c       2009-08-09 08:25:58 UTC 
(rev 8822)
@@ -32,11 +32,11 @@
 #define PORT 12435
 
 
-static struct GNUNET_NETWORK_SocketHandle *csock;
+static struct GNUNET_NETWORK_ConnectionHandle *csock;
 
-static struct GNUNET_NETWORK_SocketHandle *asock;
+static struct GNUNET_NETWORK_ConnectionHandle *asock;
 
-static struct GNUNET_NETWORK_SocketHandle *lsock;
+static struct GNUNET_NETWORK_ConnectionHandle *lsock;
 
 static int ls;
 
@@ -85,13 +85,13 @@
 run_accept_cancel (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc)
 {
 
-  asock = GNUNET_NETWORK_socket_create_from_accept (tc->sched,
+  asock = GNUNET_NETWORK_connection_create_from_accept (tc->sched,
                                                     NULL, NULL, ls, 1024);
   GNUNET_assert (asock != NULL);
-  GNUNET_assert (GNUNET_YES == GNUNET_NETWORK_socket_check (asock));
-  GNUNET_NETWORK_socket_destroy (lsock);
+  GNUNET_assert (GNUNET_YES == GNUNET_NETWORK_connection_check (asock));
+  GNUNET_NETWORK_connection_destroy (lsock);
   receive_task
-    = GNUNET_NETWORK_receive (asock,
+    = GNUNET_NETWORK_connection_receive (asock,
                               1024,
                               GNUNET_TIME_relative_multiply
                               (GNUNET_TIME_UNIT_SECONDS, 5), &dead_receive,
@@ -103,9 +103,9 @@
 receive_cancel_task (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc)
 {
   int *ok = cls;
-  GNUNET_NETWORK_receive_cancel (asock, receive_task);
-  GNUNET_NETWORK_socket_destroy (csock);
-  GNUNET_NETWORK_socket_destroy (asock);
+  GNUNET_NETWORK_connection_receive_cancel (asock, receive_task);
+  GNUNET_NETWORK_connection_destroy (csock);
+  GNUNET_NETWORK_connection_destroy (asock);
   *ok = 0;
 }
 
@@ -115,9 +115,9 @@
 task_receive_cancel (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc)
 {
   ls = open_listen_socket ();
-  lsock = GNUNET_NETWORK_socket_create_from_existing (tc->sched, ls, 0);
+  lsock = GNUNET_NETWORK_connection_create_from_existing (tc->sched, ls, 0);
   GNUNET_assert (lsock != NULL);
-  csock = GNUNET_NETWORK_socket_create_from_connect (tc->sched,
+  csock = GNUNET_NETWORK_connection_create_from_connect (tc->sched,
                                                      "localhost", PORT, 1024);
   GNUNET_assert (csock != NULL);
   GNUNET_SCHEDULER_add_read (tc->sched,

Modified: gnunet/src/util/test_network_timeout.c
===================================================================
--- gnunet/src/util/test_network_timeout.c      2009-08-08 14:10:24 UTC (rev 
8821)
+++ gnunet/src/util/test_network_timeout.c      2009-08-09 08:25:58 UTC (rev 
8822)
@@ -31,9 +31,9 @@
 
 #define PORT 12435
 
-static struct GNUNET_NETWORK_SocketHandle *csock;
+static struct GNUNET_NETWORK_ConnectionHandle *csock;
 
-static struct GNUNET_NETWORK_SocketHandle *lsock;
+static struct GNUNET_NETWORK_ConnectionHandle *lsock;
 
 static int ls;
 
@@ -74,8 +74,8 @@
 #endif
       GNUNET_assert (buf == NULL);
       *ok = 0;
-      GNUNET_NETWORK_socket_destroy (lsock);
-      GNUNET_NETWORK_socket_destroy (csock);
+      GNUNET_NETWORK_connection_destroy (lsock);
+      GNUNET_NETWORK_connection_destroy (csock);
       return 0;
     }
 #if VERBOSE
@@ -85,7 +85,7 @@
   memset (buf, 42, 1024);
 
   GNUNET_assert (NULL !=
-                 GNUNET_NETWORK_notify_transmit_ready (csock,
+                 GNUNET_NETWORK_connection_notify_transmit_ready (csock,
                                                        1024,
                                                        
GNUNET_TIME_UNIT_SECONDS,
                                                        &send_kilo, cls));
@@ -98,13 +98,13 @@
 {
 
   ls = open_listen_socket ();
-  lsock = GNUNET_NETWORK_socket_create_from_existing (tc->sched, ls, 0);
+  lsock = GNUNET_NETWORK_connection_create_from_existing (tc->sched, ls, 0);
   GNUNET_assert (lsock != NULL);
-  csock = GNUNET_NETWORK_socket_create_from_connect (tc->sched,
+  csock = GNUNET_NETWORK_connection_create_from_connect (tc->sched,
                                                      "localhost", PORT, 1024);
   GNUNET_assert (csock != NULL);
   GNUNET_assert (NULL !=
-                 GNUNET_NETWORK_notify_transmit_ready (csock,
+                 GNUNET_NETWORK_connection_notify_transmit_ready (csock,
                                                        1024,
                                                        
GNUNET_TIME_UNIT_SECONDS,
                                                        &send_kilo, cls));

Modified: gnunet/src/util/test_network_timeout_no_connect.c
===================================================================
--- gnunet/src/util/test_network_timeout_no_connect.c   2009-08-08 14:10:24 UTC 
(rev 8821)
+++ gnunet/src/util/test_network_timeout_no_connect.c   2009-08-09 08:25:58 UTC 
(rev 8822)
@@ -31,7 +31,7 @@
 
 #define PORT 13425
 
-static struct GNUNET_NETWORK_SocketHandle *csock;
+static struct GNUNET_NETWORK_ConnectionHandle *csock;
 
 static size_t
 handle_timeout (void *cls, size_t size, void *buf)
@@ -51,11 +51,11 @@
 static void
 task_timeout (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc)
 {
-  csock = GNUNET_NETWORK_socket_create_from_connect (tc->sched,
+  csock = GNUNET_NETWORK_connection_create_from_connect (tc->sched,
                                                      "localhost", PORT, 1024);
   GNUNET_assert (csock != NULL);
   GNUNET_assert (NULL !=
-                 GNUNET_NETWORK_notify_transmit_ready (csock,
+                 GNUNET_NETWORK_connection_notify_transmit_ready (csock,
                                                        1024,
                                                        
GNUNET_TIME_UNIT_SECONDS,
                                                        &handle_timeout, cls));

Modified: gnunet/src/util/test_network_transmit_cancel.c
===================================================================
--- gnunet/src/util/test_network_transmit_cancel.c      2009-08-08 14:10:24 UTC 
(rev 8821)
+++ gnunet/src/util/test_network_transmit_cancel.c      2009-08-09 08:25:58 UTC 
(rev 8822)
@@ -46,17 +46,17 @@
 {
   int *ok = cls;
   struct GNUNET_NETWORK_TransmitHandle *th;
-  struct GNUNET_NETWORK_SocketHandle *csock;
+  struct GNUNET_NETWORK_ConnectionHandle *csock;
 
-  csock = GNUNET_NETWORK_socket_create_from_connect (tc->sched,
+  csock = GNUNET_NETWORK_connection_create_from_connect (tc->sched,
                                                      "localhost", PORT, 1024);
   GNUNET_assert (csock != NULL);
-  th = GNUNET_NETWORK_notify_transmit_ready (csock,
+  th = GNUNET_NETWORK_connection_notify_transmit_ready (csock,
                                              12,
                                              GNUNET_TIME_UNIT_MINUTES,
                                              &not_run, cls);
-  GNUNET_NETWORK_notify_transmit_ready_cancel (th);
-  GNUNET_NETWORK_socket_destroy (csock);
+  GNUNET_NETWORK_connection_notify_transmit_ready_cancel (th);
+  GNUNET_NETWORK_connection_destroy (csock);
   *ok = 0;
 }
 





reply via email to

[Prev in Thread] Current Thread [Next in Thread]