1 files changed, 33 insertions, 0 deletions
diff --git a/bgpd/bgp_session.c b/bgpd/bgp_session.c
index cbbc181e..8836b1b3 100644
--- a/bgpd/bgp_session.c
+++ b/bgpd/bgp_session.c
@@ -320,6 +320,9 @@ bgp_session_enable(bgp_peer peer)
   confirm(sizeof(struct bgp_session_enable_args) == 0) ;
 
   session->state = bgp_session_sEnabled;
+
+  ++bgp_engine_queue_stats.event ;
+
   bgp_to_bgp_engine(mqb) ;
 } ;
 
@@ -418,6 +421,22 @@ bgp_session_disable(bgp_peer peer, bgp_notify notification)
 
   args = mqb_get_args(mqb) ;
   args->notification = notification ;
+  {
+    int c, s ;
+    if (notification != NULL)
+      {
+        c = notification->code ;
+        s = notification->subcode ;
+      }
+    else
+      {
+        c = 0 ;
+        s = 0 ;
+      } ;
+    fprintf(stderr, " session disable %d/%d", c, s) ;
+  } ;
+
+  ++bgp_engine_queue_stats.event ;
 
   bgp_to_bgp_engine_priority(mqb) ;
 } ;
@@ -475,6 +494,8 @@ bgp_session_event(bgp_session session, bgp_session_event_t  event,
   args->ordinal      = ordinal ;
   args->stopped      = stopped,
 
+  ++peering_engine_queue_stats.event ;
+
   bgp_to_peering_engine(mqb) ;
 }
 
@@ -502,6 +523,8 @@ bgp_session_update_send(bgp_session session, struct stream* upd)
   session->flow_control++;      /* count them in ... */
   BGP_SESSION_UNLOCK(session) ; /*>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>*/
 
+  ++bgp_engine_queue_stats.update ;
+
   bgp_to_bgp_engine(mqb) ;
 } ;
 
@@ -626,6 +649,8 @@ bgp_session_route_refresh_send(bgp_session session, bgp_route_refresh rr)
   args->rr         = rr ;
   args->is_pending = NULL ;
 
+  ++bgp_engine_queue_stats.event ;
+
   bgp_to_bgp_engine(mqb) ;
 } ;
 
@@ -689,6 +714,8 @@ bgp_session_end_of_rib_send(bgp_session session, qAFI_t afi, qSAFI_t safi)
   args->safi       = get_iSAFI(qafx) ;
   args->is_pending = NULL ;
 
+  ++bgp_engine_queue_stats.xon ;
+
   bgp_to_bgp_engine(mqb) ;
 } ;
 
@@ -753,6 +780,8 @@ bgp_session_update_recv(bgp_session session, struct stream* buf, bgp_size_t size
   args->buf = stream_dup(buf) ;
   args->size = size;
 
+  ++peering_engine_queue_stats.update ;
+
   bgp_to_peering_engine(mqb) ;
 }
 
@@ -831,6 +860,8 @@ bgp_session_XON(bgp_session session)
 
   confirm(sizeof(struct bgp_session_XON_args) == 0) ;
 
+  ++peering_engine_queue_stats.xon ;
+
   bgp_to_peering_engine(mqb) ;
 }
 
@@ -863,6 +894,8 @@ bgp_session_set_ttl(bgp_session session, int ttl)
   args = mqb_get_args(mqb) ;
   args->ttl = ttl ;
 
+  ++bgp_engine_queue_stats.event ;
+
   bgp_to_bgp_engine(mqb) ;
 }