update Socket.send, recv
This commit is contained in:
@@ -102,13 +102,13 @@ static inline int connectsocket(
|
|||||||
}
|
}
|
||||||
|
|
||||||
static inline int recvsocket(
|
static inline int recvsocket(
|
||||||
int descriptor, void* buf, size_t len, int flags
|
int descriptor, char* buf, size_t len, int flags
|
||||||
) noexcept {
|
) noexcept {
|
||||||
return recv(descriptor, buf, len, flags);
|
return recv(descriptor, buf, len, flags);
|
||||||
}
|
}
|
||||||
|
|
||||||
static inline int sendsocket(
|
static inline int sendsocket(
|
||||||
int descriptor, const void* buf, size_t len, int flags
|
int descriptor, const char* buf, size_t len, int flags
|
||||||
) noexcept {
|
) noexcept {
|
||||||
return send(descriptor, buf, len, flags);
|
return send(descriptor, buf, len, flags);
|
||||||
}
|
}
|
||||||
@@ -146,7 +146,7 @@ public:
|
|||||||
freeaddrinfo(addr);
|
freeaddrinfo(addr);
|
||||||
}
|
}
|
||||||
|
|
||||||
int recv(void* buffer, size_t length, bool blocking) override {
|
int recv(char* buffer, size_t length, bool blocking) override {
|
||||||
int len = recvsocket(descriptor, buffer, length, blocking ? MSG_WAITALL : MSG_DONTWAIT);
|
int len = recvsocket(descriptor, buffer, length, blocking ? MSG_WAITALL : MSG_DONTWAIT);
|
||||||
if (len == 0) {
|
if (len == 0) {
|
||||||
int err = errno;
|
int err = errno;
|
||||||
@@ -162,7 +162,7 @@ public:
|
|||||||
return len;
|
return len;
|
||||||
}
|
}
|
||||||
|
|
||||||
int send(const void* buffer, size_t length) override {
|
int send(const char* buffer, size_t length) override {
|
||||||
int len = sendsocket(descriptor, buffer, length, 0);
|
int len = sendsocket(descriptor, buffer, length, 0);
|
||||||
if (len == -1) {
|
if (len == -1) {
|
||||||
int err = errno;
|
int err = errno;
|
||||||
|
|||||||
@@ -26,8 +26,8 @@ namespace network {
|
|||||||
|
|
||||||
class Socket {
|
class Socket {
|
||||||
public:
|
public:
|
||||||
virtual int recv(void* buffer, size_t length, bool blocking) = 0;
|
virtual int recv(char* buffer, size_t length, bool blocking) = 0;
|
||||||
virtual int send(const void* buffer, size_t length) = 0;
|
virtual int send(const char* buffer, size_t length) = 0;
|
||||||
virtual void close() = 0;
|
virtual void close() = 0;
|
||||||
virtual bool isOpen() const = 0;
|
virtual bool isOpen() const = 0;
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user