dataPacketStore.h 671 Bytes
Newer Older
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
#include <stdint.h>
#include <stdbool.h>
#include <bits/pthreadtypes.h>

#ifndef PRRT_DATAPACKETSTORE_H
#define PRRT_DATAPACKETSTORE_H

typedef struct prrtDataPacketStore {
    pthread_mutex_t lock;
    BPTreeNode* dataStore;
} PrrtDataPacketStore;

PrrtDataPacketStore* PrrtDataPacketStore_create(void);
uint32_t PrrtDataPacketStore_size(PrrtDataPacketStore* store);
void PrrtDataPacketStore_remove_range(PrrtDataPacketStore *store, List *res, prrtSequenceNumber_t start, prrtSequenceNumber_t stop);
bool PrrtDataPacketStore_destroy(PrrtDataPacketStore* store);
bool PrrtDataStore_insert(PrrtDataPacketStore *store, PrrtPacket *packet);

#endif //PRRT_DATAPACKETSTORE_H