proxygen::RFC1867Base Class Reference

Inheritance diagram for proxygen::RFC1867Base:

Public Member Functions
void	SetUp ()
void	parse (unique_ptr< IOBuf > input, size_t chunkSize=0)

Protected Member Functions
void	testSimple (unique_ptr< IOBuf > data, size_t fileSize, size_t splitSize, size_t parts)

Protected Attributes
StrictMock< Mock1867Callback >	callback_
RFC1867Codec	codec_ {kTestBoundary}

Detailed Description

Definition at line 119 of file RFC1867Test.cpp.

Member Function Documentation

void proxygen::RFC1867Base::parse ( unique_ptr< IOBuf >  input, size_t  chunkSize = 0  )

inline

Definition at line 126 of file RFC1867Test.cpp.

References folly::IOBufQueue::append(), codec_, data, min, folly::gen::move, folly::IOBuf::prependChain(), and testSimple().

                                                            {
    IOBufQueue ibuf{IOBufQueue::cacheChainLength()};
    ibuf.append(std::move(input));
    if (chunkSize == 0) {
      chunkSize = ibuf.chainLength();
    }
    unique_ptr<IOBuf> rem;
    while (!ibuf.empty()) {
      auto chunk = ibuf.split(std::min(chunkSize, ibuf.chainLength()));
      if (rem) {
        rem->prependChain(std::move(chunk));
        chunk = std::move(rem);
      }
      rem = codec_.onIngress(std::move(chunk));
    }
    codec_.onIngressEOM();
  }

void proxygen::RFC1867Base::SetUp ( )

inline

Definition at line 122 of file RFC1867Test.cpp.

References callback_, and codec_.

               {
    codec_.setCallback(&callback_);
  }

void proxygen::RFC1867Base::testSimple ( unique_ptr< IOBuf >  data, size_t  fileSize, size_t  splitSize, size_t  parts  )

protected

Parameters

data	full multipart content
filesize	sum of all parts
parts	number of parts

Definition at line 167 of file RFC1867Test.cpp.

References testing::_, callback_, EXPECT_CALL, testing::Invoke(), parse(), testing::Return(), and uint64_t.

                                           {
  size_t fileLength = 0;
  IOBufQueue parsedData{IOBufQueue::cacheChainLength()};
  EXPECT_CALL(callback_, onFieldStartImpl(_, _, _, _))
          .Times(parts)
          .WillRepeatedly(Return(0));
  EXPECT_CALL(callback_, onFieldData(_, _))
    .WillRepeatedly(Invoke([&] (std::shared_ptr<IOBuf> data, uint64_t) {
          fileLength += data->computeChainDataLength();
          parsedData.append(data->clone());
          return 0;
        }));
  EXPECT_CALL(callback_, onFieldEnd(true, _))
          .Times(parts)
          .WillRepeatedly(Return());
  parse(data->clone(), splitSize);
  auto parsedDataBuf = parsedData.move();
  if (fileLength > 0) {
    // isChained() called from coalesce below asserts if no data has
    // been added
    parsedDataBuf->coalesce();
  }
  CHECK_EQ(fileLength, fileSize);
}

Member Data Documentation

StrictMock<Mock1867Callback> proxygen::RFC1867Base::callback_

protected

Definition at line 150 of file RFC1867Test.cpp.

RFC1867Codec proxygen::RFC1867Base::codec_ {kTestBoundary}

protected

Definition at line 151 of file RFC1867Test.cpp.

---

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

• proxygen/lib/http/experimental/test/RFC1867Test.cpp