le_streamtask.c - OpenGrok cross reference for /base/startup/init/services/loopevent/task/le

Lines Matching defs:taskHandle
26     const TaskHandle taskHandle, const LE_SendMessageComplete complete)

29     StreamTask *stream = (StreamTask *)taskHandle;

32         int ret = write(GetSocketFd(taskHandle), buffer->data, buffer->dataSize);

34             LE_LOGE("HandleSendMsg_ fd:%d send data size %d %d, err:%d", GetSocketFd(taskHandle),

37         LE_LOGV("HandleSendMsg_ fd:%d send data size %d %d", GetSocketFd(taskHandle), buffer->dataSize, ret);

40             complete(taskHandle, buffer);

46         LE_LOGV("HandleSendMsg_ fd:%d empty wait read", GetSocketFd(taskHandle));

47         loop->modEvent(loop, (const BaseTask *)taskHandle, EVENT_READ);

54     const TaskHandle taskHandle, const LE_RecvMessage recvMessage, const LE_HandleRecvMsg handleRecvMsg)

62             readLen = handleRecvMsg(taskHandle, buffer->data, LOOP_DEFAULT_BUFFER, 0);

64             readLen = recv(GetSocketFd(taskHandle), buffer->data, LOOP_DEFAULT_BUFFER, 0);

66         LE_LOGV("HandleRecvMsg fd:%d read msg len %d", GetSocketFd(taskHandle), readLen);

86         recvMessage(taskHandle, buffer->data, readLen);

137 static void HandleStreamTaskClose_(const LoopHandle loopHandle, const TaskHandle taskHandle)

139     BaseTask *task = (BaseTask *)taskHandle;

166     TaskHandle taskHandle = (TaskHandle)connectTask;

172     if (getsockopt(LE_GetSocketFd(taskHandle), SOL_SOCKET, SO_PEERCRED, &cred, &credSize) == 0) {

202     TaskHandle *taskHandle, const LE_StreamServerInfo *info)

204     LE_CHECK(loopHandle != NULL && taskHandle != NULL && info != NULL, return LE_INVALID_PARAM, "Invalid parameters");

231     *taskHandle = (TaskHandle)task;

236     TaskHandle *taskHandle, const LE_StreamInfo *info)

238     LE_CHECK(loopHandle != NULL && taskHandle != NULL && info != NULL, return LE_INVALID_PARAM, "Invalid parameters");

259     *taskHandle = (TaskHandle)task;

264     TaskHandle *taskHandle, const LE_StreamInfo *info)

267     LE_CHECK(server != NULL && taskHandle != NULL, return LE_INVALID_PARAM, "Invalid parameters");

292     *taskHandle = (TaskHandle)task;

296 void LE_CloseStreamTask(const LoopHandle loopHandle, const TaskHandle taskHandle)

298     LE_CHECK(loopHandle != NULL && taskHandle != NULL, return, "Invalid parameters");

299     LE_CloseTask(loopHandle, taskHandle);

302 int LE_GetSocketFd(const TaskHandle taskHandle)

304     LE_CHECK(taskHandle != NULL, return -1, "Invalid parameters");

305     return GetSocketFd(taskHandle);