aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--src/ats/test_ats_api_scheduling_add_address.c26
-rw-r--r--src/ats/test_ats_api_scheduling_destroy_address.c27
2 files changed, 43 insertions, 10 deletions
diff --git a/src/ats/test_ats_api_scheduling_add_address.c b/src/ats/test_ats_api_scheduling_add_address.c
index fdabbbe29..f94884cd0 100644
--- a/src/ats/test_ats_api_scheduling_add_address.c
+++ b/src/ats/test_ats_api_scheduling_add_address.c
@@ -58,6 +58,24 @@ static struct PeerContext p;
58 58
59 59
60static void 60static void
61create_test_address (struct Test_Address *dest, char * plugin, void *session, void *addr, size_t addrlen)
62{
63 dest->plugin = GNUNET_strdup (plugin);
64 dest->session = session;
65 dest->addr = GNUNET_malloc (addrlen);
66 memcpy (dest->addr, addr, addrlen);
67 dest->addr_len = addrlen;
68}
69
70static void
71free_test_address (struct Test_Address *dest)
72{
73 GNUNET_free (dest->plugin);
74 GNUNET_free (dest->addr);
75}
76
77
78static void
61end_badly (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) 79end_badly (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc)
62{ 80{
63 die_task = GNUNET_SCHEDULER_NO_TASK; 81 die_task = GNUNET_SCHEDULER_NO_TASK;
@@ -66,6 +84,7 @@ end_badly (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc)
66 GNUNET_ATS_scheduling_done (sched_ats); 84 GNUNET_ATS_scheduling_done (sched_ats);
67 if (perf_ats != NULL) 85 if (perf_ats != NULL)
68 GNUNET_ATS_performance_done (perf_ats); 86 GNUNET_ATS_performance_done (perf_ats);
87 free_test_address (&test_addr);
69 ret = GNUNET_SYSERR; 88 ret = GNUNET_SYSERR;
70} 89}
71 90
@@ -84,6 +103,7 @@ end ()
84 sched_ats = NULL; 103 sched_ats = NULL;
85 GNUNET_ATS_performance_done (perf_ats); 104 GNUNET_ATS_performance_done (perf_ats);
86 perf_ats = NULL; 105 perf_ats = NULL;
106 free_test_address (&test_addr);
87 ret = 0; 107 ret = 0;
88} 108}
89 109
@@ -167,11 +187,7 @@ run (void *cls,
167 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Created peer `%s'\n", 187 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Created peer `%s'\n",
168 GNUNET_i2s_full(&p.id)); 188 GNUNET_i2s_full(&p.id));
169 189
170 test_addr.plugin = "test"; 190 create_test_address (&test_addr, "test", &test_addr, "test", strlen ("test") + 1);
171 test_addr.session = NULL;
172 test_addr.addr = GNUNET_strdup ("test");
173 test_addr.addr_len = 4;
174
175 /* Adding address without session */ 191 /* Adding address without session */
176 hello_address.peer = p.id; 192 hello_address.peer = p.id;
177 hello_address.transport_name = test_addr.plugin; 193 hello_address.transport_name = test_addr.plugin;
diff --git a/src/ats/test_ats_api_scheduling_destroy_address.c b/src/ats/test_ats_api_scheduling_destroy_address.c
index cf6f24cd5..820d8ee6c 100644
--- a/src/ats/test_ats_api_scheduling_destroy_address.c
+++ b/src/ats/test_ats_api_scheduling_destroy_address.c
@@ -59,6 +59,24 @@ static struct PeerContext p;
59 59
60 60
61static void 61static void
62create_test_address (struct Test_Address *dest, char * plugin, void *session, void *addr, size_t addrlen)
63{
64 dest->plugin = GNUNET_strdup (plugin);
65 dest->session = session;
66 dest->addr = GNUNET_malloc (addrlen);
67 memcpy (dest->addr, addr, addrlen);
68 dest->addr_len = addrlen;
69}
70
71static void
72free_test_address (struct Test_Address *dest)
73{
74 GNUNET_free (dest->plugin);
75 GNUNET_free (dest->addr);
76}
77
78
79static void
62end_badly (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) 80end_badly (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc)
63{ 81{
64 die_task = GNUNET_SCHEDULER_NO_TASK; 82 die_task = GNUNET_SCHEDULER_NO_TASK;
@@ -67,6 +85,7 @@ end_badly (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc)
67 GNUNET_ATS_scheduling_done (sched_ats); 85 GNUNET_ATS_scheduling_done (sched_ats);
68 if (perf_ats != NULL) 86 if (perf_ats != NULL)
69 GNUNET_ATS_performance_done (perf_ats); 87 GNUNET_ATS_performance_done (perf_ats);
88 free_test_address (&test_addr);
70 ret = GNUNET_SYSERR; 89 ret = GNUNET_SYSERR;
71} 90}
72 91
@@ -80,11 +99,12 @@ end ()
80 GNUNET_SCHEDULER_cancel (die_task); 99 GNUNET_SCHEDULER_cancel (die_task);
81 die_task = GNUNET_SCHEDULER_NO_TASK; 100 die_task = GNUNET_SCHEDULER_NO_TASK;
82 } 101 }
83 102 free_test_address (&test_addr);
84 GNUNET_ATS_scheduling_done (sched_ats); 103 GNUNET_ATS_scheduling_done (sched_ats);
85 sched_ats = NULL; 104 sched_ats = NULL;
86 GNUNET_ATS_performance_done (perf_ats); 105 GNUNET_ATS_performance_done (perf_ats);
87 perf_ats = NULL; 106 perf_ats = NULL;
107 free_test_address (&test_addr);
88} 108}
89 109
90void address_callback (void *cls, 110void address_callback (void *cls,
@@ -163,10 +183,7 @@ run (void *cls,
163 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Created peer `%s'\n", 183 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Created peer `%s'\n",
164 GNUNET_i2s_full(&p.id)); 184 GNUNET_i2s_full(&p.id));
165 185
166 test_addr.plugin = "test"; 186 create_test_address (&test_addr, "test", &test_addr, "test", strlen ("test") + 1);
167 test_addr.session = NULL;
168 test_addr.addr = GNUNET_strdup ("test");
169 test_addr.addr_len = 4;
170 187
171 /* Adding address without session */ 188 /* Adding address without session */
172 hello_address.peer = p.id; 189 hello_address.peer = p.id;