forked from project-chip/connectedhomeip
-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Add records of session establishment for subscription resumption (pro…
…ject-chip#31755) * Add records of session establishment for subscription resumption * Restyled by clang-format * review changes * Schedule subscription resumption when failing to establish the session in SubscriptionResumptionSessionEstablisher * Add option to set subscription timeout resumption retry interval seconds for Linux app Add cirque test for subscription resumption timeout * Restyled by clang-format * Restyled by autopep8 * Restyled by isort * fix CI building * Add test to the test list * add subscription resumption restries number to SubscriptionInfo struct * review changes * make resumption retries persistent * Restyled by clang-format * ci build fixes * try to fix cirque test --------- Co-authored-by: Restyled.io <[email protected]>
- Loading branch information
Showing
12 changed files
with
361 additions
and
9 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 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
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
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
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
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
125 changes: 125 additions & 0 deletions
125
src/controller/python/test/test_scripts/subscription_resumption_timeout_test.py
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
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,125 @@ | ||
| #!/usr/bin/env python3 | ||
|
|
||
| # | ||
| # Copyright (c) 2024 Project CHIP Authors | ||
| # All rights reserved. | ||
| # | ||
| # Licensed under the Apache License, Version 2.0 (the "License"); | ||
| # you may not use this file except in compliance with the License. | ||
| # You may obtain a copy of the License at | ||
| # | ||
| # http://www.apache.org/licenses/LICENSE-2.0 | ||
| # | ||
| # Unless required by applicable law or agreed to in writing, software | ||
| # distributed under the License is distributed on an "AS IS" BASIS, | ||
| # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. | ||
| # See the License for the specific language governing permissions and | ||
| # limitations under the License. | ||
| # | ||
|
|
||
| # Commissioning test. | ||
|
|
||
| import os | ||
| import sys | ||
| from optparse import OptionParser | ||
|
|
||
| from base import BaseTestHelper, FailIfNot, TestFail, TestTimeout, logger | ||
|
|
||
| TEST_DISCRIMINATOR = 3840 | ||
| TEST_SETUPPIN = 20202021 | ||
|
|
||
| TEST_ENDPOINT_ID = 0 | ||
|
|
||
|
|
||
| def main(): | ||
| optParser = OptionParser() | ||
| optParser.add_option( | ||
| "-t", | ||
| "--timeout", | ||
| action="store", | ||
| dest="testTimeout", | ||
| default=90, | ||
| type='int', | ||
| help="The program will return with timeout after specified seconds.", | ||
| metavar="<timeout-second>", | ||
| ) | ||
| optParser.add_option( | ||
| "-a", | ||
| "--address", | ||
| action="store", | ||
| dest="deviceAddress", | ||
| default='', | ||
| type='str', | ||
| help="Address of the device", | ||
| metavar="<device-addr>", | ||
| ) | ||
| optParser.add_option( | ||
| "--nodeid", | ||
| action="store", | ||
| dest="nodeid", | ||
| default=1, | ||
| type=int, | ||
| help="The Node ID issued to the device", | ||
| metavar="<nodeid>" | ||
| ) | ||
| optParser.add_option( | ||
| "--discriminator", | ||
| action="store", | ||
| dest="discriminator", | ||
| default=TEST_DISCRIMINATOR, | ||
| type=int, | ||
| help="Discriminator of the device", | ||
| metavar="<nodeid>" | ||
| ) | ||
| optParser.add_option( | ||
| "--setuppin", | ||
| action="store", | ||
| dest="setuppin", | ||
| default=TEST_SETUPPIN, | ||
| type=int, | ||
| help="Setup PIN of the device", | ||
| metavar="<nodeid>" | ||
| ) | ||
| optParser.add_option( | ||
| "-p", | ||
| "--paa-trust-store-path", | ||
| action="store", | ||
| dest="paaTrustStorePath", | ||
| default='', | ||
| type='str', | ||
| help="Path that contains valid and trusted PAA Root Certificates.", | ||
| metavar="<paa-trust-store-path>" | ||
| ) | ||
|
|
||
| (options, remainingArgs) = optParser.parse_args(sys.argv[1:]) | ||
|
|
||
| timeoutTicker = TestTimeout(options.testTimeout) | ||
| timeoutTicker.start() | ||
|
|
||
| test = BaseTestHelper( | ||
| nodeid=112233, paaTrustStorePath=options.paaTrustStorePath, testCommissioner=True) | ||
|
|
||
| FailIfNot( | ||
| test.TestOnNetworkCommissioning(options.discriminator, options.setuppin, options.nodeid, options.deviceAddress), | ||
| "Failed on on-network commissioing") | ||
| try: | ||
| test.devCtrl.ZCLSubscribeAttribute("BasicInformation", "NodeLabel", options.nodeid, TEST_ENDPOINT_ID, 1, 2, | ||
| keepSubscriptions=True, autoResubscribe=False) | ||
| except Exception as ex: | ||
| TestFail(f"Failed to subscribe attribute: {ex}") | ||
|
|
||
| timeoutTicker.stop() | ||
|
|
||
| logger.info("Test finished") | ||
|
|
||
| # TODO: Python device controller cannot be shutdown clean sometimes and will block on AsyncDNSResolverSockets shutdown. | ||
| # Call os._exit(0) to force close it. | ||
| os._exit(0) | ||
|
|
||
|
|
||
| if __name__ == "__main__": | ||
| try: | ||
| main() | ||
| except Exception as ex: | ||
| logger.exception(ex) | ||
| TestFail("Exception occurred when running tests.") |
Oops, something went wrong.