Home
last modified time | relevance | path

Searched +defs:event +defs:stream (Results 1 – 25 of 1280) sorted by relevance

12345678910>>...52

/aosp_15_r20/system/chre/platform/slpi/see/
H A Dsee_helper.cc57 #define LOG_NANOPB_ERROR(stream) \ argument
107 UniquePtr<uint8_t> event; member
144 bool copyPayload(pb_ostream_t *stream, const pb_field_t *field, in copyPayload()
188 pb_ostream_t stream = pb_ostream_from_buffer(msg->get(), *msgLen); in encodeSnsStdAttrReq() local
235 pb_ostream_t stream = pb_ostream_from_buffer(msg->get(), *msgLen); in encodeSnsSuidReq() local
284 pb_ostream_t stream = pb_ostream_from_buffer(msg->get(), *msgLen); in encodeSnsResamplerConfig() local
326 pb_ostream_t stream = pb_ostream_from_buffer(msg->get(), *msgLen); in encodeSnsStdSensorConfig() local
347 pb_ostream_t stream = pb_ostream_from_buffer(msgBuffer, msgBufferSize); in encodeSnsRemoteProcSensorConfig() local
402 bool decodeStringField(pb_istream_t *stream, const pb_field_t *field, in decodeStringField()
418 bool decodeSnsSuidEventSuid(pb_istream_t *stream, const pb_field_t *field, in decodeSnsSuidEventSuid()
[all …]
/aosp_15_r20/external/tensorflow/tensorflow/core/profiler/backends/gpu/
H A Drocm_tracer.cc267 void DumpRocmTracerEvent(const RocmTracerEvent& event, in DumpRocmTracerEvent()
446 RocmTracerEvent event; in AddKernelEventUponApiExit() local
470 const hipStream_t& stream = data->args.hipModuleLaunchKernel.stream; in AddKernelEventUponApiExit() local
497 const hipStream_t& stream = data->args.hipExtModuleLaunchKernel.hStream; in AddKernelEventUponApiExit() local
519 const hipStream_t& stream = data->args.hipHccModuleLaunchKernel.hStream; in AddKernelEventUponApiExit() local
526 hipStream_t stream = data->args.hipLaunchKernel.stream; in AddKernelEventUponApiExit() local
561 RocmTracerEvent event; in AddNormalMemcpyEventUponApiExit() local
589 const hipStream_t& stream = data->args.hipMemcpyDtoHAsync.stream; in AddNormalMemcpyEventUponApiExit() local
604 const hipStream_t& stream = data->args.hipMemcpyHtoDAsync.stream; in AddNormalMemcpyEventUponApiExit() local
617 const hipStream_t& stream = data->args.hipMemcpyDtoDAsync.stream; in AddNormalMemcpyEventUponApiExit() local
[all …]
H A Dcupti_tracer.cc373 CuptiTracerEvent event{}; in AddKernelEventUponApiExit() local
392 CuptiTracerEvent event{}; in PopulateMemcpyCallbackEvent() local
422 CuptiTracerEvent event = in AddNormalMemcpyEventUponApiExit() local
442 CuptiTracerEvent event{}; in AddCuMemsetEventUponApiExit() local
478 CuptiTracerEvent event = in AddP2PMemcpyEventUponApiExit() local
490 CuptiTracerEvent event{}; in AddCuMemAllocEventUponApiExit() local
513 CuptiTracerEvent event{}; in AddCuMemAllocPitchEventUponApiExit() local
537 CuptiTracerEvent event{}; in AddCuMemFreeEventUponApiExit() local
556 CuptiTracerEvent event{}; in AddGenericEventUponApiExit() local
573 CuptiTracerEvent event{}; in AddKernelActivityEvent() local
[all …]
/aosp_15_r20/external/tensorflow/tensorflow/c/experimental/stream_executor/
H A Dstream_executor_test.cc269 TF_Status* const status) -> void { in TEST_F()
274 SP_Stream stream) -> void { in TEST_F()
283 Stream* stream = new Stream(executor); in TEST_F() local
314 TF_Status* const status) -> void { in TEST_F()
323 Stream stream(executor); in TEST_F() local
337 TF_Status* const status) -> void { in TEST_F()
342 SP_Event event) -> void { in TEST_F()
351 Event* event = new Event(executor); in TEST_F() local
362 TF_Status* const status) -> void { in TEST_F()
366 SP_Event event) -> void { delete event; }; in TEST_F()
[all …]
H A Dstream_executor_test_util.cc39 void CreateStream(const SP_Device* const device, SP_Stream* stream, in CreateStream()
43 void DestroyStream(const SP_Device* const device, SP_Stream stream) {} in DestroyStream()
46 void GetStreamStatus(const SP_Device* const device, SP_Stream stream, in GetStreamStatus()
48 void CreateEvent(const SP_Device* const device, SP_Event* event, in CreateEvent()
52 void DestroyEvent(const SP_Device* const device, SP_Event event) {} in DestroyEvent()
53 SE_EventStatus GetEventStatus(const SP_Device* const device, SP_Event event) { in GetEventStatus()
56 void RecordEvent(const SP_Device* const device, SP_Stream stream, in RecordEvent()
57 SP_Event event, TF_Status* const status) {} in RecordEvent()
58 void WaitForEvent(const SP_Device* const device, SP_Stream stream, in WaitForEvent()
59 SP_Event event, TF_Status* const status) {} in WaitForEvent()
[all …]
H A Dstream_executor.cc352 port::Status MemZero(Stream* stream, DeviceMemoryBase* location, in MemZero()
362 port::Status Memset(Stream* stream, DeviceMemoryBase* location, uint8 pattern, in Memset()
372 port::Status Memset32(Stream* stream, DeviceMemoryBase* location, in Memset32()
382 bool Memcpy(Stream* stream, void* host_dst, const DeviceMemoryBase& gpu_src, in Memcpy()
396 bool Memcpy(Stream* stream, DeviceMemoryBase* gpu_dst, const void* host_src, in Memcpy()
410 bool MemcpyDeviceToDevice(Stream* stream, DeviceMemoryBase* gpu_dst, in MemcpyDeviceToDevice()
426 bool HostCallback(Stream* stream, in HostCallback()
434 port::Status AllocateEvent(Event* event) override { in AllocateEvent()
438 port::Status DeallocateEvent(Event* event) override { in DeallocateEvent()
442 port::Status RecordEvent(Stream* stream, Event* event) override { in RecordEvent()
[all …]
/aosp_15_r20/external/tensorflow/tensorflow/compiler/xla/python/tpu_driver/
H A Dgrpc_tpu_driver.cc51 explicit GrpcEvent(EventId id, GrpcTpuStream* stream) in GrpcEvent()
60 GrpcTpuStream* stream() const { return stream_; } in stream() function in tpu_driver::__anonb00856100111::GrpcEvent
88 explicit GrpcBufferHandle(EventId id, std::shared_ptr<GrpcEvent> event, in GrpcBufferHandle()
101 GrpcTpuStream* stream() const { return stream_; } in stream() function in tpu_driver::__anonb00856100111::GrpcBufferHandle
116 std::shared_ptr<GrpcEvent> event) in GrpcCompiledProgramHandle()
125 GrpcTpuStream* stream() const { return stream_; } in stream() function in tpu_driver::__anonb00856100111::GrpcCompiledProgramHandle
156 explicit GrpcLoadedProgramHandle(EventId id, std::shared_ptr<GrpcEvent> event) in GrpcLoadedProgramHandle()
162 GrpcTpuStream* stream() const { return stream_; } in stream() function in tpu_driver::__anonb00856100111::GrpcLoadedProgramHandle
367 auto* stream = static_cast<GrpcBufferHandle*>(handle.get())->stream(); in Deallocate() local
374 auto* stream = static_cast<GrpcBufferHandle*>(dst)->stream(); in TransferToDevice() local
[all …]
/aosp_15_r20/external/tensorflow/tensorflow/compiler/xla/service/interpreter/
H A Dexecutor.h63 port::Status Launch(Stream *stream, const ThreadDim &thread_dims, in Launch()
85 bool MemcpyDeviceToDevice(Stream *stream, DeviceMemoryBase *pop_dst, in MemcpyDeviceToDevice()
91 port::Status MemZero(Stream *stream, DeviceMemoryBase *location, in MemZero()
95 port::Status Memset(Stream *stream, DeviceMemoryBase *location, in Memset()
99 port::Status Memset32(Stream *stream, DeviceMemoryBase *location, in Memset32()
130 port::Status AllocateEvent(Event *event) override { in AllocateEvent()
134 port::Status DeallocateEvent(Event *event) override { in DeallocateEvent()
138 port::Status RecordEvent(Stream *stream, Event *event) override { in RecordEvent()
142 port::Status WaitForEvent(Stream *stream, Event *event) override { in WaitForEvent()
146 Event::Status PollForEventStatus(Event *event) override { in PollForEventStatus()
[all …]
/aosp_15_r20/external/tensorflow/tensorflow/compiler/xla/stream_executor/host/
H A Dhost_gpu_executor.cc38 HostStream* AsHostStream(Stream* stream) { in AsHostStream()
99 bool HostExecutor::Memcpy(Stream* stream, void* host_dst, in Memcpy()
109 bool HostExecutor::Memcpy(Stream* stream, DeviceMemoryBase* gpu_dst, in Memcpy()
119 bool HostExecutor::MemcpyDeviceToDevice(Stream* stream, in MemcpyDeviceToDevice()
133 port::Status HostExecutor::MemZero(Stream* stream, DeviceMemoryBase* location, in MemZero()
143 port::Status HostExecutor::Memset(Stream* stream, DeviceMemoryBase* location, in Memset()
153 port::Status HostExecutor::Memset32(Stream* stream, DeviceMemoryBase* location, in Memset32()
183 bool HostExecutor::HostCallback(Stream* stream, in HostCallback()
189 bool HostExecutor::AllocateStream(Stream* stream) { return true; } in AllocateStream()
191 void HostExecutor::DeallocateStream(Stream* stream) {} in DeallocateStream()
[all …]
/aosp_15_r20/external/pytorch/c10/core/impl/
H A DVirtualGuardImpl.h61 void** event, in record()
62 const Stream& stream, in record()
67 void block(void* event, const Stream& stream) const override { in block()
70 bool queryEvent(void* event) const override { in queryEvent()
73 void destroyEvent(void* event, const DeviceIndex device_index) in destroyEvent()
78 bool queryStream(const Stream& stream) const override { in queryStream()
81 void synchronizeStream(const Stream& stream) const override { in synchronizeStream()
85 void recordDataPtrOnStream(const c10::DataPtr& data_ptr, const Stream& stream) in recordDataPtrOnStream()
95 void synchronizeEvent(void* event) const override { in synchronizeEvent()
/aosp_15_r20/external/tensorflow/tensorflow/compiler/xla/stream_executor/tpu/
H A Dtpu_executor.cc63 Status TpuExecutor::BlockHostUntilDone(Stream* stream) { in BlockHostUntilDone()
77 Status TpuExecutor::GetStatus(Stream* stream) { in GetStatus()
89 bool TpuExecutor::AllocateStream(Stream* stream) { in AllocateStream()
94 void TpuExecutor::DeallocateStream(Stream* stream) { in DeallocateStream()
108 Status TpuExecutor::AllocateEvent(Event* event) { return OkStatus(); } in AllocateEvent()
110 Status TpuExecutor::DeallocateEvent(Event* event) { in DeallocateEvent()
120 bool TpuExecutor::StartTimer(Stream* stream, ::stream_executor::Timer* timer) { in StartTimer()
126 bool TpuExecutor::StopTimer(Stream* stream, ::stream_executor::Timer* timer) { in StopTimer()
133 stream_executor::Event* event) { in PollForEventStatus()
140 Status TpuExecutor::RecordEvent(Stream* stream, in RecordEvent()
[all …]
/aosp_15_r20/external/tensorflow/tensorflow/stream_executor/rocm/
H A Drocm_gpu_executor.cc62 static GpuEvent* AsGpuEvent(Event* event) { in AsGpuEvent()
89 static GpuContext* GetGpuContext(Stream* stream) { in GetGpuContext()
119 GpuExecutor::CreateOrShareConstant(Stream* stream, in CreateOrShareConstant()
298 port::Status GpuExecutor::Launch(Stream* stream, const ThreadDim& thread_dims, in Launch()
506 port::Status GpuExecutor::MemZero(Stream* stream, DeviceMemoryBase* location, in MemZero()
516 port::Status GpuExecutor::Memset(Stream* stream, DeviceMemoryBase* location, in Memset()
526 port::Status GpuExecutor::Memset32(Stream* stream, DeviceMemoryBase* location, in Memset32()
538 bool GpuExecutor::Memcpy(Stream* stream, void* host_dst, in Memcpy()
545 bool GpuExecutor::Memcpy(Stream* stream, DeviceMemoryBase* gpu_dst, in Memcpy()
552 bool GpuExecutor::MemcpyDeviceToDevice(Stream* stream, in MemcpyDeviceToDevice()
[all …]
/aosp_15_r20/external/sonivox/jet_tools/JetCreator/
H A Dmidifile.py206 def __init__ (self, stream, msg): argument
257 def ReadByte (stream): argument
264 def ReadBytes (stream, length): argument
270 def ReadVarLenQty (stream): argument
278 def WriteByte (stream, value): argument
281 def WriteBytes (stream, bytes): argument
285 def WriteVarLenQty (stream, value): argument
304 def Check (self, event): argument
313 def Check (self, event): argument
323 def Check (self, event): argument
[all …]
/aosp_15_r20/external/tensorflow/tensorflow/compiler/xla/stream_executor/cuda/
H A Dcuda_gpu_executor.cc88 static GpuEvent* AsGpuEvent(Event* event) { in AsGpuEvent()
374 GpuExecutor::CreateOrShareConstant(Stream* stream, in CreateOrShareConstant()
441 port::Status GpuExecutor::Launch(Stream* stream, const ThreadDim& thread_dims, in Launch()
638 port::Status GpuExecutor::MemZero(Stream* stream, DeviceMemoryBase* location, in MemZero()
648 port::Status GpuExecutor::Memset(Stream* stream, DeviceMemoryBase* location, in Memset()
658 port::Status GpuExecutor::Memset32(Stream* stream, DeviceMemoryBase* location, in Memset32()
670 bool GpuExecutor::Memcpy(Stream* stream, void* host_dst, in Memcpy()
677 bool GpuExecutor::Memcpy(Stream* stream, DeviceMemoryBase* gpu_dst, in Memcpy()
684 bool GpuExecutor::MemcpyDeviceToDevice(Stream* stream, in MemcpyDeviceToDevice()
693 bool GpuExecutor::HostCallback(Stream* stream, in HostCallback()
[all …]
/aosp_15_r20/external/grpc-grpc-java/servlet/src/main/java/io/grpc/servlet/
H A DServletAdapter.java138 ServletServerStream stream = new ServletServerStream( in doPost() local
210 final ServletServerStream stream; field in ServletAdapter.GrpcAsyncListener
212 GrpcAsyncListener(ServletServerStream stream, InternalLogId logId) { in GrpcAsyncListener()
218 public void onComplete(AsyncEvent event) {} in onComplete()
221 public void onTimeout(AsyncEvent event) { in onTimeout()
236 public void onError(AsyncEvent event) { in onError()
253 public void onStartAsync(AsyncEvent event) {} in onStartAsync()
257 final ServletServerStream stream; field in ServletAdapter.GrpcReadListener
263 ServletServerStream stream, in GrpcReadListener()
/aosp_15_r20/external/tensorflow/tensorflow/compiler/xla/stream_executor/
H A Dstream_executor_pimpl.cc211 StreamExecutor::CreateOrShareConstant(Stream* stream, in CreateOrShareConstant()
295 dnn::DataType input_type, dnn::DataType output_type, Stream* stream, in GetConvolveRunners()
318 double leakyrelu_alpha, Stream* stream, in GetFusedConvolveRunners()
338 dnn::ConvolutionKind kind, dnn::DataType element_type, Stream* stream, in GetMIOpenConvolveAlgorithms()
366 Stream* stream, std::vector<blas::AlgorithmType>* out_algorithms) { in GetBlasGemmAlgorithms()
474 port::Status StreamExecutor::Launch(Stream* stream, in Launch()
485 port::Status StreamExecutor::BlockHostUntilDone(Stream* stream) { in BlockHostUntilDone()
493 port::Status StreamExecutor::GetStatus(Stream* stream) { in GetStatus()
704 bool StreamExecutor::Memcpy(Stream* stream, void* host_dst, in Memcpy()
709 bool StreamExecutor::Memcpy(Stream* stream, DeviceMemoryBase* device_dst, in Memcpy()
[all …]
/aosp_15_r20/external/rust/android-crates-io/crates/axum/src/response/
Dsse.rs58 stream: S, field
264 pub fn event<T>(mut self, event: T) -> Event in event() method
390 event: Bytes, field
434 pub fn event(mut self, event: Event) -> Self { in event() method
474 let event = this.keep_alive.event.clone(); in poll_event() localVariable
530 let stream = stream::iter(vec![ in basic() localVariable
546 let mut stream = client.get("/").send().await; in basic() localVariable
575 let stream = stream::repeat_with(|| Event::default().data("msg")) in keep_alive() localVariable
588 let mut stream = client.get("/").send().await; in keep_alive() localVariable
611 let stream = stream::repeat_with(|| Event::default().data("msg")) in keep_alive_ends_when_the_stream_ends() localVariable
[all …]
/aosp_15_r20/frameworks/opt/net/voip/src/jni/rtp/
DAudioGroup.cpp230 void AudioStream::sendDtmf(int event) in sendDtmf()
624 epoll_event event; in set() local
661 bool AudioGroup::sendDtmf(int event) in sendDtmf()
684 bool AudioGroup::add(AudioStream *stream) in add()
688 epoll_event event; in add() local
708 bool AudioGroup::remove(AudioStream *stream) in remove()
739 for (AudioStream *stream = chain; stream; stream = stream->mNext) { in threadLoop() local
749 int event = mGroup->mDtmfEvent; in threadLoop() local
751 for (AudioStream *stream = chain; stream; stream = stream->mNext) { in threadLoop() local
960 AudioStream *stream = NULL; in add() local
[all …]
/aosp_15_r20/external/webrtc/logging/rtc_event_log/
H A Drtc_event_log_unittest.cc233 auto event = gen_.NewAudioReceiveStreamConfig(ssrc, extensions); in WriteAudioRecvConfigs() local
250 auto event = gen_.NewAudioSendStreamConfig(ssrc, extensions); in WriteAudioSendConfigs() local
269 auto event = gen_.NewVideoReceiveStreamConfig(ssrc, all_extensions); in WriteVideoRecvConfigs() local
298 auto event = gen_.NewVideoSendStreamConfig(ssrc, all_extensions); in WriteVideoSendConfigs() local
308 auto event = gen_.NewVideoSendStreamConfig(ssrc, extensions); in WriteVideoSendConfigs() local
352 auto event = gen_.NewAlrState(); in WriteLog() local
361 auto event = gen_.NewRouteChange(); in WriteLog() local
370 size_t stream = prng_.Rand(incoming_extensions_.size() - 1); in WriteLog() local
373 auto event = gen_.NewAudioPlayout(ssrc); in WriteLog() local
382 auto event = gen_.NewAudioNetworkAdaptation(); in WriteLog() local
[all …]
/aosp_15_r20/external/webrtc/rtc_tools/rtc_event_log_to_text/
H A Dconverter.cc78 auto audio_recv_stream_handler = [&](const LoggedAudioRecvConfig& event) { in Convert()
86 auto audio_send_stream_handler = [&](const LoggedAudioSendConfig& event) { in Convert()
93 auto video_recv_stream_handler = [&](const LoggedVideoRecvConfig& event) { in Convert()
102 auto video_send_stream_handler = [&](const LoggedVideoSendConfig& event) { in Convert()
110 auto start_logging_handler = [&](const LoggedStartEvent& event) { in Convert()
114 auto stop_logging_handler = [&](const LoggedStopEvent& event) { in Convert()
118 auto alr_state_handler = [&](const LoggedAlrStateEvent& event) { in Convert()
123 auto audio_playout_handler = [&](const LoggedAudioPlayoutEvent& event) { in Convert()
129 [&](const LoggedAudioNetworkAdaptationEvent& event) { in Convert()
157 [&](const LoggedBweProbeClusterCreatedEvent& event) { in Convert()
[all …]
/aosp_15_r20/external/tensorflow/tensorflow/core/profiler/utils/
H A Dgroup_events_test.cc65 auto stream = device_plane_builder.GetOrCreateLine(0); in TEST() local
109 auto stream = device_plane_builder.GetOrCreateLine(0); in TEST() local
149 auto stream = device_plane_builder.GetOrCreateLine(0); in TEST() local
301 auto is_eager = [](const XEventVisitor& event) { in TEST()
309 line.ForEachEvent([&](const XEventVisitor& event) { in TEST()
325 line.ForEachEvent([&](const XEventVisitor& event) { in TEST()
376 auto stream = device_plane_builder.GetOrCreateLine(0); in TEST() local
423 [&](const tensorflow::profiler::XEventVisitor& event) { in TEST()
464 [&](const tensorflow::profiler::XEventVisitor& event) { in TEST()
509 [&](const tensorflow::profiler::XEventVisitor& event) { in TEST()
[all …]
/aosp_15_r20/system/chre/apps/nearby/location/lbs/contexthub/nanoapps/nearby/
H A Dapp_manager.cc68 const chreBleAdvertisementEvent *event; in HandleEvent() local
186 void AppManager::HandleMessageFromHost(const chreMessageFromHostData *event) { in HandleMessageFromHost()
241 pb_istream_t stream = pb_istream_from_buffer(message, message_size); in HandleHostConfigRequest() local
308 auto stream = pb_ostream_from_buffer(static_cast<pb_byte_t *>(msg_buf), in SendFilterResultsToHost() local
345 auto stream = pb_ostream_from_buffer(static_cast<pb_byte_t *>(msg_buf), in SendFilterResultToHost() local
374 static bool EncodeFilterResultCallback(pb_ostream_t *stream, in EncodeFilterResultCallback()
417 pb_ostream_t *stream, size_t *msg_size) { in EncodeFilterResults()
440 pb_ostream_t *stream, size_t *msg_size) { in EncodeFilterResult()
458 const chreMessageFromHostData *event) { in HandleHostExtConfigRequest()
460 pb_istream_t stream = in HandleHostExtConfigRequest() local
/aosp_15_r20/external/pytorch/torch/csrc/jit/cuda/
H A Dcuda.h119 c10::intrusive_ptr<CUDAEvent> event) { in recordEvent()
128 inline void CUDAStream::waitEvent(const c10::intrusive_ptr<CUDAEvent>& event) { in waitEvent()
133 const c10::intrusive_ptr<CUDAStream>& stream) { in waitStream()
139 inline void CUDAEvent::record(const c10::intrusive_ptr<CUDAStream>& stream) { in record()
143 inline void CUDAEvent::recordInternal(CUDAStream* stream) { in recordInternal()
147 inline void CUDAEvent::wait(const c10::intrusive_ptr<CUDAStream>& stream) { in wait()
/aosp_15_r20/packages/modules/Bluetooth/system/stack/btu/
Dbtu_hcif.cc560 const uint8_t* stream = p_buf->data + p_buf->offset; in btu_hcif_send_cmd() local
639 static void btu_hcif_command_complete_evt_with_cb_on_task(BT_HDR* event, void* context) { in btu_hcif_command_complete_evt_with_cb_on_task()
643 uint8_t* stream = event->data + event->offset + 3; in btu_hcif_command_complete_evt_with_cb_on_task() local
665 static void btu_hcif_command_status_evt_with_cb_on_task(uint8_t status, BT_HDR* event, in btu_hcif_command_status_evt_with_cb_on_task()
668 uint8_t* stream = event->data + event->offset; in btu_hcif_command_status_evt_with_cb_on_task() local
1000 static void btu_hcif_command_complete_evt_on_task(BT_HDR* event) { in btu_hcif_command_complete_evt_on_task()
1004 uint8_t* stream = event->data + event->offset + 3; in btu_hcif_command_complete_evt_on_task() local
1147 static void btu_hcif_command_status_evt_on_task(uint8_t status, BT_HDR* event) { in btu_hcif_command_status_evt_on_task()
1149 uint8_t* stream = event->data + event->offset; in btu_hcif_command_status_evt_on_task() local
1226 void btu_hcif_proc_sp_req_evt(tBTM_SP_EVT event, const uint8_t* p) { in btu_hcif_proc_sp_req_evt()
/aosp_15_r20/external/pytorch/torch/
H A D_streambase.py9 def wait_event(self, event) -> None: argument
13 def wait_stream(self, stream) -> None: argument
17 def record_event(self, event=None) -> None: argument
29 def __eq__(self, stream) -> bool: argument
37 def wait(self, stream=None) -> None: argument

12345678910>>...52