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

maintain a double ended queue of created assignments

Browse source
This commit is contained in:
Stephen Birarda 2013-09-05 16:38:48 -07:00
parent 5e4d4b4651
commit d498d97da7
1 changed files with 26 additions and 21 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

47
assignment-server/src/main.cpp
View file

@ -21,7 +21,7 @@ const int MAX_PACKET_SIZE_BYTES = 1400;
int main(int argc, const char* argv[]) { int main(int argc, const char* argv[]) {
std::queue<Assignment> assignmentQueue; std::deque<Assignment> assignmentQueue;
sockaddr_in senderSocket; sockaddr_in senderSocket;
unsigned char senderData[MAX_PACKET_SIZE_BYTES] = {}; unsigned char senderData[MAX_PACKET_SIZE_BYTES] = {};
@ -38,43 +38,48 @@ int main(int argc, const char* argv[]) {
// construct the requested assignment from the packet data // construct the requested assignment from the packet data
Assignment requestAssignment(senderData, receivedBytes); Assignment requestAssignment(senderData, receivedBytes);
// grab the first assignment in the queue, if it exists qDebug() << "Received request for assignment:" << requestAssignment;
// make sure there are assignments in the queue at all
if (assignmentQueue.size() > 0) { if (assignmentQueue.size() > 0) {
Assignment firstAssignment = assignmentQueue.front();
bool eitherHasPool = (firstAssignment.getPool() || requestAssignment.getPool()); // enumerate assignments until we find one to give this client (if possible)
bool bothHavePool = (firstAssignment.getPool() && requestAssignment.getPool()); for (std::deque<Assignment>::iterator assignment = assignmentQueue.begin();
assignment != assignmentQueue.end();
// make sure there is a pool match for the created and requested assignment assignment++) {
// or that neither has a designated pool
if ((eitherHasPool && bothHavePool && strcmp(firstAssignment.getPool(), requestAssignment.getPool()) == 0)
|| !eitherHasPool) {
assignmentQueue.pop();
int numAssignmentBytes = firstAssignment.packToBuffer(assignmentPacket + numSendHeaderBytes); bool eitherHasPool = (assignment->getPool() || requestAssignment.getPool());
bool bothHavePool = (assignment->getPool() && requestAssignment.getPool());
// send the assignment // make sure there is a pool match for the created and requested assignment
serverSocket.send((sockaddr*) &senderSocket, assignmentPacket, numSendHeaderBytes + numAssignmentBytes); // or that neither has a designated pool
if ((eitherHasPool && bothHavePool
&& strcmp(assignment->getPool(), requestAssignment.getPool()) == 0)
|| !eitherHasPool) {
assignmentQueue.erase(assignment);
int numAssignmentBytes = assignment->packToBuffer(assignmentPacket + numSendHeaderBytes);
// send the assignment
serverSocket.send((sockaddr*) &senderSocket,
assignmentPacket,
numSendHeaderBytes + numAssignmentBytes);
}
} }
} }
} else if (senderData[0] == PACKET_TYPE_CREATE_ASSIGNMENT && packetVersionMatch(senderData)) { } else if (senderData[0] == PACKET_TYPE_CREATE_ASSIGNMENT && packetVersionMatch(senderData)) {
// construct the create assignment from the packet data // construct the create assignment from the packet data
Assignment createdAssignment(senderData, receivedBytes); Assignment createdAssignment(senderData, receivedBytes);
qDebug() << "Received an assignment:" << createdAssignment; qDebug() << "Received a created assignment:" << createdAssignment;
// assignment server is on a public server // assignment server is on a public server
// assume that the address we now have for the sender is the public address/port // assume that the address we now have for the sender is the public address/port
// and store that with the assignment so it can be given to the requestor later // and store that with the assignment so it can be given to the requestor later
createdAssignment.setDomainSocket((sockaddr*) &senderSocket); createdAssignment.setDomainSocket((sockaddr*) &senderSocket);
// until we have a GUID setup just keep the latest assignment
if (assignmentQueue.size() > 0) {
assignmentQueue.pop();
}
// add this assignment to the queue // add this assignment to the queue
assignmentQueue.push(createdAssignment); assignmentQueue.push_back(createdAssignment);
} }
} }
} }