HomeSort by: relevance | last modified time | path
    Searched defs:task_p (Results 1 - 5 of 5) sorted by relevancy

  /src/lib/libisns/
isns.c 130 struct isns_task_s *task_p; local
174 task_p = isns_new_task(cfg_p, ISNS_TASK_INIT_SOCKET_IO, 1);
175 task_p->var.init_socket_io.sd = fd;
176 task_p->var.init_socket_io.ai_p = ai_p;
178 isns_taskq_insert_head(cfg_p, task_p);
180 isns_wait_task(task_p, NULL);
193 struct isns_task_s *task_p; local
201 task_p = isns_new_task(cfg_p, ISNS_TASK_INIT_REFRESH, 0);
202 if (task_p == NULL)
208 isns_free_task(task_p);
    [all...]
isns_util.c 139 struct isns_task_s *task_p; local
156 if ((task_p = cfg_p->curtask_p) != NULL) {
157 if (task_p->task_type == ISNS_TASK_SEND_PDU)
158 isns_complete_trans(task_p->var.send_pdu.trans_p);
159 isns_free_task(task_p);
162 while ((task_p = isns_taskq_remove(cfg_p)) != NULL) {
163 if (task_p->task_type == ISNS_TASK_SEND_PDU)
164 isns_complete_trans(task_p->var.send_pdu.trans_p);
165 isns_free_task(task_p);
isns_task.c 57 isns_run_task(struct isns_task_s *task_p)
67 DBG("isns_run_task: task_type=%d\n", task_p->task_type);
69 if (task_p->task_type < ARRAY_ELEMS(task_dispatch_table))
70 task_dispatch_table[task_p->task_type](task_p);
72 DBG("isns_run_task: unknown task type=%d\n", task_p->task_type);
77 isns_wait_task(struct isns_task_s *task_p, const struct timespec *timeout_p)
83 DBG("isns_wait_task: waitable=%d\n", task_p->waitable);
85 if (!task_p->waitable)
88 pthread_mutex_lock(&task_p->wait_mutex)
403 struct isns_task_s *task_p; local
485 struct isns_task_s *task_p = NULL; local
501 struct isns_task_s *task_p; local
    [all...]
isns_thread.c 95 struct isns_task_s *task_p = NULL; local
100 task_p = isns_taskq_remove(cfg_p);
103 return task_p;
105 if (task_p == NULL)
108 if (task_p->task_type != ISNS_TASK_INIT_SOCKET_IO) {
109 isns_taskq_insert_head(cfg_p, task_p);
111 task_p = isns_new_task(cfg_p,
113 task_p->var.reconnect_server.ai_p = cfg_p->ai_p;
116 return task_p;
isns_pdu.c 548 struct isns_task_s *task_p; local
551 if (((task_p = cfg_p->curtask_p) != NULL)
552 && (task_p->task_type == ISNS_TASK_SEND_PDU)
553 && (task_p->var.send_pdu.trans_p->id == trans_id)) {
554 isns_complete_trans(task_p->var.send_pdu.trans_p);
555 isns_end_task(task_p);
560 task_p = isns_taskq_remove_trans(cfg_p, trans_id);
561 if (task_p) {
562 isns_complete_trans(task_p->var.send_pdu.trans_p);
563 isns_end_task(task_p);
831 struct isns_task_s* task_p; local
    [all...]

Completed in 63 milliseconds