fix conflict

wangzhengquan

2020-07-28 b7228c8620a6a0b593f1d8b82af5aac7ba456a85

fix conflict

 Makefile

@@ -1,6 +1,7 @@
DIRS = src test_socket demo test
TAR_NAME = shm_queue.tar.gz

 
all:
    for i in $(DIRS); do \
        (cd $$i && echo "making $$i" && $(MAKE) ) || exit 1; \

 demo/Makefile

@@ -15,6 +15,7 @@


PROGS = dgram_mod_req_rep dgram_mod_survey dgram_mod_bus
 


build: $(PROGS)

 demo/dgram_mod_req_rep

Binary files differ

 demo/dgram_mod_survey

Binary files differ

 src/libshm_queue.a

Binary files differ

 src/queue/hashtable.c

@@ -276,6 +276,7 @@



 
std::set<int> * hashtable_keyset(hashtable_t *hashtable) {
  std::set<int> *keyset = new std::set<int>;
  tailq_entry_t *item;
@@ -306,5 +307,3 @@
  SemUtil::inc(hashtable->wlock);
  return key;
}



 src/socket/dgram_mod_socket.c

@@ -121,8 +121,8 @@
int  dgram_mod_start_bus(void * _socket) {
    dgram_mod_socket_t * socket = (dgram_mod_socket_t *) _socket;
    socket->mod = BUS;
// printf("mem_pool_malloc_by_key before\n");
    socket->topic_sub_map =    mem_pool_attach<SHMTopicSubMap>(BUS_MAP_KEY);
 
    run_pubsub_proxy(socket);
    // pthread_t tid;
    // pthread_create(&tid, NULL, run_accept_sub_request, _socket);

 test/Makefile

@@ -15,6 +15,7 @@

 
PROGS = protocle_parse strtok test_set test_vector lambda test
 

build: $(PROGS)


 test/protocle_parse

Binary files differ

 test/strtok

Binary files differ

 test/test

Binary files differ

 test/test.c

@@ -1,15 +1,7 @@
#include "usg_common.h"
#include "usg_typedef.h"

int test(char *src, int size) {
    int i = strlen(src);
    char dest[size];
    strncpy(dest, src, size);
    puts(dest);
    return i;
}
 
int main() {
    char *str = "hello";
    int r = test(str, strlen(str));
    printf("%d\n", r);
}
}
	 

 test/test_set

Binary files differ

 test/test_vector

Binary files differ

 test_socket/dgram_mod_bus

Binary files differ

 test_socket/dgram_mod_bus.c

@@ -12,13 +12,13 @@
void server(int port, bool restart) {
 // signal(SIGINT,  sigint_handler);
  server_socket = dgram_mod_open_socket();
  dgram_mod_force_bind(server_socket, port);
  
  // if(restart) {
   
  // } else {
  //   // dgram_mod_bind(server_socket, port);
  // }


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

 test_socket/dgram_mod_req_rep

Binary files differ

 test_socket/dgram_mod_survey

Binary files differ