X-Git-Url: https://git.ucc.asn.au/?a=blobdiff_plain;f=src%2Fserver%2Fhandler_door.c;h=cc66945d810f237a60fd7f051814ea14b71a824b;hb=f66299331a4e635b3d25d3526e3900e67cd1895b;hp=fe8d1d98aadfb85c13abbeb7e2de0020ec223c6a;hpb=5c37cb7fbefa79cc79399cfb1da0c3b0c4c6bc9e;p=tpg%2Fopendispense2.git diff --git a/src/server/handler_door.c b/src/server/handler_door.c index fe8d1d9..cc66945 100644 --- a/src/server/handler_door.c +++ b/src/server/handler_door.c @@ -17,11 +17,11 @@ #include #include #include -#if !USE_POPEN -# include -#endif +#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 === @@ -85,9 +85,12 @@ int Door_CanDispense(int User, int Item) int Door_DoDispense(int User, int Item) { FILE *child_stdin; - char buf[512]; + #if 0 int stdin_pair[2]; int stdout_pair[2]; + #else + int child_stdin_fd; + #endif pid_t childPid; pid_t parentPid; @@ -107,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 ) { @@ -127,23 +123,18 @@ 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, 512)) < 0) + if( giDoor_ChildStatus || (len = read(child_stdin_fd, buf, sizeof buf)) < 0) { #if DEBUG printf("Door_DoDispense: fread fail\n"); @@ -152,52 +143,55 @@ int Door_DoDispense(int User, int Item) } 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 - printf("Door_DoDispense: fputs password\n"); - #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 + // Re-lock the door (and quit llogin) if( giDoor_ChildStatus || fputs("ATH0\n", child_stdin) == 0 ) { - #if DEBUG - printf("Door_DoDispense: fputs lock\n"); - #endif + 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);