| 118 | | |
| 119 | | #------------------------------------------------------------------ |
| 120 | | # dataOut_complexShort_i class definition |
| 121 | | #------------------------------------------------------------------ |
| 122 | | class dataOut_timingStatus_i(CF__POA.Port): |
| 123 | | def __init__(self, parent, name): |
| 124 | | self.parent = parent |
| 125 | | self.outPorts = {} |
| 126 | | self.name = name |
| 127 | | |
| 128 | | self.data_buffer = [] |
| 129 | | self.data_event = threading.Event() |
| 130 | | self.data_buffer_lock = threading.Lock() |
| 131 | | |
| 132 | | self.is_running = True |
| 133 | | self.process_thread = threading.Thread(target = self.Process) |
| 134 | | self.process_thread.start() |
| 135 | | |
| 136 | | def connectPort(self, connection, connectionId): |
| 137 | | port = connection._narrow(customInterfaces__POA.timingStatus) |
| 138 | | self.outPorts[str(connectionId)] = port |
| 139 | | self.parent.outPort0_active = True |
| 140 | | |
| 141 | | def disconnectPort(self, connectionId): |
| 142 | | self.outPorts.pop(str(connectionId)) |
| 143 | | if len(self.outPorts)==0: |
| 144 | | self.parent.outPort0_active = False |
| 145 | | |
| 146 | | def releasePort(self): |
| 147 | | # shut down the Process thread |
| 148 | | self.is_running = False |
| 149 | | self.data_event.set() |
| 150 | | |
| 151 | | def send_data(self, I, Q): |
| 152 | | self.data_buffer_lock.acquire() |
| 153 | | self.data_buffer.insert(0, (I,Q)) |
| 154 | | self.data_buffer_lock.release() |
| 155 | | self.data_event.set() |
| 156 | | |
| 157 | | def Process(self): |
| 158 | | while self.is_running: |
| 159 | | self.data_event.wait() |
| 160 | | while len(self.data_buffer) > 0: |
| 161 | | self.data_buffer_lock.acquire() |
| 162 | | new_data = self.data_buffer.pop() |
| 163 | | self.data_buffer_lock.release() |
| 164 | | |
| 165 | | for port in self.outPorts.values(): |
| 166 | | port.pushPacket(new_data[0], new_data[1]) |
| 167 | | |
| 168 | | self.data_event.clear() |
