diff options
Diffstat (limited to 'aclk/aclk_rx_msgs.c')
| -rw-r--r-- | aclk/aclk_rx_msgs.c | 10 |
1 files changed, 2 insertions, 8 deletions
diff --git a/aclk/aclk_rx_msgs.c b/aclk/aclk_rx_msgs.c index a1a7958528..445d2f193c 100644 --- a/aclk/aclk_rx_msgs.c +++ b/aclk/aclk_rx_msgs.c @@ -313,10 +313,7 @@ int send_node_instances(const char *msg, size_t msg_len) int stream_charts_and_dimensions(const char *msg, size_t msg_len) { - if (aclk_ctx_based) { - error_report("Got StreamChartsAndDimensions in Context mode! Ignoring"); - return 1; - } + aclk_ctx_based = 0; stream_charts_and_dims_t res = parse_stream_charts_and_dims(msg, msg_len); if (!res.claim_id || !res.node_id) { error("Error parsing StreamChartsAndDimensions msg"); @@ -432,10 +429,7 @@ int handle_disconnect_req(const char *msg, size_t msg_len) int contexts_checkpoint(const char *msg, size_t msg_len) { - if (!aclk_ctx_based) { - error_report("Received ContextsCheckpoint message but context based communication was not enabled (Cloud violated the protocol). Ignoring message"); - return 1; - } + aclk_ctx_based = 1; struct ctxs_checkpoint *cmd = parse_ctxs_checkpoint(msg, msg_len); if (!cmd) |