| @@ -296,7 +296,7 class VoltageReader(JRODataReader, ProcessingUnit): | |||
|
|
296 | 296 | self.nReadBlocks += 1 |
|
|
297 | 297 | self.blockPointer = 0 |
|
|
298 | 298 | |
|
|
299 | block = self.receiver.recv() | |
|
|
299 | topic, block = self.receiver.recv_multipart() | |
|
|
300 | 300 | |
|
|
301 | 301 | self.basicHeaderObj.read(block[self.blockPointer:]) |
|
|
302 | 302 | self.blockPointer += self.basicHeaderObj.length |
| @@ -309,7 +309,7 class VoltageReader(JRODataReader, ProcessingUnit): | |||
|
|
309 | 309 | self.readFirstHeaderFromServer() |
|
|
310 | 310 | |
|
|
311 | 311 | timestamp = self.basicHeaderObj.get_datatime() |
|
|
312 | print('[Receiving] - Block {} - {}'.format(self.nTotalBlocks, timestamp)) | |
|
|
312 | print('[Receiving] - Block {} - {} from {}'.format(self.nTotalBlocks, timestamp, topic.decode())) | |
|
|
313 | 313 | if self.nTotalBlocks == self.processingHeaderObj.dataBlocksPerFile: |
|
|
314 | 314 | self.nTotalBlocks = 0 |
|
|
315 | 315 | self.nReadBlocks = 0 |
General Comments 0
You need to be logged in to leave comments.
Login now