#include <iostream>
#include <semaphore.h>
#include <map>
#include <queue>
#include <set>
#include <cstring>
#include <sys/socket.h>
#include <arpa/inet.h>
#include "pcap_layer.h"
#include "wmp_config.h"
#include "core/include/frames.h"
#include "bridge.hh"
#include "basic_io.h"
#include "buffer_layer.h"
#include "marte_layer.h"
#include <cassert>
#include <cstdlib>
#include <algorithm>
#include <assert.h>
#include "misc.h"
#include "BoundedHash.h"
#include "shmem_layer.h"
#include "core/include/wmp_utils.h"
Go to the source code of this file.
Defines | |
#define | EXIT_KEY 1 |
Functions | |
void | buffer_layer_activate (bool activate) |
void | buffer_layer_clear () |
int | buffer_layer_init (int _st, int nnodes, char *iface) |
int | buffer_layer_sniff_packet (char *data, simData_Hdr &sdh, unsigned long long &time_us, std::set< int > &reached, std::map< int, robo_pose_t > &poses) |
void | buffer_layer_stop () |
void * | loop (void *v) |
int | wmpGetFrameHash (wmpFrame *p) |
Variables | |
bool | active = false |
static BoundedHash< int, pac, unsigned long long > | bh |
static bool | bl_keep_running = false |
static base_time_t | bt [33] |
static int | foreign_idx = 100 |
static std::vector< ts_key_t > | keyQueue |
static std::vector< int > | keyQueue2 |
int | lastPopped |
static pthread_mutex_t | mex |
static int | num_nodes |
static std::map< int, pac > | rxMap |
static std::map< int, pac > | rxMap2 |
static sem_t | rxsem |
sniff_func_t | sf |
sniff_func_t | sf2 |
static int | st |
static bool | synchronized |
#define EXIT_KEY 1 |
Definition at line 63 of file buffer_layer.cc.
void buffer_layer_activate | ( | bool | activate | ) |
Definition at line 90 of file buffer_layer.cc.
void buffer_layer_clear | ( | ) |
Definition at line 96 of file buffer_layer.cc.
int buffer_layer_init | ( | int | _st, |
int | nnodes, | ||
char * | iface | ||
) |
Definition at line 254 of file buffer_layer.cc.
int buffer_layer_sniff_packet | ( | char * | data, |
simData_Hdr & | sdh, | ||
unsigned long long & | time_us, | ||
std::set< int > & | reached, | ||
std::map< int, robo_pose_t > & | poses | ||
) |
Definition at line 104 of file buffer_layer.cc.
void buffer_layer_stop | ( | ) |
Definition at line 295 of file buffer_layer.cc.
void* loop | ( | void * | v | ) |
Definition at line 145 of file buffer_layer.cc.
int wmpGetFrameHash | ( | wmpFrame * | p | ) |
Definition at line 85 of file buffer_layer.cc.
bool active = false |
Definition at line 89 of file buffer_layer.cc.
BoundedHash<int, pac, unsigned long long> bh [static] |
Definition at line 67 of file buffer_layer.cc.
bool bl_keep_running = false [static] |
Definition at line 72 of file buffer_layer.cc.
base_time_t bt[33] [static] |
Definition at line 79 of file buffer_layer.cc.
int foreign_idx = 100 [static] |
Definition at line 77 of file buffer_layer.cc.
Definition at line 66 of file buffer_layer.cc.
std::vector<int> keyQueue2 [static] |
Definition at line 69 of file buffer_layer.cc.
int lastPopped |
Definition at line 95 of file buffer_layer.cc.
pthread_mutex_t mex [static] |
Definition at line 71 of file buffer_layer.cc.
int num_nodes [static] |
Definition at line 75 of file buffer_layer.cc.
Definition at line 65 of file buffer_layer.cc.
Definition at line 68 of file buffer_layer.cc.
sem_t rxsem [static] |
Definition at line 70 of file buffer_layer.cc.
Definition at line 251 of file buffer_layer.cc.
Definition at line 252 of file buffer_layer.cc.
int st [static] |
Definition at line 76 of file buffer_layer.cc.
bool synchronized [static] |
Definition at line 74 of file buffer_layer.cc.