Mirrors/overte
3
0
Fork 0
mirror of https://github.com/overte-org/overte.git synced 2025-08-09 16:41:02 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions 2

keep one last PairableDevice and one last RequestingClient

Browse source
This commit is contained in:
Stephen Birarda 2013-05-13 16:14:17 -07:00
parent 3fdd9c5a39
commit 0f9d72e2c1
1 changed files with 44 additions and 25 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -24,6 +24,15 @@ struct PairableDevice {
sockaddr_in localSocket; sockaddr_in localSocket;
}; };
struct RequestingClient {
char address[INET_ADDRSTRLEN];
int port;
};
UDPSocket serverSocket(PAIRING_SERVER_LISTEN_PORT);
PairableDevice *lastDevice = NULL;
RequestingClient *lastClient = NULL;
int indexOfFirstOccurenceOfCharacter(char* haystack, char needle) { int indexOfFirstOccurenceOfCharacter(char* haystack, char needle) {
int currentIndex = 0; int currentIndex = 0;
@ -34,70 +43,80 @@ int indexOfFirstOccurenceOfCharacter(char* haystack, char needle) {
return currentIndex; return currentIndex;
} }
void sendLastClientToLastDevice() {
char pairData[INET_ADDRSTRLEN + 6] = {};
int bytesWritten = sprintf(pairData, "%s:%d", ::lastClient->address, ::lastClient->port);
::serverSocket.send((sockaddr*) &::lastDevice->sendingSocket, pairData, bytesWritten);
}
int main(int argc, const char* argv[]) { int main(int argc, const char* argv[]) {
UDPSocket serverSocket(PAIRING_SERVER_LISTEN_PORT);
sockaddr_in senderSocket; sockaddr_in senderSocket;
char senderData[MAX_PACKET_SIZE_BYTES] = {}; char senderData[MAX_PACKET_SIZE_BYTES] = {};
ssize_t receivedBytes = 0; ssize_t receivedBytes = 0;
std::vector<PairableDevice> devices;
while (true) { while (true) {
if (serverSocket.receive((sockaddr *)&senderSocket, &senderData, &receivedBytes)) { if (::serverSocket.receive((sockaddr *)&senderSocket, &senderData, &receivedBytes)) {
if (senderData[0] == 'A') { if (senderData[0] == 'A') {
// this is a device reporting itself as available // this is a device reporting itself as available
// create a new PairableDevice PairableDevice tempDevice = {};
PairableDevice newDevice = {};
char deviceAddress[INET_ADDRSTRLEN] = {}; char deviceAddress[INET_ADDRSTRLEN] = {};
int socketPort = 0; int socketPort = 0;
int numMatches = sscanf(senderData, "Available %s%[^:]:%d %s", int numMatches = sscanf(senderData, "Available %s%[^:]:%d %s",
newDevice.identifier, tempDevice.identifier,
deviceAddress, deviceAddress,
&socketPort, &socketPort,
newDevice.name); tempDevice.name);
if (numMatches >= 3) { if (numMatches >= 3) {
// if we have fewer than 6 matches the packet wasn't properly formatted // if we have fewer than 3 matches the packet wasn't properly formatted
// otherwise copy the tempDevice to the persisting lastDevice
*::lastDevice = tempDevice;
// setup the localSocket for the pairing device // setup the localSocket for the pairing device
newDevice.localSocket.sin_family = AF_INET; ::lastDevice->localSocket.sin_family = AF_INET;
inet_pton(AF_INET, deviceAddress, &newDevice); inet_pton(AF_INET, deviceAddress, &::lastDevice);
newDevice.localSocket.sin_port = socketPort; ::lastDevice->localSocket.sin_port = socketPort;
// store this device's sending socket so we can talk back to it // store this device's sending socket so we can talk back to it
newDevice.sendingSocket = senderSocket; ::lastDevice->sendingSocket = senderSocket;
// push this new device into the vector // push this new device into the vector
printf("Adding device %s (%s) - %s:%d to list\n", printf("Adding device %s (%s) - %s:%d to list\n",
newDevice.identifier, ::lastDevice->identifier,
newDevice.name, ::lastDevice->name,
deviceAddress, deviceAddress,
socketPort); socketPort);
devices.push_back(newDevice); if (::lastClient) {
sendLastClientToLastDevice();
}
} }
} else if (senderData[0] == 'F') { } else if (senderData[0] == 'F') {
// this is a client looking to pair with a device // this is a client looking to pair with a device
// send the most recent device this address so it can attempt to pair // send the most recent device this address so it can attempt to pair
char requestorAddress[INET_ADDRSTRLEN] = {}; RequestingClient tempClient = {};
int requestorPort = 0;
int requestorMatches = sscanf(senderData, "Find %[^:]:%d", requestorAddress, &requestorPort); int requestorMatches = sscanf(senderData, "Find %[^:]:%d",
printf("Find request from interface client at %s:%d\n", requestorAddress, requestorPort); tempClient.address,
&tempClient.port);
if (requestorMatches == 2) { if (requestorMatches == 2) {
PairableDevice lastDevice = devices[devices.size() - 1]; // good data, copy the tempClient to the persisting lastInterfaceClient
*::lastClient = tempClient;
char pairData[INET_ADDRSTRLEN + 6] = {}; printf("Find request from interface client at %s:%d\n",
sprintf(pairData, "%s:%d", requestorAddress, requestorPort); ::lastClient->address,
::lastClient->port);
serverSocket.send((sockaddr*) &lastDevice.sendingSocket, pairData, strlen(pairData)); if (::lastDevice) {
sendLastClientToLastDevice();
}
} }
} }
} }