From 97b2c471cbd2d2cb9282489e632cdf8f270295e1 Mon Sep 17 00:00:00 2001
From: wangzhengquan <wangzhengquan85@126.com>
Date: 星期四, 25 二月 2021 15:08:29 +0800
Subject: [PATCH] update

---
 test_net_socket/shm_util.cpp |   37 ++++++++++++++++++++++++++++++++-----
 1 files changed, 32 insertions(+), 5 deletions(-)

diff --git a/test_net_socket/shm_util.cpp b/test_net_socket/shm_util.cpp
index bf214ed..c441930 100644
--- a/test_net_socket/shm_util.cpp
+++ b/test_net_socket/shm_util.cpp
@@ -532,12 +532,24 @@
   hashtable_foreach(hashtable, [&](int key, void * value){
     if(key >= 100 ) {
       mqueue = (LockFreeQueue<shm_packet_t> *)hashtable_get(hashtable, key);
+      printf("%d\n", key);
       printf("%10d \t %10d\n", key, mqueue->size());
     } else {
       printf("%10d \t %10s\n", key, "");
     }
    
   });
+}
+
+void info(int key) {
+  LockFreeQueue<shm_packet_t> * mqueue;
+  hashtable_t *hashtable = mm_get_hashtable();
+  mqueue = (LockFreeQueue<shm_packet_t> *) hashtable_get(hashtable, key);
+  printf("%10s: %-10p\n", "PTR", mqueue);
+  printf("%10s: %-10d\n", "KEY", key);
+  printf("%10s: %-10d\n", "LENGTH", mqueue->size());
+
+
 }
 
 
@@ -604,6 +616,7 @@
   fpe("./shm_util list\n");
   fpe("# remove  key 1001\n");
   fpe("./shm_util rm 1001\n");
+  fpe("./shm_util info 1002\n");
   fpe("\n");
 }
 
@@ -788,15 +801,29 @@
   else if (strcmp("list", fun) == 0 ) {
     list();
   }
+  else if (strcmp("info", fun) == 0 ) {
+    if(argc < 2) {
+
+      usage(prog);
+      
+    } else {
+      for(i = 1; i < argc; i++) {
+        int key = atoi(argv[i]);
+        info(key);
+      }
+    }
+  }
   else if (strcmp("rm", fun) == 0 ) {
     if(argc < 2) {
       usage(prog);
-      exit(1);
+      
+    } else {
+       for(i = 1; i < argc; i++) {
+        int key = atoi(argv[i]);
+        remove(key);
+      }
     }
-    for(i = 1; i < argc; i++) {
-      int key = atoi(argv[i]);
-      remove(key);
-    }
+   
   }
   else if (strcmp("sendandrecv", fun) == 0 ) {
     if(argc < 3) {

--
Gitblit v1.8.0