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
|
/* -*- Mode: C++; c-basic-offset: 2; indent-tabs-mode: nil; tab-width: 8 -*- */
/* This Source Code Form is subject to the terms of the Mozilla Public
* License, v. 2.0. If a copy of the MPL was not distributed with this
* file, You can obtain one at http://mozilla.org/MPL/2.0/. */
#include "BrowserStreamParent.h"
#include "PluginInstanceParent.h"
#include "nsNPAPIPlugin.h"
#include "mozilla/UniquePtr.h"
#include "mozilla/Unused.h"
// How much data are we willing to send across the wire
// in one chunk?
static const int32_t kSendDataChunk = 0xffff;
namespace mozilla::plugins {
BrowserStreamParent::BrowserStreamParent(PluginInstanceParent* npp,
NPStream* stream)
: mNPP(npp), mStream(stream), mState(INITIALIZING) {
mStream->pdata = static_cast<AStream*>(this);
nsNPAPIStreamWrapper* wrapper =
reinterpret_cast<nsNPAPIStreamWrapper*>(mStream->ndata);
if (wrapper) {
mStreamListener = wrapper->GetStreamListener();
}
}
BrowserStreamParent::~BrowserStreamParent() { mStream->pdata = nullptr; }
void BrowserStreamParent::ActorDestroy(ActorDestroyReason aWhy) {
// Implement me! Bug 1005159
}
void BrowserStreamParent::NPP_DestroyStream(NPReason reason) {
NS_ASSERTION(ALIVE == mState || INITIALIZING == mState,
"NPP_DestroyStream called twice?");
bool stillInitializing = INITIALIZING == mState;
if (stillInitializing) {
mState = DEFERRING_DESTROY;
} else {
mState = DYING;
Unused << SendNPP_DestroyStream(reason);
}
}
mozilla::ipc::IPCResult BrowserStreamParent::RecvStreamDestroyed() {
if (DYING != mState) {
NS_ERROR("Unexpected state");
return IPC_FAIL_NO_REASON(this);
}
mStreamPeer = nullptr;
mState = DELETING;
IProtocol* mgr = Manager();
if (!Send__delete__(this)) {
return IPC_FAIL_NO_REASON(mgr);
}
return IPC_OK();
}
int32_t BrowserStreamParent::WriteReady() {
if (mState == INITIALIZING) {
return 0;
}
return kSendDataChunk;
}
int32_t BrowserStreamParent::Write(int32_t offset, int32_t len, void* buffer) {
PLUGIN_LOG_DEBUG_FUNCTION;
NS_ASSERTION(ALIVE == mState, "Sending data after NPP_DestroyStream?");
NS_ASSERTION(len > 0, "Non-positive length to NPP_Write");
if (len > kSendDataChunk) len = kSendDataChunk;
return SendWrite(offset, mStream->end,
nsCString(static_cast<char*>(buffer), len))
? len
: -1;
}
} // namespace mozilla::plugins
|
