Estou com problemas de continuidade no meu código depois de uma chamada de função, relacionada ao recebimento de dados via socket com o seguinte código:
def le_dados(obj):
lista_rcv = []
while True:
data = obj.recv(2)
if data:
lista_rcv.append(data)
if len(lista_rcv) == 4:
lista_rcv.append(obj.getpeername())
global status_central
status_central = lista_rcv
lista_rcv = []
sleep(0.25)
Essa função é chamada dentro de outra função assim:
process = multiprocessing.Process(target=le_dados(s))
process.daemon = True
process.start()
O que não estou conseguindo visualizar, talvez por falta de experiência é porque o código para na linha:
data = obj.recv(2)
Não deixando o o código seguir a diante na chamada do process
,
fica parado aqui:
process = multiprocessing.Process(target=le_dados(s))
não deixando assim eu estartar minha Gui que vem depois disso.
Só complementando, segue o restante do código, ele é usado para se conectar a dispositivos onde enviarei e receberei comandos, com um só deu certo, mas quando tento com vários não estou conseguindo.
import socket
import os
import Gcomn
from time import sleep
import multiprocessing
PORT = 7557
status_central = []
on_off_disp = []
def conecta_dispositivos():
sql = 'select nome_disp, Ip_disp from dispositivos'
dados_dis = Gcomn.le_dados(sql)
global on_off_disp
on_off_disp = []
for i in range (len(dados_dis)):
try:
s = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
#s.settimeout(5)
s.connect((dados_dis[i][1] ,7557))
if s:
print("Conectado a: ", s.getpeername())
sleep (1.5)
sendData()
on_off_disp.append(1)
print('vou chamar o process')
process = multiprocessing.Process(target=recebe_dados(s))
process.daemon = True
process.start()
print('depois do process')
except socket.error:
print ('Erro ao conectar em: ', dados_dis[i][0])
on_off_disp.append(0)
def recebe_dados(obj):
lista_rcv = []
obj.setblocking(False)
while True:
data = obj.recv(2)
if data:
lista_rcv.append(data)
if len(lista_rcv) == 4:
lista_rcv.append(obj.getpeername())
global status_central
status_central = lista_rcv
lista_rcv = []
else:
print('não recebi nada')
sleep(0.25)
def sendData(comando = 'A00000'):
s.send(comando.encode('utf-8'))
conecta_dispositivos()
recv
está bloqueando a execução até que receba algum dado através do socket. Você pode setar a conexão para não bloquear o programa assim que criar o socketobj
comobj.setblocking(False)
, porém, precisará tratar o caso onde você chamou orecv
e não recebeu nenhum dado – Gomiero 24/10/16 às 14:43socket
para não bloquear, precisará mudar também o seu algoritmo. Com o código que está na pergunta ("travando"), você tentou conectar nosocket
a partir de outro programa (ex: telnet) e enviar algum dado? Ele não desbloqueou? – Gomiero 24/10/16 às 17:20