mirror of
https://github.com/libretro/ppsspp.git
synced 2025-03-05 23:18:32 +00:00
73 lines
1.4 KiB
C++
73 lines
1.4 KiB
C++
#pragma once
|
|
|
|
#include <string>
|
|
|
|
namespace net {
|
|
|
|
class InputSink {
|
|
public:
|
|
InputSink(size_t fd);
|
|
|
|
bool ReadLine(std::string &s);
|
|
std::string ReadLine();
|
|
bool ReadLineWithEnding(std::string &s);
|
|
std::string ReadLineWithEnding();
|
|
|
|
// Read exactly this number of bytes, or fail.
|
|
bool TakeExact(char *buf, size_t bytes);
|
|
// Read whatever is convenient (may even return 0 bytes when there's more coming eventually.)
|
|
size_t TakeAtMost(char *buf, size_t bytes);
|
|
// Skip exactly this number of bytes, or fail.
|
|
bool Skip(size_t bytes);
|
|
|
|
bool Empty();
|
|
|
|
private:
|
|
void Fill();
|
|
bool Block();
|
|
void AccountFill(int bytes);
|
|
void AccountDrain(size_t bytes);
|
|
size_t FindNewline() const;
|
|
|
|
static const size_t BUFFER_SIZE = 32 * 1024;
|
|
static const size_t PRESSURE = 8 * 1024;
|
|
|
|
size_t fd_;
|
|
char buf_[BUFFER_SIZE];
|
|
size_t read_;
|
|
size_t write_;
|
|
size_t valid_;
|
|
};
|
|
|
|
class OutputSink {
|
|
public:
|
|
OutputSink(size_t fd);
|
|
|
|
bool Push(const std::string &s);
|
|
bool Push(const char *buf, size_t bytes);
|
|
size_t PushAtMost(const char *buf, size_t bytes);
|
|
bool PushCRLF(const std::string &s);
|
|
bool Printf(const char *fmt, ...);
|
|
|
|
bool Flush();
|
|
|
|
bool Empty();
|
|
|
|
private:
|
|
void Drain();
|
|
bool Block();
|
|
void AccountPush(size_t bytes);
|
|
void AccountDrain(int bytes);
|
|
|
|
static const size_t BUFFER_SIZE = 32 * 1024;
|
|
static const size_t PRESSURE = 8 * 1024;
|
|
|
|
size_t fd_;
|
|
char buf_[BUFFER_SIZE];
|
|
size_t read_;
|
|
size_t write_;
|
|
size_t valid_;
|
|
};
|
|
|
|
};
|