#include "bus_server_socket.h"
|
#include "shm_mod_socket.h"
|
#include "shm_mm_wrapper.h"
|
#include "usg_common.h"
|
#include "mm.h"
|
#include "logger_factory.h"
|
#include <sys/time.h>
|
#include <sys/types.h>
|
#include <sys/wait.h>
|
#include <unistd.h>
|
#include "bus_error.h"
|
|
#include "bh_api.h"
|
#include "proc_def.h"
|
|
static ProcInfo proc_desc;
|
|
int main(int argc, char *argv[]) {
|
int ret;
|
void *buf_temp = NULL;
|
void *errBuf = NULL;
|
void *proc_id = NULL;
|
void *src = NULL;
|
void *data_buf = NULL;
|
char topics_buf[200] = { 0x00 };
|
int size;
|
int id_len;
|
int count = 0;
|
const int timeout_ms = 3000;
|
|
memset(&proc_desc, 0x00, sizeof(ProcInfo));
|
strncpy(proc_desc.proc_id, "Hello", strlen("Hello"));
|
strncpy(proc_desc.name, "World", strlen("World"));
|
strncpy(proc_desc.public_info, "Good", strlen("Good") + 1);
|
|
const char *topics_server_specific_reg_buf1 = "Server Specific topics demo1";
|
const char *topics_server_specific_reg_buf2 = "Server Specific Hello World";
|
|
ret = BHRegister(&proc_desc, (const int)sizeof(ProcInfo), &buf_temp, &size, timeout_ms);
|
if (ret == true) {
|
printf("the process registered OKay\n");
|
|
BHFree(buf_temp, size);
|
|
} else {
|
BHGetLastError(&errBuf, &size);
|
|
printf("the process registered fail with error: %s\n", (char *)errBuf);
|
|
BHFree(errBuf, size);
|
};
|
|
ret = BHRegisterTopics(topics_server_specific_reg_buf1, strlen(topics_server_specific_reg_buf1), &buf_temp, &size, timeout_ms);
|
if (ret == true) {
|
printf("the process registered topics OKay\n");
|
|
BHFree(buf_temp, size);
|
|
} else {
|
BHGetLastError(&errBuf, &size);
|
printf("the process registered1 fail with errorL %s\n", (char *)errBuf);
|
|
BHFree(errBuf, size);
|
};
|
|
ret = BHRegisterTopics(topics_server_specific_reg_buf2, strlen(topics_server_specific_reg_buf2), &buf_temp, &size, timeout_ms);
|
if (ret == true) {
|
printf("the process registered topics OKay\n");
|
|
BHFree(buf_temp, size);
|
|
} else {
|
BHGetLastError(&errBuf, &size);
|
printf("the process registered1 fail with errorL %s\n", (char *)errBuf);
|
|
BHFree(errBuf, size);
|
};
|
|
while(true) {
|
ret = BHReadRequest(&proc_id, &id_len, &buf_temp, &size, &src, -1);
|
if (ret == true) {
|
|
strncpy(topics_buf, (char *)buf_temp, (sizeof(topics_buf) - 1) > size ? size : (sizeof(topics_buf) - 1));
|
printf("Get data(%s)", topics_buf);
|
|
memset(topics_buf, 0x00, sizeof(topics_buf));
|
strncpy(topics_buf, (char *)proc_id, (sizeof(topics_buf) - 1) > id_len ? id_len : (sizeof(topics_buf) - 1));
|
printf("proc id(%s)", topics_buf);
|
|
BHFree(buf_temp, size);
|
BHFree(proc_id, id_len);
|
|
memset(topics_buf, 0x00, sizeof(topics_buf));
|
sprintf(topics_buf, "Get data count: %d", ++count);
|
ret = BHSendReply(src, topics_buf, strlen(topics_buf));
|
if (ret == true) {
|
|
printf("the process send reply OKay\n");
|
|
} else {
|
|
BHGetLastError(&errBuf, &size);
|
printf("the process send reply fail with errorL %s\n", (char *)errBuf);
|
|
BHFree(errBuf, size);
|
};
|
|
BHFree(src, size);
|
|
} else {
|
BHGetLastError(&errBuf, &size);
|
printf("BHReadRequest fail with error(%s)\n", (char *)errBuf);
|
|
BHFree(errBuf, size);
|
};
|
}
|
|
return 0;
|
|
}
|
