Functions — github.com/aarond10/epoll_threadpool

CodeHub MCPcopy Create free account

hub / github.com/aarond10/epoll_threadpool / functions

Functions117 in github.com/aarond10/epoll_threadpool

⨍ Functions 117◇ Types & classes 27

↓ 31 callersMethodtryWait

* Waits until we either have a value to return or 'when' is reached. * @returns true if value available, false otherwise. */

src/future.h:112

↓ 27 callersMethodstart

↓ 24 callersMethodenqueue

src/eventmanager.cc:129

↓ 24 callersMethodsize

* Returns the current length in bytes of all blocks combined. */

src/iobuffer.h:112

↓ 18 callersMethodpush_back

src/future.h:317

↓ 13 callersMethodpulldown

* Ensures that the first n bytes are stored in contiguous memory. * Returns a pointer to the start of the memory on success, NULL on error. */

src/iobuffer.h:118

↓ 13 callersMethodstop

src/eventmanager.cc:91

↓ 10 callersMethodaddCallback

* Registers a callback to get run when the Future's value is set. * If a callback is added after the value has been set, it will be * executed i

src/future.h:130

↓ 9 callersMethodset

* Sets the return value. */

src/future.h:101

↓ 8 callersMethodconsume

* Consumes the first n bytes of the buffer. * Takes care of freeing memory, etc. * Returns false if asked to consume more data than is available

src/iobuffer.h:141

↓ 8 callersMethodremoveFd

src/eventmanager.cc:158

↓ 8 callersMethodsignal

src/barrier.h:75

↓ 8 callersMethodwatchFd

src/eventmanager.cc:142

↓ 7 callersFunctioncreateListenSocket

src/tcp_test.cc:51

↓ 6 callersMethodappend

* Appends another IOBuffer instance to this IOBuffer. All data from the * first buffer will be appended to this buffer without memcpying the * d

src/iobuffer.h:70

↓ 6 callersMethoddisconnect

↓ 5 callersMethodwrite

↓ 4 callersMethodsetAcceptCallback

↓ 4 callersMethodwait

src/notification.h:72

↓ 3 callersMethodsetDisconnectCallback

↓ 2 callersMethodsetReceiveCallback

↓ 2 callersMethodsize

src/future.h:320

↓ 1 callersMethodaddErrback

* Adds an "errback", a callback that is triggered if the Future * is destroyed without ever setting a value. */

src/future.h:146

↓ 1 callersMethodcancel

src/eventmanager.h:77

↓ 1 callersMethodhasCallbacks

src/future.h:185

↓ 1 callersMethodhasValue

src/future.h:181

↓ 1 callersMethodisDisconnected

↓ 1 callersMethodrun

src/eventmanager.h:97

↓ 1 callersMethodshutdown

↓ 1 callersMethodthread_main

src/eventmanager.cc:214

src/barrier.h:58

MethodConcreteItem

src/future.h:338

MethodCountingNotification

* Creates a notification that will only be signalled after num calls to * signal(). */

src/notification.h:98

FunctionEnqueuedAfterCheck

src/eventmanager_test.cc:149

FunctionEnqueuedAfterCheck2

src/eventmanager_test.cc:155

FunctionEnqueuedCountCheck

src/eventmanager_test.cc:107

MethodEventManager

src/eventmanager.cc:44

FunctionFillWriteBufferAccept

Consume data and count bytes.

src/tcp_test.cc:216

FunctionFillWriteBufferReceive

src/tcp_test.cc:205

src/eventmanager.h:76

src/future.h:73

MethodFutureBarrier

src/future.h:361

MethodFutureSet

src/future.h:314

src/iobuffer.h:49

src/future.h:161

src/eventmanager.h:86

MethodNotification

src/notification.h:44

src/eventmanager_test.cc:42

Code coverage - test basic creation and listening functionality.

src/tcp_test.cc:62

src/future_test.cc:43

src/iobuffer_test.cc:36

MethodTcpListenSocket

MethodTcpSocket

FunctionTestCancelA

src/eventmanager_test.cc:240

FunctionTestCancelB

src/eventmanager_test.cc:243

FunctionWatchFdRead

src/eventmanager_test.cc:179

FunctionWatchFdWrite

src/eventmanager_test.cc:186

FunctionWorkerStartStop

src/eventmanager_test.cc:162

FunctionacceptConnectionCallback

src/tcp_test.cc:182

FunctionacceptDisconnectHandler

src/tcp_test.cc:148

FunctionacceptHandler

src/tcp_test.cc:107

MethodaddCallback

src/future.h:244

MethodaddCallback

src/future.h:340

MethodaddCallback

src/future.h:377

MethodaddCallbackHelper

Helper that discards argument on addCallback() callback.

src/future.h:353

MethodaddErrback

src/future.h:265

src/barrier.h:66

FunctioncallbackHelper

src/future_test.cc:57

src/eventmanager.h:92

MethodcompareTasks

Used to sort heap with earliest time at the top

src/eventmanager.h:175

MethodcurrentTime

src/eventmanager.cc:123

FunctiondisconnectChecker

src/tcp_test.cc:144

* Enqueues a function to be run on one of the EventManager's worker threads. * The function will be run on the first available thread. * It is s

src/eventmanager.h:140

MethodepollUpdate

src/eventmanager.cc:179

* Returns the file descriptor for the socket. * @note This shouldn't be used directly. Its exposed for debugging. */

MethodgetEventManager

* Returns the eventmanager for this class. */

MethodgetEventManager

* Returns the eventmanager for this class. */

MethodonCanSend

MethodonReceive

Methodoperator()

src/eventmanager.h:80

FunctionreceiveChecker

src/tcp_test.cc:94

MethodremoveCallback

* Deregisters a callback registered with addCallback() to ensure * it is never called after this function returns. */

src/future.h:138

MethodremoveCallback

src/future.h:259

MethodremoveErrback

* Deregisters an errback. * @see addErrback */

src/future.h:154

MethodremoveErrback

src/future.h:271

src/future.h:189

src/notification.h:54

src/notification.h:101

src/future.h:409

src/eventmanager.cc:72

Methodtrampoline

src/eventmanager.cc:208

src/notification.h:61

src/future.h:214

src/future.h:348

next →1–100 of 117, ranked by callers