grpc::experimental::OrcaService::Reactor Class Reference

Inheritance diagram for grpc::experimental::OrcaService::Reactor:

Public Member Functions
void	OnCancel () override
void	OnDone () override
void	OnWriteDone (bool ok) override
	Reactor (OrcaService *service, const ByteBuffer *request_buffer)
Public Member Functions inherited from grpc::ServerWriteReactor< ByteBuffer >
void	Finish (grpc::Status s) ABSL_LOCKS_EXCLUDED(writer_mu_)
void	OnCancel () override
virtual void	OnSendInitialMetadataDone (bool)
	The following notifications are exactly like ServerBidiReactor. More...
	ServerWriteReactor ()
void	StartSendInitialMetadata () ABSL_LOCKS_EXCLUDED(writer_mu_)
	The following operation initiations are exactly like ServerBidiReactor. More...
void	StartWrite (const ByteBuffer *resp)
void	StartWrite (const ByteBuffer *resp, grpc::WriteOptions options) ABSL_LOCKS_EXCLUDED(writer_mu_)
void	StartWriteAndFinish (const ByteBuffer *resp, grpc::WriteOptions options, grpc::Status s) ABSL_LOCKS_EXCLUDED(writer_mu_)
void	StartWriteLast (const ByteBuffer *resp, grpc::WriteOptions options)
	~ServerWriteReactor () override=default
Public Member Functions inherited from grpc_core::RefCounted< Reactor >
RefCounted &	operator= (const RefCounted &)=delete
RefCountedPtr< Reactor >	Ref () GRPC_MUST_USE_RESULT
RefCountedPtr< Reactor >	Ref (const DebugLocation &location, const char *reason) GRPC_MUST_USE_RESULT
	RefCounted (const RefCounted &)=delete
RefCountedPtr< Reactor >	RefIfNonZero () GRPC_MUST_USE_RESULT
RefCountedPtr< Reactor >	RefIfNonZero (const DebugLocation &location, const char *reason) GRPC_MUST_USE_RESULT
void	Unref ()
void	Unref (const DebugLocation &location, const char *reason)
	~RefCounted ()=default
Public Member Functions inherited from grpc_core::PolymorphicRefCount
virtual	~PolymorphicRefCount ()=default

Private Member Functions
bool	MaybeCancelTimer ()
bool	MaybeScheduleTimer ()
void	OnTimer ()
void	SendResponse ()

Private Attributes
grpc_core::Duration	report_interval_
ByteBuffer	response_
OrcaService *	service_
grpc::internal::Mutex	timer_mu_
absl::optional< EventEngine::TaskHandle > timer_handle_ ABSL_GUARDED_BY &	timer_mu_
bool cancelled_ ABSL_GUARDED_BY	timer_mu_ = false

Additional Inherited Members
Public Types inherited from grpc_core::RefCounted< Reactor >
using	RefCountedChildType = Reactor
Protected Member Functions inherited from grpc_core::RefCounted< Reactor >
	RefCounted (const char *trace=nullptr, intptr_t initial_refcount=1)

Detailed Description

Definition at line 63 of file orca_service.cc.

Constructor & Destructor Documentation

Reactor()

grpc::experimental::OrcaService::Reactor::Reactor ( OrcaService *  service, const ByteBuffer *  request_buffer  )

inlineexplicit

Definition at line 66 of file orca_service.cc.

Member Function Documentation

MaybeCancelTimer()

bool grpc::experimental::OrcaService::Reactor::MaybeCancelTimer ( )

inlineprivate

Definition at line 136 of file orca_service.cc.

MaybeScheduleTimer()

bool grpc::experimental::OrcaService::Reactor::MaybeScheduleTimer ( )

inlineprivate

Definition at line 125 of file orca_service.cc.

OnCancel()

void grpc::experimental::OrcaService::Reactor::OnCancel ( )

inlineoverride

Definition at line 106 of file orca_service.cc.

OnDone()

void grpc::experimental::OrcaService::Reactor::OnDone ( )

inlineoverridevirtual

Implements grpc::ServerWriteReactor< ByteBuffer >.

Definition at line 112 of file orca_service.cc.

OnTimer()

void grpc::experimental::OrcaService::Reactor::OnTimer ( )

inlineprivate

Definition at line 147 of file orca_service.cc.

OnWriteDone()

void grpc::experimental::OrcaService::Reactor::OnWriteDone ( bool  ok )

inlineoverridevirtual

Reimplemented from grpc::ServerWriteReactor< ByteBuffer >.

Definition at line 95 of file orca_service.cc.

SendResponse()

void grpc::experimental::OrcaService::Reactor::SendResponse ( )

inlineprivate

Definition at line 118 of file orca_service.cc.

Member Data Documentation

report_interval_

grpc_core::Duration grpc::experimental::OrcaService::Reactor::report_interval_

private

Definition at line 162 of file orca_service.cc.

response_

ByteBuffer grpc::experimental::OrcaService::Reactor::response_

private

Definition at line 163 of file orca_service.cc.

service_

OrcaService* grpc::experimental::OrcaService::Reactor::service_

private

Definition at line 155 of file orca_service.cc.

timer_mu_ [1/3]

grpc::internal::Mutex grpc::experimental::OrcaService::Reactor::timer_mu_

private

Definition at line 157 of file orca_service.cc.

timer_mu_ [2/3]

absl::optional<EventEngine::TaskHandle> timer_handle_ ABSL_GUARDED_BY& grpc::experimental::OrcaService::Reactor::timer_mu_

private

Definition at line 159 of file orca_service.cc.

timer_mu_ [3/3]

bool cancelled_ ABSL_GUARDED_BY grpc::experimental::OrcaService::Reactor::timer_mu_ = false

private

Definition at line 160 of file orca_service.cc.

---

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

• orca_service.cc