[geode-native] branch develop updated: GEODE-8524: Add support for KEY_SET and GET_ALL_70 messages (#655)

[bb...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

bbender pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/geode-native.git


The following commit(s) were added to refs/heads/develop by this push:
     new b3216fa  GEODE-8524: Add support for KEY_SET and GET_ALL_70 messages (#655)
b3216fa is described below

commit b3216fa70144688a29fe32235e0bd8fc9e015d69
Author: Blake Bender <bb...@pivotal.io>
AuthorDate: Thu Sep 24 09:07:32 2020 -0700

    GEODE-8524: Add support for KEY_SET and GET_ALL_70 messages (#655)
    
    Co-authored-by: Blake Bender <bb...@vmware.com>
---
 tools/gnmsg/client_messages.py | 15 +++++++++++++++
 1 file changed, 15 insertions(+)

diff --git a/tools/gnmsg/client_messages.py b/tools/gnmsg/client_messages.py
index 39f72b1..6110f4a 100644
--- a/tools/gnmsg/client_messages.py
+++ b/tools/gnmsg/client_messages.py
@@ -372,6 +372,19 @@ def read_execute_function_message(properties, message_bytes, offset):
     (properties["FunctionName"], offset) = parse_region_part(message_bytes, offset)
     (properties["Arguments"], offset) = parse_object_part(message_bytes, offset)
 
+def parse_getall_optional_callback_arguments(message_bytes, offset):
+    (local_object, local_offset) = parse_object_part(message_bytes, offset)
+    if (local_object["IsObject"] == 0):
+        (local_object, local_offset) = parse_raw_int_part(message_bytes, offset)
+    return (local_object, local_offset)
+
+def read_get_all_70_message(properties, message_bytes, offset):
+    (properties["Region"], offset) = parse_region_part(message_bytes, offset)
+    (properties["KeyList"], offset) = parse_key_or_value(message_bytes, offset)
+    (properties["CallbackArguments"], offset) = parse_getall_optional_callback_arguments(message_bytes, offset)
+
+def read_key_set(properties, message_bytes, offset):
+    (properties["Region"], offset) = parse_region_part(message_bytes, offset)
 
 client_message_parsers = {
     "PUT": read_put_message,
@@ -386,6 +399,8 @@ client_message_parsers = {
     "EXECUTECQ_WITH_IR_MSG_TYPE": read_executecq_with_ir_msg_type_message,
     "STOPCQ_MSG_TYPE": read_stopcq_or_closecq_msg_type_message,
     "CLOSECQ_MSG_TYPE": read_stopcq_or_closecq_msg_type_message,
+    "GET_ALL_70": read_get_all_70_message,
+    "KEY_SET": read_key_set,
     "GET_PDX_ID_FOR_TYPE": read_get_pdx_id_for_type_message,
     "GET_FUNCTION_ATTRIBUTES": read_get_function_attributes_message,
     "EXECUTE_FUNCTION": read_execute_function_message,