Home - News ( United States | United Kingdom | Italy | Germany ) - Football scores

Showing content from http://www.ncbi.nlm.nih.gov/IEB/ToolBox/CPP_DOC/doxyhtml/srv__sockets_8hpp_source.html below:

NCBI C++ ToolKit: src/app/netcache/srv_sockets.hpp Source File

intr = boost::intrusive;

SSrvSockList_tag;

intr::list_member_hook<intr::tag<SSrvSockList_tag> >

;

SSrvSockList_tag;

<

NumType>

<

NumType>

Factory that creates CSrvSocketTask-derived object for each connection coming to listening port which...

virtual CSrvSocketTask * CreateSocketTask(void)=0

virtual ~CSrvSocketFactory(void)

Task controlling a socket.

Uint2 m_WrPos

Position of current writing pointer in the write buffer.

Uint8 m_ConnStartJfy

Jiffy number when Connect() method was called.

bool IsProxyInProgress(void)

Check whether proxying started earlier is still in progress.

bool NeedToClose(void)

Checks if socket should be closed because of long inactivity or because server is in "hard" shutdown ...

bool Connect(Uint4 host, Uint2 port)

Create new socket and connect it to given IP and port.

void x_CloseSocket(bool do_abort)

Close or abort the socket – they have little difference, thus they joined in one method.

bool m_RegReadHup

Flag showing if epoll returned RDHUP on this socket.

CSrvSocketTask * m_ProxySrc

Source task for proxying.

Uint1 m_SeenWriteEvts

Number of last write event seen by Write() when it wrote to socket.

bool HasError(void)

Checks if socket has some error in it.

bool m_CRMet

Flag showing if '\r' symbol was seen at the end of last line but ' ' wasn't seen yet.

Uint8 m_ReadBytes

Total number of bytes read from socket.

int m_Fd

File descriptor for the socket.

size_t Write(const void *buf, size_t size)

Write into the socket as much as immediately possible (including writing into internal write buffers ...

void AbortSocket(void)

Abort the socket, i.e.

Uint2 m_PeerPort

Remembered peer port.

CSrvSocketTask & WriteText(CTempString message)

Write text into socket.

CSrvSocketTask & WriteNumber(NumType num)

Write number into socket as string, i.e.

void GetPeerAddress(string &host, Uint2 &port)

Get peer IP and port for this socket.

bool IsReadDataAvailable(void)

Checks if there's some data available for reading in internal buffers.

void CloseSocket(void)

Close the socket gracefully, i.e.

Uint2 m_WrMemSize

Size of memory allocated for write buffer.

Uint8 m_ProxySize

Amount left to proxy if proxying operation is in progress.

bool ProxyHadError(void)

Check whether proxying started earlier finished successfully or any of sockets had some error in it.

CSrvSocketTask & operator=(const CSrvSocketTask &)

bool m_NeedToFlush

Flag showing that task needs to flush all write buffers.

virtual void InternalRunSlice(TSrvThreadNum thr_num)

Internal function to execute time slice work.

virtual void Terminate(void)

Terminate the task.

bool m_NeedToClose

Flag showing that socket needs to be closed because of long inactivity.

char * m_RdBuf

Read buffer.

Uint4 m_PeerAddr

Remembered peer IP address.

bool m_ErrorPrinted

Flag showing if pending error in socket was printed in logs.

bool CanHaveMoreRead(void)

Checks if socket can ever have more data to read even though it may not have it at the moment.

bool m_ProxyHadError

Flag showing that last proxying operation finished with error.

bool m_SockCanReadMore

Flag showing that socket can have more reads, i.e. there was no EOF yet.

bool m_FlushIsDone

Flag showing that write buffers were flushed.

bool m_RegError

Flag showing if there's error pending on the socket.

bool ReadData(void *buf, Uint2 size)

Read from socket exactly the given data size.

CSrvSocketTask * m_ProxyDst

Destination task for proxying.

bool ReadToBuf(void)

Read from socket into internal buffer.

void RequestFlush(void)

Request flushing of all data saved in internal write buffers to socket.

Uint2 m_RdPos

Position of current reading in the read buffer, i.e.

void Flush(void)

Flush all data saved in internal write buffers to socket.

size_t Read(void *buf, size_t size)

Read from socket into memory.

bool ReadNumber(NumType *num)

Read from socket a number in native machine representation.

char * m_WrBuf

Write buffer.

virtual ~CSrvSocketTask(void)

Uint2 GetLocalPort(void)

Get local port this socket was created on.

void WriteData(const void *buf, size_t size)

Write the exact amount of data into the socket.

Uint1 m_SeenReadEvts

Number of last read event seen by Read() when it read from socket.

bool IsWriteDataPending(void)

Checks if there's some data pending in write buffers and waiting to be sent to kernel.

Uint2 m_WrSize

Size of data in the write buffer waiting for writing.

Uint8 m_WrittenBytes

Total number of bytes written to socket.

Uint2 m_RdSize

Size of data available for reading in the read buffer.

bool m_SockCanWrite

Flag showing that socket is writable.

bool StartProcessing(TSrvThreadNum thread_num=0, bool boost=false)

Start processing of the socket and include it into TaskServer's central epoll.

bool ReadLine(CTempString *line)

Read from socket one line which ends with ' ', '\r ' or '\0'.

bool NeedEarlyClose(void)

Checks if socket should be closed because of internal reasons (long inactivity or "hard" shutdown as ...

void x_PrintError(void)

Prints socket's error if there's any error pending on the socket.

void StartProxyTo(CSrvSocketTask *dst_task, Uint8 proxy_size)

Start proxying of raw data from this socket to the one in dst_task.

Uint1 m_RegWriteEvts

Counter of "writable" events received from epoll.

CSrvSocketTask(const CSrvSocketTask &)

bool m_SockHasRead

Flag showing that socket is readable.

CSrvSocketTask & WriteBool(bool b)

bool FlushIsDone(void)

Check if data flushing requested earlier is complete.

Uint1 m_RegReadEvts

Counter of "readable" events received from epoll.

Main working entity in TaskServer.

CTempString implements a light-weight string on top of a storage buffer whose lifetime management is ...

uint8_t Uint1

1-byte (8-bit) unsigned integer

uint32_t Uint4

4-byte (32-bit) unsigned integer

uint16_t Uint2

2-byte (16-bit) unsigned integer

uint64_t Uint8

8-byte (64-bit) unsigned integer

#define END_NCBI_SCOPE

End previously defined NCBI scope.

#define BEGIN_NCBI_SCOPE

Define ncbi namespace.

const struct ncbi::grid::netcache::search::fields::SIZE size

intr::list_base_hook< intr::tag< SSrvSockList_tag > > TSrvSockListHook

For TaskServer's internal use only.

Uint2 TSrvThreadNum

Type for thread number in TaskServer.

RetroSearch is an open source project built by @garambo | Open a GitHub Issue

Search and Browse the WWW like it's 1997 | Search results from DuckDuckGo

HTML: 3.2 | Encoding: UTF-8 | Version: 0.7.4