commit

wangzhengquan

2020-07-27 aeaeda81cfe398081a7c1a5c287981c8df974aa2

commit

 demo/dgram_mod_bus.c

@@ -1,13 +1,21 @@
#include "dgram_mod_socket.h"
#include "shm_mm.h"
#include "usg_common.h"
#include "mm.h"

void server(int port) {
  void *socket = dgram_mod_open_socket();
  dgram_mod_bind(socket, port);


void server(int port, bool restart) {
  void * server_socket = dgram_mod_open_socket();

  if(restart) {
    dgram_mod_force_bind(server_socket, port);
  } else {
     dgram_mod_bind(server_socket, port);
  }
 
   
  dgram_mod_start_bus(socket);
  
  dgram_mod_start_bus(server_socket);
}


@@ -68,14 +76,20 @@
  shm_init(512);
  int port;
  if (argc < 3) {
    fprintf(stderr, "Usage: reqrep %s|%s <PORT> ...\n", "server", "client");
    fprintf(stderr, "Usage: %s %s|%s <PORT> ...\n", argv[0], "server", "client");
    return 1;
  }

  port = atoi(argv[2]);

  if (strcmp("server", argv[1]) == 0) {
    server(port);
    if(argc >= 4 && strcmp("restart", argv[3]) == 0) {
      server(port, true);
    }
    else{
      server(port, false);
    }
    
  }

  if (strcmp("client", argv[1]) == 0)

 demo/dgram_mod_req_rep

Binary files differ

 demo/dgram_mod_survey

Binary files differ

 src/libshm_queue.a

Binary files differ

 src/queue/include/mem_pool.h

@@ -40,16 +40,27 @@
    // T* tptr;
    hashtable_t *hashtable = mm_get_hashtable();
  ptr = hashtable_get(hashtable, key);
printf("mem_pool_malloc_by_key  malloc before %d, %p\n", key, ptr);
// printf("mem_pool_malloc_by_key  malloc before %d, %p\n", key, ptr);
  if(ptr == NULL || ptr == (void *)1 ) {
    ptr = mm_malloc(sizeof(T));
    hashtable_put(hashtable, key, ptr);
    new(ptr) T;
printf("mem_pool_malloc_by_key  use new %d, %p\n", key, ptr);
// printf("mem_pool_malloc_by_key  use new %d, %p\n", key, ptr);
  }
  return (T*)ptr; 
}

static inline void mem_pool_free_by_key(int key) {
    void *ptr;
    // T* tptr;
    hashtable_t *hashtable = mm_get_hashtable();
  ptr = hashtable_get(hashtable, key);
  if(ptr != NULL) {
      mm_free(ptr);
      hashtable_remove(hashtable, key);
  }
}

static inline void mem_pool_free (void *ptr) {
    mm_free(ptr);
    // notify malloc

 src/socket/dgram_mod_socket.c

@@ -49,7 +49,7 @@
            subscripter_set = map_iter->second;
            delete subscripter_set;
        }
        delete topic_sub_map;
        mem_pool_free_by_key(BUS_MAP_KEY);
    }
    


 test_socket/dgram_mod_bus

Binary files differ

 test_socket/dgram_mod_bus.c

@@ -2,7 +2,8 @@
#include "shm_mm.h"
#include "usg_common.h"
#include "mm.h"
 



void server(int port, bool restart) {
  void * server_socket = dgram_mod_open_socket();

 test_socket/dgram_mod_req_rep

Binary files differ

 test_socket/dgram_mod_survey

Binary files differ