namespace content {
EmbeddedWorkerTestHelper::EmbeddedWorkerTestHelper(
- ServiceWorkerContextCore* context)
+ ServiceWorkerContextCore* context,
+ int mock_render_process_id)
: context_(context->AsWeakPtr()),
next_thread_id_(0),
weak_factory_(this) {
+ registry()->AddChildProcessSender(mock_render_process_id, this);
}
EmbeddedWorkerTestHelper::~EmbeddedWorkerTestHelper() {
}
-void EmbeddedWorkerTestHelper::SimulateAddProcess(
+void EmbeddedWorkerTestHelper::SimulateAddProcessToWorker(
int embedded_worker_id,
int process_id) {
EmbeddedWorkerInstance* worker = registry()->GetWorker(embedded_worker_id);
worker->AddProcessReference(process_id);
}
-void EmbeddedWorkerTestHelper::SimulateRemoveProcess(
- int embedded_worker_id, int process_id) {
- EmbeddedWorkerInstance* worker = registry()->GetWorker(embedded_worker_id);
- ASSERT_TRUE(worker);
- registry()->RemoveChildProcessSender(process_id);
- worker->ReleaseProcessReference(process_id);
-}
-
bool EmbeddedWorkerTestHelper::Send(IPC::Message* message) {
OnMessageReceived(*message);
delete message;
void EmbeddedWorkerTestHelper::OnSendMessageToWorker(
int thread_id,
int embedded_worker_id,
+ int request_id,
const IPC::Message& message) {
// Do nothing on the message by default.
}
}
void EmbeddedWorkerTestHelper::SimulateSendMessageToBrowser(
- int embedded_worker_id, const IPC::Message& message) {
- registry()->OnSendMessageToBrowser(embedded_worker_id, message);
+ int embedded_worker_id, int request_id, const IPC::Message& message) {
+ registry()->OnSendMessageToBrowser(embedded_worker_id, request_id, message);
}
void EmbeddedWorkerTestHelper::OnStartWorkerStub(
void EmbeddedWorkerTestHelper::OnSendMessageToWorkerStub(
int thread_id,
int embedded_worker_id,
+ int request_id,
const IPC::Message& message) {
EmbeddedWorkerInstance* worker = registry()->GetWorker(embedded_worker_id);
ASSERT_TRUE(worker != NULL);
weak_factory_.GetWeakPtr(),
thread_id,
embedded_worker_id,
+ request_id,
message));
}