|
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() |