Cedric Roux
52cf61de97
Whenever the value T_BUFFER_MAX changes, the tracers had to be recompiled. The only reason why it was needed is because we used some fixed size buffers to read events. This commit removes this restriction. Also, with the basic simulator, this value T_BUFFER_MAX now comes with an #ifdef which would have required some special hackish-level tricks in the tracers, which is not good. Let's just allocate memory when needed.
114 lines
2.9 KiB
C
114 lines
2.9 KiB
C
#include <stdio.h>
|
|
#include <stdlib.h>
|
|
#include <string.h>
|
|
#include "utils.h"
|
|
#include "event.h"
|
|
#include "database.h"
|
|
#include "config.h"
|
|
#include "../T_defs.h"
|
|
|
|
void usage(void)
|
|
{
|
|
printf(
|
|
"options:\n"
|
|
" -d <database file> this option is mandatory\n"
|
|
" -ip <host> connect to given IP address (default %s)\n"
|
|
" -p <port> connect to given port (default %d)\n",
|
|
DEFAULT_REMOTE_IP,
|
|
DEFAULT_REMOTE_PORT
|
|
);
|
|
exit(1);
|
|
}
|
|
|
|
struct timespec time_sub(struct timespec a, struct timespec b)
|
|
{
|
|
struct timespec ret;
|
|
if (a.tv_nsec < b.tv_nsec) {
|
|
ret.tv_nsec = (int64_t)a.tv_nsec - (int64_t)b.tv_nsec + 1000000000;
|
|
ret.tv_sec = a.tv_sec - b.tv_sec - 1;
|
|
} else {
|
|
ret.tv_nsec = a.tv_nsec - b.tv_nsec;
|
|
ret.tv_sec = a.tv_sec - b.tv_sec;
|
|
}
|
|
return ret;
|
|
}
|
|
|
|
int main(int n, char **v)
|
|
{
|
|
char *database_filename = NULL;
|
|
void *database;
|
|
char *ip = DEFAULT_REMOTE_IP;
|
|
int port = DEFAULT_REMOTE_PORT;
|
|
int i;
|
|
char t;
|
|
int number_of_events;
|
|
int socket;
|
|
int *is_on;
|
|
int ev_fun;
|
|
int start_valid = 0;
|
|
struct timespec start_time, stop_time, delta_time;
|
|
|
|
for (i = 1; i < n; i++) {
|
|
if (!strcmp(v[i], "-h") || !strcmp(v[i], "--help")) usage();
|
|
if (!strcmp(v[i], "-d"))
|
|
{ if (i > n-2) usage(); database_filename = v[++i]; continue; }
|
|
if (!strcmp(v[i], "-ip")) { if (i > n-2) usage(); ip = v[++i]; continue; }
|
|
if (!strcmp(v[i], "-p"))
|
|
{ if (i > n-2) usage(); port = atoi(v[++i]); continue; }
|
|
usage();
|
|
}
|
|
|
|
if (database_filename == NULL) {
|
|
printf("ERROR: provide a database file (-d)\n");
|
|
exit(1);
|
|
}
|
|
|
|
database = parse_database(database_filename);
|
|
|
|
load_config_file(database_filename);
|
|
|
|
number_of_events = number_of_ids(database);
|
|
is_on = calloc(number_of_events, sizeof(int));
|
|
if (is_on == NULL) abort();
|
|
|
|
on_off(database, "VCD_FUNCTION_ENB_DLSCH_ULSCH_SCHEDULER", is_on, 1);
|
|
|
|
ev_fun = event_id_from_name(database,
|
|
"VCD_FUNCTION_ENB_DLSCH_ULSCH_SCHEDULER");
|
|
|
|
socket = connect_to(ip, port);
|
|
|
|
t = 1;
|
|
if (socket_send(socket, &t, 1) == -1 ||
|
|
socket_send(socket, &number_of_events, sizeof(int)) == -1 ||
|
|
socket_send(socket, is_on, number_of_events * sizeof(int)) == -1)
|
|
abort();
|
|
|
|
OBUF ebuf = { osize: 0, omaxsize: 0, obuf: NULL };
|
|
|
|
while (1) {
|
|
event e;
|
|
int on_off;
|
|
e = get_event(socket, &ebuf, database);
|
|
if (e.type == -1) break;
|
|
if (e.type != ev_fun)
|
|
{ printf("unhandled event %d\n", e.type); continue; }
|
|
on_off = e.e[0].i;
|
|
printf("yo %d\n", on_off);
|
|
if (on_off == 1) {
|
|
start_time = e.sending_time;
|
|
start_valid = 1;
|
|
continue;
|
|
}
|
|
if (on_off != 0) { printf("fatal!\n"); abort(); }
|
|
if (!start_valid) continue;
|
|
stop_time = e.sending_time;
|
|
delta_time = time_sub(stop_time, start_time);
|
|
fprintf(stderr, "%ld\n",
|
|
delta_time.tv_sec * 1000000000UL + delta_time.tv_nsec);
|
|
fflush(stderr);
|
|
}
|
|
|
|
return 0;
|
|
}
|