KernelBufferDrainer 48 plugin/ipc/socket/kernelbufferdrainer.cpp static KernelBufferDrainer *theDrainer = NULL; KernelBufferDrainer 49 plugin/ipc/socket/kernelbufferdrainer.cpp KernelBufferDrainer& KernelBufferDrainer::instance() KernelBufferDrainer 57 plugin/ipc/socket/kernelbufferdrainer.cpp void KernelBufferDrainer::onConnect(const jalib::JSocket& sock, KernelBufferDrainer 67 plugin/ipc/socket/kernelbufferdrainer.cpp void KernelBufferDrainer::onData(jalib::JReaderInterface* sock) KernelBufferDrainer 77 plugin/ipc/socket/kernelbufferdrainer.cpp void KernelBufferDrainer::onDisconnect(jalib::JReaderInterface* sock) KernelBufferDrainer 93 plugin/ipc/socket/kernelbufferdrainer.cpp void KernelBufferDrainer::onTimeoutInterval() KernelBufferDrainer 149 plugin/ipc/socket/kernelbufferdrainer.cpp void KernelBufferDrainer::beginDrainOf(int fd, const ConnectionIdentifier& id) KernelBufferDrainer 165 plugin/ipc/socket/kernelbufferdrainer.cpp void KernelBufferDrainer::refillAllSockets() KernelBufferDrainer 217 plugin/ipc/socket/kernelbufferdrainer.cpp const vector<char>& KernelBufferDrainer::getDrainedData(ConnectionIdentifier id) KernelBufferDrainer 36 plugin/ipc/socket/kernelbufferdrainer.h class KernelBufferDrainer : public jalib::JMultiSocketProgram KernelBufferDrainer 39 plugin/ipc/socket/kernelbufferdrainer.h KernelBufferDrainer() : _timeoutCount(0) {} KernelBufferDrainer 40 plugin/ipc/socket/kernelbufferdrainer.h static KernelBufferDrainer& instance(); KernelBufferDrainer 362 plugin/ipc/socket/socketconnection.cpp KernelBufferDrainer::instance().getDrainedData(_id); KernelBufferDrainer 390 plugin/ipc/socket/socketconnection.cpp KernelBufferDrainer::instance().beginDrainOf(_fds[0], _id); KernelBufferDrainer 393 plugin/ipc/socket/socketconnection.cpp KernelBufferDrainer::instance().addListenSocket(_fds[0]); KernelBufferDrainer 462 plugin/ipc/socket/socketconnection.cpp KernelBufferDrainer::instance().getDrainedData(_id); KernelBufferDrainer 49 plugin/ipc/socket/socketconnlist.cpp KernelBufferDrainer::instance().monitorSockets(DRAINER_CHECK_FREQ); KernelBufferDrainer 52 plugin/ipc/socket/socketconnlist.cpp KernelBufferDrainer::instance().getDisconnectedSockets(); KernelBufferDrainer 135 plugin/ipc/socket/socketconnlist.cpp KernelBufferDrainer::instance().refillAllSockets();