arrow::Status wait()

in src/afs.cc [640:655]

• 13 lines of code
• 3 McCabe index (conditional complexity)

	arrow::Status wait(LocalSessionData* session, SharedRingBuffer* buffer, WaitMode mode)
	{
		const char* tag = (mode == WaitMode::Read) ? "wait read" : "wait written";
		auto peerPID = peer_pid(session);

		if (ARROW_PREDICT_FALSE(peerPID == InvalidPid))
		{
			return arrow::Status::IOError(
				Tag, ": ", tag_, ": ", tag, ": ", peer_name(), ": not alive");
		}

		P("%s: %s: %s: %s: kill: %d", Tag, tag_, tag, peer_name(), peerPID);
		kill(peerPID, SIGUSR1);

		return wait_internal(session, buffer, mode, tag);
	}