1 //===------- SimpleEPCServer.cpp - EPC over simple abstract channel -------===//
5 // SPDX-License-Identifier: Apache-2.0 WITH LLVM-exception
7 //===----------------------------------------------------------------------===//
44     --Outstanding;  in dispatch()
72       assert(SeqNo == 0 && "Non-zero SeqNo for Setup?");  in handleMessage()
73       assert(!TagAddr && "Non-zero TagAddr for Setup?");  in handleMessage()
77       assert(SeqNo == 0 && "Non-zero SeqNo for Hangup?");  in handleMessage()
78       assert(!TagAddr && "Non-zero TagAddr for Hangup?");  in handleMessage()
82       assert(!TagAddr && "Non-zero TagAddr for Result?");  in handleMessage()
88     dbgs() << ", seqno = " << SeqNo << ", tag-addr = " << TagAddr  in handleMessage()
89            << ", arg-buffer = " << formatv("{0:x}", ArgBytes.size())  in handleMessage()
131   // Send out-of-band errors to any waiting threads.  in handleDisconnect()
133     KV.second->set_value(  in handleDisconnect()
137   D->shutdown();  in handleDisconnect()
142       joinErrors(std::move(ShutdownErr), Services.back()->shutdown());  in handleDisconnect()
161       assert(SeqNo == 0 && "Non-zero SeqNo for Setup?");  in sendMessage()
162       assert(!TagAddr && "Non-zero TagAddr for Setup?");  in sendMessage()
166       assert(SeqNo == 0 && "Non-zero SeqNo for Hangup?");  in sendMessage()
167       assert(!TagAddr && "Non-zero TagAddr for Hangup?");  in sendMessage()
171       assert(!TagAddr && "Non-zero TagAddr for Result?");  in sendMessage()
177     dbgs() << ", seqno = " << SeqNo << ", tag-addr = " << TagAddr  in sendMessage()
178            << ", arg-buffer = " << formatv("{0:x}", ArgBytes.size())  in sendMessage()
181   auto Err = T->sendMessage(OpC, SeqNo, TagAddr, ArgBytes);  in sendMessage()
184       dbgs() << "  \\--> SimpleRemoteEPC::sendMessage failed\n";  in sendMessage()
240     P = I->second;  in handleResult()
246   P->set_value(std::move(R));  in handleResult()
253   D->dispatch([this, RemoteSeqNo, TagAddr, ArgBytes = std::move(ArgBytes)]() {  in handleCallWrapper()
294       ->doJITDispatch(FnTag, ArgData, ArgSize)  in jitDispatchEntry()