1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
|
#pragma once
#include <c10/util/Exception.h>
#include <mutex>
#include <vector>
namespace torch {
namespace autograd {
namespace utils {
// Warning handler for multi-threaded contexts. Gather warnings from
// all threads into a single queue, then process together at the end
// in the main thread.
class DelayWarningHandler : public at::WarningHandler {
public:
~DelayWarningHandler() override = default;
void replay_warnings();
private:
void process(
const at::SourceLocation& source_location,
const std::string& msg,
bool verbatim) override;
struct Warning {
c10::SourceLocation source_location;
std::string msg;
bool verbatim;
};
std::vector<Warning> warnings_;
std::mutex mutex_;
};
} // namespace utils
} // namespace autograd
} // namespace torch
|
