ios - iOS CoreBluetooth 仮想周辺機器の複数の通知

Question

20 バイトを超えるデータを Bluetooth LE セントラルに送信する必要がある iOS アプリケーションに取り組んでいます。ペリフェラル マネージャをセットアップし、20 バイトの各「パケット」を次々に送信します。true が返されたときにのみ次のパケットを送信します (false が返された場合は呼び出されperipheralManager.updatevalueた後に再試行します)。ほとんどの場合、これは機能しますが、約 20% の場合、送信されるデータは正しくありません。peripheralManagerIsReadyToUpdateSubscribersupdateValue

私は3つのパケットを持っています。ほとんどの場合、セントラルは A の次に B の次に C を受信しますが、セントラルは B の次に B の次に C を受信するか、A の次に C の次に C を受信することがあります。

常に 3 つの通知を送信していますが、値が正しくありません。

重要な場合：

特性の値はBLECharacteristicオブジェクトのインスタンスに保存されます

@objc public class BLECharacteristic: CBMutableCharacteristic{
    public var dynamicValue: Data?
    public override init(type UUID: CBUUID, properties: CBCharacteristicProperties, value: Data?, permissions: CBAttributePermissions){
        super.init(type: UUID, properties: properties, value: nil, permissions: permissions)
        self.dynamicValue = value
    }
    public convenience init(characteristic: CBCharacteristic){
        self.init(type: characteristic.uuid, properties: characteristic.properties, value: characteristic.value, permissions: CBAttributePermissions.readable)
    }
}

が呼び出された後に通知が送信されるように「バッファリング」されるperipheralManagerIsReadyToUpdateSubscribersと、情報はDelayedNotificationオブジェクトに格納されます。

@objc public class DelayedNotification: NSObject{
    private(set) var valueToNotify: Data
    private(set) var characteristic: BLECharacteristic
    private(set) var devicesToNotify: [CBCentral]?

    @objc public init(_ data: Data, _ char: BLECharacteristic, _ devsNotify: [CBCentral]?){
        valueToNotify = data
        characteristic = char
        devicesToNotify = devsNotify
    }
}

オブジェクトの作成時:

var valueToSend: Data
if(characteristic.dynamicValue == nil){
    valueToSend = Data()
}else{
    valueToSend = characteristic.dynamicValue!
}

buffer.append(DelayedNotification(valueToSend, characteristic, devicesToNotify))

編集：より多くのコード

private func notifyDevices(_ characteristic: BLECharacteristic){
    DispatchQueue.main.async {
        var valueToSend: Data
        if(characteristic.dynamicValue == nil){
            valueToSend = Data()
        }else{
            valueToSend = Data(characteristic.dynamicValue!)
        }

        self.notificationLock.wait()
        self.notBuffer.append(DelayedNotification(valueToSend, characteristic, nil))
        self.notificationLock.signal()

        self.processNotificationBuffer()
    }
}

private func processNotificationBuffer(){
    DispatchQueue.main.async{
        self.notificationLock.wait()

        for notification in self.notBuffer{
            let res = self.peripheralManager.updateValue(Data(notification.valueToNotify), for: notification.characteristic, onSubscribedCentrals: notification.devicesToNotify)
            if(res){
                NSLog("Sent: " + String(data: notification.valueToNotify, encoding: .utf8)!) // This is always printed in the right order
                notificationSent()
                self.notBuffer.remove(at: self.notBuffer.index(of: notification)!)
            }
        }

        self.notificationLock.signal()
    }
}

@objc public func peripheralManagerIsReady(toUpdateSubscribers peripheral: CBPeripheralManager) {
    processNotificationBuffer()
}