blob: 3fdfb560a091792c7acf3f0ad6a813d9f7d72fdd [file] [log] [blame]
// Copyright 2014 The Chromium Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#include "remoting/client/client_status_logger.h"
#include "base/macros.h"
#include "base/rand_util.h"
#include "remoting/client/chromoting_stats.h"
#include "remoting/client/server_log_entry_client.h"
using remoting::protocol::ConnectionToHost;
namespace {
const char kSessionIdAlphabet[] =
"abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ1234567890";
const int kSessionIdLength = 20;
const int kMaxSessionIdAgeDays = 1;
bool IsStartOfSession(ConnectionToHost::State state) {
return state == ConnectionToHost::INITIALIZING ||
state == ConnectionToHost::CONNECTING ||
state == ConnectionToHost::AUTHENTICATED ||
state == ConnectionToHost::CONNECTED;
}
bool IsEndOfSession(ConnectionToHost::State state) {
return state == ConnectionToHost::FAILED ||
state == ConnectionToHost::CLOSED;
}
bool ShouldAddDuration(ConnectionToHost::State state) {
// Duration is added to log entries at the end of the session, as well as at
// some intermediate states where it is relevant (e.g. to determine how long
// it took for a session to become CONNECTED).
return IsEndOfSession(state) || state == ConnectionToHost::CONNECTED;
}
} // namespace
namespace remoting {
ClientStatusLogger::ClientStatusLogger(ServerLogEntry::Mode mode,
SignalStrategy* signal_strategy,
const std::string& directory_bot_jid)
: log_to_server_(mode, signal_strategy, directory_bot_jid) {
}
ClientStatusLogger::~ClientStatusLogger() {
}
void ClientStatusLogger::LogSessionStateChange(
protocol::ConnectionToHost::State state,
protocol::ErrorCode error) {
DCHECK(CalledOnValidThread());
scoped_ptr<ServerLogEntry> entry(
MakeLogEntryForSessionStateChange(state, error));
AddClientFieldsToLogEntry(entry.get());
entry->AddModeField(log_to_server_.mode());
MaybeExpireSessionId();
if (IsStartOfSession(state)) {
// Maybe set the session ID and start time.
if (session_id_.empty()) {
GenerateSessionId();
}
if (session_start_time_.is_null()) {
session_start_time_ = base::TimeTicks::Now();
}
}
if (!session_id_.empty()) {
AddSessionIdToLogEntry(entry.get(), session_id_);
}
// Maybe clear the session start time and log the session duration.
if (ShouldAddDuration(state) && !session_start_time_.is_null()) {
AddSessionDurationToLogEntry(entry.get(),
base::TimeTicks::Now() - session_start_time_);
}
if (IsEndOfSession(state)) {
session_start_time_ = base::TimeTicks();
session_id_.clear();
}
log_to_server_.Log(*entry.get());
}
void ClientStatusLogger::LogStatistics(ChromotingStats* statistics) {
DCHECK(CalledOnValidThread());
MaybeExpireSessionId();
scoped_ptr<ServerLogEntry> entry(MakeLogEntryForStatistics(statistics));
AddClientFieldsToLogEntry(entry.get());
entry->AddModeField(log_to_server_.mode());
AddSessionIdToLogEntry(entry.get(), session_id_);
log_to_server_.Log(*entry.get());
}
void ClientStatusLogger::SetSignalingStateForTest(SignalStrategy::State state) {
log_to_server_.OnSignalStrategyStateChange(state);
}
void ClientStatusLogger::GenerateSessionId() {
session_id_.resize(kSessionIdLength);
for (int i = 0; i < kSessionIdLength; i++) {
const int alphabet_size = arraysize(kSessionIdAlphabet) - 1;
session_id_[i] = kSessionIdAlphabet[base::RandGenerator(alphabet_size)];
}
session_id_generation_time_ = base::TimeTicks::Now();
}
void ClientStatusLogger::MaybeExpireSessionId() {
if (session_id_.empty()) {
return;
}
base::TimeDelta max_age = base::TimeDelta::FromDays(kMaxSessionIdAgeDays);
if (base::TimeTicks::Now() - session_id_generation_time_ > max_age) {
// Log the old session ID.
scoped_ptr<ServerLogEntry> entry(MakeLogEntryForSessionIdOld(session_id_));
entry->AddModeField(log_to_server_.mode());
log_to_server_.Log(*entry.get());
// Generate a new session ID.
GenerateSessionId();
// Log the new session ID.
entry = MakeLogEntryForSessionIdNew(session_id_);
entry->AddModeField(log_to_server_.mode());
log_to_server_.Log(*entry.get());
}
}
} // namespace remoting