| @@ -56,6 +56,7 class DigitalRFReader(ProcessingUnit): | |||||
| 56 | self.__nBaud = None |
|
56 | self.__nBaud = None | |
| 57 | self.__code = None |
|
57 | self.__code = None | |
| 58 | self.dtype = None |
|
58 | self.dtype = None | |
|
|
59 | self.oldAverage = None | |||
| 59 |
|
60 | |||
| 60 | def close(self): |
|
61 | def close(self): | |
| 61 | 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 | |
| @@ -643,6 +644,7 class DigitalRFWriter(Operation): | |||||
| 643 | self.metadata_dict = {} |
|
644 | self.metadata_dict = {} | |
| 644 | self.dataOut = None |
|
645 | self.dataOut = None | |
| 645 | self.dtype = None |
|
646 | self.dtype = None | |
|
|
647 | self.oldAverage = 0 | |||
| 646 |
|
648 | |||
| 647 | def setHeader(self): |
|
649 | def setHeader(self): | |
| 648 |
|
650 | |||
| @@ -681,9 +683,7 class DigitalRFWriter(Operation): | |||||
| 681 | self.arr_data = arr_data = numpy.ones((self.__nSamples, len( |
|
683 | self.arr_data = arr_data = numpy.ones((self.__nSamples, len( | |
| 682 | self.dataOut.channelList)), dtype=[('r', self.__dtype), ('i', self.__dtype)]) |
|
684 | self.dataOut.channelList)), dtype=[('r', self.__dtype), ('i', self.__dtype)]) | |
| 683 |
|
685 | |||
| 684 |
file_cadence_millisecs = |
|
686 | file_cadence_millisecs = 1000 | |
| 685 | 1.0 * self.__blocks_per_file * self.__nProfiles * self.__nSamples / self.__sample_rate) * 1000 |
|
|||
| 686 | sub_cadence_secs = file_cadence_millisecs / 500 |
|
|||
| 687 |
|
687 | |||
| 688 | sample_rate_fraction = Fraction(self.__sample_rate).limit_denominator() |
|
688 | sample_rate_fraction = Fraction(self.__sample_rate).limit_denominator() | |
| 689 | sample_rate_numerator = long(sample_rate_fraction.numerator) |
|
689 | sample_rate_numerator = long(sample_rate_fraction.numerator) | |
| @@ -691,7 +691,7 class DigitalRFWriter(Operation): | |||||
| 691 | start_global_index = dataOut.utctime * self.__sample_rate |
|
691 | start_global_index = dataOut.utctime * self.__sample_rate | |
| 692 |
|
692 | |||
| 693 | uuid = 'prueba' |
|
693 | uuid = 'prueba' | |
| 694 |
compression_level = |
|
694 | compression_level = 0 | |
| 695 | checksum = False |
|
695 | checksum = False | |
| 696 | is_complex = True |
|
696 | is_complex = True | |
| 697 | num_subchannels = len(dataOut.channelList) |
|
697 | num_subchannels = len(dataOut.channelList) | |
| @@ -751,7 +751,7 class DigitalRFWriter(Operation): | |||||
| 751 |
|
751 | |||
| 752 | return |
|
752 | return | |
| 753 |
|
753 | |||
| 754 |
def run(self, dataOut, frequency=49.92e6, path=None, fileCadence=100, dirCadence= |
|
754 | def run(self, dataOut, frequency=49.92e6, path=None, fileCadence=1000, dirCadence=36000, metadataCadence=1, **kwargs): | |
| 755 | ''' |
|
755 | ''' | |
| 756 | This method will be called many times so here you should put all your code |
|
756 | This method will be called many times so here you should put all your code | |
| 757 | Inputs: |
|
757 | Inputs: | |
| @@ -779,6 +779,7 class DigitalRFWriter(Operation): | |||||
| 779 | except: |
|
779 | except: | |
| 780 | pass |
|
780 | pass | |
| 781 |
|
781 | |||
|
|
782 | ||||
| 782 | # raise |
|
783 | # raise | |
| 783 | if __name__ == '__main__': |
|
784 | if __name__ == '__main__': | |
| 784 |
|
785 | |||
| @@ -259,6 +259,8 class VoltageReader(JRODataReader, ProcessingUnit): | |||||
| 259 |
|
259 | |||
| 260 | self.getBasicHeader() |
|
260 | self.getBasicHeader() | |
| 261 |
|
261 | |||
|
|
262 | self.dataOut.processingHeaderObj = self.processingHeaderObj.copy() | |||
|
|
263 | ||||
| 262 | self.dataOut.systemHeaderObj = self.systemHeaderObj.copy() |
|
264 | self.dataOut.systemHeaderObj = self.systemHeaderObj.copy() | |
| 263 |
|
265 | |||
| 264 | self.dataOut.radarControllerHeaderObj = self.radarControllerHeaderObj.copy() |
|
266 | self.dataOut.radarControllerHeaderObj = self.radarControllerHeaderObj.copy() | |
General Comments 0
You need to be logged in to leave comments.
Login now