socket_reads.h

// Copyright 2017 Rice University, COMP 413 2017

#include <netinet/in.h>
#include <iostream>
#include <asio.hpp>

#include <ProtobufRpcEngine.pb.h>

#pragma once

using asio::ip::tcp;

namespace rpcserver {
asio::error_code read_full(tcp::socket &sock, asio::mutable_buffers_1 buf);
bool read_byte(tcp::socket &sock, unsigned char *byte);
bool read_int16(tcp::socket &sock, uint16_t *out);
bool read_int32(tcp::socket &sock, uint32_t *out);
bool read_int64(tcp::socket &sock, uint64_t *out);
size_t read_varint(tcp::socket &sock, uint64_t *out);
bool read_delimited_proto(
    tcp::socket &sock,
    ::google::protobuf::Message &proto,
    uint64_t *consumed);
bool read_delimited_proto(
    tcp::socket &sock,
    ::google::protobuf::Message &proto);
bool read_proto(
    tcp::socket &sock,
    ::google::protobuf::Message &proto, uint64_t len);
}  // namespace rpcserver