dom/plugins/BrowserStreamParent.cpp

   1 /* -*- Mode: C++; c-basic-offset: 2; indent-tabs-mode: nil; tab-width: 8 -*- */
   2
   3 #include "BrowserStreamParent.h"
   4 #include "PluginInstanceParent.h"
   5
   6 #include "mozilla/unused.h"
   7
   8 // How much data are we willing to send across the wire
   9 // in one chunk?
  10 static const int32_t kSendDataChunk = 0x4000;
  11
  12 namespace mozilla {
  13 namespace plugins {
  14
  15 BrowserStreamParent::BrowserStreamParent(PluginInstanceParent* npp,
  16                                          NPStream* stream)
  17   : mNPP(npp)
  18   , mStream(stream)
  19   , mState(ALIVE)
  20 {
  21   mStream->pdata = static_cast<AStream*>(this);
  22 }
  23
  24 BrowserStreamParent::~BrowserStreamParent()
  25 {
  26 }
  27
  28 bool
  29 BrowserStreamParent::AnswerNPN_RequestRead(const IPCByteRanges& ranges,
  30                                            NPError* result)
  31 {
  32   PLUGIN_LOG_DEBUG_FUNCTION;
  33
  34   switch (mState) {
  35   case ALIVE:
  36     break;
  37
  38   case DYING:
  39     *result = NPERR_GENERIC_ERROR;
  40     return true;
  41
  42   default:
  43     NS_ERROR("Unexpected state");
  44     return false;
  45   }
  46
  47   if (!mStream)
  48     return false;
  49
  50   if (ranges.size() > PR_INT32_MAX)
  51     return false;
  52
  53   nsAutoArrayPtr<NPByteRange> rp(new NPByteRange[ranges.size()]);
  54   for (PRUint32 i = 0; i < ranges.size(); ++i) {
  55     rp[i].offset = ranges[i].offset;
  56     rp[i].length = ranges[i].length;
  57     rp[i].next = &rp[i + 1];
  58   }
  59   rp[ranges.size() - 1].next = NULL;
  60
  61   *result = mNPP->mNPNIface->requestread(mStream, rp);
  62   return true;
  63 }
  64
  65 bool
  66 BrowserStreamParent::RecvNPN_DestroyStream(const NPReason& reason)
  67 {
  68   switch (mState) {
  69   case ALIVE:
  70     break;
  71
  72   case DYING:
  73     return true;
  74
  75   default:
  76     NS_ERROR("Unexpected state");
  77     return false;
  78   };
  79
  80   mNPP->mNPNIface->destroystream(mNPP->mNPP, mStream, reason);
  81   return true;
  82 }
  83
  84 void
  85 BrowserStreamParent::NPP_DestroyStream(NPReason reason)
  86 {
  87   NS_ASSERTION(ALIVE == mState, "NPP_DestroyStream called twice?");
  88   mState = DYING;
  89   unused << SendNPP_DestroyStream(reason);
  90 }
  91
  92 bool
  93 BrowserStreamParent::RecvStreamDestroyed()
  94 {
  95   if (DYING != mState) {
  96     NS_ERROR("Unexpected state");
  97     return false;
  98   }
  99
 100   mState = DELETING;
 101   return Send__delete__(this);
 102 }
 103
 104 int32_t
 105 BrowserStreamParent::WriteReady()
 106 {
 107   return kSendDataChunk;
 108 }
 109
 110 int32_t
 111 BrowserStreamParent::Write(int32_t offset,
 112                            int32_t len,
 113                            void* buffer)
 114 {
 115   PLUGIN_LOG_DEBUG_FUNCTION;
 116
 117   NS_ASSERTION(ALIVE == mState, "Sending data after NPP_DestroyStream?");
 118   NS_ASSERTION(len > 0, "Non-positive length to NPP_Write");
 119
 120   if (len > kSendDataChunk)
 121     len = kSendDataChunk;
 122
 123   return SendWrite(offset,
 124                    nsCString(static_cast<char*>(buffer), len),
 125                    mStream->end) ?
 126     len : -1;
 127 }
 128
 129 void
 130 BrowserStreamParent::StreamAsFile(const char* fname)
 131 {
 132   PLUGIN_LOG_DEBUG_FUNCTION;
 133
 134   NS_ASSERTION(ALIVE == mState,
 135                "Calling streamasfile after NPP_DestroyStream?");
 136
 137   unused << CallNPP_StreamAsFile(nsCString(fname));
 138   return;
 139 }
 140
 141 } // namespace plugins
 142 } // namespace mozilla