[Top][All Lists]
[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[GNUnet-SVN] r24513 - gnunet/src/ats
From: |
gnunet |
Subject: |
[GNUnet-SVN] r24513 - gnunet/src/ats |
Date: |
Wed, 24 Oct 2012 15:44:47 +0200 |
Author: wachs
Date: 2012-10-24 15:44:47 +0200 (Wed, 24 Oct 2012)
New Revision: 24513
Modified:
gnunet/src/ats/gnunet-ats.c
Log:
- more
Modified: gnunet/src/ats/gnunet-ats.c
===================================================================
--- gnunet/src/ats/gnunet-ats.c 2012-10-24 13:24:37 UTC (rev 24512)
+++ gnunet/src/ats/gnunet-ats.c 2012-10-24 13:44:47 UTC (rev 24513)
@@ -31,11 +31,40 @@
* Final status code.
*/
static int ret;
+static int results;
static struct GNUNET_ATS_PerformanceHandle *ph;
-GNUNET_SCHEDULER_Task end_task;
+GNUNET_SCHEDULER_TaskIdentifier end_task;
+void ats_perf_cb (void *cls,
+ const struct
+ GNUNET_HELLO_Address *
+ address,
+ struct
+ GNUNET_BANDWIDTH_Value32NBO
+ bandwidth_out,
+ struct
+ GNUNET_BANDWIDTH_Value32NBO
+ bandwidth_in,
+ const struct
+ GNUNET_ATS_Information *
+ ats, uint32_t ats_count)
+{
+ fprintf (stderr, "Peer `%s'\n", GNUNET_i2s (&address->peer));
+ results++;
+}
+
+void end (void *cls,
+ const struct GNUNET_SCHEDULER_TaskContext *tc)
+{
+ GNUNET_ATS_performance_done (ph);
+ ph = NULL;
+ /*FIXME */fprintf (stderr, "NOT IMPLEMENTED!\n");
+ fprintf (stderr, "ATS returned %u addresses\n", results);
+ ret = 0;
+}
+
void testservice_task (void *cls,
const struct GNUNET_SCHEDULER_TaskContext *tc)
{
@@ -51,11 +80,8 @@
if (NULL == ph)
fprintf (stderr, "Cannot connect to ATS service, exiting...\n");
- /* FIXME do work here*/
- fprintf (stderr, "NOT IMPLEMENTED\n");
-
- GNUNET_ATS_performance_done (ph);
- ret = 0;
+ end_task = GNUNET_SCHEDULER_add_delayed (GNUNET_TIME_UNIT_SECONDS, &end,
NULL);
+ ret = 1;
}
/**
[Prev in Thread] |
Current Thread |
[Next in Thread] |
- [GNUnet-SVN] r24513 - gnunet/src/ats,
gnunet <=