Classes | Public Member Functions | Static Public Member Functions | Private Member Functions | Private Attributes | Friends | List of all members
grpc::internal::ClientCallbackWriterImpl< Request > Class Template Reference

#include <client_callback.h>

Inheritance diagram for grpc::internal::ClientCallbackWriterImpl< Request >:
Inheritance graph
[legend]

Classes

struct  StartCallBacklog
 

Public Member Functions

void AddHold (int holds) override
 
void RemoveHold () override
 
void StartCall () ABSL_LOCKS_EXCLUDED(start_mu_) override
 
void Write (const Request *msg, grpc::WriteOptions options) ABSL_LOCKS_EXCLUDED(start_mu_) override
 
void WritesDone () ABSL_LOCKS_EXCLUDED(start_mu_) override
 
- Public Member Functions inherited from grpc::ClientCallbackWriter< Request >
void Write (const Request *req)
 
void WriteLast (const Request *req, grpc::WriteOptions options)
 
virtual ~ClientCallbackWriter ()
 

Static Public Member Functions

static void operator delete (void *, std::size_t size)
 
static void operator delete (void *, void *)
 

Private Member Functions

StartCallBacklog backlog_ ABSL_GUARDED_BY (start_mu_)
 
template<class Response >
 ClientCallbackWriterImpl (grpc::internal::Call call, grpc::ClientContext *context, Response *response, ClientWriteReactor< Request > *reactor)
 
void MaybeFinish (bool from_reaction)
 

Private Attributes

grpc::internal::Call call_
 
std::atomic< intptr_tcallbacks_outstanding_ {3}
 
grpc::ClientContext *const context_
 
bool corked_write_needed_
 
grpc::internal::CallOpSet< grpc::internal::CallOpGenericRecvMessage, grpc::internal::CallOpClientRecvStatusfinish_ops_
 
grpc::Status finish_status_
 
grpc::internal::CallbackWithSuccessTag finish_tag_
 
ClientWriteReactor< Request > *const reactor_
 
const bool start_corked_
 
grpc::internal::Mutex start_mu_
 
grpc::internal::CallOpSet< grpc::internal::CallOpSendInitialMetadata, grpc::internal::CallOpRecvInitialMetadatastart_ops_
 
grpc::internal::CallbackWithSuccessTag start_tag_
 
std::atomic_bool started_ {false}
 
grpc::internal::CallOpSet< grpc::internal::CallOpSendInitialMetadata, grpc::internal::CallOpSendMessage, grpc::internal::CallOpClientSendClosewrite_ops_
 
grpc::internal::CallbackWithSuccessTag write_tag_
 
grpc::internal::CallOpSet< grpc::internal::CallOpSendInitialMetadata, grpc::internal::CallOpClientSendClosewrites_done_ops_
 
grpc::internal::CallbackWithSuccessTag writes_done_tag_
 

Friends

class ClientCallbackWriterFactory< Request >
 

Additional Inherited Members

- Protected Member Functions inherited from grpc::ClientCallbackWriter< Request >
void BindReactor (ClientWriteReactor< Request > *reactor)
 

Detailed Description

template<class Request>
class grpc::internal::ClientCallbackWriterImpl< Request >

Definition at line 885 of file impl/codegen/client_callback.h.

Constructor & Destructor Documentation

◆ ClientCallbackWriterImpl()

template<class Request >
template<class Response >
grpc::internal::ClientCallbackWriterImpl< Request >::ClientCallbackWriterImpl ( grpc::internal::Call  call,
grpc::ClientContext context,
Response *  response,
ClientWriteReactor< Request > *  reactor 
)
inlineprivate

Definition at line 994 of file impl/codegen/client_callback.h.

Member Function Documentation

◆ ABSL_GUARDED_BY()

template<class Request >
StartCallBacklog backlog_ grpc::internal::ClientCallbackWriterImpl< Request >::ABSL_GUARDED_BY ( start_mu_  )
private

◆ AddHold()

template<class Request >
void grpc::internal::ClientCallbackWriterImpl< Request >::AddHold ( int  holds)
inlineoverridevirtual

◆ MaybeFinish()

template<class Request >
void grpc::internal::ClientCallbackWriterImpl< Request >::MaybeFinish ( bool  from_reaction)
inlineprivate

Definition at line 1038 of file impl/codegen/client_callback.h.

◆ operator delete() [1/2]

template<class Request >
static void grpc::internal::ClientCallbackWriterImpl< Request >::operator delete ( void *  ,
std::size_t  size 
)
inlinestatic

Definition at line 888 of file impl/codegen/client_callback.h.

◆ operator delete() [2/2]

template<class Request >
static void grpc::internal::ClientCallbackWriterImpl< Request >::operator delete ( void *  ,
void *   
)
inlinestatic

Definition at line 897 of file impl/codegen/client_callback.h.

◆ RemoveHold()

template<class Request >
void grpc::internal::ClientCallbackWriterImpl< Request >::RemoveHold ( )
inlineoverridevirtual

◆ StartCall()

template<class Request >
void grpc::internal::ClientCallbackWriterImpl< Request >::StartCall ( )
inlineoverridevirtual

◆ Write()

template<class Request >
void grpc::internal::ClientCallbackWriterImpl< Request >::Write ( const Request *  msg,
grpc::WriteOptions  options 
)
inlineoverridevirtual

◆ WritesDone()

template<class Request >
void grpc::internal::ClientCallbackWriterImpl< Request >::WritesDone ( )
inlineoverridevirtual

Friends And Related Function Documentation

◆ ClientCallbackWriterFactory< Request >

template<class Request >
friend class ClientCallbackWriterFactory< Request >
friend

Definition at line 991 of file impl/codegen/client_callback.h.

Member Data Documentation

◆ call_

template<class Request >
grpc::internal::Call grpc::internal::ClientCallbackWriterImpl< Request >::call_
private

Definition at line 1055 of file impl/codegen/client_callback.h.

◆ callbacks_outstanding_

template<class Request >
std::atomic<intptr_t> grpc::internal::ClientCallbackWriterImpl< Request >::callbacks_outstanding_ {3}
private

Definition at line 1090 of file impl/codegen/client_callback.h.

◆ context_

template<class Request >
grpc::ClientContext* const grpc::internal::ClientCallbackWriterImpl< Request >::context_
private

Definition at line 1054 of file impl/codegen/client_callback.h.

◆ corked_write_needed_

template<class Request >
bool grpc::internal::ClientCallbackWriterImpl< Request >::corked_write_needed_
private

Definition at line 1063 of file impl/codegen/client_callback.h.

◆ finish_ops_

Definition at line 1068 of file impl/codegen/client_callback.h.

◆ finish_status_

template<class Request >
grpc::Status grpc::internal::ClientCallbackWriterImpl< Request >::finish_status_
private

Definition at line 1070 of file impl/codegen/client_callback.h.

◆ finish_tag_

template<class Request >
grpc::internal::CallbackWithSuccessTag grpc::internal::ClientCallbackWriterImpl< Request >::finish_tag_
private

Definition at line 1069 of file impl/codegen/client_callback.h.

◆ reactor_

template<class Request >
ClientWriteReactor<Request>* const grpc::internal::ClientCallbackWriterImpl< Request >::reactor_
private

Definition at line 1056 of file impl/codegen/client_callback.h.

◆ start_corked_

template<class Request >
const bool grpc::internal::ClientCallbackWriterImpl< Request >::start_corked_
private

Definition at line 1062 of file impl/codegen/client_callback.h.

◆ start_mu_

template<class Request >
grpc::internal::Mutex grpc::internal::ClientCallbackWriterImpl< Request >::start_mu_
private

Definition at line 1092 of file impl/codegen/client_callback.h.

◆ start_ops_

Definition at line 1060 of file impl/codegen/client_callback.h.

◆ start_tag_

template<class Request >
grpc::internal::CallbackWithSuccessTag grpc::internal::ClientCallbackWriterImpl< Request >::start_tag_
private

Definition at line 1061 of file impl/codegen/client_callback.h.

◆ started_

template<class Request >
std::atomic_bool grpc::internal::ClientCallbackWriterImpl< Request >::started_ {false}
private

Definition at line 1091 of file impl/codegen/client_callback.h.

◆ write_ops_

Definition at line 1075 of file impl/codegen/client_callback.h.

◆ write_tag_

template<class Request >
grpc::internal::CallbackWithSuccessTag grpc::internal::ClientCallbackWriterImpl< Request >::write_tag_
private

Definition at line 1076 of file impl/codegen/client_callback.h.

◆ writes_done_ops_

Definition at line 1080 of file impl/codegen/client_callback.h.

◆ writes_done_tag_

template<class Request >
grpc::internal::CallbackWithSuccessTag grpc::internal::ClientCallbackWriterImpl< Request >::writes_done_tag_
private

Definition at line 1081 of file impl/codegen/client_callback.h.


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


grpc
Author(s):
autogenerated on Fri May 16 2025 03:03:33