Lines Matching refs:stream

47 int ParamServerCreate(ParamTaskPtr *stream, const ParamStreamInfo *streamInfo)  in ParamServerCreate()  argument
49 PARAM_CHECK(stream != NULL && streamInfo != NULL, return -1, "Invalid param"); in ParamServerCreate()
56 return LE_CreateStreamServer(LE_GetDefaultLoop(), stream, &info); in ParamServerCreate()
59 int ParamStreamCreate(ParamTaskPtr *stream, ParamTaskPtr server, in ParamStreamCreate() argument
62 PARAM_CHECK(stream != NULL && streamInfo != NULL, return -1, "Invalid stream"); in ParamStreamCreate()
76 LE_STATUS status = LE_AcceptStreamClient(LE_GetDefaultLoop(), server, stream, &info); in ParamStreamCreate()
81 void *ParamGetTaskUserData(const ParamTaskPtr stream) in ParamGetTaskUserData() argument
83 PARAM_CHECK(stream != NULL, return NULL, "Invalid stream"); in ParamGetTaskUserData()
84 return LE_GetUserData(stream); in ParamGetTaskUserData()
87 int ParamTaskSendMsg(const ParamTaskPtr stream, const ParamMessage *msg) in ParamTaskSendMsg() argument
90 PARAM_CHECK(stream != NULL, free((void *)msg); in ParamTaskSendMsg()
100 return LE_Send(LE_GetDefaultLoop(), stream, bufferHandle, dataSize); in ParamTaskSendMsg()
103 int ParamEventTaskCreate(ParamTaskPtr *stream, LE_ProcessAsyncEvent eventProcess) in ParamEventTaskCreate() argument
105 PARAM_CHECK(stream != NULL && eventProcess != NULL, return -1, "Invalid info or stream"); in ParamEventTaskCreate()
106 return LE_CreateAsyncTask(LE_GetDefaultLoop(), stream, eventProcess); in ParamEventTaskCreate()
109 int ParamEventSend(const ParamTaskPtr stream, uint64_t eventId, const char *content, uint32_t size) in ParamEventSend() argument
111 PARAM_CHECK(stream != NULL, return -1, "Invalid stream"); in ParamEventSend()
113 return LE_StartAsyncEvent(LE_GetDefaultLoop(), stream, eventId, (const uint8_t *)content, size); in ParamEventSend()
116 int ParamTaskClose(const ParamTaskPtr stream) in ParamTaskClose() argument
118 PARAM_CHECK(stream != NULL, return -1, "Invalid param"); in ParamTaskClose()
119 LE_CloseTask(LE_GetDefaultLoop(), stream); in ParamTaskClose()