uint64_t num_peers,
const struct GNUNET_PeerIdentity *peers);
-/**
- * Callback called when view was updated
- *
- * @param num_peers the number of peers returned
- * @param peers array with num_peers PeerIDs
- */
-typedef void (* GNUNET_RPS_ViewUpdateCB) (void *cls,
- uint64_t num_peers,
- const struct GNUNET_PeerIdentity *peers);
-
-/**
- * Callback called when a peer from the biased stream was received
- *
- * @param peer The received peer
- */
-typedef void (* GNUNET_RPS_StreamInputCB) (void *cls,
- uint64_t num_peers,
- const struct GNUNET_PeerIdentity *peer);
/**
* Connect to the rps service
void
GNUNET_RPS_view_request (struct GNUNET_RPS_Handle *rps_handle,
uint32_t num_updates,
- GNUNET_RPS_ViewUpdateCB view_update_cb,
+ GNUNET_RPS_NotifyReadyCB view_update_cb,
void *cls);
void
GNUNET_RPS_stream_request (struct GNUNET_RPS_Handle *rps_handle,
uint32_t num_updates,
- GNUNET_RPS_StreamInputCB stream_input_cb,
+ GNUNET_RPS_NotifyReadyCB stream_input_cb,
void *cls);
/**
* @brief Callback called on each update of the view
*/
- GNUNET_RPS_ViewUpdateCB view_update_cb;
+ GNUNET_RPS_NotifyReadyCB view_update_cb;
/**
* @brief Closure to each requested update of the view
/**
* @brief Callback called on each peer of the biased input stream
*/
- GNUNET_RPS_StreamInputCB stream_input_cb;
+ GNUNET_RPS_NotifyReadyCB stream_input_cb;
/**
* @brief Closure to each requested peer from the biased stream
void
GNUNET_RPS_view_request (struct GNUNET_RPS_Handle *rps_handle,
uint32_t num_updates,
- GNUNET_RPS_ViewUpdateCB view_update_cb,
+ GNUNET_RPS_NotifyReadyCB view_update_cb,
void *cls)
{
struct GNUNET_MQ_Envelope *ev;
void
GNUNET_RPS_stream_request (struct GNUNET_RPS_Handle *rps_handle,
uint32_t num_peers,
- GNUNET_RPS_StreamInputCB stream_input_cb,
+ GNUNET_RPS_NotifyReadyCB stream_input_cb,
void *cls)
{
struct GNUNET_MQ_Envelope *ev;