##// END OF EJS Templates
schain-jc
RSS
test for localtime plotting issues
test for localtime plotting issues
George Yong - - Load All Authors

File last commit:

r1167:1f521b07c958
r1218:afa054b492c7
Show More
jroIO_usrp_api.py
138 lines | 3.4 KiB | text/x-python | PythonLexer
/ schainpy / model / io / jroIO_usrp_api.py
History | Source | Raw |Copy content |Copy permalink
Miguel Valdez
Merge with branch schain_julia_drifts from rev. 803 to 995....
 r568 '''
Created on Jul 15, 2014
@author: roj-idl71
'''
import time
import threading
George Yong
Python 2to3, Spectra (all operations) working
 r1167 import pickle
Miguel Valdez
Merge with branch schain_julia_drifts from rev. 803 to 995....
 r568
Miguel Valdez
-jroIO_usrp_api is not include in Schain model anymore...
 r634 # try:
# from gevent import sleep
# except:
from time import sleep
Miguel Valdez
Merge with branch schain_julia_drifts from rev. 803 to 995....
 r568
SERIALIZER = cPickle
# from schainpy.serializer import DynamicSerializer
from schainpy.model.io.jroIO_usrp import USRPReader
Miguel Valdez
serializer module added to Signal Chain
 r697 from schainpy.model.serializer.data import obj2Serial
Miguel Valdez
Merge with branch schain_julia_drifts from rev. 803 to 995....
 r568
class USRPReaderAPI(USRPReader, threading.Thread):
# __isBufferEmpty = True
__DATAKEYLIST = ['data','utctime','flagNoData']
def __init__(self, serializer='msgpack'):
threading.Thread.__init__(self)
USRPReader.__init__(self)
# self.__serializerObj = DynamicSerializer.DynamicSerializer('msgpack')
self.__mySerial = None
self.__isBufferEmpty = True
self.setSerializer(serializer)
def setSerializer(self, serializer):
self.__serializer = serializer
def getSerializer(self):
return self.__serializer
def getProfileIndex(self):
return self.profileIndex
def getSerialMetaData(self):
if self.__isBufferEmpty:
ini = time.time()
while True:
if not self.__isBufferEmpty:
break
if time.time() - ini > 20:
break
sleep(1e-12)
# if not self.getData():
# self.__isBufferEmpty = False
# return None
if self.dataOut.flagNoData:
return None
myMetadataSerial = obj2Serial(self.dataOut,
serializer = self.__serializer)
return myMetadataSerial
def getSerialData(self):
if self.__isBufferEmpty:
ini = time.time()
while True:
if not self.__isBufferEmpty:
break
if time.time() - ini > 20:
break
sleep(1e-12)
# if not self.getData():
# self.__isBufferEmpty = False
# return None
if self.dataOut.flagNoData:
return None
self.__isBufferEmpty = True
return self.__mySerial
def run(self):
'''
Miguel Valdez
A new SendToServer Unit has been created to upload files to a remote server....
 r573 This method will be called once when start() is called
Miguel Valdez
Merge with branch schain_julia_drifts from rev. 803 to 995....
 r568 '''
if not self.isConfig:
George Yong
Python 2to3, Spectra (all operations) working
 r1167 raise RuntimeError('setup() method has to be called before start()')
Miguel Valdez
Bug fixed in zerorpc test module
 r800
George Yong
Python 2to3, Spectra (all operations) working
 r1167 print("Running ...")
Miguel Valdez
Bug fixed in zerorpc test module
 r800
Miguel Valdez
Merge with branch schain_julia_drifts from rev. 803 to 995....
 r568 while True:
if not self.__isBufferEmpty:
sleep(1e-12)
continue
if not self.getData():
break
George Yong
Python 2to3, Spectra (all operations) working
 r1167 print(".", end=' ')
Miguel Valdez
Merge with branch schain_julia_drifts from rev. 803 to 995....
 r568
self.__mySerial = obj2Serial(self.dataOut,
keyList = self.__DATAKEYLIST,
serializer = self.__serializer)
self.__isBufferEmpty = False
# print self.profileIndex
# print 'wait 1 second'
# sleep(0.1)
Miguel Valdez
Bug fixed in zerorpc test module
 r800
George Yong
Python 2to3, Spectra (all operations) working
 r1167 print("Closing thread")
Miguel Valdez
Bug fixed in zerorpc test module
 r800
Miguel Valdez
Merge with branch schain_julia_drifts from rev. 803 to 995....
 r568 return