root/native_client_sdk/src/libraries/nacl_io/stream/stream_fs.h

INCLUDED FROM

// Copyright 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_STREAM_STREAM_H_
#define LIBRARIES_NACL_IO_STREAM_STREAM_H_

#include "nacl_io/filesystem.h"

#include "ppapi/c/pp_completion_callback.h"
#include "ppapi/c/pp_resource.h"

namespace nacl_io {

// StreamFs provides a "mount point" for stream objects which do not provide a
// path, such as FDs returned by pipe, socket, and sockpair.  It also provides
// a background thread for dispatching completion callbacks.

class StreamFs;
class StreamNode;

class StreamFs : public Filesystem {
 public:
  class Work {
   public:
    explicit Work(StreamFs* filesystem) : filesystem_(filesystem) {}
    virtual ~Work() {}

    // Called by adding work the queue, val should be safe to ignore.
    virtual bool Start(int32_t val) = 0;

    // Called as a completion of work in Start.  Value of val depend on
    // the function invoked in Start.
    virtual void Run(int32_t val) = 0;
    StreamFs* filesystem() { return filesystem_; }

   private:
    StreamFs* filesystem_;
  };

 protected:
  StreamFs();
  virtual ~StreamFs();

 public:
  // Enqueue a work object onto this StreamFs's thread
  void EnqueueWork(Work* work);

  // Returns a completion callback which will execute the StartWork member
  // of a MountSocketWork object.
  static PP_CompletionCallback GetStartCompletion(Work* work);

  // Returns a completion callback which will execute the RunCallback member
  // of a MountSocketWork object.
  static PP_CompletionCallback GetRunCompletion(Work* work);

  virtual Error Access(const Path& path, int a_mode);
  virtual Error Open(const Path& path, int o_flags, ScopedNode* out_node);
  virtual Error Unlink(const Path& path);
  virtual Error Mkdir(const Path& path, int permissions);
  virtual Error Rmdir(const Path& path);
  virtual Error Remove(const Path& path);
  virtual Error Rename(const Path& path, const Path& newpath);

  static void* StreamThreadThunk(void*);
  void StreamThread();

 private:
  PP_Resource message_loop_;
  pthread_cond_t message_cond_;
  sdk_util::SimpleLock message_lock_;

  friend class KernelProxy;
  DISALLOW_COPY_AND_ASSIGN(StreamFs);
};

}  // namespace nacl_io

#endif  // LIBRARIES_NACL_IO_STREAM_STREAM_H_