代码拉取完成,页面将自动刷新
#include "r_sock.h"
#include <stdio.h>
#include <errno.h>
#include "r_util.h"
#ifdef _LINUX
#include <unistd.h>
#endif
r_sock::r_sock()
#ifdef _WIN32
: m_sock(INVALID_SOCKET)
#else
: m_sock(-1)
#endif
{
}
r_sock::~r_sock()
{
this->Close();
}
void r_sock::Close()
{
if(this->Valid())
{
#ifdef _WIN32
closesocket(m_sock);
m_sock = INVALID_SOCKET;
#else
close(m_sock);
m_sock = -1;
#endif
}
}
bool r_sock::Valid()
{
#ifdef _WIN32
return m_sock != INVALID_SOCKET;
#else
return m_sock != -1;
#endif // _WIN32
}
int r_sock::Connect(r_string& host, int port )
{
m_sock = socket(AF_INET, SOCK_STREAM, 0);
if(!this->Valid())
{
r_log("fail to create sock, err:%d\n", errno);
return -1;
}
struct sockaddr_in server_addr;
memset(&server_addr, 0, sizeof(server_addr));
server_addr.sin_family = AF_INET;
server_addr.sin_addr.s_addr = inet_addr(host.c_str());
server_addr.sin_port = htons(port);
int ret = connect(m_sock, (struct sockaddr*)&server_addr, sizeof(server_addr));
if(ret)
{
r_log("fail to connect %s:%d, err:%d\n", host.c_str(), port, errno);
this->Close();
return -1;
}
return 0;
}
int r_sock::Send(const char* buf, int size)
{
return send(m_sock, buf, size, 0);
}
int r_sock::Recv(char* buf, int size)
{
return recv(m_sock, buf, size, 0);
}
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。