| @@ -1,4 +1,3 | |||||
| 1 |
|
||||
| 2 |
|
|
1 | ''' | |
| 3 | Created on Jul 3, 2014 |
|
2 | Created on Jul 3, 2014 | |
| 4 |
|
3 | |||
| @@ -57,6 +56,7 class DigitalRFReader(ProcessingUnit): | |||||
| 57 | self.__code = None |
|
56 | self.__code = None | |
| 58 | self.dtype = None |
|
57 | self.dtype = None | |
| 59 | self.oldAverage = None |
|
58 | self.oldAverage = None | |
|
|
59 | self.path = None | |||
| 60 |
|
60 | |||
| 61 | def close(self): |
|
61 | def close(self): | |
| 62 | print 'Average of writing to digital rf format is ', self.oldAverage * 1000 |
|
62 | print 'Average of writing to digital rf format is ', self.oldAverage * 1000 | |
| @@ -245,13 +245,14 class DigitalRFReader(ProcessingUnit): | |||||
| 245 | startDate |
|
245 | startDate | |
| 246 | endDate |
|
246 | endDate | |
| 247 | startTime |
|
247 | startTime | |
| 248 |
endTime |
|
248 | endTime | |
| 249 | set |
|
249 | set | |
| 250 | expLabel |
|
250 | expLabel | |
| 251 | ext |
|
251 | ext | |
| 252 | online |
|
252 | online | |
| 253 | delay |
|
253 | delay | |
| 254 | ''' |
|
254 | ''' | |
|
|
255 | self.path = path | |||
| 255 | self.nCohInt = nCohInt |
|
256 | self.nCohInt = nCohInt | |
| 256 | self.flagDecodeData = flagDecodeData |
|
257 | self.flagDecodeData = flagDecodeData | |
| 257 | self.i = 0 |
|
258 | self.i = 0 | |
| @@ -302,7 +303,9 class DigitalRFReader(ProcessingUnit): | |||||
| 302 |
|
303 | |||
| 303 | self.__frequency = self.fixed_metadata_dict.get('frequency', 1) |
|
304 | self.__frequency = self.fixed_metadata_dict.get('frequency', 1) | |
| 304 |
|
305 | |||
| 305 |
self.__timezone = self.fixed_metadata_dict.get('timezone', |
|
306 | self.__timezone = self.fixed_metadata_dict.get('timezone', 18000) | |
|
|
307 | ||||
|
|
308 | #print self.__timezone,"timezone" | |||
| 306 |
|
309 | |||
| 307 | try: |
|
310 | try: | |
| 308 | nSamples = self.fixed_metadata_dict['nSamples'] |
|
311 | nSamples = self.fixed_metadata_dict['nSamples'] | |
| @@ -438,7 +441,8 class DigitalRFReader(ProcessingUnit): | |||||
| 438 | try: |
|
441 | try: | |
| 439 | self.digitalReadObj.reload(complete_update=True) |
|
442 | self.digitalReadObj.reload(complete_update=True) | |
| 440 | except: |
|
443 | except: | |
| 441 |
self.digitalReadObj. |
|
444 | self.digitalReadObj = digital_rf.DigitalRFReader(self.path) | |
|
|
445 | #self.digitalReadObj.reload() | |||
| 442 |
|
446 | |||
| 443 | start_index, end_index = self.digitalReadObj.get_bounds( |
|
447 | start_index, end_index = self.digitalReadObj.get_bounds( | |
| 444 | self.__channelNameList[self.__channelList[0]]) |
|
448 | self.__channelNameList[self.__channelList[0]]) | |
| @@ -482,6 +486,7 class DigitalRFReader(ProcessingUnit): | |||||
| 482 | if self.__thisUnixSample + 2 * self.__samples_to_read > self.__endUTCSecond * self.__sample_rate: |
|
486 | if self.__thisUnixSample + 2 * self.__samples_to_read > self.__endUTCSecond * self.__sample_rate: | |
| 483 | print "[Reading] There are no more data into selected time-range" |
|
487 | print "[Reading] There are no more data into selected time-range" | |
| 484 | if self.__online: |
|
488 | if self.__online: | |
|
|
489 | sleep(3) | |||
| 485 | self.__reload() |
|
490 | self.__reload() | |
| 486 | else: |
|
491 | else: | |
| 487 | return False |
|
492 | return False | |
General Comments 0
You need to be logged in to leave comments.
Login now