/*
* Empire - A multi-player, client/server Internet based war game.
- * Copyright (C) 1986-2009, Dave Pare, Jeff Bailey, Thomas Ruschak,
- * Ken Stevens, Steve McClure
+ * Copyright (C) 1986-2011, Dave Pare, Jeff Bailey, Thomas Ruschak,
+ * Ken Stevens, Steve McClure, Markus Armbruster
*
- * This program is free software; you can redistribute it and/or modify
+ * Empire is free software: you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
- * the Free Software Foundation; either version 2 of the License, or
+ * the Free Software Foundation, either version 3 of the License, or
* (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
- * along with this program; if not, write to the Free Software
- * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
+ * along with this program. If not, see <http://www.gnu.org/licenses/>.
*
* ---
*
* play.c: Playing the game
*
* Known contributors to this file:
- * Markus Armbruster, 2007
+ * Markus Armbruster, 2007-2009
* Ron Koenderink, 2007-2009
*/
#include <signal.h>
#include <stdio.h>
#include <stdlib.h>
-#ifndef _WIN32
-#include <sys/select.h>
-#include <unistd.h>
-#else
+#ifdef _WIN32
#include <process.h>
-#include <io.h>
+#include <sys/socket.h>
+#else
+#include <sys/select.h>
#endif
+#include <unistd.h>
#include "linebuf.h"
#include "misc.h"
#include "proto.h"
static HANDLE ctrl_c_event;
static int bounce_status, bounce_error;
+struct sigaction {
+ int sa_flags;
+ void (*sa_handler)(int sig);
+};
+
#define SIGPIPE -1
static void (*ctrl_handler)(int sig) = { SIG_DFL };
/*
* This function uses to WaitForMultipleObjects to wait for both
* stdin and socket reading or writing.
- * Stdin is treated special in WIN32. Waiting for stdin is done
+ * Stdin is treated special in WIN32. Waiting for stdin is done
* via a bounce_full event which is set in the stdin thread.
- * Execute command file reading is done via handle. Execute
- * command is read via CreateFile/ReadFile instead open/read
- * because a file descriptor is not waitable.
- * WaitForMultipleObjects will only respond with one object
+ * Execute command file reading is done via handle.
+ * WaitForMultipleObjects will only respond with one object,
* so an additonal select is also done to determine
- * which individual events are active for the sock.
+ * which individual events are active.
*/
static int
-w32_select(int nfds, fd_set *rdfd, fd_set *wrfd, fd_set *errfd, struct timeval* time)
+w32_select(int nfds, fd_set *rdfd, fd_set *wrfd, fd_set *errfd,
+ struct timeval *time)
{
HANDLE handles[3];
SOCKET sock;
- int inp, result, s_result, num_handles;
+ int inp, sockfd, result, s_result, num_handles;
struct timeval tv_time = {0, 0};
- fd_set rdfd2;
+ fd_set rdsock, wrsock;
switch (rdfd->fd_count) {
case 1:
inp = -1;
- sock = rdfd->fd_array[0];
+ sockfd = rdfd->fd_array[0];
break;
case 2:
inp = rdfd->fd_array[0];
- sock = rdfd->fd_array[1];
+ sockfd = rdfd->fd_array[1];
break;
default:
assert(0);
}
+ sock = w32_fd2socket(sockfd);
assert(wrfd->fd_count == 0
- || (wrfd->fd_count == 1 && wrfd->fd_array[0] == sock));
+ || (wrfd->fd_count == 1 && wrfd->fd_array[0] == (SOCKET)sockfd));
assert(inp < 0 || inp == input_fd);
num_handles = 0;
handles[num_handles++] = ctrl_c_event;
if (inp >= 0)
- handles[num_handles++] = inp ? (HANDLE)inp : bounce_full;
+ handles[num_handles++]
+ = inp ? (HANDLE)_get_osfhandle(inp) : bounce_full;
/* always wait on the socket */
handles[num_handles++] = WSACreateEvent();
return -1;
}
- FD_ZERO(&rdfd2);
- FD_SET(sock, &rdfd2);
- s_result = select(sock + 1, &rdfd2, wrfd, NULL, &tv_time);
+ FD_ZERO(&rdsock);
+ FD_ZERO(&wrsock);
+ FD_SET(sock, &rdsock);
+ if (wrfd->fd_count)
+ FD_SET(sock, &wrsock);
+ s_result = select(sock + 1, &rdsock, &wrsock, NULL, &tv_time);
if (s_result < 0) {
- errno = WSAGetLastError();
+ w32_set_winsock_errno();
return s_result;
}
- *rdfd = rdfd2;
- if (inp >= 0 && result == WAIT_OBJECT_0 + 1) {
- FD_SET((SOCKET)inp, rdfd);
+ if (!FD_ISSET(sock, &rdsock))
+ FD_CLR((SOCKET)sockfd, rdfd);
+ if (!FD_ISSET(sock, &wrsock))
+ FD_CLR((SOCKET)sockfd, wrfd);
+ if (inp >= 0 && result == WAIT_OBJECT_0 + 1)
s_result++;
- }
+ else
+ FD_CLR((SOCKET)inp, rdfd);
+
return s_result;
}
int i, res;
if (fd)
- return ring_from_file(r, fd);
+ return ring_from_file(r, fd);
if (bounce_status < 0) {
- errno = bounce_error;
- res = bounce_status;
+ errno = bounce_error;
+ res = bounce_status;
} else {
- for (i = 0; i < bounce_status; i++) {
- if (ring_putc(r, bounce_buf[i]) == EOF) {
- /* more work to do, hold on to bounce_buf */
- memmove(bounce_buf, bounce_buf + i, bounce_status - i);
- bounce_status -= i;
- return i;
- }
- }
- res = i;
+ for (i = 0; i < bounce_status; i++) {
+ if (ring_putc(r, bounce_buf[i]) == EOF) {
+ /* more work to do, hold on to bounce_buf */
+ memmove(bounce_buf, bounce_buf + i, bounce_status - i);
+ bounce_status -= i;
+ return i;
+ }
+ }
+ res = i;
}
ResetEvent(bounce_full);
return res;
}
#define ring_from_file w32_ring_from_file_or_bounce_buf
-#define close(fd) w32_close_handle((fd))
-#define read(sock, buffer, buf_size) \
- w32_recv((sock), (buffer), (buf_size), 0)
#define select(nfds, rd, wr, error, time) \
w32_select((nfds), (rd), (wr), (error), (time))
#define sigemptyset(mask) ((void)0)
#endif
#define EOF_COOKIE "ctld\n"
-#define INTR_COOKIE "\naborted\n"
+#define INTR_COOKIE "aborted\n"
int input_fd;
int send_eof; /* need to send EOF_COOKIE */
struct sigaction sa;
struct ring inbuf; /* input buffer, draining to SOCK */
int eof_fd0; /* read fd 0 hit EOF? */
+ int input_eol; /* input ends with '\n'? */
fd_set rdfd, wrfd;
int n;
sigaction(SIGPIPE, &sa, NULL);
ring_init(&inbuf);
- eof_fd0 = send_eof = send_intr = 0;
+ eof_fd0 = input_eol = send_eof = send_intr = 0;
input_fd = 0;
sysdep_stdin_init();
}
}
- if (send_eof
+ if ((send_eof || send_intr) && !input_eol
+ && ring_putc(&inbuf, '\n') != EOF)
+ input_eol = 1;
+ if (send_eof && input_eol
&& ring_putm(&inbuf, EOF_COOKIE, sizeof(EOF_COOKIE) - 1) >= 0)
send_eof--;
- if (send_intr
+ if (send_intr && input_eol
&& ring_putm(&inbuf, INTR_COOKIE, sizeof(INTR_COOKIE) - 1) >= 0) {
send_intr = 0;
if (input_fd) {
sa.sa_handler = SIG_DFL;
sigaction(SIGINT, &sa, NULL);
}
- }
+ } else
+ input_eol = ring_peek(&inbuf, -1) == '\n';
}
/* send it to the server */