diff options
author | matz <matz@b2dd03c8-39d4-4d8f-98ff-823fe69b080e> | 1999-08-13 05:37:52 +0000 |
---|---|---|
committer | matz <matz@b2dd03c8-39d4-4d8f-98ff-823fe69b080e> | 1999-08-13 05:37:52 +0000 |
commit | 0a64817fb80016030c03518fb9459f63c11605ea (patch) | |
tree | 3ea2e607f9ea08c56830ef7b803cd259e3d67c7f /ext/pty/pty.c | |
parent | 210367ec889f5910e270d6ea2c7ddb8a8d939e61 (diff) |
remove marshal/gtk/kconv
git-svn-id: svn+ssh://ci.ruby-lang.org/ruby/trunk@518 b2dd03c8-39d4-4d8f-98ff-823fe69b080e
Diffstat (limited to 'ext/pty/pty.c')
-rw-r--r-- | ext/pty/pty.c | 497 |
1 files changed, 497 insertions, 0 deletions
diff --git a/ext/pty/pty.c b/ext/pty/pty.c new file mode 100644 index 0000000000..98be9044b7 --- /dev/null +++ b/ext/pty/pty.c @@ -0,0 +1,497 @@ +#include "config.h" +#include <stdio.h> +#include <sys/types.h> +#include <sys/file.h> +#include <fcntl.h> +#include <errno.h> +#include <pwd.h> +#if !defined(HAVE_OPENPTY) && !defined(HAVE__GETPTY) +#include <sys/ioctl.h> +#endif +#ifdef HAVE_SYS_WAIT_H +#include <sys/wait.h> +#else +#define WIFSTOPPED(status) (((status) & 0xff) == 0x7f) +#endif +#include <ctype.h> + +#include <ruby.h> +#include <rubyio.h> + +#include <signal.h> +#ifdef HAVE_SYS_STROPTS_H +#include <sys/stropts.h> +#endif + +#ifdef HAVE_UNISTD_H +#include <unistd.h> +#endif + +#define DEVICELEN 16 + +#if !defined(HAVE_OPENPTY) +#ifdef __hpux +char *MasterDevice = "/dev/ptym/pty%s", + *SlaveDevice = "/dev/pty/tty%s", + *deviceNo[] = { + "p0","p1","p2","p3","p4","p5","p6","p7", + "p8","p9","pa","pb","pc","pd","pe","pf", + "q0","q1","q2","q3","q4","q5","q6","q7", + "q8","q9","qa","qb","qc","qd","qe","qf", + "r0","r1","r2","r3","r4","r5","r6","r7", + "r8","r9","ra","rb","rc","rd","re","rf", + "s0","s1","s2","s3","s4","s5","s6","s7", + "s8","s9","sa","sb","sc","sd","se","sf", + "t0","t1","t2","t3","t4","t5","t6","t7", + "t8","t9","ta","tb","tc","td","te","tf", + "u0","u1","u2","u3","u4","u5","u6","u7", + "u8","u9","ua","ub","uc","ud","ue","uf", + "v0","v1","v2","v3","v4","v5","v6","v7", + "v8","v9","va","vb","vc","vd","ve","vf", + "w0","w1","w2","w3","w4","w5","w6","w7", + "w8","w9","wa","wb","wc","wd","we","wf", + 0, + }; +#else /* NOT HPUX */ +#ifdef _IBMESA /* AIX/ESA */ +char *MasterDevice = "/dev/ptyp%s", + *SlaveDevice = "/dev/ttyp%s", + *deviceNo[] = { +"00","01","02","03","04","05","06","07","08","09","0a","0b","0c","0d","0e","0f", +"10","11","12","13","14","15","16","17","18","19","1a","1b","1c","1d","1e","1f", +"20","21","22","23","24","25","26","27","28","29","2a","2b","2c","2d","2e","2f", +"30","31","32","33","34","35","36","37","38","39","3a","3b","3c","3d","3e","3f", +"40","41","42","43","44","45","46","47","48","49","4a","4b","4c","4d","4e","4f", +"50","51","52","53","54","55","56","57","58","59","5a","5b","5c","5d","5e","5f", +"60","61","62","63","64","65","66","67","68","69","6a","6b","6c","6d","6e","6f", +"70","71","72","73","74","75","76","77","78","79","7a","7b","7c","7d","7e","7f", +"80","81","82","83","84","85","86","87","88","89","8a","8b","8c","8d","8e","8f", +"90","91","92","93","94","95","96","97","98","99","9a","9b","9c","9d","9e","9f", +"a0","a1","a2","a3","a4","a5","a6","a7","a8","a9","aa","ab","ac","ad","ae","af", +"b0","b1","b2","b3","b4","b5","b6","b7","b8","b9","ba","bb","bc","bd","be","bf", +"c0","c1","c2","c3","c4","c5","c6","c7","c8","c9","ca","cb","cc","cd","ce","cf", +"d0","d1","d2","d3","d4","d5","d6","d7","d8","d9","da","db","dc","dd","de","df", +"e0","e1","e2","e3","e4","e5","e6","e7","e8","e9","ea","eb","ec","ed","ee","ef", +"f0","f1","f2","f3","f4","f5","f6","f7","f8","f9","fa","fb","fc","fd","fe","ff", + }; +#else +char *MasterDevice = "/dev/pty%s", + *SlaveDevice = "/dev/tty%s", + *deviceNo[] = { + "p0","p1","p2","p3","p4","p5","p6","p7", + "p8","p9","pa","pb","pc","pd","pe","pf", + "q0","q1","q2","q3","q4","q5","q6","q7", + "q8","q9","qa","qb","qc","qd","qe","qf", + "r0","r1","r2","r3","r4","r5","r6","r7", + "r8","r9","ra","rb","rc","rd","re","rf", + 0, + }; +#endif /* _IBMESA */ +#endif /* HPUX */ +#endif /* !defined(HAVE_OPENPTY) */ + +char SlaveName[DEVICELEN]; + +extern int errno; + +#define MAX_PTY 16 +static int n_pty,last_pty; +static int chld_pid[MAX_PTY]; + +#ifndef HAVE_SETEUID +# ifdef HAVE_SETREUID +# define seteuid(e) setreuid(-1, (e)) +# else /* NOT HAVE_SETREUID */ +# ifdef HAVE_SETRESUID +# define seteuid(e) setresuid(-1, (e), -1) +# else /* NOT HAVE_SETRESUID */ + /* I can't set euid. (;_;) */ +# endif /* HAVE_SETRESUID */ +# endif /* HAVE_SETREUID */ +#endif /* NO_SETEUID */ + +struct pty_info { + int fd; + pid_t child_pid; +}; + +static void +set_signal_action(action) + RETSIGTYPE (*action)(); +{ +#ifdef __hpux + struct sigvec sv; + /* + * signal SIGCHLD should be delivered on stop of the child + */ + sv.sv_handler = action; + sv.sv_mask = sigmask(SIGCHLD); + sv.sv_flags = SV_BSDSIG; + sigvector(SIGCHLD, &sv, (struct sigvec *) 0); +#else /* not HPUX */ +#if defined(SA_NOCLDSTOP) + struct sigaction sa; + /* + * signal SIGCHLD should be delivered on stop of the child + * (for SVR4) + */ + sa.sa_handler = action; + sigemptyset(&sa.sa_mask); + sigaddset(&sa.sa_mask, SIGCHLD); + sa.sa_flags = 0; /* SA_NOCLDSTOP flag is removed */ + sigaction(SIGCHLD, &sa, (struct sigaction *) 0); +#else + signal(SIGCHLD,action); +#endif +#endif /* not HPUX */ + +} + +static void +reset_signal_action() +{ + set_signal_action(SIG_DFL); +} + +static RETSIGTYPE +chld_changed() +{ + int cpid; + int i,n = -1; + int statusp; + + for (;;) { +#ifdef HAVE_WAITPID + cpid = waitpid(-1, &statusp, WUNTRACED|WNOHANG); +#else + cpid = wait3(&statusp, WUNTRACED|WNOHANG, 0); +#endif + if (cpid == 0 || cpid == -1) + return; + for (i = 0; i < last_pty; i++) { + if (chld_pid[i] == cpid) { + n = i; + goto catched; + } + } + rb_raise(rb_eRuntimeError, "fork: %d", cpid); + } + catched: + +#ifdef IF_STOPPED + if (IF_STOPPED(statusp)) { /* suspend */ + rb_raise(rb_eRuntimeError, "Stopped: %d",cpid); + } +#else +#ifdef WIFSTOPPED + if (WIFSTOPPED(statusp)) { /* suspend */ + rb_raise(rb_eRuntimeError, "Stopped: %d",cpid); + } +#else +---->> Either IF_STOPPED or WIFSTOPPED is needed <<---- +#endif /* WIFSTOPPED */ +#endif /* IF_STOPPED */ + if (n >= 0) { + chld_pid[n] = 0; + n_pty--; + if (n_pty == 0) + reset_signal_action(); + } + rb_raise(rb_eRuntimeError, "Child_changed: %d",cpid); +} + +static void getDevice _((int*, int*)); + +static void +establishShell(shellname, info) + char *shellname; + struct pty_info *info; +{ + static int i,j,master,slave,currentPid; + char *p,*getenv(); + struct passwd *pwent; + RETSIGTYPE chld_changed(); + + if (shellname[0] == '\0') { + if ((p = getenv("SHELL")) != NULL) { + shellname = p; + } + else { + pwent = getpwuid(getuid()); + if (pwent && pwent->pw_shell) + shellname = pwent->pw_shell; + else + shellname = "/bin/sh"; + } + } + getDevice(&master,&slave); + + currentPid = getpid(); + set_signal_action(chld_changed); + if((i = vfork()) < 0) { + rb_sys_fail("fork failed"); + } + + if(i == 0) { /* child */ + int argc; + char *argv[1024]; + currentPid = getpid(); + + /* + * Set free from process group and controlling terminal + */ +#ifdef HAVE_SETSID + (void) setsid(); +#else /* HAS_SETSID */ +# ifdef HAVE_SETPGRP +# ifdef SETGRP_VOID + if (setpgrp() == -1) + perror("setpgrp()"); +# else /* SETGRP_VOID */ + if (setpgrp(0, currentPid) == -1) + rb_sys_fail("setpgrp()"); + if ((i = open("/dev/tty", O_RDONLY)) < 0) + rb_sys_fail("/dev/tty"); + else { + if (ioctl(i, TIOCNOTTY, (char *)0)) + perror("ioctl(TIOCNOTTY)"); + close(i); + } +# endif /* SETGRP_VOID */ +# endif /* HAVE_SETPGRP */ +#endif /* HAS_SETSID */ + + /* + * obtain new controlling terminal + */ +#if defined(TIOCSCTTY) + close(master); + (void) ioctl(slave, TIOCSCTTY, (char *)0); + /* errors ignored for sun */ +#else + close(slave); + slave = open(SlaveName, O_RDWR); + if (slave < 0) { + perror("open: pty slave"); + _exit(1); + } + close(master); +#endif + dup2(slave,0); + dup2(slave,1); + dup2(slave,2); + close(slave); + + seteuid(getuid()); + + argc = 0; + for (i = 0; shellname[i];) { + while (isspace(shellname[i])) i++; + for (j = i; shellname[j] && !isspace(shellname[j]); j++); + argv[argc] = (char*)xmalloc(j-i+1); + strncpy(argv[argc],&shellname[i],j-i); + argv[argc][j-i] = 0; + i = j; + argc++; + } + argv[argc] = NULL; + execvp(argv[0],argv); + sleep(1); + _exit(1); + } + + close(slave); + + if (n_pty == last_pty) { + chld_pid[n_pty] = i; + n_pty++; + last_pty++; + } + else { + for (j = 0; j < last_pty; j++) { + if (chld_pid[j] == 0) { + chld_pid[j] = i; + n_pty++; + } + } + } + info->child_pid = i; + info->fd = master; +} + +#ifdef HAVE_OPENPTY +/* + * Use openpty(3) of 4.3BSD Reno and later, + * or the same interface function. + */ +static void +getDevice(master,slave) + int *master,*slave; +{ + if (openpty(master, slave, SlaveName, + (struct termios *)0, (struct winsize *)0) == -1) { + rb_raise(rb_eRuntimeError, "openpty() failed"); + } +} +#else /* HAVE_OPENPTY */ +#ifdef HAVE__GETPTY +static void +getDevice(master,slave) + int *master,*slave; +{ + char *name; + + if (!(name = _getpty(master, O_RDWR, 0622, 0))) { + rb_raise(rb_eRuntimeError, "_getpty() failed"); + } + + *slave = open(name, O_RDWR); + strcpy(SlaveName, name); +} +#else /* HAVE__GETPTY */ +static void +getDevice(master,slave) + int *master,*slave; +{ + char **p; + int i,j; + char MasterName[DEVICELEN]; + +#ifdef HAVE_DEV_PTMX + char *pn; + void (*s)(); + + extern char *ptsname(int); + extern int unlockpt(int); + extern int grantpt(int); + + if((i = open("/dev/ptmx", O_RDWR, 0)) != -1) { + s = signal(SIGCHLD, SIG_DFL); + if(grantpt(i) != -1) { + signal(SIGCHLD, s); + if(unlockpt(i) != -1) { + if((pn = ptsname(i)) != NULL) { + if((j = open(pn, O_RDWR, 0)) != -1) { +#if defined I_PUSH + if(ioctl(j, I_PUSH, "ptem") != -1) { + if(ioctl(j, I_PUSH, "ldterm") != -1) { +#endif + *master = i; + *slave = j; + strcpy(SlaveName, pn); + return; +#if defined I_PUSH + } + } +#endif + } + } + } + } + close(i); + } + rb_raise(rb_eRuntimeError, "Cannot get Master/Slave device"); +#else + for (p = deviceNo; *p != NULL; p++) { + sprintf(MasterName ,MasterDevice,*p); + if ((i = open(MasterName,O_RDWR,0)) >= 0) { + *master = i; + sprintf(SlaveName ,SlaveDevice,*p); + if ((j = open(SlaveName,O_RDWR,0)) >= 0) { + *slave = j; + chown(SlaveName, getuid(), getgid()); + chmod(SlaveName, 0622); + return; + } + close(i); + } + } + rb_raise(rb_eRuntimeError, "Cannot get %s\n", SlaveDevice); +#endif +} +#endif /* HAVE__GETPTY */ +#endif /* HAVE_OPENPTY */ + +static void +freeDevice() +{ + chmod(SlaveName, 0666); + chown(SlaveName, 0, 0); +} + +/* ruby function: getpty */ +static VALUE +pty_getpty(self, shell) + VALUE self, shell; +{ + VALUE res; + struct pty_info info; + OpenFile *wfptr,*rfptr; + NEWOBJ(rport, struct RFile); + NEWOBJ(wport, struct RFile); + + if (n_pty == MAX_PTY+1) { + rb_raise(rb_eRuntimeError, "Too many ptys are open"); + } + + OBJSETUP(rport, rb_cFile, T_FILE); + MakeOpenFile(rport, rfptr); + + OBJSETUP(wport, rb_cFile, T_FILE); + MakeOpenFile(wport, wfptr); + + establishShell(RSTRING(shell)->ptr,&info); + + rfptr->mode = rb_io_mode_flags("r"); + rfptr->f = fdopen(info.fd, "r"); + rfptr->path = strdup(RSTRING(shell)->ptr); + + wfptr->mode = rb_io_mode_flags("w"); + wfptr->f = fdopen(dup(info.fd), "w"); + wfptr->path = strdup(RSTRING(shell)->ptr); + + res = rb_ary_new2(2); + rb_ary_store(res,0,(VALUE)rport); + rb_ary_store(res,1,(VALUE)wport); + rb_ary_store(res,2,INT2FIX(info.child_pid)); + + if (rb_iterator_p()) { + rb_yield((VALUE)res); + reset_signal_action(); + return Qnil; + } + else { + return (VALUE)res; + } +} + +/* ruby function: protect_signal */ +static VALUE +pty_protect(self) + VALUE self; +{ + reset_signal_action(); + rb_yield(Qnil); + set_signal_action(chld_changed); + return self; +} + +static VALUE +pty_reset_signal(self) + VALUE self; +{ + reset_signal_action(); + return self; +} + +static VALUE cPTY; + +void +Init_pty() +{ + cPTY = rb_define_module("PTY"); + rb_define_module_function(cPTY,"getpty",pty_getpty,1); + rb_define_module_function(cPTY,"spawn",pty_getpty,1); + rb_define_module_function(cPTY,"protect_signal",pty_protect,0); + rb_define_module_function(cPTY,"reset_signal",pty_reset_signal,0); +} |