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
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
|
#pragma once
#include <c10/util/Optional.h>
#include <torch/csrc/Export.h>
#include <torch/csrc/distributed/rpc/types.h>
#include <mutex>
#include <unordered_map>
namespace torch {
namespace distributed {
namespace rpc {
extern const std::string REMOTE_PROFILING_KEY_PREFIX;
class TORCH_API RemoteProfilerManager {
public:
// Retrieves the lazily-initialized RemoteProfilerManager singleton instance.
static RemoteProfilerManager& getInstance();
// Sets the current, thread-local profiling key.
void setCurrentKey(std::string key);
// Returns whether the current profiling key is set.
bool isCurrentKeySet() const;
// Unsets the current, thread-local profiling key to allow other RPCs to reset
// it.
void unsetCurrentKey();
// inserts a pair (globallyUniqueId, key) to an in-memory map. The
// corresponding ID is used in RPC deserialization to prefix remotely profiled
// events with the right key.
void saveRPCKey(
ProfilingId globallyUniqueId,
const std::string& rpcProfilingKey);
// Retrieves the profiling key corresponding to the given globallyUniqueId.
// Throws if it is not found.
std::string retrieveRPCProfilingKey(const ProfilingId& globallyUniqueId);
// Generates the next globally unique ID for profiling.
ProfilingId getNextProfilerId();
// Retrieves the currently set thread-local profiling key. Throws if it is not
// set.
std::string& getCurrentProfilingKey();
// erases the globallyUniqueId from the map. This can help save memory in the
// case that many RPCs are being profiled.
void eraseKey(const ProfilingId& globallyUniqueId);
RemoteProfilerManager(const RemoteProfilerManager& other) = delete;
RemoteProfilerManager operator=(const RemoteProfilerManager& other) = delete;
RemoteProfilerManager(RemoteProfilerManager&&) = delete;
RemoteProfilerManager& operator=(RemoteProfilerManager&&) = delete;
private:
RemoteProfilerManager();
~RemoteProfilerManager() = default;
local_id_t getNextLocalId();
std::unordered_map<ProfilingId, std::string, ProfilingId::Hash>
profiledRpcKeys_;
static thread_local c10::optional<std::string> currentThreadLocalKey_;
std::mutex mutex_;
local_id_t currentLocalId_;
};
} // namespace rpc
} // namespace distributed
} // namespace torch
|
