native_client_sdk/src/libraries/nacl_io/socket/fifo_packet.cc

   1 // Copyright 2013 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 #include "nacl_io/socket/fifo_packet.h"
   6
   7 #include <stdlib.h>
   8 #include <string.h>
   9
  10 #include <algorithm>
  11
  12 #include "nacl_io/socket/packet.h"
  13
  14 namespace nacl_io {
  15
  16 FIFOPacket::FIFOPacket(size_t size) : max_bytes_(size), cur_bytes_(0) {
  17 }
  18
  19 FIFOPacket::~FIFOPacket() {
  20   while (!IsEmpty())
  21     delete ReadPacket();
  22 }
  23
  24 bool FIFOPacket::IsEmpty() {
  25   return packets_.empty();
  26 }
  27
  28 bool FIFOPacket::Resize(size_t len) {
  29   max_bytes_ = len;
  30   return true;
  31 }
  32
  33 size_t FIFOPacket::ReadAvailable() {
  34   return cur_bytes_;
  35 }
  36
  37 size_t FIFOPacket::WriteAvailable() {
  38   if (cur_bytes_ > max_bytes_)
  39     return 0;
  40
  41   return max_bytes_ - cur_bytes_;
  42 }
  43
  44 bool FIFOPacket::IsFull() {
  45   return cur_bytes_ >= max_bytes_;
  46 }
  47
  48 Packet* FIFOPacket::PeekPacket() {
  49   if (packets_.empty())
  50     return NULL;
  51
  52   return packets_.back();
  53 }
  54
  55 Packet* FIFOPacket::ReadPacket() {
  56   if (packets_.empty())
  57     return NULL;
  58
  59   Packet* out = packets_.back();
  60   packets_.pop_back();
  61
  62   cur_bytes_ -= out->len();
  63   return out;
  64 }
  65
  66 void FIFOPacket::WritePacket(Packet* packet) {
  67   cur_bytes_ += packet->len();
  68   packets_.push_front(packet);
  69 }
  70
  71 }  // namespace nacl_io