folly::ReadCallbackTerminator Class Reference

Inheritance diagram for folly::ReadCallbackTerminator:

Public Member Functions
	ReadCallbackTerminator (EventBase *base, WriteCallbackBase *wcb)
void	readDataAvailable (size_t len) noexceptoverride
Public Member Functions inherited from folly::ReadCallback
	ReadCallback (WriteCallbackBase *wcb)
	~ReadCallback () override
void	getReadBuffer (void **bufReturn, size_t *lenReturn) override
void	readDataAvailable (size_t len) noexceptoverride
Public Member Functions inherited from folly::ReadCallbackBase
	ReadCallbackBase (WriteCallbackBase *wcb)
	~ReadCallbackBase () override
void	setSocket (const std::shared_ptr< AsyncSSLSocket > &socket)
void	setState (StateEnum s)
void	readErr (const AsyncSocketException &ex) noexceptoverride
void	readEOF () noexceptoverride
Public Member Functions inherited from folly::AsyncReader::ReadCallback
virtual bool	isBufferMovable () noexcept
virtual size_t	maxBufferSize () const
virtual void	readBufferAvailable (std::unique_ptr< IOBuf >) noexcept

Private Attributes
EventBase *	base_

Additional Inherited Members
Public Attributes inherited from folly::ReadCallback
std::vector< Buffer >	buffers
Buffer	currentBuffer
Public Attributes inherited from folly::ReadCallbackBase
std::shared_ptr< AsyncSSLSocket >	socket_
WriteCallbackBase *	wcb_
StateEnum	state

Detailed Description

Definition at line 1847 of file AsyncSSLSocketTest.cpp.

Constructor & Destructor Documentation

folly::ReadCallbackTerminator::ReadCallbackTerminator ( EventBase *  base, WriteCallbackBase *  wcb  )

inline

Definition at line 1849 of file AsyncSSLSocketTest.cpp.

      : ReadCallback(wcb), base_(base) {}

Member Function Documentation

void folly::ReadCallbackTerminator::readDataAvailable ( size_t  len )

inlineoverridevirtualnoexcept

readDataAvailable() will be invoked when data has been successfully read into the buffer returned by the last call to getReadBuffer().

The read callback remains installed after readDataAvailable() returns. It must be explicitly uninstalled to stop receiving read events. getReadBuffer() will be called at least once before each call to readDataAvailable(). getReadBuffer() will also be called before any call to readEOF().

Parameters

len	The number of bytes placed in the buffer.

Implements folly::AsyncReader::ReadCallback.

Definition at line 1853 of file AsyncSSLSocketTest.cpp.

References base_, socket_, and STATE_SUCCEEDED.

                                                       {
    std::cerr << "readDataAvailable, len " << len << std::endl;

    currentBuffer.length = len;

    buffers.push_back(currentBuffer);
    currentBuffer.reset();
    state = STATE_SUCCEEDED;

    socket_->setReadCB(nullptr);
    base_->terminateLoopSoon();
  }

Member Data Documentation

EventBase* folly::ReadCallbackTerminator::base_

private

Definition at line 1867 of file AsyncSSLSocketTest.cpp.

---

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

• proxygen/folly/folly/io/async/test/AsyncSSLSocketTest.cpp