Lines Matching defs:cmd
80 /*cmd executes in socket poll thread */
278 //add the cmd fd for read & write
311 APPL_TRACE_ERROR("cmd socket is not created. socket thread may not initialized");
326 sock_cmd_t cmd = {CMD_ADD_FD, fd, type, flags, user_id};
328 return send(ts[h].cmd_fdw, &cmd, sizeof(cmd), 0) == sizeof(cmd);
344 sock_cmd_t cmd = {CMD_REMOVE_FD, fd, 0, 0, 0};
345 return send(ts[thread_handle].cmd_fdw, &cmd, sizeof(cmd), 0) == sizeof(cmd);
357 APPL_TRACE_ERROR("cmd socket is not created. socket thread may not initialized");
360 sock_cmd_t cmd = {CMD_USER_PRIVATE, 0, type, size, user_id};
361 APPL_TRACE_DEBUG("post cmd type:%d, size:%d, h:%d, ", type, size, h);
362 sock_cmd_t* cmd_send = &cmd;
363 int size_send = sizeof(cmd);
366 size_send = sizeof(cmd) + size;
370 *cmd_send = cmd;
375 APPL_TRACE_ERROR("alloca failed at h:%d, cmd type:%d, size:%d", h, type, size_send);
390 APPL_TRACE_ERROR("thread handle:%d, cmd socket is not created", h);
393 sock_cmd_t cmd = {CMD_WAKEUP, 0, 0, 0, 0};
394 return send(ts[h].cmd_fdw, &cmd, sizeof(cmd), 0) == sizeof(cmd);
405 APPL_TRACE_ERROR("cmd socket is not created");
408 sock_cmd_t cmd = {CMD_EXIT, 0, 0, 0, 0};
409 if(send(ts[h].cmd_fdw, &cmd, sizeof(cmd), 0) == sizeof(cmd))
502 sock_cmd_t cmd = {-1, 0, 0, 0, 0};
504 if(recv(fd, &cmd, sizeof(cmd), MSG_WAITALL) != sizeof(cmd))
506 APPL_TRACE_ERROR("recv cmd errno:%d", errno);
509 APPL_TRACE_DEBUG("cmd.id:%d", cmd.id);
510 switch(cmd.id)
513 add_poll(h, cmd.fd, cmd.type, cmd.flags, cmd.user_id);
519 if (poll_slot->pfd.fd == cmd.fd)
525 close(cmd.fd);
532 ts[h].cmd_callback(fd, cmd.type, cmd.flags, cmd.user_id);
537 APPL_TRACE_DEBUG("unknown cmd: %d", cmd.id);
620 if(pfds[0].revents) //cmd fd always is the first one
630 else ret--; //exclude the cmd fd
