Home
last modified time | relevance | path

Searched refs:StreamTask (Results 1 – 5 of 5) sorted by relevance

/base/startup/init/services/loopevent/task/
Dle_task.h92 } StreamTask; typedef
95 StreamTask stream;
103 StreamTask stream;
113 StreamTask stream;
124 LE_Buffer *GetNextBuffer(StreamTask *task, const LE_Buffer *next);
125 LE_Buffer *GetFirstBuffer(StreamTask *task);
126 int IsBufferEmpty(StreamTask *task);
128 void FreeBuffer(const LoopHandle loop, StreamTask *task, LE_Buffer *buffer);
129 void AddBuffer(StreamTask *task, LE_Buffer *buffer);
Dle_task.c62 StreamTask *stream = (StreamTask *)task; in CloseTask()
86 int IsBufferEmpty(StreamTask *task) in IsBufferEmpty()
94 LE_Buffer *GetFirstBuffer(StreamTask *task) in GetFirstBuffer()
106 void AddBuffer(StreamTask *task, LE_Buffer *buffer) in AddBuffer()
113 LE_Buffer *GetNextBuffer(StreamTask *task, const LE_Buffer *next) in GetNextBuffer()
130 void FreeBuffer(const LoopHandle loop, StreamTask *task, LE_Buffer *buffer) in FreeBuffer()
153 FreeBuffer(loop, (StreamTask *)taskHandle, (LE_Buffer *)handle); in LE_FreeBuffer()
180 AddBuffer((StreamTask *)taskHandle, buffer); in LE_Send()
182 AddBuffer((StreamTask *)taskHandle, buffer); in LE_Send()
Dle_streamtask.c29 StreamTask *stream = (StreamTask *)taskHandle; in HandleSendMsg_()
Dle_asynctask.c33 StreamTask *task = &asyncTask->stream; in DoAsyncEvent_()
/base/startup/init/test/unittest/loopevent/
Dloopevent_unittest.cpp161 AddBuffer((StreamTask *)client, buffer); in LeTaskTest()
170 EXPECT_EQ(GetNextBuffer((StreamTask *)client, next), nullptr); in LeTaskTest()