std::string accName = "local server '";
accName += anna::functions::socketLiteralAsString(a_key.first, a_key.second);
accName += "' on origin-realm '";
- accName += a_engine ? a_engine->getOriginRealm() : "unknown"; // it should be known (createServer)
+ accName += a_engine ? a_engine->getOriginRealmName() : "unknown"; // it should be known (createServer)
accName += "' and origin-host '";
- accName += a_engine ? a_engine->getOriginHost() : "unknown"; // it should be known (createServer)
+ accName += a_engine ? a_engine->getOriginHostName() : "unknown"; // it should be known (createServer)
accName += "'";
a_messageStatistics.initialize(accName);
}
LocalServer::serverSession_key LocalServer::getServerSessionKey(const anna::comm::ClientSocket &clientSocket) const throw() {
- return (anna::functions::exclusiveHash(clientSocket.getRemoteAccessPoint().getINetAddress().serialize()));
+ return (anna::functions::hash(clientSocket.getRemoteAccessPoint().getINetAddress().serialize().c_str()));
}
}
// Inform local server (availability changes):
- bool changes = refreshAvailability();
+ refreshAvailability();
+
// OAM
OamModule &oamModule = OamModule::instantiate();
oamModule.count(OamModule::Counter::CreatedConnectionForServerSession);
result->setClientSocket((anna::comm::ClientSocket*)(&clientSocket));
result->a_parent = this;
result->a_socketId = key; // de momento...
- result->initializeSequences(); // despu�s de asignar el LocalServer y el socketId (*)
- // (*) Las secuencias se basan en la semilla: srand(::time(NULL) + anna::functions::exclusiveHash(anna::functions::asString("%s:%d|%d", getAddress().c_str(), getPort(), a_socketId)));
+ result->initializeSequences(); // despues de asignar el LocalServer y el socketId (sequences are seed-based by mean exclusive hash)
result->a_engine = a_engine;
a_serverSessions.insert(serverSession_value_type(key, result));
newConnection();
// Send:
try {
- const Response* response = a_lastUsedResource->send(message);
+ a_lastUsedResource->send(message);
return true; // no matter if response is NULL (answers, i.e.) or not.
} catch(anna::RuntimeException &ex) {
ex.trace();
bool LocalServer::broadcast(const Message* message) throw(anna::RuntimeException) {
LOGMETHOD(anna::TraceMethod tttm("diameter::comm::LocalServer", "broadcast", ANNA_FILE_LOCATION));
- const Response* response;
bool allok = true;
for(serverSession_iterator it = serverSession_begin(); it != serverSession_end(); it++) {
try {
- response = serverSession(it)->send(message);
+ serverSession(it)->send(message);
} catch(anna::RuntimeException &ex) {
ex.trace();
allok = false;