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 GetOSpace()41 size_t GetOSpace() { 42 return post_message_buffer_size_ - BytesOutstanding(); 43 }; GetISpace()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); BytesOutstanding()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_ 94