MeshCentral/MeshAgent
1
0
Fork 0
mirror of https://github.com/Ylianst/MeshAgent synced 2025-12-15 07:43:50 +00:00
Code Issues Releases Wiki Activity

Fixed bug where if you try to write data to a piped stream that was paused, the buffered data wouldn't get retried.

Browse Source
This commit is contained in:
Bryan Roe
2019-01-16 15:51:33 -08:00
parent f39beca4aa
commit 381baaf06a
1 changed files with 13 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
microscript/ILibDuktape_ReadableStream.c
View File

@@ -204,7 +204,19 @@ int ILibDuktape_readableStream_WriteData_Flush(struct ILibDuktape_WritableStream
stream->pipeInProgress = 0; stream->pipeInProgress = 0;
unpipeInProgress = stream->unpipeInProgress; unpipeInProgress = stream->unpipeInProgress;
sem_post(&(stream->pipeLock)); sem_post(&(stream->pipeLock));
if (unpipeInProgress == 0 && stream->ResumeHandler != NULL && stream->paused != 0) { stream->paused = 0; stream->ResumeHandler(stream, stream->user); }
if (stream->paused != 0 && stream->paused_data != NULL)
{
stream->paused = 0;
if (ILibDuktape_readableStream_resume_flush(stream) == 0 && stream->ResumeHandler != NULL)
{
stream->ResumeHandler(stream, stream->user);
}
}
else
{
if (unpipeInProgress == 0 && stream->ResumeHandler != NULL && stream->paused != 0) { stream->paused = 0; stream->ResumeHandler(stream, stream->user); }
}
return(1); return(1);
} }
return(0); return(0);