Showing the changes to interface/src/DataServerClient.cpp (1 of 1 file). Show all
Unified · Split
| @@ -50,7 +50,7 @@ void DataServerClient::putValueForKey(const QString& key, const char* value) { · 49 unmodified lines | |||
| 50 | putPacket[numPacketBytes++] = '\0'; | 50 | putPacket[numPacketBytes++] = '\0'; |
| 51 | 51 | ||
| 52 | // add the putPacket to our vector of unconfirmed packets, will be deleted once put is confirmed | 52 | // add the putPacket to our vector of unconfirmed packets, will be deleted once put is confirmed |
| 53 | _unmatchedPackets.insert(std::pair<unsigned char*, int>(putPacket, numPacketBytes)); | 53 | // _unmatchedPackets.insert(std::pair<unsigned char*, int>(putPacket, numPacketBytes)); |
| 54 | 54 | ||
| 55 | // send this put request to the data server | 55 | // send this put request to the data server |
| 56 | NodeList::getInstance()->getNodeSocket()->send((sockaddr*) &DATA_SERVER_SOCKET, putPacket, numPacketBytes); | 56 | NodeList::getInstance()->getNodeSocket()->send((sockaddr*) &DATA_SERVER_SOCKET, putPacket, numPacketBytes); |
| @@ -88,7 +88,7 @@ void DataServerClient::getValuesForKeysAndUserString(const QStringList& keys, co · 31 unmodified lines | |||
| 88 | } | 88 | } |
| 89 | 89 | ||
| 90 | // add the getPacket to our vector of uncofirmed packets, will be deleted once we get a response from the nameserver | 90 | // add the getPacket to our vector of uncofirmed packets, will be deleted once we get a response from the nameserver |
| 91 | _unmatchedPackets.insert(std::pair<unsigned char*, int>(getPacket, numPacketBytes)); | 91 | // _unmatchedPackets.insert(std::pair<unsigned char*, int>(getPacket, numPacketBytes)); |
| 92 | 92 | ||
| 93 | // send the get to the data server | 93 | // send the get to the data server |
| 94 | NodeList::getInstance()->getNodeSocket()->send((sockaddr*) &DATA_SERVER_SOCKET, getPacket, numPacketBytes); | 94 | NodeList::getInstance()->getNodeSocket()->send((sockaddr*) &DATA_SERVER_SOCKET, getPacket, numPacketBytes); |
| @@ -151,7 +151,7 @@ void DataServerClient::processSendFromDataServer(unsigned char* packetData, int · 56 unmodified lines | |||
| 151 | } | 151 | } |
| 152 | 152 | ||
| 153 | // remove the matched packet from our map so it isn't re-sent to the data-server | 153 | // remove the matched packet from our map so it isn't re-sent to the data-server |
| 154 | removeMatchedPacketFromMap(packetData, numPacketBytes); | 154 | // removeMatchedPacketFromMap(packetData, numPacketBytes); |
| 155 | } | 155 | } |
| 156 | 156 | ||
| 157 | void DataServerClient::processMessageFromDataServer(unsigned char* packetData, int numPacketBytes) { | 157 | void DataServerClient::processMessageFromDataServer(unsigned char* packetData, int numPacketBytes) { |