WIP Measuring latency
This commit is contained in:
parent
afbb41fa2e
commit
0598bf8533
2 changed files with 40 additions and 4 deletions
|
@ -12,7 +12,7 @@ void free_char(void* c) {
|
|||
|
||||
void free_cat(void* vcat) {
|
||||
struct evt_core_cat* cat = (struct evt_core_cat*) vcat;
|
||||
cat->free_app_ctx(cat->app_ctx);
|
||||
if (cat->free_app_ctx != NULL) cat->free_app_ctx(cat->app_ctx);
|
||||
g_array_free(cat->socklist, TRUE);
|
||||
free(cat->name);
|
||||
free(cat);
|
||||
|
|
|
@ -1,13 +1,49 @@
|
|||
#include <stdlib.h>
|
||||
#include <stdio.h>
|
||||
#include "evt_core.h"
|
||||
#include "net_tools.h"
|
||||
|
||||
int main(void) {
|
||||
struct timer_ctx {
|
||||
uint64_t counter;
|
||||
};
|
||||
|
||||
void on_udp(struct evt_core_ctx* ctx, struct evt_core_cat* cat, int fd) {
|
||||
}
|
||||
|
||||
void on_timer(struct evt_core_ctx* ctx, struct evt_core_cat* cat, int fd) {
|
||||
}
|
||||
|
||||
int main(int argc, char** argv) {
|
||||
printf("~ measlat ~\n");
|
||||
if (argc < 3) exit(EXIT_FAILURE);
|
||||
|
||||
struct timer_ctx apptime = {0};
|
||||
struct evt_core_ctx evts = {0};
|
||||
struct evt_core_cat udp_read = {};
|
||||
struct evt_core_cat timer = {};
|
||||
struct evt_core_cat udp_read = {
|
||||
.app_ctx = NULL,
|
||||
.free_app_ctx = NULL,
|
||||
.cb = on_udp,
|
||||
.name = "udp-read",
|
||||
.flags = EPOLLIN | EPOLLET,
|
||||
.socklist = NULL
|
||||
};
|
||||
struct evt_core_cat timer = {
|
||||
.app_ctx = &apptime,
|
||||
.free_app_ctx = NULL,
|
||||
.cb = on_timer,
|
||||
.name = "timer",
|
||||
.flags = EPOLLIN | EPOLLET,
|
||||
.socklist = NULL
|
||||
};
|
||||
|
||||
evt_core_init(&evts);
|
||||
evt_core_add_cat (&evts, &udp_read);
|
||||
evt_core_add_cat(&evts, &timer);
|
||||
printf("--- Categories registered\n");
|
||||
|
||||
int udp_sock = create_udp_client (argv[1], argv[2]);
|
||||
evt_core_add_fd (&evts, "udp-read", udp_sock);
|
||||
|
||||
|
||||
return 0;
|
||||
}
|
||||
|
|
Loading…
Reference in a new issue