/* 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 */
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--;
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;
}
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);
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. */
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];
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--;
}
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;
* 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) {
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;
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)
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;
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,
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,
/* 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,
"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
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,