sharedmemory.py 文件源码

def _writeRecord(self, record):
        if not self.isInitialized():
            return

        vals = []

        for colname in self.labels:
            val = record.data.get(colname)
            if (not val is None) and (operator.isNumberType(val) and (type(val) in [int, float, long])):
                vals.append(val)
            elif (not val is None) and (operator.isNumberType(val)):
                valsmca = []
                for i in range(0, len(val)):
                    valsmca.append(val[i])
                sufix = "1D"
                if self.array.endswith(sufix):
                    valsmca = numpy.array(valsmca)
                    self.sps.putdatarow(
                        self.program, self.array, record.recordno, valsmca)

        sufix = "0D"
        if self.array.endswith(sufix):
            vals = numpy.array(vals)
            self.sps.putdatarow(self.program, self.array,
                                record.recordno, vals)

        self.nopts += 1

        env = {'nopts': self.nopts,
               'peak': 111,
               'peakpos': 34,
               'fwhm': 12.3,
               'fwhmpos': 45,
               'com': 23}

        self.putAllEnv(env)