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
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
|
/*
* BRLTTY - A background process providing access to the console screen (when in
* text mode) for a blind person using a refreshable braille display.
*
* Copyright (C) 1995-2010 by The BRLTTY Developers.
*
* BRLTTY comes with ABSOLUTELY NO WARRANTY.
*
* This is free software, placed under the terms of the
* GNU General Public License, as published by the Free Software
* Foundation; either version 2 of the License, or (at your option) any
* later version. Please see the file LICENSE-GPL for details.
*
* Web Page: http://mielke.cc/brltty/
*
* This software is maintained by Dave Mielke <dave@mielke.cc>.
*/
#include "prologue.h"
#include <errno.h>
#include <sys/socket.h>
#include <bluetooth/bluetooth.h>
#include <bluetooth/rfcomm.h>
#include "log.h"
#include "io_bluetooth.h"
#include "bluetooth_internal.h"
#include "io_misc.h"
struct BluetoothConnectionExtensionStruct {
int socket;
struct sockaddr_rc local;
struct sockaddr_rc remote;
};
BluetoothConnectionExtension *
bthConnect (uint64_t bda, uint8_t channel) {
BluetoothConnectionExtension *bcx;
if ((bcx = malloc(sizeof(*bcx)))) {
memset(bcx, 0, sizeof(*bcx));
if ((bcx->socket = socket(PF_BLUETOOTH, SOCK_STREAM, BTPROTO_RFCOMM)) != -1) {
bcx->local.rc_family = AF_BLUETOOTH;
bcx->local.rc_channel = 0;
bacpy(&bcx->local.rc_bdaddr, BDADDR_ANY); /* Any HCI. No support for explicit
* interface specification yet.
*/
if (bind(bcx->socket, (struct sockaddr *)&bcx->local, sizeof(bcx->local)) != -1) {
bcx->remote.rc_family = AF_BLUETOOTH;
bcx->remote.rc_channel = channel;
{
int index;
for (index=0; index<BDA_SIZE; index+=1) {
bcx->remote.rc_bdaddr.b[index] = bda & 0XFF;
bda >>= 8;
}
}
if (connect(bcx->socket, (struct sockaddr *)&bcx->remote, sizeof(bcx->remote)) != -1) {
if (setBlockingIo(bcx->socket, 0)) {
return bcx;
}
} else if ((errno != EHOSTDOWN) && (errno != EHOSTUNREACH)) {
LogError("RFCOMM connect");
}
} else {
LogError("RFCOMM bind");
}
close(bcx->socket);
} else {
LogError("RFCOMM socket");
}
free(bcx);
} else {
LogError("malloc");
}
return NULL;
}
void
bthDisconnect (BluetoothConnectionExtension *bcx) {
close(bcx->socket);
free(bcx);
}
int
bthAwaitInput (BluetoothConnection *connection, int milliseconds) {
BluetoothConnectionExtension *bcx = connection->extension;
return awaitInput(bcx->socket, milliseconds);
}
ssize_t
bthReadData (
BluetoothConnection *connection, void *buffer, size_t size,
int initialTimeout, int subsequentTimeout
) {
BluetoothConnectionExtension *bcx = connection->extension;
return readData(bcx->socket, buffer, size, initialTimeout, subsequentTimeout);
}
ssize_t
bthWriteData (BluetoothConnection *connection, const void *buffer, size_t size) {
BluetoothConnectionExtension *bcx = connection->extension;
return writeData(bcx->socket, buffer, size);
}
|
