#include "rtxsrc/rtxContext.h"
#include "rtxsrc/rtxMemBuf.h"

Macros
#define	OSRTSTRMF_INPUT 0x0001

#define	OSRTSTRMF_OUTPUT 0x0002

#define	OSRTSTRMF_BUFFERED 0x8000 /* direct-buffer stream */

#define	OSRTSTRMF_UNBUFFERED 0x4000 /* force unbuffered stream */

#define	OSRTSTRMF_POSMARKED 0x2000 /* stream has marked position */

#define	OSRTSTRMF_FIXINMEM 0x1000 /* disable flushing */

#define	OSRTSTRMF_HEXTEXT 0x0800 /* do hex text / binary conversion */

#define	OSRTSTRMF_BUF_INPUT (OSRTSTRMF_INPUT\|OSRTSTRMF_BUFFERED)

#define	OSRTSTRMF_BUF_OUTPUT (OSRTSTRMF_OUTPUT\|OSRTSTRMF_BUFFERED)

#define	OSRTSTRMID_FILE 1

#define	OSRTSTRMID_SOCKET 2

#define	OSRTSTRMID_MEMORY 3

#define	OSRTSTRMID_BUFFERED 4

#define	OSRTSTRMID_DIRECTBUF 5

#define	OSRTSTRMID_CTXTBUF 6

#define	OSRTSTRMID_ZLIB 7

#define	OSRTSTRMID_USER 1000

#define	OSRTSTRM_K_BUFSIZE 1024

#define	OSRTSTRM_K_INVALIDMARK ((size_t)-1)

#define	OSRTSTREAM_BYTEINDEX(pctxt)

#define	OSRTSTREAM_ID(pctxt) ((pctxt)->pStream->id)

#define	OSRTSTREAM_FLAGS(pctxt) ((pctxt)->pStream->flags)

#define	rtxStreamBlockingRead rtxStreamRead

Typedefs
typedef long(*	OSRTStreamReadProc) (struct OSRTSTREAM pStream, OSOCTET pbuffer, size_t nocts)

typedef OSRTStreamReadProc	OSRTStreamBlockingReadProc

typedef long(*	OSRTStreamWriteProc) (struct OSRTSTREAM pStream, const OSOCTET data, size_t numocts)

typedef int(*	OSRTStreamFlushProc) (struct OSRTSTREAM *pStream)

typedef int(*	OSRTStreamCloseProc) (struct OSRTSTREAM *pStream)

typedef int(*	OSRTStreamSkipProc) (struct OSRTSTREAM *pStream, size_t skipBytes)

typedef int(*	OSRTStreamMarkProc) (struct OSRTSTREAM *pStream, size_t readAheadLimit)

typedef int(*	OSRTStreamResetProc) (struct OSRTSTREAM *pStream)

typedef int(*	OSRTStreamGetPosProc) (struct OSRTSTREAM pStream, size_t ppos)

typedef int(*	OSRTStreamSetPosProc) (struct OSRTSTREAM *pStream, size_t pos)

typedef struct OSRTSTREAM	OSRTSTREAM

Functions
int	rtxStreamClose (OSCTXT *pctxt)

int	rtxStreamFlush (OSCTXT *pctxt)

int	rtxStreamLoadInputBuffer (OSCTXT *pctxt, OSSIZE nbytes)

int	rtxStreamInit (OSCTXT *pctxt)

int	rtxStreamInitCtxtBuf (OSCTXT *pctxt)

int	rtxStreamRemoveCtxtBuf (OSCTXT *pctxt)

long	rtxStreamRead (OSCTXT pctxt, OSOCTET pbuffer, size_t nocts)

long	rtxStreamRead2 (OSCTXT pctxt, OSOCTET pbuffer, size_t nocts, size_t bufSize)

long	rtxStreamReadDirect (OSCTXT pctxt, OSOCTET pbuffer, OSSIZE bufSize)

int	rtxStreamSkip (OSCTXT *pctxt, size_t skipBytes)

long	rtxStreamWrite (OSCTXT pctxt, const OSOCTET data, size_t numocts)

int	rtxStreamGetIOBytes (OSCTXT pctxt, size_t pPos)

int	rtxStreamMark (OSCTXT *pctxt, size_t readAheadLimit)

int	rtxStreamReset (OSCTXT *pctxt)

OSBOOL	rtxStreamMarkSupported (OSCTXT *pctxt)

OSBOOL	rtxStreamIsOpened (OSCTXT *pctxt)

OSBOOL	rtxStreamIsReadable (OSCTXT *pctxt)

OSBOOL	rtxStreamIsWritable (OSCTXT *pctxt)

int	rtxStreamRelease (OSCTXT *pctxt)

void	rtxStreamSetCapture (OSCTXT pctxt, OSRTMEMBUF pmembuf)

OSRTMEMBUF *	rtxStreamGetCapture (OSCTXT *pctxt)

int	rtxStreamGetPos (OSCTXT pctxt, size_t ppos)

int	rtxStreamSetPos (OSCTXT *pctxt, size_t pos)

Detailed Description

Input/output data stream type definitions and function prototypes.

Classes