@@ -102,6 +102,85 class VoltageReader(JRODataReader): | |||||
102 |
|
102 | |||
103 | self.m_DataObj = m_Voltage |
|
103 | self.m_DataObj = m_Voltage | |
104 |
|
104 | |||
|
105 | self.idProfile = 0 | |||
|
106 | ||||
|
107 | self.datablock = None | |||
|
108 | ||||
|
109 | self.pts2read = 0 | |||
|
110 | ||||
|
111 | self.utc = 0 | |||
|
112 | ||||
|
113 | self.ext = ".r" | |||
|
114 | ||||
|
115 | self.optchar = "D" | |||
|
116 | ||||
|
117 | self.m_BasicHeader = BasicHeader() | |||
|
118 | ||||
|
119 | self.m_SystemHeader = SystemHeader() | |||
|
120 | ||||
|
121 | self.m_RadarControllerHeader = RadarControllerHeader() | |||
|
122 | ||||
|
123 | self.m_ProcessingHeader = ProcessingHeader() | |||
|
124 | ||||
|
125 | self.online = 0 | |||
|
126 | ||||
|
127 | self.fp = None | |||
|
128 | ||||
|
129 | self.idFile = None | |||
|
130 | ||||
|
131 | self.startDateTime = None | |||
|
132 | ||||
|
133 | self.endDateTime = None | |||
|
134 | ||||
|
135 | self.dataType = None | |||
|
136 | ||||
|
137 | self.fileSizeByHeader = None | |||
|
138 | ||||
|
139 | self.filenameList = [] | |||
|
140 | ||||
|
141 | self.filename = None | |||
|
142 | ||||
|
143 | self.fileSize = None | |||
|
144 | ||||
|
145 | self.firstHeaderSize = 0 | |||
|
146 | ||||
|
147 | self.basicHeaderSize = 24 | |||
|
148 | ||||
|
149 | self.pathList = [] | |||
|
150 | ||||
|
151 | self.filenameList = [] | |||
|
152 | ||||
|
153 | self.lastUTTime = 0 | |||
|
154 | ||||
|
155 | self.maxTimeStep = 30 | |||
|
156 | ||||
|
157 | self.flagNoMoreFiles = 0 | |||
|
158 | ||||
|
159 | self.set = 0 | |||
|
160 | ||||
|
161 | self.path = None | |||
|
162 | ||||
|
163 | self.datablockIndex = 9999 | |||
|
164 | ||||
|
165 | self.delay = 3 #seconds | |||
|
166 | ||||
|
167 | self.nTries = 3 #quantity tries | |||
|
168 | ||||
|
169 | self.nFiles = 3 #number of files for searching | |||
|
170 | ||||
|
171 | self.nBlocks = 0 | |||
|
172 | ||||
|
173 | self.flagIsNewFile = 1 | |||
|
174 | ||||
|
175 | self.ippSeconds = 0 | |||
|
176 | ||||
|
177 | self.flagResetProcessing = 0 | |||
|
178 | ||||
|
179 | self.flagIsNewBlock = 0 | |||
|
180 | ||||
|
181 | self.nReadBlocks = 0 | |||
|
182 | ||||
|
183 | self.blocksize = 0 | |||
105 |
|
184 | |||
106 | def __hasNotDataInBuffer(self): |
|
185 | def __hasNotDataInBuffer(self): | |
107 | if self.datablockIndex >= self.m_ProcessingHeader.profilesPerBlock: |
|
186 | if self.datablockIndex >= self.m_ProcessingHeader.profilesPerBlock: | |
@@ -230,7 +309,7 class VoltageReader(JRODataReader): | |||||
230 | self.m_DataObj.m_ProcessingHeader = self.m_ProcessingHeader.copy() |
|
309 | self.m_DataObj.m_ProcessingHeader = self.m_ProcessingHeader.copy() | |
231 | self.m_DataObj.m_RadarControllerHeader = self.m_RadarControllerHeader.copy() |
|
310 | self.m_DataObj.m_RadarControllerHeader = self.m_RadarControllerHeader.copy() | |
232 | self.m_DataObj.m_SystemHeader = self.m_SystemHeader.copy() |
|
311 | self.m_DataObj.m_SystemHeader = self.m_SystemHeader.copy() | |
233 | self.m_DataObj.heights = self.heights |
|
312 | self.m_DataObj.heightList = self.heightList | |
234 | self.m_DataObj.dataType = self.dataType |
|
313 | self.m_DataObj.dataType = self.dataType | |
235 |
|
314 | |||
236 | if self.flagNoMoreFiles == 1: |
|
315 | if self.flagNoMoreFiles == 1: | |
@@ -293,7 +372,7 class VoltageWriter( JRODataWriter ): | |||||
293 | m_Voltage = Voltage() |
|
372 | m_Voltage = Voltage() | |
294 |
|
373 | |||
295 | if not( isinstance(m_Voltage, Voltage) ): |
|
374 | if not( isinstance(m_Voltage, Voltage) ): | |
296 |
raise ValueError, "in VoltageReader, m_ |
|
375 | raise ValueError, "in VoltageReader, m_Voltage must be an Spectra class object" | |
297 |
|
376 | |||
298 | self.m_DataObj = m_Voltage |
|
377 | self.m_DataObj = m_Voltage | |
299 |
|
378 | |||
@@ -319,10 +398,10 class VoltageWriter( JRODataWriter ): | |||||
319 | self.m_ProcessingHeader.numHeights, |
|
398 | self.m_ProcessingHeader.numHeights, | |
320 | self.m_SystemHeader.numChannels ) |
|
399 | self.m_SystemHeader.numChannels ) | |
321 |
|
400 | |||
322 | self.datablock = numpy.zeros(self.m_SystemHeader.numChannels, |
|
401 | self.datablock = numpy.zeros((self.m_SystemHeader.numChannels, | |
323 | self.m_ProcessingHeader.profilesPerBlock, |
|
402 | self.m_ProcessingHeader.profilesPerBlock, | |
324 | self.m_ProcessingHeader.numHeights, |
|
403 | self.m_ProcessingHeader.numHeights), | |
325 | numpy.dtype('complex')) |
|
404 | dtype=numpy.dtype('complex')) | |
326 |
|
405 | |||
327 |
|
406 | |||
328 | def writeBlock(self): |
|
407 | def writeBlock(self): |
General Comments 0
You need to be logged in to leave comments.
Login now