Revision a3758ab2 daemons/ganeti-confd
b/daemons/ganeti-confd | ||
---|---|---|
69 | 69 |
|
70 | 70 |
# this method is overriding a daemon.AsyncUDPSocket method |
71 | 71 |
def handle_datagram(self, payload_in, ip, port): |
72 |
payload_out = self.processor.ExecQuery(payload_in, ip, port) |
|
73 |
if payload_out is not None: |
|
72 |
|
|
73 |
if len(payload_in) < len(constants.CONFD_MAGIC_FOURCC): |
|
74 |
logging.debug("Received a query which is too short to be true") |
|
75 |
return |
|
76 |
|
|
77 |
magic_number = payload_in[:4] |
|
78 |
query = payload_in[4:] |
|
79 |
|
|
80 |
if magic_number != constants.CONFD_MAGIC_FOURCC: |
|
81 |
logging.debug("Received a query with an unknown magic number") |
|
82 |
return |
|
83 |
|
|
84 |
answer = self.processor.ExecQuery(query, ip, port) |
|
85 |
if answer is not None: |
|
86 |
payload_out = ''.join([constants.CONFD_MAGIC_FOURCC, answer]) |
|
74 | 87 |
self.enqueue_send(ip, port, payload_out) |
75 | 88 |
|
76 | 89 |
|
Also available in: Unified diff