aboutsummaryrefslogtreecommitdiff
path: root/src/namestore/namestore_api_monitor.c
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2013-07-09 14:37:12 +0000
committerChristian Grothoff <christian@grothoff.org>2013-07-09 14:37:12 +0000
commit15e649e0158e4e591779dbba8bb89a9b1aceecc6 (patch)
treec3c941a8bb476648148c1ab26ca193f9f3788555 /src/namestore/namestore_api_monitor.c
parent733629155b27695e462e43a4883b79769ebecbb5 (diff)
downloadgnunet-15e649e0158e4e591779dbba8bb89a9b1aceecc6.tar.gz
gnunet-15e649e0158e4e591779dbba8bb89a9b1aceecc6.zip
-fixes in monitoring code
Diffstat (limited to 'src/namestore/namestore_api_monitor.c')
-rw-r--r--src/namestore/namestore_api_monitor.c13
1 files changed, 8 insertions, 5 deletions
diff --git a/src/namestore/namestore_api_monitor.c b/src/namestore/namestore_api_monitor.c
index 8f6aacf19..a6a014839 100644
--- a/src/namestore/namestore_api_monitor.c
+++ b/src/namestore/namestore_api_monitor.c
@@ -205,10 +205,10 @@ handle_updates (void *cls,
205 &handle_updates, 205 &handle_updates,
206 zm, 206 zm,
207 GNUNET_TIME_UNIT_FOREVER_REL); 207 GNUNET_TIME_UNIT_FOREVER_REL);
208 zm->monitor(zm->cls, 208 zm->monitor (zm->cls,
209 &lrm->public_key, expire, 209 &lrm->public_key, expire,
210 name_tmp, 210 name_tmp,
211 rd_count, rd, &lrm->signature); 211 rd_count, rd, NULL);
212 } 212 }
213} 213}
214 214
@@ -229,12 +229,15 @@ transmit_monitor_message (void *cls,
229 struct GNUNET_NAMESTORE_ZoneMonitor *zm = cls; 229 struct GNUNET_NAMESTORE_ZoneMonitor *zm = cls;
230 struct ZoneMonitorStartMessage sm; 230 struct ZoneMonitorStartMessage sm;
231 231
232 zm->th = NULL;
232 if (size < sizeof (struct ZoneMonitorStartMessage)) 233 if (size < sizeof (struct ZoneMonitorStartMessage))
233 { 234 {
234 reconnect (zm); 235 reconnect (zm);
235 return 0; 236 return 0;
236 } 237 }
237 238 sm.gns_header.header.type = htons (GNUNET_MESSAGE_TYPE_NAMESTORE_MONITOR_START);
239 sm.gns_header.header.size = htons (sizeof (struct ZoneMonitorStartMessage));
240 sm.gns_header.r_id = htonl (0);
238 sm.zone = zm->zone; 241 sm.zone = zm->zone;
239 sm.all_zones = htonl (zm->all_zones); 242 sm.all_zones = htonl (zm->all_zones);
240 memcpy (buf, &sm, sizeof (sm)); 243 memcpy (buf, &sm, sizeof (sm));