@@ -124,7 +124,7 class PlotManager(): | |||||
124 | subtitle = "%s:\n" %(name) |
|
124 | subtitle = "%s:\n" %(name) | |
125 | subtitle += "Hostname: %s\n" %socket.gethostbyname(socket.gethostname()) |
|
125 | subtitle += "Hostname: %s\n" %socket.gethostbyname(socket.gethostname()) | |
126 | subtitle += "Working directory: %s\n" %os.path.abspath("./") |
|
126 | subtitle += "Working directory: %s\n" %os.path.abspath("./") | |
127 | # subtitle += "Configuration file: %s\n" %self.filename |
|
127 | # subtitle += "Configuration file: %s\n" %self.filename | |
128 | subtitle += "Time: %s\n" %str(datetime.datetime.now()) |
|
128 | subtitle += "Time: %s\n" %str(datetime.datetime.now()) | |
129 |
|
129 | |||
130 | adminObj = schainpy.admin.SchainNotify() |
|
130 | adminObj = schainpy.admin.SchainNotify() |
@@ -618,7 +618,7 class JRODataReader(JRODataIO): | |||||
618 | dateList, pathList = self.findDatafiles(path, startDate, endDate, expLabel, ext, walk, include_path=True) |
|
618 | dateList, pathList = self.findDatafiles(path, startDate, endDate, expLabel, ext, walk, include_path=True) | |
619 |
|
619 | |||
620 | if dateList == []: |
|
620 | if dateList == []: | |
621 | # print "[Reading] Date range selected invalid [%s - %s]: No *%s files in %s)" %(startDate, endDate, ext, path) |
|
621 | # print "[Reading] Date range selected invalid [%s - %s]: No *%s files in %s)" %(startDate, endDate, ext, path) | |
622 | return None, None |
|
622 | return None, None | |
623 |
|
623 | |||
624 | if len(dateList) > 1: |
|
624 | if len(dateList) > 1: | |
@@ -630,7 +630,7 class JRODataReader(JRODataIO): | |||||
630 | datetimeList = [] |
|
630 | datetimeList = [] | |
631 |
|
631 | |||
632 | for thisPath in pathList: |
|
632 | for thisPath in pathList: | |
633 | # thisPath = pathList[pathDict[file]] |
|
633 | # thisPath = pathList[pathDict[file]] | |
634 |
|
634 | |||
635 | fileList = glob.glob1(thisPath, "*%s" %ext) |
|
635 | fileList = glob.glob1(thisPath, "*%s" %ext) | |
636 | fileList.sort() |
|
636 | fileList.sort() | |
@@ -746,7 +746,7 class JRODataReader(JRODataIO): | |||||
746 | idFile += 1 |
|
746 | idFile += 1 | |
747 | if not(idFile < len(self.filenameList)): |
|
747 | if not(idFile < len(self.filenameList)): | |
748 | self.flagNoMoreFiles = 1 |
|
748 | self.flagNoMoreFiles = 1 | |
749 | # print "[Reading] No more Files" |
|
749 | # print "[Reading] No more Files" | |
750 | return 0 |
|
750 | return 0 | |
751 |
|
751 | |||
752 | filename = self.filenameList[idFile] |
|
752 | filename = self.filenameList[idFile] | |
@@ -764,7 +764,7 class JRODataReader(JRODataIO): | |||||
764 | self.fileSize = fileSize |
|
764 | self.fileSize = fileSize | |
765 | self.fp = fp |
|
765 | self.fp = fp | |
766 |
|
766 | |||
767 | # print "[Reading] Setting the file: %s"%self.filename |
|
767 | # print "[Reading] Setting the file: %s"%self.filename | |
768 |
|
768 | |||
769 | return 1 |
|
769 | return 1 | |
770 |
|
770 | |||
@@ -847,14 +847,14 class JRODataReader(JRODataIO): | |||||
847 | if self.fp != None: self.fp.close() |
|
847 | if self.fp != None: self.fp.close() | |
848 | self.fp = open(fullfilename, 'rb') |
|
848 | self.fp = open(fullfilename, 'rb') | |
849 | self.flagNoMoreFiles = 0 |
|
849 | self.flagNoMoreFiles = 0 | |
850 | # print '[Reading] Setting the file: %s' % fullfilename |
|
850 | # print '[Reading] Setting the file: %s' % fullfilename | |
851 | else: |
|
851 | else: | |
852 | self.fileSize = 0 |
|
852 | self.fileSize = 0 | |
853 | self.filename = None |
|
853 | self.filename = None | |
854 | self.flagIsNewFile = 0 |
|
854 | self.flagIsNewFile = 0 | |
855 | self.fp = None |
|
855 | self.fp = None | |
856 | self.flagNoMoreFiles = 1 |
|
856 | self.flagNoMoreFiles = 1 | |
857 | # print '[Reading] No more files to read' |
|
857 | # print '[Reading] No more files to read' | |
858 |
|
858 | |||
859 | return fileOk_flag |
|
859 | return fileOk_flag | |
860 |
|
860 | |||
@@ -907,7 +907,7 class JRODataReader(JRODataIO): | |||||
907 | return 1 |
|
907 | return 1 | |
908 |
|
908 | |||
909 | if self.fileSize == self.fileSizeByHeader: |
|
909 | if self.fileSize == self.fileSizeByHeader: | |
910 | # self.flagEoF = True |
|
910 | # self.flagEoF = True | |
911 | return 0 |
|
911 | return 0 | |
912 |
|
912 | |||
913 | print "[Reading] Waiting %0.2f seconds for the next block, try %03d ..." % (self.delay, nTries+1) |
|
913 | print "[Reading] Waiting %0.2f seconds for the next block, try %03d ..." % (self.delay, nTries+1) | |
@@ -962,11 +962,11 class JRODataReader(JRODataIO): | |||||
962 | self.fp.seek(self.fp.tell() - neededsize) |
|
962 | self.fp.seek(self.fp.tell() - neededsize) | |
963 | break |
|
963 | break | |
964 |
|
964 | |||
965 | # csize = self.fileSize - self.fp.tell() |
|
965 | # csize = self.fileSize - self.fp.tell() | |
966 | # neededsize = self.processingHeaderObj.blockSize + self.basicHeaderSize |
|
966 | # neededsize = self.processingHeaderObj.blockSize + self.basicHeaderSize | |
967 | # factor = int(csize/neededsize) |
|
967 | # factor = int(csize/neededsize) | |
968 | # if factor > 0: |
|
968 | # if factor > 0: | |
969 | # self.fp.seek(self.fp.tell() + factor*neededsize) |
|
969 | # self.fp.seek(self.fp.tell() + factor*neededsize) | |
970 |
|
970 | |||
971 | self.flagIsNewFile = 0 |
|
971 | self.flagIsNewFile = 0 | |
972 | self.__isFirstTimeOnline = 0 |
|
972 | self.__isFirstTimeOnline = 0 | |
@@ -976,8 +976,8 class JRODataReader(JRODataIO): | |||||
976 | if self.fp == None: |
|
976 | if self.fp == None: | |
977 | return 0 |
|
977 | return 0 | |
978 |
|
978 | |||
979 | # if self.online: |
|
979 | # if self.online: | |
980 | # self.__jumpToLastBlock() |
|
980 | # self.__jumpToLastBlock() | |
981 |
|
981 | |||
982 | if self.flagIsNewFile: |
|
982 | if self.flagIsNewFile: | |
983 | self.lastUTTime = self.basicHeaderObj.utc |
|
983 | self.lastUTTime = self.basicHeaderObj.utc | |
@@ -1069,8 +1069,8 class JRODataReader(JRODataIO): | |||||
1069 | self.dtype = datatype_str |
|
1069 | self.dtype = datatype_str | |
1070 | #self.ippSeconds = 2 * 1000 * self.radarControllerHeaderObj.ipp / self.c |
|
1070 | #self.ippSeconds = 2 * 1000 * self.radarControllerHeaderObj.ipp / self.c | |
1071 | self.fileSizeByHeader = self.processingHeaderObj.dataBlocksPerFile * self.processingHeaderObj.blockSize + self.firstHeaderSize + self.basicHeaderSize*(self.processingHeaderObj.dataBlocksPerFile - 1) |
|
1071 | self.fileSizeByHeader = self.processingHeaderObj.dataBlocksPerFile * self.processingHeaderObj.blockSize + self.firstHeaderSize + self.basicHeaderSize*(self.processingHeaderObj.dataBlocksPerFile - 1) | |
1072 | # self.dataOut.channelList = numpy.arange(self.systemHeaderObj.numChannels) |
|
1072 | # self.dataOut.channelList = numpy.arange(self.systemHeaderObj.numChannels) | |
1073 | # self.dataOut.channelIndexList = numpy.arange(self.systemHeaderObj.numChannels) |
|
1073 | # self.dataOut.channelIndexList = numpy.arange(self.systemHeaderObj.numChannels) | |
1074 | self.getBlockDimension() |
|
1074 | self.getBlockDimension() | |
1075 |
|
1075 | |||
1076 | def __verifyFile(self, filename, msgFlag=True): |
|
1076 | def __verifyFile(self, filename, msgFlag=True): | |
@@ -1331,7 +1331,7 class JRODataReader(JRODataIO): | |||||
1331 | self.filenameList = [] |
|
1331 | self.filenameList = [] | |
1332 | return |
|
1332 | return | |
1333 |
|
1333 | |||
1334 | # self.getBasicHeader() |
|
1334 | # self.getBasicHeader() | |
1335 |
|
1335 | |||
1336 | if last_set != None: |
|
1336 | if last_set != None: | |
1337 | self.dataOut.last_block = last_set * self.processingHeaderObj.dataBlocksPerFile + self.basicHeaderObj.dataBlock |
|
1337 | self.dataOut.last_block = last_set * self.processingHeaderObj.dataBlocksPerFile + self.basicHeaderObj.dataBlock |
General Comments 0
You need to be logged in to leave comments.
Login now