##// END OF EJS Templates
serializer module added to Signal Chain
Miguel Valdez -
r697:7ac8878019bb
parent child
Show More
@@ -16,7 +16,7 SERIALIZER = cPickle
16
16
17 # from schainpy.serializer import DynamicSerializer
17 # from schainpy.serializer import DynamicSerializer
18 from schainpy.model.io.jroIO_usrp import USRPReader
18 from schainpy.model.io.jroIO_usrp import USRPReader
19 from schainpy.serializer.DataTranslate import obj2Serial
19 from schainpy.model.serializer.data import obj2Serial
20
20
21 class USRPReaderAPI(USRPReader, threading.Thread):
21 class USRPReaderAPI(USRPReader, threading.Thread):
22
22
1 NO CONTENT: file renamed from schainpy/serializer/__init__.py to schainpy/model/serializer/__init__.py
NO CONTENT: file renamed from schainpy/serializer/__init__.py to schainpy/model/serializer/__init__.py
@@ -3,7 +3,7 Created on Jul 15, 2014
3
3
4 @author: Miguel Urco
4 @author: Miguel Urco
5 '''
5 '''
6 from JROSerializer import DynamicSerializer
6 from serializer import DynamicSerializer
7
7
8 PICKLE_SERIALIZER = DynamicSerializer('cPickle')
8 PICKLE_SERIALIZER = DynamicSerializer('cPickle')
9 MSGPACK_SERIALIZER = DynamicSerializer('msgpack')
9 MSGPACK_SERIALIZER = DynamicSerializer('msgpack')
@@ -75,14 +75,13 def dict2Obj(myDict):
75
75
76 return myObj
76 return myObj
77
77
78 def obj2Serial(myObj, serializer='msgpack', **kwargs):
78 def dict2Serial(myDict, serializer='msgpack'):
79
79
80 if serializer == 'cPickle':
80 if serializer == 'cPickle':
81 SERIALIZER = PICKLE_SERIALIZER
81 SERIALIZER = PICKLE_SERIALIZER
82 else:
82 else:
83 SERIALIZER = MSGPACK_SERIALIZER
83 SERIALIZER = MSGPACK_SERIALIZER
84
84
85 myDict = obj2Dict(myObj, **kwargs)
86 mySerial = SERIALIZER.dumps(myDict)
85 mySerial = SERIALIZER.dumps(myDict)
87
86
88 return mySerial
87 return mySerial
@@ -93,8 +92,22 def serial2Dict(mySerial, serializer='msgpack'):
93 SERIALIZER = PICKLE_SERIALIZER
92 SERIALIZER = PICKLE_SERIALIZER
94 else:
93 else:
95 SERIALIZER = MSGPACK_SERIALIZER
94 SERIALIZER = MSGPACK_SERIALIZER
95
96 myDict = SERIALIZER.loads(mySerial)
97
98 return myDict
99
100 def obj2Serial(myObj, serializer='msgpack', **kwargs):
101
102 if serializer == 'cPickle':
103 SERIALIZER = PICKLE_SERIALIZER
104 else:
105 SERIALIZER = MSGPACK_SERIALIZER
96
106
97 return SERIALIZER.loads(mySerial)
107 myDict = obj2Dict(myObj, **kwargs)
108 mySerial = dict2Serial(myDict, serializer)
109
110 return mySerial
98
111
99 def serial2Obj(mySerial, metadataDict = {}, serializer='msgpack'):
112 def serial2Obj(mySerial, metadataDict = {}, serializer='msgpack'):
100
113
@@ -103,7 +116,7 def serial2Obj(mySerial, metadataDict = {}, serializer='msgpack'):
103 else:
116 else:
104 SERIALIZER = MSGPACK_SERIALIZER
117 SERIALIZER = MSGPACK_SERIALIZER
105
118
106 myDataDict = SERIALIZER.loads(mySerial)
119 myDataDict = serial2Dict(mySerial, serializer)
107
120
108 if not metadataDict:
121 if not metadataDict:
109 myObj = dict2Obj(myDataDict)
122 myObj = dict2Obj(myDataDict)
@@ -112,4 +125,4 def serial2Obj(mySerial, metadataDict = {}, serializer='msgpack'):
112 metadataDict.update(myDataDict)
125 metadataDict.update(myDataDict)
113 myObj = dict2Obj(metadataDict)
126 myObj = dict2Obj(metadataDict)
114
127
115 return myObj No newline at end of file
128 return myObj
1 NO CONTENT: file renamed from schainpy/serializer/JROSerializer.py to schainpy/model/serializer/serializer.py
NO CONTENT: file renamed from schainpy/serializer/JROSerializer.py to schainpy/model/serializer/serializer.py
1 NO CONTENT: file renamed from schainpy/serializer/test/DynamicObject.py to schainpy/model/serializer/test/DynamicObject.py
NO CONTENT: file renamed from schainpy/serializer/test/DynamicObject.py to schainpy/model/serializer/test/DynamicObject.py
1 NO CONTENT: file renamed from schainpy/serializer/test/DynamicSerializer.py to schainpy/model/serializer/test/DynamicSerializer.py
NO CONTENT: file renamed from schainpy/serializer/test/DynamicSerializer.py to schainpy/model/serializer/test/DynamicSerializer.py
1 NO CONTENT: file renamed from schainpy/serializer/test/DynamicYAML.py to schainpy/model/serializer/test/DynamicYAML.py
NO CONTENT: file renamed from schainpy/serializer/test/DynamicYAML.py to schainpy/model/serializer/test/DynamicYAML.py
1 NO CONTENT: file renamed from schainpy/serializer/test/Lookup.py to schainpy/model/serializer/test/Lookup.py
NO CONTENT: file renamed from schainpy/serializer/test/Lookup.py to schainpy/model/serializer/test/Lookup.py
1 NO CONTENT: file renamed from schainpy/serializer/test/OrderedYAML.py to schainpy/model/serializer/test/OrderedYAML.py
NO CONTENT: file renamed from schainpy/serializer/test/OrderedYAML.py to schainpy/model/serializer/test/OrderedYAML.py
1 NO CONTENT: file renamed from schainpy/serializer/test/PrecisionTime.py to schainpy/model/serializer/test/PrecisionTime.py
NO CONTENT: file renamed from schainpy/serializer/test/PrecisionTime.py to schainpy/model/serializer/test/PrecisionTime.py
1 NO CONTENT: file renamed from schainpy/serializer/test/Serializer.py to schainpy/model/serializer/test/Serializer.py
NO CONTENT: file renamed from schainpy/serializer/test/Serializer.py to schainpy/model/serializer/test/Serializer.py
1 NO CONTENT: file renamed from schainpy/serializer/test/__init__.py to schainpy/model/serializer/test/__init__.py
NO CONTENT: file renamed from schainpy/serializer/test/__init__.py to schainpy/model/serializer/test/__init__.py
1 NO CONTENT: file renamed from schainpy/serializer/test/serialtest.py to schainpy/model/serializer/test/serialtest.py
NO CONTENT: file renamed from schainpy/serializer/test/serialtest.py to schainpy/model/serializer/test/serialtest.py
1 NO CONTENT: file renamed from schainpy/serializer/test/test _serializer_speed.py to schainpy/model/serializer/test/test _serializer_speed.py
NO CONTENT: file renamed from schainpy/serializer/test/test _serializer_speed.py to schainpy/model/serializer/test/test _serializer_speed.py
General Comments 0
You need to be logged in to leave comments. Login now