diff --git a/artifacts/iqpilot_emac_private/manifest.json b/artifacts/iqpilot_emac_private/manifest.json index cf339e3b3..ed66bffe9 100644 --- a/artifacts/iqpilot_emac_private/manifest.json +++ b/artifacts/iqpilot_emac_private/manifest.json @@ -536,27 +536,27 @@ }, "python/iqpilot_private/emac/bulk_transport.cpython-312-aarch64-linux-gnu.so": { "mode": 493, - "sha256": "0fec7e56196064f024cf317a6f23d9f2111f90753c48bb7d616e06e27335157d", - "size": 333888 + "sha256": "c069d85362528e1f1e36c419950096eb81dd07e96fdb14fa6aac6c50178bad27", + "size": 333808 }, "python/iqpilot_private/emac/ffs_holder.cpython-312-aarch64-linux-gnu.so": { "mode": 493, - "sha256": "4d6e7c4bc97ced0bf2def103d2fc8eb98364747aa33e495bc448c68644739750", - "size": 68064 + "sha256": "846394e2620f16d5bb457a22a01bf44b0c7ba2c3511e90a1b6a2f57bf60e65ef", + "size": 68072 }, "python/iqpilot_private/emac/mac_client.cpython-312-aarch64-linux-gnu.so": { "mode": 493, - "sha256": "a23b14f9f2c5c7a058c20ef0421bb741fc67c2adff13824c1c808e6831430f91", - "size": 267960 + "sha256": "af7708ec07d580ed547985fd45b11ae92c5aa44b3b3222c2550b694e3caaf110", + "size": 267864 }, "python/iqpilot_private/emac/mac_protocol.cpython-312-aarch64-linux-gnu.so": { "mode": 493, - "sha256": "189c7d6d5599f92fc224a086ef55520118130785f482c0667cc808071c84e718", - "size": 203544 + "sha256": "abefe36ce82767927f9c258a08ef13421b724d85736291043d3062fe19451dcd", + "size": 203552 }, "python/iqpilot_private/emac/maciqmodeld.cpython-312-aarch64-linux-gnu.so": { "mode": 493, - "sha256": "2cf0bc9d6362f2d4c9691f4f0ef7989a5651cc3153e99e5c2e15d9da1b93e598", + "sha256": "518157f68e397db8bc4ac345989b62abccddd5fa91f41c4a0c42d5408cde4477", "size": 399040 }, "runtime": { @@ -568,10 +568,10 @@ } }, "signatures": { - "python/iqpilot_private/emac/bulk_transport.cpython-312-aarch64-linux-gnu.so": "laKo35uiFJAsuGj7+N5l5IVbXmTQ/jyB01c31OfA7XCT0AG09/cg9ArgDhQv5qr3babesKgUKoPg2vtFnnXyDg==", - "python/iqpilot_private/emac/ffs_holder.cpython-312-aarch64-linux-gnu.so": "Sd6VF2hrGHXoXTe3IpCYoTDczM741xcQ1sKiHGcCgNqkeORvLumWxic20ylmWhWOTHziPB9Y723vFOGcKZzDAQ==", - "python/iqpilot_private/emac/mac_client.cpython-312-aarch64-linux-gnu.so": "O9O/B4IDlCutovmEPDnLxdKAFsURjXS+pyaK0OvmoOlOQW1fQS+ZahxaQ0dkwASDzEMWUxUFr0j9PrlihUVpCA==", - "python/iqpilot_private/emac/mac_protocol.cpython-312-aarch64-linux-gnu.so": "77vKNawQIdv95LPwTFn79N2RXaz6dQUcRtgtnH+R7T2TN2LBSKhKvtzu2sKkKyDG7038qrJfhE9BiJYtho56BA==", - "python/iqpilot_private/emac/maciqmodeld.cpython-312-aarch64-linux-gnu.so": "Fhxo++ZiJmWGBghe/dH/ytHe+T67v/HAA6k4js7Bd+C07dA/zMlgTI45QlBx2fZN2qC602Z4Stijy+/EQziuCg==" + "python/iqpilot_private/emac/bulk_transport.cpython-312-aarch64-linux-gnu.so": "U9GH0luMCR2czyM8p33BMAvmT48ZKjlSndkx1YpTDKAvCvmksXlrhckumbk65JX9vXR8xLRLYGksR7muXvDpBw==", + "python/iqpilot_private/emac/ffs_holder.cpython-312-aarch64-linux-gnu.so": "I1r0dLpsIGW/UufeQJ2s/DVEzB1t1ANW5HwsILHbf7nh6ifasd7JrfEIkQPl+U+fbu2N5D0ciSKaMNJXFwXYAQ==", + "python/iqpilot_private/emac/mac_client.cpython-312-aarch64-linux-gnu.so": "zxJFn+T/NY/qBNRYJ/s7Xqp8PFVO9GCTiMqH03Y2TiZGiisgwrUGDEcBjBVAIjDDYqjYTn8s01p7cN2PCK92Dg==", + "python/iqpilot_private/emac/mac_protocol.cpython-312-aarch64-linux-gnu.so": "y0TNy549j35aJ7lnS4N21Fx5XRwfWjCZxyObB+SQnZWJQ8sW63r4lVS+t01koyQUXLmzT3/y1mYJ3WujlkxACQ==", + "python/iqpilot_private/emac/maciqmodeld.cpython-312-aarch64-linux-gnu.so": "K1glyNgXfg7KVRXYhfsGS53iH9hxv+k5TOzylw6Cu3KA2JvyOYUgMhQlVDg+p+t4DJYfOr69H/d5ENtgHGVNDg==" } } diff --git a/artifacts/iqpilot_emac_private/manifest.json.sig b/artifacts/iqpilot_emac_private/manifest.json.sig index 5e95c35ca..c126d077b 100644 --- a/artifacts/iqpilot_emac_private/manifest.json.sig +++ b/artifacts/iqpilot_emac_private/manifest.json.sig @@ -1 +1 @@ -nBzDAB5lnwH7Ynehfwf48y7ACh39HIRNiff55kmMtNG466wcxBrkMcnEJz/rDf7ehRcZmyD08CVW5QCfMsHBAA== +xwY/6EveM0uSrV6q37dNH9aAkFdYr5Wr1YSawQtQNWBSyzDwA5qacLqCqZFbLbLAx1A9d8wUSEDPeAESmMHMBA== diff --git a/artifacts/iqpilot_emac_private/python/iqpilot_private/emac/bulk_transport.cpython-312-aarch64-linux-gnu.so b/artifacts/iqpilot_emac_private/python/iqpilot_private/emac/bulk_transport.cpython-312-aarch64-linux-gnu.so index d0d27eb79..079dda44c 100755 Binary files a/artifacts/iqpilot_emac_private/python/iqpilot_private/emac/bulk_transport.cpython-312-aarch64-linux-gnu.so and b/artifacts/iqpilot_emac_private/python/iqpilot_private/emac/bulk_transport.cpython-312-aarch64-linux-gnu.so differ diff --git a/artifacts/iqpilot_emac_private/python/iqpilot_private/emac/ffs_holder.cpython-312-aarch64-linux-gnu.so b/artifacts/iqpilot_emac_private/python/iqpilot_private/emac/ffs_holder.cpython-312-aarch64-linux-gnu.so index c906ed22a..97372609f 100755 Binary files a/artifacts/iqpilot_emac_private/python/iqpilot_private/emac/ffs_holder.cpython-312-aarch64-linux-gnu.so and b/artifacts/iqpilot_emac_private/python/iqpilot_private/emac/ffs_holder.cpython-312-aarch64-linux-gnu.so differ diff --git a/artifacts/iqpilot_emac_private/python/iqpilot_private/emac/mac_client.cpython-312-aarch64-linux-gnu.so b/artifacts/iqpilot_emac_private/python/iqpilot_private/emac/mac_client.cpython-312-aarch64-linux-gnu.so index 13355aeba..6430d9a7e 100755 Binary files a/artifacts/iqpilot_emac_private/python/iqpilot_private/emac/mac_client.cpython-312-aarch64-linux-gnu.so and b/artifacts/iqpilot_emac_private/python/iqpilot_private/emac/mac_client.cpython-312-aarch64-linux-gnu.so differ diff --git a/artifacts/iqpilot_emac_private/python/iqpilot_private/emac/mac_protocol.cpython-312-aarch64-linux-gnu.so b/artifacts/iqpilot_emac_private/python/iqpilot_private/emac/mac_protocol.cpython-312-aarch64-linux-gnu.so index 2eeda697e..50a7ef9e3 100755 Binary files a/artifacts/iqpilot_emac_private/python/iqpilot_private/emac/mac_protocol.cpython-312-aarch64-linux-gnu.so and b/artifacts/iqpilot_emac_private/python/iqpilot_private/emac/mac_protocol.cpython-312-aarch64-linux-gnu.so differ diff --git a/artifacts/iqpilot_emac_private/python/iqpilot_private/emac/maciqmodeld.cpython-312-aarch64-linux-gnu.so b/artifacts/iqpilot_emac_private/python/iqpilot_private/emac/maciqmodeld.cpython-312-aarch64-linux-gnu.so index e76f8c727..e03fa1469 100755 Binary files a/artifacts/iqpilot_emac_private/python/iqpilot_private/emac/maciqmodeld.cpython-312-aarch64-linux-gnu.so and b/artifacts/iqpilot_emac_private/python/iqpilot_private/emac/maciqmodeld.cpython-312-aarch64-linux-gnu.so differ diff --git a/artifacts/iqpilot_model_selector_private/manifest.json b/artifacts/iqpilot_model_selector_private/manifest.json index 7e9210c54..14dcd5d93 100644 --- a/artifacts/iqpilot_model_selector_private/manifest.json +++ b/artifacts/iqpilot_model_selector_private/manifest.json @@ -176,8 +176,8 @@ }, "python/iqpilot_private/models/__init__.cpython-312-aarch64-linux-gnu.so": { "mode": 493, - "sha256": "665a6a5163899f37bb7e41fd42fe79ecd77e50496285b60c6555971b8337f463", - "size": 67568 + "sha256": "6a43103927cc37690f78758c36db0fcc3bf97ce05f94acd3f5a84ebf914d2a50", + "size": 67640 }, "python/iqpilot_private/models/__init__.py": { "mode": 420, @@ -186,38 +186,38 @@ }, "python/iqpilot_private/models/big_catalog.cpython-312-aarch64-linux-gnu.so": { "mode": 493, - "sha256": "8a63da11107132869d7ea4e391197ca8bde2d13d6d92b09a83484503910a75d5", - "size": 133856 + "sha256": "f3e34dd9c64d25bd2f5b729ae94e9bedd63f9b585f772f35d94f382bef4f864c", + "size": 133864 }, "python/iqpilot_private/models/egpu_model.cpython-312-aarch64-linux-gnu.so": { "mode": 493, - "sha256": "7090be17ce2063905fc364ee925384708895150f4d6eef642a94b941d3c6c88d", - "size": 68096 + "sha256": "469cb16c85db9ec1f66d614039706e8243612abdb44e578fbc964009fb598608", + "size": 68144 }, "python/iqpilot_private/models/emac_model_meta.cpython-312-aarch64-linux-gnu.so": { "mode": 493, - "sha256": "c2691e7a3e77e78d20d21cbf0d0bc4d59fd294935c7ebd0cc7225b0d77619914", - "size": 134032 + "sha256": "8c977c4fa77753b7ab325f3988ed8535a11a0f269c1f3a8d74b4ebf3fa951d33", + "size": 134056 }, "python/iqpilot_private/models/fetcher.cpython-312-aarch64-linux-gnu.so": { "mode": 493, - "sha256": "d085741bb6a7d2a94d616d53e78e0ae76d381ca926017646ec33931375fb5963", - "size": 136200 + "sha256": "f499359e1c4f0e7ca0b495991267d3ec96813862bc098e7cbb62afc59bb8a306", + "size": 136128 }, "python/iqpilot_private/models/git_auth.cpython-312-aarch64-linux-gnu.so": { "mode": 493, - "sha256": "951ecc3665d6a2232f50ca3002f7f84753789ecd1adfc06cc85884b42c47e05c", - "size": 68032 + "sha256": "92e357d4c38827dd85373fe231e33f67a6a139ceae13f1031696ccb82dd0e872", + "size": 68080 }, "python/iqpilot_private/models/helpers.cpython-312-aarch64-linux-gnu.so": { "mode": 493, - "sha256": "8670d22574d59c9b2f43c0fa047967a3236fc4eb0ca315a61fe0c9f2636d886a", - "size": 203512 + "sha256": "a5c874def693b474f2f834efb7c35041bc5b9ae94c95d8eed70119591dfebcb2", + "size": 203576 }, "python/iqpilot_private/models/manager.cpython-312-aarch64-linux-gnu.so": { "mode": 493, - "sha256": "c0fcfd5193cd11e52f22d8c804ace3b436f49aaa6655689c2f1903931544a977", - "size": 339976 + "sha256": "8cd40e577d35d9f6d263b82cd3538de9cbec1cfefb937eee62d8610fab1a55d8", + "size": 340016 }, "runtime": { "entries": { @@ -228,13 +228,13 @@ } }, "signatures": { - "python/iqpilot_private/models/__init__.cpython-312-aarch64-linux-gnu.so": "BaGn+mLXPAGLqnVJhDUt8C2ZEm1E9+MUCPoOnJhQGQybFOr36MuoubfpEgPoy1993Tm4IGD3pZASyFefJNXtBQ==", - "python/iqpilot_private/models/big_catalog.cpython-312-aarch64-linux-gnu.so": "DfeUTDggp3zRuVHoECcYdCliGhB1A/BdQoicWHddyTS4YptXxaow5Rads9qnmRIiBpSgR8d0vH9fwNxpQl0aBw==", - "python/iqpilot_private/models/egpu_model.cpython-312-aarch64-linux-gnu.so": "9sIFDj6iIVEUE+lxa3Ryk/djxgiPMu78MM/WQdjYfpVQNv2OQ7IkBu121iNa5XIv/CTFMl1G6KGTWO5/Qm9iBw==", - "python/iqpilot_private/models/emac_model_meta.cpython-312-aarch64-linux-gnu.so": "CjvP1I4QBJu6zRW75XHEUWX6F6Wks9xtnuu1hdjv/V2Vw11Vf+Wa8zCztpKBgMx3dzbQ/p++xpTf5p7TCoMyAA==", - "python/iqpilot_private/models/fetcher.cpython-312-aarch64-linux-gnu.so": "WNq4sNwhPeu7NuW+hj1UOv1lAiQN2k8lPwImfeS7vFLY0G+pUBpnCVhD49SmjMmPyfCoxJkxD+wdhogPT2u6DQ==", - "python/iqpilot_private/models/git_auth.cpython-312-aarch64-linux-gnu.so": "FJ7yptMwvQxz5kB6XLjNJKBDy3+jrwWsPe/KBa8ki/e6uNavH63Umu18z5e6aY4AYp9D8z0pBOt5lk1X+bFvBg==", - "python/iqpilot_private/models/helpers.cpython-312-aarch64-linux-gnu.so": "9sX2Peumx+BT3G+LRIbPtcs42mULnRiXJMbQq3esj7yfaGsbf3l5XQ/9BDr8U/A6aFWfatOYSwbFD37ZGdLxCg==", - "python/iqpilot_private/models/manager.cpython-312-aarch64-linux-gnu.so": "uyUgRSqgfhMcboJeDLTF1vAuw6thTLubkKp4wsn3i3VFAGkLzE0fEkhzoRo1TSn8hkb787kNQs+Z/woCPxi5AQ==" + "python/iqpilot_private/models/__init__.cpython-312-aarch64-linux-gnu.so": "gLnDq3G09ay0HyWUBNAUwdsG5UBZoVZB9WGa37xLga9AJa3Z36XI9orNi5/gdKFArIkjZXNk8RkRHfXauLQeBw==", + "python/iqpilot_private/models/big_catalog.cpython-312-aarch64-linux-gnu.so": "45g/h58OcdFMdfN2qL3qEgAjHDlCpgl6asqg5iC7uudqQ+hkhd5snuNG7k0mCrQJZGQQ8RoRITMUUxqi+P50CQ==", + "python/iqpilot_private/models/egpu_model.cpython-312-aarch64-linux-gnu.so": "2l6hQ1qK+k/rYrcnci9NwsZMXzhb+tdWkSrc8cIDgs0cvfPpzOmzTCDW9W2oKZpjmvV6fvKtIvc1mOutqc/NCA==", + "python/iqpilot_private/models/emac_model_meta.cpython-312-aarch64-linux-gnu.so": "ui3uSKS2m9PyKJOeFE5W8K6Qgzrl94JAig4eBGGJJjFcJ74r0fkdwj7Xft7g/DOjfNq0/1K5eynO41sRXGOWDw==", + "python/iqpilot_private/models/fetcher.cpython-312-aarch64-linux-gnu.so": "tcwYHuntp8+uT3+T6Yt6JcPNehom6gHoYHFs8vNtiXZ+ihYTUSCPx20apn+WdGKjwj7xZIsEgBzfpSBQgiKCAA==", + "python/iqpilot_private/models/git_auth.cpython-312-aarch64-linux-gnu.so": "RjXxVhDtSo/sqt3J5Ab6JZOqsYZUce9MltRBQ6VSEEnHXcJS/NhIrEOfodXJminO1EQxTw7nW/afbMUGM3FFBw==", + "python/iqpilot_private/models/helpers.cpython-312-aarch64-linux-gnu.so": "73KWi0yqKZPYwNMztjWYUY5GbD3B+flzrlmxrCo8NgDNA4q/flsjG4lhEdq6y0Q2UBSl0u3hRSsF/aSLKZeeBA==", + "python/iqpilot_private/models/manager.cpython-312-aarch64-linux-gnu.so": "k4ZfRTRE1kiKmwVclS2wa3ylNzt1XVuWkZS9AKuajtHkQc/08tQaIDcjAsVfKYJk5diHZICkMp5lX1fyOqdPCQ==" } } diff --git a/artifacts/iqpilot_model_selector_private/manifest.json.sig b/artifacts/iqpilot_model_selector_private/manifest.json.sig index 0c712184a..d1d10bfc3 100644 --- a/artifacts/iqpilot_model_selector_private/manifest.json.sig +++ b/artifacts/iqpilot_model_selector_private/manifest.json.sig @@ -1 +1 @@ -aZ2PpZxlTDJ1Nffu+hFtfKK0qyUkkllomgYgTX69J4YU4/aODiwBvJDwHZ6+1nlvv4fDA10s7SPNxwwP9j0OBA== +VKaSq35mXT1Nv9JNxFhrAse02ZheQGYFKtULc85QsP/MMkDHngMcXXA3NCtPaQ6D+jnrHIzHNdQpgz88UHfRCg== diff --git a/artifacts/iqpilot_model_selector_private/python/iqpilot_private/models/__init__.cpython-312-aarch64-linux-gnu.so b/artifacts/iqpilot_model_selector_private/python/iqpilot_private/models/__init__.cpython-312-aarch64-linux-gnu.so index 20382dc61..2480d4581 100755 Binary files a/artifacts/iqpilot_model_selector_private/python/iqpilot_private/models/__init__.cpython-312-aarch64-linux-gnu.so and b/artifacts/iqpilot_model_selector_private/python/iqpilot_private/models/__init__.cpython-312-aarch64-linux-gnu.so differ diff --git a/artifacts/iqpilot_model_selector_private/python/iqpilot_private/models/big_catalog.cpython-312-aarch64-linux-gnu.so b/artifacts/iqpilot_model_selector_private/python/iqpilot_private/models/big_catalog.cpython-312-aarch64-linux-gnu.so index d3018cfde..4f915d44a 100755 Binary files a/artifacts/iqpilot_model_selector_private/python/iqpilot_private/models/big_catalog.cpython-312-aarch64-linux-gnu.so and b/artifacts/iqpilot_model_selector_private/python/iqpilot_private/models/big_catalog.cpython-312-aarch64-linux-gnu.so differ diff --git a/artifacts/iqpilot_model_selector_private/python/iqpilot_private/models/egpu_model.cpython-312-aarch64-linux-gnu.so b/artifacts/iqpilot_model_selector_private/python/iqpilot_private/models/egpu_model.cpython-312-aarch64-linux-gnu.so index 5f4a6a621..899456c8d 100755 Binary files a/artifacts/iqpilot_model_selector_private/python/iqpilot_private/models/egpu_model.cpython-312-aarch64-linux-gnu.so and b/artifacts/iqpilot_model_selector_private/python/iqpilot_private/models/egpu_model.cpython-312-aarch64-linux-gnu.so differ diff --git a/artifacts/iqpilot_model_selector_private/python/iqpilot_private/models/emac_model_meta.cpython-312-aarch64-linux-gnu.so b/artifacts/iqpilot_model_selector_private/python/iqpilot_private/models/emac_model_meta.cpython-312-aarch64-linux-gnu.so index 9710587a4..3ce3cebee 100755 Binary files a/artifacts/iqpilot_model_selector_private/python/iqpilot_private/models/emac_model_meta.cpython-312-aarch64-linux-gnu.so and b/artifacts/iqpilot_model_selector_private/python/iqpilot_private/models/emac_model_meta.cpython-312-aarch64-linux-gnu.so differ diff --git a/artifacts/iqpilot_model_selector_private/python/iqpilot_private/models/fetcher.cpython-312-aarch64-linux-gnu.so b/artifacts/iqpilot_model_selector_private/python/iqpilot_private/models/fetcher.cpython-312-aarch64-linux-gnu.so index 3b763ab31..9e3b90c0d 100755 Binary files a/artifacts/iqpilot_model_selector_private/python/iqpilot_private/models/fetcher.cpython-312-aarch64-linux-gnu.so and b/artifacts/iqpilot_model_selector_private/python/iqpilot_private/models/fetcher.cpython-312-aarch64-linux-gnu.so differ diff --git a/artifacts/iqpilot_model_selector_private/python/iqpilot_private/models/git_auth.cpython-312-aarch64-linux-gnu.so b/artifacts/iqpilot_model_selector_private/python/iqpilot_private/models/git_auth.cpython-312-aarch64-linux-gnu.so index 5b939661b..c4d20492a 100755 Binary files a/artifacts/iqpilot_model_selector_private/python/iqpilot_private/models/git_auth.cpython-312-aarch64-linux-gnu.so and b/artifacts/iqpilot_model_selector_private/python/iqpilot_private/models/git_auth.cpython-312-aarch64-linux-gnu.so differ diff --git a/artifacts/iqpilot_model_selector_private/python/iqpilot_private/models/helpers.cpython-312-aarch64-linux-gnu.so b/artifacts/iqpilot_model_selector_private/python/iqpilot_private/models/helpers.cpython-312-aarch64-linux-gnu.so index 5f67a7413..ddca32207 100755 Binary files a/artifacts/iqpilot_model_selector_private/python/iqpilot_private/models/helpers.cpython-312-aarch64-linux-gnu.so and b/artifacts/iqpilot_model_selector_private/python/iqpilot_private/models/helpers.cpython-312-aarch64-linux-gnu.so differ diff --git a/artifacts/iqpilot_model_selector_private/python/iqpilot_private/models/manager.cpython-312-aarch64-linux-gnu.so b/artifacts/iqpilot_model_selector_private/python/iqpilot_private/models/manager.cpython-312-aarch64-linux-gnu.so index 53e81b991..728584ca0 100755 Binary files a/artifacts/iqpilot_model_selector_private/python/iqpilot_private/models/manager.cpython-312-aarch64-linux-gnu.so and b/artifacts/iqpilot_model_selector_private/python/iqpilot_private/models/manager.cpython-312-aarch64-linux-gnu.so differ diff --git a/iqpilot/selfdrive/iqmodeld/model_channel.py b/iqpilot/selfdrive/iqmodeld/model_channel.py index a9fa710bc..937a2d932 100644 --- a/iqpilot/selfdrive/iqmodeld/model_channel.py +++ b/iqpilot/selfdrive/iqmodeld/model_channel.py @@ -44,6 +44,14 @@ class ModelChannel: return None return frame_id + def peek(self) -> tuple[int | None, bool]: + seq, frame_id, length = HEADER.unpack(self.mm[:HEADER.size]) + if seq % 2 != 0: + return None, True + if seq == 0 or length == 0: + return None, False + return frame_id, False + def read(self) -> tuple[int, dict] | None: seq1, frame_id, length = HEADER.unpack(self.mm[:HEADER.size]) if seq1 == 0 or seq1 % 2 != 0 or length == 0: diff --git a/iqpilot/selfdrive/iqmodeld/modeld_selector.py b/iqpilot/selfdrive/iqmodeld/modeld_selector.py index 636b985b9..de1672a0c 100644 --- a/iqpilot/selfdrive/iqmodeld/modeld_selector.py +++ b/iqpilot/selfdrive/iqmodeld/modeld_selector.py @@ -110,7 +110,10 @@ def wait_for_big(big_channel, target: int, deadline: float, min_frame: int = -1, big_peek = None grab_at = deadline - 0.004 while time.perf_counter() < deadline: - bfid = big_channel.peek_frame_id() + bfid, writing = big_channel.peek() + if writing: + time.sleep(0.0002) + continue big_peek = bfid if bfid == target - 1 and time.perf_counter() < grab_at: time.sleep(0.0005) @@ -119,7 +122,8 @@ def wait_for_big(big_channel, target: int, deadline: float, min_frame: int = -1, got = big_channel.read() if got is not None and got[0] == bfid: return got[1], big_peek - break + time.sleep(0.0002) + continue if bfid is None or bfid <= min_frame or bfid > target + BIG_FUTURE_ACCEPT or target - bfid > max_lag_frames: break time.sleep(0.0005)