A class that asynchronously reads from a file descriptor. More...
#include <unix-fd-reader.h>
Inheritance diagram for ns3::FdReader:
Collaboration diagram for ns3::FdReader:Classes | |
| struct | Data |
| A structure representing data read. More... | |
Public Member Functions | |
| FdReader () | |
| Constructor. More... | |
| virtual | ~FdReader () |
| Destructor. More... | |
| void | Start (int fd, Callback< void, uint8_t *, ssize_t > readCallback) |
| Start a new read thread. More... | |
| void | Stop (void) |
| Stop the read thread and reset internal state. More... | |
Public Member Functions inherited from ns3::SimpleRefCount< FdReader > | |
| SimpleRefCount () | |
| Constructor. More... | |
| SimpleRefCount (const SimpleRefCount &o) | |
| Copy constructor. More... | |
| uint32_t | GetReferenceCount (void) const |
| Get the reference count of the object. More... | |
| SimpleRefCount & | operator= (const SimpleRefCount &o) |
| Assignment. More... | |
| void | Ref (void) const |
| Increment the reference count. More... | |
| void | Unref (void) const |
| Decrement the reference count. More... | |
Protected Member Functions | |
| virtual FdReader::Data | DoRead (void)=0 |
| The read implementation. More... | |
Protected Attributes | |
| int | m_fd |
| The file descriptor to read from. More... | |
Private Member Functions | |
| void | DestroyEvent (void) |
| Event handler scheduled for destroy time to halt the thread. More... | |
| void | Run (void) |
| The asynchronous function which performs the read. More... | |
Private Attributes | |
| EventId | m_destroyEvent |
| The event scheduled for destroy time which will invoke DestroyEvent and halt the thread. More... | |
| int | m_evpipe [2] |
| Pipe used to signal events between threads. More... | |
| Callback< void, uint8_t *, ssize_t > | m_readCallback |
| The main thread callback function to invoke when we have data. More... | |
| Ptr< SystemThread > | m_readThread |
| The thread doing the read, created and launched by Start(). More... | |
| bool | m_stop |
| Signal the read thread to stop. More... | |
Additional Inherited Members | |
Static Public Member Functions inherited from ns3::SimpleRefCount< FdReader > | |
| static void | Cleanup (void) |
| Noop. More... | |
A class that asynchronously reads from a file descriptor.
This class can be used to start a system thread that reads from a given file descriptor and invokes a given callback when data is received. This class handles thread management automatically but the DoRead() method must be implemented by a subclass.
Definition at line 47 of file unix-fd-reader.h.
| ns3::FdReader::FdReader | ( | ) |
Constructor.
Definition at line 45 of file unix-fd-reader.cc.
References m_evpipe, and NS_LOG_FUNCTION.
|
virtual |
Destructor.
Definition at line 54 of file unix-fd-reader.cc.
References NS_LOG_FUNCTION, and Stop().
Here is the call graph for this function:
|
private |
Event handler scheduled for destroy time to halt the thread.
Definition at line 112 of file unix-fd-reader.cc.
References NS_LOG_FUNCTION, Stop(), and ns3::SimpleRefCount< FdReader >::Unref().
Referenced by Start().
Here is the call graph for this function:
Here is the caller graph for this function:
|
protectedpure virtual |
The read implementation.
The value of m_len returned controls further processing. The callback function is only invoked when m_len is positive; any data read is not processed when m_len is negative; reading stops when m_len is zero.
The management of memory associated with m_buf must be compatible with the read callback.
Implemented in ns3::FdNetDeviceFdReader, and ns3::TapBridgeFdReader.
Referenced by Run().
Here is the caller graph for this function:
|
private |
The asynchronous function which performs the read.
Definition at line 161 of file unix-fd-reader.cc.
References DoRead(), ns3::FdReader::Data::m_buf, m_evpipe, m_fd, ns3::FdReader::Data::m_len, m_readCallback, m_stop, NS_FATAL_ERROR, and NS_LOG_FUNCTION.
Referenced by Start().
Here is the call graph for this function:
Here is the caller graph for this function:| void ns3::FdReader::Start | ( | int | fd, |
| Callback< void, uint8_t *, ssize_t > | readCallback | ||
| ) |
Start a new read thread.
| fd | A valid file descriptor open for reading. |
| readCallback | A callback to invoke when new data is available. |
Definition at line 60 of file unix-fd-reader.cc.
References DestroyEvent(), ns3::EventId::IsRunning(), m_destroyEvent, m_evpipe, m_fd, m_readCallback, m_readThread, ns3::MakeCallback(), NS_ASSERT_MSG, NS_FATAL_ERROR, NS_LOG_FUNCTION, NS_LOG_LOGIC, ns3::SimpleRefCount< FdReader >::Ref(), Run(), and ns3::Simulator::ScheduleDestroy().
Here is the call graph for this function:| void ns3::FdReader::Stop | ( | void | ) |
Stop the read thread and reset internal state.
This does not close the file descriptor used for reading.
Definition at line 119 of file unix-fd-reader.cc.
References m_evpipe, m_fd, m_readCallback, m_readThread, m_stop, NS_LOG_FUNCTION, NS_LOG_WARN, ns3::Callback< R, T1, T2, T3, T4, T5, T6, T7, T8, T9 >::Nullify(), and zero.
Referenced by DestroyEvent(), and ~FdReader().
Here is the call graph for this function:
Here is the caller graph for this function:
|
private |
The event scheduled for destroy time which will invoke DestroyEvent and halt the thread.
Definition at line 135 of file unix-fd-reader.h.
Referenced by Start().
|
private |
Pipe used to signal events between threads.
Definition at line 127 of file unix-fd-reader.h.
Referenced by FdReader(), Run(), Start(), and Stop().
|
protected |
The file descriptor to read from.
Definition at line 111 of file unix-fd-reader.h.
Referenced by ns3::TapBridgeFdReader::DoRead(), ns3::FdNetDeviceFdReader::DoRead(), Run(), Start(), and Stop().
|
private |
The main thread callback function to invoke when we have data.
Definition at line 121 of file unix-fd-reader.h.
|
private |
The thread doing the read, created and launched by Start().
Definition at line 124 of file unix-fd-reader.h.
|
private |
Signal the read thread to stop.
Definition at line 129 of file unix-fd-reader.h.