|
|
@ -314,7 +314,9 @@ class ConnectionState: |
|
|
|
try: |
|
|
|
await utils.sane_wait_for(chunks, timeout=len(chunks) * 30.0) |
|
|
|
except asyncio.TimeoutError: |
|
|
|
log.info('Somehow timed out waiting for chunks.') |
|
|
|
log.warning('Somehow timed out waiting for chunks.') |
|
|
|
else: |
|
|
|
log.info('Finished requesting guild member chunks for %d guilds.', len(guilds)) |
|
|
|
|
|
|
|
async def query_members(self, guild, query, limit, cache): |
|
|
|
guild_id = guild.id |
|
|
@ -339,7 +341,7 @@ class ConnectionState: |
|
|
|
|
|
|
|
return members |
|
|
|
except asyncio.TimeoutError: |
|
|
|
log.info('Timed out waiting for chunks with query %r and limit %d for guild_id %d', query, limit, guild_id) |
|
|
|
log.warning('Timed out waiting for chunks with query %r and limit %d for guild_id %d', query, limit, guild_id) |
|
|
|
raise |
|
|
|
|
|
|
|
async def _delay_ready(self): |
|
|
@ -884,7 +886,7 @@ class ConnectionState: |
|
|
|
guild_id = int(data['guild_id']) |
|
|
|
guild = self._get_guild(guild_id) |
|
|
|
members = [Member(guild=guild, data=member, state=self) for member in data.get('members', [])] |
|
|
|
log.info('Processed a chunk for %s members in guild ID %s.', len(members), guild_id) |
|
|
|
log.debug('Processed a chunk for %s members in guild ID %s.', len(members), guild_id) |
|
|
|
if self._cache_members: |
|
|
|
for member in members: |
|
|
|
existing = guild.get_member(member.id) |
|
|
@ -1055,6 +1057,8 @@ class AutoShardedConnectionState(ConnectionState): |
|
|
|
await utils.sane_wait_for(chunks, timeout=len(chunks) * 30.0) |
|
|
|
except asyncio.TimeoutError: |
|
|
|
log.info('Somehow timed out waiting for chunks.') |
|
|
|
else: |
|
|
|
log.info('Finished requesting guild member chunks for %d guilds.', len(guilds)) |
|
|
|
|
|
|
|
async def _delay_ready(self): |
|
|
|
launch = self._ready_state.launch |
|
|
|