Blame winpr/include/winpr/collections.h

Packit Service fa4841
/**
Packit Service fa4841
 * WinPR: Windows Portable Runtime
Packit Service fa4841
 * Collections
Packit Service fa4841
 *
Packit Service fa4841
 * Copyright 2012 Marc-Andre Moreau <marcandre.moreau@gmail.com>
Packit Service fa4841
 *
Packit Service fa4841
 * Licensed under the Apache License, Version 2.0 (the "License");
Packit Service fa4841
 * you may not use this file except in compliance with the License.
Packit Service fa4841
 * You may obtain a copy of the License at
Packit Service fa4841
 *
Packit Service fa4841
 *     http://www.apache.org/licenses/LICENSE-2.0
Packit Service fa4841
 *
Packit Service fa4841
 * Unless required by applicable law or agreed to in writing, software
Packit Service fa4841
 * distributed under the License is distributed on an "AS IS" BASIS,
Packit Service fa4841
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
Packit Service fa4841
 * See the License for the specific language governing permissions and
Packit Service fa4841
 * limitations under the License.
Packit Service fa4841
 */
Packit Service fa4841
Packit Service fa4841
#ifndef WINPR_COLLECTIONS_H
Packit Service fa4841
#define WINPR_COLLECTIONS_H
Packit Service fa4841
Packit Service fa4841
#include <stdio.h>
Packit Service fa4841
#include <stdlib.h>
Packit Service fa4841
#include <string.h>
Packit Service fa4841
Packit Service fa4841
#include <winpr/winpr.h>
Packit Service fa4841
#include <winpr/wtypes.h>
Packit Service fa4841
Packit Service fa4841
#include <winpr/crt.h>
Packit Service fa4841
#include <winpr/synch.h>
Packit Service fa4841
#include <winpr/stream.h>
Packit Service fa4841
Packit Service fa4841
#ifdef __cplusplus
Packit Service b1ea74
extern "C"
Packit Service b1ea74
{
Packit Service fa4841
#endif
Packit Service fa4841
Packit Service b1ea74
	typedef void* (*OBJECT_NEW_FN)(void* val);
Packit Service b1ea74
	typedef void (*OBJECT_INIT_FN)(void* obj);
Packit Service b1ea74
	typedef void (*OBJECT_UNINIT_FN)(void* obj);
Packit Service b1ea74
	typedef void (*OBJECT_FREE_FN)(void* obj);
Packit Service b1ea74
	typedef BOOL (*OBJECT_EQUALS_FN)(const void* objA, const void* objB);
Packit Service fa4841
Packit Service b1ea74
	struct _wObject
Packit Service b1ea74
	{
Packit Service b1ea74
		OBJECT_NEW_FN fnObjectNew;
Packit Service b1ea74
		OBJECT_INIT_FN fnObjectInit;
Packit Service b1ea74
		OBJECT_UNINIT_FN fnObjectUninit;
Packit Service b1ea74
		OBJECT_FREE_FN fnObjectFree;
Packit Service b1ea74
		OBJECT_EQUALS_FN fnObjectEquals;
Packit Service b1ea74
	};
Packit Service b1ea74
	typedef struct _wObject wObject;
Packit Service fa4841
Packit Service b1ea74
	/* System.Collections.Queue */
Packit Service fa4841
Packit Service b1ea74
	struct _wQueue
Packit Service b1ea74
	{
Packit Service b1ea74
		int capacity;
Packit Service b1ea74
		int growthFactor;
Packit Service b1ea74
		BOOL synchronized;
Packit Service fa4841
Packit Service b1ea74
		int head;
Packit Service b1ea74
		int tail;
Packit Service b1ea74
		int size;
Packit Service b1ea74
		void** array;
Packit Service b1ea74
		CRITICAL_SECTION lock;
Packit Service b1ea74
		HANDLE event;
Packit Service fa4841
Packit Service b1ea74
		wObject object;
Packit Service b1ea74
	};
Packit Service b1ea74
	typedef struct _wQueue wQueue;
Packit Service fa4841
Packit Service b1ea74
	WINPR_API int Queue_Count(wQueue* queue);
Packit Service fa4841
Packit Service b1ea74
	WINPR_API void Queue_Lock(wQueue* queue);
Packit Service b1ea74
	WINPR_API void Queue_Unlock(wQueue* queue);
Packit Service fa4841
Packit Service b1ea74
	WINPR_API HANDLE Queue_Event(wQueue* queue);
Packit Service fa4841
Packit Service b1ea74
#define Queue_Object(_queue) (&_queue->object)
Packit Service fa4841
Packit Service b1ea74
	WINPR_API void Queue_Clear(wQueue* queue);
Packit Service fa4841
Packit Service b1ea74
	WINPR_API BOOL Queue_Contains(wQueue* queue, void* obj);
Packit Service fa4841
Packit Service b1ea74
	WINPR_API BOOL Queue_Enqueue(wQueue* queue, void* obj);
Packit Service b1ea74
	WINPR_API void* Queue_Dequeue(wQueue* queue);
Packit Service fa4841
Packit Service b1ea74
	WINPR_API void* Queue_Peek(wQueue* queue);
Packit Service fa4841
Packit Service b1ea74
	WINPR_API wQueue* Queue_New(BOOL synchronized, int capacity, int growthFactor);
Packit Service b1ea74
	WINPR_API void Queue_Free(wQueue* queue);
Packit Service fa4841
Packit Service b1ea74
	/* System.Collections.Stack */
Packit Service fa4841
Packit Service b1ea74
	struct _wStack
Packit Service b1ea74
	{
Packit Service b1ea74
		int size;
Packit Service b1ea74
		int capacity;
Packit Service b1ea74
		void** array;
Packit Service b1ea74
		CRITICAL_SECTION lock;
Packit Service b1ea74
		BOOL synchronized;
Packit Service b1ea74
		wObject object;
Packit Service b1ea74
	};
Packit Service b1ea74
	typedef struct _wStack wStack;
Packit Service fa4841
Packit Service b1ea74
	WINPR_API int Stack_Count(wStack* stack);
Packit Service b1ea74
	WINPR_API BOOL Stack_IsSynchronized(wStack* stack);
Packit Service fa4841
Packit Service b1ea74
#define Stack_Object(_stack) (&_stack->object)
Packit Service fa4841
Packit Service b1ea74
	WINPR_API void Stack_Clear(wStack* stack);
Packit Service b1ea74
	WINPR_API BOOL Stack_Contains(wStack* stack, void* obj);
Packit Service fa4841
Packit Service b1ea74
	WINPR_API void Stack_Push(wStack* stack, void* obj);
Packit Service b1ea74
	WINPR_API void* Stack_Pop(wStack* stack);
Packit Service fa4841
Packit Service b1ea74
	WINPR_API void* Stack_Peek(wStack* stack);
Packit Service fa4841
Packit Service b1ea74
	WINPR_API wStack* Stack_New(BOOL synchronized);
Packit Service b1ea74
	WINPR_API void Stack_Free(wStack* stack);
Packit Service fa4841
Packit Service b1ea74
	/* System.Collections.ArrayList */
Packit Service fa4841
Packit Service b1ea74
	struct _wArrayList
Packit Service b1ea74
	{
Packit Service b1ea74
		int capacity;
Packit Service b1ea74
		int growthFactor;
Packit Service b1ea74
		BOOL synchronized;
Packit Service fa4841
Packit Service b1ea74
		int size;
Packit Service b1ea74
		void** array;
Packit Service b1ea74
		CRITICAL_SECTION lock;
Packit Service fa4841
Packit Service b1ea74
		wObject object;
Packit Service b1ea74
	};
Packit Service b1ea74
	typedef struct _wArrayList wArrayList;
Packit Service fa4841
Packit Service b1ea74
	WINPR_API int ArrayList_Capacity(wArrayList* arrayList);
Packit Service b1ea74
	WINPR_API int ArrayList_Count(wArrayList* arrayList);
Packit Service b1ea74
	WINPR_API int ArrayList_Items(wArrayList* arrayList, ULONG_PTR** ppItems);
Packit Service b1ea74
	WINPR_API BOOL ArrayList_IsFixedSized(wArrayList* arrayList);
Packit Service b1ea74
	WINPR_API BOOL ArrayList_IsReadOnly(wArrayList* arrayList);
Packit Service b1ea74
	WINPR_API BOOL ArrayList_IsSynchronized(wArrayList* arrayList);
Packit Service fa4841
Packit Service b1ea74
	WINPR_API void ArrayList_Lock(wArrayList* arrayList);
Packit Service b1ea74
	WINPR_API void ArrayList_Unlock(wArrayList* arrayList);
Packit Service fa4841
Packit Service b1ea74
	WINPR_API void* ArrayList_GetItem(wArrayList* arrayList, int index);
Packit Service b1ea74
	WINPR_API void ArrayList_SetItem(wArrayList* arrayList, int index, void* obj);
Packit Service fa4841
Packit Service b1ea74
#define ArrayList_Object(_arrayList) (&_arrayList->object)
Packit Service fa4841
Packit Service b1ea74
#define ArrayList_ForEach(_lst, _type, index, value)                                       \
Packit Service b1ea74
	for (index = 0;                                                                        \
Packit Service b1ea74
	     index < ArrayList_Count(_lst) && (value = (_type)ArrayList_GetItem(_lst, index)); \
Packit Service b1ea74
	     index++)
Packit Service fa4841
Packit Service b1ea74
	WINPR_API void ArrayList_Clear(wArrayList* arrayList);
Packit Service b1ea74
	WINPR_API BOOL ArrayList_Contains(wArrayList* arrayList, void* obj);
Packit Service fa4841
Packit Service b1ea74
	WINPR_API int ArrayList_Add(wArrayList* arrayList, void* obj);
Packit Service b1ea74
	WINPR_API BOOL ArrayList_Insert(wArrayList* arrayList, int index, void* obj);
Packit Service fa4841
Packit Service b1ea74
	WINPR_API BOOL ArrayList_Remove(wArrayList* arrayList, void* obj);
Packit Service b1ea74
	WINPR_API BOOL ArrayList_RemoveAt(wArrayList* arrayList, int index);
Packit Service fa4841
Packit Service b1ea74
	WINPR_API int ArrayList_IndexOf(wArrayList* arrayList, void* obj, int startIndex, int count);
Packit Service b1ea74
	WINPR_API int ArrayList_LastIndexOf(wArrayList* arrayList, void* obj, int startIndex,
Packit Service b1ea74
	                                    int count);
Packit Service fa4841
Packit Service b1ea74
	WINPR_API wArrayList* ArrayList_New(BOOL synchronized);
Packit Service b1ea74
	WINPR_API void ArrayList_Free(wArrayList* arrayList);
Packit Service fa4841
Packit Service b1ea74
	/* System.Collections.DictionaryBase */
Packit Service fa4841
Packit Service b1ea74
	struct _wDictionary
Packit Service b1ea74
	{
Packit Service b1ea74
		BOOL synchronized;
Packit Service b1ea74
		CRITICAL_SECTION lock;
Packit Service b1ea74
	};
Packit Service b1ea74
	typedef struct _wDictionary wDictionary;
Packit Service fa4841
Packit Service b1ea74
	/* System.Collections.Specialized.ListDictionary */
Packit Service fa4841
Packit Service b1ea74
	typedef struct _wListDictionaryItem wListDictionaryItem;
Packit Service fa4841
Packit Service b1ea74
	struct _wListDictionaryItem
Packit Service b1ea74
	{
Packit Service b1ea74
		void* key;
Packit Service b1ea74
		void* value;
Packit Service fa4841
Packit Service b1ea74
		wListDictionaryItem* next;
Packit Service b1ea74
	};
Packit Service fa4841
Packit Service b1ea74
	struct _wListDictionary
Packit Service b1ea74
	{
Packit Service b1ea74
		BOOL synchronized;
Packit Service b1ea74
		CRITICAL_SECTION lock;
Packit Service fa4841
Packit Service b1ea74
		wListDictionaryItem* head;
Packit Service b1ea74
		wObject objectKey;
Packit Service b1ea74
		wObject objectValue;
Packit Service b1ea74
	};
Packit Service b1ea74
	typedef struct _wListDictionary wListDictionary;
Packit Service fa4841
Packit Service b1ea74
#define ListDictionary_KeyObject(_dictionary) (&_dictionary->objectKey)
Packit Service b1ea74
#define ListDictionary_ValueObject(_dictionary) (&_dictionary->objectValue)
Packit Service fa4841
Packit Service b1ea74
	WINPR_API int ListDictionary_Count(wListDictionary* listDictionary);
Packit Service fa4841
Packit Service b1ea74
	WINPR_API void ListDictionary_Lock(wListDictionary* listDictionary);
Packit Service b1ea74
	WINPR_API void ListDictionary_Unlock(wListDictionary* listDictionary);
Packit Service fa4841
Packit Service b1ea74
	WINPR_API BOOL ListDictionary_Add(wListDictionary* listDictionary, const void* key,
Packit Service b1ea74
	                                  void* value);
Packit Service b1ea74
	WINPR_API void* ListDictionary_Remove(wListDictionary* listDictionary, const void* key);
Packit Service b1ea74
	WINPR_API void* ListDictionary_Remove_Head(wListDictionary* listDictionary);
Packit Service b1ea74
	WINPR_API void ListDictionary_Clear(wListDictionary* listDictionary);
Packit Service fa4841
Packit Service b1ea74
	WINPR_API BOOL ListDictionary_Contains(wListDictionary* listDictionary, const void* key);
Packit Service b1ea74
	WINPR_API int ListDictionary_GetKeys(wListDictionary* listDictionary, ULONG_PTR** ppKeys);
Packit Service fa4841
Packit Service b1ea74
	WINPR_API void* ListDictionary_GetItemValue(wListDictionary* listDictionary, const void* key);
Packit Service b1ea74
	WINPR_API BOOL ListDictionary_SetItemValue(wListDictionary* listDictionary, const void* key,
Packit Service b1ea74
	                                           void* value);
Packit Service fa4841
Packit Service b1ea74
	WINPR_API wListDictionary* ListDictionary_New(BOOL synchronized);
Packit Service b1ea74
	WINPR_API void ListDictionary_Free(wListDictionary* listDictionary);
Packit Service fa4841
Packit Service b1ea74
	/* System.Collections.Generic.LinkedList<T> */
Packit Service fa4841
Packit Service b1ea74
	typedef struct _wLinkedList wLinkedList;
Packit Service fa4841
Packit Service b1ea74
	WINPR_API int LinkedList_Count(wLinkedList* list);
Packit Service b1ea74
	WINPR_API void* LinkedList_First(wLinkedList* list);
Packit Service b1ea74
	WINPR_API void* LinkedList_Last(wLinkedList* list);
Packit Service fa4841
Packit Service b1ea74
	WINPR_API BOOL LinkedList_Contains(wLinkedList* list, void* value);
Packit Service b1ea74
	WINPR_API void LinkedList_Clear(wLinkedList* list);
Packit Service fa4841
Packit Service b1ea74
	WINPR_API BOOL LinkedList_AddFirst(wLinkedList* list, void* value);
Packit Service b1ea74
	WINPR_API BOOL LinkedList_AddLast(wLinkedList* list, void* value);
Packit Service fa4841
Packit Service b1ea74
	WINPR_API BOOL LinkedList_Remove(wLinkedList* list, void* value);
Packit Service b1ea74
	WINPR_API void LinkedList_RemoveFirst(wLinkedList* list);
Packit Service b1ea74
	WINPR_API void LinkedList_RemoveLast(wLinkedList* list);
Packit Service fa4841
Packit Service b1ea74
	WINPR_API void LinkedList_Enumerator_Reset(wLinkedList* list);
Packit Service b1ea74
	WINPR_API void* LinkedList_Enumerator_Current(wLinkedList* list);
Packit Service b1ea74
	WINPR_API BOOL LinkedList_Enumerator_MoveNext(wLinkedList* list);
Packit Service fa4841
Packit Service b1ea74
	WINPR_API wLinkedList* LinkedList_New(void);
Packit Service b1ea74
	WINPR_API void LinkedList_Free(wLinkedList* list);
Packit Service fa4841
Packit Service b1ea74
	WINPR_API wObject* LinkedList_Object(wLinkedList* list);
Packit Service fa4841
Packit Service b1ea74
	/* System.Collections.Generic.KeyValuePair<TKey,TValue> */
Packit Service fa4841
Packit Service b1ea74
	typedef struct _wKeyValuePair wKeyValuePair;
Packit Service fa4841
Packit Service b1ea74
	struct _wKeyValuePair
Packit Service b1ea74
	{
Packit Service b1ea74
		void* key;
Packit Service b1ea74
		void* value;
Packit Service fa4841
Packit Service b1ea74
		wKeyValuePair* next;
Packit Service b1ea74
	};
Packit Service fa4841
Packit Service b1ea74
	/* Reference Table */
Packit Service fa4841
Packit Service b1ea74
	struct _wReference
Packit Service b1ea74
	{
Packit Service b1ea74
		UINT32 Count;
Packit Service b1ea74
		void* Pointer;
Packit Service b1ea74
	};
Packit Service b1ea74
	typedef struct _wReference wReference;
Packit Service fa4841
Packit Service b1ea74
	typedef int (*REFERENCE_FREE)(void* context, void* ptr);
Packit Service fa4841
Packit Service b1ea74
	struct _wReferenceTable
Packit Service b1ea74
	{
Packit Service b1ea74
		UINT32 size;
Packit Service b1ea74
		CRITICAL_SECTION lock;
Packit Service b1ea74
		void* context;
Packit Service b1ea74
		BOOL synchronized;
Packit Service b1ea74
		wReference* array;
Packit Service b1ea74
		REFERENCE_FREE ReferenceFree;
Packit Service b1ea74
	};
Packit Service b1ea74
	typedef struct _wReferenceTable wReferenceTable;
Packit Service fa4841
Packit Service b1ea74
	WINPR_API UINT32 ReferenceTable_Add(wReferenceTable* referenceTable, void* ptr);
Packit Service b1ea74
	WINPR_API UINT32 ReferenceTable_Release(wReferenceTable* referenceTable, void* ptr);
Packit Service fa4841
Packit Service b1ea74
	WINPR_API wReferenceTable* ReferenceTable_New(BOOL synchronized, void* context,
Packit Service b1ea74
	                                              REFERENCE_FREE ReferenceFree);
Packit Service b1ea74
	WINPR_API void ReferenceTable_Free(wReferenceTable* referenceTable);
Packit Service fa4841
Packit Service b1ea74
	/* Countdown Event */
Packit Service fa4841
Packit Service b1ea74
	struct _wCountdownEvent
Packit Service b1ea74
	{
Packit Service b1ea74
		DWORD count;
Packit Service b1ea74
		CRITICAL_SECTION lock;
Packit Service b1ea74
		HANDLE event;
Packit Service b1ea74
		DWORD initialCount;
Packit Service b1ea74
	};
Packit Service b1ea74
	typedef struct _wCountdownEvent wCountdownEvent;
Packit Service fa4841
Packit Service b1ea74
	WINPR_API DWORD CountdownEvent_CurrentCount(wCountdownEvent* countdown);
Packit Service b1ea74
	WINPR_API DWORD CountdownEvent_InitialCount(wCountdownEvent* countdown);
Packit Service b1ea74
	WINPR_API BOOL CountdownEvent_IsSet(wCountdownEvent* countdown);
Packit Service b1ea74
	WINPR_API HANDLE CountdownEvent_WaitHandle(wCountdownEvent* countdown);
Packit Service fa4841
Packit Service b1ea74
	WINPR_API void CountdownEvent_AddCount(wCountdownEvent* countdown, DWORD signalCount);
Packit Service b1ea74
	WINPR_API BOOL CountdownEvent_Signal(wCountdownEvent* countdown, DWORD signalCount);
Packit Service b1ea74
	WINPR_API void CountdownEvent_Reset(wCountdownEvent* countdown, DWORD count);
Packit Service fa4841
Packit Service b1ea74
	WINPR_API wCountdownEvent* CountdownEvent_New(DWORD initialCount);
Packit Service b1ea74
	WINPR_API void CountdownEvent_Free(wCountdownEvent* countdown);
Packit Service fa4841
Packit Service b1ea74
	/* Hash Table */
Packit Service fa4841
Packit Service b1ea74
	typedef UINT32 (*HASH_TABLE_HASH_FN)(void* key);
Packit Service b1ea74
	typedef BOOL (*HASH_TABLE_KEY_COMPARE_FN)(void* key1, void* key2);
Packit Service b1ea74
	typedef BOOL (*HASH_TABLE_VALUE_COMPARE_FN)(void* value1, void* value2);
Packit Service b1ea74
	typedef void* (*HASH_TABLE_KEY_CLONE_FN)(void* key);
Packit Service b1ea74
	typedef void* (*HASH_TABLE_VALUE_CLONE_FN)(void* value);
Packit Service b1ea74
	typedef void (*HASH_TABLE_KEY_FREE_FN)(void* key);
Packit Service b1ea74
	typedef void (*HASH_TABLE_VALUE_FREE_FN)(void* value);
Packit Service fa4841
Packit Service b1ea74
	struct _wHashTable
Packit Service b1ea74
	{
Packit Service b1ea74
		BOOL synchronized;
Packit Service b1ea74
		CRITICAL_SECTION lock;
Packit Service fa4841
Packit Service b1ea74
		int numOfBuckets;
Packit Service b1ea74
		int numOfElements;
Packit Service b1ea74
		float idealRatio;
Packit Service b1ea74
		float lowerRehashThreshold;
Packit Service b1ea74
		float upperRehashThreshold;
Packit Service b1ea74
		wKeyValuePair** bucketArray;
Packit Service b1ea74
Packit Service b1ea74
		HASH_TABLE_HASH_FN hash;
Packit Service b1ea74
		HASH_TABLE_KEY_COMPARE_FN keyCompare;
Packit Service b1ea74
		HASH_TABLE_VALUE_COMPARE_FN valueCompare;
Packit Service b1ea74
		HASH_TABLE_KEY_CLONE_FN keyClone;
Packit Service b1ea74
		HASH_TABLE_VALUE_CLONE_FN valueClone;
Packit Service b1ea74
		HASH_TABLE_KEY_FREE_FN keyFree;
Packit Service b1ea74
		HASH_TABLE_VALUE_FREE_FN valueFree;
Packit Service b1ea74
	};
Packit Service b1ea74
	typedef struct _wHashTable wHashTable;
Packit Service fa4841
Packit Service b1ea74
	WINPR_API int HashTable_Count(wHashTable* table);
Packit Service b1ea74
	WINPR_API int HashTable_Add(wHashTable* table, void* key, void* value);
Packit Service b1ea74
	WINPR_API BOOL HashTable_Remove(wHashTable* table, void* key);
Packit Service b1ea74
	WINPR_API void HashTable_Clear(wHashTable* table);
Packit Service b1ea74
	WINPR_API BOOL HashTable_Contains(wHashTable* table, void* key);
Packit Service b1ea74
	WINPR_API BOOL HashTable_ContainsKey(wHashTable* table, void* key);
Packit Service b1ea74
	WINPR_API BOOL HashTable_ContainsValue(wHashTable* table, void* value);
Packit Service b1ea74
	WINPR_API void* HashTable_GetItemValue(wHashTable* table, void* key);
Packit Service b1ea74
	WINPR_API BOOL HashTable_SetItemValue(wHashTable* table, void* key, void* value);
Packit Service b1ea74
	WINPR_API int HashTable_GetKeys(wHashTable* table, ULONG_PTR** ppKeys);
Packit Service fa4841
Packit Service b1ea74
	WINPR_API UINT32 HashTable_PointerHash(void* pointer);
Packit Service b1ea74
	WINPR_API BOOL HashTable_PointerCompare(void* pointer1, void* pointer2);
Packit Service fa4841
Packit Service b1ea74
	WINPR_API UINT32 HashTable_StringHash(void* key);
Packit Service b1ea74
	WINPR_API BOOL HashTable_StringCompare(void* string1, void* string2);
Packit Service b1ea74
	WINPR_API void* HashTable_StringClone(void* str);
Packit Service b1ea74
	WINPR_API void HashTable_StringFree(void* str);
Packit Service fa4841
Packit Service b1ea74
	WINPR_API wHashTable* HashTable_New(BOOL synchronized);
Packit Service b1ea74
	WINPR_API void HashTable_Free(wHashTable* table);
Packit Service fa4841
Packit Service b1ea74
	/* BufferPool */
Packit Service fa4841
Packit Service b1ea74
	struct _wBufferPoolItem
Packit Service b1ea74
	{
Packit Service b1ea74
		int size;
Packit Service b1ea74
		void* buffer;
Packit Service b1ea74
	};
Packit Service b1ea74
	typedef struct _wBufferPoolItem wBufferPoolItem;
Packit Service fa4841
Packit Service b1ea74
	struct _wBufferPool
Packit Service b1ea74
	{
Packit Service b1ea74
		int fixedSize;
Packit Service b1ea74
		DWORD alignment;
Packit Service b1ea74
		BOOL synchronized;
Packit Service b1ea74
		CRITICAL_SECTION lock;
Packit Service fa4841
Packit Service b1ea74
		int size;
Packit Service b1ea74
		int capacity;
Packit Service b1ea74
		void** array;
Packit Service fa4841
Packit Service b1ea74
		int aSize;
Packit Service b1ea74
		int aCapacity;
Packit Service b1ea74
		wBufferPoolItem* aArray;
Packit Service fa4841
Packit Service b1ea74
		int uSize;
Packit Service b1ea74
		int uCapacity;
Packit Service b1ea74
		wBufferPoolItem* uArray;
Packit Service b1ea74
	};
Packit Service b1ea74
	typedef struct _wBufferPool wBufferPool;
Packit Service fa4841
Packit Service b1ea74
	WINPR_API int BufferPool_GetPoolSize(wBufferPool* pool);
Packit Service b1ea74
	WINPR_API int BufferPool_GetBufferSize(wBufferPool* pool, void* buffer);
Packit Service fa4841
Packit Service b1ea74
	WINPR_API void* BufferPool_Take(wBufferPool* pool, int bufferSize);
Packit Service b1ea74
	WINPR_API BOOL BufferPool_Return(wBufferPool* pool, void* buffer);
Packit Service b1ea74
	WINPR_API void BufferPool_Clear(wBufferPool* pool);
Packit Service fa4841
Packit Service b1ea74
	WINPR_API wBufferPool* BufferPool_New(BOOL synchronized, int fixedSize, DWORD alignment);
Packit Service b1ea74
	WINPR_API void BufferPool_Free(wBufferPool* pool);
Packit Service fa4841
Packit Service b1ea74
	/* ObjectPool */
Packit Service fa4841
Packit Service b1ea74
	struct _wObjectPool
Packit Service b1ea74
	{
Packit Service b1ea74
		int size;
Packit Service b1ea74
		int capacity;
Packit Service b1ea74
		void** array;
Packit Service b1ea74
		CRITICAL_SECTION lock;
Packit Service b1ea74
		wObject object;
Packit Service b1ea74
		BOOL synchronized;
Packit Service b1ea74
	};
Packit Service b1ea74
	typedef struct _wObjectPool wObjectPool;
Packit Service fa4841
Packit Service b1ea74
	WINPR_API void* ObjectPool_Take(wObjectPool* pool);
Packit Service b1ea74
	WINPR_API void ObjectPool_Return(wObjectPool* pool, void* obj);
Packit Service b1ea74
	WINPR_API void ObjectPool_Clear(wObjectPool* pool);
Packit Service fa4841
Packit Service b1ea74
#define ObjectPool_Object(_pool) (&_pool->object)
Packit Service fa4841
Packit Service b1ea74
	WINPR_API wObjectPool* ObjectPool_New(BOOL synchronized);
Packit Service b1ea74
	WINPR_API void ObjectPool_Free(wObjectPool* pool);
Packit Service fa4841
Packit Service b1ea74
	/* Message Queue */
Packit Service fa4841
Packit Service b1ea74
	typedef struct _wMessage wMessage;
Packit Service fa4841
Packit Service b1ea74
	typedef void (*MESSAGE_FREE_FN)(wMessage* message);
Packit Service fa4841
Packit Service b1ea74
	struct _wMessage
Packit Service b1ea74
	{
Packit Service b1ea74
		UINT32 id;
Packit Service b1ea74
		void* context;
Packit Service b1ea74
		void* wParam;
Packit Service b1ea74
		void* lParam;
Packit Service b1ea74
		UINT64 time;
Packit Service b1ea74
		MESSAGE_FREE_FN Free;
Packit Service b1ea74
	};
Packit Service fa4841
Packit Service b1ea74
	struct _wMessageQueue
Packit Service b1ea74
	{
Packit Service b1ea74
		int head;
Packit Service b1ea74
		int tail;
Packit Service b1ea74
		int size;
Packit Service b1ea74
		int capacity;
Packit Service b1ea74
		wMessage* array;
Packit Service b1ea74
		CRITICAL_SECTION lock;
Packit Service b1ea74
		HANDLE event;
Packit Service fa4841
Packit Service b1ea74
		wObject object;
Packit Service b1ea74
	};
Packit Service b1ea74
	typedef struct _wMessageQueue wMessageQueue;
Packit Service b1ea74
Packit Service b1ea74
#define WMQ_QUIT 0xFFFFFFFF
Packit Service b1ea74
Packit Service b1ea74
	WINPR_API HANDLE MessageQueue_Event(wMessageQueue* queue);
Packit Service b1ea74
	WINPR_API BOOL MessageQueue_Wait(wMessageQueue* queue);
Packit Service b1ea74
	WINPR_API int MessageQueue_Size(wMessageQueue* queue);
Packit Service b1ea74
Packit Service b1ea74
	WINPR_API BOOL MessageQueue_Dispatch(wMessageQueue* queue, wMessage* message);
Packit Service b1ea74
	WINPR_API BOOL MessageQueue_Post(wMessageQueue* queue, void* context, UINT32 type, void* wParam,
Packit Service b1ea74
	                                 void* lParam);
Packit Service b1ea74
	WINPR_API BOOL MessageQueue_PostQuit(wMessageQueue* queue, int nExitCode);
Packit Service b1ea74
Packit Service b1ea74
	WINPR_API int MessageQueue_Get(wMessageQueue* queue, wMessage* message);
Packit Service b1ea74
	WINPR_API int MessageQueue_Peek(wMessageQueue* queue, wMessage* message, BOOL remove);
Packit Service b1ea74
Packit Service b1ea74
	/*! \brief Clears all elements in a message queue.
Packit Service b1ea74
	 *
Packit Service b1ea74
	 *  \note If dynamically allocated data is part of the messages,
Packit Service b1ea74
	 *        a custom cleanup handler must be passed in the 'callback'
Packit Service b1ea74
	 *        argument for MessageQueue_New.
Packit Service b1ea74
	 *
Packit Service b1ea74
	 *  \param queue The queue to clear.
Packit Service b1ea74
	 *
Packit Service b1ea74
	 *  \return 0 in case of success or a error code otherwise.
Packit Service b1ea74
	 */
Packit Service b1ea74
	WINPR_API int MessageQueue_Clear(wMessageQueue* queue);
Packit Service b1ea74
Packit Service b1ea74
	/*! \brief Creates a new message queue.
Packit Service b1ea74
	 * 				 If 'callback' is null, no custom cleanup will be done
Packit Service b1ea74
	 * 				 on message queue deallocation.
Packit Service b1ea74
	 * 				 If the 'callback' argument contains valid uninit or
Packit Service b1ea74
	 * 				 free functions those will be called by
Packit Service b1ea74
	 * 				 'MessageQueue_Clear'.
Packit Service b1ea74
	 *
Packit Service b1ea74
	 * \param callback a pointer to custom initialization / cleanup functions.
Packit Service b1ea74
	 * 								 Can be NULL if not used.
Packit Service b1ea74
	 *
Packit Service b1ea74
	 * \return A pointer to a newly allocated MessageQueue or NULL.
Packit Service b1ea74
	 */
Packit Service b1ea74
	WINPR_API wMessageQueue* MessageQueue_New(const wObject* callback);
Packit Service b1ea74
Packit Service b1ea74
	/*! \brief Frees resources allocated by a message queue.
Packit Service b1ea74
	 * 				 This function will only free resources allocated
Packit Service b1ea74
	 *				 internally.
Packit Service b1ea74
	 *
Packit Service b1ea74
	 * \note Empty the queue before calling this function with
Packit Service b1ea74
	 * 			 'MessageQueue_Clear', 'MessageQueue_Get' or
Packit Service b1ea74
	 * 			 'MessageQueue_Peek' to free all resources allocated
Packit Service b1ea74
	 * 			 by the message contained.
Packit Service b1ea74
	 *
Packit Service b1ea74
	 * \param queue A pointer to the queue to be freed.
Packit Service b1ea74
	 */
Packit Service b1ea74
	WINPR_API void MessageQueue_Free(wMessageQueue* queue);
Packit Service b1ea74
Packit Service b1ea74
	/* Message Pipe */
Packit Service b1ea74
Packit Service b1ea74
	struct _wMessagePipe
Packit Service b1ea74
	{
Packit Service b1ea74
		wMessageQueue* In;
Packit Service b1ea74
		wMessageQueue* Out;
Packit Service b1ea74
	};
Packit Service b1ea74
	typedef struct _wMessagePipe wMessagePipe;
Packit Service fa4841
Packit Service b1ea74
	WINPR_API void MessagePipe_PostQuit(wMessagePipe* pipe, int nExitCode);
Packit Service fa4841
Packit Service b1ea74
	WINPR_API wMessagePipe* MessagePipe_New(void);
Packit Service b1ea74
	WINPR_API void MessagePipe_Free(wMessagePipe* pipe);
Packit Service fa4841
Packit Service b1ea74
	/* Publisher/Subscriber Pattern */
Packit Service b1ea74
Packit Service b1ea74
	struct _wEventArgs
Packit Service b1ea74
	{
Packit Service b1ea74
		DWORD Size;
Packit Service b1ea74
		const char* Sender;
Packit Service b1ea74
	};
Packit Service b1ea74
	typedef struct _wEventArgs wEventArgs;
Packit Service fa4841
Packit Service b1ea74
	typedef void (*pEventHandler)(void* context, wEventArgs* e);
Packit Service fa4841
Packit Service b1ea74
#define MAX_EVENT_HANDLERS 32
Packit Service b1ea74
Packit Service b1ea74
	struct _wEventType
Packit Service b1ea74
	{
Packit Service b1ea74
		const char* EventName;
Packit Service b1ea74
		wEventArgs EventArgs;
Packit Service b1ea74
		int EventHandlerCount;
Packit Service b1ea74
		pEventHandler EventHandlers[MAX_EVENT_HANDLERS];
Packit Service b1ea74
	};
Packit Service b1ea74
	typedef struct _wEventType wEventType;
Packit Service b1ea74
Packit Service b1ea74
#define EventArgsInit(_event_args, _sender)                  \
Packit Service b1ea74
	memset(_event_args, 0, sizeof(*_event_args));            \
Packit Service b1ea74
	((wEventArgs*)_event_args)->Size = sizeof(*_event_args); \
Packit Service b1ea74
	((wEventArgs*)_event_args)->Sender = _sender
Packit Service b1ea74
Packit Service b1ea74
#define DEFINE_EVENT_HANDLER(_name) \
Packit Service b1ea74
	typedef void (*p##_name##EventHandler)(void* context, _name##EventArgs* e)
Packit Service b1ea74
Packit Service b1ea74
#define DEFINE_EVENT_RAISE(_name)                                                           \
Packit Service b1ea74
	static INLINE int PubSub_On##_name(wPubSub* pubSub, void* context, _name##EventArgs* e) \
Packit Service b1ea74
	{                                                                                       \
Packit Service b1ea74
		return PubSub_OnEvent(pubSub, #_name, context, (wEventArgs*)e);                     \
Packit Service b1ea74
	}
Packit Service b1ea74
Packit Service b1ea74
#define DEFINE_EVENT_SUBSCRIBE(_name)                                              \
Packit Service b1ea74
	static INLINE int PubSub_Subscribe##_name(wPubSub* pubSub,                     \
Packit Service b1ea74
	                                          p##_name##EventHandler EventHandler) \
Packit Service b1ea74
	{                                                                              \
Packit Service b1ea74
		return PubSub_Subscribe(pubSub, #_name, (pEventHandler)EventHandler);      \
Packit Service b1ea74
	}
Packit Service b1ea74
Packit Service b1ea74
#define DEFINE_EVENT_UNSUBSCRIBE(_name)                                              \
Packit Service b1ea74
	static INLINE int PubSub_Unsubscribe##_name(wPubSub* pubSub,                     \
Packit Service b1ea74
	                                            p##_name##EventHandler EventHandler) \
Packit Service b1ea74
	{                                                                                \
Packit Service b1ea74
		return PubSub_Unsubscribe(pubSub, #_name, (pEventHandler)EventHandler);      \
Packit Service b1ea74
	}
Packit Service b1ea74
Packit Service b1ea74
#define DEFINE_EVENT_BEGIN(_name)      \
Packit Service b1ea74
	typedef struct _##_name##EventArgs \
Packit Service b1ea74
	{                                  \
Packit Service fa4841
		wEventArgs e;
Packit Service fa4841
Packit Service b1ea74
#define DEFINE_EVENT_END(_name)   \
Packit Service b1ea74
	}                             \
Packit Service b1ea74
	_name##EventArgs;             \
Packit Service b1ea74
	DEFINE_EVENT_HANDLER(_name);  \
Packit Service b1ea74
	DEFINE_EVENT_RAISE(_name)     \
Packit Service fa4841
	DEFINE_EVENT_SUBSCRIBE(_name) \
Packit Service fa4841
	DEFINE_EVENT_UNSUBSCRIBE(_name)
Packit Service fa4841
Packit Service b1ea74
#define DEFINE_EVENT_ENTRY(_name) { #_name, { sizeof(_name##EventArgs), NULL }, 0, { NULL } },
Packit Service fa4841
Packit Service fa4841
	struct _wPubSub
Packit Service fa4841
	{
Packit Service fa4841
		CRITICAL_SECTION lock;
Packit Service fa4841
		BOOL synchronized;
Packit Service fa4841
Packit Service fa4841
		int size;
Packit Service fa4841
		int count;
Packit Service fa4841
		wEventType* events;
Packit Service fa4841
	};
Packit Service fa4841
	typedef struct _wPubSub wPubSub;
Packit Service fa4841
Packit Service fa4841
	WINPR_API void PubSub_Lock(wPubSub* pubSub);
Packit Service fa4841
	WINPR_API void PubSub_Unlock(wPubSub* pubSub);
Packit Service fa4841
Packit Service fa4841
	WINPR_API wEventType* PubSub_GetEventTypes(wPubSub* pubSub, int* count);
Packit Service fa4841
	WINPR_API void PubSub_AddEventTypes(wPubSub* pubSub, wEventType* events, int count);
Packit Service fa4841
	WINPR_API wEventType* PubSub_FindEventType(wPubSub* pubSub, const char* EventName);
Packit Service fa4841
Packit Service b1ea74
	WINPR_API int PubSub_Subscribe(wPubSub* pubSub, const char* EventName,
Packit Service b1ea74
	                               pEventHandler EventHandler);
Packit Service fa4841
	WINPR_API int PubSub_Unsubscribe(wPubSub* pubSub, const char* EventName,
Packit Service fa4841
	                                 pEventHandler EventHandler);
Packit Service fa4841
Packit Service b1ea74
	WINPR_API int PubSub_OnEvent(wPubSub* pubSub, const char* EventName, void* context,
Packit Service b1ea74
	                             wEventArgs* e);
Packit Service fa4841
Packit Service fa4841
	WINPR_API wPubSub* PubSub_New(BOOL synchronized);
Packit Service fa4841
	WINPR_API void PubSub_Free(wPubSub* pubSub);
Packit Service fa4841
Packit Service fa4841
	/* BipBuffer */
Packit Service fa4841
Packit Service fa4841
	struct _wBipBlock
Packit Service fa4841
	{
Packit Service fa4841
		size_t index;
Packit Service fa4841
		size_t size;
Packit Service fa4841
	};
Packit Service fa4841
	typedef struct _wBipBlock wBipBlock;
Packit Service fa4841
Packit Service fa4841
	struct _wBipBuffer
Packit Service fa4841
	{
Packit Service fa4841
		size_t size;
Packit Service fa4841
		BYTE* buffer;
Packit Service fa4841
		size_t pageSize;
Packit Service fa4841
		wBipBlock blockA;
Packit Service fa4841
		wBipBlock blockB;
Packit Service fa4841
		wBipBlock readR;
Packit Service fa4841
		wBipBlock writeR;
Packit Service fa4841
	};
Packit Service fa4841
	typedef struct _wBipBuffer wBipBuffer;
Packit Service fa4841
Packit Service fa4841
	WINPR_API BOOL BipBuffer_Grow(wBipBuffer* bb, size_t size);
Packit Service fa4841
	WINPR_API void BipBuffer_Clear(wBipBuffer* bb);
Packit Service fa4841
Packit Service fa4841
	WINPR_API size_t BipBuffer_UsedSize(wBipBuffer* bb);
Packit Service fa4841
	WINPR_API size_t BipBuffer_BufferSize(wBipBuffer* bb);
Packit Service fa4841
Packit Service fa4841
	WINPR_API BYTE* BipBuffer_WriteReserve(wBipBuffer* bb, size_t size);
Packit Service fa4841
	WINPR_API BYTE* BipBuffer_WriteTryReserve(wBipBuffer* bb, size_t size, size_t* reserved);
Packit Service fa4841
	WINPR_API void BipBuffer_WriteCommit(wBipBuffer* bb, size_t size);
Packit Service fa4841
Packit Service fa4841
	WINPR_API BYTE* BipBuffer_ReadReserve(wBipBuffer* bb, size_t size);
Packit Service fa4841
	WINPR_API BYTE* BipBuffer_ReadTryReserve(wBipBuffer* bb, size_t size, size_t* reserved);
Packit Service fa4841
	WINPR_API void BipBuffer_ReadCommit(wBipBuffer* bb, size_t size);
Packit Service fa4841
Packit Service b1ea74
	WINPR_API SSIZE_T BipBuffer_Read(wBipBuffer* bb, BYTE* data, size_t size);
Packit Service b1ea74
	WINPR_API SSIZE_T BipBuffer_Write(wBipBuffer* bb, const BYTE* data, size_t size);
Packit Service fa4841
Packit Service fa4841
	WINPR_API wBipBuffer* BipBuffer_New(size_t size);
Packit Service fa4841
	WINPR_API void BipBuffer_Free(wBipBuffer* bb);
Packit Service fa4841
Packit Service fa4841
#ifdef __cplusplus
Packit Service fa4841
}
Packit Service fa4841
#endif
Packit Service fa4841
Packit Service fa4841
#endif /* WINPR_COLLECTIONS_H */