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