fix timeout
This commit is contained in:
parent
410cc2b6c6
commit
ddeede0ebe
60
MD_Getc.c
60
MD_Getc.c
@ -2,9 +2,9 @@
|
|||||||
#include <stdio.h>
|
#include <stdio.h>
|
||||||
#if defined(_MSC_VER) || defined(WIN32)
|
#if defined(_MSC_VER) || defined(WIN32)
|
||||||
#include <winsock2.h>
|
#include <winsock2.h>
|
||||||
#define STDIN_FILENO 1
|
|
||||||
#else
|
#else
|
||||||
#include <sys/socket.h>
|
#include <sys/socket.h>
|
||||||
|
#include <sys/select.h>
|
||||||
#include <unistd.h>
|
#include <unistd.h>
|
||||||
#endif
|
#endif
|
||||||
#include <time.h>
|
#include <time.h>
|
||||||
@ -19,23 +19,31 @@ extern time_t mdtimeremaining;
|
|||||||
char md_getc() {
|
char md_getc() {
|
||||||
char c = 'x';
|
char c = 'x';
|
||||||
int ret;
|
int ret;
|
||||||
|
int rs;
|
||||||
|
|
||||||
int stage = 0;
|
int stage = 0;
|
||||||
|
|
||||||
|
struct timeval tv;
|
||||||
|
|
||||||
while (1) {
|
while (1) {
|
||||||
|
fd_set rfd;
|
||||||
|
FD_ZERO(&rfd);
|
||||||
if (mdcontrol.socket == -1) {
|
if (mdcontrol.socket == -1) {
|
||||||
ret = read(STDIN_FILENO, &c, 1);
|
FD_SET(STDIN_FILENO, &rfd);
|
||||||
} else {
|
} else {
|
||||||
ret = recv(mdcontrol.socket, &c, 1, 0);
|
FD_SET(mdcontrol.socket, &rfd);
|
||||||
}
|
}
|
||||||
if (ret == 0) {
|
|
||||||
md_exit(0);
|
tv.tv_sec = 60;
|
||||||
|
tv.tv_usec = 0;
|
||||||
|
|
||||||
|
if (mdcontrol.socket == -1) {
|
||||||
|
rs = select(STDIN_FILENO + 1, &rfd, NULL, NULL, &tv);
|
||||||
|
} else {
|
||||||
|
rs = select(mdcontrol.socket + 1, &rfd, NULL, NULL, &tv);
|
||||||
}
|
}
|
||||||
#if defined(_MSC_VER) || defined(WIN32)
|
|
||||||
if (ret == SOCKET_ERROR && WSAGetLastError() == WSAEWOULDBLOCK) {
|
if (rs == 0) {
|
||||||
#else
|
|
||||||
if (ret == -1 && (errno == EAGAIN || errno == EWOULDBLOCK)) {
|
|
||||||
#endif
|
|
||||||
if (mdtimeout <= time(NULL)) {
|
if (mdtimeout <= time(NULL)) {
|
||||||
md_printf("\r\nIdle timeout!\r\n");
|
md_printf("\r\nIdle timeout!\r\n");
|
||||||
md_exit(0);
|
md_exit(0);
|
||||||
@ -44,18 +52,13 @@ char md_getc() {
|
|||||||
md_printf("\r\nOut of time!\r\n");
|
md_printf("\r\nOut of time!\r\n");
|
||||||
md_exit(0);
|
md_exit(0);
|
||||||
}
|
}
|
||||||
#if defined(_MSC_VER)
|
} else if (rs == -1 && errno != EINTR) {
|
||||||
Sleep(1);
|
|
||||||
#else
|
|
||||||
usleep(100);
|
|
||||||
#endif
|
|
||||||
continue;
|
|
||||||
}
|
|
||||||
else if (ret < 0) {
|
|
||||||
md_exit(0);
|
md_exit(0);
|
||||||
}
|
} else if (mdcontrol.socket != -1 && FD_ISSET(mdcontrol.socket, &rfd)) {
|
||||||
|
ret = recv(mdcontrol.socket, &c, 1, 0);
|
||||||
if (mdcontrol.socket != -1) {
|
if (ret <= 0) {
|
||||||
|
md_exit(0);
|
||||||
|
}
|
||||||
if ((unsigned char)c == IAC && stage == 0) {
|
if ((unsigned char)c == IAC && stage == 0) {
|
||||||
stage = 1;
|
stage = 1;
|
||||||
continue;
|
continue;
|
||||||
@ -81,14 +84,21 @@ char md_getc() {
|
|||||||
}
|
}
|
||||||
continue;
|
continue;
|
||||||
}
|
}
|
||||||
}
|
|
||||||
|
|
||||||
mdtimeout = time(NULL) + 900;
|
mdtimeout = time(NULL) + 900;
|
||||||
return c;
|
return c;
|
||||||
|
} else if (mdcontrol.socket == -1 && FD_ISSET(STDIN_FILENO, &rfd)) {
|
||||||
|
ret = read(STDIN_FILENO, &c, 1);
|
||||||
|
if (ret <= 0) {
|
||||||
|
md_exit(0);
|
||||||
|
}
|
||||||
|
mdtimeout = time(NULL) + 900;
|
||||||
|
return c;
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
char md_get_answer(char *options) {
|
char md_get_answer(const char *options) {
|
||||||
char c;
|
char c;
|
||||||
c = md_getc();
|
c = md_getc();
|
||||||
while (strchr(options, c) == NULL) {
|
while (strchr(options, c) == NULL) {
|
||||||
|
@ -4,9 +4,6 @@
|
|||||||
#if defined(_MSC_VER) || defined(WIN32)
|
#if defined(_MSC_VER) || defined(WIN32)
|
||||||
#include <winsock2.h>
|
#include <winsock2.h>
|
||||||
#include "MD_AnsiCons.h"
|
#include "MD_AnsiCons.h"
|
||||||
|
|
||||||
#define STDOUT_FILENO 0
|
|
||||||
|
|
||||||
#else
|
#else
|
||||||
#include <sys/socket.h>
|
#include <sys/socket.h>
|
||||||
#include <unistd.h>
|
#include <unistd.h>
|
||||||
|
@ -4,7 +4,7 @@
|
|||||||
#include <stdint.h>
|
#include <stdint.h>
|
||||||
|
|
||||||
#define MAGIDOOR_VERSION_MAJOR 1
|
#define MAGIDOOR_VERSION_MAJOR 1
|
||||||
#define MAGIDOOR_VERSION_MINOR 2
|
#define MAGIDOOR_VERSION_MINOR 3
|
||||||
|
|
||||||
#define TRUE 1
|
#define TRUE 1
|
||||||
#define FALSE 0
|
#define FALSE 0
|
||||||
@ -34,5 +34,5 @@ extern int md_getstring(char* ptr, int maxlen, char minchar, char maxchar);
|
|||||||
extern void md_sendfile(const char* filename, int pause);
|
extern void md_sendfile(const char* filename, int pause);
|
||||||
extern void md_clr_scr();
|
extern void md_clr_scr();
|
||||||
extern void md_set_cursor(int y, int x);
|
extern void md_set_cursor(int y, int x);
|
||||||
extern char md_get_answer(char* options);
|
extern char md_get_answer(const char* options);
|
||||||
#endif
|
#endif
|
||||||
|
Loading…
x
Reference in New Issue
Block a user