GNUnet 0.21.0
GSF_PendingRequest Struct Reference

An active request. More...

Collaboration diagram for GSF_PendingRequest:
[legend]

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_HashCodereplies_seen
 Array of hash codes of replies we've already seen. More...
 
struct GNUNET_BLOCK_Groupbg
 Block group for filtering replies we've already seen. More...
 
struct GNUNET_CONTAINER_HeapNodehnode
 Entry for this pending request in the expiration heap, or NULL. More...
 
struct GNUNET_DATASTORE_QueueEntryqe
 Datastore queue entry for this request (or NULL for none). More...
 
struct GNUNET_DHT_GetHandlegh
 DHT request handle for this request (or NULL for none). More...
 
struct GSF_CadetRequestcadet_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_Taskwarn_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...
 

Detailed Description

An active request.

Definition at line 77 of file gnunet-service-fs_pr.c.

Field Documentation

◆ public_data

◆ rh

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().

◆ rh_cls

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().

◆ replies_seen

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().

◆ bg

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().

◆ hnode

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_().

◆ qe

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().

◆ gh

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_().

◆ cadet_request

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_().

◆ llc_cont

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_().

◆ llc_cont_cls

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_().

◆ local_result

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().

◆ sender_pid

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_().

◆ origin_pid

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_().

◆ qe_start

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().

◆ warn_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().

◆ have_first_uid

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().

◆ seen_null

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().

◆ first_uid

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().

◆ result_count

size_t GSF_PendingRequest::result_count

Result count.

Definition at line 181 of file gnunet-service-fs_pr.c.

Referenced by process_local_reply().

◆ cadet_retry_count

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_().

◆ replies_seen_count

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().

◆ replies_seen_size

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_().


The documentation for this struct was generated from the following file: