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
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
|
// Copyright (c) 2011 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.
#define UNIT_TEST // To get the ShadowingAtExitManager.
#include "base/at_exit.h"
#include "webkit/plugins/npapi/test/plugin_thread_async_call_test.h"
#include "base/bind.h"
#include "base/message_loop.h"
#include "base/string_util.h"
#include "base/threading/thread.h"
#include "webkit/plugins/npapi/test/plugin_client.h"
namespace NPAPIClient {
namespace {
// There are two plugin instances in this test. The long lived instance is used
// for reporting errors and signalling test completion. The short lived one is
// used to verify that async callbacks are not invoked after NPP_Destroy.
PluginThreadAsyncCallTest* g_short_lived_instance;
PluginThreadAsyncCallTest* g_long_lived_instance;
void OnCallSucceededHelper(void* data) {
static_cast<PluginThreadAsyncCallTest*>(data)->OnCallSucceeded();
}
void OnCallFailed(void* data) {
g_long_lived_instance->SetError("Async callback invoked after NPP_Destroy");
}
void OnCallCompletedHelper(void* data) {
static_cast<PluginThreadAsyncCallTest*>(data)->OnCallCompleted();
}
}
PluginThreadAsyncCallTest::PluginThreadAsyncCallTest(
NPP id, NPNetscapeFuncs *host_functions)
: PluginTest(id, host_functions), at_exit_manager_(NULL) {
}
PluginThreadAsyncCallTest::~PluginThreadAsyncCallTest() {
delete at_exit_manager_;
}
NPError PluginThreadAsyncCallTest::New(
uint16 mode, int16 argc, const char* argn[], const char* argv[],
NPSavedData* saved) {
NPError error = PluginTest::New(mode, argc, argn, argv, saved);
if (error != NPERR_NO_ERROR)
return error;
// Determine whether this is the short lived instance.
for (int i = 0; i < argc; ++i) {
if (base::strcasecmp(argn[i], "short_lived") == 0) {
if (base::strcasecmp(argv[i], "true") == 0) {
g_short_lived_instance = this;
} else {
g_long_lived_instance = this;
}
}
}
// Schedule an async call that will succeed. Make sure to call that API from
// a different thread to fully test it.
if (this == g_short_lived_instance) {
// This is slightly complicated thanks to the Linux shared library build,
// which shares more compilation units between the NPAPI plug-in and
// the base code.
at_exit_manager_ = new base::ShadowingAtExitManager();
base::Thread random_thread("random_thread");
random_thread.Start();
random_thread.message_loop()->PostTask(
FROM_HERE, base::Bind(&PluginThreadAsyncCallTest::AsyncCall,
base::Unretained(this)));
}
return NPERR_NO_ERROR;
}
void PluginThreadAsyncCallTest::AsyncCall() {
HostFunctions()->pluginthreadasynccall(id(), OnCallSucceededHelper, this);
}
void PluginThreadAsyncCallTest::OnCallSucceeded() {
// Delete the short lived instance.
NPIdentifier delete_id = HostFunctions()->getstringidentifier(
"deleteShortLivedInstance");
NPObject *window_obj = NULL;
HostFunctions()->getvalue(id(), NPNVWindowNPObject, &window_obj);
NPVariant result;
HostFunctions()->invoke(id(), window_obj, delete_id, NULL, 0, &result);
}
NPError PluginThreadAsyncCallTest::Destroy() {
if (this == g_short_lived_instance) {
// Schedule an async call that should not be called.
HostFunctions()->pluginthreadasynccall(id(), OnCallFailed, NULL);
// Schedule an async call to end the test using the long lived instance.
HostFunctions()->pluginthreadasynccall(g_long_lived_instance->id(),
OnCallCompletedHelper,
g_long_lived_instance);
}
return NPERR_NO_ERROR;
}
void PluginThreadAsyncCallTest::OnCallCompleted() {
SignalTestCompleted();
}
} // namespace NPAPIClient
|
