native_client_sdk/src/libraries/nacl_io/devfs/jspipe_event_emitter.h

   1 // Copyright 2014 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_DEVFS_JSPIPE_EVENT_EMITTER_H_
   6 #define LIBRARIES_NACL_IO_DEVFS_JSPIPE_EVENT_EMITTER_H_
   7
   8 #include <poll.h>
   9 #include <ppapi/c/pp_var.h>
  10 #include <stdint.h>
  11 #include <stdlib.h>
  12
  13 #include <string>
  14
  15 #include "nacl_io/fifo_char.h"
  16 #include "nacl_io/pipe/pipe_event_emitter.h"
  17
  18 #include "sdk_util/auto_lock.h"
  19 #include "sdk_util/macros.h"
  20
  21 namespace nacl_io {
  22
  23 class PepperInterface;
  24 class MessagingInterface;
  25 class VarInterface;
  26 class VarArrayInterface;
  27 class VarArrayBufferInterface;
  28 class VarDictionaryInterface;
  29
  30 class JSPipeEventEmitter;
  31 typedef sdk_util::ScopedRef<JSPipeEventEmitter> ScopedJSPipeEventEmitter;
  32
  33 class JSPipeEventEmitter : public EventEmitter {
  34  public:
  35   JSPipeEventEmitter(PepperInterface* ppapi, size_t size);
  36   virtual void Destroy();
  37
  38   Error Read_Locked(char* data, size_t len, int* out_bytes);
  39   Error Write_Locked(const char* data, size_t len, int* out_bytes);
  40
  41   size_t GetOSpace() {
  42     return post_message_buffer_size_ - BytesOutstanding();
  43   };
  44   size_t GetISpace() {
  45     return input_fifo_.WriteAvailable();
  46   };
  47   Error SetName(const char* name);
  48   Error HandleJSMessage(PP_Var message);
  49
  50  protected:
  51   size_t HandleJSWrite(const char* data, size_t len);
  52   void HandleJSAck(size_t byte_count);
  53   Error HandleJSWrite(PP_Var message);
  54   Error HandleJSAck(PP_Var message);
  55   void UpdateStatus_Locked();
  56   PP_Var VarFromCStr(const char* string);
  57   Error SendAckMessage(size_t byte_count);
  58   size_t BytesOutstanding() { return bytes_sent_ - bytes_acked_; }
  59   Error SendMessageToJS(PP_Var operation, PP_Var payload);
  60   Error SendWriteMessage(const void* buf, size_t count);
  61   int VarStrcmp(PP_Var a, PP_Var b);
  62
  63  private:
  64   std::string name_;
  65   FIFOChar input_fifo_;
  66
  67   // Number of bytes that to send via PostMessage before and ACK
  68   // is required.
  69   size_t post_message_buffer_size_;
  70   size_t bytes_sent_;
  71   size_t bytes_acked_;
  72   size_t bytes_read_;
  73
  74   PepperInterface* ppapi_;
  75   MessagingInterface* messaging_iface_;
  76   VarInterface* var_iface_;
  77   VarArrayInterface* array_iface_;
  78   VarArrayBufferInterface* buffer_iface_;
  79   VarDictionaryInterface* dict_iface_;
  80
  81   PP_Var pipe_name_var_;
  82   PP_Var pipe_key_;
  83   PP_Var operation_key_;
  84   PP_Var payload_key_;
  85   PP_Var write_var_;
  86   PP_Var ack_var_;
  87
  88   DISALLOW_COPY_AND_ASSIGN(JSPipeEventEmitter);
  89 };
  90
  91 }  // namespace nacl_io
  92
  93 #endif  // LIBRARIES_NACL_IO_DEVFS_JSPIPE_EVENT_EMITTER_H_