| 303 | self.master.close() |
| 304 | |
| 305 | def pipe(self, target): |
| 306 | target.target_system = self.target_system |
| 307 | |
| 308 | # vehicle -> self -> target |
| 309 | @self.forward_message |
| 310 | def callback(_, msg): |
| 311 | try: |
| 312 | target.out_queue.put(msg.pack(target.master.mav)) |
| 313 | except: |
| 314 | try: |
| 315 | assert len(msg.get_msgbuf()) > 0 |
| 316 | target.out_queue.put(msg.get_msgbuf()) |
| 317 | except: |
| 318 | errprinter('>>> Could not pack this object on receive: %s' % type(msg)) |
| 319 | |
| 320 | # target -> self -> vehicle |
| 321 | @target.forward_message |
| 322 | def callback(_, msg): |
| 323 | msg = copy.copy(msg) |
| 324 | target.fix_targets(msg) |
| 325 | try: |
| 326 | self.out_queue.put(msg.pack(self.master.mav)) |
| 327 | except: |
| 328 | try: |
| 329 | assert len(msg.get_msgbuf()) > 0 |
| 330 | self.out_queue.put(msg.get_msgbuf()) |
| 331 | except: |
| 332 | errprinter('>>> Could not pack this object on forward: %s' % type(msg)) |
| 333 | |
| 334 | return target |