Add docstrings.
This commit is contained in:
parent
93dd3d8d9d
commit
a3ee504c59
@ -82,7 +82,7 @@ def send_to_running_instance(cmdlist):
|
|||||||
|
|
||||||
|
|
||||||
def init_server():
|
def init_server():
|
||||||
global server
|
"""Start the IPC server and listen to commands."""
|
||||||
ok = QLocalServer.removeServer(SOCKETNAME)
|
ok = QLocalServer.removeServer(SOCKETNAME)
|
||||||
if not ok:
|
if not ok:
|
||||||
raise IPCError("Error while removing server {}!".format(SOCKETNAME))
|
raise IPCError("Error while removing server {}!".format(SOCKETNAME))
|
||||||
@ -94,8 +94,11 @@ def init_server():
|
|||||||
|
|
||||||
|
|
||||||
def on_localsocket_connection():
|
def on_localsocket_connection():
|
||||||
|
"""Slot for a new connection for the local socket.
|
||||||
|
|
||||||
|
FIXME this should be async.
|
||||||
|
"""
|
||||||
socket = server.nextPendingConnection()
|
socket = server.nextPendingConnection()
|
||||||
# FIXME timeout:
|
|
||||||
while not socket.canReadLine():
|
while not socket.canReadLine():
|
||||||
socket.waitForReadyRead()
|
socket.waitForReadyRead()
|
||||||
data = bytes(socket.readLine())
|
data = bytes(socket.readLine())
|
||||||
|
Loading…
Reference in New Issue
Block a user