worker_exception.h

#pragma once

#include <exception>
#include <string>
#include <utility>

namespace torch {
namespace data {

struct WorkerException : public std::exception {
  explicit WorkerException(std::exception_ptr original)
      : original_exception(std::move(original)),
        message("Caught exception in DataLoader worker thread.") {
    try {
      std::rethrow_exception(original_exception);
    } catch (std::exception& e) {
      message += " Original message: ";
      message += e.what();
    }
  }

  const char* what() const noexcept override {
    return message.c_str();
  }

  std::exception_ptr original_exception;

  std::string message;
};

} // namespace data
} // namespace torch