C++ Rest SDK
The C++ REST SDK is a Microsoft project for cloud-based client-server communication in native code using a modern asynchronous C++ API design. This project aims to help C++ developers connect to and interact with services.
Public Types | Public Member Functions | Protected Member Functions | Protected Attributes | List of all members
Concurrency::streams::details::streambuf_state_manager< _CharType > Class Template Referenceabstract
Inheritance diagram for Concurrency::streams::details::streambuf_state_manager< _CharType >:
Concurrency::streams::details::basic_streambuf< _CharType > Concurrency::streams::details::basic_file_buffer< _CharType > Concurrency::streams::details::basic_producer_consumer_buffer< _CharType > Concurrency::streams::details::basic_rawptr_buffer< _CharType > Concurrency::streams::details::basic_stdio_buffer< _CharType >

Public Types

typedef details::basic_streambuf< _CharType >::traits traits
 
typedef details::basic_streambuf< _CharType >::int_type int_type
 
typedef details::basic_streambuf< _CharType >::pos_type pos_type
 
typedef details::basic_streambuf< _CharType >::off_type off_type
 
- Public Types inherited from Concurrency::streams::details::basic_streambuf< _CharType >
typedef _CharType char_type
 
typedef ::concurrency::streams::char_traits< _CharType > traits
 
typedef traits::int_type int_type
 
typedef traits::pos_type pos_type
 
typedef traits::off_type off_type
 

Public Member Functions

virtual bool can_read () const
 can_read is used to determine whether a stream buffer will support read operations (get). More...
 
virtual bool can_write () const
 can_write is used to determine whether a stream buffer will support write operations (put). More...
 
virtual bool is_open () const
 Checks if the stream buffer is open. More...
 
virtual pplx::task< void > close (std::ios_base::openmode mode=std::ios_base::in|std::ios_base::out)
 Closes the stream buffer, preventing further read or write operations. More...
 
virtual pplx::task< void > close (std::ios_base::openmode mode, std::exception_ptr eptr)
 Closes the stream buffer with an exception. More...
 
virtual bool is_eof () const
 is_eof is used to determine whether a read head has reached the end of the buffer. More...
 
virtual pplx::task< int_type > putc (_CharType ch)
 Writes a single character to the stream. More...
 
virtual pplx::task< size_t > putn (const _CharType *ptr, size_t count)
 Writes a number of characters to the stream. More...
 
virtual pplx::task< size_t > putn_nocopy (const _CharType *ptr, size_t count)
 Writes a number of characters to the stream. Note: callers must make sure the data to be written is valid until the returned task completes. More...
 
virtual pplx::task< int_type > bumpc ()
 Reads a single character from the stream and advances the read position. More...
 
virtual int_type sbumpc ()
 Reads a single character from the stream and advances the read position. More...
 
virtual pplx::task< int_type > getc ()
 Reads a single character from the stream without advancing the read position. More...
 
virtual int_type sgetc ()
 Reads a single character from the stream without advancing the read position. More...
 
virtual pplx::task< int_type > nextc ()
 Advances the read position, then returns the next character without advancing again. More...
 
virtual pplx::task< int_type > ungetc ()
 Retreats the read position, then returns the current character without advancing. More...
 
virtual pplx::task< size_t > getn (_Out_writes_(count) _CharType *ptr, _In_ size_t count)
 Reads up to a given number of characters from the stream. More...
 
virtual size_t scopy (_Out_writes_(count) _CharType *ptr, _In_ size_t count)
 Copies up to a given number of characters from the stream, synchronously. More...
 
virtual pplx::task< void > sync ()
 For output streams, flush any internally buffered data to the underlying medium. More...
 
virtual std::exception_ptr exception () const
 Retrieves the stream buffer exception_ptr if it has been set. More...
 
_CharType * alloc (size_t count)
 Allocates a contiguous memory block and returns it. More...
 
void commit (size_t count)
 Submits a block already allocated by the stream buffer. More...
 
virtual bool can_seek () const =0
 can_seek is used to determine whether a stream buffer supports seeking. More...
 
virtual bool has_size () const =0
 has_size is used to determine whether a stream buffer supports size(). More...
 
virtual utility::size64_t size () const
 Gets the size of the stream, if known. Calls to has_size will determine whether the result of size can be relied on. More...
 
virtual size_t buffer_size (std::ios_base::openmode direction=std::ios_base::in) const =0
 Gets the stream buffer size, if one has been set. More...
 
virtual void set_buffer_size (size_t size, std::ios_base::openmode direction=std::ios_base::in)=0
 Sets the stream buffer implementation to buffer or not buffer. More...
 
virtual size_t in_avail () const =0
 For any input stream, in_avail returns the number of characters that are immediately available to be consumed without blocking. May be used in conjunction with <cref="::sbumpc method"/> to read data without incurring the overhead of using tasks. More...
 
virtual pos_type getpos (std::ios_base::openmode direction) const =0
 Gets the current read or write position in the stream. More...
 
virtual pos_type seekpos (pos_type pos, std::ios_base::openmode direction)=0
 Seeks to the given position. More...
 
virtual pos_type seekoff (off_type offset, std::ios_base::seekdir way, std::ios_base::openmode mode)=0
 Seeks to a position given by a relative offset. More...
 
virtual bool acquire (_Out_writes_(count) _CharType *&ptr, _In_ size_t &count)=0
 
virtual void release (_Out_writes_(count) _CharType *ptr, _In_ size_t count)=0
 Releases a block of data acquired using ::acquire method. This frees the stream buffer to de-allocate the memory, if it so desires. Move the read position ahead by the count. More...
 
- Public Member Functions inherited from Concurrency::streams::details::basic_streambuf< _CharType >
virtual ~basic_streambuf ()
 Virtual constructor for stream buffers. More...
 
virtual _CharType * alloc (_In_ size_t count)=0
 Allocates a contiguous memory block and returns it. More...
 
virtual void commit (_In_ size_t count)=0
 Submits a block already allocated by the stream buffer. More...
 
virtual bool acquire (_Out_ _CharType *&ptr, _Out_ size_t &count)=0
 Gets a pointer to the next already allocated contiguous block of data. More...
 

Protected Member Functions

virtual pplx::task< int_type > _putc (_CharType ch)=0
 
virtual pplx::task< size_t > _putn (const _CharType *ptr, size_t count, bool)
 
virtual pplx::task< size_t > _putn (const _CharType *ptr, size_t count)=0
 
virtual pplx::task< int_type > _bumpc ()=0
 
virtual int_type _sbumpc ()=0
 
virtual pplx::task< int_type > _getc ()=0
 
virtual int_type _sgetc ()=0
 
virtual pplx::task< int_type > _nextc ()=0
 
virtual pplx::task< int_type > _ungetc ()=0
 
virtual pplx::task< size_t > _getn (_Out_writes_(count) _CharType *ptr, _In_ size_t count)=0
 
virtual size_t _scopy (_Out_writes_(count) _CharType *ptr, _In_ size_t count)=0
 
virtual pplx::task< bool > _sync ()=0
 
virtual _CharType * _alloc (size_t count)=0
 
virtual void _commit (size_t count)=0
 
virtual pplx::task< void > _close_read ()
 The real read head close operation, implementation should override it if there is any resource to be released. More...
 
virtual pplx::task< void > _close_write ()
 The real write head close operation, implementation should override it if there is any resource to be released. More...
 
 streambuf_state_manager (std::ios_base::openmode mode)
 

Protected Attributes

std::exception_ptr m_currentException
 
bool m_stream_can_read
 
bool m_stream_can_write
 
bool m_stream_read_eof
 
bool m_alloced
 

Member Function Documentation

template<typename _CharType>
virtual pplx::task<void> Concurrency::streams::details::streambuf_state_manager< _CharType >::_close_read ( )
inlineprotectedvirtual

The real read head close operation, implementation should override it if there is any resource to be released.

Reimplemented in Concurrency::streams::details::basic_file_buffer< _CharType >.

template<typename _CharType>
virtual pplx::task<void> Concurrency::streams::details::streambuf_state_manager< _CharType >::_close_write ( )
inlineprotectedvirtual

The real write head close operation, implementation should override it if there is any resource to be released.

Reimplemented in Concurrency::streams::details::basic_file_buffer< _CharType >.

template<typename _CharType>
_CharType* Concurrency::streams::details::streambuf_state_manager< _CharType >::alloc ( size_t  count)
inline

Allocates a contiguous memory block and returns it.

Parameters
countThe number of characters to allocate.
Returns
A pointer to a block to write to, null if the stream buffer implementation does not support alloc/commit.

This is intended as an advanced API to be used only when it is important to avoid extra copies.

template<typename _CharType>
virtual size_t Concurrency::streams::details::streambuf_state_manager< _CharType >::buffer_size ( std::ios_base::openmode  direction = std::ios_base::in) const
pure virtual

Gets the stream buffer size, if one has been set.

Parameters
directionThe direction of buffering (in or out)
Returns
The size of the internal buffer (for the given direction).

An implementation that does not support buffering will always return 0.

Implements Concurrency::streams::details::basic_streambuf< _CharType >.

Implemented in Concurrency::streams::details::basic_file_buffer< _CharType >, Concurrency::streams::details::basic_rawptr_buffer< _CharType >, Concurrency::streams::details::basic_container_buffer< _CollectionType >, and Concurrency::streams::details::basic_producer_consumer_buffer< _CharType >.

template<typename _CharType>
virtual pplx::task<int_type> Concurrency::streams::details::streambuf_state_manager< _CharType >::bumpc ( )
inlinevirtual

Reads a single character from the stream and advances the read position.

Returns
The value of the character. EOF if the read fails.

Implements Concurrency::streams::details::basic_streambuf< _CharType >.

template<typename _CharType>
virtual bool Concurrency::streams::details::streambuf_state_manager< _CharType >::can_read ( ) const
inlinevirtual

can_read is used to determine whether a stream buffer will support read operations (get).

Implements Concurrency::streams::details::basic_streambuf< _CharType >.

template<typename _CharType>
virtual bool Concurrency::streams::details::streambuf_state_manager< _CharType >::can_seek ( ) const
pure virtual
template<typename _CharType>
virtual bool Concurrency::streams::details::streambuf_state_manager< _CharType >::can_write ( ) const
inlinevirtual

can_write is used to determine whether a stream buffer will support write operations (put).

Implements Concurrency::streams::details::basic_streambuf< _CharType >.

template<typename _CharType>
virtual pplx::task<void> Concurrency::streams::details::streambuf_state_manager< _CharType >::close ( std::ios_base::openmode  mode = std::ios_base::in | std::ios_base::out)
inlinevirtual

Closes the stream buffer, preventing further read or write operations.

Parameters
modeThe I/O mode (in or out) to close for.

Implements Concurrency::streams::details::basic_streambuf< _CharType >.

Reimplemented in Concurrency::streams::details::basic_rawptr_buffer< _CharType >.

template<typename _CharType>
virtual pplx::task<void> Concurrency::streams::details::streambuf_state_manager< _CharType >::close ( std::ios_base::openmode  mode,
std::exception_ptr  eptr 
)
inlinevirtual

Closes the stream buffer with an exception.

Parameters
modeThe I/O mode (in or out) to close for.
eptrPointer to the exception.

Implements Concurrency::streams::details::basic_streambuf< _CharType >.

template<typename _CharType>
void Concurrency::streams::details::streambuf_state_manager< _CharType >::commit ( size_t  count)
inline

Submits a block already allocated by the stream buffer.

Parameters
countThe number of characters to be committed.

This is intended as an advanced API to be used only when it is important to avoid extra copies.

template<typename _CharType>
virtual std::exception_ptr Concurrency::streams::details::streambuf_state_manager< _CharType >::exception ( ) const
inlinevirtual

Retrieves the stream buffer exception_ptr if it has been set.

Returns
Pointer to the exception, if it has been set; otherwise, nullptr will be returned.

Implements Concurrency::streams::details::basic_streambuf< _CharType >.

template<typename _CharType>
virtual pplx::task<int_type> Concurrency::streams::details::streambuf_state_manager< _CharType >::getc ( )
inlinevirtual

Reads a single character from the stream without advancing the read position.

Returns
The value of the byte. EOF if the read fails.

Implements Concurrency::streams::details::basic_streambuf< _CharType >.

template<typename _CharType>
virtual pplx::task<size_t> Concurrency::streams::details::streambuf_state_manager< _CharType >::getn ( _Out_writes_(count) _CharType *  ptr,
_In_ size_t  count 
)
inlinevirtual

Reads up to a given number of characters from the stream.

Parameters
ptrThe address of the target memory area.
countThe maximum number of characters to read.
Returns
The number of characters read. O if the end of the stream is reached.

Implements Concurrency::streams::details::basic_streambuf< _CharType >.

template<typename _CharType>
virtual pos_type Concurrency::streams::details::streambuf_state_manager< _CharType >::getpos ( std::ios_base::openmode  direction) const
pure virtual

Gets the current read or write position in the stream.

Parameters
directionThe I/O direction to seek (see remarks)
Returns
The current position. EOF if the operation fails.

Some streams may have separate write and read cursors. For such streams, the direction parameter defines whether to move the read or the write cursor.

Implements Concurrency::streams::details::basic_streambuf< _CharType >.

Implemented in Concurrency::streams::details::basic_file_buffer< _CharType >, Concurrency::streams::details::basic_rawptr_buffer< _CharType >, Concurrency::streams::details::basic_container_buffer< _CollectionType >, and Concurrency::streams::details::basic_producer_consumer_buffer< _CharType >.

template<typename _CharType>
virtual bool Concurrency::streams::details::streambuf_state_manager< _CharType >::has_size ( ) const
pure virtual
template<typename _CharType>
virtual size_t Concurrency::streams::details::streambuf_state_manager< _CharType >::in_avail ( ) const
pure virtual

For any input stream, in_avail returns the number of characters that are immediately available to be consumed without blocking. May be used in conjunction with <cref="::sbumpc method"/> to read data without incurring the overhead of using tasks.

Implements Concurrency::streams::details::basic_streambuf< _CharType >.

Implemented in Concurrency::streams::details::basic_file_buffer< _CharType >, Concurrency::streams::details::basic_rawptr_buffer< _CharType >, Concurrency::streams::details::basic_container_buffer< _CollectionType >, and Concurrency::streams::details::basic_producer_consumer_buffer< _CharType >.

template<typename _CharType>
virtual bool Concurrency::streams::details::streambuf_state_manager< _CharType >::is_eof ( ) const
inlinevirtual

is_eof is used to determine whether a read head has reached the end of the buffer.

Implements Concurrency::streams::details::basic_streambuf< _CharType >.

template<typename _CharType>
virtual bool Concurrency::streams::details::streambuf_state_manager< _CharType >::is_open ( ) const
inlinevirtual

Checks if the stream buffer is open.

No separation is made between open for reading and open for writing.

Implements Concurrency::streams::details::basic_streambuf< _CharType >.

template<typename _CharType>
virtual pplx::task<int_type> Concurrency::streams::details::streambuf_state_manager< _CharType >::nextc ( )
inlinevirtual

Advances the read position, then returns the next character without advancing again.

Returns
The value of the character. EOF if the read fails.

Implements Concurrency::streams::details::basic_streambuf< _CharType >.

template<typename _CharType>
virtual pplx::task<int_type> Concurrency::streams::details::streambuf_state_manager< _CharType >::putc ( _CharType  ch)
inlinevirtual

Writes a single character to the stream.

Parameters
chThe character to write
Returns
The value of the character. EOF if the write operation fails

Implements Concurrency::streams::details::basic_streambuf< _CharType >.

template<typename _CharType>
virtual pplx::task<size_t> Concurrency::streams::details::streambuf_state_manager< _CharType >::putn ( const _CharType *  ptr,
size_t  count 
)
inlinevirtual

Writes a number of characters to the stream.

Parameters
ptrA pointer to the block of data to be written.
countThe number of characters to write.
Returns
The number of characters actually written, either 'count' or 0.

Implements Concurrency::streams::details::basic_streambuf< _CharType >.

template<typename _CharType>
virtual pplx::task<size_t> Concurrency::streams::details::streambuf_state_manager< _CharType >::putn_nocopy ( const _CharType *  ptr,
size_t  count 
)
inlinevirtual

Writes a number of characters to the stream. Note: callers must make sure the data to be written is valid until the returned task completes.

Parameters
ptrA pointer to the block of data to be written.
countThe number of characters to write.
Returns
A task that holds the number of characters actually written, either 'count' or 0.

Implements Concurrency::streams::details::basic_streambuf< _CharType >.

template<typename _CharType>
virtual void Concurrency::streams::details::streambuf_state_manager< _CharType >::release ( _Out_writes_(count) _CharType *  ptr,
_In_ size_t  count 
)
pure virtual

Releases a block of data acquired using ::acquire method. This frees the stream buffer to de-allocate the memory, if it so desires. Move the read position ahead by the count.

Parameters
ptrA pointer to the block of data to be released.
countThe number of characters that were read.

Implements Concurrency::streams::details::basic_streambuf< _CharType >.

Implemented in Concurrency::streams::details::basic_file_buffer< _CharType >.

template<typename _CharType>
virtual int_type Concurrency::streams::details::streambuf_state_manager< _CharType >::sbumpc ( )
inlinevirtual

Reads a single character from the stream and advances the read position.

Returns
The value of the character. -1 if the read fails. -2 if an asynchronous read is required

This is a synchronous operation, but is guaranteed to never block.

Implements Concurrency::streams::details::basic_streambuf< _CharType >.

template<typename _CharType>
virtual size_t Concurrency::streams::details::streambuf_state_manager< _CharType >::scopy ( _Out_writes_(count) _CharType *  ptr,
_In_ size_t  count 
)
inlinevirtual

Copies up to a given number of characters from the stream, synchronously.

Parameters
ptrThe address of the target memory area.
countThe maximum number of characters to read.
Returns
The number of characters copied. O if the end of the stream is reached or an asynchronous read is required.

This is a synchronous operation, but is guaranteed to never block.

Implements Concurrency::streams::details::basic_streambuf< _CharType >.

template<typename _CharType>
virtual pos_type Concurrency::streams::details::streambuf_state_manager< _CharType >::seekoff ( off_type  offset,
std::ios_base::seekdir  way,
std::ios_base::openmode  mode 
)
pure virtual

Seeks to a position given by a relative offset.

Parameters
offsetThe relative position to seek to
wayThe starting point (beginning, end, current) for the seek.
modeThe I/O direction to seek (see remarks)
Returns
The position. EOF if the operation fails.

Some streams may have separate write and read cursors. For such streams, the mode parameter defines whether to move the read or the write cursor.

Implements Concurrency::streams::details::basic_streambuf< _CharType >.

Implemented in Concurrency::streams::details::basic_file_buffer< _CharType >, Concurrency::streams::details::basic_rawptr_buffer< _CharType >, Concurrency::streams::details::basic_container_buffer< _CollectionType >, and Concurrency::streams::details::basic_producer_consumer_buffer< _CharType >.

template<typename _CharType>
virtual pos_type Concurrency::streams::details::streambuf_state_manager< _CharType >::seekpos ( pos_type  pos,
std::ios_base::openmode  direction 
)
pure virtual

Seeks to the given position.

Parameters
posThe offset from the beginning of the stream.
directionThe I/O direction to seek (see remarks).
Returns
The position. EOF if the operation fails.

Some streams may have separate write and read cursors. For such streams, the direction parameter defines whether to move the read or the write cursor.

Implements Concurrency::streams::details::basic_streambuf< _CharType >.

Implemented in Concurrency::streams::details::basic_file_buffer< _CharType >, Concurrency::streams::details::basic_rawptr_buffer< _CharType >, Concurrency::streams::details::basic_container_buffer< _CollectionType >, and Concurrency::streams::details::basic_producer_consumer_buffer< _CharType >.

template<typename _CharType>
virtual void Concurrency::streams::details::streambuf_state_manager< _CharType >::set_buffer_size ( size_t  size,
std::ios_base::openmode  direction = std::ios_base::in 
)
pure virtual

Sets the stream buffer implementation to buffer or not buffer.

Parameters
sizeThe size to use for internal buffering, 0 if no buffering should be done.
directionThe direction of buffering (in or out)

An implementation that does not support buffering will silently ignore calls to this function and it will not have any effect on what is returned by subsequent calls to ::buffer_size method.

Implements Concurrency::streams::details::basic_streambuf< _CharType >.

Implemented in Concurrency::streams::details::basic_file_buffer< _CharType >, Concurrency::streams::details::basic_rawptr_buffer< _CharType >, Concurrency::streams::details::basic_container_buffer< _CollectionType >, and Concurrency::streams::details::basic_producer_consumer_buffer< _CharType >.

template<typename _CharType>
virtual int_type Concurrency::streams::details::streambuf_state_manager< _CharType >::sgetc ( )
inlinevirtual

Reads a single character from the stream without advancing the read position.

Returns
The value of the character. EOF if the read fails. ::requires_async method if an asynchronous read is required

This is a synchronous operation, but is guaranteed to never block.

Implements Concurrency::streams::details::basic_streambuf< _CharType >.

template<typename _CharType>
virtual utility::size64_t Concurrency::streams::details::streambuf_state_manager< _CharType >::size ( ) const
inlinevirtual
template<typename _CharType>
virtual pplx::task<void> Concurrency::streams::details::streambuf_state_manager< _CharType >::sync ( )
inlinevirtual

For output streams, flush any internally buffered data to the underlying medium.

Returns
true if the flush succeeds, false if not

Implements Concurrency::streams::details::basic_streambuf< _CharType >.

template<typename _CharType>
virtual pplx::task<int_type> Concurrency::streams::details::streambuf_state_manager< _CharType >::ungetc ( )
inlinevirtual

Retreats the read position, then returns the current character without advancing.

Returns
The value of the character. EOF if the read fails. ::requires_async method if an asynchronous read is required

Implements Concurrency::streams::details::basic_streambuf< _CharType >.


The documentation for this class was generated from the following file: