28 typedef std::unique_ptr<MockAsyncSocket, Destructor>
UniquePtr;
46 connect_(callback, address,
timeout, options, bindAddr);
58 MOCK_METHOD1(_setPreReceivedData,
void(std::unique_ptr<IOBuf>&));
64 return _setPreReceivedData(data);
MOCK_METHOD0(detachFd, int())
MOCK_CONST_METHOD0(getFd, int())
virtual bool hangup() const
void connect(AsyncSocket::ConnectCallback *callback, const folly::SocketAddress &address, int timeout, const OptionMap &options, const folly::SocketAddress &bindAddr) noexceptoverride
size_t getRawBytesWritten() const override
virtual void setErrMessageCB(ErrMessageCallback *callback)
—— Concurrent Priority Queue Implementation ——
requires E e noexcept(noexcept(s.error(std::move(e))))
virtual void setSendMsgParamCB(SendMsgParamsCallback *callback)
std::map< OptionKey, int > OptionMap
SocketAddress getPeerAddress() const
MOCK_METHOD5(connect_, void(AsyncSocket::ConnectCallback *, const folly::SocketAddress &, int, const OptionMap &, const folly::SocketAddress &))
constexpr auto data(C &c) -> decltype(c.data())
MockAsyncSocket(EventBase *base)
bool good() const override
MOCK_METHOD1(setReadCB, void(ReadCallback *))
MOCK_METHOD4(setSockOptVirtual, int(int, int, void const *, socklen_t))
virtual int getFd() const
MOCK_CONST_METHOD1(getPeerAddress, void(folly::SocketAddress *))
SocketAddress getLocalAddress() const
void setReadCB(ReadCallback *callback) override
void setPreReceivedData(std::unique_ptr< IOBuf > data) override
std::unique_ptr< MockAsyncSocket, Destructor > UniquePtr
bool readable() const override
virtual int setSockOptVirtual(int level, int optname, void const *optval, socklen_t optlen)