def _add_logical_channel(self, logical_request):
        try:
            self._logical_channels_condition.acquire()
            if self._logical_channels in logical_request.channel_id:
                self._logger.debug('Channel id %d already exists' %
                                   logical_request.channel_id)
                raise PhysicalConnectionError(
                    _DROP_CODE_CHANNEL_ALREADY_EXISTS,
                    'Channel id %d already exists' %
                    logical_request.channel_id)
            worker = _Worker(self, logical_request)
            channel_data = _LogicalChannelData(logical_request, worker)
            self._logical_channels[logical_request.channel_id] = channel_data
            worker.start()
        finally:
            self._logical_channels_condition.release()
dataset/ETHPy150Open google/pywebsocket/mod_pywebsocket/mux.py/_MuxHandler._add_logical_channel/swapped operands of `in`