[NaCl SDK] Support non blocking TCP/UDP

native_client_sdk/src/libraries/nacl_io/fifo_char.cc

Index: native_client_sdk/src/libraries/nacl_io/fifo_char.cc
diff --git a/native_client_sdk/src/libraries/nacl_io/fifo_char.cc b/native_client_sdk/src/libraries/nacl_io/fifo_char.cc
new file mode 100644
index 0000000000000000000000000000000000000000..db7956a424a9596202bd01828fd98f50e84ba5dc
--- /dev/null
+++ b/native_client_sdk/src/libraries/nacl_io/fifo_char.cc
@@ -0,0 +1,120 @@
+// Copyright (c) 2013 The Chromium Authors. All rights reserved.
+// Use of this source code is governed by a BSD-style license that can be
+// found in the LICENSE file.
+
+#include "nacl_io/fifo_char.h"
+
+#include <stdlib.h>
+#include <string.h>
+
+#include <algorithm>
+
+namespace nacl_io {
+
+FIFOChar::FIFOChar(size_t size)
+    : buffer_(NULL),
+      size_(size),
+      avail_(0),
+      tail_(0) {
+  if (size) {
+    buffer_ = new char[size];
+  } else {
+    buffer_ = NULL;
+  }
+}
+
+FIFOChar::~FIFOChar() {
+  delete[] buffer_;
+}
+
+bool FIFOChar::IsEmpty() {
+  return avail_ == 0;
+}
+
+bool FIFOChar::IsFull() {
+  return avail_ >= size_;
+}
+
+bool FIFOChar::Resize(size_t len) {
+  // Can not resize smaller than the current size
+  if (len < avail_)
+    return false;
+
+  // Read current data into new buffer
+  char* data = new char[len];
+  avail_ = Read(data, avail_);
+
+  // Replace buffer
+  delete[] buffer_;
+  buffer_ = data;
+  size_ = len;
+  return true;
+}
+
+
+size_t FIFOChar::ReadAvailable() {
+  return avail_;
+}
+
+size_t FIFOChar::WriteAvailable() {
+  return size_ - avail_;
+}
+
+size_t FIFOChar::Peek(void* buf, size_t len) {
+  char* ptr = static_cast<char*>(buf);
+
+  size_t out = 0;
+  len = std::min(len, avail_);
+
+  size_t offs = tail_;
+  while (len > 0) {
+    size_t read_len = std::min(len, size_ - offs);
+    memcpy(ptr, &buffer_[offs], read_len);
+
+    ptr += read_len;
+    offs += read_len;
+    if (static_cast<size_t>(offs) == size_)
+      offs = 0;
+
+    out += read_len;
+    len -= read_len;
+  }
+
+  return out;
+}
+
+size_t FIFOChar::Read(void* buf, size_t len) {
+  size_t read_len = Peek(buf, len);
+  if (read_len > 0) {
+    avail_ -= read_len;
+    tail_ = (tail_ + read_len) % size_;
+  }
+  return read_len;
+}
+
+size_t FIFOChar::Write(const void* buf, size_t len) {
+  const char* ptr = static_cast<const char*>(buf);
+  size_t out = 0;
+  size_t room = size_ - avail_;
+  len = std::min(len, room);
+
+  size_t offs = tail_ + avail_;
+  while (len > 0) {
+    size_t write_len = std::min(len, size_ - offs);
+    memcpy(&buffer_[offs], ptr, write_len);
+
+    ptr += write_len;
+    offs += write_len;
+    if (offs == size_)
+      offs = 0;
+
+    out += write_len;
+    len -= write_len;
+  }
+
+  avail_ += out;
+  return out;
+}
+
+
+}  // namespace nacl_io