@@ -65,7 +65,7 @@ failed(::CudaEvent) = false
65
65
isdone (ev:: CudaEvent ) = CUDA. query (ev. event)
66
66
67
67
function Event (:: CUDADevice )
68
- stream = CUDA. CuDefaultStream ()
68
+ stream = CUDA. stream ()
69
69
event = CUDA. CuEvent (CUDA. EVENT_DISABLE_TIMING)
70
70
CUDA. record (event, stream)
71
71
CudaEvent (event)
@@ -85,11 +85,11 @@ function wait(::CPU, ev::CudaEvent, progress=yield)
85
85
end
86
86
end
87
87
88
- # Use this to synchronize between computation using the CuDefaultStream
89
- wait (:: CUDADevice , ev:: CudaEvent , progress= nothing , stream= CUDA. CuDefaultStream ()) = CUDA. wait (ev. event, stream)
88
+ # Use this to synchronize between computation using the task local stream
89
+ wait (:: CUDADevice , ev:: CudaEvent , progress= nothing , stream= CUDA. stream ()) = CUDA. wait (ev. event, stream)
90
90
wait (:: CUDADevice , ev:: NoneEvent , progress= nothing , stream= nothing ) = nothing
91
91
92
- function wait (:: CUDADevice , ev:: MultiEvent , progress= nothing , stream= CUDA. CuDefaultStream ())
92
+ function wait (:: CUDADevice , ev:: MultiEvent , progress= nothing , stream= CUDA. stream ())
93
93
dependencies = collect (ev. events)
94
94
cudadeps = filter (d-> d isa CudaEvent, dependencies)
95
95
otherdeps = filter (d-> ! (d isa CudaEvent), dependencies)
0 commit comments