added missing 'public' inheritance to SocketRpcChannel, added SocketR…

…pcChannel::IsClosed
ersintarhan · Aug 19, 2011 · b407669 · b407669
1 parent d96dabf
commit b407669
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 1 deletion.
diff --git a/Cpp/Source/ProtoBufRemote/SocketRpcChannel.cpp b/Cpp/Source/ProtoBufRemote/SocketRpcChannel.cpp
@@ -47,6 +47,11 @@ void SocketRpcChannel::CloseAndJoin()
     }
 }
 
+bool SocketRpcChannel::IsClosed()
+{
+    return (m_socket == INVALID_SOCKET);
+}
+
 unsigned int SocketRpcChannel::GetAndClearBytesRead()
 {
 	return _InterlockedExchange(reinterpret_cast<LONG*>(&m_bytesRead), 0);

diff --git a/Cpp/Source/ProtoBufRemote/SocketRpcChannel.h b/Cpp/Source/ProtoBufRemote/SocketRpcChannel.h
@@ -7,7 +7,7 @@
 
 namespace ProtoBufRemote {
 
-class SocketRpcChannel : RpcChannel
+class SocketRpcChannel : public RpcChannel
 {
 public:
 	SocketRpcChannel(RpcController* controller, SOCKET socket);
@@ -17,6 +17,8 @@ class SocketRpcChannel : RpcChannel
 
 	void CloseAndJoin();
 
+    bool IsClosed();
+
 	virtual void Send(const RpcMessage& message);
 
 	unsigned int GetAndClearBytesRead();