Revert "Reland "[C10] PG observability hooks. (pytorch#108815)" (pytorch#110907)"

This reverts commit 7678cd2.

Reverted pytorch#110907 on behalf of https://github.com/huydhn due to Sorry for reverting this, but macos job in trunk starts failing after this https://hud.pytorch.org/pytorch/pytorch/commit/7678cd22af46c9df4fb47a409d3e8ad71a6127ea ([comment](pytorch#110907 (comment)))

Author: pytorchmergebot

build_variables.bzl

@@ -521,7 +521,6 @@ libtorch_distributed_base_sources = [
     "torch/csrc/distributed/c10d/Backend.cpp",
     "torch/csrc/distributed/c10d/FileStore.cpp",
     "torch/csrc/distributed/c10d/GlooDeviceFactory.cpp",
-    "torch/csrc/distributed/c10d/Hooks.cpp",
     "torch/csrc/distributed/c10d/Ops.cpp",
     "torch/csrc/distributed/c10d/ParamCommsUtils.cpp",
     "torch/csrc/distributed/c10d/PrefixStore.cpp",

test/distributed/test_hooks.py

@@ -11,10 +11,6 @@ _DEFAULT_FIRST_BUCKET_BYTES: int
 _DEFAULT_NO_TIMEOUT: timedelta
 _DEFAULT_PG_TIMEOUT: timedelta
 
-class EventKind(Enum):
-    START = ...
-    END = ...
-
 class BuiltinCommHookType(Enum):
     ALLREDUCE = ...
     FP16_COMPRESS = ...
@@ -24,8 +20,6 @@ def _register_builtin_comm_hook(
     reducer: Reducer,
     comm_hook_type: BuiltinCommHookType,
 ): ...
-def _dequeue_c10d_event() -> Dict[str, object]: ...
-def _enable_event_collection(pipe_fs: int) -> None: ...
 
 class GradBucket:
     def index(self) -> int: ...

torch/_C/_distributed_c10d.pyi

@@ -1,26 +1,9 @@
 #include <c10/util/Logging.h>
 #include <fmt/format.h>
 #include <torch/csrc/distributed/c10d/Backend.hpp>
-#include <torch/csrc/distributed/c10d/Hooks.hpp>
-#include <torch/csrc/distributed/c10d/logging.h>
 
 namespace c10d {
 
-namespace {
-void commonEventinit(
-    details::EventInfo& evt,
-    const Backend& backend,
-    const Work& work) {
-  evt.timestamp =
-      std::chrono::system_clock::to_time_t(std::chrono::system_clock::now());
-  evt.pg_name = backend.getGroupName();
-  evt.backend = backend.getBackendName();
-  evt.sequence_number = work.getSequencenumber();
-  evt.operation = c10d::opTypeToString(work.retrieveOpType());
-  evt.drop_count = 0;
-}
-} // namespace
-
 Backend::Backend(int rank, int size)
     : rank_(rank), size_(size), dist_debug_level_(debug_level()) {
   C10_LOG_API_USAGE_ONCE("c10d.backend");
@@ -32,21 +15,4 @@ void Backend::init() {
   C10_LOG_API_USAGE_ONCE(fmt::format("c10d.backend_{}", getBackendName()));
 }
 
-void Backend::emitCollectiveStart(const Work& work) {
-  details::EventInfo evt;
-  commonEventinit(evt, *this, work);
-
-  evt.event_kind = ::c10d::EventKind::CollectiveStart;
-  details::enqueue_c10d_event(std::move(evt));
-}
-
-void Backend::emitCollectiveEnd(const Work& work) {
-  details::EventInfo evt;
-  commonEventinit(evt, *this, work);
-
-  evt.event_kind = ::c10d::EventKind::CollectiveEnd;
-  evt.duration_ms = work.getDuration();
-  details::enqueue_c10d_event(std::move(evt));
-}
-
 } // namespace c10d

torch/csrc/distributed/c10d/Backend.cpp

@@ -366,8 +366,6 @@ class TORCH_API Backend : public torch::CustomClassHolder {
   // Implementations of this interface need to call this to setup
   // appropriate logging etc.
   void init();
-  void emitCollectiveStart(const Work& work);
-  void emitCollectiveEnd(const Work& work);
 
   const int rank_;
   const int size_;