Enum EventMsg 

pub enum EventMsg {
    Create {
        reply: Sender<Result<Event, GpuError>>,
    },
    Record {
        event: Event,
        stream: Arc<CudaStream>,
        reply: Sender<Result<(), GpuError>>,
    },
    Wait {
        event: Event,
        stream: Arc<CudaStream>,
        reply: Sender<Result<(), GpuError>>,
    },
    Query {
        event: Event,
        reply: Sender<Result<bool, GpuError>>,
    },
    ElapsedTime {
        start: Event,
        end: Event,
        reply: Sender<Result<Duration, GpuError>>,
    },
    Synchronize {
        event: Event,
        reply: Sender<Result<(), GpuError>>,
    },
    GetIpcHandle {
        event: Event,
        reply: Sender<Result<IpcEventHandle, GpuError>>,
    },
    OpenIpcHandle {
        handle: IpcEventHandle,
        reply: Sender<Result<Event, GpuError>>,
    },
}

Variants

Create

Create a new event. Reply with the typed Event.

Fields

reply: Sender<Result<Event, GpuError>>

Record

Record event against the current work in stream.

Fields

event: Event

stream: Arc<CudaStream>

reply: Sender<Result<(), GpuError>>

Wait

Wait on stream until event completes.

Fields

event: Event

stream: Arc<CudaStream>

reply: Sender<Result<(), GpuError>>

Query

Non-blocking query: true if completed.

Fields

event: Event

reply: Sender<Result<bool, GpuError>>

ElapsedTime

Elapsed wall-clock time between two events.

Fields

start: Event

end: Event

reply: Sender<Result<Duration, GpuError>>

Synchronize

Block the calling task until event completes.

Fields

event: Event

reply: Sender<Result<(), GpuError>>

GetIpcHandle

Export an IPC handle for event so a peer process can open it via OpenIpcHandle.

Fields

event: Event

reply: Sender<Result<IpcEventHandle, GpuError>>

OpenIpcHandle

Open an IPC handle minted by another process. The opened event is bound to the actor’s context.

Fields

handle: IpcEventHandle

reply: Sender<Result<Event, GpuError>>