We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 1acb101 commit 0c13988Copy full SHA for 0c13988
libc/shared/rpc.h
@@ -551,6 +551,9 @@ template <uint32_t opcode> RPC_ATTRS Client::Port Client::open() {
551
/// port if it has a pending receive operation
552
RPC_ATTRS rpc::optional<typename Server::Port>
553
Server::try_open(uint32_t lane_size, uint32_t start) {
554
+ if (rpc::get_lane_id() >= lane_size)
555
+ return rpc::nullopt;
556
+
557
// Perform a naive linear scan for a port that has a pending request.
558
for (uint32_t index = start; index < process.port_count; ++index) {
559
uint64_t lane_mask = rpc::get_lane_mask();
0 commit comments