diff options
-rw-r--r-- | src/ats/test_ats_api_scheduling_add_address.c | 26 | ||||
-rw-r--r-- | src/ats/test_ats_api_scheduling_destroy_address.c | 27 |
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 | ||
60 | static void | 60 | static void |
61 | create_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 | |||
70 | static void | ||
71 | free_test_address (struct Test_Address *dest) | ||
72 | { | ||
73 | GNUNET_free (dest->plugin); | ||
74 | GNUNET_free (dest->addr); | ||
75 | } | ||
76 | |||
77 | |||
78 | static void | ||
61 | end_badly (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) | 79 | end_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 | ||
61 | static void | 61 | static void |
62 | create_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 | |||
71 | static void | ||
72 | free_test_address (struct Test_Address *dest) | ||
73 | { | ||
74 | GNUNET_free (dest->plugin); | ||
75 | GNUNET_free (dest->addr); | ||
76 | } | ||
77 | |||
78 | |||
79 | static void | ||
62 | end_badly (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) | 80 | end_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 | ||
90 | void address_callback (void *cls, | 110 | void 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; |