2 Unix SMB/CIFS implementation.
3 Connect to 445 and 139/nbsesssetup
4 Copyright (C) Volker Lendecke 2010
6 This program is free software; you can redistribute it and/or modify
7 it under the terms of the GNU General Public License as published by
8 the Free Software Foundation; either version 3 of the License, or
9 (at your option) any later version.
11 This program is distributed in the hope that it will be useful,
12 but WITHOUT ANY WARRANTY; without even the implied warranty of
13 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
14 GNU General Public License for more details.
16 You should have received a copy of the GNU General Public License
17 along with this program. If not, see <http://www.gnu.org/licenses/>.
21 #include "../lib/async_req/async_sock.h"
22 #include "async_smb.h"
24 struct nb_connect_state
{
25 struct tevent_context
*ev
;
26 const struct sockaddr_storage
*addr
;
27 const char *called_name
;
30 struct nmb_name called
;
31 struct nmb_name calling
;
34 static int nb_connect_state_destructor(struct nb_connect_state
*state
);
35 static void nb_connect_connected(struct tevent_req
*subreq
);
36 static void nb_connect_done(struct tevent_req
*subreq
);
38 static struct tevent_req
*nb_connect_send(TALLOC_CTX
*mem_ctx
,
39 struct tevent_context
*ev
,
40 const struct sockaddr_storage
*addr
,
41 const char *called_name
,
43 const char *calling_name
,
46 struct tevent_req
*req
, *subreq
;
47 struct nb_connect_state
*state
;
49 req
= tevent_req_create(mem_ctx
, &state
, struct nb_connect_state
);
54 state
->called_name
= called_name
;
58 make_nmb_name(&state
->called
, called_name
, called_type
);
59 make_nmb_name(&state
->calling
, calling_name
, calling_type
);
61 talloc_set_destructor(state
, nb_connect_state_destructor
);
63 subreq
= open_socket_out_send(state
, ev
, addr
, 139, 5000);
64 if (tevent_req_nomem(subreq
, req
)) {
65 return tevent_req_post(req
, ev
);
67 tevent_req_set_callback(subreq
, nb_connect_connected
, req
);
71 static int nb_connect_state_destructor(struct nb_connect_state
*state
)
73 if (state
->sock
!= -1) {
79 static void nb_connect_connected(struct tevent_req
*subreq
)
81 struct tevent_req
*req
= tevent_req_callback_data(
82 subreq
, struct tevent_req
);
83 struct nb_connect_state
*state
= tevent_req_data(
84 req
, struct nb_connect_state
);
87 status
= open_socket_out_recv(subreq
, &state
->sock
);
89 if (!NT_STATUS_IS_OK(status
)) {
90 tevent_req_nterror(req
, status
);
93 subreq
= cli_session_request_send(state
, state
->ev
, state
->sock
,
94 &state
->called
, &state
->calling
);
95 if (tevent_req_nomem(subreq
, req
)) {
98 tevent_req_set_callback(subreq
, nb_connect_done
, req
);
101 static void nb_connect_done(struct tevent_req
*subreq
)
103 struct tevent_req
*req
= tevent_req_callback_data(
104 subreq
, struct tevent_req
);
105 struct nb_connect_state
*state
= tevent_req_data(
106 req
, struct nb_connect_state
);
111 ret
= cli_session_request_recv(subreq
, &err
, &resp
);
114 tevent_req_nterror(req
, map_nt_error_from_unix(err
));
119 * RFC1002: 0x82 - POSITIVE SESSION RESPONSE
124 * The server did not like our session request
129 if (strequal(state
->called_name
, "*SMBSERVER")) {
131 * Here we could try a name status request and
132 * use the first 0x20 type name.
135 req
, NT_STATUS_RESOURCE_NAME_NOT_FOUND
);
140 * We could be subtle and distinguish between
141 * different failure modes, but what we do here
142 * instead is just retry with *SMBSERVER type 0x20.
144 state
->called_name
= "*SMBSERVER";
145 make_nmb_name(&state
->called
, state
->called_name
, 0x20);
147 subreq
= open_socket_out_send(state
, state
->ev
, state
->addr
,
149 if (tevent_req_nomem(subreq
, req
)) {
152 tevent_req_set_callback(subreq
, nb_connect_connected
, req
);
156 tevent_req_done(req
);
161 static NTSTATUS
nb_connect_recv(struct tevent_req
*req
, int *sock
)
163 struct nb_connect_state
*state
= tevent_req_data(
164 req
, struct nb_connect_state
);
167 if (tevent_req_is_nterror(req
, &status
)) {
175 struct smbsock_connect_state
{
176 struct tevent_context
*ev
;
177 const struct sockaddr_storage
*addr
;
178 const char *called_name
;
180 const char *calling_name
;
181 uint8_t calling_type
;
182 struct tevent_req
*req_139
;
183 struct tevent_req
*req_445
;
188 static int smbsock_connect_state_destructor(
189 struct smbsock_connect_state
*state
);
190 static void smbsock_connect_connected(struct tevent_req
*subreq
);
191 static void smbsock_connect_do_139(struct tevent_req
*subreq
);
193 struct tevent_req
*smbsock_connect_send(TALLOC_CTX
*mem_ctx
,
194 struct tevent_context
*ev
,
195 const struct sockaddr_storage
*addr
,
197 const char *called_name
,
199 const char *calling_name
,
202 struct tevent_req
*req
, *subreq
;
203 struct smbsock_connect_state
*state
;
205 req
= tevent_req_create(mem_ctx
, &state
, struct smbsock_connect_state
);
213 (called_name
!= NULL
) ? called_name
: "*SMBSERVER";
215 (called_type
!= -1) ? called_type
: 0x20;
216 state
->calling_name
=
217 (calling_name
!= NULL
) ? calling_name
: global_myname();
218 state
->calling_type
=
219 (calling_type
!= -1) ? calling_type
: 0x00;
221 talloc_set_destructor(state
, smbsock_connect_state_destructor
);
224 subreq
= tevent_wakeup_send(state
, ev
, timeval_set(0, 0));
225 if (tevent_req_nomem(subreq
, req
)) {
226 return tevent_req_post(req
, ev
);
228 tevent_req_set_callback(subreq
, smbsock_connect_do_139
, req
);
232 state
->req_445
= open_socket_out_send(state
, ev
, addr
, port
,
234 if (tevent_req_nomem(state
->req_445
, req
)) {
235 return tevent_req_post(req
, ev
);
237 tevent_req_set_callback(
238 state
->req_445
, smbsock_connect_connected
, req
);
246 state
->req_445
= open_socket_out_send(state
, ev
, addr
, 445, 5000);
247 if (tevent_req_nomem(state
->req_445
, req
)) {
248 return tevent_req_post(req
, ev
);
250 tevent_req_set_callback(state
->req_445
, smbsock_connect_connected
,
254 * After 5 msecs, fire the 139 request
256 state
->req_139
= tevent_wakeup_send(
257 state
, ev
, timeval_current_ofs(0, 5000));
258 if (tevent_req_nomem(state
->req_139
, req
)) {
259 TALLOC_FREE(state
->req_445
);
260 return tevent_req_post(req
, ev
);
262 tevent_req_set_callback(state
->req_139
, smbsock_connect_do_139
,
267 static int smbsock_connect_state_destructor(
268 struct smbsock_connect_state
*state
)
270 if (state
->sock
!= -1) {
276 static void smbsock_connect_do_139(struct tevent_req
*subreq
)
278 struct tevent_req
*req
= tevent_req_callback_data(
279 subreq
, struct tevent_req
);
280 struct smbsock_connect_state
*state
= tevent_req_data(
281 req
, struct smbsock_connect_state
);
284 ret
= tevent_wakeup_recv(subreq
);
287 tevent_req_nterror(req
, NT_STATUS_INTERNAL_ERROR
);
290 state
->req_139
= nb_connect_send(state
, state
->ev
, state
->addr
,
294 state
->calling_type
);
295 if (tevent_req_nomem(state
->req_139
, req
)) {
298 tevent_req_set_callback(state
->req_139
, smbsock_connect_connected
,
302 static void smbsock_connect_connected(struct tevent_req
*subreq
)
304 struct tevent_req
*req
= tevent_req_callback_data(
305 subreq
, struct tevent_req
);
306 struct smbsock_connect_state
*state
= tevent_req_data(
307 req
, struct smbsock_connect_state
);
308 struct tevent_req
*unfinished_req
;
311 if (subreq
== state
->req_445
) {
313 status
= open_socket_out_recv(subreq
, &state
->sock
);
314 TALLOC_FREE(state
->req_445
);
315 unfinished_req
= state
->req_139
;
318 } else if (subreq
== state
->req_139
) {
320 status
= nb_connect_recv(subreq
, &state
->sock
);
321 TALLOC_FREE(state
->req_139
);
322 unfinished_req
= state
->req_445
;
326 tevent_req_nterror(req
, NT_STATUS_INTERNAL_ERROR
);
330 if (NT_STATUS_IS_OK(status
)) {
331 TALLOC_FREE(unfinished_req
);
332 state
->req_139
= NULL
;
333 state
->req_445
= NULL
;
334 tevent_req_done(req
);
337 if (unfinished_req
== NULL
) {
339 * Both requests failed
341 tevent_req_nterror(req
, status
);
345 * Do nothing, wait for the second request to come here.
349 NTSTATUS
smbsock_connect_recv(struct tevent_req
*req
, int *sock
,
352 struct smbsock_connect_state
*state
= tevent_req_data(
353 req
, struct smbsock_connect_state
);
356 if (tevent_req_is_nterror(req
, &status
)) {
361 if (ret_port
!= NULL
) {
362 *ret_port
= state
->port
;
367 NTSTATUS
smbsock_connect(const struct sockaddr_storage
*addr
, uint16_t port
,
368 const char *called_name
, int called_type
,
369 const char *calling_name
, int calling_type
,
370 int *pfd
, uint16_t *ret_port
)
372 TALLOC_CTX
*frame
= talloc_stackframe();
373 struct event_context
*ev
;
374 struct tevent_req
*req
;
375 NTSTATUS status
= NT_STATUS_NO_MEMORY
;
377 ev
= event_context_init(frame
);
381 req
= smbsock_connect_send(frame
, ev
, addr
, port
,
382 called_name
, called_type
,
383 calling_name
, calling_type
);
387 if (!tevent_req_poll_ntstatus(req
, ev
, &status
)) {
390 status
= smbsock_connect_recv(req
, pfd
, ret_port
);
396 struct smbsock_any_connect_state
{
397 struct tevent_context
*ev
;
398 const struct sockaddr_storage
*addrs
;
399 const char **called_names
;
401 const char **calling_names
;
406 struct tevent_req
**requests
;
411 uint16_t chosen_port
;
415 static bool smbsock_any_connect_send_next(
416 struct tevent_req
*req
, struct smbsock_any_connect_state
*state
);
417 static void smbsock_any_connect_trynext(struct tevent_req
*subreq
);
418 static void smbsock_any_connect_connected(struct tevent_req
*subreq
);
420 struct tevent_req
*smbsock_any_connect_send(TALLOC_CTX
*mem_ctx
,
421 struct tevent_context
*ev
,
422 const struct sockaddr_storage
*addrs
,
423 const char **called_names
,
425 const char **calling_names
,
427 size_t num_addrs
, uint16_t port
)
429 struct tevent_req
*req
, *subreq
;
430 struct smbsock_any_connect_state
*state
;
432 req
= tevent_req_create(mem_ctx
, &state
,
433 struct smbsock_any_connect_state
);
438 state
->addrs
= addrs
;
439 state
->num_addrs
= num_addrs
;
440 state
->called_names
= called_names
;
441 state
->called_types
= called_types
;
442 state
->calling_names
= calling_names
;
443 state
->calling_types
= calling_types
;
446 if (num_addrs
== 0) {
447 tevent_req_nterror(req
, NT_STATUS_INVALID_PARAMETER
);
448 return tevent_req_post(req
, ev
);
451 state
->requests
= talloc_zero_array(state
, struct tevent_req
*,
453 if (tevent_req_nomem(state
->requests
, req
)) {
454 return tevent_req_post(req
, ev
);
456 if (!smbsock_any_connect_send_next(req
, state
)) {
457 return tevent_req_post(req
, ev
);
459 if (state
->num_sent
>= state
->num_addrs
) {
462 subreq
= tevent_wakeup_send(state
, ev
, timeval_current_ofs(0, 10000));
463 if (tevent_req_nomem(subreq
, req
)) {
464 return tevent_req_post(req
, ev
);
466 tevent_req_set_callback(subreq
, smbsock_any_connect_trynext
, req
);
470 static void smbsock_any_connect_trynext(struct tevent_req
*subreq
)
472 struct tevent_req
*req
= tevent_req_callback_data(
473 subreq
, struct tevent_req
);
474 struct smbsock_any_connect_state
*state
= tevent_req_data(
475 req
, struct smbsock_any_connect_state
);
478 ret
= tevent_wakeup_recv(subreq
);
481 tevent_req_nterror(req
, NT_STATUS_INTERNAL_ERROR
);
484 if (!smbsock_any_connect_send_next(req
, state
)) {
487 if (state
->num_sent
>= state
->num_addrs
) {
490 subreq
= tevent_wakeup_send(state
, state
->ev
,
491 tevent_timeval_set(0, 10000));
492 if (tevent_req_nomem(subreq
, req
)) {
495 tevent_req_set_callback(subreq
, smbsock_any_connect_trynext
, req
);
498 static bool smbsock_any_connect_send_next(
499 struct tevent_req
*req
, struct smbsock_any_connect_state
*state
)
501 struct tevent_req
*subreq
;
503 if (state
->num_sent
>= state
->num_addrs
) {
504 tevent_req_nterror(req
, NT_STATUS_INTERNAL_ERROR
);
507 subreq
= smbsock_connect_send(
508 state
->requests
, state
->ev
, &state
->addrs
[state
->num_sent
],
510 (state
->called_names
!= NULL
)
511 ? state
->called_names
[state
->num_sent
] : NULL
,
512 (state
->called_types
!= NULL
)
513 ? state
->called_types
[state
->num_sent
] : -1,
514 (state
->calling_names
!= NULL
)
515 ? state
->calling_names
[state
->num_sent
] : NULL
,
516 (state
->calling_types
!= NULL
)
517 ? state
->calling_types
[state
->num_sent
] : -1);
518 if (tevent_req_nomem(subreq
, req
)) {
521 tevent_req_set_callback(subreq
, smbsock_any_connect_connected
, req
);
523 state
->requests
[state
->num_sent
] = subreq
;
524 state
->num_sent
+= 1;
529 static void smbsock_any_connect_connected(struct tevent_req
*subreq
)
531 struct tevent_req
*req
= tevent_req_callback_data(
532 subreq
, struct tevent_req
);
533 struct smbsock_any_connect_state
*state
= tevent_req_data(
534 req
, struct smbsock_any_connect_state
);
537 uint16_t chosen_port
;
539 size_t chosen_index
= 0;
541 for (i
=0; i
<state
->num_sent
; i
++) {
542 if (state
->requests
[i
] == subreq
) {
547 if (i
== state
->num_sent
) {
548 tevent_req_nterror(req
, NT_STATUS_INTERNAL_ERROR
);
552 status
= smbsock_connect_recv(subreq
, &fd
, &chosen_port
);
555 state
->requests
[chosen_index
] = NULL
;
557 if (NT_STATUS_IS_OK(status
)) {
559 * This will kill all the other requests
561 TALLOC_FREE(state
->requests
);
563 state
->chosen_port
= chosen_port
;
564 state
->chosen_index
= chosen_index
;
565 tevent_req_done(req
);
569 state
->num_received
+= 1;
570 if (state
->num_received
<= state
->num_addrs
) {
572 * More addrs pending, wait for the others
578 * This is the last response, none succeeded.
580 tevent_req_nterror(req
, status
);
584 NTSTATUS
smbsock_any_connect_recv(struct tevent_req
*req
, int *pfd
,
585 size_t *chosen_index
,
586 uint16_t *chosen_port
)
588 struct smbsock_any_connect_state
*state
= tevent_req_data(
589 req
, struct smbsock_any_connect_state
);
592 if (tevent_req_is_nterror(req
, &status
)) {
596 if (chosen_index
!= NULL
) {
597 *chosen_index
= state
->chosen_index
;
599 if (chosen_port
!= NULL
) {
600 *chosen_port
= state
->chosen_port
;
605 NTSTATUS
smbsock_any_connect(const struct sockaddr_storage
*addrs
,
606 const char **called_names
,
608 const char **calling_names
,
612 int *pfd
, size_t *chosen_index
,
613 uint16_t *chosen_port
)
615 TALLOC_CTX
*frame
= talloc_stackframe();
616 struct event_context
*ev
;
617 struct tevent_req
*req
;
618 NTSTATUS status
= NT_STATUS_NO_MEMORY
;
620 ev
= event_context_init(frame
);
624 req
= smbsock_any_connect_send(frame
, ev
, addrs
,
625 called_names
, called_types
,
626 calling_names
, calling_types
,
631 if (!tevent_req_poll_ntstatus(req
, ev
, &status
)) {
634 status
= smbsock_any_connect_recv(req
, pfd
, chosen_index
, chosen_port
);