Revision c8eded0b lib/daemon.py
b/lib/daemon.py | ||
---|---|---|
95 | 95 |
def handle_read(self): |
96 | 96 |
try: |
97 | 97 |
try: |
98 |
payload, address = self.recvfrom(4096)
|
|
98 |
payload, address = self.recvfrom(constants.MAX_UDP_DATA_SIZE)
|
|
99 | 99 |
except socket.error, err: |
100 | 100 |
if err.errno == errno.EINTR: |
101 | 101 |
# we got a signal while trying to read. no need to do anything, |
... | ... | |
148 | 148 |
"""Enqueue a datagram to be sent when possible |
149 | 149 |
|
150 | 150 |
""" |
151 |
if len(payload) > constants.MAX_UDP_DATA_SIZE: |
|
152 |
raise errors.UdpDataSizeError('Packet too big: %s > %s' % (len(payload), |
|
153 |
constants.MAX_UDP_DATA_SIZE)) |
|
151 | 154 |
self._out_queue.append((ip, port, payload)) |
152 | 155 |
|
153 | 156 |
|
Also available in: Unified diff