12345678910111213141516171819202122232425262728293031323334353637383940414243444546 |
- #ifndef __INGEST_HPP__
- #define __INGEST_HPP__
- struct ClientList {
- uint32_t num;
- uint32_t start;
- uint32_t end;
- sgx_aes_gcm_128bit_key_t *keys;
- };
- class Ingestion{
- private:
- ClientList clients;
- MsgBuffer buffer;
- uint32_t max_buffer_size;
- public:
- Ingestion() {
- }
- void generateClientKeys(sgx_aes_gcm_128bit_key_t &ESK);
- void initialize(uint32_t cnum, uint32_t cstart, sgx_aes_gcm_128bit_key_t &ESK);
- uint32_t getClientNum() {
- return (clients.num);
- }
- uint32_t getClientStart() {
- return (clients.start);
- }
- sgx_aes_gcm_128bit_key_t* getClientKeys() {
- return (clients.keys);
- }
- bool processMsgBundle(clientid_t cid, unsigned char *msgbundle,
- uint32_t num_msgs);
- };
- extern Ingestion g_ing;
- #endif
|