cbgo/l2cap.m at master · tinygo-org/cbgo · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
#import <Foundation/Foundation.h>
#import <CoreBluetooth/CoreBluetooth.h>
#import "bt.h"

// l2cap.m: L2CAP Connection-Oriented Channel support (macOS 10.13+)

void cb_prph_open_l2cap_channel(void *prph, uint16_t psm) {
    CBPeripheral *p = (CBPeripheral *)prph;
    [p openL2CAPChannel:(CBL2CAPPSM)psm];
}

uint16_t cb_l2cap_psm(void *channel) {
    CBL2CAPChannel *ch = (CBL2CAPChannel *)channel;
    return ch.PSM;
}

int cb_l2cap_read(void *channel, uint8_t *buf, int maxLen) {
    CBL2CAPChannel *ch = (CBL2CAPChannel *)channel;
    NSInputStream *stream = ch.inputStream;
    if (![stream hasBytesAvailable]) {
        return 0;
    }
    return (int)[stream read:buf maxLength:maxLen];
}

int cb_l2cap_write(void *channel, const uint8_t *data, int len) {
    CBL2CAPChannel *ch = (CBL2CAPChannel *)channel;
    NSOutputStream *stream = ch.outputStream;
    if (![stream hasSpaceAvailable]) {
        return 0;
    }
    return (int)[stream write:data maxLength:len];
}

struct bt_error cb_l2cap_input_stream_error(void *channel) {
    CBL2CAPChannel *ch = (CBL2CAPChannel *)channel;
    NSInputStream *stream = ch.inputStream;
    if (stream.streamStatus == NSStreamStatusError) {
        return nserror_to_bt_error(stream.streamError);
    }
    return (struct bt_error){0};
}

struct bt_error cb_l2cap_output_stream_error(void *channel) {
    CBL2CAPChannel *ch = (CBL2CAPChannel *)channel;
    NSOutputStream *stream = ch.outputStream;
    if (stream.streamStatus == NSStreamStatusError) {
        return nserror_to_bt_error(stream.streamError);
    }
    return (struct bt_error){0};
}

bool cb_l2cap_has_bytes_available(void *channel) {
    CBL2CAPChannel *ch = (CBL2CAPChannel *)channel;
    return [ch.inputStream hasBytesAvailable];
}

bool cb_l2cap_has_space_available(void *channel) {
    CBL2CAPChannel *ch = (CBL2CAPChannel *)channel;
    return [ch.outputStream hasSpaceAvailable];
}

void cb_l2cap_schedule_streams(void *channel) {
    CBL2CAPChannel *ch = (CBL2CAPChannel *)channel;
    NSRunLoop *rl = [NSRunLoop mainRunLoop];
    [ch.inputStream scheduleInRunLoop:rl forMode:NSDefaultRunLoopMode];
    [ch.outputStream scheduleInRunLoop:rl forMode:NSDefaultRunLoopMode];
    [ch.inputStream open];
    [ch.outputStream open];
}

void cb_l2cap_close(void *channel) {
    CBL2CAPChannel *ch = (CBL2CAPChannel *)channel;
    NSRunLoop *rl = [NSRunLoop mainRunLoop];
    [ch.inputStream close];
    [ch.outputStream close];
    [ch.inputStream removeFromRunLoop:rl forMode:NSDefaultRunLoopMode];
    [ch.outputStream removeFromRunLoop:rl forMode:NSDefaultRunLoopMode];
    [ch release];
}

void cb_pmgr_publish_l2cap_channel(void *pmgr, bool encryption) {
    CBPeripheralManager *pm = (CBPeripheralManager *)pmgr;
    [pm publishL2CAPChannelWithEncryption:encryption];
}

void cb_pmgr_unpublish_l2cap_channel(void *pmgr, uint16_t psm) {
    CBPeripheralManager *pm = (CBPeripheralManager *)pmgr;
    [pm unpublishL2CAPChannel:(CBL2CAPPSM)psm];
}