[fix] fix some compatibility bugs.

Author: wangxingyuan

ngx_rtmp.c

@@ -777,9 +777,11 @@ ngx_rtmp_init_listening(ngx_conf_t *cf, ngx_rtmp_conf_port_t *port)
                 break;
         }
 
+#if (NGX_HAVE_REUSEPORT)
         if (ngx_clone_listening(cf, ls) != NGX_OK) {
             return NGX_ERROR;
         }
+#endif
 
         addr++;
         last--;
@@ -1340,3 +1342,63 @@ ngx_rtmp_find_virtual_server(ngx_connection_t *c,
 
     return NGX_DECLINED;
 }
+
+
+#if (nginx_version <= 1011001)
+in_port_t
+ngx_inet_get_port(struct sockaddr *sa)
+{
+    struct sockaddr_in   *sin;
+#if (NGX_HAVE_INET6)
+    struct sockaddr_in6  *sin6;
+#endif
+
+    switch (sa->sa_family) {
+
+#if (NGX_HAVE_INET6)
+    case AF_INET6:
+        sin6 = (struct sockaddr_in6 *) sa;
+        return ntohs(sin6->sin6_port);
+#endif
+
+#if (NGX_HAVE_UNIX_DOMAIN)
+    case AF_UNIX:
+        return 0;
+#endif
+
+    default: /* AF_INET */
+        sin = (struct sockaddr_in *) sa;
+        return ntohs(sin->sin_port);
+    }
+}
+
+
+void
+ngx_inet_set_port(struct sockaddr *sa, in_port_t port)
+{
+    struct sockaddr_in   *sin;
+#if (NGX_HAVE_INET6)
+    struct sockaddr_in6  *sin6;
+#endif
+
+    switch (sa->sa_family) {
+
+#if (NGX_HAVE_INET6)
+    case AF_INET6:
+        sin6 = (struct sockaddr_in6 *) sa;
+        sin6->sin6_port = htons(port);
+        break;
+#endif
+
+#if (NGX_HAVE_UNIX_DOMAIN)
+    case AF_UNIX:
+        break;
+#endif
+
+    default: /* AF_INET */
+        sin = (struct sockaddr_in *) sa;
+        sin->sin_port = htons(port);
+        break;
+    }
+}
+#endif

ngx_rtmp.h

@@ -82,6 +82,20 @@ typedef struct {
 } ngx_rtmp_conf_port_t;
 
 
+#if (nginx_version <= 1010003)
+typedef union {
+    struct sockaddr           sockaddr;
+    struct sockaddr_in        sockaddr_in;
+#if (NGX_HAVE_INET6)
+    struct sockaddr_in6       sockaddr_in6;
+#endif
+#if (NGX_HAVE_UNIX_DOMAIN)
+    struct sockaddr_un        sockaddr_un;
+#endif
+} ngx_sockaddr_t;
+#endif
+
+
 typedef struct {
     ngx_sockaddr_t             sockaddr;
     socklen_t                  socklen;
@@ -821,6 +835,9 @@ ngx_int_t ngx_rtmp_validate_host(ngx_str_t *host, ngx_pool_t *pool,
 ngx_int_t ngx_rtmp_set_virtual_server(ngx_rtmp_session_t *s, ngx_str_t *host);
 ngx_int_t ngx_rtmp_process_request_line(ngx_rtmp_session_t *s,
     const u_char *name, const u_char *args, const u_char *cmd);
-
+#if (nginx_version <= 1011001)
+in_port_t ngx_inet_get_port(struct sockaddr *sa);
+void ngx_inet_set_port(struct sockaddr *sa, in_port_t port);
+#endif
 
 #endif /* _NGX_RTMP_H_INCLUDED_ */