23 std::lock_guard<std::recursive_mutex> lock(
24 Scheduler::getInstance().StreamBuffersPoolMutex);
27 Scheduler::getInstance().StreamBuffersPool.find(Stream.get());
28 assert((StreamBuf != Scheduler::getInstance().StreamBuffersPool.end()) &&
29 "Stream is unexpectedly not found in pool.");
31 StrBufs = StreamBuf->second;
34 assert(StrBufs &&
"No buffers for a stream.");
40 auto Q = createSyclObjFromImpl<queue>(Queue);
43 StrBufs->FlushBuf.get_access<access::mode::discard_write,
44 access::target::host_buffer>(
47 char *FlushBufPtr = FlushBufAcc.get_pointer();
48 std::memset(FlushBufPtr, 0, FlushBufSize);