1*4882a593Smuzhiyun /*
2*4882a593Smuzhiyun * Copyright 2017 Rockchip Electronics Co. LTD
3*4882a593Smuzhiyun *
4*4882a593Smuzhiyun * Licensed under the Apache License, Version 2.0 (the "License");
5*4882a593Smuzhiyun * you may not use this file except in compliance with the License.
6*4882a593Smuzhiyun * You may obtain a copy of the License at
7*4882a593Smuzhiyun *
8*4882a593Smuzhiyun * http://www.apache.org/licenses/LICENSE-2.0
9*4882a593Smuzhiyun *
10*4882a593Smuzhiyun * Unless required by applicable law or agreed to in writing, software
11*4882a593Smuzhiyun * distributed under the License is distributed on an "AS IS" BASIS,
12*4882a593Smuzhiyun * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13*4882a593Smuzhiyun * See the License for the specific language governing permissions and
14*4882a593Smuzhiyun * limitations under the License.
15*4882a593Smuzhiyun */
16*4882a593Smuzhiyun
17*4882a593Smuzhiyun #include "mpp_err.h"
18*4882a593Smuzhiyun #include "mpp_queue.h"
19*4882a593Smuzhiyun
MppQueue(node_destructor func)20*4882a593Smuzhiyun MppQueue::MppQueue(node_destructor func)
21*4882a593Smuzhiyun : mpp_list(func), mFlushFlag(0)
22*4882a593Smuzhiyun {
23*4882a593Smuzhiyun sem_init(&mQueuePending, 0, 0);
24*4882a593Smuzhiyun }
25*4882a593Smuzhiyun
~MppQueue()26*4882a593Smuzhiyun MppQueue::~MppQueue()
27*4882a593Smuzhiyun {
28*4882a593Smuzhiyun sem_destroy (&mQueuePending);
29*4882a593Smuzhiyun }
30*4882a593Smuzhiyun
push(void * data,RK_S32 size)31*4882a593Smuzhiyun RK_S32 MppQueue::push(void *data, RK_S32 size)
32*4882a593Smuzhiyun {
33*4882a593Smuzhiyun RK_S32 ret = 0;
34*4882a593Smuzhiyun
35*4882a593Smuzhiyun ret = mpp_list::add_at_tail(data, size);
36*4882a593Smuzhiyun mFlushFlag = 0;
37*4882a593Smuzhiyun sem_post(&mQueuePending);
38*4882a593Smuzhiyun
39*4882a593Smuzhiyun return ret;
40*4882a593Smuzhiyun }
41*4882a593Smuzhiyun
pull(void * data,RK_S32 size)42*4882a593Smuzhiyun RK_S32 MppQueue::pull(void *data, RK_S32 size)
43*4882a593Smuzhiyun {
44*4882a593Smuzhiyun if (!mFlushFlag)
45*4882a593Smuzhiyun sem_wait(&mQueuePending);
46*4882a593Smuzhiyun {
47*4882a593Smuzhiyun AutoMutex autoLock(mpp_list::mutex());
48*4882a593Smuzhiyun if (!mpp_list::list_size())
49*4882a593Smuzhiyun return MPP_NOK;
50*4882a593Smuzhiyun
51*4882a593Smuzhiyun return mpp_list::del_at_head(data, size);
52*4882a593Smuzhiyun }
53*4882a593Smuzhiyun return MPP_ERR_INIT;
54*4882a593Smuzhiyun }
55*4882a593Smuzhiyun
flush()56*4882a593Smuzhiyun RK_S32 MppQueue::flush()
57*4882a593Smuzhiyun {
58*4882a593Smuzhiyun if (mFlushFlag)
59*4882a593Smuzhiyun return 0;
60*4882a593Smuzhiyun
61*4882a593Smuzhiyun mFlushFlag = 1;
62*4882a593Smuzhiyun sem_post(&mQueuePending);
63*4882a593Smuzhiyun return mpp_list::flush();
64*4882a593Smuzhiyun }
65