|
|
@@ -210,11 +210,6 @@ private: |
|
|
|
pipe.openExisting (pipeName);
|
|
|
|
}
|
|
|
|
|
|
|
|
~NamedPipeThread()
|
|
|
|
{
|
|
|
|
stopThread (100);
|
|
|
|
}
|
|
|
|
|
|
|
|
NamedPipe pipe;
|
|
|
|
const String& pipeName;
|
|
|
|
WaitableEvent& workCompleted;
|
|
|
@@ -231,6 +226,11 @@ private: |
|
|
|
sendData (sData)
|
|
|
|
{}
|
|
|
|
|
|
|
|
~SenderThread() override
|
|
|
|
{
|
|
|
|
stopThread (100);
|
|
|
|
}
|
|
|
|
|
|
|
|
void run() override
|
|
|
|
{
|
|
|
|
result = pipe.write (&sendData, sizeof (sendData), 2000);
|
|
|
@@ -248,6 +248,11 @@ private: |
|
|
|
: NamedPipeThread ("NamePipeSender", pName, shouldCreatePipe, completed)
|
|
|
|
{}
|
|
|
|
|
|
|
|
~ReceiverThread() override
|
|
|
|
{
|
|
|
|
stopThread (100);
|
|
|
|
}
|
|
|
|
|
|
|
|
void run() override
|
|
|
|
{
|
|
|
|
result = pipe.read (&recvData, sizeof (recvData), 2000);
|
|
|
|