Commit a8f9d8b
committed
Update on "Add an option to run RPC tests with TCP init"
We have found a few bugs where initializing/de-initializing/re-initializing RPC, and using RPC along with process groups does not work as expected, usually under TCP/env initialization (which is used over `file` which is the init that we use in our test in multi-machine scenarios).
Due to this motivation, this PR adds an environment variable `RPC_INIT_WITH_TCP` that allows us to run any RPC test with TCP initialization.
To avoid port collisions, we use `common.find_free_port()`.
Differential Revision: [D25085458](https://our.internmc.facebook.com/intern/diff/D25085458/)
**NOTE FOR REVIEWERS**: This PR has internal Facebook specific changes or comments, please review them on [Phabricator](https://our.internmc.facebook.com/intern/diff/D25085458/)!
[ghstack-poisoned]189 files changed
Lines changed: 19172 additions & 16964 deletions
File tree
- .circleci
- cimodel/data
- scripts
- verbatim-sources/job-specs
- .github/workflows
- .jenkins/pytorch/win-test-helpers
- aten/src
- ATen
- core
- cuda
- native
- cuda
- metal/mpscnn
- vulkan
- api
- glsl
- ops
- test
- vulkan
- THCUNN
- generic
- c10
- core
- macros
- caffe2
- core
- opt/custom
- python
- helpers
- layers
- onnx
- tests
- cmake
- Modules
- docs/source
- notes
- test
- cpp/tensorexpr
- jit
- onnx
- quantization
- third_party
- tools/code_analyzer
- torch
- csrc
- distributed/autograd/context
- jit
- frontend
- passes/onnx
- runtime
- static
- tensorexpr
- distributed/algorithms/ddp_comm_hooks
- fx/experimental
- jit
- nn
- intrinsic/qat/modules
- modules
- qat/modules
- onnx
- testing/_internal
Some content is hidden
Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
30 | 30 | | |
31 | 31 | | |
32 | 32 | | |
33 | | - | |
34 | | - | |
35 | | - | |
36 | | - | |
37 | 33 | | |
38 | 34 | | |
39 | 35 | | |
| |||
60 | 56 | | |
61 | 57 | | |
62 | 58 | | |
63 | | - | |
64 | | - | |
| 59 | + | |
| 60 | + | |
65 | 61 | | |
66 | 62 | | |
67 | 63 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
131 | 131 | | |
132 | 132 | | |
133 | 133 | | |
134 | | - | |
135 | | - | |
136 | | - | |
137 | | - | |
| 134 | + | |
| 135 | + | |
| 136 | + | |
| 137 | + | |
138 | 138 | | |
139 | 139 | | |
140 | 140 | | |
| |||
0 commit comments