// Copyright (c) 2013 The Chromium Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.

#ifndef LIBRARIES_NACL_IO_MOUNT_NODE_STREAM_H_
#define LIBRARIES_NACL_IO_MOUNT_NODE_STREAM_H_

#include <map>
#include <string>

#include "nacl_io/event_emitter_pipe.h"
#include "nacl_io/mount_node.h"
#include "sdk_util/atomicops.h"

namespace nacl_io {

class MountNodeStream;
class MountStream;

typedef sdk_util::ScopedRef<MountNodeStream> ScopedMountNodeStream;

enum StreamStateFlags {
  SSF_CONNECTING = 0x0001,
  SSF_SENDING = 0x0002,
  SSF_RECVING = 0x0004,
  SSF_CLOSING = 0x0008,
  SSF_CAN_SEND = 0x0020,
  SSF_CAN_RECV = 0x0040,
  SSF_NON_BLOCK = 0x1000,
  SSF_ERROR = 0x4000,
  SSF_CLOSED = 0x8000
};


class MountNodeStream : public MountNode {
 public:
  explicit MountNodeStream(Mount* mnt);

  virtual Error Init(int perm);

  // Attempts to pump input and output
  virtual void QueueInput();
  virtual void QueueOutput();

  void SetStreamFlags(uint32_t bits);
  void ClearStreamFlags(uint32_t bits);
  uint32_t GetStreamFlags();
  bool TestStreamFlags(uint32_t bits);

  MountStream* mount_stream();

 protected:
  int read_timeout_;
  int write_timeout_;

 private:
  sdk_util::Atomic32 stream_state_flags_;
};

}  // namespace nacl_io

#endif  // LIBRARIES_NACL_IO_MOUNT_NODE_STREAM_H_