[Top][All Lists]
[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[GNUnet-SVN] r17794 - gnunet/src/transport
From: |
gnunet |
Subject: |
[GNUnet-SVN] r17794 - gnunet/src/transport |
Date: |
Wed, 26 Oct 2011 15:16:49 +0200 |
Author: wachs
Date: 2011-10-26 15:16:49 +0200 (Wed, 26 Oct 2011)
New Revision: 17794
Modified:
gnunet/src/transport/gnunet-service-transport_neighbours_fsm.c
Log:
Modified: gnunet/src/transport/gnunet-service-transport_neighbours_fsm.c
===================================================================
--- gnunet/src/transport/gnunet-service-transport_neighbours_fsm.c
2011-10-26 12:51:13 UTC (rev 17793)
+++ gnunet/src/transport/gnunet-service-transport_neighbours_fsm.c
2011-10-26 13:16:49 UTC (rev 17794)
@@ -975,6 +975,14 @@
size_t len;
size_t ret;
+ GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
+ "SWITCH! Peer `%4s' switches to plugin `%s' address '%s' session
%X\n",
+ GNUNET_i2s (peer), plugin_name,
+ (address_len == 0) ? "<inbound>" : GST_plugins_a2s (plugin_name,
+ address,
+ address_len),
+ session);
+
GNUNET_assert (neighbours != NULL);
n = lookup_neighbour (peer);
if (NULL == n)
@@ -987,7 +995,9 @@
return GNUNET_NO;
}
- change_state (n, S_CONNECT_SENT);
+ // FIXME state transition when peer is connected?
+ if (!is_connected(n))
+ change_state (n, S_CONNECT_SENT);
#if DEBUG_TRANSPORT
GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
@@ -1643,6 +1653,19 @@
send_disconnect(n);
return;
}
+
+ if (NULL != session)
+ GNUNET_log_from (GNUNET_ERROR_TYPE_ERROR | GNUNET_ERROR_TYPE_BULK,
+ "transport-ats",
+ "Giving ATS session %p of plugin %s for peer %s\n",
+ session,
+ plugin_name,
+ GNUNET_i2s (peer));
+ GNUNET_ATS_address_update (GST_ats,
+ peer,
+ plugin_name, sender_address, sender_address_len,
+ session, ats, ats_count);
+
neighbour_connected (n, ats, ats_count, GNUNET_YES);
}
@@ -1681,6 +1704,18 @@
if (is_connected(n))
return;
+ if (NULL != session)
+ GNUNET_log_from (GNUNET_ERROR_TYPE_ERROR | GNUNET_ERROR_TYPE_BULK,
+ "transport-ats",
+ "Giving ATS session %p of plugin %s for peer %s\n",
+ session,
+ plugin_name,
+ GNUNET_i2s (peer));
+ GNUNET_ATS_address_update (GST_ats,
+ peer,
+ plugin_name, sender_address, sender_address_len,
+ session, ats, ats_count);
+
neighbour_connected (n, ats, ats_count, GNUNET_NO);
}
@@ -1759,7 +1794,7 @@
if (ts.abs_value > n->connect_ts.abs_value)
{
if (NULL != session)
- GNUNET_log_from (GNUNET_ERROR_TYPE_INFO | GNUNET_ERROR_TYPE_BULK,
+ GNUNET_log_from (GNUNET_ERROR_TYPE_ERROR | GNUNET_ERROR_TYPE_BULK,
"transport-ats",
"Giving ATS session %p of plugin %s for peer %s\n",
session,
[Prev in Thread] |
Current Thread |
[Next in Thread] |
- [GNUnet-SVN] r17794 - gnunet/src/transport,
gnunet <=