def _CheckSocket(self):
    if self._rstream is None or self._wstream is None:
      raise errors.ProtocolError("Connection is closed")
Make sure we are connected.
dataset/ETHPy150Open ganeti/ganeti/lib/rpc/transport.py/FdTransport._CheckSocket