An active request. More...
Data Fields | |
struct GSF_PendingRequestData | public_data |
Public data for the request. More... | |
GSF_PendingRequestReplyHandler | rh |
Function to call if we encounter a reply. More... | |
void * | rh_cls |
Closure for rh. More... | |
struct GNUNET_HashCode * | replies_seen |
Array of hash codes of replies we've already seen. More... | |
struct GNUNET_BLOCK_Group * | bg |
Block group for filtering replies we've already seen. More... | |
struct GNUNET_CONTAINER_HeapNode * | hnode |
Entry for this pending request in the expiration heap, or NULL. More... | |
struct GNUNET_DATASTORE_QueueEntry * | qe |
Datastore queue entry for this request (or NULL for none). More... | |
struct GNUNET_DHT_GetHandle * | gh |
DHT request handle for this request (or NULL for none). More... | |
struct GSF_CadetRequest * | cadet_request |
Cadet request handle for this request (or NULL for none). More... | |
GSF_LocalLookupContinuation | llc_cont |
Function to call upon completion of the local get request, or NULL for none. More... | |
void * | llc_cont_cls |
Closure for llc_cont. More... | |
enum GNUNET_BLOCK_ReplyEvaluationResult | local_result |
Last result from the local datastore lookup evaluation. More... | |
GNUNET_PEER_Id | sender_pid |
Identity of the peer that we should use for the 'sender' (recipient of the response) when forwarding (0 for none). More... | |
GNUNET_PEER_Id | origin_pid |
Identity of the peer that we should never forward this query to since it originated this query (0 for none). More... | |
struct GNUNET_TIME_Absolute | qe_start |
Time we started the last datastore lookup. More... | |
struct GNUNET_SCHEDULER_Task * | warn_task |
Task that warns us if the local datastore lookup takes too long. More... | |
bool | have_first_uid |
Do we have a first UID yet? More... | |
bool | seen_null |
Have we seen a NULL result yet? More... | |
uint64_t | first_uid |
Unique ID of the first result from the local datastore; used to terminate the loop. More... | |
size_t | result_count |
Result count. More... | |
unsigned int | cadet_retry_count |
How often have we retried this request via 'cadet'? (used to bound overall retries). More... | |
unsigned int | replies_seen_count |
Number of valid entries in the 'replies_seen' array. More... | |
unsigned int | replies_seen_size |
Length of the 'replies_seen' array. More... | |
An active request.
Definition at line 77 of file gnunet-service-fs_pr.c.
struct GSF_PendingRequestData GSF_PendingRequest::public_data |
Public data for the request.
Definition at line 82 of file gnunet-service-fs_pr.c.
Referenced by cadet_reply_proc(), call_continuation(), clean_request(), GSF_cadet_lookup_(), GSF_dht_lookup_(), GSF_pending_request_cancel_(), GSF_pending_request_create_(), GSF_pending_request_get_data_(), GSF_pending_request_get_message_(), GSF_pending_request_is_compatible_(), GSF_pending_request_update_(), no_more_local_results(), process_local_reply(), process_reply(), start_local_query(), and update_request_performance_data().
GSF_PendingRequestReplyHandler GSF_PendingRequest::rh |
Function to call if we encounter a reply.
Definition at line 87 of file gnunet-service-fs_pr.c.
Referenced by call_continuation(), GSF_pending_request_cancel_(), GSF_pending_request_create_(), GSF_pending_request_test_active_(), and process_reply().
void* GSF_PendingRequest::rh_cls |
Closure for rh.
Definition at line 92 of file gnunet-service-fs_pr.c.
Referenced by call_continuation(), GSF_pending_request_create_(), and process_reply().
struct GNUNET_HashCode* GSF_PendingRequest::replies_seen |
Array of hash codes of replies we've already seen.
Definition at line 97 of file gnunet-service-fs_pr.c.
Referenced by clean_request(), GSF_dht_lookup_(), GSF_pending_request_create_(), GSF_pending_request_update_(), and refresh_bloomfilter().
struct GNUNET_BLOCK_Group* GSF_PendingRequest::bg |
Block group for filtering replies we've already seen.
Definition at line 102 of file gnunet-service-fs_pr.c.
Referenced by clean_request(), GSF_pending_request_create_(), GSF_pending_request_get_message_(), GSF_pending_request_update_(), process_reply(), and refresh_bloomfilter().
struct GNUNET_CONTAINER_HeapNode* GSF_PendingRequest::hnode |
Entry for this pending request in the expiration heap, or NULL.
Definition at line 107 of file gnunet-service-fs_pr.c.
Referenced by clean_request(), and GSF_pending_request_create_().
struct GNUNET_DATASTORE_QueueEntry* GSF_PendingRequest::qe |
Datastore queue entry for this request (or NULL for none).
Definition at line 112 of file gnunet-service-fs_pr.c.
Referenced by call_continuation(), clean_request(), GSF_pending_request_cancel_(), process_local_reply(), and start_local_query().
struct GNUNET_DHT_GetHandle* GSF_PendingRequest::gh |
DHT request handle for this request (or NULL for none).
Definition at line 117 of file gnunet-service-fs_pr.c.
Referenced by clean_request(), GSF_dht_lookup_(), GSF_local_lookup_(), GSF_pending_request_cancel_(), and GSF_pending_request_update_().
struct GSF_CadetRequest* GSF_PendingRequest::cadet_request |
Cadet request handle for this request (or NULL for none).
Definition at line 122 of file gnunet-service-fs_pr.c.
Referenced by cadet_reply_proc(), clean_request(), GSF_cadet_lookup_(), GSF_local_lookup_(), and GSF_pending_request_cancel_().
GSF_LocalLookupContinuation GSF_PendingRequest::llc_cont |
Function to call upon completion of the local get request, or NULL for none.
Definition at line 128 of file gnunet-service-fs_pr.c.
Referenced by call_continuation(), clean_request(), GSF_local_lookup_(), and GSF_pending_request_cancel_().
void* GSF_PendingRequest::llc_cont_cls |
Closure for llc_cont.
Definition at line 133 of file gnunet-service-fs_pr.c.
Referenced by call_continuation(), clean_request(), GSF_local_lookup_(), and GSF_pending_request_cancel_().
enum GNUNET_BLOCK_ReplyEvaluationResult GSF_PendingRequest::local_result |
Last result from the local datastore lookup evaluation.
Definition at line 138 of file gnunet-service-fs_pr.c.
Referenced by call_continuation(), clean_request(), GSF_pending_request_cancel_(), and process_local_reply().
GNUNET_PEER_Id GSF_PendingRequest::sender_pid |
Identity of the peer that we should use for the 'sender' (recipient of the response) when forwarding (0 for none).
Definition at line 144 of file gnunet-service-fs_pr.c.
Referenced by clean_request(), GSF_dht_lookup_(), GSF_pending_request_create_(), and GSF_pending_request_get_message_().
GNUNET_PEER_Id GSF_PendingRequest::origin_pid |
Identity of the peer that we should never forward this query to since it originated this query (0 for none).
Definition at line 150 of file gnunet-service-fs_pr.c.
Referenced by clean_request(), GSF_pending_request_create_(), and GSF_pending_request_test_target_().
struct GNUNET_TIME_Absolute GSF_PendingRequest::qe_start |
Time we started the last datastore lookup.
Definition at line 155 of file gnunet-service-fs_pr.c.
Referenced by odc_warn_delay_task(), process_local_reply(), start_local_query(), and warn_delay_task().
struct GNUNET_SCHEDULER_Task* GSF_PendingRequest::warn_task |
Task that warns us if the local datastore lookup takes too long.
Definition at line 160 of file gnunet-service-fs_pr.c.
Referenced by call_continuation(), clean_request(), GSF_pending_request_cancel_(), odc_warn_delay_task(), process_local_reply(), start_local_query(), and warn_delay_task().
bool GSF_PendingRequest::have_first_uid |
Do we have a first UID yet?
Definition at line 165 of file gnunet-service-fs_pr.c.
Referenced by process_local_reply().
bool GSF_PendingRequest::seen_null |
Have we seen a NULL result yet?
Definition at line 170 of file gnunet-service-fs_pr.c.
Referenced by process_local_reply().
uint64_t GSF_PendingRequest::first_uid |
Unique ID of the first result from the local datastore; used to terminate the loop.
Definition at line 176 of file gnunet-service-fs_pr.c.
Referenced by process_local_reply().
size_t GSF_PendingRequest::result_count |
Result count.
Definition at line 181 of file gnunet-service-fs_pr.c.
Referenced by process_local_reply().
unsigned int GSF_PendingRequest::cadet_retry_count |
How often have we retried this request via 'cadet'? (used to bound overall retries).
Definition at line 187 of file gnunet-service-fs_pr.c.
Referenced by cadet_reply_proc(), clean_request(), and GSF_pending_request_cancel_().
unsigned int GSF_PendingRequest::replies_seen_count |
Number of valid entries in the 'replies_seen' array.
Definition at line 192 of file gnunet-service-fs_pr.c.
Referenced by GSF_dht_lookup_(), GSF_pending_request_create_(), GSF_pending_request_update_(), and refresh_bloomfilter().
unsigned int GSF_PendingRequest::replies_seen_size |
Length of the 'replies_seen' array.
Definition at line 197 of file gnunet-service-fs_pr.c.
Referenced by GSF_pending_request_create_(), and GSF_pending_request_update_().