LOG (GNUNET_ERROR_TYPE_DEBUG,
"Get informed about peer %s getting live\n",
GNUNET_i2s (&peer_ctx->peer_id));
LOG (GNUNET_ERROR_TYPE_DEBUG,
"Get informed about peer %s getting live\n",
GNUNET_i2s (&peer_ctx->peer_id));
LOG (GNUNET_ERROR_TYPE_DEBUG,
"Already waiting for notification\n");
LOG (GNUNET_ERROR_TYPE_DEBUG,
"Already waiting for notification\n");
- if (GNUNET_YES == get_peer_flag (peer_ctx, VALID) ||
- NULL != peer_ctx->send_channel ||
- NULL != peer_ctx->recv_channel)
+ if (GNUNET_YES == get_peer_flag (peer_ctx, VALID))
{
if (GNUNET_NO == in_arr (pull_list, pull_list_size, &peers[i]))
GNUNET_array_append (pull_list, pull_list_size, peers[i]);
{
if (GNUNET_NO == in_arr (pull_list, pull_list_size, &peers[i]))
GNUNET_array_append (pull_list, pull_list_size, peers[i]);
/* Send PUSH to attacked peers */
peer_ctx = get_peer_ctx (peer_map, &attacked_peer);
/* Send PUSH to attacked peers */
peer_ctx = get_peer_ctx (peer_map, &attacked_peer);
- if (GNUNET_YES == get_peer_flag (peer_ctx, VALID)
- || NULL != peer_ctx->send_channel
- || NULL != peer_ctx->recv_channel)
+ if (GNUNET_YES == get_peer_flag (peer_ctx, VALID))
{
LOG (GNUNET_ERROR_TYPE_DEBUG,
"Goding to send push to attacked peer (%s)\n",
{
LOG (GNUNET_ERROR_TYPE_DEBUG,
"Goding to send push to attacked peer (%s)\n",
- LOG (GNUNET_ERROR_TYPE_DEBUG, "Failed to read ROUNDINTERVAL from config\n");
+ GNUNET_log_config_missing (GNUNET_ERROR_TYPE_ERROR,
+ "RPS", "ROUNDINTERVAL");
- if (GNUNET_OK != GNUNET_CONFIGURATION_get_value_number (cfg, "RPS",
- "INITSIZE",
- (long long unsigned int *) &sampler_size_est_need))
+ if (GNUNET_OK !=
+ GNUNET_CONFIGURATION_get_value_number (cfg, "RPS", "INITSIZE",
+ (long long unsigned int *) &sampler_size_est_need))