| 49 | self._wires = [] |
| 50 | |
| 51 | def connection(self): |
| 52 | c1 = Connection() |
| 53 | c2 = Connection() |
| 54 | t1 = Transport() |
| 55 | t1.bind(c1) |
| 56 | t2 = Transport() |
| 57 | t2.bind(c2) |
| 58 | self._wires.append((c1, t1, c2, t2)) |
| 59 | |
| 60 | mask1 = 0 |
| 61 | mask2 = 0 |
| 62 | |
| 63 | for cat in ("TRACE_FRM", "TRACE_RAW"): |
| 64 | trc = os.environ.get("PN_%s" % cat) |
| 65 | if trc and trc.lower() in ("1", "2", "yes", "true"): |
| 66 | mask1 = mask1 | getattr(Transport, cat) |
| 67 | if trc == "2": |
| 68 | mask2 = mask2 | getattr(Transport, cat) |
| 69 | t1.trace(mask1) |
| 70 | t2.trace(mask2) |
| 71 | |
| 72 | return c1, c2 |
| 73 | |
| 74 | def link(self, name, max_frame=None, idle_timeout=None): |
| 75 | c1, c2 = self.connection() |