aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorng0 <ng0@n0.is>2019-02-26 09:00:13 +0000
committerng0 <ng0@n0.is>2019-02-26 09:00:13 +0000
commitda4c0317d642b5d0e2fbf8d92446db879098517b (patch)
tree7d21375cdf67cb54967f7192ab802772790830c0
parent8e34c4b9da209d60e83162f543da754de7ea5d20 (diff)
parent2120037b332c32106dab2dcda0f6ff56115173c7 (diff)
downloadgnunet-da4c0317d642b5d0e2fbf8d92446db879098517b.tar.gz
gnunet-da4c0317d642b5d0e2fbf8d92446db879098517b.zip
Merge branch 'master' of gnunet.org:gnunet
-rw-r--r--src/core/core_api_monitor_peers.c13
-rw-r--r--src/rps/gnunet-rps-profiler.c2
-rw-r--r--src/testbed/gnunet-testbed-profiler.c32
3 files changed, 23 insertions, 24 deletions
diff --git a/src/core/core_api_monitor_peers.c b/src/core/core_api_monitor_peers.c
index 8820b44d1..0ebb94d7b 100644
--- a/src/core/core_api_monitor_peers.c
+++ b/src/core/core_api_monitor_peers.c
@@ -11,7 +11,7 @@
11 WITHOUT ANY WARRANTY; without even the implied warranty of 11 WITHOUT ANY WARRANTY; without even the implied warranty of
12 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU 12 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
13 Affero General Public License for more details. 13 Affero General Public License for more details.
14 14
15 You should have received a copy of the GNU Affero General Public License 15 You should have received a copy of the GNU Affero General Public License
16 along with this program. If not, see <http://www.gnu.org/licenses/>. 16 along with this program. If not, see <http://www.gnu.org/licenses/>.
17 17
@@ -135,10 +135,11 @@ reconnect (struct GNUNET_CORE_MonitorHandle *mh)
135 if (NULL == mh->mq) 135 if (NULL == mh->mq)
136 return; 136 return;
137 /* notify callback about reconnect */ 137 /* notify callback about reconnect */
138 mh->peer_cb (mh->peer_cb_cls, 138 if (NULL != mh->peer_cb)
139 NULL, 139 mh->peer_cb (mh->peer_cb_cls,
140 GNUNET_CORE_KX_CORE_DISCONNECT, 140 NULL,
141 GNUNET_TIME_UNIT_FOREVER_ABS); 141 GNUNET_CORE_KX_CORE_DISCONNECT,
142 GNUNET_TIME_UNIT_FOREVER_ABS);
142 env = GNUNET_MQ_msg (msg, 143 env = GNUNET_MQ_msg (msg,
143 GNUNET_MESSAGE_TYPE_CORE_MONITOR_PEERS); 144 GNUNET_MESSAGE_TYPE_CORE_MONITOR_PEERS);
144 GNUNET_MQ_send (mh->mq, 145 GNUNET_MQ_send (mh->mq,
@@ -172,9 +173,9 @@ GNUNET_CORE_monitor_start (const struct GNUNET_CONFIGURATION_Handle *cfg,
172 GNUNET_assert (NULL != peer_cb); 173 GNUNET_assert (NULL != peer_cb);
173 mh = GNUNET_new (struct GNUNET_CORE_MonitorHandle); 174 mh = GNUNET_new (struct GNUNET_CORE_MonitorHandle);
174 mh->cfg = cfg; 175 mh->cfg = cfg;
176 reconnect (mh);
175 mh->peer_cb = peer_cb; 177 mh->peer_cb = peer_cb;
176 mh->peer_cb_cls = peer_cb_cls; 178 mh->peer_cb_cls = peer_cb_cls;
177 reconnect (mh);
178 if (NULL == mh->mq) 179 if (NULL == mh->mq)
179 { 180 {
180 GNUNET_free (mh); 181 GNUNET_free (mh);
diff --git a/src/rps/gnunet-rps-profiler.c b/src/rps/gnunet-rps-profiler.c
index cdf555432..9aa786334 100644
--- a/src/rps/gnunet-rps-profiler.c
+++ b/src/rps/gnunet-rps-profiler.c
@@ -2976,6 +2976,8 @@ main (int argc, char *argv[])
2976 GNUNET_GETOPT_OPTION_END 2976 GNUNET_GETOPT_OPTION_END
2977 }; 2977 };
2978 2978
2979 unsetenv ("XDG_DATA_HOME");
2980 unsetenv ("XDG_CONFIG_HOME");
2979 //if (GNUNET_OK != 2981 //if (GNUNET_OK !=
2980 // GNUNET_STRINGS_get_utf8_args (argc, argv, 2982 // GNUNET_STRINGS_get_utf8_args (argc, argv,
2981 // &argc, &argv)) 2983 // &argc, &argv))
diff --git a/src/testbed/gnunet-testbed-profiler.c b/src/testbed/gnunet-testbed-profiler.c
index 8b19d7431..d9401286c 100644
--- a/src/testbed/gnunet-testbed-profiler.c
+++ b/src/testbed/gnunet-testbed-profiler.c
@@ -11,7 +11,7 @@
11 WITHOUT ANY WARRANTY; without even the implied warranty of 11 WITHOUT ANY WARRANTY; without even the implied warranty of
12 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU 12 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
13 Affero General Public License for more details. 13 Affero General Public License for more details.
14 14
15 You should have received a copy of the GNU Affero General Public License 15 You should have received a copy of the GNU Affero General Public License
16 along with this program. If not, see <http://www.gnu.org/licenses/>. 16 along with this program. If not, see <http://www.gnu.org/licenses/>.
17 17
@@ -276,27 +276,23 @@ int
276main (int argc, char *const *argv) 276main (int argc, char *const *argv)
277{ 277{
278 struct GNUNET_GETOPT_CommandLineOption options[] = { 278 struct GNUNET_GETOPT_CommandLineOption options[] = {
279
280 GNUNET_GETOPT_option_uint ('p', 279 GNUNET_GETOPT_option_uint ('p',
281 "num-peers", 280 "num-peers",
282 "COUNT", 281 "COUNT",
283 gettext_noop ("create COUNT number of peers"), 282 gettext_noop ("create COUNT number of peers"),
284 &num_peers), 283 &num_peers),
285
286 GNUNET_GETOPT_option_uint ('e', 284 GNUNET_GETOPT_option_uint ('e',
287 "num-errors", 285 "num-errors",
288 "COUNT", 286 "COUNT",
289 gettext_noop ("tolerate COUNT number of continious timeout failures"), 287 gettext_noop ("tolerate COUNT number of continious timeout failures"),
290 &num_cont_fails), 288 &num_cont_fails),
291
292 GNUNET_GETOPT_option_flag ('n', 289 GNUNET_GETOPT_option_flag ('n',
293 "non-interactive", 290 "non-interactive",
294 gettext_noop ("run profiler in non-interactive mode where upon " 291 gettext_noop ("run profiler in non-interactive mode where upon "
295 "testbed setup the profiler does not wait for a " 292 "testbed setup the profiler does not wait for a "
296 "keystroke but continues to run until a termination " 293 "keystroke but continues to run until a termination "
297 "signal is received"), 294 "signal is received"),
298 &noninteractive), 295 &noninteractive),
299
300#if !ENABLE_SUPERMUC 296#if !ENABLE_SUPERMUC
301 GNUNET_GETOPT_option_string ('H', 297 GNUNET_GETOPT_option_string ('H',
302 "hosts", 298 "hosts",