[GNUnet-SVN] r16485 - gnunet/src/transport

[gnunet]

Author: grothoff
Date: 2011-08-13 12:44:22 +0200 (Sat, 13 Aug 2011)
New Revision: 16485

Modified:
   gnunet/src/transport/gnunet-service-transport-new.c
Log:
stuff

Modified: gnunet/src/transport/gnunet-service-transport-new.c
===================================================================
--- gnunet/src/transport/gnunet-service-transport-new.c 2011-08-13 10:40:10 UTC 
(rev 16484)
+++ gnunet/src/transport/gnunet-service-transport-new.c 2011-08-13 10:44:22 UTC 
(rev 16485)
@@ -86,6 +86,7 @@
                      const struct GNUNET_MessageHeader *hello)
 {
   GST_clients_broadcast (hello, GNUNET_NO);
+  GNUNET_break (0); // FIXME
 #if 0
   GNUNET_CONTAINER_multihashmap_iterate (neighbours,
                                         &transmit_our_hello_if_pong,
@@ -131,6 +132,7 @@
                             const char *sender_address,
                             uint16_t sender_address_len)
 {
+  GNUNET_break (0); // FIXME
   return GNUNET_TIME_UNIT_ZERO;
 }
 
@@ -179,10 +181,73 @@
                        const struct GNUNET_PeerIdentity *peer,
                        struct Session *session)
 {
+  GNUNET_break (0); // FIXME
 }
 
 
 /**
+ * Function called by ATS to notify the callee that the
+ * assigned bandwidth or address for a given peer was changed.  If the
+ * callback is called with address/bandwidth assignments of zero, the
+ * ATS disconnect function will still be called once the disconnect 
+ * actually happened.
+ *
+ * @param cls closure
+ * @param peer identity of the peer
+ * @param plugin_name name of the transport plugin, NULL to disconnect
+ * @param session session to use (if available)
+ * @param plugin_addr address to use (if available)
+ * @param plugin_addr_len number of bytes in addr
+ * @param bandwidth assigned outbound bandwidth for the connection
+ */
+static void 
+ats_request_address_change (void *cls,
+                           const struct GNUNET_PeerIdentity *peer,
+                           const char *plugin_name,
+                           struct Session *session,
+                           const void *plugin_addr,
+                           size_t plugin_addr_len,
+                           struct GNUNET_BANDWIDTH_Value32NBO bandwidth)
+{
+  GNUNET_break (0); // FIXME
+}
+
+
+/**
+ * Function called to notify transport users that another
+ * peer connected to us.
+ *
+ * @param cls closure
+ * @param peer the peer that connected
+ * @param ats performance data
+ * @param ats_count number of entries in ats (excluding 0-termination)
+ */
+static void
+neighbours_connect_notification (void *cls,
+                                const struct GNUNET_PeerIdentity * peer,
+                                const struct GNUNET_TRANSPORT_ATS_Information 
*ats,
+                                uint32_t ats_count)
+{
+  GNUNET_break (0); // FIXME
+}
+
+
+/**
+ * Function called to notify transport users that another
+ * peer disconnected from us.
+ *
+ * @param cls closure
+ * @param peer the peer that disconnected
+ */
+static void
+neighbours_disconnect_notification (void *cls,
+                                   const struct GNUNET_PeerIdentity *peer)
+{
+  GNUNET_break (0); // FIXME
+}
+
+
+/**
  * Function called when the service shuts down.  Unloads our plugins
  * and cancels pending validations.
  *
@@ -282,11 +347,11 @@
                    &plugin_env_address_change_notification, 
                    &plugin_env_session_end);
   GST_ats = GNUNET_ATS_init (GST_cfg,
-                         NULL, // FIXME...
-                         NULL); // FIXME...
-  GST_neighbours_start (NULL, // FIXME...
-                       NULL, // FIXME...
-                       NULL); // FIXME...
+                            &ats_request_address_change, 
+                            NULL);
+  GST_neighbours_start (NULL,
+                       &neighbours_connect_notification,
+                       &neighbours_disconnect_notification);
   GST_clients_start (server);
   GST_validation_start ();
 }