(self)
| 231 | self._new_data_buffers.put((tag, timestamp, data)) |
| 232 | |
| 233 | def get_data(self): |
| 234 | try: |
| 235 | data_dict = {} |
| 236 | while len(data_dict.keys()) < len(self._sensors_objects.keys()): |
| 237 | |
| 238 | # Don't wait for the opendrive sensor |
| 239 | if self._opendrive_tag and self._opendrive_tag not in data_dict.keys() \ |
| 240 | and len(self._sensors_objects.keys()) == len(data_dict.keys()) + 1: |
| 241 | # print("Ignoring opendrive sensor") |
| 242 | break |
| 243 | |
| 244 | sensor_data = self._new_data_buffers.get(True, self._queue_timeout) |
| 245 | data_dict[sensor_data[0]] = ((sensor_data[1], sensor_data[2])) |
| 246 | |
| 247 | except Empty: |
| 248 | raise SensorReceivedNoData("A sensor took too long to send their data") |
| 249 | |
| 250 | return data_dict |
no test coverage detected