X-Git-Url: https://git.ucc.asn.au/?a=blobdiff_plain;f=src%2Fserver%2Fhandler_door.c;h=cc66945d810f237a60fd7f051814ea14b71a824b;hb=470cc8029bc931275ce82dd33709ba90c4f4c62f;hp=69c5bcec9a9dab7d9140e62e42ab5066a22e1f4f;hpb=2263a6c4b7df73a8c5ac6968f0bb180ac5f7fb0e;p=tpg%2Fopendispense2.git diff --git a/src/server/handler_door.c b/src/server/handler_door.c index 69c5bce..cc66945 100644 --- a/src/server/handler_door.c +++ b/src/server/handler_door.c @@ -19,8 +19,9 @@ #include #include #include +#include -#define DOOR_UNLOCKED_DELAY 10 // 10 seconds before it re-locks +#define DOOR_UNLOCKED_DELAY 5 // Time in seconds before the door re-locks // === IMPORTS === @@ -84,8 +85,12 @@ int Door_CanDispense(int User, int Item) int Door_DoDispense(int User, int Item) { FILE *child_stdin; + #if 0 int stdin_pair[2]; int stdout_pair[2]; + #else + int child_stdin_fd; + #endif pid_t childPid; pid_t parentPid; @@ -105,16 +110,9 @@ int Door_DoDispense(int User, int Item) return 1; } - // Create stdin/stdout - if( pipe(stdin_pair) || pipe(stdout_pair) ) - { - perror("pipe"); - return -1; - } - giDoor_ChildStatus = 0; // Set child status to zero parentPid = getpid(); - childPid = fork(); + childPid = forkpty(&child_stdin_fd, NULL, NULL, NULL); if( childPid < 0 ) { @@ -125,83 +123,75 @@ int Door_DoDispense(int User, int Item) // Child process if( childPid == 0 ) { - // Close write end of stdin, and set it to #0 - close(stdin_pair[1]); dup2(stdin_pair[0], 0); - // Close read end of stdout, and set it to #1 - close(stdout_pair[0]); dup2(stdout_pair[1], 1); - - //execl("/bin/sh", "sh", "-c", "llogin door -w-", NULL); execl("/usr/bin/llogin", "llogin", "door", "-w-", NULL); perror("execl"); exit(-1); } - child_stdin = fdopen(stdin_pair[1], "w"); - close(stdin_pair[0]); // child stdin read - close(stdout_pair[1]); // child stdout write - + child_stdin = fdopen(child_stdin_fd, "w"); + + int read_child_output() { char buf[1024]; int len; - if( giDoor_ChildStatus || (len = read(stdout_pair[0], buf, sizeof buf)) < 0) + if( giDoor_ChildStatus || (len = read(child_stdin_fd, buf, sizeof buf)) < 0) { #if DEBUG - int child_exit; - waitpid(childPid, &child_exit, 0); - printf("Door_DoDispense: fread fail (child status %i)\n", child_exit); + printf("Door_DoDispense: fread fail\n"); #endif return -1; } buf[len] = '\0'; - #if DEBUG + #if DEBUG > 1 printf("Door_DoDispense: buf = %i '%s'\n", len, buf); #endif + return 0; } + + if( read_child_output() ) return -1; // Send password if( giDoor_ChildStatus || fputs(gsDoor_Password, child_stdin) <= 0 ) { - #if DEBUG - int child_exit; - waitpid(childPid, &child_exit, 0); - printf("Door_DoDispense: fputs password fail (child status %i)\n", child_exit); - #endif + printf("Door_DoDispense: fputs password fail\n"); return -1; } fputs("\n", child_stdin); + fflush(child_stdin); + if( read_child_output() ) return -1; #if DEBUG printf("Door_DoDispense: Door unlock\n"); #endif - // ATH1 - Unlock door - if( giDoor_ChildStatus || fputs("ATH1\n", child_stdin) <= 0) { + if( giDoor_ChildStatus || fputs("ATH1\n", child_stdin) == 0) { #if DEBUG - printf("Door_DoDispense: fputs unlock\n"); + printf("Door_DoDispense: fputs unlock failed (or child terminated)\n"); #endif return -1; } + fflush(child_stdin); // Wait before re-locking sleep(DOOR_UNLOCKED_DELAY); - #if DEBUG printf("Door_DoDispense: Door re-lock\n"); #endif - // Re-lock the door (and quit llogin) - if( giDoor_ChildStatus || fputs("ATH0\n\x1D", child_stdin) == 0 ) { - #if DEBUG - printf("Door_DoDispense: fputs lock\n"); - #endif + if( giDoor_ChildStatus || fputs("ATH0\n", child_stdin) == 0 ) { + fprintf(stderr, "Oh F**k, the door may be stuck unlocked, someone use llogin!\n"); return -1; } + fflush(child_stdin); + fputs("\x1D", child_stdin); + + // Wait a little so llogin can send the lock message + sleep(1); fclose(child_stdin); - close(stdin_pair[1]); // child stdin write - close(stdout_pair[0]); // child stdout read + close(child_stdin_fd); #if DEBUG printf("Door_DoDispense: User %i opened door\n", User);