LogCabin::RPC::MessageSocket::ReceiveSocket Struct Reference

This class is an Event::File monitor that calls readable() when the socket can be read from without blocking. More...

Inheritance diagram for LogCabin::RPC::MessageSocket::ReceiveSocket:

List of all members.

Public Member Functions
	ReceiveSocket (int fd, MessageSocket &messageSocket)
	~ReceiveSocket ()
void	handleFileEvent (uint32_t events)
	This method is overridden by a subclass and invoked when a file event occurs.
Private Attributes
MessageSocket &	messageSocket

---

Detailed Description

This class is an Event::File monitor that calls readable() when the socket can be read from without blocking.

This is always set for EPOLLIN events in a non-one-shot (persistent) manner.

Definition at line 168 of file MessageSocket.h.

---

Constructor & Destructor Documentation

LogCabin::RPC::MessageSocket::ReceiveSocket::ReceiveSocket	(	int	fd,
		MessageSocket &	messageSocket
	)

Definition at line 78 of file MessageSocket.cc.

LogCabin::RPC::MessageSocket::ReceiveSocket::~ReceiveSocket

(

)

Definition at line 95 of file MessageSocket.cc.

---

Member Function Documentation

void LogCabin::RPC::MessageSocket::ReceiveSocket::handleFileEvent

(

uint32_t

events

)

[virtual]

This method is overridden by a subclass and invoked when a file event occurs.

This method will be invoked by the main event loop on whatever thread is running the Event::Loop.

If the event still exists when this method returns (e.g., the file is readable but the method did not read the data), then the method will be invoked again (unless flags such as EPOLLONESHOT or EPOLLET are used).

Parameters:

events

Indicates whether the file is readable or writable or both (OR'ed combination of EPOLL_EVENTS values).

Implements LogCabin::Event::File.

Definition at line 100 of file MessageSocket.cc.

---

Member Data Documentation

MessageSocket& LogCabin::RPC::MessageSocket::ReceiveSocket::messageSocket [private]

Definition at line 174 of file MessageSocket.h.

---

The documentation for this struct was generated from the following files:

• RPC/MessageSocket.h
• RPC/MessageSocket.cc