[BACK]Return to ssh-agent.c CVS log [TXT][DIR] Up to [local] / src / usr.bin / ssh

Diff for /src/usr.bin/ssh/ssh-agent.c between version 1.11 and 1.12

version 1.11, 1999/10/07 22:46:32 version 1.12, 1999/10/14 18:17:42
Line 31 
Line 31 
 typedef struct  typedef struct
 {  {
   int fd;    int fd;
   enum { AUTH_UNUSED, AUTH_FD, AUTH_SOCKET, AUTH_SOCKET_FD,    enum { AUTH_UNUSED, AUTH_SOCKET, AUTH_CONNECTION } type;
     AUTH_CONNECTION } type;  
   Buffer input;    Buffer input;
   Buffer output;    Buffer output;
 } SocketEntry;  } SocketEntry;
Line 324 
Line 323 
     return;      return;
   buffer_consume(&e->input, 4);    buffer_consume(&e->input, 4);
   type = buffer_get_char(&e->input);    type = buffer_get_char(&e->input);
   
   switch (type)    switch (type)
     {      {
     case SSH_AGENTC_REQUEST_RSA_IDENTITIES:      case SSH_AGENTC_REQUEST_RSA_IDENTITIES:
Line 391 
Line 391 
   for (i = 0; i < sockets_alloc; i++)    for (i = 0; i < sockets_alloc; i++)
     switch (sockets[i].type)      switch (sockets[i].type)
       {        {
       case AUTH_FD:  
       case AUTH_CONNECTION:  
       case AUTH_SOCKET:        case AUTH_SOCKET:
       case AUTH_SOCKET_FD:        case AUTH_CONNECTION:
         FD_SET(sockets[i].fd, readset);          FD_SET(sockets[i].fd, readset);
         if (buffer_len(&sockets[i].output) > 0)          if (buffer_len(&sockets[i].output) > 0)
           FD_SET(sockets[i].fd, writeset);            FD_SET(sockets[i].fd, writeset);
Line 410 
Line 408 
 void after_select(fd_set *readset, fd_set *writeset)  void after_select(fd_set *readset, fd_set *writeset)
 {  {
   unsigned int i;    unsigned int i;
   int len, sock, port;    int len, sock;
   char buf[1024];    char buf[1024];
   struct sockaddr_in sin;  
   struct sockaddr_un sunaddr;    struct sockaddr_un sunaddr;
   
   for (i = 0; i < sockets_alloc; i++)    for (i = 0; i < sockets_alloc; i++)
Line 420 
Line 417 
       {        {
       case AUTH_UNUSED:        case AUTH_UNUSED:
         break;          break;
       case AUTH_FD:  
         if (FD_ISSET(sockets[i].fd, readset))  
           {  
             len = recv(sockets[i].fd, buf, sizeof(buf), 0);  
             if (len <= 0)  
               { /* All instances of the other side have been closed. */  
                 log("Authentication agent exiting.");  
                 exit(0);  
               }  
           process_auth_fd_input:  
             if (len != 3 || (unsigned char)buf[0] != SSH_AUTHFD_CONNECT)  
               break; /* Incorrect message; ignore it. */  
             /* It is a connection request message. */  
             port = (unsigned char)buf[1] * 256 + (unsigned char)buf[2];  
             memset(&sin, 0, sizeof(sin));  
             sin.sin_family = AF_INET;  
             sin.sin_addr.s_addr = htonl(0x7f000001); /* localhost */  
             sin.sin_port = htons(port);  
             sock = socket(AF_INET, SOCK_STREAM, 0);  
             if (sock < 0)  
               {  
                 perror("socket");  
                 break;  
               }  
             if (connect(sock, (struct sockaddr *)&sin, sizeof(sin)) < 0)  
               {  
                 perror("connecting to port requested in authfd message");  
                 close(sock);  
                 break;  
               }  
             new_socket(AUTH_CONNECTION, sock);  
           }  
         break;  
       case AUTH_SOCKET:        case AUTH_SOCKET:
         if (FD_ISSET(sockets[i].fd, readset))          if (FD_ISSET(sockets[i].fd, readset))
           {            {
Line 463 
Line 427 
                 perror("accept from AUTH_SOCKET");                  perror("accept from AUTH_SOCKET");
                 break;                  break;
               }                }
             new_socket(AUTH_SOCKET_FD, sock);              new_socket(AUTH_CONNECTION, sock);
           }            }
         break;          break;
       case AUTH_SOCKET_FD:  
         if (FD_ISSET(sockets[i].fd, readset))  
           {  
             len = recv(sockets[i].fd, buf, sizeof(buf), 0);  
             if (len <= 0)  
               { /* The other side has closed the socket. */  
                 shutdown(sockets[i].fd, SHUT_RDWR);  
                 close(sockets[i].fd);  
                 sockets[i].type = AUTH_UNUSED;  
                 break;  
               }  
             goto process_auth_fd_input;  
           }  
         break;  
       case AUTH_CONNECTION:        case AUTH_CONNECTION:
         if (buffer_len(&sockets[i].output) > 0 &&          if (buffer_len(&sockets[i].output) > 0 &&
             FD_ISSET(sockets[i].fd, writeset))              FD_ISSET(sockets[i].fd, writeset))
Line 568 
Line 518 
      the authentication agent. */       the authentication agent. */
   if (fork() != 0)    if (fork() != 0)
     { /* Parent - execute the given command. */      { /* Parent - execute the given command. */
       setenv("SSH_AUTHENTICATION_SOCKET", socket_name, 1);        setenv(SSH_AUTHSOCKET_ENV_NAME, socket_name, 1);
       execvp(av[1], av + 1);        execvp(av[1], av + 1);
       perror(av[1]);        perror(av[1]);
       exit(1);        exit(1);
Legend:
Removed from v.1.11  
changed lines
  Added in v.1.12