]> git.ipfire.org Git - thirdparty/apache/httpd.git/commitdiff
Bring network code to the parameter order spec. This means contexts go last,
authorRyan Bloom <rbb@apache.org>
Sun, 10 Oct 1999 20:35:06 +0000 (20:35 +0000)
committerRyan Bloom <rbb@apache.org>
Sun, 10 Oct 1999 20:35:06 +0000 (20:35 +0000)
and result parameters go first.  Also fixed a small bug in the Makefile.  We
should be removing the libs dir when we do a distclean, we are now.

git-svn-id: https://svn.apache.org/repos/asf/httpd/httpd/trunk@83956 13f79535-47bb-0310-9956-ffa450edef68

server/listen.c
server/mpm/dexter/dexter.c
server/mpm/mpmt_pthread/mpmt_pthread.c
server/mpm/prefork/prefork.c
server/mpm/winnt/mpm_winnt.c
server/rfc1413.c

index 5ded01b0af384a5a0b22b9820e08adefbf240648..c016ccaf7c9ba527b364f9e512c3133fe198b4c8 100644 (file)
@@ -160,7 +160,7 @@ static void alloc_listener(process_rec *process, char *addr, unsigned int port)
 
     /* see if we've got an old listener for this address:port */
     for (walk = &old_listeners; *walk; walk = &(*walk)->next) {
-        ap_getport((*walk)->sd, &oldport);
+        ap_getport(&oldport, (*walk)->sd);
        ap_getipaddr(oldaddr,sizeof oldaddr,(*walk)->sd);
        if (!strcmp(oldaddr, addr) && port == oldport) {
            /* re-use existing record */
index cff180d78dcc98dfa07b6982d3da0736aa8a6e7c..a2e2ae639707e75d1307046976a89e51a84c756e 100644 (file)
@@ -952,7 +952,7 @@ static void *worker_thread(void *arg)
             pthread_mutex_unlock(&idle_thread_count_mutex);
            break;
        }
-        ap_get_os_sock(csd, &native_socket);
+        ap_get_os_sock(&native_socket, csd);
         process_socket(ptrans, &sa_client, native_socket, conn_id);
         ap_clear_pool(ptrans);
         requests_this_child--;
@@ -1011,7 +1011,7 @@ static void child_main(int child_num_arg)
     listenfds[0].events = POLLIN;
     listenfds[0].revents = 0;
     for (lr = ap_listeners, i = 1; i <= num_listenfds; lr = lr->next, ++i) {
-        ap_get_os_sock(lr->sd, &listenfds[i].fd);
+        ap_get_os_sock(&listenfds[i].fd, lr->sd);
         listenfds[i].events = POLLIN; /* should we add POLLPRI ?*/
         listenfds[i].revents = 0;
     }
index 97254b512d9576869b82970881b0397b44af1670..cffac05e460b683070125e92647708c08b3ed3bb 100644 (file)
@@ -816,7 +816,7 @@ static void * worker_thread(void * dummy)
     worker_thread_count++;
     pthread_mutex_unlock(&worker_thread_count_mutex);
 
-    ap_setup_poll(&pollset, tpool, num_listensocks+1);
+    ap_setup_poll(&pollset, num_listensocks+1, tpool);
     for(n=0 ; n <= num_listensocks ; ++n)
        ap_add_poll_socket(pollset, listensocks[n], APR_POLLIN);
 
@@ -853,7 +853,7 @@ static void * worker_thread(void * dummy)
 
             if (workers_may_exit) break;
 
-           ap_get_revents(pollset, listensocks[0], &event);
+           ap_get_revents(&event, listensocks[0], pollset);
             if (event & APR_POLLIN) {
                 /* A process got a signal on the shutdown pipe. Check if we're
                  * the lucky process to die. */
@@ -874,7 +874,7 @@ static void * worker_thread(void * dummy)
                         curr_pollfd = 1;
                     }
                     /* XXX: Should we check for POLLERR? */
-                   ap_get_revents(pollset, listensocks[curr_pollfd], &event);
+                   ap_get_revents(&event, listensocks[curr_pollfd], pollset);
                     if (event & APR_POLLIN) {
                         last_pollfd = curr_pollfd;
                        sd=listensocks[curr_pollfd];
@@ -894,7 +894,7 @@ static void * worker_thread(void * dummy)
             SAFE_ACCEPT(intra_mutex_off(0));
             break;
         }
-        ap_get_os_sock(csd, &thesock);
+        ap_get_os_sock(&thesock, csd);
         process_socket(ptrans, &sa_client, thesock, process_slot, thread_slot);
         ap_clear_pool(ptrans);
         requests_this_child--;
index e628997bca1b6d30462c5bf2fa9ae3d947c10e1a..41e8f033d52b5de15370c7cdffcafd273dfe906d 100644 (file)
@@ -2047,7 +2047,7 @@ static void child_main(int child_num_arg)
                }
                first_lr=lr;
                do {
-                    ap_get_os_sock(lr->sd, &sockdes);
+                    ap_get_os_sock(&sockdes, lr->sd);
                    if (FD_ISSET(sockdes, &main_fds))
                        goto got_listener;
                    lr = lr->next;
@@ -2206,7 +2206,7 @@ static void child_main(int child_num_arg)
         * socket options, file descriptors, and read/write buffers.
         */
 
-        ap_get_os_sock(csd, &sockdes);
+        ap_get_os_sock(&sockdes, csd);
 
        clen = sizeof(sa_server);
        if (getsockname(sockdes, &sa_server, &clen) < 0) {
@@ -2544,7 +2544,7 @@ static int setup_listeners(server_rec *s)
     listenmaxfd = -1;
     FD_ZERO(&listenfds);
     for (lr = ap_listeners; lr; lr = lr->next) {
-        ap_get_os_sock(lr->sd, &sockdes);
+        ap_get_os_sock(&sockdes, lr->sd);
        FD_SET(sockdes, &listenfds);
        if (sockdes > listenmaxfd) {
            listenmaxfd = sockdes;
index 4242e75d403e968d89b4be8ce5fdb7529fb44c5a..13fa16edbca8272c72445014e0cf52149949a8fd 100644 (file)
@@ -353,7 +353,7 @@ static ap_inline ap_listen_rec *find_ready_listener(fd_set * main_fds)
     SOCKET nsd;
 
     for (lr = head_listener; lr ; lr = lr->next) {
-        ap_get_os_sock(lr->sd, &nsd);
+        ap_get_os_sock(&nsd, lr->sd);
        if (FD_ISSET(nsd, main_fds)) {
            head_listener = lr->next;
             if (head_listener == NULL)
@@ -379,7 +379,7 @@ static int setup_listeners(ap_context_t *pconf, server_rec *s)
     for (lr = ap_listeners; lr; lr = lr->next) {
         num_listeners++;
         if (lr->sd != NULL) {
-            ap_get_os_sock(lr->sd, &nsd);
+            ap_get_os_sock(&nsd, lr->sd);
             FD_SET(nsd, &listenfds);
             if (listenmaxfd == INVALID_SOCKET || nsd > listenmaxfd) {
                 listenmaxfd = nsd;
@@ -749,7 +749,7 @@ static int create_and_queue_completion_context(ap_context_t *p, ap_listen_rec *l
     context->conn_io =  ap_bcreate(context->ptrans, B_RDWR);
     context->recv_buf = context->conn_io->inbase;
     context->recv_buf_size = context->conn_io->bufsiz - 2*PADDED_ADDR_SIZE;
-    ap_get_os_sock(context->lr->sd, &nsd);
+    ap_get_os_sock(&nsd, context->lr->sd);
 
     AcceptEx(nsd,//context->lr->fd, 
              context->accept_socket,
@@ -779,7 +779,7 @@ static ap_inline void reset_completion_context(PCOMP_CONTEXT context)
     context->conn_io =  ap_bcreate(context->ptrans, B_RDWR);
     context->recv_buf = context->conn_io->inbase;
     context->recv_buf_size = context->conn_io->bufsiz - 2*PADDED_ADDR_SIZE;
-    ap_get_os_sock(context->lr->sd, &nsd);
+    ap_get_os_sock(&nsd, context->lr->sd);
 
     rc = AcceptEx(nsd, //context->lr->fd, 
                   context->accept_socket,
@@ -1082,7 +1082,7 @@ static void worker_main()
 
         /* Associate each listener with the completion port */
         for (lr = ap_listeners; lr != NULL; lr = lr->next) {
-            ap_get_os_sock(lr->sd, &nsd);
+            ap_get_os_sock(&nsd, lr->sd);
             CreateIoCompletionPort((HANDLE) nsd, //(HANDLE)lr->fd,
                                    AcceptExCompPort,
                                    0,
index c3d8be2a19a238385899c8e881279d1f001b821c..ac7092167da96024a3b83ad514786c65fd91656f 100644 (file)
@@ -131,7 +131,7 @@ static int get_rfc1413(ap_socket_t *sock, const char *local_ip,
                    "bind: rfc1413: Error binding to local port");
        return -1;
     }
-    ap_getport(sock, &sav_our_port);
+    ap_getport(&sav_our_port, sock);
 
 /*
  * errors from connect usually imply the remote machine doesn't support
@@ -142,7 +142,7 @@ static int get_rfc1413(ap_socket_t *sock, const char *local_ip,
                     
     if (ap_connect(sock, NULL) != APR_SUCCESS)
         return -1;
-    ap_getport(sock, &sav_rmt_port);
+    ap_getport(&sav_rmt_port, sock);
 
 /* send the data */
     buflen = ap_snprintf(buffer, sizeof(buffer), "%u,%u\r\n", sav_rmt_port,