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

Lines Matching defs:info
202     TaskHandle *taskHandle, const LE_StreamServerInfo *info)

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

205     LE_CHECK(info->server != NULL, return LE_INVALID_PARAM, "Invalid parameters server");

206     LE_CHECK(info->incommingConnect != NULL, return LE_INVALID_PARAM,

207         "Invalid parameters incommingConnect %s", info->server);

209     int fd = info->socketId;

211     if (info->socketId <= 0) {

212         fd = CreateSocket(info->baseInfo.flags, info->server);

213         LE_CHECK(fd > 0, return LE_FAILURE, "Failed to create socket %s", info->server);

215         ret = listenSocket(fd, info->baseInfo.flags, info->server);

216         LE_CHECK(ret == 0, return LE_FAILURE, "Failed to listen socket %s", info->server);

220     StreamServerTask *task = (StreamServerTask *)CreateTask(loopHandle, fd, &info->baseInfo,

221         sizeof(StreamServerTask) + strlen(info->server) + 1);

227     task->incommingConnect = info->incommingConnect;

229     ret = memcpy_s(task->server, strlen(info->server) + 1, info->server, strlen(info->server) + 1);

230     LE_CHECK(ret == 0, return LE_FAILURE, "Failed to copy server name %s", info->server);

236     TaskHandle *taskHandle, const LE_StreamInfo *info)

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

239     LE_CHECK(info->recvMessage != NULL, return LE_FAILURE, "Invalid parameters recvMessage %s", info->server);

241     int fd = CreateSocket(info->baseInfo.flags, info->server);

242     LE_CHECK(fd > 0, return LE_FAILURE, "Failed to create socket %s", info->server);

244     StreamClientTask *task = (StreamClientTask *)CreateTask(loopHandle, fd, &info->baseInfo, sizeof(StreamClientTask));

252     task->connectComplete = info->connectComplete;

253     task->sendMessageComplete = info->sendMessageComplete;

254     task->recvMessage = info->recvMessage;

255     task->disConnectComplete = info->disConnectComplete;

256     task->handleRecvMsg = info->handleRecvMsg;

264     TaskHandle *taskHandle, const LE_StreamInfo *info)

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

268     LE_CHECK(info->recvMessage != NULL, return LE_INVALID_PARAM, "Invalid parameters recvMessage");

270     if ((info->baseInfo.flags & TASK_TEST) != TASK_TEST) {

271         fd = AcceptSocket(GetSocketFd(server), info->baseInfo.flags);

275         loopHandle, fd, &info->baseInfo, sizeof(StreamConnectTask));

281     task->disConnectComplete = info->disConnectComplete;

282     task->sendMessageComplete = info->sendMessageComplete;

283     task->recvMessage = info->recvMessage;

285     task->handleRecvMsg = info->handleRecvMsg;

288     if ((info->baseInfo.flags & TASK_TEST) != TASK_TEST) {