The Tor Browser: netwerk/protocol/http/SpdyPush3.h@6474c204b198

Cloned upstream origin tor-browser at tor-browser-31.3.0esr-4.5-1-build1
revision ID fc1c9ff7c1b2defdbc039f12214767608f46423f for hacking purpose.

     1 /* -*- Mode: C++; tab-width: 2; indent-tabs-mode: nil; c-basic-offset: 2 -*- */

     2 /* This Source Code Form is subject to the terms of the Mozilla Public

     3  * License, v. 2.0. If a copy of the MPL was not distributed with this

     4  * file, You can obtain one at http://mozilla.org/MPL/2.0/. */

     6 // SPDY Server Push as defined by

     7 // http://dev.chromium.org/spdy/spdy-protocol/spdy-protocol-draft3

     9 #ifndef mozilla_net_SpdyPush3_Internal_h

    10 #define mozilla_net_SpdyPush3_Internal_h

    12 #include "mozilla/Attributes.h"

    13 #include "mozilla/TimeStamp.h"

    14 #include "nsILoadGroup.h"

    15 #include "nsString.h"

    16 #include "SpdyStream3.h"

    18 namespace mozilla {

    19 namespace net {

    21 class SpdySession3;

    23 class SpdyPush3TransactionBuffer;

    25 class SpdyPushedStream3 MOZ_FINAL : public SpdyStream3

    26 {

    27 public:

    28   SpdyPushedStream3(SpdyPush3TransactionBuffer *aTransaction,

    29                     SpdySession3 *aSession,

    30                     SpdyStream3 *aAssociatedStream,

    31                     uint32_t aID);

    32   virtual ~SpdyPushedStream3() {}

    34   bool GetPushComplete();

    35   SpdyStream3 *GetConsumerStream() { return mConsumerStream; };

    36   void SetConsumerStream(SpdyStream3 *aStream) { mConsumerStream = aStream; }

    37   bool GetHashKey(nsCString &key);

    39   // override of SpdyStream3

    40   nsresult ReadSegments(nsAHttpSegmentReader *,  uint32_t, uint32_t *);

    41   nsresult WriteSegments(nsAHttpSegmentWriter *, uint32_t, uint32_t *);

    43   nsILoadGroupConnectionInfo *LoadGroupConnectionInfo() { return mLoadGroupCI; };

    44   void ConnectPushedStream(SpdyStream3 *consumer);

    46   bool DeferCleanupOnSuccess() { return mDeferCleanupOnSuccess; }

    47   void SetDeferCleanupOnSuccess(bool val) { mDeferCleanupOnSuccess = val; }

    49   bool IsOrphaned(TimeStamp now);

    51   nsresult GetBufferedData(char *buf, uint32_t count, uint32_t *countWritten);

    53   // overload of SpdyStream3

    54   virtual bool HasSink() { return !!mConsumerStream; }

    56 private:

    58   SpdyStream3 *mConsumerStream; // paired request stream that consumes from

    59                                 // real spdy one.. null until a match is made.

    61   nsCOMPtr<nsILoadGroupConnectionInfo> mLoadGroupCI;

    63   SpdyPush3TransactionBuffer *mBufferedPush;

    64   TimeStamp          mLastRead;

    66   nsCString mHashKey;

    67   nsresult mStatus;

    68   bool mPushCompleted; // server push FIN received

    69   bool mDeferCleanupOnSuccess;

    70 };

    72 class SpdyPush3TransactionBuffer MOZ_FINAL : public nsAHttpTransaction

    73 {

    74 public:

    75   NS_DECL_THREADSAFE_ISUPPORTS

    76   NS_DECL_NSAHTTPTRANSACTION

    78   SpdyPush3TransactionBuffer();

    79   virtual ~SpdyPush3TransactionBuffer();

    81   nsresult GetBufferedData(char *buf, uint32_t count, uint32_t *countWritten);

    82   void SetPushStream(SpdyPushedStream3 *stream) { mPushStream = stream; }

    84 private:

    85   const static uint32_t kDefaultBufferSize = 4096;

    87   nsresult mStatus;

    88   nsHttpRequestHead *mRequestHead;

    89   SpdyPushedStream3 *mPushStream;

    90   bool mIsDone;

    92   nsAutoArrayPtr<char> mBufferedHTTP1;

    93   uint32_t mBufferedHTTP1Size;

    94   uint32_t mBufferedHTTP1Used;

    95   uint32_t mBufferedHTTP1Consumed;

    96 };

    98 } // namespace mozilla::net

    99 } // namespace mozilla

   101 #endif // mozilla_net_SpdyPush3_Internal_h

The Tor Browser / file revision