aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--src/transport/gnunet-service-transport.c5
1 files changed, 4 insertions, 1 deletions
diff --git a/src/transport/gnunet-service-transport.c b/src/transport/gnunet-service-transport.c
index b9f4dc30f..7fd4760ef 100644
--- a/src/transport/gnunet-service-transport.c
+++ b/src/transport/gnunet-service-transport.c
@@ -125,6 +125,8 @@ process_hello_update (void *cls, const struct GNUNET_MessageHeader *hello)
125 */ 125 */
126static struct GNUNET_TIME_Relative 126static struct GNUNET_TIME_Relative
127process_payload (const struct GNUNET_PeerIdentity *peer, 127process_payload (const struct GNUNET_PeerIdentity *peer,
128 const struct GNUNET_HELLO_Address *address,
129 struct Session *session,
128 const struct GNUNET_MessageHeader *message, 130 const struct GNUNET_MessageHeader *message,
129 const struct GNUNET_ATS_Information *ats, uint32_t ats_count) 131 const struct GNUNET_ATS_Information *ats, uint32_t ats_count)
130{ 132{
@@ -169,6 +171,7 @@ process_payload (const struct GNUNET_PeerIdentity *peer,
169 ap[ats_count].value = htonl ((uint32_t) GST_neighbour_get_latency (peer).rel_value); 171 ap[ats_count].value = htonl ((uint32_t) GST_neighbour_get_latency (peer).rel_value);
170 memcpy (&ap[ats_count + 1], message, ntohs (message->size)); 172 memcpy (&ap[ats_count + 1], message, ntohs (message->size));
171 173
174 GNUNET_ATS_address_update (GST_ats, address, session, ap, ats_count +1 );
172 GST_clients_broadcast (&im->header, GNUNET_YES); 175 GST_clients_broadcast (&im->header, GNUNET_YES);
173 176
174 return ret; 177 return ret;
@@ -269,7 +272,7 @@ plugin_env_receive_callback (void *cls,
269 break; 272 break;
270 default: 273 default:
271 /* should be payload */ 274 /* should be payload */
272 ret = process_payload (peer, message, ats, ats_count); 275 ret = process_payload (peer, &address, session, message, ats, ats_count);
273 break; 276 break;
274 } 277 }
275end: 278end: