21 #ifndef UTP_POLLPIPE_H
22 #define UTP_POLLPIPE_H
26 #include <net/wakeuppipe.h>
41 typedef QSharedPointer<PollPipe> Ptr;
44 bool polling()
const {
return poll_index >= 0;}
49 QMutexLocker lock(&mutex);
50 conn_ids.set(conn_id,
true);
52 poll_index = p->
add(qSharedPointerCast<PollClient>(
self));
58 QMutexLocker lock(&mutex);
59 return poll_index >= 0 && conn_ids[conn];
71 std::bitset<65536> conn_ids;
77 #endif // UTP_POLLPIPE_H