GRPC C++  1.62.0
Public Member Functions | Protected Member Functions
grpc::ServerInterface::GenericAsyncRequest Class Reference

#include <server_interface.h>

Public Member Functions

 GenericAsyncRequest (ServerInterface *server, GenericServerContext *context, internal::ServerAsyncStreamingInterface *stream, grpc::CompletionQueue *call_cq, grpc::ServerCompletionQueue *notification_cq, void *tag, bool delete_on_finalize, bool issue_request=true)
 
bool FinalizeResult (void **tag, bool *status) override
 FinalizeResult must be called before informing user code that the operation bound to the underlying core completion queue tag has completed. More...
 
- Public Member Functions inherited from grpc::ServerInterface::BaseAsyncRequest
 BaseAsyncRequest (ServerInterface *server, grpc::ServerContext *context, internal::ServerAsyncStreamingInterface *stream, grpc::CompletionQueue *call_cq, grpc::ServerCompletionQueue *notification_cq, void *tag, bool delete_on_finalize)
 
 ~BaseAsyncRequest () override
 
- Public Member Functions inherited from grpc::internal::CompletionQueueTag
virtual ~CompletionQueueTag ()
 

Protected Member Functions

void IssueRequest ()
 

Additional Inherited Members

- Protected Attributes inherited from grpc::ServerInterface::BaseAsyncRequest
ServerInterface *const server_
 
grpc::ServerContext *const context_
 
internal::ServerAsyncStreamingInterface *const stream_
 
grpc::CompletionQueue *const call_cq_
 
grpc::ServerCompletionQueue *const notification_cq_
 
void *const tag_
 
const bool delete_on_finalize_
 
grpc_callcall_
 
internal::Call call_wrapper_
 
internal::InterceptorBatchMethodsImpl interceptor_methods_
 
bool done_intercepting_
 
bool call_metric_recording_enabled_
 
experimental::ServerMetricRecorderserver_metric_recorder_
 

Constructor & Destructor Documentation

◆ GenericAsyncRequest()

grpc::ServerInterface::GenericAsyncRequest::GenericAsyncRequest ( ServerInterface server,
GenericServerContext context,
internal::ServerAsyncStreamingInterface stream,
grpc::CompletionQueue call_cq,
grpc::ServerCompletionQueue notification_cq,
void *  tag,
bool  delete_on_finalize,
bool  issue_request = true 
)

Member Function Documentation

◆ FinalizeResult()

bool grpc::ServerInterface::GenericAsyncRequest::FinalizeResult ( void **  tag,
bool *  status 
)
overridevirtual

FinalizeResult must be called before informing user code that the operation bound to the underlying core completion queue tag has completed.

In practice, this means:

  1. For the sync API - before returning from Pluck
  2. For the CQ-based async API - before returning from Next
  3. For the callback-based API - before invoking the user callback

This is the method that translates from core-side tag/status to C++ API-observable tag/status.

The return value is the status of the operation (returning status is the general behavior of this function). If this function returns false, the tag is dropped and not returned from the completion queue: this concept is for events that are observed at core but not requested by the user application (e.g., server shutdown, for server unimplemented method responses, or for cases where a server-side RPC doesn't have a completion notification registered using AsyncNotifyWhenDone)

Reimplemented from grpc::ServerInterface::BaseAsyncRequest.

◆ IssueRequest()

void grpc::ServerInterface::GenericAsyncRequest::IssueRequest ( )
protected

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