| @@ -201,3 +201,8 @@ int NamedPipe::write (const void* sourceBuffer, int numBytesToWrite, int timeOut | |||||
| { | { | ||||
| return pimpl != nullptr ? pimpl->write (static_cast <const char*> (sourceBuffer), numBytesToWrite, timeOutMilliseconds) : -1; | return pimpl != nullptr ? pimpl->write (static_cast <const char*> (sourceBuffer), numBytesToWrite, timeOutMilliseconds) : -1; | ||||
| } | } | ||||
| bool NamedPipe::isOpen() const | |||||
| { | |||||
| return pimpl != nullptr; | |||||
| } | |||||
| @@ -795,6 +795,8 @@ public: | |||||
| } | } | ||||
| } | } | ||||
| bool isConnected() const noexcept { return connected; } | |||||
| HANDLE pipeH, cancelEvent; | HANDLE pipeH, cancelEvent; | ||||
| bool connected, isPipe; | bool connected, isPipe; | ||||
| }; | }; | ||||
| @@ -808,6 +810,11 @@ NamedPipe::~NamedPipe() | |||||
| close(); | close(); | ||||
| } | } | ||||
| bool NamedPipe::isOpen() const | |||||
| { | |||||
| return pimpl != nullptr && pimpl->connected; | |||||
| } | |||||
| void NamedPipe::cancelPendingReads() | void NamedPipe::cancelPendingReads() | ||||
| { | { | ||||
| if (pimpl != nullptr) | if (pimpl != nullptr) | ||||
| @@ -35,11 +35,6 @@ bool NamedPipe::createNewPipe (const String& pipeName) | |||||
| return openInternal (pipeName, true); | return openInternal (pipeName, true); | ||||
| } | } | ||||
| bool NamedPipe::isOpen() const | |||||
| { | |||||
| return pimpl != nullptr; | |||||
| } | |||||
| String NamedPipe::getName() const | String NamedPipe::getName() const | ||||
| { | { | ||||
| return currentPipeName; | return currentPipeName; | ||||