schain Files · schainpy/model/io/jroIO_usrp_api.py

Remove numpy.complex

jespinoza - - Load All Authors

File last commit:

r1396:f39ad5b721a3


                r1595:fed0fad1169f

Download file

             jroIO_usrp_api.py
        
                    139 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

        jespinoza
    
Merge EW-Drifts

              r1396
            
          __DATAKEYLIST = ['data', 'utctime', 'flagNoData']

        Miguel Valdez
    
Merge with branch schain_julia_drifts from rev. 803 to 995....

              r568
            
          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,

        jespinoza
    
Merge EW-Drifts

              r1396
            
                                            serializer=self.__serializer)

        Miguel Valdez
    
Merge with branch schain_julia_drifts from rev. 803 to 995....

              r568
            
              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,

        jespinoza
    
Merge EW-Drifts

              r1396
            
                                               keyList=self.__DATAKEYLIST,

                                               serializer=self.__serializer)

        Miguel Valdez
    
Merge with branch schain_julia_drifts from rev. 803 to 995....

              r568
            
                  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
            
        jespinoza
    
Merge EW-Drifts

              r1396
            
              return

	Site-wide shortcuts
/	Use quick search box
g h	Goto home page
g g	Goto my private gists page
g G	Goto my public gists page
g 0-9	Goto bookmarked items from 0-9
n r	New repository page
n g	New gist page

	Repositories
g s	Goto summary page
g c	Goto changelog page
g f	Goto files page
g F	Goto files page with file search activated
g p	Goto pull requests page
g o	Goto repository settings
g O	Goto repository access permissions settings
t s	Toggle sidebar on some pages

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

jespinoza Merge EW-Drifts	r1396	__DATAKEYLIST = ['data', 'utctime', 'flagNoData']
Miguel Valdez Merge with branch schain_julia_drifts from rev. 803 to 995....	r568
		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,
jespinoza Merge EW-Drifts	r1396	serializer=self.__serializer)
Miguel Valdez Merge with branch schain_julia_drifts from rev. 803 to 995....	r568
		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,
jespinoza Merge EW-Drifts	r1396	keyList=self.__DATAKEYLIST,
		serializer=self.__serializer)
Miguel Valdez Merge with branch schain_julia_drifts from rev. 803 to 995....	r568	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
jespinoza Merge EW-Drifts	r1396	return