TestAsyncTransport::ReadEvent Class Reference

Public Member Functions
	ReadEvent (const void *buf, size_t buflen, std::chrono::milliseconds delay)
	ReadEvent (const folly::AsyncSocketException &ex, std::chrono::milliseconds delay)
	~ReadEvent ()
std::chrono::milliseconds	getDelay () const
bool	isFinalEvent () const
const char *	getBuffer () const
size_t	getLength () const
void	consumeData (size_t length)
bool	isError () const
const folly::AsyncSocketException &	getException () const

Private Attributes
char *	buffer_
char *	readStart_
char *	dataEnd_
bool	isError_
folly::AsyncSocketException	exception_
std::chrono::milliseconds	delay_

Detailed Description

Definition at line 31 of file TestAsyncTransport.cpp.

Constructor & Destructor Documentation

TestAsyncTransport::ReadEvent::ReadEvent ( const void *  buf, size_t  buflen, std::chrono::milliseconds  delay  )

inline

Definition at line 33 of file TestAsyncTransport.cpp.

References buffer_, dataEnd_, and readStart_.

    : buffer_(nullptr),
      readStart_(nullptr),
      dataEnd_(nullptr),
      isError_(false),
      exception_(folly::AsyncSocketException::UNKNOWN, ""),
      delay_(delay) {
    if (buflen == 0) {
      // This means EOF
      return;
    }
    CHECK_NOTNULL(buf);

    buffer_ = static_cast<char*>(malloc(buflen));
    if (buffer_ == nullptr) {
      throw std::bad_alloc();
    }
    memcpy(buffer_, buf, buflen);
    readStart_ = buffer_;
    dataEnd_ = buffer_ + buflen;
  }

TestAsyncTransport::ReadEvent::ReadEvent ( const folly::AsyncSocketException &  ex, std::chrono::milliseconds  delay  )

inline

Definition at line 55 of file TestAsyncTransport.cpp.

    : buffer_(nullptr),
      readStart_(nullptr),
      dataEnd_(nullptr),
      isError_(true),
      exception_(ex),
      delay_(delay) {}

TestAsyncTransport::ReadEvent::~ReadEvent ( )

inline

Definition at line 63 of file TestAsyncTransport.cpp.

References buffer_, and bm::free().

               {
    free(buffer_);
  }

Member Function Documentation

void TestAsyncTransport::ReadEvent::consumeData ( size_t  length )

inline

Definition at line 83 of file TestAsyncTransport.cpp.

References dataEnd_, and readStart_.

                                  {
    CHECK_LE(readStart_ + length, dataEnd_);
    readStart_ += length;
  }

const char* TestAsyncTransport::ReadEvent::getBuffer ( ) const

inline

Definition at line 75 of file TestAsyncTransport.cpp.

References readStart_.

                                {
    return readStart_;
  }

std::chrono::milliseconds TestAsyncTransport::ReadEvent::getDelay ( ) const

inline

Definition at line 67 of file TestAsyncTransport.cpp.

References delay_.

                                         {
    return delay_;
  }

const folly::AsyncSocketException& TestAsyncTransport::ReadEvent::getException ( ) const

inline

Definition at line 92 of file TestAsyncTransport.cpp.

References exception_.

                                                        {
    return exception_;
  }

size_t TestAsyncTransport::ReadEvent::getLength ( ) const

inline

Definition at line 79 of file TestAsyncTransport.cpp.

References dataEnd_, and readStart_.

                           {
    return (dataEnd_ - readStart_);
  }

bool TestAsyncTransport::ReadEvent::isError ( ) const

inline

Definition at line 88 of file TestAsyncTransport.cpp.

References isError_.

                       {
    return isError_;
  }

bool TestAsyncTransport::ReadEvent::isFinalEvent ( ) const

inline

Definition at line 71 of file TestAsyncTransport.cpp.

References buffer_.

                            {
    return buffer_ == nullptr;
  }

Member Data Documentation

char* TestAsyncTransport::ReadEvent::buffer_

private

Definition at line 97 of file TestAsyncTransport.cpp.

Referenced by isFinalEvent(), ReadEvent(), and ~ReadEvent().

char* TestAsyncTransport::ReadEvent::dataEnd_

private

Definition at line 99 of file TestAsyncTransport.cpp.

Referenced by consumeData(), getLength(), and ReadEvent().

std::chrono::milliseconds TestAsyncTransport::ReadEvent::delay_

private

Definition at line 104 of file TestAsyncTransport.cpp.

Referenced by getDelay().

folly::AsyncSocketException TestAsyncTransport::ReadEvent::exception_

private

Definition at line 102 of file TestAsyncTransport.cpp.

Referenced by getException().

bool TestAsyncTransport::ReadEvent::isError_

private

Definition at line 101 of file TestAsyncTransport.cpp.

Referenced by isError().

char* TestAsyncTransport::ReadEvent::readStart_

private

Definition at line 98 of file TestAsyncTransport.cpp.

Referenced by consumeData(), getBuffer(), getLength(), and ReadEvent().

---

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

• proxygen/lib/test/TestAsyncTransport.cpp