diff options
author | Uros Majstorovic <majstor@majstor.org> | 2017-08-13 00:22:37 +0200 |
---|---|---|
committer | Uros Majstorovic <majstor@majstor.org> | 2017-08-13 00:22:37 +0200 |
commit | d830d95720e41b3374dd1edda04ef1ea4272967d (patch) | |
tree | b45b601cecdcf8dfa33351c3b2170eac13d13116 /code/test/vc_client.c | |
parent | cdb555810c1fc9c94dd02a66a96876923d78a650 (diff) |
proxy renamed to vconn
Diffstat (limited to 'code/test/vc_client.c')
-rw-r--r-- | code/test/vc_client.c | 91 |
1 files changed, 91 insertions, 0 deletions
diff --git a/code/test/vc_client.c b/code/test/vc_client.c new file mode 100644 index 0000000..586fec5 --- /dev/null +++ b/code/test/vc_client.c @@ -0,0 +1,91 @@ +#include <stdio.h> +#include <string.h> +#include <unistd.h> +#include <stdlib.h> + +#include "core.h" +#include "vconn.h" +#include "util.h" + +ECPContext ctx; +ECPSocket sock; +ECPConnHandler handler; + +ECPConnection conn; +ECPNode node; + +ECPVConnection vconn[20]; +ECPNode vconn_node[20]; + +#define CTYPE_TEST 0 +#define MTYPE_MSG 8 + +ssize_t handle_open(ECPConnection *conn, ecp_seq_t sq, unsigned char t, unsigned char *p, ssize_t s) { + uint32_t seq = 0; + + ecp_conn_handle_open(conn, sq, t, p, s); + if (s < 0) { + printf("OPEN ERR:%ld\n", s); + return s; + } + + printf("OPEN!\n"); + + unsigned char payload[ECP_SIZE_PLD(1000)]; + unsigned char *buf = ecp_pld_get_buf(payload); + char *msg = "PERA JE CAR!"; + + ecp_pld_set_type(payload, MTYPE_MSG); + strcpy((char *)buf, msg); + ssize_t _rv = ecp_send(conn, payload, sizeof(payload)); + return s; +} + +ssize_t handle_msg(ECPConnection *conn, ecp_seq_t sq, unsigned char t, unsigned char *p, ssize_t s) { + printf("MSG S:%s size:%ld\n", p, s); + return s; +} + +static void usage(char *arg) { + fprintf(stderr, "Usage: %s <server.pub> <v1.pub> ... <vn.pub>\n", arg); + exit(1); +} + +int main(int argc, char *argv[]) { + int rv, i; + + if ((argc < 3) || (argc > 22)) usage(argv[0]); + + rv = ecp_init(&ctx); + printf("ecp_init RV:%d\n", rv); + + rv = ecp_conn_handler_init(&handler); + handler.msg[ECP_MTYPE_OPEN] = handle_open; + handler.msg[MTYPE_MSG] = handle_msg; + ctx.handler[CTYPE_TEST] = &handler; + + rv = ecp_sock_create(&sock, &ctx, NULL); + printf("ecp_sock_create RV:%d\n", rv); + + rv = ecp_sock_open(&sock, NULL); + printf("ecp_sock_open RV:%d\n", rv); + + rv = ecp_start_receiver(&sock); + printf("ecp_start_receiver RV:%d\n", rv); + + rv = ecp_util_node_load(&ctx, &node, argv[1]); + printf("ecp_util_node_load RV:%d\n", rv); + + for (i=0; i<argc-2; i++) { + rv = ecp_util_node_load(&ctx, &vconn_node[i], argv[i+2]); + printf("ecp_util_node_load RV:%d\n", rv); + } + + rv = ecp_conn_create(&conn, &sock, CTYPE_TEST); + printf("ecp_conn_create RV:%d\n", rv); + + rv = ecp_vconn_open(&conn, &node, vconn, vconn_node, argc-2); + printf("ecp_vconn_open RV:%d\n", rv); + + while (1) sleep(1); +}
\ No newline at end of file |