NeonXP/bluetooth
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

ninafw: should support muliple connections as a central

Browse source 
Signed-off-by: deadprogram <ron@hybridgroup.com>
This commit is contained in:
deadprogram 2024-01-19 00:33:07 +01:00 committed by BCG
parent 00a475adf1
commit 0a9bffe397
2 changed files with 20 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

20
adapter_ninafw.go
View file

@ -184,7 +184,7 @@ func (a *Adapter) startNotifications() {
println("notification received", not.connectionHandle, not.handle, not.data) println("notification received", not.connectionHandle, not.handle, not.data)
} }
d := a.findDevice(not.connectionHandle) d := a.findConnectedDevice(not.connectionHandle)
if d.deviceInternal == nil { if d.deviceInternal == nil {
if debug { if debug {
println("no device found for handle", not.connectionHandle) println("no device found for handle", not.connectionHandle)
@ -212,7 +212,23 @@ func (a *Adapter) startNotifications() {
}() }()
} }
func (a *Adapter) findDevice(handle uint16) Device { func (a *Adapter) addDevice(d Device) {
a.connectedDevices = append(a.connectedDevices, d)
}
func (a *Adapter) removeDevice(d Device) {
for i := range a.connectedDevices {
if d.handle == a.connectedDevices[i].handle {
copy(a.connectedDevices[i:], a.connectedDevices[i+1:])
a.connectedDevices[len(a.connectedDevices)-1] = Device{} // the zero value of T
a.connectedDevices = a.connectedDevices[:len(a.connectedDevices)-1]
return
}
}
}
func (a *Adapter) findConnectedDevice(handle uint16) Device {
for _, d := range a.connectedDevices { for _, d := range a.connectedDevices {
if d.handle == handle { if d.handle == handle {
if debug { if debug {

4
gap_ninafw.go
View file

@ -178,7 +178,7 @@ func (a *Adapter) Connect(address Address, params ConnectionParams) (Device, err
notificationRegistrations: make([]notificationRegistration, 0), notificationRegistrations: make([]notificationRegistration, 0),
}, },
} }
a.connectedDevices = append(a.connectedDevices, d) a.addDevice(d)
return d, nil return d, nil
@ -228,7 +228,7 @@ func (d Device) Disconnect() error {
return err return err
} }
d.adapter.connectedDevices = []Device{} d.adapter.removeDevice(d)
return nil return nil
} }