Logo ROOT  
Reference Guide
 
Loading...
Searching...
No Matches
THttpWSEngine Class Referenceabstract

Internal instance used to exchange WS functionality between THttpServer and THttpWSHandler.

Normally should not be used directly

Definition at line 26 of file THttpWSEngine.h.

Public Member Functions

virtual ~THttpWSEngine ()=default
 
virtual void ClearHandle (Bool_t)=0
 
virtual UInt_t GetId () const =0
 
virtual void PostProcess (std::shared_ptr< THttpCallArg > &arg)
 Method invoked after user process data received via websocket.
 
virtual Bool_t PreProcess (std::shared_ptr< THttpCallArg > &arg)
 Method should be invoked before processing data coming from websocket If method returns kTRUE, data is processed internally and not dedicated for further usage.
 
virtual void Send (const void *buf, int len)=0
 
virtual void SendCharStar (const char *str)
 Envelope for sending string via the websocket.
 
virtual void SendHeader (const char *hdr, const void *buf, int len)=0
 

Protected Member Functions

 THttpWSEngine ()=default
 
virtual Bool_t CanSendDirectly ()
 One always can send data to websocket - as long as previous send operation completed.
 
virtual Bool_t SupportSendThrd () const
 Indicate if engine require extra thread to complete postponed thread operation.
 

Private Types

enum  { kNone , kData , kHeader , kText }
 

Private Attributes

std::condition_variable fCond
 ! condition used to sync with sending thread
 
std::string fData
 ! data (binary or text)
 
bool fDisabled {false}
 ! true shortly before cleanup, set under locked fMutex from WSHandler
 
bool fHasSendThrd {false}
 ! if thread was started one have to call join method for it
 
std::string fHdr
 ! header
 
bool fMTSend {false}
 ! true when send operation runs, set under locked fMutex from WSHandler
 
std::mutex fMutex
 ! protects all data behind
 
bool fSending {false}
 ! performing send operation in other thread
 
std::thread fSendThrd
 ! dedicated thread for all send operations
 
bool fWaiting {false}
 ! if condition wait is called
 
enum THttpWSEngine:: { ... }  kNone
 ! kind of operation
 

Friends

class THttpWSHandler
 

#include </home/sftnight/build/workspace/root-makedoc-v628/rootspi/rdoc/src/v6-28-00-patches/net/http/src/THttpWSEngine.h>

Inheritance diagram for THttpWSEngine:
[legend]

Member Enumeration Documentation

◆ anonymous enum

anonymous enum
private
Enumerator
kNone 
kData 
kHeader 
kText 

Definition at line 41 of file THttpWSEngine.h.

Constructor & Destructor Documentation

◆ THttpWSEngine()

THttpWSEngine::THttpWSEngine ( )
protecteddefault

◆ ~THttpWSEngine()

virtual THttpWSEngine::~THttpWSEngine ( )
virtualdefault

Member Function Documentation

◆ CanSendDirectly()

virtual Bool_t THttpWSEngine::CanSendDirectly ( )
inlineprotectedvirtual

One always can send data to websocket - as long as previous send operation completed.

Reimplemented in THttpLongPollEngine.

Definition at line 52 of file THttpWSEngine.h.

◆ ClearHandle()

virtual void THttpWSEngine::ClearHandle ( Bool_t  )
pure virtual

Implemented in TCivetwebWSEngine, and THttpLongPollEngine.

◆ GetId()

virtual UInt_t THttpWSEngine::GetId ( ) const
pure virtual

Implemented in TCivetwebWSEngine, and THttpLongPollEngine.

◆ PostProcess()

void THttpWSEngine::PostProcess ( std::shared_ptr< THttpCallArg > &  arg)
virtual

Method invoked after user process data received via websocket.

Reimplemented in THttpLongPollEngine.

Definition at line 48 of file THttpWSEngine.cxx.

◆ PreProcess()

Bool_t THttpWSEngine::PreProcess ( std::shared_ptr< THttpCallArg > &  arg)
virtual

Method should be invoked before processing data coming from websocket If method returns kTRUE, data is processed internally and not dedicated for further usage.

Reimplemented in THttpLongPollEngine.

Definition at line 40 of file THttpWSEngine.cxx.

◆ Send()

virtual void THttpWSEngine::Send ( const void *  buf,
int  len 
)
pure virtual

Implemented in TCivetwebWSEngine, and THttpLongPollEngine.

◆ SendCharStar()

void THttpWSEngine::SendCharStar ( const char *  str)
virtual

Envelope for sending string via the websocket.

Reimplemented in THttpLongPollEngine, and TCivetwebWSEngine.

Definition at line 29 of file THttpWSEngine.cxx.

◆ SendHeader()

virtual void THttpWSEngine::SendHeader ( const char *  hdr,
const void *  buf,
int  len 
)
pure virtual

Implemented in TCivetwebWSEngine, and THttpLongPollEngine.

◆ SupportSendThrd()

virtual Bool_t THttpWSEngine::SupportSendThrd ( ) const
inlineprotectedvirtual

Indicate if engine require extra thread to complete postponed thread operation.

Reimplemented in TCivetwebWSEngine.

Definition at line 49 of file THttpWSEngine.h.

Friends And Related Symbol Documentation

◆ THttpWSHandler

friend class THttpWSHandler
friend

Definition at line 29 of file THttpWSEngine.h.

Member Data Documentation

◆ fCond

std::condition_variable THttpWSEngine::fCond
private

! condition used to sync with sending thread

Definition at line 38 of file THttpWSEngine.h.

◆ fData

std::string THttpWSEngine::fData
private

! data (binary or text)

Definition at line 42 of file THttpWSEngine.h.

◆ fDisabled

bool THttpWSEngine::fDisabled {false}
private

! true shortly before cleanup, set under locked fMutex from WSHandler

Definition at line 32 of file THttpWSEngine.h.

◆ fHasSendThrd

bool THttpWSEngine::fHasSendThrd {false}
private

! if thread was started one have to call join method for it

Definition at line 35 of file THttpWSEngine.h.

◆ fHdr

std::string THttpWSEngine::fHdr
private

! header

Definition at line 43 of file THttpWSEngine.h.

◆ fMTSend

bool THttpWSEngine::fMTSend {false}
private

! true when send operation runs, set under locked fMutex from WSHandler

Definition at line 31 of file THttpWSEngine.h.

◆ fMutex

std::mutex THttpWSEngine::fMutex
private

! protects all data behind

Definition at line 37 of file THttpWSEngine.h.

◆ fSending

bool THttpWSEngine::fSending {false}
private

! performing send operation in other thread

Definition at line 40 of file THttpWSEngine.h.

◆ fSendThrd

std::thread THttpWSEngine::fSendThrd
private

! dedicated thread for all send operations

Definition at line 34 of file THttpWSEngine.h.

◆ fWaiting

bool THttpWSEngine::fWaiting {false}
private

! if condition wait is called

Definition at line 39 of file THttpWSEngine.h.

◆ []

enum { ... } THttpWSEngine::kNone

! kind of operation

  • net/http/src/THttpWSEngine.h
  • net/http/src/THttpWSEngine.cxx