Handle heartbeat message #46
Merged
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
I_HEARTBEAT_RESPONSE.
represents the new state of the dictionary stored in Sensor
attribute children. The new state is what a controller wants to
achieve. The children dictionary is only
updated when I_HEARTBEAT_RESPONSE is received and _handle_heartbeat
is called.
the deque to store replies for received messages. Add replies to
queue when heartbeat is received.
and Sensor.queue. Get tasks from Gateway.queue until it's
empty in run loop before receiving new messages.
children. This is used in Gateway method set_child_value to update
values of new_state Sensor attribute.
I_HEARTBEAT_RESPONSE to _handle_heartbeat.
instead update new_state dict if new_state is non empty. It's non
empty if _handle_heartbeat has been called at least once.
is called.