Searched refs:StreamInWorkerLogic (Results 1 – 2 of 2) sorted by relevance
158 const std::string StreamInWorkerLogic::kThreadName = "reader";160 StreamInWorkerLogic::Status StreamInWorkerLogic::cycle() { in cycle()186 StreamInWorkerLogic::Status status = Status::CONTINUE; in cycle()317 bool StreamInWorkerLogic::read(size_t clientSize, StreamDescriptor::Reply* reply) { in read()
265 class StreamInWorkerLogic : public StreamWorkerCommonLogic {268 StreamInWorkerLogic(StreamContext* context, DriverInterface* driver) in StreamInWorkerLogic() function277 using StreamInWorker = StreamWorkerImpl<StreamInWorkerLogic>;