Lines Matching refs:stream
29 StreamTask *stream = (StreamTask *)taskHandle;
30 LE_Buffer *buffer = GetFirstBuffer(stream);
42 FreeBuffer(loopHandle, stream, buffer);
43 buffer = GetFirstBuffer(stream);
45 if (IsBufferEmpty(stream)) {
94 StreamConnectTask *stream = (StreamConnectTask *)handle;
99 status = HandleSendMsg_(loopHandle, handle, stream->sendMessageComplete);
102 status = HandleRecvMsg_(loopHandle, handle, stream->recvMessage, stream->handleRecvMsg);
105 if (stream->disConnectComplete) {
106 stream->disConnectComplete(handle);
167 printf("\tfd: %d \n", connectTask->stream.base.taskId.fd);
247 task->stream.base.handleEvent = HandleClientEvent_;
248 task->stream.base.innerClose = HandleStreamTaskClose_;
249 OH_ListInit(&task->stream.buffHead);
250 LoopMutexInit(&task->stream.mutex);
278 task->stream.base.handleEvent = HandleStreamEvent_;
279 task->stream.base.innerClose = HandleStreamTaskClose_;
280 task->stream.base.dumpTaskInfo = DumpStreamConnectTaskInfo_;
286 OH_ListInit(&task->stream.buffHead);
287 LoopMutexInit(&task->stream.mutex);