schain Files · schainpy/model/serializer/test/DynamicSerializer.py

Rewrite controller, remove MPDecorator to units (keep for plots an writers) use of queues for interproc comm instead of zmq, self operations are no longer supported

George Yong - - Load All Authors

File last commit:

r1167:1f521b07c958


                r1287:af11e4aac00c

Download file

             DynamicSerializer.py
        
                    68 lines
            
             | 2.0 KiB
            
                | text/x-python
            
             |
                PythonLexer
            
             / schainpy / model / serializer / test / DynamicSerializer.py
          
                    History
                
                 |
                  Source
                 | Raw
                 |Copy content
                 |Copy permalink

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

              r568
            
      #

      # rps 6/9/2014

      # mit haystack obs

      #

      # wrapper for Karl's code

      import DynamicObject     # used for serial/deserial of complex python objects

      import Serializer        # used for serial/deserial of complex python

      #

      class DynamicSerializer:

          #

          #------------------------------------------------------

          #

          def __init__(self,which='yaml'):

              #

              # choices are: yaml, msgpack, hdf5, json

              #

              self.err_f = False

              self.whichList = ['yaml', 'msgpack', 'hdf5', 'json'] # from Serialzer.py

              self.err_f,self.serializer = self.initSerializer(which)

          #

          #------------------------------------------------------

          #

          def initSerializer(self,which):

              #

              # calls REU student code that works but hasn't been walked-through

              # it's a dynamic serializer not strictly a yaml serializer

              #

              err_f = False

              match_f = False

              serializer = None

              ii = 0

              while ii < len(self.whichList):

                  if (self.whichList[ii] == which):

                      match_f = True

                      break

                  ii = ii + 1

              # end while

              if not match_f:

                  err_f = True

              else:

                  serializer = which

                  serializer = Serializer.serializers[serializer]()

              return err_f,serializer

              # end initSerializer

              #

              # --------------------------------------------------

              #

          def loads(self,element):   # borrows name from json module (json - to - python)

              retval = self.serializer.fromSerial(element)  # de-serialize

              return retval

          # end loads

          #

          # --------------------------------------------------

          #

          def dumps(self,element):  # borrows name from json module (python - to - json)

              retval = self.serializer.toSerial(element)  # serialize

              return retval

          # end dumps

          #

          # --------------------------------------------------

          #

      # end class DynamicSerializer

      if __name__ == "__main__":

          DynamicSerializer()

        George Yong
    
Python 2to3, Spectra (all operations) working

              r1167
            
          print("DynamicSerializer ran")

	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	#
		# rps 6/9/2014
		# mit haystack obs
		#
		# wrapper for Karl's code

		import DynamicObject # used for serial/deserial of complex python objects
		import Serializer # used for serial/deserial of complex python

		#
		class DynamicSerializer:
		#
		#------------------------------------------------------
		#
		def __init__(self,which='yaml'):
		#
		# choices are: yaml, msgpack, hdf5, json
		#
		self.err_f = False
		self.whichList = ['yaml', 'msgpack', 'hdf5', 'json'] # from Serialzer.py
		self.err_f,self.serializer = self.initSerializer(which)
		#
		#------------------------------------------------------
		#
		def initSerializer(self,which):
		#
		# calls REU student code that works but hasn't been walked-through
		# it's a dynamic serializer not strictly a yaml serializer
		#
		err_f = False
		match_f = False
		serializer = None
		ii = 0
		while ii < len(self.whichList):
		if (self.whichList[ii] == which):
		match_f = True
		break
		ii = ii + 1
		# end while
		if not match_f:
		err_f = True
		else:
		serializer = which
		serializer = Serializer.serializers[serializer]()

		return err_f,serializer
		# end initSerializer
		#
		# --------------------------------------------------
		#
		def loads(self,element): # borrows name from json module (json - to - python)
		retval = self.serializer.fromSerial(element) # de-serialize
		return retval
		# end loads
		#
		# --------------------------------------------------
		#
		def dumps(self,element): # borrows name from json module (python - to - json)
		retval = self.serializer.toSerial(element) # serialize
		return retval
		# end dumps
		#
		# --------------------------------------------------
		#
		# end class DynamicSerializer

		if __name__ == "__main__":
		DynamicSerializer()
George Yong Python 2to3, Spectra (all operations) working	r1167	print("DynamicSerializer ran")