Mirrors/overte-JulianGro
3
0
Fork 0
mirror of https://github.com/JulianGro/overte.git synced 2025-04-16 22:30:42 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

accept a local address and port from requestor

Browse source
This commit is contained in:
Stephen Birarda 2013-05-03 12:22:20 -07:00
parent 5f26d44fd8
commit d0444ee5b7
1 changed files with 16 additions and 11 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

27
pairing-server/src/main.cpp
View file

@ -36,15 +36,15 @@ int main(int argc, const char* argv[]) {
UDPSocket serverSocket(PAIRING_SERVER_LISTEN_PORT);
sockaddr_in senderSocket;
char deviceData[MAX_PACKET_SIZE_BYTES] = {};
char senderData[MAX_PACKET_SIZE_BYTES] = {};
ssize_t receivedBytes = 0;
std::vector<PairableDevice> devices;
while (true) {
if (serverSocket.receive((sockaddr *)&senderSocket, &deviceData, &receivedBytes)) {
if (serverSocket.receive((sockaddr *)&senderSocket, &senderData, &receivedBytes)) {
if (deviceData[0] == 'A') {
if (senderData[0] == 'A') {
// this is a device reporting itself as available
// create a new PairableDevice
@ -53,7 +53,7 @@ int main(int argc, const char* argv[]) {
int addressBytes[4];
int socketPort = 0;
int numMatches = sscanf(deviceData, "A %s %d.%d.%d.%d:%d %s",
int numMatches = sscanf(senderData, "Available %s %d.%d.%d.%d:%d %s",
newDevice.identifier,
&addressBytes[3],
&addressBytes[2],
@ -80,18 +80,23 @@ int main(int argc, const char* argv[]) {
printf("Adding device %s (%s) to list\n", newDevice.identifier, newDevice.name);
devices.push_back(newDevice);
}
} else if (deviceData[0] == 'P') {
} else if (senderData[0] == 'F') {
// this is a client looking to pair with a device
// send the most recent device this address so it can attempt to pair
char requestorSocketString[INET_ADDRSTRLEN + 6] = {};
char requestorAddress[INET_ADDRSTRLEN];
inet_ntop(AF_INET, &(senderSocket.sin_addr), requestorAddress, INET_ADDRSTRLEN);
char requestorAddress[INET_ADDRSTRLEN] = {};
int requestorPort = 0;
sprintf(requestorSocketString, "%s:%d", requestorAddress, ntohs(senderSocket.sin_port));
int requestorMatches = sscanf(senderData, "Find %[^:]:%d", requestorAddress, &requestorPort);
PairableDevice lastDevice = devices[devices.size() - 1];
serverSocket.send((sockaddr*) &lastDevice.sendingSocket, requestorSocketString, strlen(requestorSocketString));
if (requestorMatches == 2) {
PairableDevice lastDevice = devices[devices.size() - 1];
char pairData[INET_ADDRSTRLEN + 6] = {};
sprintf(pairData, "%s:%d", requestorAddress, requestorPort);
serverSocket.send((sockaddr*) &lastDevice.sendingSocket, pairData, strlen(pairData));
}
}
}
}