diff options
Diffstat (limited to 'google_apis/gcm/engine/mcs_client.cc')
-rw-r--r-- | google_apis/gcm/engine/mcs_client.cc | 25 |
1 files changed, 1 insertions, 24 deletions
diff --git a/google_apis/gcm/engine/mcs_client.cc b/google_apis/gcm/engine/mcs_client.cc index a99a333..da8300c7 100644 --- a/google_apis/gcm/engine/mcs_client.cc +++ b/google_apis/gcm/engine/mcs_client.cc @@ -15,7 +15,6 @@ #include "google_apis/gcm/base/mcs_util.h" #include "google_apis/gcm/base/socket_stream.h" #include "google_apis/gcm/engine/connection_factory.h" -#include "google_apis/gcm/monitoring/gcm_stats_recorder.h" using namespace google::protobuf::io; @@ -129,14 +128,6 @@ ReliablePacketInfo::ReliablePacketInfo() } ReliablePacketInfo::~ReliablePacketInfo() {} -int MCSClient::GetSendQueueSize() const { - return to_send_.size(); -} - -int MCSClient::GetResendQueueSize() const { - return to_resend_.size(); -} - std::string MCSClient::GetStateString() const { switch(state_) { case UNINITIALIZED: @@ -156,8 +147,7 @@ std::string MCSClient::GetStateString() const { MCSClient::MCSClient(const std::string& version_string, base::Clock* clock, ConnectionFactory* connection_factory, - GCMStore* gcm_store, - GCMStatsRecorder* recorder) + GCMStore* gcm_store) : version_string_(version_string), clock_(clock), state_(UNINITIALIZED), @@ -170,7 +160,6 @@ MCSClient::MCSClient(const std::string& version_string, stream_id_out_(0), stream_id_in_(0), gcm_store_(gcm_store), - recorder_(recorder), weak_ptr_factory_(this) { } @@ -506,11 +495,6 @@ void MCSClient::SendPacketToWire(ReliablePacketInfo* packet_info) { base::Time::kMicrosecondsPerSecond) - sent; DVLOG(1) << "Message was queued for " << queued << " seconds."; data_message->set_queued(queued); - recorder_->RecordDataSentToWire( - data_message->category(), - data_message->to(), - data_message->id(), - queued); } // Set the proper last received stream id to acknowledge received server @@ -878,13 +862,6 @@ void MCSClient::NotifyMessageSendStatus( const mcs_proto::DataMessageStanza* data_message_stanza = reinterpret_cast<const mcs_proto::DataMessageStanza*>(&protobuf); - recorder_->RecordNotifySendStatus( - data_message_stanza->category(), - data_message_stanza->to(), - data_message_stanza->id(), - status, - protobuf.ByteSize(), - data_message_stanza->ttl()); message_sent_callback_.Run( data_message_stanza->device_user_id(), data_message_stanza->category(), |