Diff: private/rci_binary_traverse.h

Revision:

0:1c358ea10753

--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/private/rci_binary_traverse.h	Tue Dec 03 13:34:02 2013 +0000
@@ -0,0 +1,247 @@
+/*
+ * Copyright (c) 2013 Digi International Inc.,
+ * All rights not expressly granted are reserved.
+ *
+ * This Source Code Form is subject to the terms of the Mozilla Public
+ * License, v. 2.0. If a copy of the MPL was not distributed with this file,
+ * You can obtain one at http://mozilla.org/MPL/2.0/.
+ *
+ * Digi International Inc. 11001 Bren Road East, Minnetonka, MN 55343
+ * =======================================================================
+ */
+
+static void traverse_rci_command(rci_t * const rci)
+{
+    trigger_rci_callback(rci, connector_request_id_remote_config_action_start);
+
+    set_rci_output_state(rci, rci_output_state_command_id);
+    state_call(rci, rci_parser_state_output);
+
+}
+static void traverse_group_id(rci_t * const rci)
+{
+    trigger_rci_callback(rci, connector_request_id_remote_config_group_start);
+
+    set_rci_output_state(rci, rci_output_state_group_id);
+    state_call(rci, rci_parser_state_output);
+}
+
+static void traverse_element_id(rci_t * const rci)
+{
+
+    connector_group_element_t const * const element = get_current_element(rci);
+
+    if ((rci->shared.callback_data.action == connector_remote_action_query) &&
+        (element->access == connector_element_access_write_only))
+    {
+        goto done;
+    }
+
+    trigger_rci_callback(rci, connector_request_id_remote_config_group_process);
+    set_rci_output_state(rci, rci_output_state_field_id);
+    state_call(rci, rci_parser_state_output);
+
+done:
+    return;
+}
+
+static void traverse_element_end(rci_t * const rci)
+{
+    trigger_rci_callback(rci, connector_request_id_remote_config_group_end);
+
+    set_rci_output_state(rci, rci_output_state_field_terminator);
+    state_call(rci, rci_parser_state_output);
+}
+
+static void traverse_group_end(rci_t * const rci)
+{
+    trigger_rci_callback(rci, connector_request_id_remote_config_action_end);
+    set_rci_output_state(rci, rci_output_state_group_terminator);
+    state_call(rci, rci_parser_state_output);
+
+}
+
+static connector_bool_t traverse_all_elements(rci_t * const rci)
+{
+    connector_bool_t done = connector_false;
+
+    if (!have_element_id(rci))
+    {
+        /* all fields */
+        set_element_id(rci, 0);
+        traverse_element_id(rci);
+    }
+    else
+    {
+        connector_group_t const * const group =  get_current_group(rci);
+        unsigned int const id = get_element_id(rci) + 1;
+
+        if (id < group->elements.count)
+        {
+            set_element_id(rci, id);
+            traverse_element_id(rci);
+        }
+        else
+        {
+            traverse_element_end(rci);
+            done = connector_true;
+        }
+    }
+    return done;
+}
+
+static connector_bool_t traverse_all_group_instances(rci_t * const rci)
+{
+    connector_bool_t done = connector_false;
+
+    switch (rci->traverse.process_state)
+    {
+        case rci_traverse_process_group:
+        case rci_traverse_process_element:
+            if (traverse_all_elements(rci))
+                rci->traverse.process_state = rci_traverse_process_next_instance;
+            break;
+        case rci_traverse_process_next_instance:
+            {
+                connector_group_t const * const group =  get_current_group(rci);
+                if (group->instances > 1 && group->instances > get_group_index(rci))
+                {
+                    /* next instances */
+                    increment_group_index(rci);
+                    traverse_group_id(rci);
+                    rci->traverse.process_state = rci_traverse_process_element;
+                }
+                else
+                {
+                    /* no more instances */
+                    done = connector_true;
+                }
+            }
+            break;
+    }
+
+    return done;
+}
+
+static connector_bool_t traverse_all_groups(rci_t * const rci)
+{
+    connector_bool_t done = connector_false;
+
+    switch (rci->traverse.process_state)
+    {
+        case rci_traverse_process_group:
+        {
+            connector_remote_group_table_t const * const table = (connector_rci_config_data.group_table + rci->shared.callback_data.group.type);
+
+            if (table->count == 0)
+            {
+                traverse_group_end(rci);
+            }
+            else if (!have_group_id(rci))
+            {
+                set_group_id(rci, 0);
+                set_group_index(rci, 1);
+                traverse_group_id(rci);
+                rci->traverse.process_state = rci_traverse_process_element;
+            }
+            else
+            {
+
+                size_t const id = get_group_id(rci) + 1;
+
+                if (id == table->count)
+                {
+                    /* done all groups */
+                    traverse_group_end(rci);
+                    done = connector_true;
+                }
+                else
+                {
+                    connector_group_t const * const group =  get_current_group(rci);
+                    if (group->instances > 1 && group->instances > get_group_index(rci))
+                    {
+                        /* next instances */
+                        increment_group_index(rci);
+                    }
+                    else
+                    {
+                        /* next group */
+                        increment_group_id(rci);
+                        set_group_index(rci, 1);
+                    }
+                    traverse_group_id(rci);
+                    rci->traverse.process_state = rci_traverse_process_element;
+                }
+            }
+            break;
+        }
+        case rci_traverse_process_element:
+            if (traverse_all_elements(rci))
+                rci->traverse.process_state = rci_traverse_process_group;
+            break;
+
+        case rci_traverse_process_next_instance:
+            break;
+    }
+
+    return done;
+}
+
+static void rci_traverse_data(rci_t * const rci)
+{
+    connector_bool_t done_state = connector_true;
+
+    rci_debug_printf("traverse: %s\n", rci_traverse_state_t_as_string(rci->traverse.state));
+
+    switch (rci->traverse.state)
+    {
+        case rci_traverse_state_none:
+            if (get_rci_input_state(rci) == rci_input_state_done)
+                state_call(rci, rci_parser_state_output);
+            else
+                state_call(rci, rci_parser_state_input);
+            break;
+
+        case rci_traverse_state_command_id:
+            traverse_rci_command(rci);
+            break;
+
+        case rci_traverse_state_all_groups:
+            done_state = traverse_all_groups(rci);
+            break;
+
+        case rci_traverse_state_group_id:
+            traverse_group_id(rci);
+            break;
+
+        case rci_traverse_state_all_group_instances:
+            done_state = traverse_all_group_instances(rci);
+            break;
+
+        case rci_traverse_state_element_id:
+            traverse_element_id(rci);
+            break;
+
+        case rci_traverse_state_all_elements:
+            done_state = traverse_all_elements(rci);
+            break;
+
+        case rci_traverse_state_element_end:
+            traverse_element_end(rci);
+            break;
+
+        case rci_traverse_state_group_end:
+            traverse_group_end(rci);
+            break;
+    }
+
+    if (done_state)
+    {
+        rci->traverse.process_state = rci_traverse_process_group;
+        set_rci_traverse_state(rci, rci_traverse_state_none);
+    }
+
+    return;
+}
+
+