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) 2010 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 "webkit/glue/plugins/test/plugin_thread_async_call_test.h"
#include "base/at_exit.h"
#include "base/message_loop.h"
#include "base/thread.h"
#include "webkit/glue/plugins/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();
}
class AsyncCallTask : public Task {
public:
AsyncCallTask(PluginThreadAsyncCallTest* test_class)
: test_class_(test_class) {}
void Run() {
test_class_->AsyncCall();
}
private:
PluginThreadAsyncCallTest* test_class_;
};
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) {
}
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) {
at_exit_manager_.reset(new base::AtExitManager());
base::Thread random_thread("random_thread");
random_thread.Start();
random_thread.message_loop()->PostTask(FROM_HERE, new AsyncCallTask(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
|
