XXXX adding PID information to netstat output

*** 473,482 ****
--- 473,484 ----
  
          list_create(&so->so_acceptq_list, sizeof (struct sonode),
              offsetof(struct sonode, so_acceptq_node));
          list_create(&so->so_acceptq_defer, sizeof (struct sonode),
              offsetof(struct sonode, so_acceptq_node));
+         avl_create(&so->so_pid_tree, pid_node_comparator, sizeof (pid_node_t),
+             offsetof(pid_node_t, pn_ref_link));
          list_link_init(&so->so_acceptq_node);
          so->so_acceptq_len      = 0;
          so->so_backlog          = 0;
          so->so_listener         = NULL;
  
*** 488,497 ****
--- 490,500 ----
          so->so_filter_top       = NULL;
          so->so_filter_bottom    = NULL;
  
          mutex_init(&so->so_lock, NULL, MUTEX_DEFAULT, NULL);
          mutex_init(&so->so_acceptq_lock, NULL, MUTEX_DEFAULT, NULL);
+         mutex_init(&so->so_pid_tree_lock, NULL, MUTEX_DEFAULT, NULL);
          rw_init(&so->so_fallback_rwlock, NULL, RW_DEFAULT, NULL);
          cv_init(&so->so_state_cv, NULL, CV_DEFAULT, NULL);
          cv_init(&so->so_single_cv, NULL, CV_DEFAULT, NULL);
          cv_init(&so->so_read_cv, NULL, CV_DEFAULT, NULL);
  
*** 518,527 ****
--- 521,531 ----
  
          ASSERT(so->so_rcv_q_head == NULL);
  
          list_destroy(&so->so_acceptq_list);
          list_destroy(&so->so_acceptq_defer);
+         avl_destroy(&so->so_pid_tree);
          ASSERT(!list_link_active(&so->so_acceptq_node));
          ASSERT(so->so_listener == NULL);
  
          ASSERT(so->so_filter_active == 0);
          ASSERT(so->so_filter_tx == 0);
*** 533,542 ****
--- 537,547 ----
  
          vn_free(vp);
  
          mutex_destroy(&so->so_lock);
          mutex_destroy(&so->so_acceptq_lock);
+         mutex_destroy(&so->so_pid_tree_lock);
          rw_destroy(&so->so_fallback_rwlock);
  
          cv_destroy(&so->so_state_cv);
          cv_destroy(&so->so_single_cv);
          cv_destroy(&so->so_read_cv);
*** 624,633 ****
--- 629,639 ----
  
  void
  sonode_fini(struct sonode *so)
  {
          vnode_t *vp;
+         pid_node_t *pn;
  
          ASSERT(so->so_count == 0);
  
          if (so->so_rcv_timer_tid) {
                  ASSERT(MUTEX_NOT_HELD(&so->so_lock));
*** 652,666 ****
--- 658,720 ----
          }
          /* Detach and destroy filters */
          if (so->so_filter_top != NULL)
                  sof_sonode_cleanup(so);
  
+         mutex_enter(&so->so_pid_tree_lock);
+         while ((pn = avl_first(&so->so_pid_tree)) != NULL) {
+                 avl_remove(&so->so_pid_tree, pn);
+                 kmem_free(pn, sizeof (*pn));
+         }
+         mutex_exit(&so->so_pid_tree_lock);
+ 
          ASSERT(list_is_empty(&so->so_acceptq_list));
          ASSERT(list_is_empty(&so->so_acceptq_defer));
          ASSERT(!list_link_active(&so->so_acceptq_node));
  
          ASSERT(so->so_rcv_queued == 0);
          ASSERT(so->so_rcv_q_head == NULL);
          ASSERT(so->so_rcv_q_last_head == NULL);
          ASSERT(so->so_rcv_head == NULL);
          ASSERT(so->so_rcv_last_head == NULL);
  }
+ 
+ void
+ sonode_insert_pid(struct sonode *so, pid_t pid)
+ {
+         pid_node_t      *pn, lookup_pn;
+         avl_index_t     idx_pn;
+ 
+         lookup_pn.pn_pid = pid;
+         mutex_enter(&so->so_pid_tree_lock);
+         pn = avl_find(&so->so_pid_tree, &lookup_pn, &idx_pn);
+ 
+         if (pn != NULL) {
+                 pn->pn_count++;
+         } else {
+                 pn = kmem_zalloc(sizeof (*pn), KM_SLEEP);
+                 pn->pn_pid = pid;
+                 pn->pn_count = 1;
+                 avl_insert(&so->so_pid_tree, pn, idx_pn);
+         }
+         mutex_exit(&so->so_pid_tree_lock);
+ }
+ 
+ void
+ sonode_remove_pid(struct sonode *so, pid_t pid)
+ {
+         pid_node_t *pn, lookup_pn;
+ 
+         lookup_pn.pn_pid = pid;
+         mutex_enter(&so->so_pid_tree_lock);
+         pn = avl_find(&so->so_pid_tree, &lookup_pn, NULL);
+ 
+         if (pn != NULL) {
+                 if (pn->pn_count > 1) {
+                                 pn->pn_count--;
+                 } else {
+                         avl_remove(&so->so_pid_tree, pn);
+                         kmem_free(pn, sizeof (*pn));
+                 }
+         }
+         mutex_exit(&so->so_pid_tree_lock);
+ }