add libvncserver

[presencevnc] / libvnc / vncterm / VNCommand.c

diff --git a/libvnc/vncterm/VNCommand.c b/libvnc/vncterm/VNCommand.c
new file mode 100644 (file)
index 0000000..ecf2543
--- /dev/null
+++ b/libvnc/vncterm/VNCommand.c
@@ -0,0 +1,127 @@
+#ifdef __STRICT_ANSI__
+#define _BSD_SOURCE
+#define _POSIX_SOURCE
+#endif
+#include "VNConsole.h"
+#include "vga.h"
+#ifdef LIBVNCSERVER_HAVE_FCNTL_H
+#include <fcntl.h>
+#endif
+#ifdef LIBVNCSERVER_HAVE_SYS_TIME_H
+#include <sys/time.h>
+#endif
+#ifdef LIBVNCSERVER_HAVE_UNISTD_H
+#include <unistd.h>
+#endif
+#ifdef LIBVNCSERVER_HAVE_SYS_WAIT_H
+#include <sys/wait.h>
+#endif
+#include <errno.h>
+
+
+int main(int argc, char **argv)
+{
+  rfbBool interactive=FALSE,sendOnlyWholeLines=TRUE;
+  int serverArgc,programArg0;
+  for(serverArgc=1;serverArgc<argc
+       && argv[serverArgc][0]=='-' && argv[serverArgc][1]!='-';serverArgc++)
+    if(!strcmp(argv[serverArgc],"-interactive")) {
+      interactive=TRUE;
+      sendOnlyWholeLines=FALSE;
+
+      rfbPurgeArguments(&argc,&serverArgc,1,argv);
+    }
+  programArg0=serverArgc;
+  if(programArg0<argc && argv[programArg0][0]=='-' && argv[programArg0][1]=='-')
+    programArg0++;
+  argv[argc]=0;
+
+  if(programArg0<argc) {
+    int in[2],out[2],err[2],pid;
+    if(pipe(in)<0 || pipe(out)<0 || pipe(err)<0) {
+      rfbErr("Couldn't make pipes!");
+      return(1);
+    }
+
+    pid=fork();
+    if(!pid) {
+      dup2(in[0],0);
+      dup2(out[1],1);
+      dup2(err[1],2);
+      /*setbuf(stdin,NULL);*/
+      execvp(argv[programArg0],argv+programArg0);
+    }
+
+    {
+      char buffer[1024];
+      fd_set fs,fs1/*,ifs,ifs1*/;
+      struct timeval tv,tv1;
+      int i,c=1,num_fds,max_fd=out[0],status;
+      FILE *input_pipe;
+      vncConsolePtr console=vcGetConsole(&serverArgc,argv,80,25,&vgaFont,FALSE);
+      if(interactive)
+       console->doEcho = FALSE;
+
+      if(max_fd<err[0])
+       max_fd=err[0];
+      FD_ZERO(&fs);
+      FD_SET(out[0],&fs);
+      FD_SET(err[0],&fs);
+      /*FD_SET(0,&fs);*/
+      tv.tv_sec=0; tv.tv_usec=5000;
+
+      input_pipe=fdopen(in[1],"w");
+      setbuf(input_pipe,NULL);
+      while(c || waitpid(pid,&status,WNOHANG)==0) {
+       /* event loop */
+       vcProcessEvents(console);
+
+       /* get input */
+       if(console->inputCount) {
+         if(sendOnlyWholeLines) {
+           for(i=0;i<console->inputCount;i++)
+             if(console->inputBuffer[i]=='\n') {
+               i++;
+               fwrite(console->inputBuffer,i,1,input_pipe);
+               fflush(input_pipe);
+               /* fwrite(console->inputBuffer,i,1,stderr); */
+               if(console->inputCount>i)
+                 memmove(console->inputBuffer,console->inputBuffer+i,console->inputCount-i);
+               console->inputCount-=i;
+               i=0;
+             }
+         } else {
+           fwrite(console->inputBuffer,console->inputCount,1,input_pipe);
+           fflush(input_pipe);
+           /* fwrite(console->inputBuffer,console->inputCount,1,stderr); */
+           console->inputCount=0;
+         }
+       }
+       /* process output */
+       fs1=fs; tv1=tv;
+       num_fds=select(max_fd+1,&fs1,NULL,NULL,&tv1);
+       if(num_fds>0) {
+         /*
+         if(FD_ISSET(0,&fs1)) {
+           ch=getchar();
+           fputc(ch,f);
+         }
+         */
+         if(FD_ISSET(out[0],&fs1)) {
+           c=read(out[0],buffer,1024);
+           for(i=0;i<c;i++)
+             vcPutChar(console,buffer[i]);
+         }
+         if(FD_ISSET(err[0],&fs1)) {
+           c=read(err[0],buffer,1024);
+           for(i=0;i<c;i++)
+             vcPutChar(console,buffer[i]);
+         }             
+       } else
+         c=0;
+      }
+    }
+  }
+  rfbLog("exit\n");
+  return(0);
+}