#include <IPAddressResolver.h>#include "DHT.h"#include <RpcMacros.h>#include <BaseRpc.h>#include <GlobalStatistics.h>Go to the source code of this file.
Functions | |
| Define_Module (DHT) | |
| std::ostream & | operator<< (std::ostream &os, const DHT::PendingRpcsEntry &entry) |
Definition in file DHT.cc.
| Define_Module | ( | DHT | ) |
| std::ostream& operator<< | ( | std::ostream & | os, | |
| const DHT::PendingRpcsEntry & | entry | |||
| ) |
Definition at line 957 of file DHT.cc.
{
if (entry.getCallMsg) {
os << "GET";
} else if (entry.putCallMsg) {
os << "PUT";
}
os << " state: " << entry.state
<< " numSent: " << entry.numSent
<< " numResponses: " << entry.numResponses
<< " numFailed: " << entry.numFailed
<< " numAvailableReplica: " << entry.numAvailableReplica;
if (entry.replica.size() > 0) {
os << " replicaSize: " << entry.replica.size();
}
if (entry.hashVector != NULL) {
os << " hashVectorSize: " << entry.hashVector->size();
}
if (entry.hashes.size() > 0) {
os << " hashes:";
std::map<BinaryValue, NodeVector>::const_iterator it;
int i = 0;
for (it = entry.hashes.begin(); it != entry.hashes.end(); it++, i++) {
os << " hash" << i << ":" << it->second.size();
}
}
return os;
}
1.7.1