diff options
| author | Rapptz <[email protected]> | 2021-08-22 02:33:51 -0400 |
|---|---|---|
| committer | Rapptz <[email protected]> | 2021-08-22 02:33:51 -0400 |
| commit | ea2d972666364c0f8159c9166e97f1b6053e3b68 (patch) | |
| tree | a81c89ed4326460e808fa3b2f347cf8102bd8156 /discord/voice_client.py | |
| parent | ResponseType type alias is private (diff) | |
| download | discord.py-ea2d972666364c0f8159c9166e97f1b6053e3b68.tar.xz discord.py-ea2d972666364c0f8159c9166e97f1b6053e3b68.zip | |
Make global log variable in modules private
Diffstat (limited to 'discord/voice_client.py')
| -rw-r--r-- | discord/voice_client.py | 28 |
1 files changed, 14 insertions, 14 deletions
diff --git a/discord/voice_client.py b/discord/voice_client.py index 6816fa3e..d382a74d 100644 --- a/discord/voice_client.py +++ b/discord/voice_client.py @@ -84,7 +84,7 @@ __all__ = ( -log: logging.Logger = logging.getLogger(__name__) +_log = logging.getLogger(__name__) class VoiceProtocol: """A class that represents the Discord voice protocol. @@ -301,7 +301,7 @@ class VoiceClient(VoiceProtocol): async def on_voice_server_update(self, data: VoiceServerUpdatePayload) -> None: if self._voice_server_complete.is_set(): - log.info('Ignoring extraneous voice server update.') + _log.info('Ignoring extraneous voice server update.') return self.token = data.get('token') @@ -309,7 +309,7 @@ class VoiceClient(VoiceProtocol): endpoint = data.get('endpoint') if endpoint is None or self.token is None: - log.warning('Awaiting endpoint... This requires waiting. ' \ + _log.warning('Awaiting endpoint... This requires waiting. ' \ 'If timeout occurred considering raising the timeout and reconnecting.') return @@ -335,18 +335,18 @@ class VoiceClient(VoiceProtocol): await self.channel.guild.change_voice_state(channel=self.channel) async def voice_disconnect(self) -> None: - log.info('The voice handshake is being terminated for Channel ID %s (Guild ID %s)', self.channel.id, self.guild.id) + _log.info('The voice handshake is being terminated for Channel ID %s (Guild ID %s)', self.channel.id, self.guild.id) await self.channel.guild.change_voice_state(channel=None) def prepare_handshake(self) -> None: self._voice_state_complete.clear() self._voice_server_complete.clear() self._handshaking = True - log.info('Starting voice handshake... (connection attempt %d)', self._connections + 1) + _log.info('Starting voice handshake... (connection attempt %d)', self._connections + 1) self._connections += 1 def finish_handshake(self) -> None: - log.info('Voice handshake complete. Endpoint found %s', self.endpoint) + _log.info('Voice handshake complete. Endpoint found %s', self.endpoint) self._handshaking = False self._voice_server_complete.clear() self._voice_state_complete.clear() @@ -360,7 +360,7 @@ class VoiceClient(VoiceProtocol): return ws async def connect(self, *, reconnect: bool, timeout: float) ->None: - log.info('Connecting to voice...') + _log.info('Connecting to voice...') self.timeout = timeout for i in range(5): @@ -388,7 +388,7 @@ class VoiceClient(VoiceProtocol): break except (ConnectionClosed, asyncio.TimeoutError): if reconnect: - log.exception('Failed to connect to voice... Retrying...') + _log.exception('Failed to connect to voice... Retrying...') await asyncio.sleep(1 + i * 2.0) await self.voice_disconnect() continue @@ -453,14 +453,14 @@ class VoiceClient(VoiceProtocol): # 4014 - voice channel has been deleted. # 4015 - voice server has crashed if exc.code in (1000, 4015): - log.info('Disconnecting from voice normally, close code %d.', exc.code) + _log.info('Disconnecting from voice normally, close code %d.', exc.code) await self.disconnect() break if exc.code == 4014: - log.info('Disconnected from voice by force... potentially reconnecting.') + _log.info('Disconnected from voice by force... potentially reconnecting.') successful = await self.potential_reconnect() if not successful: - log.info('Reconnect was unsuccessful, disconnecting from voice normally...') + _log.info('Reconnect was unsuccessful, disconnecting from voice normally...') await self.disconnect() break else: @@ -471,7 +471,7 @@ class VoiceClient(VoiceProtocol): raise retry = backoff.delay() - log.exception('Disconnected from voice... Reconnecting in %.2fs.', retry) + _log.exception('Disconnected from voice... Reconnecting in %.2fs.', retry) self._connected.clear() await asyncio.sleep(retry) await self.voice_disconnect() @@ -479,7 +479,7 @@ class VoiceClient(VoiceProtocol): await self.connect(reconnect=True, timeout=self.timeout) except asyncio.TimeoutError: # at this point we've retried 5 times... let's continue the loop. - log.warning('Could not connect to voice... Retrying...') + _log.warning('Could not connect to voice... Retrying...') continue async def disconnect(self, *, force: bool = False) -> None: @@ -671,6 +671,6 @@ class VoiceClient(VoiceProtocol): try: self.socket.sendto(packet, (self.endpoint_ip, self.voice_port)) except BlockingIOError: - log.warning('A packet has been dropped (seq: %s, timestamp: %s)', self.sequence, self.timestamp) + _log.warning('A packet has been dropped (seq: %s, timestamp: %s)', self.sequence, self.timestamp) self.checked_add('timestamp', opus.Encoder.SAMPLES_PER_FRAME, 4294967295) |