Skip to content

Commit 35b4a10

Browse files
committed
further reduced cpu usage
1 parent a5c5b59 commit 35b4a10

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

FreeTAKServer/controllers/services/federation/FederationClientService.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -162,7 +162,7 @@ def connect_to_server(self, server_vars: Tuple[str, str]) -> None:
162162
federate.addr = federate_db_obj.address
163163
federate.conn = ssock
164164
federate.name = federate_db_obj.name
165-
events = selectors.EVENT_READ | selectors.EVENT_WRITE
165+
events = selectors.EVENT_READ
166166
self.sel.register(ssock, events, federate)
167167
self.federates[server_vars[0]] = federate
168168
self._send_connected_clients(ssock)
@@ -187,7 +187,7 @@ def receive_data_from_federate(self, timeout):
187187
"""
188188
dataarray = []
189189
if self.federates:
190-
events = self.sel.select(timeout)
190+
events = self.sel.select(timeout=timeout)
191191
for key, mask in events:
192192
conn = key.fileobj
193193
try:

FreeTAKServer/controllers/services/federation/federation.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -143,7 +143,7 @@ def receive_data_from_federate(self, timeout):
143143
send data through process pipe
144144
"""
145145
dataarray = []
146-
events = self.sel.select(timeout)
146+
events = self.sel.select(timeout=timeout)
147147
for key, mask in events:
148148
if key.data is None:
149149
self._accept_connection(key.fileobj)
@@ -189,7 +189,7 @@ def _accept_connection(self, sock) -> None:
189189
data.name = addr[0]
190190
data.addr = addr
191191
data.uid = str(uuid.uuid4())
192-
events = selectors.EVENT_READ | selectors.EVENT_WRITE
192+
events = selectors.EVENT_READ
193193
self._send_connected_clients(conn)
194194
self.sel.register(conn, events, data=data)
195195
self.federates[data.uid] = data

0 commit comments

Comments
 (0)