1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
|
/*******************************************************************************
* Copyright (C) ST-Ericsson SA 2011
* License terms: 3-clause BSD license
******************************************************************************/
#ifndef _QUEUE_H_
#define _QUEUE_H_
#include "t_queue.h"
#include "error_codes.h"
#ifdef _WIN32
#include "WinApiWrappers.h"
#else
#include <stdio.h>
#include "LinuxApiWrappers.h"
#endif
#include "Logger.h"
class Queue
{
public:
Queue(void);
~Queue(void);
void Create(void **const Queue_pp, const uint32 MaxLength, void (*DestroyElement)(void *Element_p));
void Destroy(void **const Queue_pp);
ErrorCode_e Enqueue(void *const Queue_p, void *const Value_p);
void *Dequeue(void *const Queue_p);
QueueCallback_fn SetCallback(void *const Queue_p, const QueueCallbackType_e Type, const QueueCallback_fn Callback, void *const Param_p);
boolean IsEmpty(const void *const Queue_p);
boolean IsMember(const void *const Queue_p, void *Value_p, boolean(*Match)(void *Value1_p, void *Value2_p));
int GetNrOfElements(const void *const Queue_p);
//Reentrant
void RCreate(void **const Queue_pp, const uint32 MaxLength, void (*DestroyElement)(void *Element_p));
void RDestroy(void **const Queue_pp);
ErrorCode_e REnqueue(void *const Queue_p, void *const Value_p);
void *RDequeue(void *const Queue_p);
QueueCallback_fn RSetCallback(void *const Queue_p, const QueueCallbackType_e Type, const QueueCallback_fn Callback, void *const Param_p);
boolean RIsEmpty(const void *const Queue_p);
boolean RIsMember(const void *const Queue_p, void *Value_p, boolean(*Match)(void *Value1_p, void *Value2_p));
int RGetNrOfElements(const void *const Queue_p);
void SetLogger(Logger *logger) {
logger_ = logger;
}
private:
CCriticalSectionObject QueueCSO;
Logger *logger_;
void PrintF(const char *text, void *pVoid);
};
#endif // _QUEUE_H_
|
