#ifndef LIBRARIES_NACL_IO_PIPE_PIPE_EVENT_EMITTER_H_
#define LIBRARIES_NACL_IO_PIPE_PIPE_EVENT_EMITTER_H_
#include <poll.h>
#include <stdint.h>
#include <stdlib.h>
#include "nacl_io/fifo_char.h"
#include "nacl_io/stream/stream_event_emitter.h"
#include "sdk_util/auto_lock.h"
#include "sdk_util/macros.h"
namespace nacl_io {
class PipeEventEmitter;
typedef sdk_util::ScopedRef<PipeEventEmitter> ScopedPipeEventEmitter;
class PipeEventEmitter : public StreamEventEmitter {
public:
PipeEventEmitter(size_t size);
size_t Read_Locked(char* data, size_t len);
size_t Write_Locked(const char* data, size_t len);
protected:
virtual FIFOChar* in_fifo() { return &fifo_; }
virtual FIFOChar* out_fifo() { return &fifo_; }
private:
FIFOChar fifo_;
DISALLOW_COPY_AND_ASSIGN(PipeEventEmitter);
};
}
#endif