196         addr = ('127.0.0.1', self.port + nodeid)
202                 self.devices[addr]['msgs'] += messages
227         addr = ('127.0.0.1', self.port + nodeid)
229         messages = self.devices[addr]['msgs']
230         self.devices[addr]['msgs'] = []
236     def _is_radio(self, addr):  argument
237         return addr[1] < self.BASE_PORT * 2
239     def _to_core_addr(self, addr):  argument
240         assert self._is_radio(addr)
241         return (addr[0], addr[1] + self.BASE_PORT)
243     def _to_radio_addr(self, addr):  argument
244         assert not self._is_radio(addr)
245         return (addr[0], addr[1] - self.BASE_PORT)
266                     msg, addr = self.sock.recvfrom(self.MAX_MESSAGE)
284                     msg, addr = self.sock.recvfrom(self.MAX_MESSAGE)
288             if addr != self._spinel_cli_addr and addr not in self.devices:
289                 self.devices[addr] = {}
290                 self.devices[addr]['alarm'] = None
291                 self.devices[addr]['msgs'] = []
292                 self.devices[addr]['time'] = self.current_time
293                 self.awake_devices.discard(addr)
305                     addr,
311                 dbg_print("New event: ", event_time, addr, type, datalen)
315                 if self.devices[addr]['alarm']:
316                     self.event_queue.remove(self.devices[addr]['alarm'])
320                 event = (event_time, self.event_sequence, addr, type, datalen)
324                 self.devices[addr]['alarm'] = event
326                 self.awake_devices.discard(addr)
328                 if (self.current_event and self.current_event[self.EVENT_ADDR] == addr):
333                 assert self._is_radio(addr)
344                     if device != addr and self._is_radio(device):
358                 self._add_message(addr[1] - self.port, data)
364                     addr,
373                     self._on_ack_seq_change(addr, frame_info.seq_no)
375                 self.awake_devices.add(addr)
378                 assert not self._is_radio(addr)
379                 radio_addr = self._to_radio_addr(addr)
394                 self.awake_devices.add(addr)
397                 assert self._is_radio(addr)
398                 core_addr = self._to_core_addr(addr)
413                 self.awake_devices.add(addr)
429     def _send_message(self, message, addr):  argument
432                 sent = self.sock.sendto(message, addr)
448             event_time, sequence, addr, type, datalen = event
449             dbg_print("Pop event: ", event_time, addr, type, datalen)
451             event_time, sequence, addr, type, datalen, data = event
455                 addr,
466         elapsed = event_time - self.devices[addr]['time']
467         self.devices[addr]['time'] = event_time
472             self.devices[addr]['alarm'] = None
473             self._send_message(message, addr)
476             self._send_message(message, addr)
479             self._send_message(message, addr)
482             self._send_message(message, addr)
486         for addr in self.devices:
487             elapsed = self.current_time - self.devices[addr]['time']
490             dbg_print('syncing', addr, elapsed)
491             self.devices[addr]['time'] = self.current_time
493             self._send_message(message, addr)
494             self.awake_devices.add(addr)