Lines 101-111
def processor(options, data_queue):
|
Link Here
|
---|
|
101 |
process(data) |
101 |
process(data) |
102 |
|
102 |
|
103 |
def listener(options, data_queue): |
103 |
def listener(options, data_queue): |
104 |
local_host_address = socket.gethostbyname(socket.gethostname()) |
|
|
105 |
size = 1024 # max hostname length |
104 |
size = 1024 # max hostname length |
106 |
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM) |
105 |
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM) |
107 |
s.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) |
106 |
s.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) |
108 |
s.bind((local_host_address, options.port, )) |
107 |
s.bind(("", options.port, )) |
109 |
s.listen(1) |
108 |
s.listen(1) |
110 |
while True: |
109 |
while True: |
111 |
(client, _, ) = s.accept() |
110 |
(client, _, ) = s.accept() |