From 4fba64a1f721d57ac6dfa7f1717195def6f747c8 Mon Sep 17 00:00:00 2001 From: wangzhengquan <wangzhengquan85@126.com> Date: 星期二, 21 七月 2020 19:46:05 +0800 Subject: [PATCH] tmp --- test_queue/multiple_queue_productor.c | 0 test_queue/single_consumer.c | 0 test_queue/multiple_queue_consumer | 0 test_queue/Makefile | 0 test_socket/dgram_socket_test | 0 test_socket/server | 0 test_queue/test.txt | 0 test_queue/test_lockfree_queue.c | 0 test_socket/Makefile | 0 test_queue/test_lockfree_queue | 0 test_queue/test | 0 test_queue/multiple_queue_productor | 0 test_socket/dgram_socket_test.c | 0 test_queue/single_productor | 0 test_socket/stream_mod_pub_sub.c | 0 test_socket/stream_socket_test.c | 0 test_queue/test_timeout | 0 test_queue/test_timeout.c | 0 test_queue/test_lostdata.c | 0 test_queue/test.h | 0 test_socket/client.c | 0 test_queue/test.c | 0 test_queue/test_queue.c | 0 test_queue/multiple_queue_consumer.c | 0 test_socket/stream_mod_req_rep.c | 0 test_queue/test_queue | 0 test_queue/test_lostdata.sh | 0 /dev/null | 0 test_queue/single_consumer | 0 test_queue/single_productor.c | 0 test_socket/server.c | 0 test_socket/survey.c | 0 test_queue/test_lostdata | 0 test_socket/client | 0 34 files changed, 0 insertions(+), 0 deletions(-) diff --git a/test2/pub.c b/test2/pub.c deleted file mode 100644 index 35f1c16..0000000 --- a/test2/pub.c +++ /dev/null @@ -1,62 +0,0 @@ -#include "shm_queue_wrapper.h" - - -typedef struct msg_t -{ - int key; - char buf[100]; - -} msg_t; - - -static void * remote_queues[100]; -static int remote_queues_len = 0; - -void *pub(void *) { - msg_t send_msg; - send_msg.key = 1; - while(true) { - for(int i = 0; i < remote_queues_len; i++ ) { - sprintf(send_msg.buf, "浠婃棩澶存潯脳脳脳脳"); - shmqueue_push(remote_queues[i], (void *)&send_msg, sizeof(send_msg)); - } - sleep(2); - } -} - -void server() { - void * msg; - int msg_size; - - int key = 1; - size_t qsize = 16; - void * local_queue = shmqueue_create( &key, qsize); - - - pthread_t tid; - pthread_create(&tid, NULL, pub, NULL); - - while(shmqueue_pop(local_queue, &msg, &msg_size) ) { - void * remote_queue = shmqueue_attach(((msg_t *)msg)->key); - remote_queues[remote_queues_len++] = remote_queue; - printf("鏀跺埌璁㈤槄璇锋眰", ((msg_t *)msg)->buf); - - - // shmqueue_drop(remote_queue); - // cout << item.pic << endl; - // i++; - } - - //閿�姣侀槦鍒� - shmqueue_drop(local_queue); -} - - -int main () { - shm_init(512); - server(); - - //鏁翠釜杩涚▼閫�鍑烘椂闇�瑕佹墽琛岃繖涓柟娉曪紝璇ユ柟娉曢鍏堜細妫�鏌ユ槸鍚﹁繕鏈夊叾浠栬繘绋嬪湪浣跨敤璇ュ叡浜唴瀛橈紝濡傛灉杩樻湁鍏朵粬杩涚▼鍦ㄤ娇鐢ㄥ氨鍙槸detach,濡傛灉娌℃湁鍏朵粬杩涚▼鍦ㄤ娇鐢ㄥ垯閿�姣佹暣鍧楀唴瀛樸�� - shm_destroy(); - return 0; -} \ No newline at end of file diff --git a/test2/sem_test b/test2/sem_test deleted file mode 100755 index 26796de..0000000 --- a/test2/sem_test +++ /dev/null Binary files differ diff --git a/test2/sem_test.c b/test2/sem_test.c deleted file mode 100644 index 8cfa626..0000000 --- a/test2/sem_test.c +++ /dev/null @@ -1,21 +0,0 @@ -#include "usg_common.h" -#include "sem_util.h" -static int mem_pool_cond = SemUtil::get(0x2001, 0); - -void *run(void *varg) { - sleep(5); - // notify malloc - SemUtil::set(mem_pool_cond, 1); -} - -int main() { - - pthread_t tid; - pthread_create(&tid, NULL, run, NULL); - SemUtil::set(mem_pool_cond, 0); - // wait for someone else to free space - printf("waiting...\n"); - SemUtil::dec(mem_pool_cond); - printf("weak...\n"); - -} \ No newline at end of file diff --git a/test2/test_queue_wrapper b/test2/test_queue_wrapper deleted file mode 100755 index c37f037..0000000 --- a/test2/test_queue_wrapper +++ /dev/null Binary files differ diff --git a/test/Makefile b/test_queue/Makefile similarity index 100% rename from test/Makefile rename to test_queue/Makefile diff --git a/test/multiple_queue_consumer b/test_queue/multiple_queue_consumer similarity index 100% rename from test/multiple_queue_consumer rename to test_queue/multiple_queue_consumer Binary files differ diff --git a/test/multiple_queue_consumer.c b/test_queue/multiple_queue_consumer.c similarity index 100% rename from test/multiple_queue_consumer.c rename to test_queue/multiple_queue_consumer.c diff --git a/test/multiple_queue_productor b/test_queue/multiple_queue_productor similarity index 100% rename from test/multiple_queue_productor rename to test_queue/multiple_queue_productor Binary files differ diff --git a/test/multiple_queue_productor.c b/test_queue/multiple_queue_productor.c similarity index 100% rename from test/multiple_queue_productor.c rename to test_queue/multiple_queue_productor.c diff --git a/test/single_consumer b/test_queue/single_consumer similarity index 100% rename from test/single_consumer rename to test_queue/single_consumer Binary files differ diff --git a/test/single_consumer.c b/test_queue/single_consumer.c similarity index 100% rename from test/single_consumer.c rename to test_queue/single_consumer.c diff --git a/test/single_productor b/test_queue/single_productor similarity index 100% rename from test/single_productor rename to test_queue/single_productor Binary files differ diff --git a/test/single_productor.c b/test_queue/single_productor.c similarity index 100% rename from test/single_productor.c rename to test_queue/single_productor.c diff --git a/test/test b/test_queue/test similarity index 100% rename from test/test rename to test_queue/test Binary files differ diff --git a/test/test.c b/test_queue/test.c similarity index 100% rename from test/test.c rename to test_queue/test.c diff --git a/test/test.h b/test_queue/test.h similarity index 100% rename from test/test.h rename to test_queue/test.h diff --git a/test/test.txt b/test_queue/test.txt similarity index 100% rename from test/test.txt rename to test_queue/test.txt diff --git a/test/test_lockfree_queue b/test_queue/test_lockfree_queue similarity index 100% rename from test/test_lockfree_queue rename to test_queue/test_lockfree_queue Binary files differ diff --git a/test/test_lockfree_queue.c b/test_queue/test_lockfree_queue.c similarity index 100% rename from test/test_lockfree_queue.c rename to test_queue/test_lockfree_queue.c diff --git a/test/test_lostdata b/test_queue/test_lostdata similarity index 100% rename from test/test_lostdata rename to test_queue/test_lostdata Binary files differ diff --git a/test/test_lostdata.c b/test_queue/test_lostdata.c similarity index 100% rename from test/test_lostdata.c rename to test_queue/test_lostdata.c diff --git a/test/test_lostdata.sh b/test_queue/test_lostdata.sh similarity index 100% rename from test/test_lostdata.sh rename to test_queue/test_lostdata.sh diff --git a/test/test_queue b/test_queue/test_queue similarity index 100% rename from test/test_queue rename to test_queue/test_queue Binary files differ diff --git a/test/test_queue.c b/test_queue/test_queue.c similarity index 100% rename from test/test_queue.c rename to test_queue/test_queue.c diff --git a/test/test_timeout b/test_queue/test_timeout similarity index 100% rename from test/test_timeout rename to test_queue/test_timeout Binary files differ diff --git a/test/test_timeout.c b/test_queue/test_timeout.c similarity index 100% rename from test/test_timeout.c rename to test_queue/test_timeout.c diff --git a/test2/Makefile b/test_socket/Makefile similarity index 100% rename from test2/Makefile rename to test_socket/Makefile diff --git a/test2/client b/test_socket/client similarity index 100% rename from test2/client rename to test_socket/client Binary files differ diff --git a/test2/client.c b/test_socket/client.c similarity index 100% rename from test2/client.c rename to test_socket/client.c diff --git a/test/dgram_socket_test b/test_socket/dgram_socket_test similarity index 100% rename from test/dgram_socket_test rename to test_socket/dgram_socket_test Binary files differ diff --git a/test/dgram_socket_test.c b/test_socket/dgram_socket_test.c similarity index 100% rename from test/dgram_socket_test.c rename to test_socket/dgram_socket_test.c diff --git a/test2/server b/test_socket/server similarity index 100% rename from test2/server rename to test_socket/server Binary files differ diff --git a/test2/server.c b/test_socket/server.c similarity index 100% rename from test2/server.c rename to test_socket/server.c diff --git a/test2/pub_sub.c b/test_socket/stream_mod_pub_sub.c similarity index 100% rename from test2/pub_sub.c rename to test_socket/stream_mod_pub_sub.c diff --git a/test2/req_rep.c b/test_socket/stream_mod_req_rep.c similarity index 100% rename from test2/req_rep.c rename to test_socket/stream_mod_req_rep.c diff --git a/test/communication.c b/test_socket/stream_socket_test.c similarity index 100% rename from test/communication.c rename to test_socket/stream_socket_test.c diff --git a/test2/survey.c b/test_socket/survey.c similarity index 100% rename from test2/survey.c rename to test_socket/survey.c -- Gitblit v1.8.0