| OLD | NEW |
| 1 // Copyright 2014 The Chromium Authors. All rights reserved. | 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 | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #ifndef LIBRARIES_NACL_IO_DEVFS_JSPIPE_EVENT_EMITTER_H_ | 5 #ifndef LIBRARIES_NACL_IO_DEVFS_JSPIPE_EVENT_EMITTER_H_ |
| 6 #define LIBRARIES_NACL_IO_DEVFS_JSPIPE_EVENT_EMITTER_H_ | 6 #define LIBRARIES_NACL_IO_DEVFS_JSPIPE_EVENT_EMITTER_H_ |
| 7 | 7 |
| 8 #include <poll.h> | 8 #include <poll.h> |
| 9 #include <ppapi/c/pp_var.h> | 9 #include <ppapi/c/pp_var.h> |
| 10 #include <stdint.h> | 10 #include <stdint.h> |
| (...skipping 20 matching lines...) Expand all Loading... |
| 31 typedef sdk_util::ScopedRef<JSPipeEventEmitter> ScopedJSPipeEventEmitter; | 31 typedef sdk_util::ScopedRef<JSPipeEventEmitter> ScopedJSPipeEventEmitter; |
| 32 | 32 |
| 33 class JSPipeEventEmitter : public EventEmitter { | 33 class JSPipeEventEmitter : public EventEmitter { |
| 34 public: | 34 public: |
| 35 JSPipeEventEmitter(PepperInterface* ppapi, size_t size); | 35 JSPipeEventEmitter(PepperInterface* ppapi, size_t size); |
| 36 virtual void Destroy(); | 36 virtual void Destroy(); |
| 37 | 37 |
| 38 Error Read_Locked(char* data, size_t len, int* out_bytes); | 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); | 39 Error Write_Locked(const char* data, size_t len, int* out_bytes); |
| 40 | 40 |
| 41 size_t GetOSpace() { return post_message_buffer_size_ - BytesOutstanding(); }; | 41 size_t GetOSpace() { |
| 42 size_t GetISpace() { return input_fifo_.WriteAvailable(); }; | 42 return post_message_buffer_size_ - BytesOutstanding(); |
| 43 }; |
| 44 size_t GetISpace() { |
| 45 return input_fifo_.WriteAvailable(); |
| 46 }; |
| 43 Error SetName(const char* name); | 47 Error SetName(const char* name); |
| 44 Error HandleJSMessage(PP_Var message); | 48 Error HandleJSMessage(PP_Var message); |
| 45 | 49 |
| 46 protected: | 50 protected: |
| 47 size_t HandleJSWrite(const char* data, size_t len); | 51 size_t HandleJSWrite(const char* data, size_t len); |
| 48 void HandleJSAck(size_t byte_count); | 52 void HandleJSAck(size_t byte_count); |
| 49 Error HandleJSWrite(PP_Var message); | 53 Error HandleJSWrite(PP_Var message); |
| 50 Error HandleJSAck(PP_Var message); | 54 Error HandleJSAck(PP_Var message); |
| 51 void UpdateStatus_Locked(); | 55 void UpdateStatus_Locked(); |
| 52 PP_Var VarFromCStr(const char* string); | 56 PP_Var VarFromCStr(const char* string); |
| (...skipping 27 matching lines...) Expand all Loading... |
| 80 PP_Var payload_key_; | 84 PP_Var payload_key_; |
| 81 PP_Var write_var_; | 85 PP_Var write_var_; |
| 82 PP_Var ack_var_; | 86 PP_Var ack_var_; |
| 83 | 87 |
| 84 DISALLOW_COPY_AND_ASSIGN(JSPipeEventEmitter); | 88 DISALLOW_COPY_AND_ASSIGN(JSPipeEventEmitter); |
| 85 }; | 89 }; |
| 86 | 90 |
| 87 } // namespace nacl_io | 91 } // namespace nacl_io |
| 88 | 92 |
| 89 #endif // LIBRARIES_NACL_IO_DEVFS_JSPIPE_EVENT_EMITTER_H_ | 93 #endif // LIBRARIES_NACL_IO_DEVFS_JSPIPE_EVENT_EMITTER_H_ |
| OLD | NEW |