ppsspp/base/buffer.cpp

#include "base/buffer.h"

#include <stdarg.h>
#include <stdlib.h>
#include <algorithm>

#ifdef _WIN32
#include <winsock2.h>
#undef min
#undef max
#else
#include <sys/socket.h>
#include <unistd.h>
#endif

#include "base/logging.h"
#include "file/fd_util.h"

Buffer::Buffer() { }
Buffer::~Buffer() { }

char *Buffer::Append(ssize_t length) {
  size_t old_size = data_.size();
  data_.resize(old_size + length);
  return &data_[0] + old_size;
}

void Buffer::Append(const std::string &str) {
  char *ptr = Append(str.size());
  memcpy(ptr, str.data(), str.size());
}

void Buffer::Append(const char *str) {
  size_t len = strlen(str);
  char *dest = Append(len);
  memcpy(dest, str, len);
}

void Buffer::AppendValue(int value) {
  char buf[16];
  // This is slow.
  sprintf(buf, "%i", value);
  Append(buf);
}

void Buffer::Take(size_t length, std::string *dest) {
  CHECK_LE(length, data_.size());
  dest->resize(length);
  memcpy(&(*dest)[0], &data_[0], length);
  data_.erase(data_.begin(), data_.begin() + length);
}

int Buffer::TakeLineCRLF(std::string *dest) {
  int after_next_line = OffsetToAfterNextCRLF();
  if (after_next_line < 0)
    return after_next_line;
  else {
    Take(after_next_line - 2, dest);
    Skip(2);  // Skip the CRLF
    return after_next_line - 2;
  }
}

void Buffer::Skip(size_t length) {
  data_.erase(data_.begin(), data_.begin() + length);
}

int Buffer::SkipLineCRLF() {
  int after_next_line = OffsetToAfterNextCRLF();
  if (after_next_line < 0)
    return after_next_line;
  else {
    Skip(after_next_line);
    return after_next_line - 2;
  }
}

int Buffer::OffsetToAfterNextCRLF() {
  for (size_t i = 0; i < data_.size() - 1; i++) {
    if (data_[i] == '\r' && data_[i + 1] == '\n') {
      return i + 2;
    }
  }
  return -1;
}

void Buffer::Printf(const char *fmt, ...) {
  char buffer[512];
  va_list vl;
  va_start(vl, fmt);
  ssize_t retval = vsnprintf(buffer, sizeof(buffer), fmt, vl);
  if (retval >= (ssize_t)sizeof(buffer)) {
    // Output was truncated. TODO: Do something.
    FLOG("Buffer::Printf truncated output");
  }
  CHECK_GE(retval, 0);
  va_end(vl);
  char *ptr = Append(retval);
  CHECK(ptr);
  memcpy(ptr, buffer, retval);
}

bool Buffer::Flush(int fd) {
  // Look into using send() directly.
  bool success = (ssize_t)data_.size() == fd_util::WriteLine(fd, &data_[0], data_.size());
  if (success) {
    data_.resize(0);
  }
  return success;
}

bool Buffer::FlushSocket(uintptr_t sock) {
  for (size_t pos = 0, end = data_.size(); pos < end; ) {
    int sent = send(sock, &data_[pos], end - pos, 0);
    if (sent < 0) {
      ELOG("FlushSocket failed");
      return false;
    }
    pos += sent;

    // Buffer full, don't spin.
    if (sent == 0) {
#ifdef _WIN32
      Sleep(1);
#else
      sleep(1);
#endif
    }
  }

  data_.resize(0);
  return true;
}

void Buffer::ReadAll(int fd) {
  char buf[1024];
  int retval;
  while ((retval = recv(fd, buf, sizeof(buf), 0)) > 0) {
    char *p = Append((size_t)retval);
    memcpy(p, buf, retval);
  }
}

void Buffer::Read(int fd, size_t sz) {
  char buf[1024];
  int retval;
  while ((retval = recv(fd, buf, std::min(sz, sizeof(buf)), 0)) > 0) {
    char *p = Append((size_t)retval);
    memcpy(p, buf, retval);
    sz -= retval;
    if (sz == 0)
      break;
  }
}

void Buffer::PeekAll(std::string *dest) {
  dest->resize(data_.size());
  memcpy(&(*dest)[0], &data_[0], data_.size());
}