#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.