#pragma once
|
#include "Protocol.h"
|
|
namespace Proto {
|
|
// ´ó¶Ë¹¤¾ß
|
void put_u16(std::vector<uint8_t>& v, uint16_t x);
|
void put_u32(std::vector<uint8_t>& v, uint32_t x);
|
void put_u64(std::vector<uint8_t>& v, uint64_t x);
|
uint16_t get_u16(const uint8_t* p);
|
uint32_t get_u32(const uint8_t* p);
|
uint64_t get_u64(const uint8_t* p);
|
void put_f64_be(std::vector<uint8_t>& v, double d);
|
double get_f64_be(const uint8_t* p);
|
|
// °ïÖú£ºpeek cmd
|
uint16_t peek_cmd(const std::vector<uint8_t>& frame);
|
|
// ±àÂ루¹¹Ö¡£ºÍ· + dataId + len + body + ⣩
|
std::vector<uint8_t> encodeRequestVersion(const ReqVersion& req);
|
std::vector<uint8_t> encodeResponseVersion(const RspVersion& rsp);
|
std::vector<uint8_t> encodeRequestMachines(const ReqMachines& req);
|
std::vector<uint8_t> encodeResponseMachines(const RspMachines& rsp);
|
std::vector<uint8_t> encodeRequestStats(const ReqStats& req);
|
std::vector<uint8_t> encodeResponseStats(const RspStats& rsp);
|
std::vector<uint8_t> encodeRequestSince(const ReqSince& req);
|
std::vector<uint8_t> encodeResponseSince(const RspSince& rsp);
|
std::vector<uint8_t> encodeRequestSinceAll(const ReqSinceAll& req);
|
std::vector<uint8_t> encodeResponseSinceAll(const RspSinceAll& rsp);
|
std::vector<uint8_t> encodeRequestBatchInfo(const ReqBatchInfo& req);
|
std::vector<uint8_t> encodeResponseBatchInfo(const RspBatchInfo& rsp);
|
|
// ½âÂë
|
bool decodeRequestVersion(const std::vector<uint8_t>& frame, ReqVersion& out);
|
bool decodeResponseVersion(const std::vector<uint8_t>& frame, RspVersion& out);
|
bool decodeRequestMachines(const std::vector<uint8_t>& frame, ReqMachines& out);
|
bool decodeResponseMachines(const std::vector<uint8_t>& frame, RspMachines& out);
|
bool decodeRequestStats(const std::vector<uint8_t>& frame, ReqStats& out);
|
bool decodeResponseStats(const std::vector<uint8_t>& frame, RspStats& out);
|
bool decodeRequestSince(const std::vector<uint8_t>& frame, ReqSince& out);
|
bool decodeResponseSince(const std::vector<uint8_t>& frame, RspSince& out);
|
bool decodeRequestSinceAll(const std::vector<uint8_t>& frame, ReqSinceAll& out);
|
bool decodeResponseSinceAll(const std::vector<uint8_t>& frame, RspSinceAll& out);
|
bool decodeRequestBatchInfo(const std::vector<uint8_t>& frame, ReqBatchInfo& out);
|
bool decodeResponseBatchInfo(const std::vector<uint8_t>& frame, RspBatchInfo& out);
|
std::vector<uint8_t> encodeResponseError(const RspError& rsp);
|
bool decodeResponseError(const std::vector<uint8_t>& frame, RspError& out);
|
|
} // namespace Proto
|
