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

Diff for /src/usr.bin/fstat/fstat.c between version 1.71 and 1.72

version 1.71, 2011/07/09 00:45:40 version 1.72, 2012/01/07 05:38:12
Line 73 
Line 73 
 #include <limits.h>  #include <limits.h>
 #include <nlist.h>  #include <nlist.h>
 #include <pwd.h>  #include <pwd.h>
   #include <search.h>
 #include <signal.h>  #include <signal.h>
 #include <stdio.h>  #include <stdio.h>
 #include <stdint.h>  #include <stdint.h>
Line 103 
Line 104 
   
 void fstat_dofile(struct kinfo_file2 *);  void fstat_dofile(struct kinfo_file2 *);
 void fstat_header(void);  void fstat_header(void);
 void fuser_dofile(struct kinfo_file2 *);  
 void getinetproto(int);  void getinetproto(int);
 void usage(void);  void usage(void);
 int getfname(char *);  int getfname(char *);
 void cryptotrans(struct kinfo_file2 *);  void cryptotrans(struct kinfo_file2 *);
 void kqueuetrans(struct kinfo_file2 *);  void kqueuetrans(struct kinfo_file2 *);
 void pipetrans(struct kinfo_file2 *);  void pipetrans(struct kinfo_file2 *);
   struct kinfo_file2 *splice_find(char, u_int64_t);
   void splice_insert(char, u_int64_t, struct kinfo_file2 *);
   void find_splices(struct kinfo_file2 *, int);
   void print_inet_details(struct kinfo_file2 *);
   #ifdef INET6
   void print_inet6_details(struct kinfo_file2 *);
   #endif
   void print_sock_details(struct kinfo_file2 *);
 void socktrans(struct kinfo_file2 *);  void socktrans(struct kinfo_file2 *);
 void systracetrans(struct kinfo_file2 *);  void systracetrans(struct kinfo_file2 *);
 void vtrans(struct kinfo_file2 *);  void vtrans(struct kinfo_file2 *);
Line 255 
Line 263 
         if ((kf = kvm_getfile2(kd, what, arg, sizeof(*kf), &cnt)) == NULL)          if ((kf = kvm_getfile2(kd, what, arg, sizeof(*kf), &cnt)) == NULL)
                 errx(1, "%s", kvm_geterr(kd));                  errx(1, "%s", kvm_geterr(kd));
   
           find_splices(kf, cnt);
         if (!fuser)          if (!fuser)
                 fstat_header();                  fstat_header();
         for (kflast = &kf[cnt]; kf < kflast; ++kf) {          for (kflast = &kf[cnt]; kf < kflast; ++kf) {
Line 543 
Line 552 
 #endif  #endif
   
 void  void
   splice_insert(char type, u_int64_t ptr, struct kinfo_file2 *data)
   {
           ENTRY entry, *found;
   
           if (asprintf(&entry.key, "%c%llx", type, ptr) == -1)
                   err(1, NULL);
           entry.data = data;
           if ((found = hsearch(entry, ENTER)) == NULL)
                   err(1, "hsearch");
           /* if it's ambiguous, set the data to NULL */
           if (found->data != data)
                   found->data = NULL;
   }
   
   struct kinfo_file2 *
   splice_find(char type, u_int64_t ptr)
   {
           ENTRY entry, *found;
           char buf[20];
   
           snprintf(buf, sizeof(buf), "%c%llx", type, ptr);
           entry.key = buf;
           found = hsearch(entry, FIND);
           return (found != NULL ? found->data : NULL);
   }
   
   void
   find_splices(struct kinfo_file2 *kf, int cnt)
   {
           int i, created;
   
           created = 0;
           for (i = 0; i < cnt; i++) {
                   if (kf[i].f_type != DTYPE_SOCKET ||
                       (kf[i].so_splice == 0 && kf[i].so_splicelen != -1))
                           continue;
                   if (created++ == 0) {
                           if (hcreate(1000) == 0)
                                   err(1, "hcreate");
                   }
                   splice_insert('>', kf[i].f_data, &kf[i]);
                   if (kf[i].so_splice != 0)
                           splice_insert('<', kf[i].so_splice, &kf[i]);
           }
   }
   
   void
   print_inet_details(struct kinfo_file2 *kf)
   {
           struct in_addr laddr, faddr;
   
           memcpy(&laddr, kf->inp_laddru, sizeof(laddr));
           memcpy(&faddr, kf->inp_faddru, sizeof(faddr));
           if (kf->so_protocol == IPPROTO_TCP) {
                   printf(" %p", (void *)(uintptr_t)kf->inp_ppcb);
                   printf(" %s:%d", laddr.s_addr == INADDR_ANY ? "*" :
                       inet_ntoa(laddr), ntohs(kf->inp_lport));
                   if (kf->inp_fport) {
                           if (kf->so_state & SS_CONNECTOUT)
                                   printf(" --> ");
                           else
                                   printf(" <-- ");
                           printf("%s:%d",
                               faddr.s_addr == INADDR_ANY ? "*" :
                               inet_ntoa(faddr), ntohs(kf->inp_fport));
                   }
           } else if (kf->so_protocol == IPPROTO_UDP) {
                   printf(" %s:%d", laddr.s_addr == INADDR_ANY ? "*" :
                       inet_ntoa(laddr), ntohs(kf->inp_lport));
                   if (kf->inp_fport) {
                           printf(" <-> %s:%d",
                               faddr.s_addr == INADDR_ANY ? "*" :
                               inet_ntoa(faddr), ntohs(kf->inp_fport));
                   }
           } else if (kf->so_pcb)
                   printf(" %p", (void *)(uintptr_t)kf->so_pcb);
   }
   
   #ifdef INET6
   void
   print_inet6_details(struct kinfo_file2 *kf)
   {
           char xaddrbuf[NI_MAXHOST + 2];
           struct in6_addr laddr6, faddr6;
   
           memcpy(&laddr6, kf->inp_laddru, sizeof(laddr6));
           memcpy(&faddr6, kf->inp_faddru, sizeof(faddr6));
           if (kf->so_protocol == IPPROTO_TCP) {
                   printf(" %p", (void *)(uintptr_t)kf->inp_ppcb);
                   snprintf(xaddrbuf, sizeof(xaddrbuf), "[%s]",
                       inet6_addrstr(&laddr6));
                   printf(" %s:%d",
                       IN6_IS_ADDR_UNSPECIFIED(&laddr6) ? "*" :
                       xaddrbuf, ntohs(kf->inp_lport));
                   if (kf->inp_fport) {
                           if (kf->so_state & SS_CONNECTOUT)
                                   printf(" --> ");
                           else
                                   printf(" <-- ");
                           snprintf(xaddrbuf, sizeof(xaddrbuf), "[%s]",
                               inet6_addrstr(&faddr6));
                           printf("%s:%d",
                               IN6_IS_ADDR_UNSPECIFIED(&faddr6) ? "*" :
                               xaddrbuf, ntohs(kf->inp_fport));
                   }
           } else if (kf->so_protocol == IPPROTO_UDP) {
                   snprintf(xaddrbuf, sizeof(xaddrbuf), "[%s]",
                       inet6_addrstr(&laddr6));
                   printf(" %s:%d",
                       IN6_IS_ADDR_UNSPECIFIED(&laddr6) ? "*" :
                       xaddrbuf, ntohs(kf->inp_lport));
                   if (kf->inp_fport) {
                           snprintf(xaddrbuf, sizeof(xaddrbuf), "[%s]",
                               inet6_addrstr(&faddr6));
                           printf(" <-> %s:%d",
                               IN6_IS_ADDR_UNSPECIFIED(&faddr6) ? "*" :
                               xaddrbuf, ntohs(kf->inp_fport));
                   }
           } else if (kf->so_pcb)
                   printf(" %p", (void *)(uintptr_t)kf->so_pcb);
   }
   #endif
   
   void
   print_sock_details(struct kinfo_file2 *kf)
   {
           if (kf->so_family == AF_INET)
                   print_inet_details(kf);
   #ifdef INET6
           else if (kf->so_family == AF_INET6)
                   print_inet6_details(kf);
   #endif
   }
   
   void
 socktrans(struct kinfo_file2 *kf)  socktrans(struct kinfo_file2 *kf)
 {  {
         static char *stypename[] = {          static char *stypename[] = {
Line 555 
Line 699 
         };          };
 #define STYPEMAX 5  #define STYPEMAX 5
         char *stype, stypebuf[24];          char *stype, stypebuf[24];
         struct in_addr laddr, faddr;  
 #ifdef INET6  
         char xaddrbuf[NI_MAXHOST + 2];  
         struct in6_addr laddr6, faddr6;  
 #endif  
   
         PREFIX(kf->fd_fd);          PREFIX(kf->fd_fd);
   
Line 584 
Line 723 
         switch (kf->so_family) {          switch (kf->so_family) {
         case AF_INET:          case AF_INET:
                 printf("* internet %s", stype);                  printf("* internet %s", stype);
                 memcpy(&laddr, kf->inp_laddru, sizeof(laddr));  
                 memcpy(&faddr, kf->inp_faddru, sizeof(faddr));  
                 getinetproto(kf->so_protocol);                  getinetproto(kf->so_protocol);
                 if (kf->so_protocol == IPPROTO_TCP) {                  print_inet_details(kf);
                         printf(" %p", (void *)(uintptr_t)kf->inp_ppcb);  
                         printf(" %s:%d", laddr.s_addr == INADDR_ANY ? "*" :  
                             inet_ntoa(laddr), ntohs(kf->inp_lport));  
                         if (kf->inp_fport) {  
                                 if (kf->so_state & SS_CONNECTOUT)  
                                         printf(" --> ");  
                                 else  
                                         printf(" <-- ");  
                                 printf("%s:%d",  
                                     faddr.s_addr == INADDR_ANY ? "*" :  
                                     inet_ntoa(faddr), ntohs(kf->inp_fport));  
                         }  
                 } else if (kf->so_protocol == IPPROTO_UDP) {  
                         printf(" %s:%d", laddr.s_addr == INADDR_ANY ? "*" :  
                             inet_ntoa(laddr), ntohs(kf->inp_lport));  
                         if (kf->inp_fport) {  
                                 printf(" <-> %s:%d",  
                                     faddr.s_addr == INADDR_ANY ? "*" :  
                                     inet_ntoa(faddr), ntohs(kf->inp_fport));  
                         }  
                 } else if (kf->so_pcb)  
                         printf(" %p", (void *)(uintptr_t)kf->so_pcb);  
                 break;                  break;
 #ifdef INET6  #ifdef INET6
         case AF_INET6:          case AF_INET6:
                 printf("* internet6 %s", stype);                  printf("* internet6 %s", stype);
                 memcpy(&laddr6, kf->inp_laddru, sizeof(laddr6));  
                 memcpy(&faddr6, kf->inp_faddru, sizeof(faddr6));  
                 getinetproto(kf->so_protocol);                  getinetproto(kf->so_protocol);
                 if (kf->so_protocol == IPPROTO_TCP) {                  print_inet6_details(kf);
                         printf(" %p", (void *)(uintptr_t)kf->inp_ppcb);  
                         snprintf(xaddrbuf, sizeof(xaddrbuf), "[%s]",  
                             inet6_addrstr(&laddr6));  
                         printf(" %s:%d",  
                             IN6_IS_ADDR_UNSPECIFIED(&laddr6) ? "*" :  
                             xaddrbuf, ntohs(kf->inp_lport));  
                         if (kf->inp_fport) {  
                                 if (kf->so_state & SS_CONNECTOUT)  
                                         printf(" --> ");  
                                 else  
                                         printf(" <-- ");  
                                 snprintf(xaddrbuf, sizeof(xaddrbuf), "[%s]",  
                                     inet6_addrstr(&faddr6));  
                                 printf("%s:%d",  
                                     IN6_IS_ADDR_UNSPECIFIED(&faddr6) ? "*" :  
                                     xaddrbuf, ntohs(kf->inp_fport));  
                         }  
                 } else if (kf->so_protocol == IPPROTO_UDP) {  
                         snprintf(xaddrbuf, sizeof(xaddrbuf), "[%s]",  
                             inet6_addrstr(&laddr6));  
                         printf(" %s:%d",  
                             IN6_IS_ADDR_UNSPECIFIED(&laddr6) ? "*" :  
                             xaddrbuf, ntohs(kf->inp_lport));  
                         if (kf->inp_fport) {  
                                 snprintf(xaddrbuf, sizeof(xaddrbuf), "[%s]",  
                                     inet6_addrstr(&faddr6));  
                                 printf(" <-> %s:%d",  
                                     IN6_IS_ADDR_UNSPECIFIED(&faddr6) ? "*" :  
                                     xaddrbuf, ntohs(kf->inp_fport));  
                         }  
                 } else if (kf->so_pcb)  
                         printf(" %p", (void *)(uintptr_t)kf->so_pcb);  
                 break;                  break;
 #endif  #endif
         case AF_UNIX:          case AF_UNIX:
Line 701 
Line 782 
                 printf("* %d %s", kf->so_family, stype);                  printf("* %d %s", kf->so_family, stype);
                 printf(" %d %p", kf->so_protocol,                  printf(" %d %p", kf->so_protocol,
                     (void *)(uintptr_t)kf->f_data);                      (void *)(uintptr_t)kf->f_data);
           }
           if (kf->so_splice != 0 || kf->so_splicelen == -1) {
                   struct kinfo_file2 *from, *to;
   
                   from = splice_find('<', kf->f_data);
                   to = NULL;
                   if (kf->so_splice != 0)
                           to = splice_find('>', kf->so_splice);
   
                   if (to != NULL && from == to) {
                           printf(" <==>");
                           print_sock_details(to);
                   } else if (kf->so_splice != 0) {
                           printf(" ==>");
                           if (to != NULL)
                                   print_sock_details(to);
                   } else if (kf->so_splicelen == -1) {
                           printf(" <==");
                           if (from != NULL)
                                   print_sock_details(from);
                   }
         }          }
         if (sflg)          if (sflg)
                 printf("\t%8llu %8llu",                  printf("\t%8llu %8llu",
Legend:
Removed from v.1.71  
changed lines
  Added in v.1.72