summaryrefslogtreecommitdiff
path: root/ecp/test
diff options
context:
space:
mode:
Diffstat (limited to 'ecp/test')
-rw-r--r--ecp/test/Makefile23
-rw-r--r--ecp/test/basic.c16
-rw-r--r--ecp/test/client.c90
-rw-r--r--ecp/test/dir.c93
-rw-r--r--ecp/test/echo.c56
-rw-r--r--ecp/test/frag.c122
-rw-r--r--ecp/test/init_vconn.c45
-rw-r--r--ecp/test/server.c55
-rw-r--r--ecp/test/vc_client.c95
-rw-r--r--ecp/test/vc_server.c91
-rw-r--r--ecp/test/vcs.c58
-rw-r--r--ecp/test/vid/Makefile23
-rw-r--r--ecp/test/vid/cap.c576
-rwxr-xr-xecp/test/vid/cap.sh3
-rw-r--r--ecp/test/vid/client.c123
-rw-r--r--ecp/test/vid/display.c68
-rw-r--r--ecp/test/vid/display.h17
-rw-r--r--ecp/test/vid/enc.c168
-rw-r--r--ecp/test/vid/enc.h7
-rw-r--r--ecp/test/vid/server.c76
-rw-r--r--ecp/test/vid/server.h7
-rw-r--r--ecp/test/vid/tools.c165
-rw-r--r--ecp/test/vid/tools.h37
-rw-r--r--ecp/test/voip.c196
24 files changed, 243 insertions, 1967 deletions
diff --git a/ecp/test/Makefile b/ecp/test/Makefile
index ce12a87..abda4e2 100644
--- a/ecp/test/Makefile
+++ b/ecp/test/Makefile
@@ -7,11 +7,23 @@ dep=../build-posix/*.a ../util/libecputil.a
%.o: %.c
$(CC) $(CFLAGS) -c $<
-all: basic # dir server echo frag stress vcs vc_server vc_client vc_client_t
+all: basic client server vcs vc_server vc_client # dir echo frag stress vc_client_t
basic: basic.o init.o $(dep)
$(CC) -o $@ $< init.o $(dep) $(LDFLAGS)
+vcs: vcs.o init_vconn.o $(dep)
+ $(CC) -o $@ $< init_vconn.o $(dep) $(LDFLAGS)
+
+vc_server: vc_server.o init_vconn.o $(dep)
+ $(CC) -o $@ $< init_vconn.o $(dep) $(LDFLAGS)
+
+vc_server2: vc_server2.o init_vconn.o $(dep)
+ $(CC) -o $@ $< init_vconn.o $(dep) $(LDFLAGS)
+
+vc_client: vc_client.o init_vconn.o $(dep)
+ $(CC) -o $@ $< init_vconn.o $(dep) $(LDFLAGS)
+
dir: dir.o init.o $(dep)
$(CC) -DWITH_DIR_SERVER -o $@ $< init.o $(dep) $(LDFLAGS)
@@ -30,15 +42,6 @@ frag: frag.o init.o $(dep)
stress: stress.o init.o $(dep)
$(CC) -o $@ $< init.o $(dep) $(LDFLAGS)
-vcs: vcs.o init_vconn.o $(dep)
- $(CC) -o $@ $< init_vconn.o $(dep) $(LDFLAGS)
-
-vc_server: vc_server.o init_vconn.o $(dep)
- $(CC) -o $@ $< init_vconn.o $(dep) $(LDFLAGS)
-
-vc_client: vc_client.o init_vconn.o $(dep)
- $(CC) -o $@ $< init_vconn.o $(dep) $(LDFLAGS)
-
vc_client_t: vc_client_t.o init_vconn.o $(dep)
$(CC) -o $@ $< init_vconn.o $(dep) $(LDFLAGS)
diff --git a/ecp/test/basic.c b/ecp/test/basic.c
index 2edb174..b266a07 100644
--- a/ecp/test/basic.c
+++ b/ecp/test/basic.c
@@ -1,26 +1,23 @@
-#include <stdio.h>
#include <string.h>
#include <unistd.h>
+#include <stdio.h>
#include <core.h>
ECPContext ctx_s;
ECPSocket sock_s;
-ECPDHKey key_perma_s;
ECPConnHandler handler_s;
ECPContext ctx_c;
ECPSocket sock_c;
-ECPDHKey key_perma_c;
ECPConnHandler handler_c;
-ECPNode node;
ECPConnection conn;
#define CTYPE_TEST 0
#define MTYPE_MSG 0
-int handle_open_c(ECPConnection *conn, ECP2Buffer *b) {
+static int handle_open_c(ECPConnection *conn, ECP2Buffer *b) {
char *_msg = "PERA JE CAR!";
ssize_t rv;
@@ -30,12 +27,12 @@ int handle_open_c(ECPConnection *conn, ECP2Buffer *b) {
return ECP_OK;
}
-ssize_t handle_msg_c(ECPConnection *conn, ecp_seq_t seq, unsigned char mtype, unsigned char *msg, size_t msg_size, ECP2Buffer *b) {
+static ssize_t handle_msg_c(ECPConnection *conn, ecp_seq_t seq, unsigned char mtype, unsigned char *msg, size_t msg_size, ECP2Buffer *b) {
printf("MSG C:%s size:%ld\n", msg, msg_size);
return msg_size;
}
-ssize_t handle_msg_s(ECPConnection *conn, ecp_seq_t seq, unsigned char mtype, unsigned char *msg, size_t msg_size, ECP2Buffer *b) {
+static ssize_t handle_msg_s(ECPConnection *conn, ecp_seq_t seq, unsigned char mtype, unsigned char *msg, size_t msg_size, ECP2Buffer *b) {
char *_msg = "VAISTINU JE CAR!";
ssize_t rv;
@@ -46,6 +43,9 @@ ssize_t handle_msg_s(ECPConnection *conn, ecp_seq_t seq, unsigned char mtype, un
}
int main(int argc, char *argv[]) {
+ ECPDHKey key_perma_c;
+ ECPDHKey key_perma_s;
+ ECPNode node;
int rv;
/* server */
@@ -96,4 +96,4 @@ int main(int argc, char *argv[]) {
printf("ecp_conn_open RV:%d\n", rv);
while (1) sleep(1);
-} \ No newline at end of file
+}
diff --git a/ecp/test/client.c b/ecp/test/client.c
index 577a888..d526f76 100644
--- a/ecp/test/client.c
+++ b/ecp/test/client.c
@@ -1,80 +1,78 @@
-#include <stdio.h>
+#include <stdlib.h>
#include <string.h>
#include <unistd.h>
-#include <stdlib.h>
+#include <stdio.h>
+
+#include <core.h>
-#include "core.h"
-#include "util.h"
+#include <util.h>
ECPContext ctx;
ECPSocket sock;
ECPConnHandler handler;
-
-ECPNode node;
ECPConnection conn;
#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, ECP2Buffer *b) {
- uint32_t seq = 0;
-
- ecp_conn_handle_open(conn, sq, t, p, s, b);
- if (s < 0) {
- printf("OPEN ERR:%ld\n", s);
- return s;
- }
-
- char *msg = "PERA JE CAR!";
- unsigned char buf[1000];
-
- strcpy((char *)buf, msg);
- ssize_t _rv = ecp_send(conn, MTYPE_MSG, buf, 1000);
-
- return s;
-}
+#define MTYPE_MSG 0
+
+static int handle_open(ECPConnection *conn, ECP2Buffer *b) {
+ char *_msg = "PERA JE CAR!";
+ ssize_t rv;
+
+ printf("OPEN\n");
+ rv = ecp_msg_send(conn, MTYPE_MSG, (unsigned char *)_msg, strlen(_msg)+1);
-ssize_t handle_msg(ECPConnection *conn, ecp_seq_t sq, unsigned char t, unsigned char *p, ssize_t s, ECP2Buffer *b) {
- printf("MSG C:%s size:%ld\n", p, s);
- return s;
+ return ECP_OK;
}
+static ssize_t handle_msg(ECPConnection *conn, ecp_seq_t seq, unsigned char mtype, unsigned char *msg, size_t msg_size, ECP2Buffer *b) {
+ printf("MSG C:%s size:%ld\n", msg, msg_size);
+ return msg_size;
+}
static void usage(char *arg) {
- fprintf(stderr, "Usage: %s <node.pub>\n", arg);
+ fprintf(stderr, "Usage: %s <address> <node.pub>\n", arg);
exit(1);
}
int main(int argc, char *argv[]) {
+ ECPDHKey key_perma;
+ ECPNode node;
+ ecp_ecdh_public_t node_pub;
int rv;
-
- if (argc != 2) usage(argv[0]);
-
+
+ /* client */
+ if (argc != 3) 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_init(&sock, &ctx, NULL);
- printf("ecp_sock_init RV:%d\n", rv);
+ ecp_conn_handler_init(&handler, handle_msg, handle_open, NULL, NULL);
+ ecp_ctx_set_handler(&ctx, &handler, CTYPE_TEST);
+
+ rv = ecp_dhkey_gen(&key_perma);
+ printf("ecp_dhkey_gen RV:%d\n", rv);
+
+ rv = ecp_sock_create(&sock, &ctx, &key_perma);
+ 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);
+ rv = ecp_conn_create(&conn, &sock, CTYPE_TEST);
+ printf("ecp_conn_create RV:%d\n", rv);
+
+ rv = ecp_util_load_pub(&node_pub, argv[2]);
+ printf("ecp_util_load_pub RV:%d\n", rv);
- rv = ecp_conn_init(&conn, &sock, CTYPE_TEST);
- printf("ecp_conn_init RV:%d\n", rv);
+ rv = ecp_node_init(&node, &node_pub, argv[1]);
+ printf("ecp_node_init RV:%d\n", rv);
rv = ecp_conn_open(&conn, &node);
printf("ecp_conn_open RV:%d\n", rv);
-
+
while (1) sleep(1);
-} \ No newline at end of file
+}
diff --git a/ecp/test/dir.c b/ecp/test/dir.c
deleted file mode 100644
index 0c2ac72..0000000
--- a/ecp/test/dir.c
+++ /dev/null
@@ -1,93 +0,0 @@
-#include <stdio.h>
-#include <string.h>
-#include <unistd.h>
-
-#include "core.h"
-#include "cr.h"
-#include "dir.h"
-#include "dir_srv.h"
-
-ECPContext ctx_s;
-ECPSocket sock_s;
-ECPDHKey key_perma_s;
-
-ECPContext ctx_c;
-ECPSocket sock_c;
-ECPDHKey key_perma_c;
-ECPConnHandler handler_c;
-
-ECPNode node;
-ECPConnection conn;
-
-static ECPDirList dir_online;
-static ECPDirList dir_shadow;
-
-#define CTYPE_TEST 0
-
-ssize_t handle_dir(ECPConnection *conn, ecp_seq_t seq, unsigned char mtype, unsigned char *msg, ssize_t size, ECP2Buffer *b) {
- ECPDirList dir;
- ssize_t rv;
-
- dir.count = 0;
- rv = ecp_dir_parse(&dir, msg, size);
- if (rv < 0) return rv;
-
- printf("DIR: %s %ld\n", (char *)ecp_cr_dh_pub_get_buf(&dir.item[0].node.public), size);
-
- return rv;
-}
-
-int main(int argc, char *argv[]) {
- int rv;
-
- dir_online.count = 1;
- strcpy((char *)ecp_cr_dh_pub_get_buf(&dir_online.item[0].node.public), "PERA");
-
- rv = ecp_init(&ctx_s);
- printf("ecp_init RV:%d\n", rv);
-
- rv = ecp_dir_init(&ctx_s, &dir_online, &dir_shadow);
- printf("ecp_dir_init RV:%d\n", rv);
-
- rv = ecp_dhkey_gen(&ctx_s, &key_perma_s);
- printf("ecp_dhkey_gen RV:%d\n", rv);
-
- rv = ecp_sock_init(&sock_s, &ctx_s, &key_perma_s);
- printf("ecp_sock_init RV:%d\n", rv);
-
- rv = ecp_sock_open(&sock_s, "0.0.0.0:3000");
- printf("ecp_sock_open RV:%d\n", rv);
-
- rv = ecp_start_receiver(&sock_s);
- printf("ecp_start_receiver RV:%d\n", rv);
-
- rv = ecp_init(&ctx_c);
- printf("ecp_init RV:%d\n", rv);
-
- rv = ecp_conn_handler_init(&handler_c);
- handler_c.msg[ECP_MTYPE_DIR] = handle_dir;
- ctx_c.handler[CTYPE_TEST] = &handler_c;
-
- rv = ecp_dhkey_gen(&ctx_c, &key_perma_c);
- printf("ecp_dhkey_gen RV:%d\n", rv);
-
- rv = ecp_sock_init(&sock_c, &ctx_c, &key_perma_c);
- printf("ecp_sock_init RV:%d\n", rv);
-
- rv = ecp_sock_open(&sock_c, NULL);
- printf("ecp_sock_open RV:%d\n", rv);
-
- rv = ecp_start_receiver(&sock_c);
- printf("ecp_start_receiver RV:%d\n", rv);
-
- rv = ecp_node_init(&node, &key_perma_s.public, "127.0.0.1:3000");
- printf("ecp_node_init RV:%d\n", rv);
-
- rv = ecp_conn_init(&conn, &sock_c, CTYPE_TEST);
- printf("ecp_conn_init RV:%d\n", rv);
-
- rv = ecp_conn_get_dirlist(&conn, &node);
- printf("ecp_conn_get_dirlist RV:%d\n", rv);
-
- while (1) sleep(1);
-} \ No newline at end of file
diff --git a/ecp/test/echo.c b/ecp/test/echo.c
deleted file mode 100644
index f3057df..0000000
--- a/ecp/test/echo.c
+++ /dev/null
@@ -1,56 +0,0 @@
-#include <stdio.h>
-#include <string.h>
-#include <unistd.h>
-#include <stdlib.h>
-
-#include "core.h"
-#include "util.h"
-
-ECPContext ctx_s;
-ECPSocket sock_s;
-ECPDHKey key_perma_s;
-ECPConnHandler handler_s;
-
-#define CTYPE_TEST 0
-#define MTYPE_MSG 8
-
-ssize_t handle_msg_s(ECPConnection *conn, ecp_seq_t sq, unsigned char t, unsigned char *p, ssize_t s, ECP2Buffer *b) {
- unsigned char buf[ECP_MAX_PLD];
-
- memcpy(buf, p, s);
- ssize_t _rv = ecp_send(conn, t, buf, s);
-
- return s;
-}
-
-static void usage(char *arg) {
- fprintf(stderr, "Usage: %s <address> <node.priv>\n", arg);
- exit(1);
-}
-
-int main(int argc, char *argv[]) {
- int rv;
-
- if (argc != 3) usage(argv[0]);
-
- rv = ecp_init(&ctx_s);
- printf("ecp_init RV:%d\n", rv);
-
- rv = ecp_conn_handler_init(&handler_s);
- handler_s.msg[MTYPE_MSG] = handle_msg_s;
- ctx_s.handler[CTYPE_TEST] = &handler_s;
-
- rv = ecp_util_key_load(&ctx_s, &key_perma_s, argv[2]);
- printf("ecp_util_key_load RV:%d\n", rv);
-
- rv = ecp_sock_init(&sock_s, &ctx_s, &key_perma_s);
- printf("ecp_sock_init RV:%d\n", rv);
-
- rv = ecp_sock_open(&sock_s, argv[1]);
- printf("ecp_sock_open RV:%d\n", rv);
-
- rv = ecp_start_receiver(&sock_s);
- printf("ecp_start_receiver RV:%d\n", rv);
-
- while (1) sleep(1);
-} \ No newline at end of file
diff --git a/ecp/test/frag.c b/ecp/test/frag.c
deleted file mode 100644
index 70b20de..0000000
--- a/ecp/test/frag.c
+++ /dev/null
@@ -1,122 +0,0 @@
-#include <stdio.h>
-#include <string.h>
-#include <unistd.h>
-
-#include "core.h"
-
-ECPContext ctx_s;
-ECPSocket sock_s;
-ECPDHKey key_perma_s;
-ECPConnHandler handler_s;
-
-ECPContext ctx_c;
-ECPSocket sock_c;
-ECPDHKey key_perma_c;
-ECPConnHandler handler_c;
-
-ECPNode node;
-ECPConnection conn;
-
-ECPRBRecv rbuf_recv;
-ECPRBMessage rbuf_r_msg[128];
-ECPFragIter frag_iter;
-unsigned char frag_buffer[8192];
-
-#define CTYPE_TEST 0
-#define MTYPE_MSG 8
-
-ssize_t handle_open_c(ECPConnection *conn, ecp_seq_t sq, unsigned char t, unsigned char *p, ssize_t s, ECP2Buffer *b) {
- uint32_t seq = 0;
-
- ecp_conn_handle_open(conn, sq, t, p, s, b);
- if (s < 0) {
- printf("OPEN ERR:%ld\n", s);
- return s;
- }
-
- unsigned char content[1000];
- char *msg = "PERA JE CAR!";
-
- strcpy((char *)content, msg);
- ssize_t _rv = ecp_send(conn, MTYPE_MSG, content, sizeof(content));
- return s;
-}
-
-ssize_t handle_msg_c(ECPConnection *conn, ecp_seq_t sq, unsigned char t, unsigned char *p, ssize_t s, ECP2Buffer *b) {
- printf("MSG C:%s size:%ld\n", p, s);
-
- ECPRBuffer *rbuf = &conn->rbuf.recv->rbuf;
- printf("RBUF: %d %d %d %d\n", rbuf->seq_start, rbuf->seq_max, rbuf->idx_start, rbuf->arr_size);
- return s;
-}
-
-ssize_t handle_msg_s(ECPConnection *conn, ecp_seq_t sq, unsigned char t, unsigned char *p, ssize_t s, ECP2Buffer *b) {
- printf("MSG S:%s size:%ld\n", p, s);
-
- unsigned char content[5000];
- char *msg = "VAISTINU JE CAR!";
-
- strcpy((char *)content, msg);
- ssize_t _rv = ecp_send(conn, MTYPE_MSG, content, sizeof(content));
- return s;
-}
-
-int main(int argc, char *argv[]) {
- int rv;
-
- rv = ecp_init(&ctx_s);
- printf("ecp_init RV:%d\n", rv);
-
- rv = ecp_conn_handler_init(&handler_s);
- handler_s.msg[MTYPE_MSG] = handle_msg_s;
- ctx_s.handler[CTYPE_TEST] = &handler_s;
-
- rv = ecp_dhkey_gen(&ctx_s, &key_perma_s);
- printf("ecp_dhkey_gen RV:%d\n", rv);
-
- rv = ecp_sock_init(&sock_s, &ctx_s, &key_perma_s);
- printf("ecp_sock_init RV:%d\n", rv);
-
- rv = ecp_sock_open(&sock_s, "0.0.0.0:3000");
- printf("ecp_sock_open RV:%d\n", rv);
-
- rv = ecp_start_receiver(&sock_s);
- printf("ecp_start_receiver RV:%d\n", rv);
-
- rv = ecp_init(&ctx_c);
- printf("ecp_init RV:%d\n", rv);
-
- rv = ecp_conn_handler_init(&handler_c);
- handler_c.msg[ECP_MTYPE_OPEN] = handle_open_c;
- handler_c.msg[MTYPE_MSG] = handle_msg_c;
- ctx_c.handler[CTYPE_TEST] = &handler_c;
-
- rv = ecp_dhkey_gen(&ctx_c, &key_perma_c);
- printf("ecp_dhkey_gen RV:%d\n", rv);
-
- rv = ecp_sock_init(&sock_c, &ctx_c, &key_perma_c);
- printf("ecp_sock_init RV:%d\n", rv);
-
- rv = ecp_sock_open(&sock_c, NULL);
- printf("ecp_sock_open RV:%d\n", rv);
-
- rv = ecp_start_receiver(&sock_c);
- printf("ecp_start_receiver RV:%d\n", rv);
-
- rv = ecp_node_init(&node, &key_perma_s.public, "127.0.0.1:3000");
- printf("ecp_node_init RV:%d\n", rv);
-
- rv = ecp_conn_init(&conn, &sock_c, CTYPE_TEST);
- printf("ecp_conn_init RV:%d\n", rv);
-
- rv = ecp_rbuf_create(&conn, NULL, NULL, 0, &rbuf_recv, rbuf_r_msg, 128);
- printf("ecp_rbuf_create RV:%d\n", rv);
-
- ecp_frag_iter_init(&frag_iter, frag_buffer, 8192);
- rbuf_recv.frag_iter = &frag_iter;
-
- rv = ecp_conn_open(&conn, &node);
- printf("ecp_conn_open RV:%d\n", rv);
-
- while (1) sleep(1);
-} \ No newline at end of file
diff --git a/ecp/test/init_vconn.c b/ecp/test/init_vconn.c
index 59e9517..88b6fa0 100644
--- a/ecp/test/init_vconn.c
+++ b/ecp/test/init_vconn.c
@@ -1,18 +1,12 @@
#include <stdlib.h>
-#include <fcntl.h>
#include <unistd.h>
+#include <stdio.h>
-#include "core.h"
-#include "vconn/vconn.h"
+#include <core.h>
+#include <vconn/vconn.h>
-static int v_rng(void *buf, size_t bufsize) {
- int fd;
-
- if((fd = open("/dev/urandom", O_RDONLY)) < 0) return -1;
- size_t nb = read(fd, buf, bufsize);
- close(fd);
- if (nb != bufsize) return -1;
- return 0;
+void handle_err(ECPConnection *conn, unsigned char mtype, int err) {
+ printf("ERR: CTYPE:0x%x MTYPE:0x%x ERR:%d\n", conn->type, mtype, err);
}
static ECPConnection *conn_alloc(ECPSocket *sock, unsigned char type) {
@@ -21,40 +15,37 @@ static ECPConnection *conn_alloc(ECPSocket *sock, unsigned char type) {
switch (type) {
case ECP_CTYPE_VCONN:
- conn = malloc(sizeof(ECPVConnIn));
+ conn = malloc(sizeof(ECPVConn));
+ if (conn) rv = ecp_vconn_create_inb((ECPVConn *)conn, sock);
+ break;
+
+ case ECP_CTYPE_VLINK:
+ conn = malloc(sizeof(ECPConnection));
+ if (conn) rv = ecp_vlink_create_inb(conn, sock);
break;
+
default:
conn = malloc(sizeof(ECPConnection));
+ if (conn) rv = ecp_conn_create_inb(conn, sock, type);
break;
}
- if (conn == NULL) return NULL;
- rv = ecp_conn_init(conn, sock, type);
+ if (conn == NULL) return NULL;
if (rv) {
- printf("free1\n");
free(conn);
return NULL;
}
+
return conn;
}
static void conn_free(ECPConnection *conn) {
- printf("free2\n");
free(conn);
}
int ecp_init(ECPContext *ctx) {
int rv;
- rv = ecp_ctx_init(ctx);
- if (rv) return rv;
-
- rv = ecp_vconn_ctx_init(ctx);
- if (rv) return rv;
-
- ctx->rng = v_rng;
- ctx->conn_alloc = conn_alloc;
- ctx->conn_free = conn_free;
-
- return ECP_OK;
+ rv = ecp_ctx_init(ctx, handle_err, NULL, conn_alloc, conn_free);
+ return rv;
} \ No newline at end of file
diff --git a/ecp/test/server.c b/ecp/test/server.c
index fabaf4e..228dbea 100644
--- a/ecp/test/server.c
+++ b/ecp/test/server.c
@@ -1,10 +1,11 @@
-#include <stdio.h>
+#include <stdlib.h>
#include <string.h>
#include <unistd.h>
-#include <stdlib.h>
+#include <stdio.h>
-#include "core.h"
-#include "util.h"
+#include <core.h>
+
+#include <util.h>
ECPContext ctx;
ECPSocket sock;
@@ -12,18 +13,16 @@ ECPDHKey key_perma;
ECPConnHandler handler;
#define CTYPE_TEST 0
-#define MTYPE_MSG 8
-
-ssize_t handle_msg(ECPConnection *conn, ecp_seq_t sq, unsigned char t, unsigned char *p, ssize_t s, ECP2Buffer *b) {
- printf("MSG S:%s size:%ld\n", p, s);
+#define MTYPE_MSG 0
- char *msg = "VAISTINU JE CAR!";
- unsigned char buf[1000];
+static ssize_t handle_msg(ECPConnection *conn, ecp_seq_t seq, unsigned char mtype, unsigned char *msg, size_t msg_size, ECP2Buffer *b) {
+ char *_msg = "VAISTINU JE CAR!";
+ ssize_t rv;
- strcpy((char *)buf, msg);
- ssize_t _rv = ecp_send(conn, MTYPE_MSG, buf, 1000);
+ printf("MSG S:%s size:%ld\n", msg, msg_size);
+ rv = ecp_msg_send(conn, MTYPE_MSG, (unsigned char *)_msg, strlen(_msg)+1);
- return s;
+ return msg_size;
}
static void usage(char *arg) {
@@ -32,28 +31,30 @@ static void usage(char *arg) {
}
int main(int argc, char *argv[]) {
+ ECPDHKey key_perma;
int rv;
-
+
+ /* server */
if (argc != 3) usage(argv[0]);
-
+
rv = ecp_init(&ctx);
printf("ecp_init RV:%d\n", rv);
-
- rv = ecp_conn_handler_init(&handler);
- handler.msg[MTYPE_MSG] = handle_msg;
- ctx.handler[CTYPE_TEST] = &handler;
-
- rv = ecp_util_key_load(&ctx, &key_perma, argv[2]);
- printf("ecp_util_key_load RV:%d\n", rv);
-
- rv = ecp_sock_init(&sock, &ctx, &key_perma);
- printf("ecp_sock_init RV:%d\n", rv);
+
+ ecp_conn_handler_init(&handler, handle_msg, NULL, NULL, NULL);
+ ecp_ctx_set_handler(&ctx, &handler, CTYPE_TEST);
+
+ rv = ecp_util_load_key(&key_perma.public, &key_perma.private, argv[2]);
+ printf("ecp_util_load_key RV:%d\n", rv);
+ key_perma.valid = 1;
+
+ rv = ecp_sock_create(&sock, &ctx, &key_perma);
+ printf("ecp_sock_create RV:%d\n", rv);
rv = ecp_sock_open(&sock, argv[1]);
printf("ecp_sock_open RV:%d\n", rv);
-
+
rv = ecp_start_receiver(&sock);
printf("ecp_start_receiver RV:%d\n", rv);
while (1) sleep(1);
-} \ No newline at end of file
+}
diff --git a/ecp/test/vc_client.c b/ecp/test/vc_client.c
index cd0ea44..89602ca 100644
--- a/ecp/test/vc_client.c
+++ b/ecp/test/vc_client.c
@@ -1,70 +1,63 @@
-#include <stdio.h>
+#include <stdlib.h>
#include <string.h>
#include <unistd.h>
-#include <stdlib.h>
+#include <stdio.h>
+
+#include <core.h>
+#include <vconn/vconn.h>
-#include "core.h"
-#include "vconn/vconn.h"
-#include "util.h"
+#include <util.h>
ECPContext ctx;
ECPSocket sock;
ECPConnHandler handler;
-
ECPConnection conn;
-ECPNode node;
-
-ECPVConnOut vconn[20];
-ECPNode vconn_node[20];
+ECPConnection vconn[3];
#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, ECP2Buffer *b) {
- uint32_t seq = 0;
-
- ecp_conn_handle_open(conn, sq, t, p, s, b);
- if (s < 0) {
- printf("OPEN ERR:%ld\n", s);
- return s;
- }
-
- printf("OPEN!\n");
+#define MTYPE_MSG 0
- char *msg = "PERA JE CAR!";
- unsigned char buf[1156];
+static int handle_open(ECPConnection *conn, ECP2Buffer *b) {
+ char *_msg = "PERA JE CAR!";
+ ssize_t rv;
- strcpy((char *)buf, msg);
- ssize_t _rv = ecp_send(conn, MTYPE_MSG, buf, 1156);
+ printf("OPEN\n");
+ rv = ecp_msg_send(conn, MTYPE_MSG, (unsigned char *)_msg, strlen(_msg)+1);
- return s;
+ return ECP_OK;
}
-ssize_t handle_msg(ECPConnection *conn, ecp_seq_t sq, unsigned char t, unsigned char *p, ssize_t s, ECP2Buffer *b) {
- printf("MSG S:%s size:%ld\n", p, s);
- return s;
+static ssize_t handle_msg(ECPConnection *conn, ecp_seq_t seq, unsigned char mtype, unsigned char *msg, size_t msg_size, ECP2Buffer *b) {
+ printf("MSG:%s size:%ld\n", msg, msg_size);
+
+ return msg_size;
}
static void usage(char *arg) {
- fprintf(stderr, "Usage: %s <server.pub> <vcs1.pub> ... <vcsn.pub>\n", arg);
+ fprintf(stderr, "Usage: %s <server.pub> <address> <vcs0.pub> [ ... <vcsN.pub> ]\n", arg);
exit(1);
}
int main(int argc, char *argv[]) {
+ ECPDHKey key_perma;
+ ECPNode node;
+ ecp_ecdh_public_t node_pub;
+ ecp_ecdh_public_t vconn_pub[3];
int rv, i;
- if ((argc < 3) || (argc > 22)) usage(argv[0]);
+ if ((argc < 4) || (argc > 6)) 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;
+ ecp_conn_handler_init(&handler, handle_msg, handle_open, NULL, NULL);
+ ecp_ctx_set_handler(&ctx, &handler, CTYPE_TEST);
- rv = ecp_sock_init(&sock, &ctx, NULL);
- printf("ecp_sock_init RV:%d\n", rv);
+ rv = ecp_dhkey_gen(&key_perma);
+ printf("ecp_dhkey_gen RV:%d\n", rv);
+
+ rv = ecp_sock_create(&sock, &ctx, &key_perma);
+ printf("ecp_sock_create RV:%d\n", rv);
rv = ecp_sock_open(&sock, NULL);
printf("ecp_sock_open RV:%d\n", rv);
@@ -72,19 +65,25 @@ int main(int argc, char *argv[]) {
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);
+ for (i=3; i<argc; i++) {
+ rv = ecp_util_load_pub(&vconn_pub[i-3], argv[i]);
+ printf("ecp_util_load_pub RV:%d\n", rv);
}
- rv = ecp_conn_init(&conn, &sock, CTYPE_TEST);
- printf("ecp_conn_init 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);
+ rv = ecp_vconn_create(vconn, vconn_pub, argc-3, &conn);
+ printf("ecp_vconn_create RV:%d\n", rv);
+
+ rv = ecp_util_load_pub(&node_pub, argv[1]);
+ printf("ecp_util_load_pub RV:%d\n", rv);
+
+ rv = ecp_node_init(&node, &node_pub, argv[2]);
+ printf("ecp_node_init RV:%d\n", rv);
+
+ rv = ecp_vconn_open(&conn, &node);
printf("ecp_vconn_open RV:%d\n", rv);
while (1) sleep(1);
-} \ No newline at end of file
+}
diff --git a/ecp/test/vc_server.c b/ecp/test/vc_server.c
index b86d7b0..de7f275 100644
--- a/ecp/test/vc_server.c
+++ b/ecp/test/vc_server.c
@@ -1,63 +1,63 @@
-#include <stdio.h>
+#include <stdlib.h>
#include <string.h>
#include <unistd.h>
-#include <stdlib.h>
+#include <stdio.h>
-#include "core.h"
-#include "vconn/vconn.h"
-#include "util.h"
+#include <core.h>
+#include <vconn/vconn.h>
+
+#include <util.h>
ECPContext ctx;
ECPSocket sock;
-ECPDHKey key_perma;
ECPConnHandler handler;
-
-ECPNode node;
ECPConnection conn;
+ECPConnection vconn[3];
#define CTYPE_TEST 0
-#define MTYPE_MSG 8
+#define MTYPE_MSG 0
-ssize_t handle_open(ECPConnection *conn, ecp_seq_t sq, unsigned char t, unsigned char *p, ssize_t s, ECP2Buffer *b) {
- printf("OPEN RECEIVED\n");
- return ecp_conn_handle_open(conn, sq, t, p, s, b);
-}
+static int handle_open(ECPConnection *conn, ECP2Buffer *b) {
+ printf("OPEN\n");
-ssize_t handle_msg(ECPConnection *conn, ecp_seq_t sq, unsigned char t, unsigned char *p, ssize_t s, ECP2Buffer *b) {
- printf("MSG S:%s size:%ld\n", p, s);
+ return ECP_OK;
+}
- char *msg = "VAISTINU JE CAR!";
- unsigned char buf[1000];
+static ssize_t handle_msg(ECPConnection *conn, ecp_seq_t seq, unsigned char mtype, unsigned char *msg, size_t msg_size, ECP2Buffer *b) {
+ char *_msg = "VAISTINU JE CAR!";
+ ssize_t rv;
- strcpy((char *)buf, msg);
- ssize_t _rv = ecp_send(conn, MTYPE_MSG, buf, strlen(msg)+1);
+ printf("MSG:%s size:%ld\n", msg, msg_size);
+ rv = ecp_msg_send(conn, MTYPE_MSG, (unsigned char *)_msg, strlen(_msg)+1);
- return s;
+ return msg_size;
}
static void usage(char *arg) {
- fprintf(stderr, "Usage: %s <node.priv> <vcs.pub>\n", arg);
+ fprintf(stderr, "Usage: %s <server.priv> <address> <vcs0.pub> [ ... <vcsN.pub> ]\n", arg);
exit(1);
}
int main(int argc, char *argv[]) {
- int rv;
+ ECPDHKey key_perma;
+ ECPNode node;
+ ecp_ecdh_public_t node_pub;
+ int rv, i;
- if (argc != 3) usage(argv[0]);
+ if ((argc < 4) || (argc > 7)) 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;
+ ecp_conn_handler_init(&handler, handle_msg, handle_open, NULL, NULL);
+ ecp_ctx_set_handler(&ctx, &handler, CTYPE_TEST);
- rv = ecp_util_key_load(&ctx, &key_perma, argv[1]);
- printf("ecp_util_key_load RV:%d\n", rv);
+ rv = ecp_util_load_key(&key_perma.public, &key_perma.private, argv[1]);
+ printf("ecp_util_load_key RV:%d\n", rv);
+ key_perma.valid = 1;
- rv = ecp_sock_init(&sock, &ctx, &key_perma);
- printf("ecp_sock_init RV:%d\n", rv);
+ rv = ecp_sock_create(&sock, &ctx, &key_perma);
+ printf("ecp_sock_create RV:%d\n", rv);
rv = ecp_sock_open(&sock, NULL);
printf("ecp_sock_open RV:%d\n", rv);
@@ -65,14 +65,29 @@ int main(int argc, char *argv[]) {
rv = ecp_start_receiver(&sock);
printf("ecp_start_receiver RV:%d\n", rv);
- rv = ecp_util_node_load(&ctx, &node, argv[2]);
- printf("ecp_util_node_load RV:%d\n", rv);
+ rv = ecp_vlink_create(&conn, &sock);
+ printf("ecp_vlink_create RV:%d\n", rv);
+
+ if (argc > 4) {
+ ecp_ecdh_public_t vconn_key[3];
+
+ for (i=3; i<argc-1; i++) {
+ rv = ecp_util_load_pub(&vconn_key[i-3], argv[i]);
+ printf("ecp_util_load_pub RV:%d\n", rv);
+ }
- rv = ecp_conn_init(&conn, &sock, ECP_CTYPE_VLINK);
- printf("ecp_conn_init RV:%d\n", rv);
+ rv = ecp_vconn_create(vconn, vconn_key, argc-4, &conn);
+ printf("ecp_vconn_create RV:%d\n", rv);
+ }
- rv = ecp_conn_open(&conn, &node);
- printf("ecp_conn_open RV:%d\n", rv);
+ rv = ecp_util_load_pub(&node_pub, argv[argc-1]);
+ printf("ecp_util_load_pub RV:%d\n", rv);
+
+ rv = ecp_node_init(&node, &node_pub, argv[2]);
+ printf("ecp_node_init RV:%d\n", rv);
+
+ rv = ecp_vconn_open(&conn, &node);
+ printf("ecp_vconn_open RV:%d\n", rv);
while (1) sleep(1);
-} \ No newline at end of file
+}
diff --git a/ecp/test/vcs.c b/ecp/test/vcs.c
index f3a0156..c4beed7 100644
--- a/ecp/test/vcs.c
+++ b/ecp/test/vcs.c
@@ -1,54 +1,60 @@
-#include <stdio.h>
+#include <stdlib.h>
#include <string.h>
#include <unistd.h>
-#include <stdlib.h>
+#include <stdio.h>
-#include "core.h"
-#include "util.h"
-#include "vconn/vconn.h"
+#include <core.h>
+#include <vconn/vconn.h>
+
+#include <util.h>
ECPContext ctx;
ECPSocket sock;
-ECPDHKey key_perma;
-
-ECPNode node;
ECPConnection conn;
static void usage(char *arg) {
- fprintf(stderr, "Usage: %s <address> <node.priv> [node.pub]\n", arg);
+ fprintf(stderr, "Usage: %s <my addr> <my.priv> [ <node addr> <node.pub> ]\n", arg);
exit(1);
}
int main(int argc, char *argv[]) {
+ ECPDHKey key_perma;
int rv;
-
- if ((argc < 3) || (argc > 4)) usage(argv[0]);
-
+
+ if ((argc < 3) || (argc > 5)) usage(argv[0]);
+
rv = ecp_init(&ctx);
printf("ecp_init RV:%d\n", rv);
-
- rv = ecp_util_key_load(&ctx, &key_perma, argv[2]);
- printf("ecp_util_key_load RV:%d\n", rv);
-
- rv = ecp_sock_init(&sock, &ctx, &key_perma);
- printf("ecp_sock_init RV:%d\n", rv);
+
+ rv = ecp_util_load_key(&key_perma.public, &key_perma.private, argv[2]);
+ printf("ecp_util_load_key RV:%d\n", rv);
+ key_perma.valid = 1;
+
+ rv = ecp_sock_create(&sock, &ctx, &key_perma);
+ printf("ecp_sock_create RV:%d\n", rv);
rv = ecp_sock_open(&sock, argv[1]);
printf("ecp_sock_open RV:%d\n", rv);
-
+
rv = ecp_start_receiver(&sock);
printf("ecp_start_receiver RV:%d\n", rv);
-
- if (argc == 4) {
- rv = ecp_util_node_load(&ctx, &node, argv[3]);
- printf("ecp_util_node_load RV:%d\n", rv);
- rv = ecp_conn_init(&conn, &sock, ECP_CTYPE_VLINK);
- printf("ecp_conn_init RV:%d\n", rv);
+ if (argc == 5) {
+ ECPNode node;
+ ecp_ecdh_public_t node_pub;
+
+ rv = ecp_vlink_create(&conn, &sock);
+ printf("ecp_vlink_create RV:%d\n", rv);
+
+ rv = ecp_util_load_pub(&node_pub, argv[4]);
+ printf("ecp_util_load_pub RV:%d\n", rv);
+
+ rv = ecp_node_init(&node, &node_pub, argv[3]);
+ printf("ecp_node_init RV:%d\n", rv);
rv = ecp_conn_open(&conn, &node);
printf("ecp_conn_open RV:%d\n", rv);
}
while (1) sleep(1);
-} \ No newline at end of file
+}
diff --git a/ecp/test/vid/Makefile b/ecp/test/vid/Makefile
deleted file mode 100644
index a9b92eb..0000000
--- a/ecp/test/vid/Makefile
+++ /dev/null
@@ -1,23 +0,0 @@
-include ../../ecp/Makefile.platform
-
-LIBVPX_HOME = /opt/my/libvpx
-CFLAGS += -D_V4L2_KERNEL_ -I/usr/src/linux-headers-$(uname -r) -I$(LIBVPX_HOME) -I/opt/local/include/SDL2 -I../../ecp -I../../util -Wno-int-to-void-pointer-cast
-LDFLAGS += -L$(LIBVPX_HOME) -L/opt/local/lib
-
-dep=../init_vconn.o ../../ecp/build-posix/*.a ../../util/libecputil.a
-
-all: cap
-
-%.o: %.c
- $(CC) $(CFLAGS) -c $<
-
-cap: cap.o enc.o tools.o server.o
- $(CC) -o $@ $< enc.o tools.o server.o $(dep) -lvpx $(LDFLAGS)
-
-client: client.o display.o tools.o
- $(CC) -o $@ $< display.o tools.o $(dep) -lvpx -lSDL2 $(LDFLAGS)
-
-clean:
- rm -f *.o
- rm -f cap client
-
diff --git a/ecp/test/vid/cap.c b/ecp/test/vid/cap.c
deleted file mode 100644
index e37c28f..0000000
--- a/ecp/test/vid/cap.c
+++ /dev/null
@@ -1,576 +0,0 @@
-/*
- * OpenCV BSD3 License
- * videodev2.h BSD License (dual license)
- * If you raise some license issue here simply don't use it and let us know
- *
- * Copyright (C) 2016 the contributors
- *
- * Luiz Vitor Martinez Cardoso
- * Jules Thuillier
- * @lex (avafinger)
- *
- * gcc cap.c -o cap $(pkg-config --libs --cflags opencv) -lm
- *
- * gcc -I/usr/src/linux-headers-VERSION/ cap.c -o cap $(pkg-config --libs --cflags opencv) -lm -O3
- *
-*/
-
-#include <stdlib.h>
-#include <stdio.h>
-#include <errno.h>
-#include <fcntl.h>
-#include <stdint.h>
-#include <unistd.h>
-#include <malloc.h>
-#include <string.h>
-#include <sys/mman.h>
-#include <sys/time.h>
-#include <sys/ioctl.h>
-
-/* -----------------------------------------------------------------------------
- * BananaPi M64 / Pine64+ (A64) or if you want to control Exposure,Hflip,Vflip
- * -----------------------------------------------------------------------------
- * _V4L2_KERNEL_ should be defined and point to: /usr/src/linux-headers-version
- *
- * build with: gcc -I/usr/src/linux-headers-3.10.102/ cap.c -o cap $(pkg-config --libs --cflags opencv) -lm -O3
- *
- *
- * -----------------------------------------------------------------------------
- * OrangePi / BananaPi / NanoPi (H3) / BPI-M3 (A83T - ov5640 & ov8865)
- * -----------------------------------------------------------------------------
- * _V4L2_KERNEL_ should not be defined unless you want Exposure, Hflip and Vflip
- *
- * build with: gcc cap.c -o cap $(pkg-config --libs --cflags opencv) -lm
- *
- *
-*/
-//#define _V4L2_KERNEL_ // BananaPi M64 / Pine64+ only or for setting Exposure,Hflip,Vflip
-
-#ifdef _V4L2_KERNEL_
-/* --- A64 --- */
-#include <linux/videodev2.h>
-#else
-/* --- H3 / A83T --- */
-#include "videodev2.h"
-#endif
-
-#ifdef _V4L2_KERNEL_
-#define V4L2_MODE_VIDEO 0x0002 /* video capture */
-#define V4L2_MODE_IMAGE 0x0003 /* image capture */
-#define V4L2_MODE_PREVIEW 0x0004 /* preview capture */
-#endif
-
-#define N_BUFFERS 4
-#define CAP_OK 0
-#define CAP_ERROR -1
-#define CAP_ERROR_RET(s) { \
- fprintf(stderr, "v4l2: %s\n", s); \
- return CAP_ERROR; \
- }
-#define CAP_CLIP(val, min, max) (((val) > (max)) ? (max) : (((val) < (min)) ? (min) : (val)))
-
-#define CLEAR(x) memset (&(x), 0, sizeof (x))
-#define ALIGN_4K(x) (((x) + (4095)) & ~(4095))
-#define ALIGN_16B(x) (((x) + (15)) & ~(15))
-
-#include "server.h"
-#include "enc.h"
-
-typedef struct {
- void *start;
- size_t length;
-} v4l2_buffer_t;
-
-int width;
-int height;
-v4l2_buffer_t *buffers = NULL;
-int n_buffers = N_BUFFERS;
-int sensor_video_mode;
-int sensor_exposure;
-int sensor_hflip;
-int sensor_vflip;
-
-double get_wall_time()
-{
- struct timeval time;
- if (gettimeofday(&time, NULL))
- return 0.;
- return (double) time.tv_sec + (double) time.tv_usec * .000001;
-}
-
-int yuv420p_to_bgr(void *in, int length, unsigned char *out)
-{
- uint8_t *yptr, *uptr, *vptr;
- uint32_t x, y, p;
-
- if (length < (width * height * 3) / 2)
- return CAP_ERROR;
-
- yptr = (uint8_t *) in;
- uptr = yptr + (width * height);
- vptr = uptr + (width * height / 4);
- p = 0;
-
- for (y = 0; y < height; y++) {
- for (x = 0; x < width; x++) {
- int r, g, b;
- int y, u, v;
-
- y = *(yptr++) << 8;
- u = uptr[p] - 128;
- v = vptr[p] - 128;
-
- r = (y + (359 * v)) >> 8;
- g = (y - (88 * u) - (183 * v)) >> 8;
- b = (y + (454 * u)) >> 8;
-
- *(out++) += CAP_CLIP(b, 0x00, 0xFF);
- *(out++) += CAP_CLIP(g, 0x00, 0xFF);
- *(out++) += CAP_CLIP(r, 0x00, 0xFF);
-
- if (x & 1)
- p++;
- }
-
- if (!(y & 1))
- p -= width / 2;
- }
-
- return CAP_ERROR;
-}
-
-static int xioctl(int fd, int request, void *arg)
-{
- int r;
- int tries = 3;
-
- do {
- r = ioctl(fd, request, arg);
- } while (--tries > 0 && -1 == r && EINTR == errno);
-
- return r;
-}
-
-int v4l2_display_sizes_pix_format(int fd)
-{
- int ret = 0;
- int fsizeind = 0; /*index for supported sizes*/
- struct v4l2_frmsizeenum fsize;
-
- fprintf(stderr, "V4L2 pixel sizes:\n");
-
- CLEAR(fsize);
- fsize.index = 0;
- fsize.pixel_format = V4L2_PIX_FMT_YUV420;
-
- while ((ret = xioctl(fd, VIDIOC_ENUM_FRAMESIZES, &fsize)) == 0) {
- fsize.index++;
- if (fsize.type == V4L2_FRMSIZE_TYPE_DISCRETE) {
- fprintf(stderr, "( %u x %u ) Pixels\n", fsize.discrete.width, fsize.discrete.height);
- fsizeind++;
- }
- }
- return fsizeind;
-}
-
-int v4l2_display_pix_format(int fd)
-{
- struct v4l2_fmtdesc fmt;
- int index;
-
- fprintf(stderr, "V4L2 pixel formats:\n");
-
- index = 0;
- CLEAR(fmt);
- fmt.index = index;
- fmt.type = V4L2_BUF_TYPE_VIDEO_CAPTURE;
-
- while (ioctl(fd, VIDIOC_ENUM_FMT, &fmt) != -1) {
- fprintf(stderr, "%i: [0x%08X] '%c%c%c%c' (%s)\n", index, fmt.pixelformat, fmt.pixelformat >> 0, fmt.pixelformat >> 8, fmt.pixelformat >> 16, fmt.pixelformat >> 24, fmt.description);
-
- memset(&fmt, 0, sizeof(fmt));
- fmt.index = ++index;
- fmt.type = V4L2_BUF_TYPE_VIDEO_CAPTURE;
- }
- // fprintf(stderr, "\n");
-}
-
-#ifdef _V4L2_KERNEL_
-int v4l2_set_exposure(int fd, int exposure)
-{
- struct v4l2_queryctrl queryctrl;
- struct v4l2_control control;
- int rc;
-
- fprintf(stderr, "set Exposure: %d\n", exposure);
- rc = 0;
- memset(&control, 0, sizeof(control));
- control.id = V4L2_CID_EXPOSURE;
- rc = xioctl(fd, VIDIOC_G_CTRL, &control);
- fprintf(stderr, "rc: %d - get exposure: %d\n", rc, control.value);
- control.value = exposure;
- rc = xioctl(fd, VIDIOC_S_CTRL, &control);
- fprintf(stderr, "rc: %d - new exposure: %d\n", rc, exposure);
- return rc;
-}
-
-int v4l2_set_hflip(int fd, int hflip)
-{
- struct v4l2_queryctrl queryctrl;
- struct v4l2_control control;
- int rc;
-
- fprintf(stderr, "set Hflip: %d\n", hflip);
- rc = 0;
- memset(&control, 0, sizeof(control));
- control.id = V4L2_CID_HFLIP;
- rc = xioctl(fd, VIDIOC_G_CTRL, &control);
- fprintf(stderr, "rc: %d - get value: %d\n", rc, control.value);
- control.value = hflip;
- rc = xioctl(fd, VIDIOC_S_CTRL, &control);
- fprintf(stderr, "rc: %d - new value: %d\n", rc, control.value);
- return rc;
-}
-
-int v4l2_set_vflip(int fd, int vflip)
-{
- struct v4l2_queryctrl queryctrl;
- struct v4l2_control control;
- int rc;
-
- fprintf(stderr, "set Vflip: %d\n", vflip);
- rc = 0;
- memset(&control, 0, sizeof(control));
- control.id = V4L2_CID_VFLIP;
- rc = xioctl(fd, VIDIOC_G_CTRL, &control);
- fprintf(stderr, "rc: %d - get value: %d\n", rc, control.value);
- control.value = vflip;
- rc = xioctl(fd, VIDIOC_S_CTRL, &control);
- fprintf(stderr, "rc: %d - new value: %d\n", rc, control.value);
- return rc;
-}
-#endif
-
-int v4l2_init_camera(int fd)
-{
- uint32_t i;
- uint32_t index;
- struct v4l2_streamparm parms;
- struct v4l2_format fmt;
- struct v4l2_input input;
- struct v4l2_capability caps;
-
- CLEAR(fmt);
- CLEAR(input);
- CLEAR(caps);
-
-
- if (xioctl(fd, VIDIOC_QUERYCAP, &caps) == -1) {
- CAP_ERROR_RET("unable to query capabilities.");
- }
-
- if (!(caps.capabilities & V4L2_CAP_VIDEO_CAPTURE)) {
- CAP_ERROR_RET("doesn't support video capturing.");
- }
-
- fprintf(stderr, "Driver: \"%s\"\n", caps.driver);
- fprintf(stderr, "Card: \"%s\"\n", caps.card);
- fprintf(stderr, "Bus: \"%s\"\n", caps.bus_info);
- fprintf(stderr, "Version: %d.%d\n", (caps.version >> 16) && 0xff, (caps.version >> 24) && 0xff);
- fprintf(stderr, "Capabilities: %08x\n", caps.capabilities);
-
- input.index = 0;
- if (xioctl(fd, VIDIOC_ENUMINPUT, &input) == -1) {
- CAP_ERROR_RET("unable to enumerate input.");
- }
-
- fprintf(stderr, "Input: %d\n", input.index);
- if (xioctl(fd, VIDIOC_S_INPUT, &input.index) == -1) {
- CAP_ERROR_RET("unable to set input.");
- }
-
- parms.type = V4L2_BUF_TYPE_VIDEO_CAPTURE;
- parms.parm.capture.capturemode = sensor_video_mode ? V4L2_MODE_VIDEO : V4L2_MODE_IMAGE;
- parms.parm.capture.timeperframe.numerator = 1;
- parms.parm.capture.timeperframe.denominator = sensor_video_mode ? 30 : 7;
- if (-1 == xioctl(fd, VIDIOC_S_PARM, &parms)) {
- CAP_ERROR_RET("unable to set stream parm.");
- }
-
- v4l2_display_pix_format(fd);
- v4l2_display_sizes_pix_format(fd);
- fprintf(stderr, "\n");
-
- fmt.fmt.pix.width = width;
- fmt.fmt.pix.height = height;
- fmt.fmt.pix.field = V4L2_FIELD_NONE; // V4L2_FIELD_ANY;
- fmt.type = V4L2_BUF_TYPE_VIDEO_CAPTURE;
- fmt.fmt.pix.pixelformat = V4L2_PIX_FMT_YUV420;
- //fmt.fmt.pix.pixelformat = V4L2_PIX_FMT_RGB24;
-
- if (xioctl(fd, VIDIOC_TRY_FMT, &fmt) == -1) {
- CAP_ERROR_RET("failed trying to set pixel format.");
- }
-
- if (fmt.fmt.pix.width != width || fmt.fmt.pix.height != height) {
- width = fmt.fmt.pix.width;
- height = fmt.fmt.pix.height;
- fprintf(stderr, "Sensor size adjusted to: %dx%d pixels\n", width, height);
- } else {
- fprintf(stderr, "Sensor size: %dx%d pixels\n", width, height);
- }
-
- if (xioctl(fd, VIDIOC_S_FMT, &fmt) == -1) {
- CAP_ERROR_RET("failed to set pixel format.");
- }
-
- switch (fmt.fmt.pix.pixelformat) {
- case V4L2_PIX_FMT_RGB24:
- fprintf(stderr, "Pixel Format: V4L2_PIX_FMT_RGB24 [0x%08X]\n",fmt.fmt.pix.pixelformat);
- break;
-
- case V4L2_PIX_FMT_YUV420:
- fprintf(stderr, "Pixel Format: V4L2_PIX_FMT_YUV420 [0x%08X]\n",fmt.fmt.pix.pixelformat);
- break;
-
- }
-
- return CAP_OK;
-}
-
-int v4l2_set_mmap(int fd, int *buffers_count)
-{
- int i;
- int nbf;
- enum v4l2_buf_type type;
- struct v4l2_requestbuffers req;
- struct v4l2_buffer buf;
-
- CLEAR(req);
- req.count = sensor_video_mode ? n_buffers : 1;
- req.memory = V4L2_MEMORY_MMAP;
- req.type = V4L2_BUF_TYPE_VIDEO_CAPTURE;
- if (xioctl(fd, VIDIOC_REQBUFS, &req) == -1) {
- CAP_ERROR_RET("failed requesting buffers.");
- }
- nbf = req.count;
- if (n_buffers != nbf) {
- CAP_ERROR_RET("insufficient buffer memory.");
- }
-
- buffers = (v4l2_buffer_t *) calloc(nbf, sizeof(v4l2_buffer_t));
- if (!buffers) {
- CAP_ERROR_RET("failed to allocated buffers memory.");
- }
-
- for (i = 0; i < nbf; i++) {
- CLEAR(buf);
- buf.index = i;
- buf.memory = V4L2_MEMORY_MMAP;
- buf.type = V4L2_BUF_TYPE_VIDEO_CAPTURE;
- if (xioctl(fd, VIDIOC_QUERYBUF, &buf) == -1) {
- CAP_ERROR_RET("failed to query buffer.");
- }
- buffers[i].length = buf.length;
- buffers[i].start = mmap(NULL, buf.length, PROT_READ | PROT_WRITE, MAP_SHARED, fd, buf.m.offset);
- if (MAP_FAILED == buffers[i].start) {
- CAP_ERROR_RET("failed to mmap buffer.");
- }
- }
-
- for (i = 0; i < nbf; i++) {
- CLEAR(buf);
- buf.index = i;
- buf.memory = V4L2_MEMORY_MMAP;
- buf.type = V4L2_BUF_TYPE_VIDEO_CAPTURE;
-
- if (xioctl(fd, VIDIOC_QBUF, &buf) == -1) {
- CAP_ERROR_RET("failed to queue buffer.");
- }
- }
-
- type = V4L2_BUF_TYPE_VIDEO_CAPTURE;
- if (xioctl(fd, VIDIOC_STREAMON, &type) == -1) {
- CAP_ERROR_RET("failed to stream on.");
- }
-
- *buffers_count = nbf;
-
- return CAP_OK;
-}
-
-int v4l2_retrieve_frame(int fd, int buffers_count, vpx_image_t *raw, vpx_codec_ctx_t *codec, int frame_index, int kframe_interval)
-{
- int sz;
- fd_set fds;
- unsigned char *frame_yuv;
- struct timeval tv;
- struct v4l2_buffer buf;
- int rc;
- char err_msg[128];
- int flags = 0;
-
- CLEAR(tv);
- CLEAR(buf);
-
- rc = 1;
- while (rc > 0) {
- FD_ZERO(&fds);
- FD_SET(fd, &fds);
-
- tv.tv_sec = 2;
- tv.tv_usec = 0;
-
- rc = select(fd + 1, &fds, NULL, NULL, &tv);
- if (-1 == rc) {
- if (EINTR == errno) {
- rc = 1; // try again
- continue;
- }
- CAP_ERROR_RET("failed to select frame.");
- }
- /* we got something */
- break;
- }
- if (rc <= 0) {
- sprintf(err_msg, "errno: %d - check sensor, something wrong.", errno);
- CAP_ERROR_RET(err_msg);
- }
-
- buf.memory = V4L2_MEMORY_MMAP;
- buf.type = V4L2_BUF_TYPE_VIDEO_CAPTURE;
- if (xioctl(fd, VIDIOC_DQBUF, &buf) == -1) {
- CAP_ERROR_RET("failed to retrieve frame.");
- }
-
- // fprintf(stderr, "Length: %d \tBytesused: %d \tAddress: %p\n", buf.length, buf.bytesused, &buffers[buf.index]);
-
- sz = ALIGN_16B(width) * height * 3 / 2;
- if (!vpx_img_read(raw, buffers[buf.index].start, sz)) {
- die_codec(NULL, "Failed to read image.");
- }
- if (frame_index % kframe_interval == 0) flags |= VPX_EFLAG_FORCE_KF;
- vpx_encode_frame(codec, raw, frame_index, flags);
-
- if (xioctl(fd, VIDIOC_QBUF, &buf) == -1) {
- CAP_ERROR_RET("failed to queue buffer.");
- }
-
- return CAP_OK;
-}
-
-int v4l2_close_camera(int fd, int buffers_count)
-{
- int i;
- enum v4l2_buf_type type;
-
- type = V4L2_BUF_TYPE_VIDEO_CAPTURE;
- if (xioctl(fd, VIDIOC_STREAMOFF, &type) == -1) {
- CAP_ERROR_RET("failed to stream off.");
- }
-
- for (i = 0; i < buffers_count; i++)
- munmap(buffers[i].start, buffers[i].length);
-
- close(fd);
-}
-
-int main(int argc, char *argv[])
-{
- int fd;
- int target_bitrate = 200;
- double after;
- double before;
- double avg, fps;
- int buffers_count;
- int kframe_interval;
- vpx_codec_er_flags_t err_resilient;
- char *address;
- char *my_key;
- char *vcs_key;
-
- if (argc != 14) {
- CAP_ERROR_RET("./cap <width> <height> <buffers [4,8]> <video mode [0,1]> <exposure [-4,4]> <hflip [0,1]> <vflip [0,1]> <kframe interval> <bitrate> <err resilient> <address> <my key> <vcs pub key>")
- }
- width = (int) atoi(argv[1]);
- height = (int) atoi(argv[2]);
- n_buffers = (int) atoi(argv[3]);
- if (n_buffers < 4)
- n_buffers = 4;
- if (n_buffers > 8)
- n_buffers = 8; // enough in VIDEO MODE!!!
-
- sensor_video_mode = (int) atoi(argv[4]);
- if (!sensor_video_mode)
- n_buffers = 1;
- sensor_exposure = (int) atoi(argv[5]);
- sensor_hflip = (int) atoi(argv[6]);
- sensor_vflip = (int) atoi(argv[7]);
- kframe_interval = (int) atoi(argv[8]);
- target_bitrate = (int) atoi(argv[9]);
- err_resilient = strtoul(argv[10], NULL, 0);
- address = argv[11];
- my_key = argv[12];
- vcs_key = argv[13];
-
- fprintf(stderr, "---- cap parameters -----\nwidth: %d\nheight: %d\nv4l2 buffers: %d\nexposure: %d\nhflip: %d\nvflip: %d\nMode: %s\n", width, height, n_buffers, sensor_exposure, sensor_hflip, sensor_vflip, sensor_video_mode ? "V4L2_MODE_VIDEO" : "V4L2_MODE_IMAGE");
-
- fd = open("/dev/video0", O_RDWR | O_NONBLOCK);
- if (fd == -1) {
- CAP_ERROR_RET("failed to open the camera.");
- }
-
- if (v4l2_init_camera(fd) == -1) {
- CAP_ERROR_RET("failed to init camera.");
- }
-#ifdef _V4L2_KERNEL_
- if (sensor_exposure != -999) {
- v4l2_set_exposure(fd, sensor_exposure);
- }
- if (sensor_hflip != -1) {
- v4l2_set_hflip(fd, sensor_hflip);
- }
-
- if (sensor_vflip != -1) {
- v4l2_set_vflip(fd, sensor_vflip);
- }
-#endif
-
- if (v4l2_set_mmap(fd, &buffers_count) == -1) {
- CAP_ERROR_RET("failed to mmap.");
- }
-
- int n = 0;
- int _fps = 30;
- const char *codec_arg = "vp9";
- vpx_codec_ctx_t codec;
- vpx_image_t raw;
-
- vpx_open(codec_arg, width, height, _fps, target_bitrate, err_resilient, &codec, &raw);
- init_server(address, my_key, vcs_key);
-
- while (1) {
- if (!conn_is_open()) {
- sleep(1);
- continue;
- }
- before = get_wall_time();
- if (v4l2_retrieve_frame(fd, buffers_count, &raw, &codec, n, kframe_interval)) {
- CAP_ERROR_RET("failed to retrieve frame.");
- }
- after = get_wall_time();
- fps = 1.0 / (after - before);
- avg += fps;
- n++;
- // fprintf(stderr, "FPS[%d]: %.2f\n", i, fps);
- }
-
- vpx_close(&codec, &raw);
- v4l2_close_camera(fd, buffers_count);
-
- if (n) {
- fprintf(stderr, "\n------- Avg FPS: %.2f --------\n\n", (double) (avg / (double) n));
- }
-
- return CAP_OK;
-}
diff --git a/ecp/test/vid/cap.sh b/ecp/test/vid/cap.sh
deleted file mode 100755
index bfd933e..0000000
--- a/ecp/test/vid/cap.sh
+++ /dev/null
@@ -1,3 +0,0 @@
-#!/bin/sh
-
-./cap 640 480 8 1 -999 -1 -1 25 256 1 0.0.0.0:3000 ../../keys/pine64-home.priv ../../keys/majstor.org.pub
diff --git a/ecp/test/vid/client.c b/ecp/test/vid/client.c
deleted file mode 100644
index 017967b..0000000
--- a/ecp/test/vid/client.c
+++ /dev/null
@@ -1,123 +0,0 @@
-#include <stdio.h>
-#include <string.h>
-#include <unistd.h>
-#include <stdlib.h>
-
-#include "vpx/vpx_decoder.h"
-#include "vpx/vp8cx.h"
-#include "tools.h"
-#include "display.h"
-
-#include "core.h"
-#include "vconn/vconn.h"
-#include "util.h"
-
-#define CTYPE_TEST 0
-#define MTYPE_MSG 8
-
-#define FRAG_BUF_SIZE 8192
-#define RBUF_MSG_SIZE 128
-
-ECPContext ctx;
-ECPSocket sock;
-ECPConnHandler handler;
-
-ECPNode node;
-ECPConnection conn;
-
-ECPVConnection vconn;
-ECPNode vconn_node;
-
-vpx_codec_ctx_t codec;
-
-ECPRBRecv rbuf_recv;
-ECPRBMessage rbuf_r_msg[RBUF_MSG_SIZE];
-ECPFragIter frag_iter;
-unsigned char frag_buffer[FRAG_BUF_SIZE];
-
-SDLCanvas sdl_canvas;
-
-ssize_t handle_msg(ECPConnection *conn, ecp_seq_t sq, unsigned char t, unsigned char *f, ssize_t sz, ECP2Buffer *b) {
- vpx_codec_iter_t iter = NULL;
- vpx_image_t *img = NULL;
-
- if (vpx_codec_decode(&codec, f, (unsigned int)sz, NULL, 0)) {
- fprintf(stderr, "\n%lu\n", sz);
- fprintf(stderr, "ERROR!\n");
- // die_codec(&codec, "Failed to decode frame.");
- }
-
- while ((img = vpx_codec_get_frame(&codec, &iter)) != NULL) {
- if (!vpx_img_write(img, sdl_canvas.yuvBuffer, sdl_canvas.yPlaneSz + 2 * sdl_canvas.uvPlaneSz)) die_codec(NULL, "Failed to write image.");
- }
- sdl_display_frame(&sdl_canvas);
-
- return sz;
-}
-
-static void usage(char *arg) {
- fprintf(stderr, "Usage: %s <node.pub> <vcs.pub>\n", arg);
- exit(1);
-}
-
-int main(int argc, char *argv[]) {
- int rv;
-
- if (argc != 3) usage(argv[0]);
-
- rv = ecp_init(&ctx);
- fprintf(stderr, "ecp_init RV:%d\n", rv);
-
- if (!rv) rv = ecp_conn_handler_init(&handler);
- if (!rv) {
- handler.msg[MTYPE_MSG] = handle_msg;
- ctx.handler[CTYPE_TEST] = &handler;
- }
-
- if (!rv) rv = ecp_sock_create(&sock, &ctx, NULL);
- fprintf(stderr, "ecp_sock_create RV:%d\n", rv);
-
- if (!rv) rv = ecp_sock_open(&sock, NULL);
- fprintf(stderr, "ecp_sock_open RV:%d\n", rv);
-
- if (!rv) rv = ecp_start_receiver(&sock);
- fprintf(stderr, "ecp_start_receiver RV:%d\n", rv);
-
- if (!rv) rv = ecp_util_node_load(&ctx, &node, argv[1]);
- fprintf(stderr, "ecp_util_node_load RV:%d\n", rv);
-
- if (!rv) rv = ecp_util_node_load(&ctx, &vconn_node, argv[2]);
- printf("ecp_util_node_load RV:%d\n", rv);
-
- if (!rv) rv = ecp_conn_create(&conn, &sock, CTYPE_TEST);
- fprintf(stderr, "ecp_conn_create RV:%d\n", rv);
-
- if (!rv) rv = ecp_rbuf_create(&conn, NULL, NULL, 0, &rbuf_recv, rbuf_r_msg, RBUF_MSG_SIZE);
- fprintf(stderr, "ecp_rbuf_create RV:%d\n", rv);
-
- if (!rv) {
- ecp_frag_iter_init(&frag_iter, frag_buffer, FRAG_BUF_SIZE);
- rbuf_recv.frag_iter = &frag_iter;
- }
-
- const char *codec_arg = "vp9";
- const VpxInterface *decoder = get_vpx_decoder_by_name(codec_arg);
- if (!decoder) die_codec(NULL, "Unknown input codec.");
-
- fprintf(stderr, "Using %s\n", vpx_codec_iface_name(decoder->codec_interface()));
-
- if (vpx_codec_dec_init(&codec, decoder->codec_interface(), NULL, 0))
- die_codec(&codec, "Failed to initialize decoder.");
-
- sdl_open(&sdl_canvas, 640, 480);
-
- // if (!rv) rv = ecp_conn_open(&conn, &node);
- // fprintf(stderr, "ecp_conn_open RV:%d\n", rv);
-
- if (!rv) rv = ecp_vconn_open(&conn, &node, &vconn, &vconn_node, 1);
- printf("ecp_vconn_open RV:%d\n", rv);
-
- sdl_loop();
- sdl_close(&sdl_canvas);
- if (vpx_codec_destroy(&codec)) die_codec(&codec, "Failed to destroy codec");
-} \ No newline at end of file
diff --git a/ecp/test/vid/display.c b/ecp/test/vid/display.c
deleted file mode 100644
index d378431..0000000
--- a/ecp/test/vid/display.c
+++ /dev/null
@@ -1,68 +0,0 @@
-#include <stdio.h>
-
-#include "display.h"
-
-void sdl_open(SDLCanvas *o, int img_width, int img_height) {
- // Initialize the SDL
- if (SDL_Init(SDL_INIT_VIDEO) != 0) {
- fprintf(stderr, "SDL_Init() Failed: %s\n", SDL_GetError());
- exit(1);
- }
-
- o->display = SDL_CreateWindow("SDL Tutorial",
- SDL_WINDOWPOS_UNDEFINED,
- SDL_WINDOWPOS_UNDEFINED,
- img_width, img_height, 0);
- if (o->display == NULL) {
- fprintf(stderr, "SDL_SetVideoMode() Failed: %s\n", SDL_GetError());
- exit(1);
- }
-
- o->renderer = SDL_CreateRenderer(o->display, -1, 0);
- if (o->renderer == NULL) {
- fprintf(stderr, "SDL_CreateRenderer() Failed: %s\n", SDL_GetError());
- exit(1);
- }
-
- o->texture = SDL_CreateTexture(o->renderer, SDL_PIXELFORMAT_YV12, SDL_TEXTUREACCESS_STREAMING, img_width, img_height);
- if (o->texture == NULL) {
- fprintf(stderr, "SDL_CreateTextureFromSurface() Failed: %s\n", SDL_GetError());
- exit(1);
- }
-
- o->yPlaneSz = img_width * img_height;
- o->uvPlaneSz = img_width * img_height / 4;
- o->yuvBuffer = (Uint8*)malloc(o->yPlaneSz + 2 * o->uvPlaneSz);
- o->yPitch = img_width;
- o->uvPitch = img_width / 2;
-}
-
-void sdl_close(SDLCanvas *o) {
- free(o->yuvBuffer);
- SDL_DestroyTexture(o->texture);
- SDL_DestroyRenderer(o->renderer);
- SDL_DestroyWindow(o->display);
- SDL_Quit();
-}
-
-void sdl_display_frame(SDLCanvas *o) {
- SDL_UpdateYUVTexture(o->texture, NULL, o->yuvBuffer, o->yPitch, o->yuvBuffer + o->yPlaneSz, o->uvPitch, o->yuvBuffer + o->yPlaneSz + o->uvPlaneSz, o->uvPitch);
- SDL_RenderClear(o->renderer);
- SDL_RenderCopy(o->renderer, o->texture, NULL, NULL);
- SDL_RenderPresent(o->renderer);
-}
-
-void sdl_loop(void) {
- SDL_Event event;
-
- while(1) {
- // Check for messages
- if (SDL_PollEvent(&event)) {
- // Check for the quit message
- if (event.type == SDL_QUIT) {
- // Quit the program
- break;
- }
- }
- }
-}
diff --git a/ecp/test/vid/display.h b/ecp/test/vid/display.h
deleted file mode 100644
index 38e07be..0000000
--- a/ecp/test/vid/display.h
+++ /dev/null
@@ -1,17 +0,0 @@
-#include "SDL.h"
-
-typedef struct SDLCanvas {
- SDL_Window *display;
- SDL_Renderer *renderer;
- SDL_Texture *texture;
- Uint8 *yuvBuffer;
- size_t yPlaneSz;
- size_t uvPlaneSz;
- int yPitch;
- int uvPitch;
-} SDLCanvas;
-
-void sdl_open(SDLCanvas *o, int img_width, int img_height);
-void sdl_close(SDLCanvas *o);
-void sdl_display_frame(SDLCanvas *o);
-void sdl_loop(void);
diff --git a/ecp/test/vid/enc.c b/ecp/test/vid/enc.c
deleted file mode 100644
index 34d0be8..0000000
--- a/ecp/test/vid/enc.c
+++ /dev/null
@@ -1,168 +0,0 @@
-/*
- * Copyright (c) 2010 The WebM project authors. All Rights Reserved.
- *
- * Use of this source code is governed by a BSD-style license
- * that can be found in the LICENSE file in the root of the source
- * tree. An additional intellectual property rights grant can be found
- * in the file PATENTS. All contributing project authors may
- * be found in the AUTHORS file in the root of the source tree.
- */
-
-// Simple Encoder
-// ==============
-//
-// This is an example of a simple encoder loop. It takes an input file in
-// YV12 format, passes it through the encoder, and writes the compressed
-// frames to disk in IVF format. Other decoder examples build upon this
-// one.
-//
-// The details of the IVF format have been elided from this example for
-// simplicity of presentation, as IVF files will not generally be used by
-// your application. In general, an IVF file consists of a file header,
-// followed by a variable number of frames. Each frame consists of a frame
-// header followed by a variable length payload. The length of the payload
-// is specified in the first four bytes of the frame header. The payload is
-// the raw compressed data.
-//
-// Standard Includes
-// -----------------
-// For encoders, you only have to include `vpx_encoder.h` and then any
-// header files for the specific codecs you use. In this case, we're using
-// vp8.
-//
-// Getting The Default Configuration
-// ---------------------------------
-// Encoders have the notion of "usage profiles." For example, an encoder
-// may want to publish default configurations for both a video
-// conferencing application and a best quality offline encoder. These
-// obviously have very different default settings. Consult the
-// documentation for your codec to see if it provides any default
-// configurations. All codecs provide a default configuration, number 0,
-// which is valid for material in the vacinity of QCIF/QVGA.
-//
-// Updating The Configuration
-// ---------------------------------
-// Almost all applications will want to update the default configuration
-// with settings specific to their usage. Here we set the width and height
-// of the video file to that specified on the command line. We also scale
-// the default bitrate based on the ratio between the default resolution
-// and the resolution specified on the command line.
-//
-// Initializing The Codec
-// ----------------------
-// The encoder is initialized by the following code.
-//
-// Encoding A Frame
-// ----------------
-// The frame is read as a continuous block (size width * height * 3 / 2)
-// from the input file. If a frame was read (the input file has not hit
-// EOF) then the frame is passed to the encoder. Otherwise, a NULL
-// is passed, indicating the End-Of-Stream condition to the encoder. The
-// `frame_cnt` is reused as the presentation time stamp (PTS) and each
-// frame is shown for one frame-time in duration. The flags parameter is
-// unused in this example. The deadline is set to VPX_DL_REALTIME to
-// make the example run as quickly as possible.
-
-// Forced Keyframes
-// ----------------
-// Keyframes can be forced by setting the VPX_EFLAG_FORCE_KF bit of the
-// flags passed to `vpx_codec_control()`. In this example, we force a
-// keyframe every <keyframe-interval> frames. Note, the output stream can
-// contain additional keyframes beyond those that have been forced using the
-// VPX_EFLAG_FORCE_KF flag because of automatic keyframe placement by the
-// encoder.
-//
-// Processing The Encoded Data
-// ---------------------------
-// Each packet of type `VPX_CODEC_CX_FRAME_PKT` contains the encoded data
-// for this frame. We write a IVF frame header, followed by the raw data.
-//
-// Cleanup
-// -------
-// The `vpx_codec_destroy` call frees any memory allocated by the codec.
-//
-// Error Handling
-// --------------
-// This example does not special case any error return codes. If there was
-// an error, a descriptive message is printed and the program exits. With
-// few exeptions, vpx_codec functions return an enumerated error status,
-// with the value `0` indicating success.
-//
-// Error Resiliency Features
-// -------------------------
-// Error resiliency is controlled by the g_error_resilient member of the
-// configuration structure. Use the `decode_with_drops` example to decode with
-// frames 5-10 dropped. Compare the output for a file encoded with this example
-// versus one encoded with the `simple_encoder` example.
-
-#include <stdio.h>
-#include <stdlib.h>
-#include <string.h>
-
-#include "enc.h"
-#include "server.h"
-
-int vpx_encode_frame(vpx_codec_ctx_t *codec, vpx_image_t *img, int frame_index, int flags) {
- int got_pkts = 0;
- vpx_codec_iter_t iter = NULL;
- const vpx_codec_cx_pkt_t *pkt = NULL;
- const vpx_codec_err_t res =
- vpx_codec_encode(codec, img, frame_index, 1, flags, VPX_DL_REALTIME);
- if (res != VPX_CODEC_OK) die_codec(codec, "Failed to encode frame");
-
- while ((pkt = vpx_codec_get_cx_data(codec, &iter)) != NULL) {
- got_pkts = 1;
-
- if (pkt->kind == VPX_CODEC_CX_FRAME_PKT) {
- const int keyframe = (pkt->data.frame.flags & VPX_FRAME_IS_KEY) != 0;
- if (send_frame(pkt->data.frame.buf, pkt->data.frame.sz, pkt->data.frame.pts) < 0) {
- die_codec(codec, "Failed to write compressed frame");
- }
- fprintf(stderr, keyframe ? "K" : ".");
- fflush(stdout);
- }
- }
-
- return got_pkts;
-}
-
-
-void vpx_open(const char *codec_arg, int width, int height, int fps, int bitrate, vpx_codec_er_flags_t err_resilient, vpx_codec_ctx_t *codec, vpx_image_t *raw) {
- vpx_codec_enc_cfg_t cfg;
- vpx_codec_err_t res;
-
- const VpxInterface *encoder = get_vpx_encoder_by_name(codec_arg);
- if (!encoder) die_codec(NULL, "Unsupported codec.");
-
- fprintf(stderr, "Using %s\n", vpx_codec_iface_name(encoder->codec_interface()));
-
- if (!vpx_img_alloc(raw, VPX_IMG_FMT_I420, width, height, 1))
- die_codec(NULL, "Failed to allocate image.");
-
- res = vpx_codec_enc_config_default(encoder->codec_interface(), &cfg, 0);
- if (res) die_codec(NULL, "Failed to get default codec config.");
-
- cfg.g_w = width;
- cfg.g_h = height;
- cfg.g_timebase.num = 1;
- cfg.g_timebase.den = fps;
- cfg.rc_target_bitrate = bitrate;
- cfg.g_error_resilient = err_resilient;
- cfg.g_lag_in_frames = 0;
- cfg.rc_end_usage = VPX_CBR;
-
- if (vpx_codec_enc_init(codec, encoder->codec_interface(), &cfg, 0))
- die_codec(codec, "Failed to initialize encoder");
-
- if (vpx_codec_control(codec, VP8E_SET_CPUUSED, 8))
- die_codec(codec, "Failed to initialize cpuused");
-}
-
-void vpx_close(vpx_codec_ctx_t *codec, vpx_image_t *raw) {
- // Flush encoder.
- while (vpx_encode_frame(codec, NULL, -1, 0)) {
- }
-
- vpx_img_free(raw);
- if (vpx_codec_destroy(codec)) die_codec(codec, "Failed to destroy codec.");
-}
diff --git a/ecp/test/vid/enc.h b/ecp/test/vid/enc.h
deleted file mode 100644
index 5acd8ce..0000000
--- a/ecp/test/vid/enc.h
+++ /dev/null
@@ -1,7 +0,0 @@
-#include "vpx/vpx_encoder.h"
-#include "vpx/vp8cx.h"
-#include "tools.h"
-
-int vpx_encode_frame(vpx_codec_ctx_t *codec, vpx_image_t *img, int frame_index, int flags);
-void vpx_open(const char *codec_arg, int width, int height, int fps, int bitrate, vpx_codec_er_flags_t err_resilient, vpx_codec_ctx_t *codec, vpx_image_t *raw);
-void vpx_close(vpx_codec_ctx_t *codec, vpx_image_t *raw);
diff --git a/ecp/test/vid/server.c b/ecp/test/vid/server.c
deleted file mode 100644
index 9d43b7a..0000000
--- a/ecp/test/vid/server.c
+++ /dev/null
@@ -1,76 +0,0 @@
-#include <stdio.h>
-#include <string.h>
-#include <unistd.h>
-#include <stdlib.h>
-
-#include "server.h"
-
-static ECPContext ctx;
-static ECPSocket sock;
-static ECPDHKey key_perma;
-static ECPConnHandler handler;
-
-static ECPConnection *conn_in;
-static int is_open = 0;
-
-#define CTYPE_TEST 0
-#define MTYPE_MSG 8
-
-ECPNode node;
-ECPConnection conn;
-
-static ssize_t handle_open(ECPConnection *c, ecp_seq_t sq, unsigned char t, unsigned char *m, ssize_t sz, ECP2Buffer *b) {
- fprintf(stderr, "IS OPEN!\n");
-
- ssize_t rv = ecp_conn_handle_open(c, sq, t, m, sz, b);
- if (rv < 0) return rv;
-
- conn_in = c;
- is_open = 1;
-
- return rv;
-}
-
-ssize_t send_frame(unsigned char *buffer, size_t size, ecp_pts_t pts) {
- return ecp_send(conn_in, MTYPE_MSG, buffer, size);
-}
-
-int conn_is_open(void) {
- return is_open;
-}
-
-int init_server(char *address, char *my_key, char *vcs_key) {
- int rv;
-
- rv = ecp_init(&ctx);
- fprintf(stderr, "ecp_init RV:%d\n", rv);
-
- if (!rv) rv = ecp_conn_handler_init(&handler);
- if (!rv) {
- handler.msg[ECP_MTYPE_OPEN] = handle_open;
- ctx.handler[CTYPE_TEST] = &handler;
- }
-
- if (!rv) rv = ecp_util_key_load(&ctx, &key_perma, my_key);
- fprintf(stderr, "ecp_util_key_load RV:%d\n", rv);
-
- if (!rv) rv = ecp_sock_create(&sock, &ctx, &key_perma);
- fprintf(stderr, "ecp_sock_create RV:%d\n", rv);
-
- if (!rv) rv = ecp_sock_open(&sock, address);
- fprintf(stderr, "ecp_sock_open RV:%d\n", rv);
-
- if (!rv) rv = ecp_start_receiver(&sock);
- fprintf(stderr, "ecp_start_receiver RV:%d\n", rv);
-
- if (!rv) rv = ecp_util_node_load(&ctx, &node, vcs_key);
- printf("ecp_util_node_load RV:%d\n", rv);
-
- if (!rv) rv = ecp_conn_create(&conn, &sock, ECP_CTYPE_VLINK);
- printf("ecp_conn_create RV:%d\n", rv);
-
- if (!rv) rv = ecp_conn_open(&conn, &node);
- printf("ecp_conn_open RV:%d\n", rv);
-
- return rv;
-}
diff --git a/ecp/test/vid/server.h b/ecp/test/vid/server.h
deleted file mode 100644
index 2158b38..0000000
--- a/ecp/test/vid/server.h
+++ /dev/null
@@ -1,7 +0,0 @@
-#include "core.h"
-#include "vconn/vconn.h"
-#include "util.h"
-
-ssize_t send_frame(unsigned char *buffer, size_t size, ecp_pts_t pts);
-int conn_is_open(void);
-int init_server(char *address, char *my_key, char *vcs_key);
diff --git a/ecp/test/vid/tools.c b/ecp/test/vid/tools.c
deleted file mode 100644
index 0307ef6..0000000
--- a/ecp/test/vid/tools.c
+++ /dev/null
@@ -1,165 +0,0 @@
-#include <stdio.h>
-#include <stdarg.h>
-#include <stdlib.h>
-#include <string.h>
-
-#include "tools.h"
-
-static const VpxInterface vpx_encoders[] = {
- { "vp8", VP8_FOURCC, &vpx_codec_vp8_cx },
- { "vp9", VP9_FOURCC, &vpx_codec_vp9_cx },
-};
-
-int get_vpx_encoder_count(void) {
- return sizeof(vpx_encoders) / sizeof(vpx_encoders[0]);
-}
-
-const VpxInterface *get_vpx_encoder_by_index(int i) { return &vpx_encoders[i]; }
-
-const VpxInterface *get_vpx_encoder_by_name(const char *name) {
- int i;
-
- for (i = 0; i < get_vpx_encoder_count(); ++i) {
- const VpxInterface *encoder = get_vpx_encoder_by_index(i);
- if (strcmp(encoder->name, name) == 0) return encoder;
- }
-
- return NULL;
-}
-
-static const VpxInterface vpx_decoders[] = {
- { "vp8", VP8_FOURCC, &vpx_codec_vp8_dx },
- { "vp9", VP9_FOURCC, &vpx_codec_vp9_dx },
-};
-
-int get_vpx_decoder_count(void) {
- return sizeof(vpx_decoders) / sizeof(vpx_decoders[0]);
-}
-
-const VpxInterface *get_vpx_decoder_by_index(int i) { return &vpx_decoders[i]; }
-
-const VpxInterface *get_vpx_decoder_by_name(const char *name) {
- int i;
-
- for (i = 0; i < get_vpx_decoder_count(); ++i) {
- const VpxInterface *const decoder = get_vpx_decoder_by_index(i);
- if (strcmp(decoder->name, name) == 0) return decoder;
- }
-
- return NULL;
-}
-
-void die_codec(vpx_codec_ctx_t *ctx, const char *s) {
- if (ctx) {
- const char *detail = vpx_codec_error_detail(ctx);
-
- fprintf(stderr, "%s: %s\n", s, vpx_codec_error(ctx));
- if (detail) fprintf(stderr, " %s\n", detail);
- } else {
- fprintf(stderr, "%s", s);
- }
- exit(EXIT_FAILURE);
-}
-
-// TODO(dkovalev): move this function to vpx_image.{c, h}, so it will be part
-// of vpx_image_t support
-int vpx_img_plane_width(const vpx_image_t *img, int plane) {
- if (plane > 0 && img->x_chroma_shift > 0)
- return (img->d_w + 1) >> img->x_chroma_shift;
- else
- return img->d_w;
-}
-
-int vpx_img_plane_height(const vpx_image_t *img, int plane) {
- if (plane > 0 && img->y_chroma_shift > 0)
- return (img->d_h + 1) >> img->y_chroma_shift;
- else
- return img->d_h;
-}
-
-int vpx_img_read(vpx_image_t *img, void *img_buf, int sz) {
- int plane;
- int off = 0;
-
- for (plane = 0; plane < 3; ++plane) {
- unsigned char *buf = img->planes[plane];
- const int stride = img->stride[plane];
- const int w = vpx_img_plane_width(img, plane) *
- ((img->fmt & VPX_IMG_FMT_HIGHBITDEPTH) ? 2 : 1);
- const int h = vpx_img_plane_height(img, plane);
- int y;
-
- for (y = 0; y < h; ++y) {
- if (off + w > sz) return 0;
- memcpy(buf, img_buf + off, w);
- off += w;
- buf += stride;
- }
- }
-
- return 1;
-}
-
-int vpx_img_write(const vpx_image_t *img, void *img_buf, int sz) {
- int plane;
- int off = 0;
-
- for (plane = 0; plane < 3; ++plane) {
- const unsigned char *buf = img->planes[plane];
- const int stride = img->stride[plane];
- const int w = vpx_img_plane_width(img, plane) *
- ((img->fmt & VPX_IMG_FMT_HIGHBITDEPTH) ? 2 : 1);
- const int h = vpx_img_plane_height(img, plane);
- int y;
-
- for (y = 0; y < h; ++y) {
- if (off + w > sz) return 0;
- memcpy(img_buf + off, buf, w);
- off += w;
- buf += stride;
- }
- }
-
- return 1;
-}
-
-int vpx_img_read_f(vpx_image_t *img, FILE *file) {
- int plane;
-
- for (plane = 0; plane < 3; ++plane) {
- unsigned char *buf = img->planes[plane];
- const int stride = img->stride[plane];
- const int w = vpx_img_plane_width(img, plane) *
- ((img->fmt & VPX_IMG_FMT_HIGHBITDEPTH) ? 2 : 1);
- const int h = vpx_img_plane_height(img, plane);
- int y;
-
- for (y = 0; y < h; ++y) {
- if (fread(buf, 1, w, file) != (size_t)w) return 0;
- buf += stride;
- }
- }
-
- return 1;
-}
-
-int vpx_img_write_f(const vpx_image_t *img, FILE *file) {
- int plane;
-
- for (plane = 0; plane < 3; ++plane) {
- const unsigned char *buf = img->planes[plane];
- const int stride = img->stride[plane];
- const int w = vpx_img_plane_width(img, plane) *
- ((img->fmt & VPX_IMG_FMT_HIGHBITDEPTH) ? 2 : 1);
- const int h = vpx_img_plane_height(img, plane);
- int y;
-
- for (y = 0; y < h; ++y) {
- if (fwrite(buf, 1, w, file) != (size_t)w) return 0;
- buf += stride;
- }
- }
-
- return 1;
-}
-
diff --git a/ecp/test/vid/tools.h b/ecp/test/vid/tools.h
deleted file mode 100644
index 645d5ba..0000000
--- a/ecp/test/vid/tools.h
+++ /dev/null
@@ -1,37 +0,0 @@
-#ifndef TOOLS_COMMON_H_
-#define TOOLS_COMMON_H_
-
-#include "vpx/vpx_codec.h"
-#include "vpx/vpx_image.h"
-#include "vpx/vp8cx.h"
-#include "vpx/vp8dx.h"
-
-#define VP8_FOURCC 0x30385056
-#define VP9_FOURCC 0x30395056
-
-struct VpxRational {
- int numerator;
- int denominator;
-};
-
-typedef struct VpxInterface {
- const char *const name;
- const uint32_t fourcc;
- vpx_codec_iface_t *(*const codec_interface)();
-} VpxInterface;
-
-const VpxInterface *get_vpx_encoder_by_index(int i);
-const VpxInterface *get_vpx_encoder_by_name(const char *name);
-
-const VpxInterface *get_vpx_decoder_by_index(int i);
-const VpxInterface *get_vpx_decoder_by_name(const char *name);
-
-void die_codec(vpx_codec_ctx_t *ctx, const char *s);
-
-int vpx_img_read(vpx_image_t *img, void *img_buf, int sz);
-int vpx_img_write(const vpx_image_t *img, void *img_buf, int sz);
-
-int vpx_img_read_f(vpx_image_t *img, FILE *file);
-int vpx_img_write_f(const vpx_image_t *img, FILE *file);
-
-#endif \ No newline at end of file
diff --git a/ecp/test/voip.c b/ecp/test/voip.c
deleted file mode 100644
index b0a9207..0000000
--- a/ecp/test/voip.c
+++ /dev/null
@@ -1,196 +0,0 @@
-#include <stdio.h>
-#include <string.h>
-#include <unistd.h>
-#include <stdlib.h>
-#include <alsa/asoundlib.h>
-
-#include <opus.h>
-
-#include "core.h"
-#include "util.h"
-
-ECPContext ctx_c;
-ECPSocket sock_c;
-ECPConnHandler handler_c;
-
-ECPNode node;
-ECPConnection conn;
-int open_done = 0;
-
-snd_pcm_t *handle_plb;
-snd_pcm_t *handle_cpt;
-OpusEncoder *opus_enc;
-OpusDecoder *opus_dec;
-// 2.5, 5, 10, 20, 40 or 60 ms
-snd_pcm_uframes_t alsa_frames = 160;
-unsigned char *alsa_out_buf = NULL;
-unsigned char *alsa_in_buf = NULL;
-
-#define CTYPE_TEST 0
-#define MTYPE_MSG 8
-
-int a_open(char *dev_name, snd_pcm_t **handle, snd_pcm_hw_params_t **hw_params, snd_pcm_stream_t stream, snd_pcm_format_t format, unsigned int *nchannels, unsigned int *sample_rate, snd_pcm_uframes_t *frames, size_t *buf_size) {
- int bits, err = 0;
- unsigned int fragments = 2;
- unsigned int frame_size;
-
- err = snd_pcm_open(handle, dev_name, stream, 0);
- if (!err) err = snd_pcm_hw_params_malloc(hw_params);
- if (!err) err = snd_pcm_hw_params_any(*handle, *hw_params);
- if (!err) err = snd_pcm_hw_params_set_access(*handle, *hw_params, SND_PCM_ACCESS_RW_INTERLEAVED);
- if (!err) err = snd_pcm_hw_params_set_format(*handle, *hw_params, format);
- if (!err) err = snd_pcm_hw_params_set_rate_near(*handle, *hw_params, sample_rate, 0);
- if (!err) err = snd_pcm_hw_params_set_channels_near(*handle, *hw_params, nchannels);
- if (!err) err = snd_pcm_hw_params_set_periods_near(*handle, *hw_params, &fragments, 0);
- if (!err) err = snd_pcm_hw_params_set_period_size_near(*handle, *hw_params, frames, 0);
- if (!err) err = snd_pcm_hw_params(*handle, *hw_params);
- if (err) return err;
-
- bits = snd_pcm_hw_params_get_sbits(*hw_params);
- if (bits < 0) return bits;
-
- frame_size = *nchannels * (bits / 8);
- *buf_size = frame_size * *frames;
-
- return ECP_OK;
-}
-
-int a_prepare(snd_pcm_t *handle, snd_pcm_hw_params_t *hw_params, unsigned char *buf, snd_pcm_uframes_t frames) {
- snd_pcm_drop(handle);
- snd_pcm_prepare(handle);
-
- if (snd_pcm_stream(handle) == SND_PCM_STREAM_PLAYBACK) {
- int i, err;
- unsigned int fragments;
-
- err = snd_pcm_hw_params_get_periods(hw_params, &fragments, NULL);
- if (err) return err;
-
- for (i=0; i<fragments; i++) snd_pcm_writei(handle, buf, frames);
- }
- return ECP_OK;
-}
-
-opus_int32 a_read(snd_pcm_t *handle, unsigned char *buf, snd_pcm_uframes_t frames, OpusEncoder *enc, unsigned char *opus_buf, opus_int32 opus_size) {
- snd_pcm_sframes_t frames_in;
-
- while ((frames_in = snd_pcm_readi(handle, buf, frames)) < 0) {
- if (frames_in == -EAGAIN)
- continue;
- snd_pcm_prepare(handle);
- }
- return opus_encode(enc, (opus_int16 *)buf, frames_in, opus_buf, opus_size);
-}
-
-snd_pcm_sframes_t a_write(OpusDecoder *dec, unsigned char *opus_buf, opus_int32 opus_size, snd_pcm_t *handle, unsigned char *buf, snd_pcm_uframes_t frames) {
- snd_pcm_sframes_t frames_in, frames_out;
-
- frames_in = opus_decode(dec, opus_buf, opus_size, (opus_int16 *)buf, frames, 0);
- while ((frames_out = snd_pcm_writei(handle, buf, frames_in)) < 0) {
- if (frames_out == -EAGAIN)
- continue;
- snd_pcm_prepare(handle);
- }
- return frames_out;
-}
-
-int a_init(void) {
- char *dev_name = "hw:1,0";
- unsigned int nchannels = 1;
- unsigned int sample_rate = 16000;
-
- snd_pcm_hw_params_t *hw_params_plb;
- snd_pcm_hw_params_t *hw_params_cpt;
- size_t buf_size;
-
- a_open(dev_name, &handle_plb, &hw_params_plb, SND_PCM_STREAM_PLAYBACK, SND_PCM_FORMAT_S16_LE, &nchannels, &sample_rate, &alsa_frames, &buf_size);
- alsa_out_buf = malloc(buf_size);
- memset(alsa_out_buf, 0, buf_size);
- a_prepare(handle_plb, hw_params_plb, alsa_out_buf, alsa_frames);
-
- a_open(dev_name, &handle_cpt, &hw_params_cpt, SND_PCM_STREAM_CAPTURE, SND_PCM_FORMAT_S16_LE, &nchannels, &sample_rate, &alsa_frames, &buf_size);
- alsa_in_buf = malloc(buf_size);
- memset(alsa_in_buf, 0, buf_size);
- a_prepare(handle_cpt, hw_params_cpt, alsa_in_buf, alsa_frames);
-
- int size;
- size = opus_encoder_get_size(nchannels);
- opus_enc = malloc(size);
- opus_encoder_init(opus_enc, sample_rate, nchannels, OPUS_APPLICATION_VOIP);
-
- size = opus_decoder_get_size(nchannels);
- opus_dec = malloc(size);
- opus_decoder_init(opus_dec, sample_rate, nchannels);
-
- return ECP_OK;
-}
-
-ssize_t handle_open_c(ECPConnection *conn, ecp_seq_t sq, unsigned char t, unsigned char *p, ssize_t s, ECP2Buffer *b) {
- uint32_t seq = 0;
-
- ecp_conn_handle_open(conn, sq, t, p, s, b);
- if (s < 0) {
- printf("OPEN ERR:%ld\n", s);
- return s;
- }
-
- a_init();
- open_done = 1;
- return s;
-}
-
-ssize_t handle_msg_c(ECPConnection *conn, ecp_seq_t sq, unsigned char t, unsigned char *p, ssize_t s, ECP2Buffer *b) {
- a_write(opus_dec, p, s, handle_plb, alsa_out_buf, alsa_frames);
- return s;
-}
-
-
-static void usage(char *arg) {
- fprintf(stderr, "Usage: %s <node.pub>\n", arg);
- exit(1);
-}
-
-int main(int argc, char *argv[]) {
- int rv;
-
- if (argc != 2) usage(argv[0]);
-
- rv = ecp_init(&ctx_c);
- printf("ecp_init RV:%d\n", rv);
-
- rv = ecp_conn_handler_init(&handler_c);
- handler_c.msg[ECP_MTYPE_OPEN] = handle_open_c;
- handler_c.msg[MTYPE_MSG] = handle_msg_c;
- ctx_c.handler[CTYPE_TEST] = &handler_c;
-
- rv = ecp_sock_init(&sock_c, &ctx_c, NULL);
- printf("ecp_sock_init RV:%d\n", rv);
-
- rv = ecp_sock_open(&sock_c, NULL);
- printf("ecp_sock_open RV:%d\n", rv);
-
- rv = ecp_start_receiver(&sock_c);
- printf("ecp_start_receiver RV:%d\n", rv);
-
- rv = ecp_util_node_load(&ctx_c, &node, argv[1]);
- printf("ecp_util_node_load RV:%d\n", rv);
-
- rv = ecp_conn_init(&conn, &sock_c, CTYPE_TEST);
- printf("ecp_conn_init RV:%d\n", rv);
-
- rv = ecp_conn_open(&conn, &node);
- printf("ecp_conn_open RV:%d\n", rv);
-
- while(!open_done) sleep(1);
-
- unsigned char payload[ECP_MAX_PLD];
- unsigned char *opus_buf;
-
- while(1) {
- ecp_pld_set_type(payload, MTYPE_MSG);
- opus_buf = ecp_pld_get_buf(payload, 0);
- opus_int32 len = a_read(handle_cpt, alsa_in_buf, alsa_frames, opus_enc, opus_buf, ECP_MAX_MSG);
- if (len < 0) continue;
- ssize_t _rv = ecp_pld_send(&conn, payload, len);
- }
-} \ No newline at end of file
generated by cgit v1.2.3 (git 2.25.1) at 2024-12-26 04:42:38 +0000