sampler = GNUNET_new (struct RPS_Sampler);
- #ifdef TO_FILE
- sampler->file_name = create_file ("sampler-");
- GNUNET_assert (NULL != sampler->file_name);
-
- LOG (GNUNET_ERROR_TYPE_DEBUG,
- "Initialised sampler %s\n",
- sampler->file_name);
- #endif /* TO_FILE */
-
sampler->max_round_interval = max_round_interval;
sampler->get_peers = sampler_get_rand_peer;
//sampler->sampler_elements = GNUNET_new_array(init_size, struct GNUNET_PeerIdentity);
&(sampler_elem->auth_key.key),
GNUNET_CRYPTO_HASH_LENGTH);
- #ifdef TO_FILE
- /* Create a file(-name) to store internals to */
- char *name_buf;
- name_buf = auth_key_to_string (sampler_elem->auth_key);
-
- sampler_elem->file_name = create_file (name_buf);
- GNUNET_free (name_buf);
- #endif /* TO_FILE */
-
sampler_elem->last_client_request = GNUNET_TIME_UNIT_FOREVER_ABS;
sampler_elem->birth = GNUNET_TIME_absolute_get ();
void
RPS_sampler_elem_destroy (struct RPS_SamplerElement *sampler_elem)
{
- #ifdef TO_FILE
- if (NULL != sampler_elem->file_name)
- {
- GNUNET_free (sampler_elem->file_name);
- }
- #endif /* TO_FILE */
GNUNET_free (sampler_elem);
}
sampler_elem->num_peers++;
- #ifdef TO_FILE
- to_file (sampler_elem->file_name,
- "Got id %s",
- GNUNET_i2s_full (new_ID));
- #endif /* TO_FILE */
-
if (0 == GNUNET_CRYPTO_cmp_peer_identity (new_ID, &(sampler_elem->peer_id)))
{
LOG (GNUNET_ERROR_TYPE_DEBUG, "Have already PeerID %s\n",
}
}
sampler_elem->is_empty = NOT_EMPTY;
-
- #ifdef TO_FILE
- to_file (sampler_elem->file_name,
- "Now holding %s",
- GNUNET_i2s_full (&sampler_elem->peer_id));
- #endif /* TO_FILE */
}
/**
struct GNUNET_CRYPTO_AuthKey auth_key)
{
sampler_elem->auth_key = auth_key;
-
- #ifdef TO_FILE
- /* Create a file(-name) to store internals to */
- char *name_buf;
- name_buf = auth_key_to_string (sampler_elem->auth_key);
-
- sampler_elem->file_name = create_file (name_buf);
- GNUNET_free (name_buf);
- #endif /* TO_FILE */
}
/* end of gnunet-service-rps.c */
//GNUNET_assert (init_size == sampler->sampler_size);
-#ifdef TO_FILE
- sampler->file_name = create_file ("sampler-");
-
- LOG (GNUNET_ERROR_TYPE_DEBUG,
- "Initialised modified sampler %s\n",
- sampler->file_name);
- to_file (sampler->file_name,
- "This is a modified sampler");
-#endif /* TO_FILE */
RPS_sampler_resize (sampler, init_size);
return sampler;
RPS_sampler_update (struct RPS_Sampler *sampler,
const struct GNUNET_PeerIdentity *id)
{
- to_file (sampler->file_name,
- "Got %s",
- GNUNET_i2s_full (id));
-
for (uint32_t i = 0; i < sampler->sampler_size; i++)
{
RPS_sampler_elem_next (sampler->sampler_elements[i],
&(sampler->sampler_elements[i]->peer_id)) )
{
LOG (GNUNET_ERROR_TYPE_DEBUG, "Reinitialising sampler\n");
- to_file (sampler->sampler_elements[i]->file_name,
- "--- non-active");
RPS_sampler_elem_reinit (sampler->sampler_elements[i]);
}
}
old_size,
new_size);
- to_file (sampler->file_name,
- "Shrinking sampler %d -> %d",
- old_size,
- new_size);
-
for (i = new_size ; i < old_size ; i++)
{
- to_file (sampler->file_name,
- "-%" PRIu32 ": %s",
- i,
- sampler->sampler_elements[i]->file_name);
RPS_sampler_elem_destroy (sampler->sampler_elements[i]);
}
old_size,
new_size);
- to_file (sampler->file_name,
- "Growing sampler %d -> %d",
- old_size,
- new_size);
-
GNUNET_array_grow (sampler->sampler_elements,
sampler->sampler_size,
new_size);
for (i = old_size ; i < new_size ; i++)
{ /* Add new sampler elements */
sampler->sampler_elements[i] = RPS_sampler_elem_create ();
-
- to_file (sampler->file_name,
- "+%" PRIu32 ": %s",
- i,
- sampler->sampler_elements[i]->file_name);
}
}
else
struct SamplerNotifyUpdateCTX *notify_ctx_head;
struct SamplerNotifyUpdateCTX *notify_ctx_tail;
- #ifdef TO_FILE
- /**
- * File name to log to
- */
- char *file_name;
- #endif /* TO_FILE */
};