blob: 5582deca53daf0810a69e0f17d51418e9d665f4d (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
|
// 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 "mojo/services/test_service/test_service_impl.h"
#include <stdint.h>
#include <utility>
#include "base/bind.h"
#include "base/i18n/time_formatting.h"
#include "base/strings/utf_string_conversions.h"
#include "mojo/services/test_service/test_service_application.h"
#include "mojo/services/test_service/test_time_service_impl.h"
#include "mojo/services/test_service/tracked_service.h"
#include "mojo/shell/public/cpp/shell.h"
namespace mojo {
namespace test {
TestServiceImpl::TestServiceImpl(Shell* shell,
TestServiceApplication* application,
InterfaceRequest<TestService> request)
: application_(application),
shell_(shell),
binding_(this, std::move(request)) {
binding_.set_connection_error_handler(
[this]() { application_->ReleaseRef(); });
}
TestServiceImpl::~TestServiceImpl() {
}
void TestServiceImpl::Ping(const mojo::Callback<void()>& callback) {
if (tracking_)
tracking_->RecordNewRequest();
callback.Run();
}
void SendTimeResponse(
const mojo::Callback<void(int64_t)>& requestor_callback,
int64_t time_usec) {
requestor_callback.Run(time_usec);
}
void TestServiceImpl::ConnectToAppAndGetTime(
const mojo::String& app_url,
const mojo::Callback<void(int64_t)>& callback) {
shell_->ConnectToInterface(app_url.get(), &time_service_);
if (tracking_) {
tracking_->RecordNewRequest();
time_service_->StartTrackingRequests(mojo::Callback<void()>());
}
time_service_->GetPartyTime(base::Bind(&SendTimeResponse, callback));
}
void TestServiceImpl::StartTrackingRequests(
const mojo::Callback<void()>& callback) {
TestRequestTrackerPtr tracker;
shell_->ConnectToInterface("mojo:test_request_tracker_app", &tracker);
tracking_.reset(new TrackedService(std::move(tracker), Name_, callback));
}
} // namespace test
} // namespace mojo
|
