LBRYCommunity/aioupnp
1
0
Fork 0
Code Issues 7 Pull requests 1 Projects Releases 1 Packages Wiki Activity

catch soap timeout error

Browse source
This commit is contained in:
Jack Robison 2018-10-12 13:20:09 -04:00
parent e8ec88cbf8
commit ad63f3e853
No known key found for this signature in database
GPG key ID: DF25C68FE0239BB2
1 changed files with 10 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
aioupnp/protocols/soap.py
View file

@ -1,7 +1,9 @@
import logging import logging
import socket import socket
import asyncio
import typing import typing
from aioupnp.protocols.scpd import scpd_post from aioupnp.protocols.scpd import scpd_post
from aioupnp.fault import UPnPError
log = logging.getLogger(__name__) log = logging.getLogger(__name__)
@ -27,10 +29,14 @@ class SOAPCommand:
raise Exception("argument mismatch: %s vs %s" % (kwargs.keys(), self.param_types.keys())) raise Exception("argument mismatch: %s vs %s" % (kwargs.keys(), self.param_types.keys()))
close_after_send = not self.return_types or self.return_types == [None] close_after_send = not self.return_types or self.return_types == [None]
soap_kwargs = {n: self.param_types[n](kwargs[n]) for n in self.param_types.keys()} soap_kwargs = {n: self.param_types[n](kwargs[n]) for n in self.param_types.keys()}
try:
response, xml_bytes = await scpd_post( response, xml_bytes = await scpd_post(
self.control_url, self.gateway_address, self.service_port, self.method, self.param_order, self.service_id, self.control_url, self.gateway_address, self.service_port, self.method, self.param_order, self.service_id,
close_after_send, self.soap_socket, **soap_kwargs close_after_send, self.soap_socket, **soap_kwargs
) )
except asyncio.TimeoutError as err:
raise UPnPError(err)
self._requests.append((soap_kwargs, xml_bytes)) self._requests.append((soap_kwargs, xml_bytes))
if not response: if not response:
return None return None