Lines Matching refs:_fd
807 if (_fd < 0) in Close()
814 close(_fd); in Close()
815 _fd = -1; in Close()
835 if (_fd > 0) in CreateSock()
837 return _fd; in CreateSock()
842 _fd = socket(AF_INET, SOCK_STREAM, 0); in CreateSock()
846 _fd = socket(AF_INET, SOCK_DGRAM, 0); in CreateSock()
849 if (_fd < 0) in CreateSock()
851 MTLOG_ERROR("create socket failed, ret %d[%m]", _fd); in CreateSock()
856 if (ioctl(_fd, FIONBIO, &flags) < 0) in CreateSock()
859 close(_fd); in CreateSock()
860 _fd = -1; in CreateSock()
866 setsockopt(_fd, IPPROTO_TCP, TCP_NODELAY, &flags, sizeof(flags)); in CreateSock()
874 close(_fd); in CreateSock()
875 _fd = -1; in CreateSock()
879 return _fd; in CreateSock()
922 …int32_t ret = ff_hook_connect(_fd, (struct sockaddr*)this->GetDestAddr(&addr), sizeof(struct socka… in Connect()
936 MTLOG_DEBUG("Open connect not ok, maybe first try, sock %d, errno %d", _fd, err); in Connect()
941 MTLOG_ERROR("Open connect not ok, sock %d, errno %d", _fd, err); in Connect()
974 int32_t ret = ff_hook_sendto(_fd, buff, buff_len, 0, in SendCacheUdp()
984 MTLOG_ERROR("socket send failed, fd %d, errno %d(%s)", _fd, in SendCacheUdp()
999 int32_t ret = ff_hook_sendto(_fd, data, len, 0, in SendCacheUdp()
1009 MTLOG_ERROR("socket send failed, fd %d, errno %d(%s)", _fd, in SendCacheUdp()
1047 ssize_t bytes = writev(_fd, iov, count); in SendCacheTcp()
1056 MTLOG_ERROR("socket writev failed, fd %d, errno %d(%s)", _fd, in SendCacheTcp()
1101 rc = MtFrame::Instance()->KqueueCtrlAdd(_fd, KQ_EVENT_READ); in SendData()
1106 rc = MtFrame::Instance()->KqueueCtrlDel(_fd, KQ_EVENT_WRITE); in SendData()
1360 ret = cache_udp_recv(&_recv_cache, _fd, NULL); in InputNotify()
1364 ret = cache_tcp_recv(&_recv_cache, _fd); in InputNotify()
1436 if (!MtFrame::Instance()->KqueueCtrlDel(_fd, KQ_EVENT_WRITE)) in OutputNotify()
1447 MTLOG_ERROR("socket epoll error, fd %d", _fd); in HangupNotify()