Skip to content

Commit 71b36eb

Browse files
committed
fix: avoid parsing distributed configuration on push request
1 parent 5e3926c commit 71b36eb

File tree

1 file changed

+7
-6
lines changed

1 file changed

+7
-6
lines changed

pyorient/messages/base.py

Lines changed: 7 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -200,9 +200,9 @@ def _decode_header(self):
200200
# 80: \x50 Request Push 1 byte: Push command id
201201
push_command_id = self._decode_field(FIELD_BYTE)
202202
push_message = self._decode_field( FIELD_STRING )
203-
_, payload = self.get_serializer().decode(push_message)
204-
if self._push_callback:
205-
self._push_callback(push_command_id, payload)
203+
# _, payload = self.get_serializer().decode(push_message)
204+
# if self._push_callback:
205+
# self._push_callback(push_command_id, payload)
206206

207207
# self._cluster_map.set_hi_availability_list(
208208
# self._decode_field( FIELD_STRING )
@@ -214,9 +214,10 @@ def _decode_header(self):
214214
while end_flag == 3:
215215
self._decode_field( FIELD_INT ) # FAKE SESSION ID = 2^-31
216216
self._decode_field( FIELD_BYTE ) # 80: 0x50 Request Push
217-
self._cluster_map.set_hi_availability_list(
218-
self._decode_field( FIELD_STRING )
219-
) # JSON WITH THE NEW CLUSTER CFG
217+
cluster_map_field = self._decode_field( FIELD_STRING );
218+
#self._cluster_map.set_hi_availability_list(
219+
# cluster_map_field
220+
#) # JSON WITH THE NEW CLUSTER CFG
220221

221222
"""
222223
:type: self._cluster_map pyorient.messages.cluster.Information

0 commit comments

Comments
 (0)