blob: 99b62c5a06b30ec0100f5ee3d2530824b2c36b11 (
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
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
|
// 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 "base/at_exit.h"
#include "base/bind.h"
#include "base/command_line.h"
#include "base/files/file_path.h"
#include "base/message_loop/message_loop.h"
#include "base/run_loop.h"
#include "mojo/public/cpp/application/application.h"
#include "mojo/public/cpp/application/connect.h"
#include "mojo/public/cpp/bindings/interface_ptr.h"
#include "mojo/public/interfaces/service_provider/service_provider.mojom.h"
#include "mojo/services/network/network_context.h"
#include "mojo/services/network/network_service_impl.h"
#include "mojo/services/public/interfaces/profile/profile_service.mojom.h"
namespace {
void OnPathReceived(const base::Closure& callback,
base::FilePath* path,
const mojo::String& path_as_string) {
DCHECK(!path_as_string.is_null());
#if defined(OS_POSIX)
*path = base::FilePath(path_as_string);
#elif defined(OS_WIN)
*path = base::FilePath::FromUTF8Unsafe(path_as_string);
#else
#error Not implemented
#endif
callback.Run();
}
// Synchronously creates a new context, using the handle to retrieve services.
// The handle must still be valid when this method returns and no message must
// have been read.
scoped_ptr<mojo::NetworkContext> CreateContext(
mojo::ScopedMessagePipeHandle* handle) {
// TODO(qsr): Do not bind a new service provider, but use a synchronous call
// when http://crbug.com/386485 is implemented.
// Temporarly bind the handle to a service provider to retrieve a profile
// service.
mojo::InterfacePtr<mojo::ServiceProvider> service_provider;
service_provider.Bind(handle->Pass());
mojo::InterfacePtr<mojo::ProfileService> profile_service;
ConnectToService(
service_provider.get(), "mojo:profile_service", &profile_service);
// Unbind the handle to prevent any message to be read.
*handle = service_provider.PassMessagePipe();
// Use a nested message loop to synchronously call a method on the profile
// service.
base::MessageLoop::ScopedNestableTaskAllower allow(
base::MessageLoop::current());
base::RunLoop run_loop;
base::FilePath base_path;
profile_service->GetPath(mojo::ProfileService::DIR_TEMP,
base::Bind(&OnPathReceived,
run_loop.QuitClosure(),
base::Unretained(&base_path)));
run_loop.Run();
base_path = base_path.Append(FILE_PATH_LITERAL("network_service"));
return scoped_ptr<mojo::NetworkContext>(new mojo::NetworkContext(base_path));
}
} // namespace
extern "C" APPLICATION_EXPORT MojoResult CDECL MojoMain(
MojoHandle service_provider_handle) {
base::CommandLine::Init(0, NULL);
base::AtExitManager at_exit;
// The IO message loop allows us to use net::URLRequest on this thread.
base::MessageLoopForIO loop;
mojo::ScopedMessagePipeHandle scoped_service_provider_handle =
mojo::MakeScopedHandle(mojo::MessagePipeHandle(service_provider_handle));
scoped_ptr<mojo::NetworkContext> context =
CreateContext(&scoped_service_provider_handle);
mojo::Application app;
app.BindServiceProvider(scoped_service_provider_handle.Pass());
app.AddService<mojo::NetworkServiceImpl>(context.get());
loop.Run();
return MOJO_RESULT_OK;
}
|
