Public Member Functions | |
| StreamHashTable (int sz) | |
| ~StreamHashTable () | |
| int | index (prefetch_udp_header *hdr) |
| Stream ** | position (prefetch_udp_header *hdr) |
| Stream ** | position (Stream *s) |
| Stream * | lookup (prefetch_udp_header *hdr) |
| void | add (Stream *s) |
| void | remove (Stream *s) |
| int | deleteStaleStreams (time_t now) |
Detailed Description
Definition at line 92 of file StufferUdpReceiver.cc.
Constructor & Destructor Documentation
| StreamHashTable::StreamHashTable | ( | int | sz | ) | [inline] |
Definition at line 99 of file StufferUdpReceiver.cc.
| StreamHashTable::~StreamHashTable | ( | ) | [inline] |
Definition at line 105 of file StufferUdpReceiver.cc.
Member Function Documentation
| void StreamHashTable::add | ( | Stream * | s | ) |
Definition at line 145 of file StufferUdpReceiver.cc.
References assert, and position().
Referenced by processPacket().
| int StreamHashTable::deleteStaleStreams | ( | time_t | now | ) |
Definition at line 161 of file StufferUdpReceiver.cc.
References Stream::fd, Stream::last_activity_time, Stream::next, number_of_timeouts, and STREAM_TIMEOUT_SECS.
Referenced by main().
| int StreamHashTable::index | ( | prefetch_udp_header * | hdr | ) | [inline] |
Definition at line 110 of file StufferUdpReceiver.cc.
References prefetch_udp_header::md5.
Referenced by position().
| Stream* StreamHashTable::lookup | ( | prefetch_udp_header * | hdr | ) | [inline] |
Definition at line 119 of file StufferUdpReceiver.cc.
References position().
Referenced by processPacket().
| Stream ** StreamHashTable::position | ( | prefetch_udp_header * | hdr | ) |
Definition at line 131 of file StufferUdpReceiver.cc.
References index(), prefetch_udp_header::md5, and Stream::next.
Referenced by add(), lookup(), position(), and remove().
Definition at line 115 of file StufferUdpReceiver.cc.
References Stream::hdr, and position().
| void StreamHashTable::remove | ( | Stream * | s | ) |
Definition at line 153 of file StufferUdpReceiver.cc.
References assert, Stream::next, and position().
Referenced by processPacket().
The documentation for this class was generated from the following file:
