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