mirror
/
amqtt
kopia lustrzana https://github.com/Yakifo/amqtt
1
0
Forkuj 0
Kod Zgłoszenia Packages Projekty Wydania Wiki Aktywność

Fix missing attribute rename

pull/8/head
Nicolas Jouanin 2015-08-12 20:21:06 +02:00
rodzic e8720a0c5f
commit 3e614fa1df
1 zmienionych plików z 2 dodań i 2 usunięć
Pokaż statystyki Ściągnij plik aktualizacji Ściągnij plik porównania Expand all files Collapse all files

4
hbmqtt/broker.py
Wyświetl plik

@ -301,10 +301,10 @@ class Broker:
# Update stats
uptime = datetime.now() - self._stats[STAT_UPTIME]
client_connected = sum(1 for k, session in self._sessions.items() if session.machine.state == 'connected')
client_connected = sum(1 for k, session in self._sessions.items() if session.transitions.state == 'connected')
if client_connected > self._stats[STAT_CLIENTS_MAXIMUM]:
self._stats[STAT_CLIENTS_MAXIMUM] = client_connected
client_disconnected = sum(1 for k, session in self._sessions.items() if session.machine.state == 'disconnected')
client_disconnected = sum(1 for k, session in self._sessions.items() if session.transitions.state == 'disconnected')
inflight_in = 0
inflight_out = 0
messages_stored = 0