| /src/lib/libisns/ |
| isns.c | 130 struct isns_task_s *task_p; local in function:isns_add_servercon
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 in function:isns_init_reg_refresh
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 in function:isns_destroy_config
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 in function:isns_new_task
485 struct isns_task_s *task_p = NULL; local in function:isns_taskq_remove
501 struct isns_task_s *task_p; local in function:isns_taskq_remove_trans
[all...] |
| isns_thread.c | 95 struct isns_task_s *task_p = NULL; local in function:isns_get_next_task
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 in function:isns_abort_trans
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 in function:isns_send_pdu
[all...] |
