iscsid_driverif.c revision 1.2 1 1.2 christos /* $NetBSD: iscsid_driverif.c,v 1.2 2011/10/29 16:54:49 christos Exp $ */
2 1.1 agc
3 1.1 agc /*-
4 1.1 agc * Copyright (c) 2005,2006,2011 The NetBSD Foundation, Inc.
5 1.1 agc * All rights reserved.
6 1.1 agc *
7 1.1 agc * This code is derived from software contributed to The NetBSD Foundation
8 1.1 agc * by Wasabi Systems, Inc.
9 1.1 agc *
10 1.1 agc * Redistribution and use in source and binary forms, with or without
11 1.1 agc * modification, are permitted provided that the following conditions
12 1.1 agc * are met:
13 1.1 agc * 1. Redistributions of source code must retain the above copyright
14 1.1 agc * notice, this list of conditions and the following disclaimer.
15 1.1 agc * 2. Redistributions in binary form must reproduce the above copyright
16 1.1 agc * notice, this list of conditions and the following disclaimer in the
17 1.1 agc * documentation and/or other materials provided with the distribution.
18 1.1 agc *
19 1.1 agc * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
20 1.1 agc * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
21 1.1 agc * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
22 1.1 agc * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
23 1.1 agc * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
24 1.1 agc * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
25 1.1 agc * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
26 1.1 agc * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
27 1.1 agc * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
28 1.1 agc * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
29 1.1 agc * POSSIBILITY OF SUCH DAMAGE.
30 1.1 agc */
31 1.1 agc #include "iscsid_globals.h"
32 1.1 agc
33 1.1 agc #include <sys/socket.h>
34 1.1 agc #include <netinet/in.h>
35 1.1 agc #include <netinet/tcp.h>
36 1.1 agc #include <netdb.h>
37 1.1 agc
38 1.1 agc
39 1.1 agc /* Global node name (Initiator Name and Alias) */
40 1.1 agc iscsid_set_node_name_req_t node_name;
41 1.1 agc
42 1.1 agc /* -------------------------------------------------------------------------- */
43 1.1 agc
44 1.1 agc /*
45 1.1 agc * set_node_name:
46 1.1 agc * Handle set_node_name request. Copy names into our own buffers and
47 1.1 agc * set the driver's info as well.
48 1.1 agc *
49 1.1 agc * Parameter:
50 1.1 agc * par The request parameter
51 1.1 agc *
52 1.1 agc * Returns: Status.
53 1.1 agc */
54 1.1 agc
55 1.1 agc uint32_t
56 1.1 agc set_node_name(iscsid_set_node_name_req_t * par)
57 1.1 agc {
58 1.1 agc iscsi_set_node_name_parameters_t snp;
59 1.1 agc
60 1.1 agc (void) memset(&snp, 0x0, sizeof(snp));
61 1.1 agc if (!par->InitiatorName[0])
62 1.1 agc return ISCSID_STATUS_NO_INITIATOR_NAME;
63 1.1 agc
64 1.1 agc if (strlen((char *)par->InitiatorName) > ISCSI_STRING_LENGTH
65 1.1 agc || strlen((char *)par->InitiatorAlias) > ISCSI_STRING_LENGTH)
66 1.1 agc return ISCSID_STATUS_PARAMETER_INVALID;
67 1.1 agc
68 1.1 agc if (!par->InitiatorAlias[0])
69 1.1 agc gethostname((char *)node_name.InitiatorAlias, sizeof(node_name.InitiatorAlias));
70 1.1 agc
71 1.1 agc node_name = *par;
72 1.1 agc
73 1.1 agc #ifdef ISCSI_DEBUG /* DEBUG ONLY: Allow op without driver present */
74 1.1 agc if (driver < 0)
75 1.1 agc return ISCSID_STATUS_SUCCESS;
76 1.1 agc #endif
77 1.1 agc
78 1.1 agc strlcpy((char *)snp.InitiatorName, (char *)par->InitiatorName,
79 1.1 agc sizeof(snp.InitiatorName));
80 1.1 agc strlcpy((char *)snp.InitiatorAlias, (char *)par->InitiatorAlias,
81 1.1 agc sizeof(snp.InitiatorAlias));
82 1.1 agc memcpy(snp.ISID, par->ISID, 6);
83 1.1 agc
84 1.1 agc DEB(10, ("Setting Node Name: %s (%s)\n",
85 1.1 agc snp.InitiatorName, snp.InitiatorAlias));
86 1.2 christos (void)ioctl(driver, ISCSI_SET_NODE_NAME, &snp);
87 1.1 agc return snp.status;
88 1.1 agc }
89 1.1 agc
90 1.1 agc
91 1.1 agc /*
92 1.1 agc * bind_socket:
93 1.1 agc * Bind socket to initiator portal.
94 1.1 agc *
95 1.1 agc * Parameter:
96 1.1 agc * sock The socket
97 1.1 agc * addr The initiator portal address
98 1.1 agc *
99 1.1 agc * Returns:
100 1.1 agc * TRUE on success, FALSE on error.
101 1.1 agc */
102 1.1 agc
103 1.1 agc STATIC int
104 1.1 agc bind_socket(int sock, uint8_t * addr)
105 1.1 agc {
106 1.1 agc struct sockaddr_in serverAddress;
107 1.1 agc struct hostent *host;
108 1.1 agc
109 1.1 agc DEB(8, ("Binding to <%s>\n", addr));
110 1.1 agc (void) memset(&serverAddress, 0x0, sizeof(serverAddress));
111 1.1 agc host = gethostbyname((char *)addr);
112 1.1 agc if (host == NULL)
113 1.1 agc return FALSE;
114 1.1 agc if (host->h_length > (int)sizeof(serverAddress.sin_addr))
115 1.1 agc return FALSE;
116 1.1 agc serverAddress.sin_family = host->h_addrtype;
117 1.1 agc serverAddress.sin_port = 0;
118 1.1 agc serverAddress.sin_len = host->h_length;
119 1.1 agc memcpy(&serverAddress.sin_addr, host->h_addr_list[0], host->h_length);
120 1.1 agc
121 1.2 christos return bind(sock, (struct sockaddr *)(void *)&serverAddress,
122 1.2 christos (socklen_t)sizeof(serverAddress)) >= 0;
123 1.1 agc }
124 1.1 agc
125 1.1 agc
126 1.1 agc /* -------------------------------------------------------------------------- */
127 1.1 agc
128 1.1 agc /*
129 1.1 agc * find_free_portal:
130 1.1 agc * Find the Portal with the least number of connections.
131 1.1 agc *
132 1.1 agc * Parameter: the portal group
133 1.1 agc *
134 1.1 agc * Returns: The pointer to the first free portal (or NULL if none found)
135 1.1 agc */
136 1.1 agc
137 1.1 agc STATIC portal_t *
138 1.1 agc find_free_portal(portal_group_t * group)
139 1.1 agc {
140 1.1 agc portal_t *curr, *m;
141 1.1 agc uint32_t n;
142 1.1 agc
143 1.1 agc if ((curr = TAILQ_FIRST(&group->portals)) == NULL)
144 1.1 agc return NULL;
145 1.1 agc
146 1.1 agc m = curr;
147 1.1 agc n = curr->active_connections;
148 1.1 agc
149 1.1 agc while ((curr = TAILQ_NEXT(curr, group_list)) != NULL)
150 1.1 agc if (curr->active_connections < n) {
151 1.1 agc m = curr;
152 1.1 agc n = curr->active_connections;
153 1.1 agc }
154 1.1 agc
155 1.1 agc return m;
156 1.1 agc }
157 1.1 agc
158 1.1 agc
159 1.1 agc /*
160 1.1 agc * make_connection:
161 1.1 agc * Common routine for login and add_connection. Creates the connection
162 1.1 agc * structure, connects the socket, and executes the login.
163 1.1 agc *
164 1.1 agc * Parameter:
165 1.1 agc * sess The associated session. NULL for a send_targets request.
166 1.1 agc * req The request parameters. NULL for send_targets.
167 1.1 agc * res The response buffer. For SendTargets, only the status
168 1.1 agc * is set. For a "real" login, the login response
169 1.1 agc * is filled in.
170 1.1 agc * stid Send target request only, else NULL. Pointer to uint32:
171 1.1 agc * On Input, contains send target ID
172 1.1 agc * On Output, receives session ID
173 1.1 agc *
174 1.1 agc * Returns: The connection structure on successful login, else NULL.
175 1.1 agc *
176 1.1 agc * NOTE: Session list must be locked on entry.
177 1.1 agc */
178 1.1 agc
179 1.1 agc STATIC connection_t *
180 1.1 agc make_connection(session_t * sess, iscsid_login_req_t * req,
181 1.1 agc iscsid_response_t * res, uint32_t * stid)
182 1.1 agc {
183 1.1 agc connection_t *conn;
184 1.1 agc iscsi_login_parameters_t loginp;
185 1.1 agc int sock;
186 1.1 agc int ret;
187 1.1 agc int yes = 1;
188 1.1 agc target_t *target;
189 1.1 agc portal_t *portal = NULL;
190 1.1 agc iscsi_portal_address_t *addr;
191 1.1 agc struct sockaddr_in serverAddress;
192 1.1 agc struct hostent *host;
193 1.1 agc initiator_t *init;
194 1.1 agc
195 1.1 agc DEB(9, ("Make Connection sess=%x, req=%x, res=%x, stid=%x\n",
196 1.1 agc (int) sess, (int) req, (int) res, (int) stid));
197 1.1 agc (void) memset(&loginp, 0x0, sizeof(loginp));
198 1.1 agc (void) memset(&serverAddress, 0x0, sizeof(serverAddress));
199 1.1 agc
200 1.1 agc /* find the target portal */
201 1.1 agc if (stid != NULL) {
202 1.1 agc send_target_t *starget;
203 1.1 agc
204 1.1 agc if ((starget = find_send_target_id(*stid)) == NULL) {
205 1.1 agc res->status = ISCSID_STATUS_INVALID_TARGET_ID;
206 1.1 agc return NULL;
207 1.1 agc }
208 1.1 agc addr = &starget->addr;
209 1.2 christos target = (target_t *)(void *)starget;
210 1.1 agc } else {
211 1.1 agc if (NO_ID(&req->portal_id)
212 1.1 agc || (portal = find_portal(&req->portal_id)) == NULL) {
213 1.1 agc portal_group_t *group;
214 1.1 agc
215 1.1 agc /* if no ID was specified, use target from existing session */
216 1.1 agc if (NO_ID(&req->portal_id)) {
217 1.1 agc if (!sess->num_connections ||
218 1.2 christos ((target = find_target_id(TARGET_LIST,
219 1.2 christos sess->target.sid.id)) == NULL)) {
220 1.1 agc res->status = ISCSID_STATUS_INVALID_PORTAL_ID;
221 1.1 agc return NULL;
222 1.1 agc }
223 1.1 agc }
224 1.1 agc /* if a target was given instead, use it */
225 1.1 agc else if ((target =
226 1.1 agc find_target(TARGET_LIST, &req->portal_id)) == NULL) {
227 1.1 agc res->status = ISCSID_STATUS_INVALID_PORTAL_ID;
228 1.1 agc return NULL;
229 1.1 agc }
230 1.1 agc /* now get from target to portal - if this is the first connection, */
231 1.1 agc /* just use the first portal group. */
232 1.1 agc if (!sess->num_connections) {
233 1.1 agc group = TAILQ_FIRST(&target->group_list);
234 1.1 agc }
235 1.1 agc /* if it's a second connection, use an available portal in the same */
236 1.1 agc /* portal group */
237 1.1 agc else {
238 1.2 christos conn = (connection_t *)(void *)
239 1.2 christos TAILQ_FIRST(&sess->connections);
240 1.1 agc
241 1.1 agc if (conn == NULL ||
242 1.1 agc (portal = find_portal_id(conn->portal.sid.id)) == NULL) {
243 1.1 agc res->status = ISCSID_STATUS_INVALID_PORTAL_ID;
244 1.1 agc return NULL;
245 1.1 agc }
246 1.1 agc group = portal->group;
247 1.1 agc }
248 1.1 agc
249 1.1 agc if ((portal = find_free_portal(group)) == NULL) {
250 1.1 agc res->status = ISCSID_STATUS_INVALID_PORTAL_ID;
251 1.1 agc return NULL;
252 1.1 agc }
253 1.1 agc DEB(1, ("find_free_portal returns pid=%d\n", portal->entry.sid.id));
254 1.1 agc } else
255 1.1 agc target = portal->target;
256 1.1 agc
257 1.1 agc addr = &portal->addr;
258 1.1 agc
259 1.1 agc /* symbolic name for connection? check for duplicates */
260 1.1 agc if (req->sym_name[0]) {
261 1.1 agc void *p;
262 1.1 agc
263 1.1 agc if (sess->num_connections)
264 1.1 agc p = find_connection_name(sess, req->sym_name);
265 1.1 agc else
266 1.1 agc p = find_session_name(req->sym_name);
267 1.1 agc if (p) {
268 1.1 agc res->status = ISCSID_STATUS_DUPLICATE_NAME;
269 1.1 agc return NULL;
270 1.1 agc }
271 1.1 agc }
272 1.1 agc }
273 1.1 agc
274 1.1 agc if (req != NULL && !NO_ID(&req->initiator_id)) {
275 1.1 agc if ((init = find_initiator(&req->initiator_id)) == NULL) {
276 1.1 agc res->status = ISCSID_STATUS_INVALID_INITIATOR_ID;
277 1.1 agc return NULL;
278 1.1 agc }
279 1.1 agc } else
280 1.1 agc init = select_initiator();
281 1.1 agc
282 1.1 agc /* translate target address */
283 1.1 agc DEB(8, ("Connecting to <%s>, port %d\n", addr->address, addr->port));
284 1.1 agc
285 1.1 agc host = gethostbyname((char *)addr->address);
286 1.1 agc if (host == NULL) {
287 1.1 agc switch (h_errno) {
288 1.1 agc case HOST_NOT_FOUND:
289 1.1 agc res->status = ISCSID_STATUS_HOST_NOT_FOUND;
290 1.1 agc break;
291 1.1 agc case TRY_AGAIN:
292 1.1 agc res->status = ISCSID_STATUS_HOST_TRY_AGAIN;
293 1.1 agc break;
294 1.1 agc default:
295 1.1 agc res->status = ISCSID_STATUS_HOST_ERROR;
296 1.1 agc break;
297 1.1 agc }
298 1.1 agc return NULL;
299 1.1 agc }
300 1.1 agc if (host->h_length > (int)sizeof(serverAddress.sin_addr)) {
301 1.1 agc res->status = ISCSID_STATUS_HOST_ERROR;
302 1.1 agc return NULL;
303 1.1 agc }
304 1.1 agc DEB(8, ("Gethostbyname OK, addrtype %d, len %d, addr %x\n",
305 1.1 agc host->h_addrtype, host->h_length, *((int *) host->h_addr_list[0])));
306 1.1 agc serverAddress.sin_family = host->h_addrtype;
307 1.1 agc serverAddress.sin_port = htons((addr->port)
308 1.1 agc ? addr->port : ISCSI_DEFAULT_PORT);
309 1.1 agc serverAddress.sin_len = host->h_length;
310 1.1 agc memcpy(&serverAddress.sin_addr, host->h_addr_list[0], host->h_length);
311 1.1 agc
312 1.1 agc /* alloc the connection structure */
313 1.1 agc conn = calloc(1, sizeof(*conn));
314 1.1 agc if (conn == NULL) {
315 1.1 agc res->status = ISCSID_STATUS_NO_RESOURCES;
316 1.1 agc return NULL;
317 1.1 agc }
318 1.1 agc /* create and connect the socket */
319 1.1 agc sock = socket(AF_INET, SOCK_STREAM, 0);
320 1.1 agc if (sock < 0) {
321 1.1 agc free(conn);
322 1.1 agc res->status = ISCSID_STATUS_SOCKET_ERROR;
323 1.1 agc return NULL;
324 1.1 agc }
325 1.1 agc
326 1.1 agc if (init) {
327 1.1 agc if (!bind_socket(sock, init->address)) {
328 1.1 agc close(sock);
329 1.1 agc free(conn);
330 1.1 agc res->status = ISCSID_STATUS_INITIATOR_BIND_ERROR;
331 1.1 agc return NULL;
332 1.1 agc }
333 1.1 agc }
334 1.1 agc
335 1.1 agc DEB(8, ("Connecting socket\n"));
336 1.2 christos if (connect(sock, (struct sockaddr *)(void *)&serverAddress,
337 1.2 christos (socklen_t)sizeof(serverAddress)) < 0) {
338 1.1 agc close(sock);
339 1.1 agc free(conn);
340 1.1 agc res->status = ISCSID_STATUS_CONNECT_ERROR;
341 1.1 agc DEB(1, ("Connecting to socket failed (error %d), returning %d\n",
342 1.1 agc errno, res->status));
343 1.1 agc return NULL;
344 1.1 agc }
345 1.1 agc /* speed up socket processing */
346 1.2 christos setsockopt(sock, IPPROTO_TCP, TCP_NODELAY, &yes, (socklen_t)sizeof(yes));
347 1.1 agc
348 1.1 agc /* setup login parameter structure */
349 1.1 agc loginp.socket = sock;
350 1.1 agc if (target->TargetName[0]) {
351 1.1 agc loginp.is_present.TargetName = 1;
352 1.1 agc loginp.TargetName = target->TargetName;
353 1.1 agc }
354 1.1 agc if (target->options.is_present.MaxConnections) {
355 1.1 agc loginp.is_present.MaxConnections = 1;
356 1.1 agc loginp.MaxConnections = target->options.MaxConnections;
357 1.1 agc }
358 1.1 agc if (target->options.is_present.DataDigest) {
359 1.1 agc loginp.is_present.DataDigest = 1;
360 1.1 agc loginp.DataDigest = target->options.DataDigest;
361 1.1 agc }
362 1.1 agc if (target->options.is_present.HeaderDigest) {
363 1.1 agc loginp.is_present.HeaderDigest = 1;
364 1.1 agc loginp.HeaderDigest = target->options.HeaderDigest;
365 1.1 agc }
366 1.1 agc if (target->options.is_present.DefaultTime2Retain) {
367 1.1 agc loginp.is_present.DefaultTime2Retain = 1;
368 1.1 agc loginp.DefaultTime2Retain = target->options.DefaultTime2Retain;
369 1.1 agc }
370 1.1 agc if (target->options.is_present.DefaultTime2Wait) {
371 1.1 agc loginp.is_present.DefaultTime2Wait = 1;
372 1.1 agc loginp.DefaultTime2Wait = target->options.DefaultTime2Wait;
373 1.1 agc }
374 1.1 agc if (target->options.is_present.ErrorRecoveryLevel) {
375 1.1 agc loginp.is_present.ErrorRecoveryLevel = 1;
376 1.1 agc loginp.ErrorRecoveryLevel = target->options.ErrorRecoveryLevel;
377 1.1 agc }
378 1.1 agc if (target->options.is_present.MaxRecvDataSegmentLength) {
379 1.1 agc loginp.is_present.MaxRecvDataSegmentLength = 1;
380 1.1 agc loginp.MaxRecvDataSegmentLength =
381 1.1 agc target->options.MaxRecvDataSegmentLength;
382 1.1 agc }
383 1.1 agc if (target->auth.auth_info.auth_number) {
384 1.1 agc loginp.is_present.auth_info = 1;
385 1.1 agc loginp.auth_info = target->auth.auth_info;
386 1.1 agc if (target->auth.password[0]) {
387 1.1 agc loginp.is_present.password = 1;
388 1.1 agc loginp.password = target->auth.password;
389 1.1 agc }
390 1.1 agc if (target->auth.target_password[0]) {
391 1.1 agc loginp.is_present.target_password = 1;
392 1.1 agc loginp.target_password = target->auth.target_password;
393 1.1 agc }
394 1.1 agc if (target->auth.user_name[0]) {
395 1.1 agc loginp.is_present.user_name = 1;
396 1.1 agc loginp.user_name = target->auth.user_name;
397 1.1 agc }
398 1.1 agc }
399 1.1 agc loginp.is_present.TargetAlias = 1;
400 1.1 agc loginp.TargetAlias = target->TargetAlias;
401 1.1 agc
402 1.1 agc if (portal != NULL) {
403 1.1 agc /* override general target options with portal options (if specified) */
404 1.1 agc if (portal->options.is_present.DataDigest) {
405 1.1 agc loginp.is_present.DataDigest = 1;
406 1.1 agc loginp.DataDigest = portal->options.DataDigest;
407 1.1 agc }
408 1.1 agc if (portal->options.is_present.HeaderDigest) {
409 1.1 agc loginp.is_present.HeaderDigest = 1;
410 1.1 agc loginp.HeaderDigest = portal->options.HeaderDigest;
411 1.1 agc }
412 1.1 agc if (portal->options.is_present.MaxRecvDataSegmentLength) {
413 1.1 agc loginp.is_present.MaxRecvDataSegmentLength = 1;
414 1.1 agc loginp.MaxRecvDataSegmentLength =
415 1.1 agc portal->options.MaxRecvDataSegmentLength;
416 1.1 agc }
417 1.1 agc }
418 1.1 agc
419 1.1 agc if (req != NULL) {
420 1.1 agc loginp.session_id = get_id(&list[SESSION_LIST].list, &req->session_id);
421 1.1 agc loginp.login_type = req->login_type;
422 1.1 agc } else
423 1.1 agc loginp.login_type = ISCSI_LOGINTYPE_DISCOVERY;
424 1.1 agc
425 1.1 agc DEB(5, ("Calling Login...\n"));
426 1.1 agc
427 1.1 agc ret = ioctl(driver, (sess != NULL && sess->num_connections)
428 1.1 agc ? ISCSI_ADD_CONNECTION : ISCSI_LOGIN, &loginp);
429 1.1 agc
430 1.1 agc res->status = loginp.status;
431 1.1 agc
432 1.1 agc if (ret)
433 1.1 agc close(sock);
434 1.1 agc
435 1.1 agc if (ret || loginp.status) {
436 1.1 agc free(conn);
437 1.1 agc if (!res->status)
438 1.1 agc res->status = ISCSID_STATUS_GENERAL_ERROR;
439 1.1 agc return NULL;
440 1.1 agc }
441 1.1 agc /* connection established! link connection into session and return IDs */
442 1.1 agc
443 1.1 agc conn->loginp = loginp;
444 1.1 agc conn->entry.sid.id = loginp.connection_id;
445 1.1 agc if (req != NULL) {
446 1.1 agc strlcpy((char *)conn->entry.sid.name, (char *)req->sym_name,
447 1.1 agc sizeof(conn->entry.sid.name));
448 1.1 agc }
449 1.1 agc
450 1.1 agc /*
451 1.1 agc Copy important target information
452 1.1 agc */
453 1.1 agc conn->target.sid = target->entry.sid;
454 1.1 agc strlcpy((char *)conn->target.TargetName, (char *)target->TargetName,
455 1.1 agc sizeof(conn->target.TargetName));
456 1.1 agc strlcpy((char *)conn->target.TargetAlias, (char *)target->TargetAlias,
457 1.1 agc sizeof(conn->target.TargetAlias));
458 1.1 agc conn->target.options = target->options;
459 1.1 agc conn->target.auth = target->auth;
460 1.1 agc conn->portal.addr = *addr;
461 1.1 agc
462 1.1 agc conn->session = sess;
463 1.1 agc
464 1.1 agc if (stid == NULL) {
465 1.2 christos iscsid_login_rsp_t *rsp = (iscsid_login_rsp_t *)(void *)
466 1.2 christos res->parameter;
467 1.1 agc
468 1.1 agc sess->entry.sid.id = loginp.session_id;
469 1.1 agc TAILQ_INSERT_TAIL(&sess->connections, &conn->entry, link);
470 1.1 agc sess->num_connections++;
471 1.1 agc
472 1.1 agc res->parameter_length = sizeof(*rsp);
473 1.1 agc rsp->connection_id = conn->entry.sid;
474 1.1 agc rsp->session_id = sess->entry.sid;
475 1.1 agc
476 1.1 agc if (init != NULL) {
477 1.1 agc conn->initiator_id = init->entry.sid.id;
478 1.1 agc init->active_connections++;
479 1.1 agc }
480 1.1 agc } else
481 1.1 agc *stid = loginp.session_id;
482 1.1 agc
483 1.1 agc /*
484 1.1 agc Copy important portal information
485 1.1 agc */
486 1.1 agc if (portal != NULL) {
487 1.1 agc conn->portal.sid = portal->entry.sid;
488 1.1 agc portal->active_connections++;
489 1.1 agc }
490 1.1 agc
491 1.1 agc return conn;
492 1.1 agc }
493 1.1 agc
494 1.1 agc
495 1.1 agc /*
496 1.1 agc * event_recover_connection:
497 1.1 agc * Handle RECOVER_CONNECTION event: Attempt to re-establish connection.
498 1.1 agc *
499 1.1 agc * Parameter:
500 1.1 agc * sid Session ID
501 1.1 agc * cid Connection ID
502 1.1 agc */
503 1.1 agc
504 1.1 agc STATIC void
505 1.1 agc event_recover_connection(uint32_t sid, uint32_t cid)
506 1.1 agc {
507 1.1 agc int sock, ret;
508 1.1 agc int yes = 1;
509 1.1 agc session_t *sess;
510 1.1 agc connection_t *conn;
511 1.1 agc portal_t *portal;
512 1.1 agc initiator_t *init;
513 1.1 agc iscsi_portal_address_t *addr;
514 1.1 agc struct sockaddr_in serverAddress;
515 1.1 agc struct hostent *host;
516 1.1 agc
517 1.1 agc DEB(1, ("Event_Recover_Connection sid=%d, cid=%d\n", sid, cid));
518 1.1 agc (void) memset(&serverAddress, 0x0, sizeof(serverAddress));
519 1.1 agc
520 1.1 agc LOCK_SESSIONS;
521 1.1 agc
522 1.1 agc sess = find_session_id(sid);
523 1.1 agc if (sess == NULL) {
524 1.1 agc UNLOCK_SESSIONS;
525 1.1 agc return;
526 1.1 agc }
527 1.1 agc
528 1.1 agc conn = find_connection_id(sess, cid);
529 1.1 agc if (conn == NULL) {
530 1.1 agc UNLOCK_SESSIONS;
531 1.1 agc return;
532 1.1 agc }
533 1.1 agc
534 1.1 agc UNLOCK_SESSIONS;
535 1.1 agc
536 1.1 agc conn->loginp.status = ISCSI_STATUS_CONNECTION_FAILED;
537 1.1 agc
538 1.1 agc /* If we can't find the portal to connect to, abort. */
539 1.1 agc
540 1.1 agc if ((portal = find_portal_id(conn->portal.sid.id)) == NULL)
541 1.1 agc return;
542 1.1 agc
543 1.1 agc init = find_initiator_id(conn->initiator_id);
544 1.1 agc addr = &portal->addr;
545 1.1 agc conn->portal.addr = *addr;
546 1.1 agc
547 1.1 agc /* translate target address */
548 1.1 agc DEB(1, ("Event_Recover_Connection Connecting to <%s>, port %d\n",
549 1.1 agc addr->address, addr->port));
550 1.1 agc
551 1.1 agc if ((host = gethostbyname((char *)addr->address)) == NULL) {
552 1.1 agc DEB(1, ("GetHostByName failed (error %d)\n", h_errno));
553 1.1 agc return;
554 1.1 agc }
555 1.1 agc if (host->h_length > (int)sizeof(serverAddress.sin_addr)) {
556 1.1 agc DEB(1, ("Host address length invalid (%d)\n", host->h_length));
557 1.1 agc return;
558 1.1 agc }
559 1.1 agc
560 1.1 agc serverAddress.sin_family = host->h_addrtype;
561 1.1 agc serverAddress.sin_port = htons((addr->port)
562 1.1 agc ? addr->port : ISCSI_DEFAULT_PORT);
563 1.1 agc serverAddress.sin_len = host->h_length;
564 1.1 agc memcpy(&serverAddress.sin_addr, host->h_addr_list[0], host->h_length);
565 1.1 agc
566 1.1 agc /* create and connect the socket */
567 1.1 agc sock = socket(AF_INET, SOCK_STREAM, 0);
568 1.1 agc if (sock < 0) {
569 1.1 agc DEB(1, ("Creating socket failed (error %d)\n", errno));
570 1.1 agc return;
571 1.1 agc }
572 1.1 agc
573 1.1 agc DEB(1, ("recover_connection: Socket = %d\n", sock));
574 1.1 agc
575 1.1 agc if (init) {
576 1.1 agc if (!bind_socket(sock, init->address)) {
577 1.1 agc DEB(1, ("Binding to interface failed (error %d)\n", errno));
578 1.1 agc close(sock);
579 1.1 agc return;
580 1.1 agc }
581 1.1 agc }
582 1.1 agc
583 1.2 christos if (connect(sock, (struct sockaddr *)(void *)&serverAddress,
584 1.2 christos (socklen_t)sizeof(serverAddress)) < 0) {
585 1.1 agc DEB(1, ("Connecting to socket failed (error %d)\n", errno));
586 1.1 agc close(sock);
587 1.1 agc return;
588 1.1 agc }
589 1.1 agc /* speed up socket processing */
590 1.2 christos setsockopt(sock, IPPROTO_TCP, TCP_NODELAY, &yes, (socklen_t)sizeof(yes));
591 1.1 agc
592 1.1 agc conn->loginp.socket = sock;
593 1.1 agc conn->loginp.status = 0;
594 1.1 agc ret = ioctl(driver, ISCSI_RESTORE_CONNECTION, &conn->loginp);
595 1.1 agc
596 1.1 agc if (ret)
597 1.1 agc close(sock);
598 1.1 agc }
599 1.1 agc
600 1.1 agc
601 1.1 agc /*
602 1.1 agc * login:
603 1.1 agc * Handle LOGIN request: Log into given portal. Create session, then
604 1.1 agc * let make_connection do the rest.
605 1.1 agc *
606 1.1 agc * Parameter:
607 1.1 agc * req The request parameters
608 1.1 agc * res The response buffer
609 1.1 agc */
610 1.1 agc
611 1.1 agc void
612 1.1 agc login(iscsid_login_req_t * req, iscsid_response_t * res)
613 1.1 agc {
614 1.1 agc session_t *sess;
615 1.1 agc connection_t *conn;
616 1.1 agc
617 1.1 agc sess = calloc(1, sizeof(*sess));
618 1.1 agc if (sess == NULL) {
619 1.1 agc res->status = ISCSID_STATUS_NO_RESOURCES;
620 1.1 agc return;
621 1.1 agc }
622 1.1 agc TAILQ_INIT(&sess->connections);
623 1.1 agc strlcpy((char *)sess->entry.sid.name, (char *)req->sym_name,
624 1.1 agc sizeof(sess->entry.sid.name));
625 1.1 agc
626 1.1 agc LOCK_SESSIONS;
627 1.1 agc conn = make_connection(sess, req, res, 0);
628 1.1 agc
629 1.1 agc if (conn == NULL)
630 1.1 agc free(sess);
631 1.1 agc else {
632 1.1 agc sess->target = conn->target;
633 1.1 agc TAILQ_INSERT_TAIL(&list[SESSION_LIST].list, &sess->entry, link);
634 1.1 agc list[SESSION_LIST].num_entries++;
635 1.1 agc }
636 1.1 agc UNLOCK_SESSIONS;
637 1.1 agc }
638 1.1 agc
639 1.1 agc
640 1.1 agc /*
641 1.1 agc * add_connection:
642 1.1 agc * Handle ADD_CONNECTION request: Log secondary connection into given portal.
643 1.1 agc * Find the session, then let make_connection do the rest.
644 1.1 agc *
645 1.1 agc * Parameter:
646 1.1 agc * req The request parameters
647 1.1 agc * res The response buffer
648 1.1 agc */
649 1.1 agc
650 1.1 agc void
651 1.1 agc add_connection(iscsid_login_req_t * req, iscsid_response_t * res)
652 1.1 agc {
653 1.1 agc session_t *sess;
654 1.1 agc
655 1.1 agc LOCK_SESSIONS;
656 1.1 agc sess = find_session(&req->session_id);
657 1.1 agc if (sess == NULL) {
658 1.1 agc UNLOCK_SESSIONS;
659 1.1 agc res->status = ISCSID_STATUS_INVALID_SESSION_ID;
660 1.1 agc return;
661 1.1 agc }
662 1.1 agc
663 1.1 agc make_connection(sess, req, res, 0);
664 1.1 agc UNLOCK_SESSIONS;
665 1.1 agc }
666 1.1 agc
667 1.1 agc
668 1.1 agc /*
669 1.1 agc * logout:
670 1.1 agc * Handle LOGOUT request: Log out the given session.
671 1.1 agc *
672 1.1 agc * Parameter:
673 1.1 agc * req The request parameters
674 1.1 agc *
675 1.1 agc * Returns: Response status
676 1.1 agc */
677 1.1 agc
678 1.1 agc uint32_t
679 1.1 agc logout(iscsid_sym_id_t * req)
680 1.1 agc {
681 1.1 agc iscsi_logout_parameters_t logoutp;
682 1.1 agc session_t *sess;
683 1.1 agc int ret;
684 1.1 agc
685 1.1 agc (void) memset(&logoutp, 0x0, sizeof(logoutp));
686 1.1 agc LOCK_SESSIONS;
687 1.1 agc sess = find_session(req);
688 1.1 agc if (sess == NULL) {
689 1.1 agc UNLOCK_SESSIONS;
690 1.1 agc return ISCSID_STATUS_INVALID_SESSION_ID;
691 1.1 agc }
692 1.1 agc
693 1.1 agc logoutp.session_id = sess->entry.sid.id;
694 1.1 agc UNLOCK_SESSIONS;
695 1.1 agc
696 1.1 agc ret = ioctl(driver, ISCSI_LOGOUT, &logoutp);
697 1.1 agc DEB(9, ("Logout returns %d, status = %d\n", ret, logoutp.status));
698 1.1 agc
699 1.1 agc return logoutp.status;
700 1.1 agc }
701 1.1 agc
702 1.1 agc
703 1.1 agc /*
704 1.1 agc * remove_connection:
705 1.1 agc * Handle REMOVE_CONNECTION request: Log out the given connection.
706 1.1 agc *
707 1.1 agc * Parameter:
708 1.1 agc * req The request parameters
709 1.1 agc *
710 1.1 agc * Returns: Response status
711 1.1 agc */
712 1.1 agc
713 1.1 agc uint32_t
714 1.1 agc remove_connection(iscsid_remove_connection_req_t * req)
715 1.1 agc {
716 1.1 agc iscsi_remove_parameters_t removep;
717 1.1 agc session_t *sess;
718 1.1 agc connection_t *conn;
719 1.1 agc int ret;
720 1.1 agc
721 1.1 agc LOCK_SESSIONS;
722 1.1 agc sess = find_session(&req->session_id);
723 1.1 agc if (sess == NULL) {
724 1.1 agc UNLOCK_SESSIONS;
725 1.1 agc return ISCSID_STATUS_INVALID_SESSION_ID;
726 1.1 agc }
727 1.1 agc conn = find_connection(sess, &req->connection_id);
728 1.1 agc if (conn == NULL) {
729 1.1 agc UNLOCK_SESSIONS;
730 1.1 agc return ISCSID_STATUS_INVALID_CONNECTION_ID;
731 1.1 agc }
732 1.1 agc
733 1.1 agc removep.session_id = sess->entry.sid.id;
734 1.1 agc removep.connection_id = conn->entry.sid.id;
735 1.1 agc UNLOCK_SESSIONS;
736 1.1 agc
737 1.1 agc ret = ioctl(driver, ISCSI_REMOVE_CONNECTION, &removep);
738 1.1 agc DEB(9, ("Remove Connection returns %d, status=%d\n", ret, removep.status));
739 1.1 agc
740 1.1 agc return removep.status;
741 1.1 agc }
742 1.1 agc
743 1.1 agc /*
744 1.1 agc * send_targets:
745 1.1 agc * Handle SEND_TARGETS request:
746 1.1 agc * First login with type = discovery.
747 1.1 agc * Then send the SendTargets iSCSI request to the target, which will
748 1.1 agc * return a list of target portals.
749 1.1 agc * Then logout.
750 1.1 agc *
751 1.1 agc * Parameter:
752 1.1 agc * stid The send target ID
753 1.1 agc * response_buffer Pointer to pointer to buffer containing response
754 1.1 agc * The response contains the list of the target
755 1.1 agc * portals. The caller frees the buffer after it
756 1.1 agc * is done with it.
757 1.1 agc * response_size Pointer to variable which upon return will hold
758 1.1 agc * the size of the response buffer.
759 1.1 agc *
760 1.1 agc * Returns: Response status
761 1.1 agc */
762 1.1 agc
763 1.1 agc uint32_t
764 1.1 agc send_targets(uint32_t stid, uint8_t **response_buffer, uint32_t *response_size)
765 1.1 agc {
766 1.1 agc iscsi_send_targets_parameters_t sendt;
767 1.1 agc iscsi_logout_parameters_t logoutp;
768 1.1 agc int ret;
769 1.1 agc connection_t *conn;
770 1.1 agc iscsid_response_t res;
771 1.1 agc uint32_t rc = ISCSID_STATUS_SUCCESS;
772 1.1 agc
773 1.1 agc (void) memset(&sendt, 0x0, sizeof(sendt));
774 1.1 agc (void) memset(&logoutp, 0x0, sizeof(logoutp));
775 1.1 agc (void) memset(&res, 0x0, sizeof(res));
776 1.1 agc conn = make_connection(NULL, NULL, &res, &stid);
777 1.1 agc DEB(9, ("Make connection returns, status = %d\n", res.status));
778 1.1 agc
779 1.1 agc if (conn == NULL)
780 1.1 agc return res.status;
781 1.1 agc
782 1.1 agc sendt.session_id = stid;
783 1.1 agc sendt.response_buffer = NULL;
784 1.1 agc sendt.response_size = 0;
785 1.1 agc sendt.response_used = sendt.response_total = 0;
786 1.1 agc strlcpy((char *)sendt.key, "All", sizeof(sendt.key));
787 1.1 agc
788 1.1 agc /*Call once to get the size of the buffer necessary */
789 1.1 agc ret = ioctl(driver, ISCSI_SEND_TARGETS, &sendt);
790 1.1 agc
791 1.1 agc if (!ret && !sendt.status) {
792 1.1 agc /* Allocate buffer required and call again to retrieve data */
793 1.1 agc /* We allocate one extra byte so we can place a terminating 0 */
794 1.1 agc /* at the end of the buffer. */
795 1.1 agc
796 1.1 agc sendt.response_size = sendt.response_total;
797 1.1 agc sendt.response_buffer = calloc(1, sendt.response_size + 1);
798 1.1 agc if (sendt.response_buffer == NULL)
799 1.1 agc rc = ISCSID_STATUS_NO_RESOURCES;
800 1.1 agc else {
801 1.1 agc ret = ioctl(driver, ISCSI_SEND_TARGETS, &sendt);
802 1.1 agc ((uint8_t *)sendt.response_buffer)[sendt.response_size] = 0;
803 1.1 agc
804 1.1 agc if (ret || sendt.status) {
805 1.1 agc free(sendt.response_buffer);
806 1.1 agc sendt.response_buffer = NULL;
807 1.1 agc sendt.response_used = 0;
808 1.1 agc if ((rc = sendt.status) == 0)
809 1.1 agc rc = ISCSID_STATUS_GENERAL_ERROR;
810 1.1 agc }
811 1.1 agc }
812 1.1 agc } else if ((rc = sendt.status) == 0)
813 1.1 agc rc = ISCSID_STATUS_GENERAL_ERROR;
814 1.1 agc
815 1.1 agc *response_buffer = sendt.response_buffer;
816 1.1 agc *response_size = sendt.response_used;
817 1.1 agc
818 1.1 agc logoutp.session_id = stid;
819 1.1 agc ret = ioctl(driver, ISCSI_LOGOUT, &logoutp);
820 1.1 agc /* ignore logout status */
821 1.1 agc
822 1.1 agc free(conn);
823 1.1 agc
824 1.1 agc return rc;
825 1.1 agc }
826 1.1 agc
827 1.1 agc
828 1.1 agc
829 1.1 agc /*
830 1.1 agc * get_version:
831 1.1 agc * Handle GET_VERSION request.
832 1.1 agc *
833 1.1 agc * Returns: Filled get_version_rsp structure.
834 1.1 agc */
835 1.1 agc
836 1.1 agc void
837 1.1 agc get_version(iscsid_response_t ** prsp, int *prsp_temp)
838 1.1 agc {
839 1.1 agc iscsid_response_t *rsp = *prsp;
840 1.1 agc iscsid_get_version_rsp_t *ver;
841 1.1 agc iscsi_get_version_parameters_t drv_ver;
842 1.1 agc
843 1.1 agc rsp = make_rsp(sizeof(iscsid_get_version_rsp_t), prsp, prsp_temp);
844 1.1 agc if (rsp == NULL)
845 1.1 agc return;
846 1.2 christos ver = (iscsid_get_version_rsp_t *)(void *)rsp->parameter;
847 1.1 agc
848 1.1 agc ver->interface_version = INTERFACE_VERSION;
849 1.1 agc ver->major = VERSION_MAJOR;
850 1.1 agc ver->minor = VERSION_MINOR;
851 1.1 agc strlcpy ((char *)ver->version_string, VERSION_STRING, sizeof(ver->version_string));
852 1.1 agc
853 1.1 agc #ifdef ISCSI_DEBUG /* DEBUG ONLY: Allow op without driver present */
854 1.1 agc if (driver < 0)
855 1.1 agc return;
856 1.1 agc #endif
857 1.1 agc ioctl(driver, ISCSI_GET_VERSION, &drv_ver);
858 1.1 agc ver->driver_interface_version = drv_ver.interface_version;
859 1.1 agc ver->driver_major = drv_ver.major;
860 1.1 agc ver->driver_minor = drv_ver.minor;
861 1.1 agc strlcpy ((char *)ver->driver_version_string, (char *)drv_ver.version_string,
862 1.1 agc sizeof (ver->driver_version_string));
863 1.1 agc }
864 1.1 agc
865 1.1 agc
866 1.1 agc /* -------------------------------------------------------------------------- */
867 1.1 agc
868 1.1 agc iscsi_register_event_parameters_t event_reg; /* registered event ID */
869 1.1 agc
870 1.1 agc
871 1.1 agc /*
872 1.1 agc * register_event_handler:
873 1.1 agc * Call driver to register the event handler.
874 1.1 agc *
875 1.1 agc * Returns:
876 1.1 agc * TRUE on success.
877 1.1 agc */
878 1.1 agc
879 1.1 agc boolean_t
880 1.1 agc register_event_handler(void)
881 1.1 agc {
882 1.1 agc ioctl(driver, ISCSI_REGISTER_EVENT, &event_reg);
883 1.1 agc return event_reg.event_id != 0;
884 1.1 agc }
885 1.1 agc
886 1.1 agc
887 1.1 agc /*
888 1.1 agc * deregister_event_handler:
889 1.1 agc * Call driver to deregister the event handler. If the event handler thread
890 1.1 agc * is waiting for an event, this will wake it up and cause it to exit.
891 1.1 agc */
892 1.1 agc
893 1.1 agc void
894 1.1 agc deregister_event_handler(void)
895 1.1 agc {
896 1.1 agc if (event_reg.event_id) {
897 1.1 agc ioctl(driver, ISCSI_DEREGISTER_EVENT, &event_reg);
898 1.1 agc event_reg.event_id = 0;
899 1.1 agc }
900 1.1 agc }
901 1.1 agc
902 1.1 agc
903 1.1 agc /*
904 1.1 agc * event_handler:
905 1.1 agc * Event handler thread. Wait for the driver to generate an event and
906 1.1 agc * process it appropriately. Exits when the driver terminates or the
907 1.1 agc * handler is deregistered because the daemon is terminating.
908 1.1 agc *
909 1.1 agc * Parameter:
910 1.1 agc * par Not used.
911 1.1 agc */
912 1.1 agc
913 1.1 agc void *
914 1.2 christos /*ARGSUSED*/
915 1.1 agc event_handler(void *par)
916 1.1 agc {
917 1.1 agc iscsi_wait_event_parameters_t evtp;
918 1.1 agc int rc;
919 1.1 agc
920 1.1 agc DEB(99, ("Event handler starts\n"));
921 1.1 agc (void) memset(&evtp, 0x0, sizeof(evtp));
922 1.1 agc
923 1.1 agc evtp.event_id = event_reg.event_id;
924 1.1 agc
925 1.1 agc do {
926 1.1 agc #ifndef ISCSI_NOTHREAD
927 1.1 agc rc = ioctl(driver, ISCSI_WAIT_EVENT, &evtp);
928 1.1 agc #else
929 1.1 agc rc = ioctl(driver, ISCSI_POLL_EVENT, &evtp);
930 1.1 agc #endif
931 1.1 agc if (rc || evtp.status)
932 1.1 agc break;
933 1.1 agc
934 1.1 agc DEB(1, ("Got Event: kind %d, status %d, sid %d, cid %d, reason %d\n",
935 1.1 agc evtp.event_kind, evtp.status, evtp.session_id,
936 1.1 agc evtp.connection_id, evtp.reason));
937 1.1 agc
938 1.1 agc switch (evtp.event_kind) {
939 1.1 agc case ISCSI_SESSION_TERMINATED:
940 1.1 agc event_kill_session(evtp.session_id);
941 1.1 agc break;
942 1.1 agc
943 1.1 agc case ISCSI_CONNECTION_TERMINATED:
944 1.1 agc event_kill_connection(evtp.session_id, evtp.connection_id);
945 1.1 agc break;
946 1.1 agc
947 1.1 agc case ISCSI_RECOVER_CONNECTION:
948 1.1 agc event_recover_connection(evtp.session_id, evtp.connection_id);
949 1.1 agc break;
950 1.1 agc
951 1.1 agc default:
952 1.1 agc break;
953 1.1 agc }
954 1.1 agc } while (evtp.event_kind != ISCSI_DRIVER_TERMINATING);
955 1.1 agc
956 1.1 agc #ifdef ISCSI_NOTHREAD
957 1.1 agc if (evtp.event_kind == ISCSI_DRIVER_TERMINATING)
958 1.1 agc #endif
959 1.1 agc exit_daemon();
960 1.1 agc
961 1.1 agc return NULL;
962 1.1 agc }
963 1.1 agc
964 1.1 agc #if 0
965 1.1 agc /*
966 1.1 agc * verify_connection:
967 1.1 agc * Verify that a specific connection still exists, delete it if not.
968 1.1 agc *
969 1.1 agc * Parameter: The connection pointer.
970 1.1 agc *
971 1.1 agc * Returns: The status returned by the driver.
972 1.1 agc */
973 1.1 agc
974 1.1 agc uint32_t
975 1.1 agc verify_connection(connection_t * conn)
976 1.1 agc {
977 1.1 agc iscsi_conn_status_parameters_t req;
978 1.1 agc session_t *sess = conn->session;
979 1.1 agc
980 1.1 agc req.connection_id = conn->entry.sid.id;
981 1.1 agc req.session_id = sess->entry.sid.id;
982 1.1 agc
983 1.1 agc ioctl(driver, ISCSI_CONNECTION_STATUS, &req);
984 1.1 agc
985 1.1 agc if (req.status) {
986 1.1 agc TAILQ_REMOVE(&sess->connections, &conn->entry, link);
987 1.1 agc sess->num_connections--;
988 1.1 agc free(conn);
989 1.1 agc }
990 1.1 agc DEB(9, ("Verify connection returns status %d\n", req.status));
991 1.1 agc return req.status;
992 1.1 agc }
993 1.1 agc
994 1.1 agc #endif
995