Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
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
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,194 @@ | ||
| /* YaNFD - Yet another NDN Forwarding Daemon | ||
| * | ||
| * Copyright (C) 2020-2024 Eric Newberry. | ||
| * | ||
| * This file is licensed under the terms of the MIT License, as found in LICENSE.md. | ||
| */ | ||
|
|
||
| package face | ||
|
|
||
| import ( | ||
| "strconv" | ||
| "sync" | ||
|
|
||
| "github.com/named-data/YaNFD/core" | ||
| "github.com/named-data/YaNFD/ndn" | ||
| "github.com/named-data/YaNFD/ndn/tlv" | ||
| "tinygo.org/x/bluetooth" | ||
| ) | ||
|
|
||
| // const BLEMTU = 512 // See esp8266ndn, it uses 512 & 517 | ||
| // Note that this MTU does not match the real MTU: tinygo/bluetooth only supports the default 23 | ||
|
|
||
| const BLERealMTU = 20 | ||
|
|
||
| var ( | ||
| serviceUUID = bluetooth.NewUUID([16]byte{0x09, 0x95, 0x77, 0xe3, 0x07, 0x88, 0x41, 0x2a, 0x88, 0x24, 0x39, 0x50, 0x84, 0xd9, 0x73, 0x91}) | ||
| csUUID = bluetooth.NewUUID([16]byte{0xcc, 0x5a, 0xbb, 0x89, 0xa5, 0x41, 0x46, 0xd8, 0xa3, 0x51, 0x2f, 0x95, 0xa6, 0xa8, 0x1f, 0x49}) | ||
| scUUID = bluetooth.NewUUID([16]byte{0x97, 0x2f, 0x95, 0x27, 0x0d, 0x83, 0x42, 0x61, 0xb9, 0x5d, 0xb1, 0xb2, 0xfc, 0x73, 0xbd, 0xe4}) | ||
| ) | ||
|
|
||
| // BLEPeripheral is a Bluetooth Low Energy GATT transport, running as a peripheral. | ||
| type BLEPeripheral struct { | ||
| transportBase | ||
|
|
||
| cs bluetooth.Characteristic | ||
| sc bluetooth.Characteristic | ||
| recvBuf []byte | ||
| startPos int | ||
| adv *bluetooth.Advertisement | ||
|
Check failure on line 39 in face/ble-peripheral.go
|
||
| lock sync.Mutex | ||
| } | ||
|
|
||
| var _ transport = &BLEPeripheral{} // trait | ||
|
|
||
| // NewBLEPeripheral creates a BLE transport. | ||
| func NewBLEPeripheral(localName string) (t *BLEPeripheral, err error) { | ||
| remoteURI := ndn.MakeBLEURI(localName, serviceUUID.String()) | ||
| t = &BLEPeripheral{ | ||
| cs: bluetooth.Characteristic{}, | ||
| sc: bluetooth.Characteristic{}, | ||
| recvBuf: make([]byte, tlv.MaxNDNPacketSize), | ||
| startPos: 0, | ||
| } | ||
|
|
||
| adapter := bluetooth.DefaultAdapter | ||
| err = adapter.Enable() | ||
| if err != nil { | ||
| core.LogError(nil, "Unable to start BLE adaptor: ", err) | ||
| t = nil | ||
| return | ||
| } | ||
| t.adv = adapter.DefaultAdvertisement() | ||
|
Check failure on line 62 in face/ble-peripheral.go
|
||
| err = t.adv.Configure(bluetooth.AdvertisementOptions{ | ||
| LocalName: localName, | ||
| ServiceUUIDs: []bluetooth.UUID{serviceUUID}, | ||
| }) | ||
| if err != nil { | ||
| core.LogError(nil, "Unable to start BLE advertiser: ", err) | ||
| t = nil | ||
| return | ||
| } | ||
| err = t.adv.Start() | ||
| if err != nil { | ||
| core.LogError(nil, "Unable to start BLE advertiser: ", err) | ||
| t = nil | ||
| return | ||
| } | ||
|
|
||
| err = adapter.AddService(&bluetooth.Service{ | ||
|
Check failure on line 79 in face/ble-peripheral.go
|
||
| UUID: serviceUUID, | ||
| Characteristics: []bluetooth.CharacteristicConfig{ | ||
| { | ||
| Handle: &t.cs, | ||
| UUID: csUUID, | ||
| Flags: (bluetooth.CharacteristicWritePermission | | ||
| bluetooth.CharacteristicWriteWithoutResponsePermission | | ||
| bluetooth.CharacteristicNotifyPermission), | ||
| WriteEvent: t.onWrite, | ||
| }, | ||
| { | ||
| Handle: &t.sc, | ||
| UUID: scUUID, | ||
| Flags: bluetooth.CharacteristicNotifyPermission | bluetooth.CharacteristicReadPermission, | ||
| }, | ||
| }, | ||
| }) | ||
| if err != nil { | ||
| core.LogError(nil, "Unable to start BLE service: ", err) | ||
| t = nil | ||
| return | ||
| } | ||
|
|
||
| scope := ndn.NonLocal | ||
| t.makeTransportBase(remoteURI, remoteURI, PersistencyPermanent, scope, ndn.MultiAccess, tlv.MaxNDNPacketSize) | ||
| t.changeState(ndn.Up) | ||
| return | ||
| } | ||
|
|
||
| func (t *BLEPeripheral) String() string { | ||
| return "BLEPeripheral, FaceID=" + strconv.FormatUint(t.faceID, 10) | ||
| } | ||
|
|
||
| // SetPersistency changes the persistency of the face. | ||
| func (t *BLEPeripheral) SetPersistency(persistency Persistency) bool { | ||
| return persistency == PersistencyPermanent | ||
| } | ||
|
|
||
| // GetSendQueueSize returns the current size of the send queue. | ||
| func (t *BLEPeripheral) GetSendQueueSize() uint64 { | ||
| return 0 | ||
| } | ||
|
|
||
| func (t *BLEPeripheral) sendFrame(frame []byte) { | ||
| sendBuf := make([]byte, BLERealMTU+2) | ||
| first := true | ||
| t.lock.Lock() | ||
| defer t.lock.Unlock() | ||
| for len(frame) != 0 { | ||
| // Chop off up to 20 bytes from the sendbuf. | ||
| partlen := BLERealMTU | ||
| if len(frame) < BLERealMTU { | ||
| partlen = len(frame) | ||
| } | ||
| part := frame[:partlen] | ||
| frame = frame[partlen:] | ||
| // This also sends a notification. | ||
| copy(sendBuf[1:], part) | ||
| if first { | ||
| sendBuf[0] = 1 // start | ||
| first = false | ||
| } else if len(frame) == 0 { | ||
| sendBuf[0] = 2 // end | ||
| } else { | ||
| sendBuf[0] = 0 // middle | ||
| } | ||
| _, err := t.sc.Write(sendBuf[:1+partlen]) | ||
|
Check failure on line 146 in face/ble-peripheral.go
|
||
| if err != nil { | ||
| core.LogError(t, "Unable to write BLE frame", err) | ||
| } | ||
| } | ||
| t.nOutBytes += uint64(len(frame)) | ||
| } | ||
|
|
||
| func (t *BLEPeripheral) changeState(new ndn.State) { | ||
| if t.state == new { | ||
| return | ||
| } | ||
|
|
||
| core.LogInfo(t, "state: ", t.state, " -> ", new) | ||
| t.state = new | ||
|
|
||
| if t.state != ndn.Up { | ||
| core.LogInfo(t, "Closing BLE socket") | ||
| t.hasQuit <- true | ||
| t.adv.Stop() | ||
|
|
||
| // Stop link service | ||
| t.linkService.tellTransportQuit() | ||
|
|
||
| FaceTable.Remove(t.faceID) | ||
| } | ||
| } | ||
|
|
||
| func (t *BLEPeripheral) onWrite(client bluetooth.Connection, offset int, value []byte) { | ||
| // Then do reassembly | ||
| if value[0] == 1 { | ||
| // Start | ||
| t.startPos = 0 | ||
| } | ||
| nCopied := copy(t.recvBuf[t.startPos:], value[1:]) | ||
| t.startPos += nCopied | ||
| if value[0] == 2 { | ||
| // End | ||
| t.linkService.handleIncomingFrame(t.recvBuf[:t.startPos]) | ||
|
|
||
| // bounce back the packet to other clients | ||
| bounceBuf := make([]byte, t.startPos) | ||
| copy(bounceBuf, t.recvBuf[:t.startPos]) | ||
| go t.sendFrame(bounceBuf) | ||
|
|
||
| t.startPos = 0 | ||
| } | ||
| t.nInBytes += uint64(len(value) - 1) | ||
| } | ||
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
Oops, something went wrong.