AuroraSupport/AuroraRPC
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

[*] eat da boogs

Browse Source
This commit is contained in:
Reece Wilson 2022-07-05 21:16:22 +01:00
parent 82f87679d2
commit c4df7fc4c2
4 changed files with 11 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
Source/AuRPCClientChannel.cpp
View File

@ -186,6 +186,11 @@ void AuRPCClientChannel::Finalize()
{
auto re = AuExchange(this->outstandingRequests, AuList<AuSPtr<AuRPCRequest>>{});
if (AuExchange(this->bIsDead_, true))
{
return;
}
for (auto a : re)
{
a->callback->OnResponse(AuRPCResponse(ERPCError::eAborted));

1
Source/AuRPCClientChannel.hpp
View File

@ -41,6 +41,7 @@ struct AuRPCClientChannel : AuRPCChannel, AuIRPCClientChannel, AuEnableSharedFro
private:
bool bConnectingAlternate_{};
bool bConnected_{};
bool bIsDead_ {};
AuSPtr<AuIRPCChannelCallbacks> callbacks_;
AuRPCPipe pipe_;
AuSPtr<AuRPC> parent_;

4
Source/AuRPCPipe.cpp
View File

@ -154,6 +154,10 @@ void AuRPCPipe::OnPipePartialEvent(AuUInt trasnferred)
void AuRPCPipe::OnPipeSuccessEvent()
{
if (this->isClient_)
{
return;
}
RpcLogDebug("Waiting for next socket");
this->isOpenWork = GetRPCProcessor()->StartSimpleLSWatch(this->pipe->AsReadChannelIsOpen(),
AuSPtr<AuIO::IIOSimpleEventListener>(this->channel->ToContext(), this));

2
Source/AuRPCRequest.cpp
View File

@ -18,7 +18,7 @@ bool AuRPCRequest::SetData(const AuMemoryViewRead& view)
{
data.Reset();
this->packetLength = view.length + this->HeaderLength();
data.Reserve(view.length + this->HeaderLength());
data.Resize(view.length + this->HeaderLength());
if (!this->data)
{
SysPushErrorMem();