folly::WriteErrorCallback Class Reference

#include <AsyncSSLSocketTest.h>

Inheritance diagram for folly::WriteErrorCallback:

Public Member Functions
	WriteErrorCallback (WriteCallbackBase *wcb)
void	readDataAvailable (size_t len) noexceptoverride
void	readErr (const AsyncSocketException &ex) noexceptoverride
Public Member Functions inherited from folly::ReadCallback
	ReadCallback (WriteCallbackBase *wcb)
	~ReadCallback () override
void	getReadBuffer (void **bufReturn, size_t *lenReturn) override
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	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

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 421 of file AsyncSSLSocketTest.h.

Constructor & Destructor Documentation

folly::WriteErrorCallback::WriteErrorCallback ( WriteCallbackBase *  wcb )

inlineexplicit

Definition at line 423 of file AsyncSSLSocketTest.h.

: ReadCallback(wcb) {}

Member Function Documentation

void folly::WriteErrorCallback::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.

Reimplemented from folly::ReadCallback.

Definition at line 425 of file AsyncSSLSocketTest.h.

References folly::netops::close(), folly::test::msvcSuppressAbortOnInvalidParams(), folly::SendMsgParamsCallbackBase::socket_, folly::STATE_FAILED, and folly::STATE_SUCCEEDED.

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

    currentBuffer.length = len;

    // close the socket before writing to trigger writeError().
    ::close(socket_->getFd());

    wcb_->setSocket(socket_);

    // Write back the same data.
    folly::test::msvcSuppressAbortOnInvalidParams(
        [&] { socket_->write(wcb_, currentBuffer.buffer, len); });

    if (wcb_->state == STATE_FAILED) {
      setState(STATE_SUCCEEDED);
    } else {
      state = STATE_FAILED;
    }

    buffers.push_back(currentBuffer);
    currentBuffer.reset();
  }

void folly::WriteErrorCallback::readErr ( const AsyncSocketException &  ex )

inlineoverridevirtualnoexcept

readError() will be invoked if an error occurs reading from the transport.

The read callback will be automatically uninstalled immediately before readError() is invoked.

Parameters

ex	An exception describing the error that occurred.

Reimplemented from folly::ReadCallbackBase.

Definition at line 449 of file AsyncSSLSocketTest.h.

                                                                 {
    std::cerr << "readError " << ex.what() << std::endl;
    // do nothing since this is expected
  }

---

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

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