enqueue
status_t _Send(TCPPacket* packet, bool enqueue = true);
taskqueue_enqueue_fn enqueue, void *context,
queue->tq_enqueue = enqueue;
if (enqueue == gtaskqueue_thread_enqueue)
taskqueue_enqueue_fn enqueue, void *context)
return _gtaskqueue_create(name, mflags, enqueue, context,
#define TASKQUEUE_DEFINE(name, enqueue, context, init) \
taskqueue_create(#name, M_WAITOK, (enqueue), (context)); \
#define TASKQUEUE_FAST_DEFINE(name, enqueue, context, init) \
taskqueue_create_fast(#name, M_WAITOK, (enqueue), \
taskqueue_enqueue_fn enqueue,
taskqueue_enqueue_fn enqueue,
taskqueue_enqueue_fn enqueue, void *context,
queue->tq_enqueue = enqueue;
if (enqueue == taskqueue_thread_enqueue)
taskqueue_enqueue_fn enqueue, void *context)
return _taskqueue_create(name, mflags, enqueue, context,
taskqueue_enqueue_fn enqueue, void *context)
return _taskqueue_create(name, mflags, enqueue, context,
TCPSocket::_Send(TCPPacket* packet, bool enqueue)
if (enqueue)
enqueue(thread, true);
enqueue(thread, true);
enqueue(oldThread, true);
enqueue(oldThread, false);
static void enqueue(Thread* thread, bool newOne);
enqueue(thread->GetThread(), false);