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
|
#pragma once
#include <torch/csrc/distributed/rpc/rpc_command_base.h>
#include <torch/csrc/distributed/rpc/types.h>
namespace torch::distributed::rpc {
// RPC call representing calling a Python function over RPC.
class TORCH_API PythonCall final : public RpcCommandBase {
public:
PythonCall(SerializedPyObj&& serializedPyObj, bool isAsyncExecution);
c10::intrusive_ptr<Message> toMessageImpl() && override;
static std::unique_ptr<PythonCall> fromMessage(const Message& message);
const SerializedPyObj& serializedPyObj() const;
inline bool isAsyncExecution() const {
return isAsyncExecution_;
}
private:
SerializedPyObj serializedPyObj_;
// NOLINTNEXTLINE(cppcoreguidelines-avoid-const-or-ref-data-members)
const bool isAsyncExecution_;
};
} // namespace torch::distributed::rpc
|
