Lines Matching refs:cmd
81 /*cmd executes in socket poll thread */
260 //add the cmd fd for read & write
293 APPL_TRACE_ERROR("cmd socket is not created. socket thread may not initialized");
308 sock_cmd_t cmd = {CMD_ADD_FD, fd, type, flags, user_id};
310 return send(ts[h].cmd_fdw, &cmd, sizeof(cmd), 0) == sizeof(cmd);
321 APPL_TRACE_ERROR("cmd socket is not created. socket thread may not initialized");
324 sock_cmd_t cmd = {CMD_USER_PRIVATE, 0, type, size, user_id};
325 APPL_TRACE_DEBUG("post cmd type:%d, size:%d, h:%d, ", type, size, h);
326 sock_cmd_t* cmd_send = &cmd;
327 int size_send = sizeof(cmd);
330 size_send = sizeof(cmd) + size;
334 *cmd_send = cmd;
339 APPL_TRACE_ERROR("alloca failed at h:%d, cmd type:%d, size:%d", h, type, size_send);
354 APPL_TRACE_ERROR("thread handle:%d, cmd socket is not created", h);
357 sock_cmd_t cmd = {CMD_WAKEUP, 0, 0, 0, 0};
358 return send(ts[h].cmd_fdw, &cmd, sizeof(cmd), 0) == sizeof(cmd);
369 APPL_TRACE_ERROR("cmd socket is not created");
372 sock_cmd_t cmd = {CMD_EXIT, 0, 0, 0, 0};
373 if(send(ts[h].cmd_fdw, &cmd, sizeof(cmd), 0) == sizeof(cmd))
466 sock_cmd_t cmd = {-1, 0, 0, 0, 0};
468 if(recv(fd, &cmd, sizeof(cmd), MSG_WAITALL) != sizeof(cmd))
470 APPL_TRACE_ERROR("recv cmd errno:%d", errno);
473 APPL_TRACE_DEBUG("cmd.id:%d", cmd.id);
474 switch(cmd.id)
477 add_poll(h, cmd.fd, cmd.type, cmd.flags, cmd.user_id);
484 ts[h].cmd_callback(fd, cmd.type, cmd.flags, cmd.user_id);
489 APPL_TRACE_DEBUG("unknown cmd: %d", cmd.id);
572 if(pfds[0].revents) //cmd fd always is the first one
582 else ret--; //exclude the cmd fd
