| /netbsd-current/lib/libisns/ |
| H A D | isns_util.c | 52 isns_issue_cmd(struct isns_config_s *cfg_p, uint8_t cmd_type) argument
54 return (int)write(cfg_p->pipe_fds[1], &cmd_type, 1);
59 isns_issue_cmd_with_data(struct isns_config_s *cfg_p, uint8_t cmd_type, argument
69 return (int)isns_file_writev(cfg_p->pipe_fds[1], iov, 2);
74 isns_change_kevent_list(struct isns_config_s *cfg_p, argument
80 return kevent(cfg_p->kq, &evt, 1, NULL, 0, NULL);
87 struct isns_config_s *cfg_p; local
90 cfg_p = (struct isns_config_s *)
92 if (cfg_p == NULL) {
96 cfg_p
137 isns_destroy_config(struct isns_config_s *cfg_p) argument
185 isns_thread_create(struct isns_config_s *cfg_p) argument
225 isns_thread_destroy(struct isns_config_s *cfg_p) argument
249 isns_process_connection_loss(struct isns_config_s *cfg_p) argument
[all...] |
| H A D | isns.c | 60 struct isns_config_s *cfg_p; local
65 if ((cfg_p = isns_new_config()) == NULL) {
70 cfg_p->is_server = is_server;
71 cfg_p->curtask_p = NULL;
73 if ((rval = pipe(cfg_p->pipe_fds)) != 0) {
75 isns_destroy_config(cfg_p);
79 if ((cfg_p->kq = kqueue()) == -1) {
81 isns_destroy_config(cfg_p);
85 rval = isns_change_kevent_list(cfg_p, (uintptr_t)cfg_p
129 struct isns_config_s *cfg_p; local
192 struct isns_config_s *cfg_p; local
230 struct isns_config_s *cfg_p = (struct isns_config_s *)isns_handle; local
[all...] |
| H A D | isns_task.c | 116 if (task_p == task_p->cfg_p->curtask_p)
117 task_p->cfg_p->curtask_p = NULL;
150 rv = isns_socket_create(&(task_p->cfg_p->sd), ai_p->ai_family,
155 rv = isns_socket_connect(task_p->cfg_p->sd, ai_p->ai_addr,
159 rv = isns_change_kevent_list(task_p->cfg_p,
167 task_p->cfg_p->sd_connected = 1;
169 /* Add cfg_p->sd to kqueue */
170 rv = isns_change_kevent_list(task_p->cfg_p,
171 (uintptr_t)(task_p->cfg_p->sd), EVFILT_READ,
197 struct isns_config_s *cfg_p; local
320 struct isns_config_s *cfg_p; local
368 struct isns_config_s *cfg_p; local
400 isns_new_task(struct isns_config_s *cfg_p, uint8_t task_type, int waitable) argument
459 isns_taskq_insert_head(struct isns_config_s *cfg_p, struct isns_task_s *task_p) argument
471 isns_taskq_insert_tail(struct isns_config_s *cfg_p, struct isns_task_s *task_p) argument
483 isns_taskq_remove(struct isns_config_s *cfg_p) argument
499 isns_taskq_remove_trans(struct isns_config_s *cfg_p, uint16_t trans_id) argument
[all...] |
| H A D | isns_thread.c | 59 struct isns_config_s *cfg_p = (struct isns_config_s *)arg; local
70 while ((cfg_p->curtask_p == NULL)
71 && ((cfg_p->curtask_p = isns_get_next_task(cfg_p)) != NULL))
72 isns_run_task(cfg_p->curtask_p);
74 nevents = kevent(cfg_p->kq, NULL, 0, evt_chgs,
82 run_thread = (evt_handler_p(evt_p, cfg_p) == 0);
93 isns_get_next_task(struct isns_config_s *cfg_p) argument
100 task_p = isns_taskq_remove(cfg_p);
102 if (cfg_p
125 isns_kevent_pipe(struct kevent* evt_p, struct isns_config_s *cfg_p) argument
230 isns_process_in_pdu(struct isns_config_s *cfg_p) argument
259 isns_kevent_socket(struct kevent *evt_p, struct isns_config_s *cfg_p) argument
463 isns_kevent_timer_recon(struct kevent *evt_p, struct isns_config_s *cfg_p) argument
508 isns_kevent_timer_refresh(struct kevent* evt_p, struct isns_config_s *cfg_p) argument
[all...] |
| H A D | isns_task.h | 72 struct isns_config_s *cfg_p; member in struct:isns_task_s
|
| H A D | isns_pdu.c | 382 trans_p->cfg_p = (struct isns_config_s *)isns_handle;
404 if (trans_p->cfg_p->is_server)
409 pdu_p = isns_new_pdu(trans_p->cfg_p, trans_p->id, func_id, pdu_flags);
499 if (!isns_is_socket_init_done(trans_p->cfg_p)) {
546 isns_abort_trans(struct isns_config_s *cfg_p, uint16_t trans_id) argument
551 if (((task_p = cfg_p->curtask_p) != NULL)
560 task_p = isns_taskq_remove_trans(cfg_p, trans_id);
720 pthread_mutex_lock(&trans_p->cfg_p->trans_mutex);
723 pthread_mutex_unlock(&trans_p->cfg_p->trans_mutex);
774 isns_new_pdu(struct isns_config_s *cfg_p, uint16_ argument
879 isns_init_pdu(struct isns_buffer_s *buf_p, struct isns_config_s *cfg_p, uint16_t trans_id, uint16_t func_id, uint16_t flags) argument
[all...] |
| H A D | isns_pdu.h | 163 struct isns_config_s *cfg_p; member in struct:isns_trans_s
183 struct isns_config_s *cfg_p; member in struct:isns_pdu_s
|