Merge pull request #214 from Peter9606/separate-stream-error
Bugfix: memsetAsync uses wrong default stream
This commit is contained in:
@@ -244,7 +244,7 @@ public:
|
|||||||
void *workspace = nullptr,
|
void *workspace = nullptr,
|
||||||
cudaStream_t stream = nullptr) {
|
cudaStream_t stream = nullptr) {
|
||||||
|
|
||||||
Status status = initialize(args, workspace);
|
Status status = initialize(args, workspace, stream);
|
||||||
|
|
||||||
if (status == Status::kSuccess) {
|
if (status == Status::kSuccess) {
|
||||||
status = run(stream);
|
status = run(stream);
|
||||||
|
|||||||
@@ -482,7 +482,7 @@ public:
|
|||||||
void *workspace = nullptr,
|
void *workspace = nullptr,
|
||||||
cudaStream_t stream = nullptr) {
|
cudaStream_t stream = nullptr) {
|
||||||
|
|
||||||
Status status = initialize(args, workspace);
|
Status status = initialize(args, workspace, stream);
|
||||||
|
|
||||||
if (status == Status::kSuccess) {
|
if (status == Status::kSuccess) {
|
||||||
status = run(stream);
|
status = run(stream);
|
||||||
@@ -673,7 +673,7 @@ public:
|
|||||||
/// Initializes GEMM state from arguments.
|
/// Initializes GEMM state from arguments.
|
||||||
Status initialize(Arguments const &args, void *workspace = nullptr, cudaStream_t stream = nullptr) {
|
Status initialize(Arguments const &args, void *workspace = nullptr, cudaStream_t stream = nullptr) {
|
||||||
|
|
||||||
return underlying_operator_.initialize(to_underlying_arguments(args), workspace);
|
return underlying_operator_.initialize(to_underlying_arguments(args), workspace, stream);
|
||||||
}
|
}
|
||||||
|
|
||||||
/// Lightweight update given a subset of arguments
|
/// Lightweight update given a subset of arguments
|
||||||
@@ -699,7 +699,7 @@ public:
|
|||||||
void *workspace = nullptr,
|
void *workspace = nullptr,
|
||||||
cudaStream_t stream = nullptr) {
|
cudaStream_t stream = nullptr) {
|
||||||
|
|
||||||
Status status = initialize(args, workspace);
|
Status status = initialize(args, workspace, stream);
|
||||||
|
|
||||||
if (status == Status::kSuccess) {
|
if (status == Status::kSuccess) {
|
||||||
status = run(stream);
|
status = run(stream);
|
||||||
|
|||||||
@@ -473,7 +473,7 @@ public:
|
|||||||
void *workspace = nullptr,
|
void *workspace = nullptr,
|
||||||
cudaStream_t stream = nullptr) {
|
cudaStream_t stream = nullptr) {
|
||||||
|
|
||||||
Status status = initialize(args, workspace);
|
Status status = initialize(args, workspace, stream);
|
||||||
|
|
||||||
if (status == Status::kSuccess) {
|
if (status == Status::kSuccess) {
|
||||||
status = run(stream);
|
status = run(stream);
|
||||||
@@ -700,7 +700,7 @@ public:
|
|||||||
/// Initializes GEMM state from arguments.
|
/// Initializes GEMM state from arguments.
|
||||||
Status initialize(Arguments const &args, void *workspace = nullptr, cudaStream_t stream = nullptr) {
|
Status initialize(Arguments const &args, void *workspace = nullptr, cudaStream_t stream = nullptr) {
|
||||||
|
|
||||||
return underlying_operator_.initialize(to_underlying_arguments(args), workspace);
|
return underlying_operator_.initialize(to_underlying_arguments(args), workspace, stream);
|
||||||
}
|
}
|
||||||
|
|
||||||
/// Lightweight update given a subset of arguments
|
/// Lightweight update given a subset of arguments
|
||||||
@@ -726,7 +726,7 @@ public:
|
|||||||
void *workspace = nullptr,
|
void *workspace = nullptr,
|
||||||
cudaStream_t stream = nullptr) {
|
cudaStream_t stream = nullptr) {
|
||||||
|
|
||||||
Status status = initialize(args, workspace);
|
Status status = initialize(args, workspace, stream);
|
||||||
|
|
||||||
if (status == Status::kSuccess) {
|
if (status == Status::kSuccess) {
|
||||||
status = run(stream);
|
status = run(stream);
|
||||||
|
|||||||
@@ -451,7 +451,7 @@ public:
|
|||||||
void *workspace = nullptr,
|
void *workspace = nullptr,
|
||||||
cudaStream_t stream = nullptr) {
|
cudaStream_t stream = nullptr) {
|
||||||
|
|
||||||
Status status = initialize(args, workspace);
|
Status status = initialize(args, workspace, stream);
|
||||||
|
|
||||||
if (status == Status::kSuccess) {
|
if (status == Status::kSuccess) {
|
||||||
status = run(stream);
|
status = run(stream);
|
||||||
@@ -666,7 +666,7 @@ public:
|
|||||||
/// Initializes GEMM state from arguments.
|
/// Initializes GEMM state from arguments.
|
||||||
Status initialize(Arguments const &args, void *workspace = nullptr, cudaStream_t stream = nullptr) {
|
Status initialize(Arguments const &args, void *workspace = nullptr, cudaStream_t stream = nullptr) {
|
||||||
|
|
||||||
return underlying_operator_.initialize(to_underlying_arguments(args), workspace);
|
return underlying_operator_.initialize(to_underlying_arguments(args), workspace, stream);
|
||||||
}
|
}
|
||||||
|
|
||||||
/// Lightweight update given a subset of arguments
|
/// Lightweight update given a subset of arguments
|
||||||
@@ -692,7 +692,7 @@ public:
|
|||||||
void *workspace = nullptr,
|
void *workspace = nullptr,
|
||||||
cudaStream_t stream = nullptr) {
|
cudaStream_t stream = nullptr) {
|
||||||
|
|
||||||
Status status = initialize(args, workspace);
|
Status status = initialize(args, workspace, stream);
|
||||||
|
|
||||||
if (status == Status::kSuccess) {
|
if (status == Status::kSuccess) {
|
||||||
status = run(stream);
|
status = run(stream);
|
||||||
|
|||||||
@@ -465,7 +465,7 @@ public:
|
|||||||
void *workspace = nullptr,
|
void *workspace = nullptr,
|
||||||
cudaStream_t stream = nullptr) {
|
cudaStream_t stream = nullptr) {
|
||||||
|
|
||||||
Status status = initialize(args, workspace);
|
Status status = initialize(args, workspace, stream);
|
||||||
|
|
||||||
if (status == Status::kSuccess) {
|
if (status == Status::kSuccess) {
|
||||||
status = run(stream);
|
status = run(stream);
|
||||||
@@ -674,7 +674,7 @@ public:
|
|||||||
/// Initializes GEMM state from arguments.
|
/// Initializes GEMM state from arguments.
|
||||||
Status initialize(Arguments const &args, void *workspace = nullptr, cudaStream_t stream = nullptr) {
|
Status initialize(Arguments const &args, void *workspace = nullptr, cudaStream_t stream = nullptr) {
|
||||||
|
|
||||||
return underlying_operator_.initialize(to_underlying_arguments(args), workspace);
|
return underlying_operator_.initialize(to_underlying_arguments(args), workspace, stream);
|
||||||
}
|
}
|
||||||
|
|
||||||
/// Lightweight update given a subset of arguments
|
/// Lightweight update given a subset of arguments
|
||||||
@@ -700,7 +700,7 @@ public:
|
|||||||
void *workspace = nullptr,
|
void *workspace = nullptr,
|
||||||
cudaStream_t stream = nullptr) {
|
cudaStream_t stream = nullptr) {
|
||||||
|
|
||||||
Status status = initialize(args, workspace);
|
Status status = initialize(args, workspace, stream);
|
||||||
|
|
||||||
if (status == Status::kSuccess) {
|
if (status == Status::kSuccess) {
|
||||||
status = run(stream);
|
status = run(stream);
|
||||||
|
|||||||
@@ -498,7 +498,7 @@ public:
|
|||||||
void *workspace = nullptr,
|
void *workspace = nullptr,
|
||||||
cudaStream_t stream = nullptr) {
|
cudaStream_t stream = nullptr) {
|
||||||
|
|
||||||
Status status = initialize(args, workspace);
|
Status status = initialize(args, workspace, stream);
|
||||||
|
|
||||||
if (status == Status::kSuccess) {
|
if (status == Status::kSuccess) {
|
||||||
status = run(stream);
|
status = run(stream);
|
||||||
|
|||||||
@@ -197,7 +197,7 @@ public:
|
|||||||
void *workspace = nullptr,
|
void *workspace = nullptr,
|
||||||
cudaStream_t stream = nullptr) {
|
cudaStream_t stream = nullptr) {
|
||||||
|
|
||||||
Status status = initialize(args, workspace);
|
Status status = initialize(args, workspace, stream);
|
||||||
|
|
||||||
if (status == Status::kSuccess) {
|
if (status == Status::kSuccess) {
|
||||||
status = run(stream);
|
status = run(stream);
|
||||||
|
|||||||
Reference in New Issue
Block a user