21 stream_impl::stream_impl(
size_t BufferSize,
size_t MaxStatementSize,
29 : BufferSize_(BufferSize), MaxStatementSize_(MaxStatementSize),
30 PropList_(PropList), Buf_(
range<1>(BufferSize + OffsetSize + 1)),
44 char *Ptr = Acc.get_pointer();
45 std::memset(Ptr, 0, Buf_.
size());
64 auto ReinterpretedBuf = OffsetSubBuf.reinterpret<unsigned, 1>(
range<1>(2));
65 return ReinterpretedBuf.get_access<sycl::access::mode::atomic>(
72 return MaxStatementSize_;
84 auto Q = createSyclObjFromImpl<queue>(Queue);
87 access::target::host_buffer>(
90 char *FlushBufPtr = FlushBufAcc.get_pointer();
91 std::memset(FlushBufPtr, 0, FlushBufSize);
100 auto Q = detail::createSyclObjFromImpl<queue>(
101 sycl::detail::Scheduler::getInstance().getDefaultHostQueue());
102 event Event = Q.submit([&](
handler &cgh) {
110 auto FlushBufHostAcc =
115 printf(
"%s", &(BufHostAcc[0]));
121 LeadEvent->getSubmittedQueue()->registerStreamServiceEvent(