代码拉取完成,页面将自动刷新
#include "../include/knet/kconnector.h"
#include "internal/ksocket_utils.h"
namespace knet {
connector::connector(workable& wkr)
: _wkr(wkr)
{
}
connector::~connector() = default;
bool connector::connect(const address& addr, int timeout_ms)
{
auto rs = create_rawsocket(addr.get_rawfamily());
if (INVALID_RAWSOCKET == rs) {
return false;
}
if (!::connect(rs, addr.as_ptr<sockaddr>(), addr.get_socklen())) {
_wkr.add_work(rs);
return true;
}
#ifdef _WIN32
if (WSAEWOULDBLOCK != WSAGetLastError()) {
#else // !_WIN32
if (EINPROGRESS != errno) {
#endif // _WIN32
kdebug("connect() failed!");
close_rawsocket(rs);
return false;
}
fd_set ws;
FD_ZERO(&ws);
FD_SET(rs, &ws);
timeval tv, *ptv = nullptr;
if (timeout_ms >= 0) {
ptv = &tv;
tv.tv_sec = timeout_ms / 1000;
timeout_ms %= 1000;
tv.tv_usec = timeout_ms * 1000;
}
do {
const auto ret = TEMP_FAILURE_RETRY(select(static_cast<int>(rs) + 1, nullptr, &ws, nullptr, ptv));
if (RAWSOCKET_ERROR == ret) {
kdebug("select() failed!");
break;
} else if (!ret) {
kdebug("select() timeout!");
break;
}
int opt = 0;
socklen_t len = sizeof(opt);
if (getsockopt(rs, SOL_SOCKET, SO_ERROR, reinterpret_cast<char*>(&opt), &len)) {
kdebug("getsockopt(SO_ERROR) failed!");
break;
}
if (opt) {
errno = opt;
kdebug("connect() failed!");
break;
}
_wkr.add_work(rs);
return true;
} while (false);
close_rawsocket(rs);
return false;
}
} // namespace knet
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。