sockets - Python multiprocessing queue generating strange data behavior -
i'm working little project 1 rpi2 distributing data 4 rpi1. done via socket, , every client connects rpi2 gets own process. there 1 process capturing images , 1 waiting new clients(on rpi2). capture process sends four(at most) vectors "client processes" , send (ecery) rpi1:s via socket.
my problem is: when run more 1 client, there seem kind of communication fault, ether in ipc or socket. because data supposed sent rpi1_a ends on rpi1_b.
can have queue going between processes aren't in parent-child relation?
some snippets code:
# create list of queues main_queue = [queue(ipc_queue_size)]*max_number_of_connections #creation of camera process: camera_process = process(target=camera_capture, args=(main_queue,client_update_queue, )) #wait client snippet: conn, addr = s.accept() p.append((process(target=clientthread, args=(conn , main_queue[nr_of_clients] ,client_update_queue, sock_lock, )),addr[0],addr[1])) p[len(p)-1][0].start() nr_of_clients = nr_of_clients + 1
Comments
Post a Comment