thrift之TTransport層的堵塞的套接字I/O傳輸類TSocket

class TSocket : public TVirtualTransport<TSocket> { ......}

　　TSocket();//所有參數都默認
　　TSocket(std::string host, int port);//根據主機名和端口構造一個socket
　　TSocket(std::string path);//構造unix域的一個socket
　　TSocket(int socket);//構造一個原始的unix句柄socket

　　TSocket::TSocket() :
　　  host_(""),
　　  port_(0),
　　  path_(""),
　　  socket_(-1),
　　  connTimeout_(0),
　　  sendTimeout_(0),
　　  recvTimeout_(0),
　　  lingerOn_(1),
　　  lingerVal_(0),
　　  noDelay_(1),
　　  maxRecvRetries_(5) {
　　  recvTimeval_.tv_sec = (int)(recvTimeout_/1000);
　　  recvTimeval_.tv_usec = (int)((recvTimeout_%1000)*1000);
　　  cachedPeerAddr_.ipv4.sin_family = AF_UNSPEC;
　　}

　　void TSocket::open() {
　　  if (isOpen()) {//如果已經打開就直接返回
　　    return;
　　  }
　　  if (! path_.empty()) {//如果unix路徑不為空就打開unix domian socket
　　    unix_open();
　　  } else {
　　    local_open();//打開通用socket
　　  }
　　}

　　void TSocket::unix_open(){
　　  if (! path_.empty()) {//保證path_不為空
　　    // Unix Domain SOcket does not need addrinfo struct, so we pass NULL
　　    openConnection(NULL);//調用真正的打開連接函數
　　  }
　　}

　　void TSocket::openConnection(struct addrinfo *res) {
　　  if (isOpen()) {
　　    return;//如果已經打開了直接返回
　　  }
　　  if (! path_.empty()) {//根據路徑是否為空創建不同的socket
　　    socket_ = socket(PF_UNIX, SOCK_STREAM, IPPROTO_IP);//創建unix domain socket
　　  } else {
　　    socket_ = socket(res->ai_family, res->ai_socktype, res->ai_protocol);//創建通用的網絡通信socket
　　  }
　　  if (sendTimeout_ > 0) {//如果發生超時設置大于0就調用設置發送超時函數設置發送超時
　　    setSendTimeout(sendTimeout_);
　　  }
　　  if (recvTimeout_ > 0) {//如果接收超時設置大于0就調用設置接收超時函數設置接收超時
　　    setRecvTimeout(recvTimeout_);
　　  }
　　  setLinger(lingerOn_, lingerVal_);//設置優雅斷開連接或關閉連接參數
　　  setNoDelay(noDelay_);//設置無延時
　　#ifdef TCP_LOW_MIN_RTO
　　  if (getUseLowMinRto()) {//設置是否使用較低的最低TCP重傳超時 
　　    int one = 1;
　　    setsockopt(socket_, IPPROTO_TCP, TCP_LOW_MIN_RTO, &one, sizeof(one));
　　  }
　　#endif
　　  //如果超時已經存在設置連接為非阻塞
　　  int flags = fcntl(socket_, F_GETFL, 0);//得到socket_的標識
　　  if (connTimeout_ > 0) {//超時已經存在
　　    if (-1 == fcntl(socket_, F_SETFL, flags | O_NONBLOCK)) {//設置為非阻塞
　　    }
　　  } else {
　　    if (-1 == fcntl(socket_, F_SETFL, flags & ~O_NONBLOCK)) {//設置為阻塞
　　    }
　　  }
　　  // 連接socket
　　  int ret;
　　  if (! path_.empty()) {//unix domain socket
　　#ifndef _WIN32 //window不支持
　　    struct sockaddr_un address;
　　    socklen_t len;
　　    if (path_.length() > sizeof(address.sun_path)) {//path_長度不能超過最長限制
　　    }
　　    address.sun_family = AF_UNIX;
　　    snprintf(address.sun_path, sizeof(address.sun_path), "%s", path_.c_str());
　　    len = sizeof(address);
　　    ret = connect(socket_, (struct sockaddr *) &address, len);//連接unix domain socket
　　#else
　　      //window不支持unix domain socket
　　#endif
　　
　　  } else {
　　    ret = connect(socket_, res->ai_addr, res->ai_addrlen);//連接通用的非unix domain socket
　　  }
　　  if (ret == 0) {//失敗了就會執行后面的代碼，用poll來監聽寫事件
　　    goto done;//成功了就直接跳轉到完成處
　　  }
　　  struct pollfd fds[1];//定于用于poll的描述符
　　  std::memset(fds, 0 , sizeof(fds));//初始化為0
　　  fds[0].fd = socket_;//描述符為socket
　　  fds[0].events = POLLOUT;//接收寫事件
　　  ret = poll(fds, 1, connTimeout_);//調用poll，有一個超時值
　　  if (ret > 0) {
　　    // 確保socket已經被連接并且沒有錯誤被設置
　　    int val;
　　    socklen_t lon;
　　    lon = sizeof(int);
　　    int ret2 = getsockopt(socket_, SOL_SOCKET, SO_ERROR, cast_sockopt(&val), &lon);//得到錯誤選項參數
　　    if (val == 0) {// socket沒有錯誤也直接到完成處了
　　      goto done;
　　    }
　　  } else if (ret == 0) {// socket 超時
　　    //相應處理代碼省略
　　  } else {
　　    // poll()出錯了，相應處理代碼省略
　　  }
　　
　　 done:
　　  fcntl(socket_, F_SETFL, flags);//設置socket到原來的模式了（阻塞）
　　  if (path_.empty()) {//如果是unix domain socket就設置緩存地址
　　    setCachedAddress(res->ai_addr, res->ai_addrlen);
　　  }
　　}

　　void TSocket::local_open(){
　　#ifdef _WIN32
　　    TWinsockSingleton::create();//兼容window平臺
　　#endif // _WIN32
　　  if (isOpen()) {//打開了就直接返回
　　    return;
　　  }
　　  if (port_ < 0 || port_ > 0xFFFF) {//驗證端口是否為有效值
　　    throw TTransportException(TTransportException::NOT_OPEN, "Specified port is invalid");
　　  }
　　  struct addrinfo hints, *res, *res0;
　　  res = NULL;
　　  res0 = NULL;
　　  int error;
　　  char port[sizeof("65535")];
　　  std::memset(&hints, 0, sizeof(hints));//內存設置為0
　　  hints.ai_family = PF_UNSPEC;
　　  hints.ai_socktype = SOCK_STREAM;
　　  hints.ai_flags = AI_PASSIVE | AI_ADDRCONFIG;
　　  sprintf(port, "%d", port_);
　　  error = getaddrinfo(host_.c_str(), port, &hints, &res0);//根據主機名得到所有網卡地址信息
　　  // 循環遍歷所有的網卡地址信息，直到有一個成功打開
　　  for (res = res0; res; res = res->ai_next) {
　　    try {
　　      openConnection(res);//調用打開函數
　　      break;//成功就退出循環
　　    } catch (TTransportException& ttx) {
　　      if (res->ai_next) {//異常處理，是否還有下一個地址，有就繼續
　　        close();
　　      } else {
　　        close();
　　        freeaddrinfo(res0); // 清除地址信息內存和資源
　　        throw;//拋出異常
　　      }
　　    }
　　  }
　　  freeaddrinfo(res0);//釋放地址結構內存
　　}

　　uint32_t TSocket::read(uint8_t* buf, uint32_t len) {
　　  int32_t retries = 0;//重試的次數
　　  uint32_t eagainThresholdMicros = 0;
　　  if (recvTimeout_) {//如果設置了接收超時時間，那么計算最大時間間隔來判斷是否系統資源耗盡
　　    eagainThresholdMicros = (recvTi

主站蜘蛛池模板：
亚洲精品日本一区二区|
久久国产精品-国产精品|
久久久精品人妻一区二区三区|
国产成人一区二区三区在线|
久久久久久久久久久免费精品|
久久久久99精品成人片牛牛影视|
青草99在线免费观看|
国产精品视频白浆免费视频|
精品国产性色av网站|
亚洲理论在线A中文字幕|
国产成人久久精品二三区|
国产国产乱老熟女视频网站97|
国产亚洲精品AA片在线爽|
亚洲最大色综合成人av|
中文字幕午夜福利片午夜福利片97
|
亚洲综合另类小说色区色噜噜|
夜爽8888视频在线观看|
国产精品伊人久久综合网|
黄床大片免费30分钟国产精品|
亚洲a人片在线观看网址|
激情文学一区二区国产区|
另类专区一区二区三区|
麻豆一区二区中文字幕|
国产精品亚洲二区在线播放|
精品国产品香蕉在线|
精品国产精品国产偷麻豆|
日韩精品成人区中文字幕|
久久久久国产一级毛片高清版A|
亚洲AV日韩AV综合在线观看
|
亚洲色欲色欲大片www无码|
国产精品va在线观看h|
成av人片一区二区久久|
天堂网亚洲综合在线|
一区二区在线观看 激情|
精品一区二区亚洲国产|
国产电影一区二区三区|
国内自拍偷拍一区二区三区|
中国CHINA体内裑精亚洲日本|
日夜啪啪一区二区三区|
久久一日本综合色鬼综合色|
国产精品色内内在线播放|