mirror of
https://github.com/openharmony/drivers_framework.git
synced 2026-07-21 11:45:23 -04:00
zhang
54 lines
1.3 KiB
C
54 lines
1.3 KiB
C
/*
|
|
* Copyright (c) 2021-2021 Huawei Device Co., Ltd.
|
|
*
|
|
* HDF is dual licensed: you can use it either under the terms of
|
|
* the GPL, or the BSD license, at your option.
|
|
* See the LICENSE file in the root of this repository for complete details.
|
|
*/
|
|
|
|
#ifndef BLOCKING_QUEUE_H
|
|
#define BLOCKING_QUEUE_H
|
|
|
|
#include "hdf_slist.h"
|
|
#include "osal_sem.h"
|
|
#include "osal_mutex.h"
|
|
|
|
#ifdef __cplusplus
|
|
extern "C" {
|
|
#endif
|
|
|
|
struct HdfBlockingQueue {
|
|
struct HdfSList list;
|
|
struct OsalSem sem;
|
|
struct OsalMutex mutex;
|
|
};
|
|
|
|
struct HdfSListEntry {
|
|
struct HdfSListNode node;
|
|
void *data;
|
|
};
|
|
|
|
void HdfBlockingQueue_Init(struct HdfBlockingQueue *queue);
|
|
|
|
void HdfBlockingQueueDestroy(struct HdfBlockingQueue *queue);
|
|
|
|
void HdfBlockingQueueFlush(struct HdfBlockingQueue *queue);
|
|
|
|
void *HdfBlockingQueueTake(struct HdfBlockingQueue *queue);
|
|
|
|
void *HdfBlockingQueueGet(struct HdfBlockingQueue *queue);
|
|
|
|
void HdfBlockingQueueRemove(struct HdfBlockingQueue *queue, void *data);
|
|
|
|
void *HdfBlockingQueuePoll(struct HdfBlockingQueue *queue, long timeout);
|
|
|
|
void HdfBlockingQueueOffer(struct HdfBlockingQueue *queue, void *val);
|
|
|
|
void *HdfBlockingQueueFind(struct HdfBlockingQueue *queue, long match_key, SlList_Comparer comparer);
|
|
|
|
#ifdef __cplusplus
|
|
}
|
|
#endif /* __cplusplus */
|
|
|
|
#endif /* BLOCKING_QUEUE_H */
|