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 |