37 网络相关函数(五)——live555源码阅读(四)网络

时间：2021-07-08 05:25:57

37 网络相关函数(五)——live555源码阅读(四)网络

本文由乌合之众 lym瞎编，欢迎转载 blog.cnblogs.net/oloroso
本文由乌合之众 lym瞎编，欢迎转载 my.oschina.net/oloroso

简介

网络相关函数是一系列用于操作网络数据的函数。在多个文件中都有相关的函数的定义。还有一些函数是系统socket API相关函数，就不提了。
　　　这一系列的函数大多有一个特点，需要一个UsageEnvironmet&型的参数。
　　　这些方法大多在live555sourcecontrol\groupsock\include\GroupsockHelper.hh中声明。

10)MAKE_SOCKADDR_IN构建sockaddr_in结构体宏
 

 #ifdef HAVE_SOCKADDR_LEN

 #define SET_SOCKADDR_SIN_LEN(var) var.sin_len = sizeof var

 #else

 #define SET_SOCKADDR_SIN_LEN(var)

 #endif

 // sockaddr_in var,使用adr和prt为其赋值(AF_INET)

 #define MAKE_SOCKADDR_IN(var,adr,prt) /*adr,prt must be in network order*/\

     struct sockaddr_in var;\

     var.sin_family = AF_INET;\

     var.sin_addr.s_addr = (adr);\

     var.sin_port = (prt);\

     SET_SOCKADDR_SIN_LEN(var);

11)setupDatagramSocket设置数据报套接口

setupDatagramSocket函数有两个参数(UsageEnvironment& env, Port port)。根据env的groupsockPriv成员来确定重用标识。如果groupsockPriv为空则使用默认设置。

setupDatagramSocket创建一个数据报形式的socket套接口，如果端口port 0，且ReceivingInterfaceAddrINADDR_ANY的时候，不进行绑定(bind)。否则若port==0的时候，绑定ReceivingInterfaceAddr（不为INADDR_ANY）和端口0(内核选择端口)。不为0的时候绑定INADDR_ANY(内核选择IP)和端口port。

绑定完成之后设置多播发生接口。如果全局的SendingInterfaceAddr== INADDR_ANY则不设置。
函数成功返回一个socket套接口句柄，失败返回-1。

 // 设置数据报套接字

 int setupDatagramSocket(UsageEnvironment& env, Port port) {

     // 初始化网络

     if (!initializeWinsockIfNecessary()) {

         socketErr(env, "Failed to initialize 'winsock': ");

         return -;

     }

     // 创建数据报套接字

     int newSocket = createSocket(SOCK_DGRAM);

     if (newSocket < ) {

         socketErr(env, "unable to create datagram socket: ");

         return newSocket;

     }

     // 获取env的groupsockPriv重新使用标识

     int reuseFlag = groupsockPriv(env)->reuseFlag;

     // 根据需要，为env释放groupsockPriv成员指向对象

     reclaimGroupsockPriv(env);

     // 设置允许重用本地地址和端口，reuseFlag用来接受传出值

     if (setsockopt(newSocket, SOL_SOCKET, SO_REUSEADDR,

         (const char*)&reuseFlag, sizeof reuseFlag) < ) {

         socketErr(env, "setsockopt(SO_REUSEADDR) error: ");

         closeSocket(newSocket);

         return -;

     }

 #if defined(__WIN32__) || defined(_WIN32)

     // Windoze doesn't properly handle SO_REUSEPORT or IP_MULTICAST_LOOP

     // win-doze 贬义,可能是由于操作系统BUG很多,而且运行速度慢,导致在运行的是后你会DOZE(打瞌睡)

     // Windows无法正确的处理SO_REUSEPORT或 IP_MULTICAST_LOOP

 #else

 #ifdef SO_REUSEPORT     //在定义了重新使用端口宏下设置

     if (setsockopt(newSocket, SOL_SOCKET, SO_REUSEPORT,

         (const char*)&reuseFlag, sizeof reuseFlag) < ) {

         socketErr(env, "setsockopt(SO_REUSEPORT) error: ");

         closeSocket(newSocket);

         return -;

     }

 #endif

 #ifdef IP_MULTICAST_LOOP    //在定义了IP多播循环下设置

     const u_int8_t loop = ;

     if (setsockopt(newSocket, IPPROTO_IP, IP_MULTICAST_LOOP,

         (const char*)&loop, sizeof loop) < ) {

         socketErr(env, "setsockopt(IP_MULTICAST_LOOP) error: ");

         closeSocket(newSocket);

         return -;

     }

 #endif

 #endif

     // Note: Windoze requires binding, even if the port number is 0

     // Windows 需要绑定，即使端口号是0

     netAddressBits addr = INADDR_ANY;   // 设置绑定地址是任意网口IP

 #if defined(__WIN32__) || defined(_WIN32)

 #else

     if (port.num() !=  || ReceivingInterfaceAddr != INADDR_ANY) {

         //ReceivingInterfaceAddr是一个全局的定义，默认是INADDR_ANY

 #endif

         if (port.num() == ) addr = ReceivingInterfaceAddr;

         // 组建sockaddr_in结构体

         MAKE_SOCKADDR_IN(name, addr, port.num());

         // 绑定socket套接口和sockaddr地址

         if (bind(newSocket, (struct sockaddr*)&name, sizeof name) != ) {

             char tmpBuffer[];

             sprintf(tmpBuffer, "bind() error (port number: %d): ",

                 ntohs(port.num()));

             socketErr(env, tmpBuffer);

             closeSocket(newSocket);

             return -;

         }

 #if defined(__WIN32__) || defined(_WIN32)

 #else

     }

 #endif

     // Set the sending interface for multicasts, if it's not the default:

     // 设置多播发送接口，如果它不是默认的：

     if (SendingInterfaceAddr != INADDR_ANY) {

         struct in_addr addr;

         addr.s_addr = SendingInterfaceAddr;

         // 设置多播接口

         if (setsockopt(newSocket, IPPROTO_IP, IP_MULTICAST_IF,

             (const char*)&addr, sizeof addr) < ) {

             socketErr(env, "error setting outgoing multicast interface: ");

             closeSocket(newSocket);

             return -;

         }

     }

     return newSocket;

 }

相关文章