Searched refs:StreamInWorkerLogic (Results 1 – 2 of 2) sorted by relevance
199 const std::string StreamInWorkerLogic::kThreadName = "reader";201 StreamInWorkerLogic::Status StreamInWorkerLogic::cycle() { in cycle()227 StreamInWorkerLogic::Status status = Status::CONTINUE; in cycle()360 bool StreamInWorkerLogic::read(size_t clientSize, StreamDescriptor::Reply* reply) { in read()399 bool StreamInWorkerLogic::readMmap(StreamDescriptor::Reply* reply) { in readMmap()
323 class StreamInWorkerLogic : public StreamWorkerCommonLogic {326 StreamInWorkerLogic(StreamContext* context, DriverInterface* driver) in StreamInWorkerLogic() function336 using StreamInWorker = StreamWorkerImpl<StreamInWorkerLogic>;