mirror of
https://github.com/pytorch/pytorch.git
synced 2025-10-22 22:25:10 +08:00
058814794b
Replace the runtime_error of the vallina C++ exceptions with TORCH_CEHCK Including: - torch/csrc/export - torch/csrc/cuda Fixes #148114 Pull Request resolved: https://github.com/pytorch/pytorch/pull/163437 Approved by: https://github.com/Skylion007, https://github.com/cyyever
44 lines
1.6 KiB
C++
44 lines
1.6 KiB
C++
#include <c10/util/Exception.h>
|
|
#include <torch/csrc/Stream.h>
|
|
#include <torch/csrc/cuda/THCP.h>
|
|
#include <torch/csrc/python_headers.h>
|
|
#include <cstdarg>
|
|
#include <string>
|
|
|
|
// NB: It's a list of *optional* CUDAStream; when nullopt, that means to use
|
|
// whatever the current stream of the device the input is associated with was.
|
|
std::vector<std::optional<at::cuda::CUDAStream>>
|
|
THPUtils_PySequence_to_CUDAStreamList(PyObject* obj) {
|
|
TORCH_CHECK(
|
|
PySequence_Check(obj),
|
|
"Expected a sequence in THPUtils_PySequence_to_CUDAStreamList");
|
|
THPObjectPtr seq = THPObjectPtr(PySequence_Fast(obj, nullptr));
|
|
TORCH_CHECK(
|
|
seq.get() != nullptr,
|
|
"expected PySequence, but got " + std::string(THPUtils_typename(obj)));
|
|
|
|
std::vector<std::optional<at::cuda::CUDAStream>> streams;
|
|
Py_ssize_t length = PySequence_Fast_GET_SIZE(seq.get());
|
|
streams.reserve(length);
|
|
for (Py_ssize_t i = 0; i < length; i++) {
|
|
PyObject* stream = PySequence_Fast_GET_ITEM(seq.get(), i);
|
|
|
|
if (PyObject_IsInstance(stream, (PyObject*)THPStreamClass)) {
|
|
// Spicy hot reinterpret cast!!
|
|
streams.emplace_back(at::cuda::CUDAStream::unpack3(
|
|
(reinterpret_cast<THPStream*>(stream))->stream_id,
|
|
static_cast<c10::DeviceIndex>(
|
|
reinterpret_cast<THPStream*>(stream)->device_index),
|
|
static_cast<c10::DeviceType>(
|
|
(reinterpret_cast<THPStream*>(stream))->device_type)));
|
|
} else if (stream == Py_None) {
|
|
streams.emplace_back();
|
|
} else {
|
|
TORCH_CHECK(
|
|
false,
|
|
"Unknown data type found in stream list. Need torch.cuda.Stream or None");
|
|
}
|
|
}
|
|
return streams;
|
|
}
|