native_client_sdk/src/libraries/nacl_io/stream/stream_node.h

   1 // Copyright 2013 The Chromium Authors. All rights reserved.
   2 // Use of this source code is governed by a BSD-style license that can be
   3 // found in the LICENSE file.
   4
   5 #ifndef LIBRARIES_NACL_IO_STREAM_STREAM_NODE_H_
   6 #define LIBRARIES_NACL_IO_STREAM_STREAM_NODE_H_
   7
   8 #include <map>
   9 #include <string>
  10
  11 #include "nacl_io/node.h"
  12 #include "nacl_io/pipe/pipe_event_emitter.h"
  13 #include "sdk_util/atomicops.h"
  14
  15 namespace nacl_io {
  16
  17 class StreamNode;
  18 class StreamFs;
  19
  20 typedef sdk_util::ScopedRef<StreamNode> ScopedStreamNode;
  21
  22 enum StreamStateFlags {
  23   SSF_CONNECTING = 0x0001,
  24   SSF_SENDING = 0x0002,
  25   SSF_RECVING = 0x0004,
  26   SSF_CLOSING = 0x0008,
  27   SSF_LISTENING = 0x000f,
  28   SSF_CAN_SEND = 0x0020,
  29   SSF_CAN_RECV = 0x0040,
  30   SSF_CAN_ACCEPT = 0x0080,
  31   SSF_CAN_CONNECT = 0x00f0,
  32   SSF_NON_BLOCK = 0x1000,
  33   SSF_ERROR = 0x4000,
  34   SSF_CLOSED = 0x8000,
  35   SSF_RECV_ENDOFSTREAM = 0x10000,
  36 };
  37
  38 class StreamNode : public Node {
  39  public:
  40   explicit StreamNode(Filesystem* fs);
  41
  42   virtual Error Init(int open_flags);
  43
  44   // Attempts to pump input and output
  45   virtual void QueueInput();
  46   virtual void QueueOutput();
  47
  48   void SetStreamFlags(uint32_t bits);
  49   void ClearStreamFlags(uint32_t bits);
  50   uint32_t GetStreamFlags();
  51   bool TestStreamFlags(uint32_t bits);
  52
  53   StreamFs* stream();
  54
  55  protected:
  56   int read_timeout_;
  57   int write_timeout_;
  58
  59  private:
  60   sdk_util::Atomic32 stream_state_flags_;
  61 };
  62
  63 }  // namespace nacl_io
  64
  65 #endif  // LIBRARIES_NACL_IO_STREAM_STREAM_NODE_H_