-
Notifications
You must be signed in to change notification settings - Fork 54
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Employ mastership info for session management (#1189)
* Implement session management using mastership information * Use exponential backoff retry package * Initialize topo channel from manager for now * checking term for updating the device state * Fix get current term * return the test to normal condition * Fix a small bug * Handle device updates * Use one single channel and single go routine for updating the device state * revert the change * Fix retries to make sure we stop it if there is mastership change * For debugging * Create a channel per session for handling device response events * comment out the session manager test * Fix consistency bug and make sure we check mastership term on the same device object * Remove old files and add some unit tests * update device state unit test * clean up the code * Move handling of mastership events to session manager * Set replicaCount to 1 * fix unit test * Use one mastership state instead of reading from store * Fix unit test
- Loading branch information
1 parent
16942d0
commit aed547f
Showing
13 changed files
with
1,355 additions
and
621 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file was deleted.
Oops, something went wrong.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.