Skip to content

Pacing BLESS calls to work around BLE loss #484

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
AfromD wants to merge 2 commits into
base: master
Choose a base branch
from
Open

Pacing BLESS calls to work around BLE loss #484

Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
7bc039b
Added pacing for Bless calls
AfromD Mar 19, 2025
a1cf514
Bless call pacing, adjusted formatting
AfromD Mar 19, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
65 changes: 48 additions & 17 deletions pythoncode/bleBless.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -325,9 +325,32 @@ class clsFTMS_bless(clsBleServer):
def __init__(self, activate):
if UseBluetooth and activate:
super().__init__("FortiusAntTrainer", FitnessMachineGatt)
self.last_call_time = 0
self.min_interval = 1 / 500 # 500 times per second
else:
pass # Data structure is created, no actions

# --------------------------------------------------------------------------
# Ratelimitedcall
# --------------------------------------------------------------------------
# Input function parameters
#
# Function slows calling the bless library down
#
# Output returncode
# --------------------------------------------------------------------------

def rate_limited_call(self, func, *args, **kwargs):
current_time = time.time()
elapsed_time = current_time - self.last_call_time

if elapsed_time < self.min_interval:
time.sleep(self.min_interval - elapsed_time)

result = func(*args, **kwargs)
self.last_call_time = time.time()
return result

# --------------------------------------------------------------------------
# SetAthleteData, SetTrainerData, SetSteeringAngle
# --------------------------------------------------------------------------
Expand All @@ -354,9 +377,10 @@ def SetAthleteData(self, HeartRate):
if self.OK:
flags = 0
h = int(self.HeartRate) & 0xff # Avoid value anomalities
info = struct.pack (bc.little_endian + bc.unsigned_char * 2, flags, h)
self.BlessServer.get_characteristic(bc.cHeartRateMeasurementUUID).value = info
self.BlessServer.update_value(bc.sHeartRateUUID, bc.cHeartRateMeasurementUUID)
info = struct.pack(bc.little_endian + bc.unsigned_char * 2, flags, h)
characteristic = self.BlessServer.get_characteristic(bc.cHeartRateMeasurementUUID)
self.rate_limited_call(setattr, characteristic, "value", info)
self.rate_limited_call(self.BlessServer.update_value, bc.sHeartRateUUID, bc.cHeartRateMeasurementUUID,)
else:
self.logfileConsole("clsFTMS_bless.SetAthleteData() error, interface not open")

Expand Down Expand Up @@ -385,8 +409,9 @@ def SetTrainerData(self, CurrentSpeed, Cadence, CurrentPower):
p = int(self.CurrentPower) & 0xffff # Avoid value anomalities
info = struct.pack (bc.little_endian + bc.unsigned_short * 4, flags, s, c, p)

self.BlessServer.get_characteristic(bc.cIndoorBikeDataUUID).value = info
self.BlessServer.update_value(bc.sFitnessMachineUUID, bc.cIndoorBikeDataUUID)
characteristic = self.BlessServer.get_characteristic(bc.cIndoorBikeDataUUID)
self.rate_limited_call(setattr, characteristic, "value", info)
self.rate_limited_call(self.BlessServer.update_value, bc.sFitnessMachineUUID, bc.cIndoorBikeDataUUID,)
else:
self.logfileConsole("clsFTMS_bless.SetTrainerData() error, interface not open")

Expand All @@ -407,8 +432,9 @@ def SetSteeringAngle(self, SteeringAngle):
if self.OK:
a = SteeringAngle # Avoid value anomalities here (if needed)
info = struct.pack (bc.little_endian + bc.float, a)
self.BlessServer.get_characteristic(bc.cSteeringAngleUUID).value = info
self.BlessServer.update_value(bc.sSteeringUUID, bc.cSteeringAngleUUID)
characteristic = self.BlessServer.get_characteristic(bc.cSteeringAngleUUID)
self.rate_limited_call(setattr, characteristic, "value", info)
self.rate_limited_call(self.BlessServer.update_value, bc.sSteeringUUID, bc.cSteeringAngleUUID)
else:
self.logfileConsole("clsFTMS_bless.SetSteeringAngle() error, interface not open")

Expand Down Expand Up @@ -646,14 +672,16 @@ def WriteRequest(self,
def notifyStartOrResume(self):
self.logfileWrite("bleBless.notifyStartOrResume()")
info = struct.pack(bc.little_endian + bc.unsigned_char, bc.fms_FitnessMachineStartedOrResumedByUser)
self.BlessServer.get_characteristic(bc.cFitnessMachineStatusUUID).value = info
self.BlessServer.update_value(bc.sFitnessMachineUUID, bc.cFitnessMachineStatusUUID)
characteristic = self.BlessServer.get_characteristic(bc.cFitnessMachineStatusUUID)
self.rate_limited_call(setattr, characteristic, "value", info)
self.rate_limited_call(self.BlessServer.update_value, bc.sFitnessMachineUUID, bc.cFitnessMachineStatusUUID,)

def notifySetTargetPower(self):
self.logfileWrite("bleBless.notifySetTargetPower()")
info = struct.pack(bc.little_endian + bc.unsigned_char + bc.unsigned_short, bc.fms_TargetPowerChanged, self.TargetPower)
self.BlessServer.get_characteristic(bc.cFitnessMachineStatusUUID).value = info
self.BlessServer.update_value(bc.sFitnessMachineUUID, bc.cFitnessMachineStatusUUID)
characteristic = self.BlessServer.get_characteristic(bc.cFitnessMachineStatusUUID)
self.rate_limited_call(setattr, characteristic, "value", info)
self.rate_limited_call(self.BlessServer.update_value, bc.sFitnessMachineUUID, bc.cFitnessMachineStatusUUID,)

def notifySetIndoorBikeSimulation(self):
self.logfileWrite("bleBless.notifySetIndoorBikeSimulation()")
Expand All @@ -665,20 +693,23 @@ def notifySetIndoorBikeSimulation(self):

info = struct.pack(bc.little_endian + bc.unsigned_char + bc.short * 2 + bc.unsigned_char * 2,
bc.fms_IndoorBikeSimulationParametersChanged, windSpeed, grade, crr, cw)
self.BlessServer.get_characteristic(bc.cFitnessMachineStatusUUID).value = info
self.BlessServer.update_value(bc.sFitnessMachineUUID, bc.cFitnessMachineStatusUUID)
characteristic = self.BlessServer.get_characteristic(bc.cFitnessMachineStatusUUID)
self.rate_limited_call(setattr, characteristic, "value", info)
self.rate_limited_call(self.BlessServer.update_value, bc.sFitnessMachineUUID, bc.cFitnessMachineStatusUUID,)

def notifyStopOrPause(self):
self.logfileWrite("bleBless.notifyStopOrPause()")
info = struct.pack(bc.little_endian + bc.unsigned_char, bc.fms_FitnessMachineStoppedOrPausedByUser)
self.BlessServer.get_characteristic(bc.cFitnessMachineStatusUUID).value = info
self.BlessServer.update_value(bc.sFitnessMachineUUID, bc.cFitnessMachineStatusUUID)
characteristic = self.BlessServer.get_characteristic(bc.cFitnessMachineStatusUUID)
self.rate_limited_call(setattr, characteristic, "value", info)
self.rate_limited_call(self.BlessServer.update_value, bc.sFitnessMachineUUID, bc.cFitnessMachineStatusUUID,)

def notifyReset(self):
self.logfileWrite("bleBless.notifyReset()")
info = struct.pack(bc.little_endian + bc.unsigned_char, bc.fms_Reset)
self.BlessServer.get_characteristic(bc.cFitnessMachineStatusUUID).value = info
self.BlessServer.update_value(bc.sFitnessMachineUUID, bc.cFitnessMachineStatusUUID)
characteristic = self.BlessServer.get_characteristic(bc.cFitnessMachineStatusUUID)
self.rate_limited_call(setattr, characteristic, "value", info)
self.rate_limited_call(self.BlessServer.update_value, bc.sFitnessMachineUUID, bc.cFitnessMachineStatusUUID,)

# ------------------------------------------------------------------------------
# S i m u l a t o r
Expand Down