xref: /netbsd-src/lib/libisns/isns.c (revision 39fd362275cc87d74a7c9cd13b3f6a7fe3217bd1)
1 /*	$NetBSD: isns.c,v 1.2 2019/10/08 19:38:27 christos Exp $	*/
2 
3 /*-
4  * Copyright (c) 2004,2009 The NetBSD Foundation, Inc.
5  * All rights reserved.
6  *
7  * This code is derived from software contributed to The NetBSD Foundation
8  * by Wasabi Systems, Inc.
9  *
10  * Redistribution and use in source and binary forms, with or without
11  * modification, are permitted provided that the following conditions
12  * are met:
13  * 1. Redistributions of source code must retain the above copyright
14  *    notice, this list of conditions and the following disclaimer.
15  * 2. Redistributions in binary form must reproduce the above copyright
16  *    notice, this list of conditions and the following disclaimer in the
17  *    documentation and/or other materials provided with the distribution.
18  *
19  * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
20  * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
21  * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
22  * PURPOSE ARE DISCLAIMED.  IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
23  * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
24  * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
25  * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
26  * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
27  * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
28  * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
29  * POSSIBILITY OF SUCH DAMAGE.
30  */
31 
32 #include <sys/cdefs.h>
33 __RCSID("$NetBSD: isns.c,v 1.2 2019/10/08 19:38:27 christos Exp $");
34 
35 /*
36  * isns.c
37  */
38 
39 #include <sys/types.h>
40 #include <sys/param.h>
41 #include <sys/uio.h>
42 #include <sys/poll.h>
43 
44 #include <errno.h>
45 #include <stdio.h>
46 #include <string.h>
47 #include <unistd.h>
48 
49 #include "isns.h"
50 #include "isns_config.h"
51 
52 
53 
54 /*
55  * isns_init()
56  */
57 int
isns_init(ISNS_HANDLE * isns_handle_p,int is_server)58 isns_init(ISNS_HANDLE *isns_handle_p, int is_server)
59 {
60 	struct isns_config_s *cfg_p;
61 	int rval;
62 
63 	*isns_handle_p = NULL;
64 
65 	if ((cfg_p = isns_new_config()) == NULL) {
66 		DBG("isns_init: error on isns_new_config()\n");
67 		return ENOMEM;
68 	}
69 
70 	cfg_p->is_server = is_server;
71 	cfg_p->curtask_p = NULL;
72 
73 	if ((rval = pipe(cfg_p->pipe_fds)) != 0) {
74 		DBG("isns_init: error on wepe_sys_pipe()\n");
75 		isns_destroy_config(cfg_p);
76 		return rval;
77 	}
78 
79 	if ((cfg_p->kq = kqueue()) == -1) {
80 		DBG("isns_init: error on kqueue()\n");
81 		isns_destroy_config(cfg_p);
82 		return -1;
83 	}
84 
85 	rval = isns_change_kevent_list(cfg_p, (uintptr_t)cfg_p->pipe_fds[0],
86 	    EVFILT_READ, EV_ADD | EV_ENABLE, (int64_t)0,
87 	    (intptr_t)isns_kevent_pipe);
88 	if (rval == -1) {
89 		DBG("isns_init: error on isns_change_kevent_list() "
90 		    "for isns_kevent_pipe\n");
91 		isns_destroy_config(cfg_p);
92 		return rval;
93 	}
94 
95 	isns_init_buffer_pool();
96 	rval = isns_add_buffer_pool(ISNS_BUF_SIZE, ISNS_BUF_COUNT);
97 	if (rval != 0) {
98 		DBG("isns_init: error on isns_init_buffer_pool()\n");
99 		isns_destroy_config(cfg_p);
100 		return rval;
101 	}
102 	rval = isns_add_buffer_pool((int)ISNS_SMALL_BUF_SIZE, ISNS_SMALL_BUF_COUNT);
103 	if (rval != 0) {
104 		DBG("isns_init: error on isns_init_buffer_pool() [small]\n");
105 		isns_destroy_config(cfg_p);
106 		isns_destroy_buffer_pool();
107 		return rval;
108 	}
109 
110 	if ((rval = isns_thread_create(cfg_p)) != 0) {
111 		DBG("isns_init: error on isns_thread_create()\n");
112 		isns_destroy_config(cfg_p);
113 		isns_destroy_buffer_pool();
114 		return rval;
115 	}
116 
117 	*isns_handle_p = (ISNS_HANDLE)cfg_p;
118 
119 	return 0;
120 }
121 
122 
123 /*
124  * isns_add_servercon()
125  */
126 int
isns_add_servercon(ISNS_HANDLE isns_handle,int fd,struct addrinfo * ai)127 isns_add_servercon(ISNS_HANDLE isns_handle, int fd, struct addrinfo *ai)
128 {
129 	struct isns_config_s *cfg_p;
130 	struct isns_task_s *task_p;
131 	struct addrinfo *ai_p;
132 	size_t len;
133 
134 	if (isns_handle == ISNS_INVALID_HANDLE)
135 		return EINVAL;
136 
137 	cfg_p = (struct isns_config_s *)isns_handle;
138 
139 	ai_p = (struct addrinfo *)isns_malloc(sizeof(struct addrinfo));
140 	if (ai_p == NULL)
141 		return ENOMEM;
142 
143 	ai_p->ai_flags = ai->ai_flags;
144 	ai_p->ai_family = ai->ai_family;
145 	ai_p->ai_socktype = ai->ai_socktype;
146 	ai_p->ai_protocol = ai->ai_protocol;
147 	ai_p->ai_addrlen = ai->ai_addrlen;
148 	if (ai->ai_canonname != NULL) {
149 		len = strlen(ai->ai_canonname);
150 		ai_p->ai_canonname = (char *)isns_malloc(len + 1);
151 		if (ai_p->ai_canonname == NULL) {
152 			isns_free(ai_p);
153 			return ENOMEM;
154 		}
155 		memset(ai_p->ai_canonname, '\0', len + 1);
156 		strlcpy(ai_p->ai_canonname, ai->ai_canonname, len + 1);
157 	} else
158 		ai_p->ai_canonname = NULL;
159 	if (ai->ai_addr != NULL) {
160 		ai_p->ai_addr = (struct sockaddr *)isns_malloc(ai_p->
161 		    ai_addrlen);
162 		if (ai_p->ai_addr == NULL) {
163 			if (ai_p->ai_canonname != NULL)
164 				isns_free(ai_p->ai_canonname);
165 			isns_free(ai_p);
166 			return ENOMEM;
167 		}
168 		memcpy(ai_p->ai_addr, ai->ai_addr, ai_p->ai_addrlen);
169 	} else
170 		ai_p->ai_addr = NULL;
171 	ai_p->ai_next = NULL;
172 
173 	/* Build task and kick off task processing */
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;
177 
178 	isns_taskq_insert_head(cfg_p, task_p);
179 	isns_issue_cmd(cfg_p, ISNS_CMD_PROCESS_TASKQ);
180 	isns_wait_task(task_p, NULL);
181 
182 	return 0;
183 }
184 
185 
186 /*
187  * isns_init_reg_refresh()
188  */
189 int
isns_init_reg_refresh(ISNS_HANDLE isns_handle,const char * node,int interval)190 isns_init_reg_refresh(ISNS_HANDLE isns_handle, const char *node, int interval)
191 {
192 	struct isns_config_s *cfg_p;
193 	struct isns_task_s *task_p;
194 	struct isns_refresh_s *ref_p;
195 
196 	if (isns_handle == ISNS_INVALID_HANDLE)
197 		return EINVAL;
198 
199 	/* Build INIT_REFRESH task with info provided. */
200 	cfg_p = (struct isns_config_s *)isns_handle;
201 	task_p = isns_new_task(cfg_p, ISNS_TASK_INIT_REFRESH, 0);
202 	if (task_p == NULL)
203 		return ENOMEM;
204 
205 	ref_p = (struct isns_refresh_s *)
206 	    isns_malloc(sizeof(struct isns_refresh_s));
207 	if (ref_p == NULL) {
208 		isns_free_task(task_p);
209 		return ENOMEM;
210 	}
211 
212 	(void) snprintf(ref_p->node, sizeof(ref_p->node), "%.*s",
213 		(int)sizeof(ref_p->node)-1, node);
214 	ref_p->interval = interval;
215 	ref_p->trans_p = NULL;
216 	task_p->var.init_refresh.ref_p = ref_p;
217 
218 	isns_taskq_insert_tail(cfg_p, task_p);
219 	isns_issue_cmd(cfg_p, ISNS_CMD_PROCESS_TASKQ);
220 
221 	return 0;
222 }
223 
224 
225 /*
226  * isns_stop()
227  */
isns_stop(ISNS_HANDLE isns_handle)228 void isns_stop(ISNS_HANDLE isns_handle)
229 {
230 	struct isns_config_s *cfg_p = (struct isns_config_s *)isns_handle;
231 
232 	DBG("isns_stop: entered\n");
233 
234 	isns_issue_cmd(cfg_p, ISNS_CMD_STOP);
235 
236 	isns_thread_destroy(cfg_p);
237 	isns_destroy_config(cfg_p);
238 	isns_destroy_buffer_pool();
239 }
240