| /src/lib/libisns/ |
| isns.c | 60 struct isns_config_s *cfg_p; local in function:isns_init
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->pipe_fds[0]
129 struct isns_config_s *cfg_p; local in function:isns_add_servercon
192 struct isns_config_s *cfg_p; local in function:isns_init_reg_refresh
230 struct isns_config_s *cfg_p = (struct isns_config_s *)isns_handle; local in function:isns_stop
[all...] |
| isns_util.c | 52 isns_issue_cmd(struct isns_config_s *cfg_p, uint8_t cmd_type)
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,
69 return (int)isns_file_writev(cfg_p->pipe_fds[1], iov, 2);
74 isns_change_kevent_list(struct isns_config_s *cfg_p,
80 return kevent(cfg_p->kq, &evt, 1, NULL, 0, NULL);
87 struct isns_config_s *cfg_p; local in function:isns_new_config
90 cfg_p = (struct isns_config_s *)
92 if (cfg_p == NULL) {
96 cfg_p->kq = -1
[all...] |
| 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 in function:isns_task_send_pdu
320 struct isns_config_s *cfg_p; local in function:isns_task_init_socket_io
368 struct isns_config_s *cfg_p; local in function:isns_task_init_refresh
[all...] |
| isns_task.h | 72 struct isns_config_s *cfg_p; member in struct:isns_task_s
|
| 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
|
| isns_thread.c | 59 struct isns_config_s *cfg_p = (struct isns_config_s *)arg; local in function:isns_control_thread
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)
100 task_p = isns_taskq_remove(cfg_p);
102 if (cfg_p->sd_connected
[all...] |
