quentin/tor_multipath_voip
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

Also speed up naive algorithm!

Browse source
This commit is contained in:
Quentin 2019-05-06 15:03:53 +02:00
parent df4e56775d
commit 9c606c2162
2 changed files with 4 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
src/algo_dup2.c
View file

@ -45,7 +45,6 @@ int algo_dup2_on_stream(struct evt_core_ctx* ctx, struct evt_core_fdinfo* fdinfo
}
int algo_dup2_on_datagram(struct evt_core_ctx* ctx, struct evt_core_fdinfo* fdinfo, struct buffer_packet* bp) {
char* url[] = { "tcp:write:127.0.0.1:7500", "tcp:write:127.0.0.1:7501" };
struct evt_core_fdinfo *to_fdinfo = NULL;
struct algo_ctx* app_ctx = fdinfo->cat->app_ctx;
@ -59,7 +58,7 @@ int algo_dup2_on_datagram(struct evt_core_ctx* ctx, struct evt_core_fdinfo* fdin
// 1. A whole packet has been read, we will find someone to write it
to_fdinfo = g_array_index(cat->socklist, struct evt_core_fdinfo*, i);
if (to_fdinfo == NULL) {
fprintf(stderr, "No fd for URL %s in udp-read.\n", url[i]);
fprintf(stderr, "No fd for cat %s in udp-read.\n", cat->name);
continue;
}

7
src/algo_naive.c
View file

@ -27,15 +27,14 @@ int algo_naive_on_stream(struct evt_core_ctx* ctx, struct evt_core_fdinfo* fdinf
}
int algo_naive_on_datagram(struct evt_core_ctx* ctx, struct evt_core_fdinfo* fdinfo, struct buffer_packet* bp) {
char url[256];
struct evt_core_fdinfo *to_fdinfo = NULL;
struct algo_ctx* app_ctx = fdinfo->cat->app_ctx;
// 1. A whole packet has been read, we will find someone to write it
sprintf(url, "tcp:write:127.0.0.1:7500");
to_fdinfo = evt_core_get_from_url (ctx, url);
struct evt_core_cat* cat = evt_core_get_from_cat (ctx, "tcp-write");
to_fdinfo = g_array_index(cat->socklist, struct evt_core_fdinfo*, 0);
if (to_fdinfo == NULL) {
fprintf(stderr, "No fd for URL %s in udp-read. Dropping packet :( \n", url);
fprintf(stderr, "No fd for cat %s in udp-read. Dropping packet :( \n", cat->name);
mv_buffer_wtof (app_ctx, fdinfo);
return 1;
}