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

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

NCBI C++ ToolKit: src/connect/ncbi_conn_streambuf.cpp Source File

unique_ptr<char, void (*)(

*)>

(

);

::sprintf(x_timeout,

,

timeout->

/ 1000000 + timeout->

,

timeout->

% 1000000);

: m_Conn(0), x_Connector(connector),

m_WriteBuf(0), m_ReadBuf(&x_Buf), m_BufSize(1), m_Status(status),

: m_Conn(

), x_Connector(0),

m_WriteBuf(0), m_ReadBuf(&x_Buf), m_BufSize(1), m_Status(

),

unique_ptr<CT_CHAR_TYPE[]> wbp;

setp(write_buf, write_buf + buf_size);

setg(ptr, ptr, ptr +

);

,

, timeout));

= (size_t)(egptr() - gptr());

gbump(

(

));

));

(pbase() < pptr()) {

));

synced =

;

,

}

(cb_valid &&

.

) {

(

|| buf_size) {

);

,

));

(pbase() <= pptr() && pptr() <= epptr());

n_towrite = (size_t)(pptr() - pbase());

(n_written <= n_towrite);

(pbase(), pbase() + n_written, n_towrite - n_written);

pbump(-

(n_written));

n_towrite -= n_written;

(pbase() <= pptr() && pptr() <= epptr());

= (size_t) m;

n_written = 0;

(

&& pbase() +

< epptr()) {

x_written = (size_t)(epptr() - pptr());

memcpy(pptr(),

, x_written);

pbump(

(x_written));

n_written += x_written;

(streamsize) n_written;

x_towrite = (size_t)(pptr() - pbase());

(x_written <= x_towrite);

(pbase(), pbase() + x_written, x_towrite - x_written);

pbump(-

(x_written));

(!x_written &&

) {

,

,

n_written += x_written;

(streamsize) n_written;

x_written = (size_t)(epptr() - pptr());

memcpy(pptr(),

, x_written);

n_written += x_written;

pbump(

(x_written));

(streamsize) n_written;

(m_MIPSPRO_ReadsomeGptrSetLevel && m_MIPSPRO_ReadsomeGptr != gptr())

= (size_t) m;

n_read = (size_t)(egptr() - gptr());

memcpy(

, gptr(), n_read);

gbump(

(n_read));

(streamsize) n_read;

xx_read = x_read;

(streamsize) n_read;

polling = !x_tmo

|| (x_tmo->

| x_tmo->

);

IOS_BASE::seekdir whence,

IOS_BASE::openmode which)

(whence == IOS_BASE::cur && off == 0) {

&& ((whence == IOS_BASE::cur && (off > 0)) ||

(whence == IOS_BASE::beg && (off -=

()) >= 0))){

(

&&

(0, (streamsize) off) == (streamsize) off)

));

(pbase() < pptr()) {

synced =

;

(gptr() < egptr())

,

(GetErrCode()) {

:

;

(GetErrCode()) {

:

;

:

;

:

;

CConn_Streambuf(CONNECTOR connector, EIO_Status status, const STimeout *timeout, size_t buf_size, CConn_IOStream::TConn_Flags flags, CT_CHAR_TYPE *ptr, size_t size)

virtual ~CConn_Streambuf()

EIO_Status Status(EIO_Event direction) const

virtual CT_INT_TYPE underflow(void)

streamsize x_Read(CT_CHAR_TYPE *buf, streamsize n)

void x_Init(const STimeout *timeout, size_t buf_size, CConn_IOStream::TConn_Flags flags, CT_CHAR_TYPE *ptr, size_t size)

CT_POS_TYPE x_GetPPos(void)

CT_CHAR_TYPE * m_WriteBuf

string x_Message(const char *method, const char *message, EIO_Status status=eIO_Success, const STimeout *timeout=kInfiniteTimeout)

virtual CT_INT_TYPE overflow(CT_INT_TYPE c)

virtual streamsize xsgetn(CT_CHAR_TYPE *buf, streamsize n)

static EIO_Status x_OnClose(CONN conn, TCONN_Callback type, void *data)

EIO_Status Fetch(const STimeout *timeout)

virtual CT_POS_TYPE seekoff(CT_OFF_TYPE off, IOS_BASE::seekdir whence, IOS_BASE::openmode which=IOS_BASE::in|IOS_BASE::out)

Only seekoff(0, IOS_BASE::cur, *) to obtain the current position, and input skip-forward are permitte...

EIO_Status x_Close(bool close)

virtual streamsize xsputn(const CT_CHAR_TYPE *buf, streamsize n)

EIO_Status Pushback(const CT_CHAR_TYPE *data, streamsize size, bool push)

Push the specified data "data" of size "size" back into the underlying connection CONN.

virtual CNcbiStreambuf * setbuf(CT_CHAR_TYPE *buf, streamsize buf_size)

Only setbuf(0, 0) is allowed to make I/O unbuffered, other parameters will cause an exception thrown ...

virtual streamsize showmanyc(void)

EIO_Status x_Pushback(void) THROWS_NONE

CT_POS_TYPE x_GetGPos(void)

std::ofstream out("events_result.xml")

main entry point for tests

static CS_CONNECTION * conn

virtual const char * GetErrCodeString(void) const override

virtual const char * GetErrCodeString(void) const override

#define NCBI_IO_CHECK(errnum)

Check EIO_Status, throw an exception if something is wrong.

@ eConn

Unspecified connect problem.

unsigned int TConn_Flags

bitwise OR of EConn_Flag

@ fConn_ReadUnbuffered

read buffer NOT to be alloc'd

@ fConn_WriteUnbuffered

write buffer NOT 2.b. alloc'd

@ fConn_DelayOpen

do not force CONN open in ctor

@ fConn_Untie

do not flush before reading

EIO_Status CONN_CreateEx(CONNECTOR connector, TCONN_Flags flags, CONN *conn)

Create all data necessary to establish a new connection (merely bind it to the specified CONNECTOR).

EIO_Status CONN_Read(CONN conn, void *buf, size_t size, size_t *n_read, EIO_ReadMethod how)

EIO_Status CONN_Flush(CONN conn)

Explicitly flush connection from any pending data written by CONN_Write().

EIO_Status CONN_SetCallback(CONN conn, ECONN_Callback type, const SCONN_Callback *new_cb, SCONN_Callback *old_cb)

unsigned int TCONN_Callback

EIO_Status CONN_Write(CONN conn, const void *buf, size_t size, size_t *n_written, EIO_WriteMethod how)

CONNECTOR next

linked list

void * data

data to pass to the callback as its last arg

EIO_Status CONN_SetTimeout(CONN conn, EIO_Event event, const STimeout *timeout)

Specify timeout for the connection I/O, including "Connect" (aka "Open") and "Close".

char * CONN_Description(CONN conn)

Return a human-readable description of the connection as a character '\0'-terminated string.

FDestroy destroy

destroys handle, can be NULL

EIO_Status CONN_Wait(CONN conn, EIO_Event event, const STimeout *timeout)

Block on the connection until it becomes available for either reading or writing (depending on "event...

SMetaConnector * meta

back link to original meta

const char * CONN_GetType(CONN conn)

Get verbal representation of connection type as a character string.

EIO_Status CONN_Close(CONN conn)

Close the connection and destroy all relevant internal data.

EIO_Status CONN_GetSOCK(CONN conn, SOCK *sock)

Get an underlying SOCK handle for connection that is implemented as a socket.

const STimeout * CONN_GetTimeout(CONN conn, EIO_Event event)

Retrieve current timeout, return NULL(kInfiniteTimeout) if it is infinite.

const STimeout g_NcbiDefConnTimeout

DEF_CONN_TIMEOUT as STimeout.

EIO_Status CONN_Status(CONN conn, EIO_Event dir)

Obtain status of the last I/O operation.

EIO_Status CONN_Pushback(CONN conn, const void *data, size_t size)

Push "size" bytes from the buffer "data" back into connection.

FCONN_Callback func

function address to call on the event

@ eCONN_OnClose

NB: CONN has been flushed prior to the call.

@ fCONN_Untie

do not call flush method prior to reading

@ fCONN_Supplement

supplement I/O with extended return codes

#define _ALWAYS_TRACE(message)

Define macros to support debugging.

#define ERR_POST_X(err_subcode, message)

Error posting with default error code and given error subcode.

void Critical(CExceptionArgs_Base &args)

void Error(CExceptionArgs_Base &args)

#define NCBI_THROW(exception_class, err_code, message)

Generic macro to throw an exception, given the exception class, error code and message string.

void Trace(CExceptionArgs_Base &args)

void Warning(CExceptionArgs_Base &args)

#define THROWS_NONE

Do not use 'throw' dynamic exception specification for C++11 compilers.

virtual const char * GetErrCodeString(void) const

Get error code interpreted as text.

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.

IO_PREFIX::streambuf CNcbiStreambuf

Portable alias for streambuf.

unsigned int usec

microseconds (modulo 1,000,000)

const char * IO_StatusStr(EIO_Status status)

Get the text form of an enum status value.

EIO_Event

I/O event (or direction).

@ eIO_Timeout

timeout expired before any I/O succeeded

@ eIO_NotSupported

operation is not supported or is not available

@ eIO_Success

everything is fine, no error occurred

@ eIO_InvalidArg

bad argument / parameter value(s) supplied

@ eIO_ReadPlain

read readily available data only, wait if none

@ eIO_WritePlain

write as much as possible, report back how much

@ eIO_ReadWrite

eIO_Read | eIO_Write (also, eCONN_OnFlush)

@ eIO_Open

also serves as no-event indicator in SOCK_Poll

@ eIO_Close

also serves as an error indicator in SOCK_Poll

Definition of all error codes used in connect library (xconnect.lib, xconnext.lib etc).

static const CS_INT unused

static void text(MDB_val *v)

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

static bool x_CheckConn(const CONN conn)

static bool x_IsThrowable(EIO_Status status)

static const STimeout * x_GetDefaultTimeout(const CONN conn)

NCBI C++ auxiliary debug macros.

std::istream & in(std::istream &in_, double &x_)

const CNSPreciseTime default_timeout(3600, 0)

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