1 // Copyright 2014 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file.
5 #include "mojo/services/test_service/test_service_impl.h"
8 #include "base/i18n/time_formatting.h"
9 #include "base/strings/utf_string_conversions.h"
10 #include "mojo/public/cpp/application/application_impl.h"
11 #include "mojo/services/test_service/test_service_application.h"
12 #include "mojo/services/test_service/test_time_service_impl.h"
13 #include "mojo/services/test_service/tracked_service.h"
18 TestServiceImpl::TestServiceImpl(ApplicationImpl
* app_impl
,
19 TestServiceApplication
* application
,
20 InterfaceRequest
<TestService
> request
)
21 : application_(application
),
23 binding_(this, request
.Pass()) {
24 binding_
.set_error_handler(this);
27 TestServiceImpl::~TestServiceImpl() {
30 void TestServiceImpl::OnConnectionError() {
31 application_
->ReleaseRef();
34 void TestServiceImpl::Ping(const mojo::Callback
<void()>& callback
) {
36 tracking_
->RecordNewRequest();
40 void SendTimeResponse(
41 const mojo::Callback
<void(int64_t)>& requestor_callback
,
43 requestor_callback
.Run(time_usec
);
46 void TestServiceImpl::ConnectToAppAndGetTime(
47 const mojo::String
& app_url
,
48 const mojo::Callback
<void(int64_t)>& callback
) {
49 app_impl_
->ConnectToService(app_url
, &time_service_
);
51 tracking_
->RecordNewRequest();
52 time_service_
->StartTrackingRequests(mojo::Callback
<void()>());
54 time_service_
->GetPartyTime(base::Bind(&SendTimeResponse
, callback
));
57 void TestServiceImpl::StartTrackingRequests(
58 const mojo::Callback
<void()>& callback
) {
59 TestRequestTrackerPtr tracker
;
60 app_impl_
->ConnectToService("mojo:test_request_tracker_app", &tracker
);
61 tracking_
.reset(new TrackedService(tracker
.Pass(), Name_
, callback
));