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__namedpipe_8cpp_source.html below:

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

rv = ::FormatMessage(FORMAT_MESSAGE_ALLOCATE_BUFFER |

FORMAT_MESSAGE_FROM_SYSTEM |

FORMAT_MESSAGE_MAX_WIDTH_MASK |

FORMAT_MESSAGE_IGNORE_INSERTS,

MAKELANGID(LANG_NEUTRAL, SUBLANG_DEFAULT),

errstr = errmsg.c_str();

::LocalFree((HLOCAL) tmpstr);

retval.

() ? retval.

() : message;

+ where +

+ what;

(

== ERROR_NO_DATA ||

== ERROR_BROKEN_PIPE ||

== ERROR_PIPE_NOT_CONNECTED ?

:

);

m_ReadStatus(eIO_Closed), m_WriteStatus(eIO_Closed)

+

);

SECURITY_ATTRIBUTES attr;

attr.nLength =

(attr);

attr.bInheritHandle =

;

attr.lpSecurityDescriptor =

;

x_sleep = 1;

GENERIC_READ | GENERIC_WRITE,

FILE_SHARE_READ | FILE_SHARE_WRITE,

&attr, OPEN_EXISTING, FILE_ATTRIBUTE_NORMAL,

= PIPE_READMODE_BYTE | PIPE_NOWAIT;

( ::SetNamedPipeHandleState(pipe, &

,

,

) ) {

= ::GetLastError();

= ::GetLastError();

&&

!= ERROR_PIPE_BUSY) ||

&&

!= ERROR_PIPE_NOT_CONNECTED)) {

&&

== ERROR_FILE_NOT_FOUND) {

+ pipename

?

:

));

(x_timeout != INFINITE) {

(x_sleep > x_timeout) {

x_timeout -= x_sleep;

(

& what) {

+

);

+ pipename

SECURITY_ATTRIBUTES attr;

attr.nLength =

(attr);

attr.bInheritHandle =

;

attr.lpSecurityDescriptor =

;

= ::CreateNamedPipe

PIPE_TYPE_BYTE | PIPE_NOWAIT,

(

== ERROR_ALREADY_EXISTS) {

+ pipename

+

);

(

& what) {

x_sleep = 1;

(

== ERROR_PIPE_CONNECTED) {

(

== ERROR_NO_DATA

) {

+

);

(

!= ERROR_PIPE_LISTENING) {

+

);

(x_timeout != INFINITE) {

(x_sleep > x_timeout) {

x_timeout -= x_sleep;

(

& what) {

+

);

+

);

(!::DisconnectNamedPipe(

)) {

+

);

(void) ::CloseHandle(

);

+

);

(

& what) {

(

& what) {

(void) ::CloseHandle(

);

x_sleep = 1;

(x_timeout != INFINITE) {

(x_sleep > x_timeout) {

x_timeout -= x_sleep;

:

));

(bytes_avail >

) {

( !bytes_avail ) {

+

);

*n_read = bytes_avail;

}

(status != eIO_Closed) {

+

);

(

& what) {

* n_written,

* timeout)

(n_written && !*n_written);

:

));

bytes_written = 0;

x_sleep = 1;

( bytes_written ) {

+

);

(x_timeout != INFINITE) {

(x_sleep > x_timeout) {

x_timeout -= x_sleep;

*n_written = bytes_written;

(

& what) {

:

)));

status == eIO_Closed ?

: status;

( direction ) {

kListenQueueSize = 64;

x_SetSocketBufSize(

sock,

,

dir);

: m_LSocket(0), m_IoSocket(0), m_PipeSize(0)

(m_LSocket || m_IoSocket) {

+

);

|| (status == eIO_Closed

+ pipename

+

(!x_SetSocketBufSize(fd, pipesize, SO_SNDBUF) ||

!x_SetSocketBufSize(fd, pipesize, SO_RCVBUF)) {

+ pipename

(

& what) {

(m_LSocket || m_IoSocket) {

+

);

(pipe.GetType()) {

+ pipename

+

);

+ pipename

+

m_PipeSize = pipesize;

(

& what) {

(!m_LSocket || m_IoSocket) {

+

+

(m_LSocket

status =

(m_LSocket, timeout, &m_IoSocket);

+

(!x_SetSocketBufSize(fd, m_PipeSize, SO_SNDBUF) ||

!x_SetSocketBufSize(fd, m_PipeSize, SO_RCVBUF)) {

+

(

& what) {

( !m_IoSocket ) {

+

));

(!m_LSocket && !m_IoSocket) {

( !m_IoSocket ) {

+

+

(m_LSocket

+

(

& what) {

* n_written,

* timeout)

(n_written && !*n_written);

( !m_IoSocket ) {

+

+

(m_LSocket

+

(

& what) {

( !m_IoSocket ) {

(m_IoSocket, event, timeout);

!m_IoSocket ? eIO_Closed :

(m_IoSocket, direction);

CNamedPipeHandle::x_SetSocketBufSize(

sock,

,

dir)

(::getsockopt(sock, SOL_SOCKET, dir, &bs_old, &bs_len) == 0

&& bs_new > bs_old) {

(::setsockopt(sock, SOL_SOCKET, dir, &bs_new, bs_len) != 0) {

: m_PipeSize(pipesize),

m_OpenTimeout(0), m_ReadTimeout(0), m_WriteTimeout(0)

n_written = &x_written;

(direction) {

kSeparators[] =

;

kSeparators[] =

;

(pipename.find_first_of(kSeparators) !=

) {

* pipedir =

;

(::stat(pipedir, &

) != 0 || !S_ISDIR(

.st_mode)

|| ::access(pipedir, W_OK) != 0) {

(::stat(pipedir, &

) != 0 || !S_ISDIR(

.st_mode)

|| ::access(pipedir, W_OK) != 0) {

(pipename, timeout);

EIO_Status Status(EIO_Event direction) const

EIO_Status Open(const string &pipename, const STimeout *timeout, size_t pipesize, CNamedPipeClient::TFlags flags)

EIO_Status x_WaitForRead(const STimeout *timeout, DWORD *in_avail)

EIO_Status Close(bool close=true)

EIO_Status Read(void *buf, size_t count, size_t *n_read, const STimeout *timeout)

EIO_Status Listen(const STimeout *timeout)

EIO_Status x_Disconnect(bool orderly)

EIO_Status Disconnect(void)

EIO_Status Create(const string &pipename, size_t pipesize)

EIO_Status Wait(EIO_Event event, const STimeout *timeout)

EIO_Status Write(const void *buf, size_t count, size_t *n_written, const STimeout *timeout)

element_type * get(void) const

Get pointer.

@ eTakeOwnership

An object can take ownership of another.

@ eNoOwnership

No ownership is assumed.

#define ERR_POST_X(err_subcode, message)

Error posting with default error code and given error subcode.

@ eSocket

Socket (UNIX only)

CNamedPipeClient(size_t pipesize=0)

Default constructor.

const STimeout * m_OpenTimeout

Timeouts.

EIO_Status Create(const string &pipename, const STimeout *timeout=kDefaultTimeout, size_t pipesize=0)

Create a server-side pipe.

CNamedPipeServer(size_t pipesize=0)

Default constructor.

EIO_Status Wait(EIO_Event event, const STimeout *timeout)

Wait for I/O readiness in the pipe.

EIO_Status Status(EIO_Event direction) const

Return (for the specified "direction"): eIO_Closed – if the pipe is closed for I/O; eIO_Timeout – if ...

const STimeout * GetTimeout(EIO_Event event) const

Get the pipe I/O timeout (or NULL, if the timeout is infinite).

bool m_IsClientSide

client/server-side pipe

STimeout m_ReadTimeoutValue

storage for m_ReadTimeout

string m_PipeName

pipe name

EIO_Status Close(void)

Close pipe connection.

EIO_Status Listen(void)

Listen on a pipe for new client connection.

void x_SetName(const string &pipename)

STimeout m_OpenTimeoutValue

storage for m_OpenTimeout

size_t m_PipeSize

pipe size

virtual ~CNamedPipe()

Destructor.

CNamedPipe(size_t pipe_size=0)

Constructor.

const STimeout * m_WriteTimeout

eIO_Write

EIO_Status Read(void *buf, size_t count, size_t *n_read=0)

Read data from the pipe.

STimeout m_WriteTimeoutValue

storage for m_WriteTimeout

const STimeout * m_ReadTimeout

eIO_Read

EIO_Status SetTimeout(EIO_Event event, const STimeout *timeout)

Specify timeout for the pipe I/O (see Open|Read|Write functions).

CNamedPipeHandle * m_NamedPipeHandle

OS-specific handle.

EIO_Status Open(const string &pipename, const STimeout *timeout=kDefaultTimeout, size_t pipesize=0, TFlags flags=0)

Open a client-side pipe connection.

EIO_Status Disconnect(void)

Disconnect the client.

EIO_Status Write(const void *buf, size_t count, size_t *n_written=0)

Write data to the pipe.

@ fNoLogIfClosed

Do not log error if server end is closed.

#define END_NCBI_SCOPE

End previously defined NCBI scope.

#define BEGIN_NCBI_SCOPE

Define ncbi namespace.

EIO_Status LSOCK_CreateUNIX(const char *path, unsigned short backlog, LSOCK *lsock, TSOCK_Flags flags)

EIO_Status SOCK_SetTimeout(SOCK sock, EIO_Event event, const STimeout *timeout)

Specify timeout for the connection I/O (see SOCK_[Read|Write|Close]()).

EIO_Status SOCK_Close(SOCK sock)

Close the SOCK handle, and destroy all relevant internal data.

EIO_Status LSOCK_Accept(LSOCK lsock, const STimeout *timeout, SOCK *sock)

[SERVER-side] Accept connection from a client.

EIO_Status SOCK_Read(SOCK sock, void *buf, size_t size, size_t *n_read, EIO_ReadMethod how)

Read/peek up to "size" bytes from "sock" to a buffer pointed to by "buf".

EIO_Status SOCK_Status(SOCK sock, EIO_Event direction)

Return low-level socket I/O status of *last* socket operation.

EIO_Status SOCK_Wait(SOCK sock, EIO_Event event, const STimeout *timeout)

Block on the socket until either the specified "event" is available or "timeout" expires (if "timeout...

EIO_Status SOCK_Write(SOCK sock, const void *data, size_t size, size_t *n_written, EIO_WriteMethod how)

Write "size" bytes of "data" to "sock".

EIO_Status LSOCK_Close(LSOCK lsock)

[SERVER-side] Close the listening socket, destroy relevant internal data.

EIO_Status SOCK_CreateUNIX(const char *path, const STimeout *timeout, SOCK *sock, const void *data, size_t size, TSOCK_Flags flags)

EIO_Status SOCK_GetOSHandle(SOCK sock, void *handle_buf, size_t handle_size)

Same as SOCK_GetOSHandleEx(sock, handle_buf, handle_size, eNoOwnership).

static enable_if< is_arithmetic< TNumeric >::value||is_convertible< TNumeric, Int8 >::value, string >::type NumericToString(TNumeric value, TNumToStringFlags flags=0, int base=10)

Convert numeric value to string.

static string & ToLower(string &str)

Convert string to lower case – string& version.

const long kMicroSecondsPerSecond

Number of microseconds in one second.

unsigned long NcbiTimeoutToMs(const STimeout *timeout)

unsigned int usec

microseconds (modulo 1,000,000)

const char * IO_StatusStr(EIO_Status status)

Get the text form of an enum status value.

const char * NcbiMessagePlusError(int *dynamic, const char *message, int error, const char *descr)

Add current "error" (and maybe its description) to the message: <message>[ {error=[[<error>][,...

EIO_Event

I/O event (or direction).

@ eIO_Timeout

timeout expired before any I/O succeeded

@ eIO_Success

everything is fine, no error occurred

@ eIO_Unknown

unknown I/O error (likely fatal but can retry)

@ 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

#define INVALID_HANDLE_VALUE

A value for an invalid file handle.

#define HANDLE

An abstraction for a file handle.

unsigned int

A callback function used to compare two keys in a database.

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

static const STimeout kZeroTimeout

#define NAMEDPIPE_THROW(err, errtxt)

static string x_FormatError(int error, const string &message)

AutoPtr< char, CDeleter< char > > TTempCharPtr

static string s_FormatErrorMessage(const string &where, const string &what)

const unsigned long kWaitPrecision

static const STimeout * s_SetTimeout(const STimeout *from, STimeout *to)

static bool x_IsDisconnectError(DWORD error)

Portable interprocess named pipe API for: UNIX, MS-Win.

#define TRUE

bool replacment for C indicating true.

void SleepMilliSec(unsigned long ml_sec, EInterruptOnSignal onsignal=eRestartOnSignal)

Defines classes: CDirEntry, CFile, CDir, CSymLink, CMemoryFile, CFileUtil, CFileLock,...

static PCRE2_SIZE bufsize

static SLJIT_INLINE sljit_ins st(sljit_gpr r, sljit_s32 d, sljit_gpr x, sljit_gpr b)

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