Luca Wehrstedt
Luca Wehrstedt
We have a lot of shorthand `using alias = long complicated type`. One chief example are the types of callbacks. The issue is that we've been inconsistent with the name...
Currently the two endpoints of a pipe open one instance of all the channel types they have in common. However, due to a strict priority order between them, they will...
Latency-sensitive applications, like the transports, that use ringbuffers as intermediate storage for the data (think SHM, or InfiniBand), might benefit from using huge pages to avoid hitting as many page...
The strerror function (which returns the human-readable message for an error number) isn't thread safe. In practice on Linux it only happens for invalid error numbers, because in that case...
https://app.circleci.com/pipelines/github/pytorch/tensorpipe/956/workflows/97acedc6-b2e9-449a-b010-65a4ead3b670/jobs/6759 That job failed because of a flaky TSAN data race, or actually three of them, all involving libuv and all looking similar: one thread was doing a uv_loop_init and...
https://app.circleci.com/pipelines/github/pytorch/tensorpipe/748/workflows/4d1ba53b-e512-4e6a-acc9-5894d7cbc15a/jobs/5062/steps
Some prospective users have been asking whether TensorPipe will support pipes between different threads of the same program. There's no reason not to support this, and its implementation is very...
In several occasions we'd like to capture non-copyable objects in a lambda's closure but can't because this lambda gets encapsulated in a std::function which must be copyable. This happens for...
Threads spawned by contexts (transports, channels, ...) are given a name so that they can be more easily identified in GDB when debugging. The names currently are of the form...
The SHM consists of: - a map from integers (known as tokens) to functions (let's call them reactions) - a shared-memory ringbuffer where the producers are other processes who push...