kopia lustrzana https://github.com/micropython/micropython-lib
umqtt.simple: Do DNS lookup in connect() method.
rodzic
f9f2264d99
commit
a09b3ec20a
|
@ -13,7 +13,8 @@ class MQTTClient:
|
||||||
port = 8883 if ssl else 1883
|
port = 8883 if ssl else 1883
|
||||||
self.client_id = client_id
|
self.client_id = client_id
|
||||||
self.sock = None
|
self.sock = None
|
||||||
self.addr = socket.getaddrinfo(server, port)[0][-1]
|
self.server = server
|
||||||
|
self.port = port
|
||||||
self.ssl = ssl
|
self.ssl = ssl
|
||||||
self.ssl_params = ssl_params
|
self.ssl_params = ssl_params
|
||||||
self.pid = 0
|
self.pid = 0
|
||||||
|
@ -53,7 +54,8 @@ class MQTTClient:
|
||||||
|
|
||||||
def connect(self, clean_session=True):
|
def connect(self, clean_session=True):
|
||||||
self.sock = socket.socket()
|
self.sock = socket.socket()
|
||||||
self.sock.connect(self.addr)
|
addr = socket.getaddrinfo(self.server, self.port)[0][-1]
|
||||||
|
self.sock.connect(addr)
|
||||||
if self.ssl:
|
if self.ssl:
|
||||||
import ussl
|
import ussl
|
||||||
self.sock = ussl.wrap_socket(self.sock, **self.ssl_params)
|
self.sock = ussl.wrap_socket(self.sock, **self.ssl_params)
|
||||||
|
|
Ładowanie…
Reference in New Issue