s3:libsmb: move cli->cnum to cli->smb1.tid and hide it behind cli_state_[g|s]et_tid()
[nivanova/samba-autobuild/.git] / source3 / libsmb / libsmb_server.c
1 /* 
2    Unix SMB/Netbios implementation.
3    SMB client library implementation
4    Copyright (C) Andrew Tridgell 1998
5    Copyright (C) Richard Sharpe 2000, 2002
6    Copyright (C) John Terpstra 2000
7    Copyright (C) Tom Jansen (Ninja ISD) 2002 
8    Copyright (C) Derrell Lipman 2003-2008
9    Copyright (C) Jeremy Allison 2007, 2008
10    Copyright (C) SATOH Fumiyasu <fumiyas@osstech.co.jp> 2009.
11
12    This program is free software; you can redistribute it and/or modify
13    it under the terms of the GNU General Public License as published by
14    the Free Software Foundation; either version 3 of the License, or
15    (at your option) any later version.
16
17    This program is distributed in the hope that it will be useful,
18    but WITHOUT ANY WARRANTY; without even the implied warranty of
19    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
20    GNU General Public License for more details.
21
22    You should have received a copy of the GNU General Public License
23    along with this program.  If not, see <http://www.gnu.org/licenses/>.
24 */
25
26 #include "includes.h"
27 #include "libsmb/libsmb.h"
28 #include "libsmbclient.h"
29 #include "libsmb_internal.h"
30 #include "../librpc/gen_ndr/ndr_lsa.h"
31 #include "rpc_client/cli_pipe.h"
32 #include "rpc_client/cli_lsarpc.h"
33 #include "libcli/security/security.h"
34 #include "libsmb/nmblib.h"
35
36 /* 
37  * Check a server for being alive and well.
38  * returns 0 if the server is in shape. Returns 1 on error 
39  * 
40  * Also useable outside libsmbclient to enable external cache
41  * to do some checks too.
42  */
43 int
44 SMBC_check_server(SMBCCTX * context,
45                   SMBCSRV * server) 
46 {
47         if (!cli_state_is_connected(server->cli)) {
48                 return 1;
49         }
50
51         return 0;
52 }
53
54 /* 
55  * Remove a server from the cached server list it's unused.
56  * On success, 0 is returned. 1 is returned if the server could not be removed.
57  * 
58  * Also useable outside libsmbclient
59  */
60 int
61 SMBC_remove_unused_server(SMBCCTX * context,
62                           SMBCSRV * srv)
63 {
64         SMBCFILE * file;
65
66         /* are we being fooled ? */
67         if (!context || !context->internal->initialized || !srv) {
68                 return 1;
69         }
70
71         /* Check all open files/directories for a relation with this server */
72         for (file = context->internal->files; file; file = file->next) {
73                 if (file->srv == srv) {
74                         /* Still used */
75                         DEBUG(3, ("smbc_remove_usused_server: "
76                                   "%p still used by %p.\n",
77                                   srv, file));
78                         return 1;
79                 }
80         }
81
82         DLIST_REMOVE(context->internal->servers, srv);
83
84         cli_shutdown(srv->cli);
85         srv->cli = NULL;
86
87         DEBUG(3, ("smbc_remove_usused_server: %p removed.\n", srv));
88
89         smbc_getFunctionRemoveCachedServer(context)(context, srv);
90
91         SAFE_FREE(srv);
92         return 0;
93 }
94
95 /****************************************************************
96  * Call the auth_fn with fixed size (fstring) buffers.
97  ***************************************************************/
98 void
99 SMBC_call_auth_fn(TALLOC_CTX *ctx,
100                   SMBCCTX *context,
101                   const char *server,
102                   const char *share,
103                   char **pp_workgroup,
104                   char **pp_username,
105                   char **pp_password)
106 {
107         fstring workgroup;
108         fstring username;
109         fstring password;
110         smbc_get_auth_data_with_context_fn auth_with_context_fn;
111
112         strlcpy(workgroup, *pp_workgroup, sizeof(workgroup));
113         strlcpy(username, *pp_username, sizeof(username));
114         strlcpy(password, *pp_password, sizeof(password));
115
116         /* See if there's an authentication with context function provided */
117         auth_with_context_fn = smbc_getFunctionAuthDataWithContext(context);
118         if (auth_with_context_fn)
119         {
120             (* auth_with_context_fn)(context,
121                                      server, share,
122                                      workgroup, sizeof(workgroup),
123                                      username, sizeof(username),
124                                      password, sizeof(password));
125         }
126         else
127         {
128             smbc_getFunctionAuthData(context)(server, share,
129                                               workgroup, sizeof(workgroup),
130                                               username, sizeof(username),
131                                               password, sizeof(password));
132         }
133
134         TALLOC_FREE(*pp_workgroup);
135         TALLOC_FREE(*pp_username);
136         TALLOC_FREE(*pp_password);
137
138         *pp_workgroup = talloc_strdup(ctx, workgroup);
139         *pp_username = talloc_strdup(ctx, username);
140         *pp_password = talloc_strdup(ctx, password);
141 }
142
143
144 void
145 SMBC_get_auth_data(const char *server, const char *share,
146                    char *workgroup_buf, int workgroup_buf_len,
147                    char *username_buf, int username_buf_len,
148                    char *password_buf, int password_buf_len)
149 {
150         /* Default function just uses provided data.  Nothing to do. */
151 }
152
153
154
155 SMBCSRV *
156 SMBC_find_server(TALLOC_CTX *ctx,
157                  SMBCCTX *context,
158                  const char *server,
159                  const char *share,
160                  char **pp_workgroup,
161                  char **pp_username,
162                  char **pp_password)
163 {
164         SMBCSRV *srv;
165         int auth_called = 0;
166
167         if (!pp_workgroup || !pp_username || !pp_password) {
168                 return NULL;
169         }
170
171 check_server_cache:
172
173         srv = smbc_getFunctionGetCachedServer(context)(context,
174                                                        server, share,
175                                                        *pp_workgroup,
176                                                        *pp_username);
177
178         if (!auth_called && !srv && (!*pp_username || !(*pp_username)[0] ||
179                                      !*pp_password || !(*pp_password)[0])) {
180                 SMBC_call_auth_fn(ctx, context, server, share,
181                                   pp_workgroup, pp_username, pp_password);
182
183                 /*
184                  * However, smbc_auth_fn may have picked up info relating to
185                  * an existing connection, so try for an existing connection
186                  * again ...
187                  */
188                 auth_called = 1;
189                 goto check_server_cache;
190
191         }
192
193         if (srv) {
194                 if (smbc_getFunctionCheckServer(context)(context, srv)) {
195                         /*
196                          * This server is no good anymore
197                          * Try to remove it and check for more possible
198                          * servers in the cache
199                          */
200                         if (smbc_getFunctionRemoveUnusedServer(context)(context,
201                                                                         srv)) { 
202                                 /*
203                                  * We could not remove the server completely,
204                                  * remove it from the cache so we will not get
205                                  * it again. It will be removed when the last
206                                  * file/dir is closed.
207                                  */
208                                 smbc_getFunctionRemoveCachedServer(context)(context,
209                                                                             srv);
210                         }
211
212                         /*
213                          * Maybe there are more cached connections to this
214                          * server
215                          */
216                         goto check_server_cache;
217                 }
218
219                 return srv;
220         }
221
222         return NULL;
223 }
224
225 /*
226  * Connect to a server, possibly on an existing connection
227  *
228  * Here, what we want to do is: If the server and username
229  * match an existing connection, reuse that, otherwise, establish a
230  * new connection.
231  *
232  * If we have to create a new connection, call the auth_fn to get the
233  * info we need, unless the username and password were passed in.
234  */
235
236 static SMBCSRV *
237 SMBC_server_internal(TALLOC_CTX *ctx,
238             SMBCCTX *context,
239             bool connect_if_not_found,
240             const char *server,
241             const char *share,
242             char **pp_workgroup,
243             char **pp_username,
244             char **pp_password,
245             bool *in_cache)
246 {
247         SMBCSRV *srv=NULL;
248         char *workgroup = NULL;
249         struct cli_state *c = NULL;
250         const char *server_n = server;
251         int is_ipc = (share != NULL && strcmp(share, "IPC$") == 0);
252         uint32 fs_attrs = 0;
253         const char *username_used;
254         NTSTATUS status;
255         char *newserver, *newshare;
256
257         ZERO_STRUCT(c);
258         *in_cache = false;
259
260         if (server[0] == 0) {
261                 errno = EPERM;
262                 return NULL;
263         }
264
265         /* Look for a cached connection */
266         srv = SMBC_find_server(ctx, context, server, share,
267                                pp_workgroup, pp_username, pp_password);
268
269         /*
270          * If we found a connection and we're only allowed one share per
271          * server...
272          */
273         if (srv &&
274             *share != '\0' &&
275             smbc_getOptionOneSharePerServer(context)) {
276
277                 /*
278                  * ... then if there's no current connection to the share,
279                  * connect to it.  SMBC_find_server(), or rather the function
280                  * pointed to by context->get_cached_srv_fn which
281                  * was called by SMBC_find_server(), will have issued a tree
282                  * disconnect if the requested share is not the same as the
283                  * one that was already connected.
284                  */
285
286                 /*
287                  * Use srv->cli->desthost and srv->cli->share instead of
288                  * server and share below to connect to the actual share,
289                  * i.e., a normal share or a referred share from
290                  * 'msdfs proxy' share.
291                  */
292                 if (!cli_state_has_tcon(srv->cli)) {
293                         /* Ensure we have accurate auth info */
294                         SMBC_call_auth_fn(ctx, context,
295                                           srv->cli->desthost,
296                                           srv->cli->share,
297                                           pp_workgroup,
298                                           pp_username,
299                                           pp_password);
300
301                         if (!*pp_workgroup || !*pp_username || !*pp_password) {
302                                 errno = ENOMEM;
303                                 cli_shutdown(srv->cli);
304                                 srv->cli = NULL;
305                                 smbc_getFunctionRemoveCachedServer(context)(context,
306                                                                             srv);
307                                 return NULL;
308                         }
309
310                         /*
311                          * We don't need to renegotiate encryption
312                          * here as the encryption context is not per
313                          * tid.
314                          */
315
316                         status = cli_tcon_andx(srv->cli, srv->cli->share, "?????",
317                                                *pp_password,
318                                                strlen(*pp_password)+1);
319                         if (!NT_STATUS_IS_OK(status)) {
320                                 errno = map_errno_from_nt_status(status);
321                                 cli_shutdown(srv->cli);
322                                 srv->cli = NULL;
323                                 smbc_getFunctionRemoveCachedServer(context)(context,
324                                                                             srv);
325                                 srv = NULL;
326                         }
327
328                         /* Determine if this share supports case sensitivity */
329                         if (is_ipc) {
330                                 DEBUG(4,
331                                       ("IPC$ so ignore case sensitivity\n"));
332                                 status = NT_STATUS_OK;
333                         } else {
334                                 status = cli_get_fs_attr_info(c, &fs_attrs);
335                         }
336
337                         if (!NT_STATUS_IS_OK(status)) {
338                                 DEBUG(4, ("Could not retrieve "
339                                           "case sensitivity flag: %s.\n",
340                                           nt_errstr(status)));
341
342                                 /*
343                                  * We can't determine the case sensitivity of
344                                  * the share. We have no choice but to use the
345                                  * user-specified case sensitivity setting.
346                                  */
347                                 if (smbc_getOptionCaseSensitive(context)) {
348                                         cli_set_case_sensitive(c, True);
349                                 } else {
350                                         cli_set_case_sensitive(c, False);
351                                 }
352                         } else if (!is_ipc) {
353                                 DEBUG(4,
354                                       ("Case sensitive: %s\n",
355                                        (fs_attrs & FILE_CASE_SENSITIVE_SEARCH
356                                         ? "True"
357                                         : "False")));
358                                 cli_set_case_sensitive(
359                                         c,
360                                         (fs_attrs & FILE_CASE_SENSITIVE_SEARCH
361                                          ? True
362                                          : False));
363                         }
364
365                         /*
366                          * Regenerate the dev value since it's based on both
367                          * server and share
368                          */
369                         if (srv) {
370                                 srv->dev = (dev_t)(str_checksum(srv->cli->desthost) ^
371                                                    str_checksum(srv->cli->share));
372                         }
373                 }
374         }
375
376         /* If we have a connection... */
377         if (srv) {
378
379                 /* ... then we're done here.  Give 'em what they came for. */
380                 *in_cache = true;
381                 goto done;
382         }
383
384         /* If we're not asked to connect when a connection doesn't exist... */
385         if (! connect_if_not_found) {
386                 /* ... then we're done here. */
387                 return NULL;
388         }
389
390         if (!*pp_workgroup || !*pp_username || !*pp_password) {
391                 errno = ENOMEM;
392                 return NULL;
393         }
394
395         DEBUG(4,("SMBC_server: server_n=[%s] server=[%s]\n", server_n, server));
396
397         DEBUG(4,(" -> server_n=[%s] server=[%s]\n", server_n, server));
398
399         status = NT_STATUS_UNSUCCESSFUL;
400
401         if (share == NULL || *share == '\0' || is_ipc) {
402                 /*
403                  * Try 139 first for IPC$
404                  */
405                 status = cli_connect_nb(server_n, NULL, 139, 0x20,
406                                         smbc_getNetbiosName(context),
407                                         Undefined, &c);
408         }
409
410         if (!NT_STATUS_IS_OK(status)) {
411                 /*
412                  * No IPC$ or 139 did not work
413                  */
414                 status = cli_connect_nb(server_n, NULL, 0, 0x20,
415                                         smbc_getNetbiosName(context),
416                                         Undefined, &c);
417         }
418
419         if (!NT_STATUS_IS_OK(status)) {
420                 errno = map_errno_from_nt_status(status);
421                 return NULL;
422         }
423
424         if (smbc_getOptionUseKerberos(context)) {
425                 c->use_kerberos = True;
426         }
427
428         if (smbc_getOptionFallbackAfterKerberos(context)) {
429                 c->fallback_after_kerberos = True;
430         }
431
432         if (smbc_getOptionUseCCache(context)) {
433                 c->use_ccache = True;
434         }
435
436         c->timeout = smbc_getTimeout(context);
437
438         status = cli_negprot(c);
439
440         if (!NT_STATUS_IS_OK(status)) {
441                 cli_shutdown(c);
442                 errno = ETIMEDOUT;
443                 return NULL;
444         }
445
446         username_used = *pp_username;
447
448         if (!NT_STATUS_IS_OK(cli_session_setup(c, username_used,
449                                                *pp_password,
450                                                strlen(*pp_password),
451                                                *pp_password,
452                                                strlen(*pp_password),
453                                                *pp_workgroup))) {
454
455                 /* Failed.  Try an anonymous login, if allowed by flags. */
456                 username_used = "";
457
458                 if (smbc_getOptionNoAutoAnonymousLogin(context) ||
459                     !NT_STATUS_IS_OK(cli_session_setup(c, username_used,
460                                                        *pp_password, 1,
461                                                        *pp_password, 0,
462                                                        *pp_workgroup))) {
463
464                         cli_shutdown(c);
465                         errno = EPERM;
466                         return NULL;
467                 }
468         }
469
470         status = cli_init_creds(c, username_used,
471                                 *pp_workgroup, *pp_password);
472         if (!NT_STATUS_IS_OK(status)) {
473                 errno = map_errno_from_nt_status(status);
474                 cli_shutdown(c);
475                 return NULL;
476         }
477
478         DEBUG(4,(" session setup ok\n"));
479
480         /* here's the fun part....to support 'msdfs proxy' shares
481            (on Samba or windows) we have to issues a TRANS_GET_DFS_REFERRAL
482            here before trying to connect to the original share.
483            cli_check_msdfs_proxy() will fail if it is a normal share. */
484
485         if ((c->capabilities & CAP_DFS) &&
486                         cli_check_msdfs_proxy(ctx, c, share,
487                                 &newserver, &newshare,
488                                 /* FIXME: cli_check_msdfs_proxy() does
489                                    not support smbc_smb_encrypt_level type */
490                                 context->internal->smb_encryption_level ?
491                                         true : false,
492                                 *pp_username,
493                                 *pp_password,
494                                 *pp_workgroup)) {
495                 cli_shutdown(c);
496                 srv = SMBC_server_internal(ctx, context, connect_if_not_found,
497                                 newserver, newshare, pp_workgroup,
498                                 pp_username, pp_password, in_cache);
499                 TALLOC_FREE(newserver);
500                 TALLOC_FREE(newshare);
501                 return srv;
502         }
503
504         /* must be a normal share */
505
506         status = cli_tcon_andx(c, share, "?????", *pp_password,
507                                strlen(*pp_password)+1);
508         if (!NT_STATUS_IS_OK(status)) {
509                 errno = map_errno_from_nt_status(status);
510                 cli_shutdown(c);
511                 return NULL;
512         }
513
514         DEBUG(4,(" tconx ok\n"));
515
516         /* Determine if this share supports case sensitivity */
517         if (is_ipc) {
518                 DEBUG(4, ("IPC$ so ignore case sensitivity\n"));
519                 status = NT_STATUS_OK;
520         } else {
521                 status = cli_get_fs_attr_info(c, &fs_attrs);
522         }
523
524         if (!NT_STATUS_IS_OK(status)) {
525                 DEBUG(4, ("Could not retrieve case sensitivity flag: %s.\n",
526                           nt_errstr(status)));
527
528                 /*
529                  * We can't determine the case sensitivity of the share. We
530                  * have no choice but to use the user-specified case
531                  * sensitivity setting.
532                  */
533                 if (smbc_getOptionCaseSensitive(context)) {
534                         cli_set_case_sensitive(c, True);
535                 } else {
536                         cli_set_case_sensitive(c, False);
537                 }
538         } else if (!is_ipc) {
539                 DEBUG(4, ("Case sensitive: %s\n",
540                           (fs_attrs & FILE_CASE_SENSITIVE_SEARCH
541                            ? "True"
542                            : "False")));
543                 cli_set_case_sensitive(c,
544                                        (fs_attrs & FILE_CASE_SENSITIVE_SEARCH
545                                         ? True
546                                         : False));
547         }
548
549         if (context->internal->smb_encryption_level) {
550                 /* Attempt UNIX smb encryption. */
551                 if (!NT_STATUS_IS_OK(cli_force_encryption(c,
552                                                           username_used,
553                                                           *pp_password,
554                                                           *pp_workgroup))) {
555
556                         /*
557                          * context->smb_encryption_level == 1
558                          * means don't fail if encryption can't be negotiated,
559                          * == 2 means fail if encryption can't be negotiated.
560                          */
561
562                         DEBUG(4,(" SMB encrypt failed\n"));
563
564                         if (context->internal->smb_encryption_level == 2) {
565                                 cli_shutdown(c);
566                                 errno = EPERM;
567                                 return NULL;
568                         }
569                 }
570                 DEBUG(4,(" SMB encrypt ok\n"));
571         }
572
573         /*
574          * Ok, we have got a nice connection
575          * Let's allocate a server structure.
576          */
577
578         srv = SMB_MALLOC_P(SMBCSRV);
579         if (!srv) {
580                 cli_shutdown(c);
581                 errno = ENOMEM;
582                 return NULL;
583         }
584
585         ZERO_STRUCTP(srv);
586         srv->cli = c;
587         srv->dev = (dev_t)(str_checksum(server) ^ str_checksum(share));
588         srv->no_pathinfo = False;
589         srv->no_pathinfo2 = False;
590         srv->no_nt_session = False;
591
592 done:
593         if (!pp_workgroup || !*pp_workgroup || !**pp_workgroup) {
594                 workgroup = talloc_strdup(ctx, smbc_getWorkgroup(context));
595         } else {
596                 workgroup = *pp_workgroup;
597         }
598         if(!workgroup) {
599                 if (c != NULL) {
600                         cli_shutdown(c);
601                 }
602                 SAFE_FREE(srv);
603                 return NULL;
604         }
605
606         /* set the credentials to make DFS work */
607         smbc_set_credentials_with_fallback(context,
608                                            workgroup,
609                                            *pp_username,
610                                            *pp_password);
611
612         return srv;
613 }
614
615 SMBCSRV *
616 SMBC_server(TALLOC_CTX *ctx,
617                 SMBCCTX *context,
618                 bool connect_if_not_found,
619                 const char *server,
620                 const char *share,
621                 char **pp_workgroup,
622                 char **pp_username,
623                 char **pp_password)
624 {
625         SMBCSRV *srv=NULL;
626         bool in_cache = false;
627
628         srv = SMBC_server_internal(ctx, context, connect_if_not_found,
629                         server, share, pp_workgroup,
630                         pp_username, pp_password, &in_cache);
631
632         if (!srv) {
633                 return NULL;
634         }
635         if (in_cache) {
636                 return srv;
637         }
638
639         /* Now add it to the cache (internal or external)  */
640         /* Let the cache function set errno if it wants to */
641         errno = 0;
642         if (smbc_getFunctionAddCachedServer(context)(context, srv,
643                                                 server, share,
644                                                 *pp_workgroup,
645                                                 *pp_username)) {
646                 int saved_errno = errno;
647                 DEBUG(3, (" Failed to add server to cache\n"));
648                 errno = saved_errno;
649                 if (errno == 0) {
650                         errno = ENOMEM;
651                 }
652                 SAFE_FREE(srv);
653                 return NULL;
654         }
655
656         DEBUG(2, ("Server connect ok: //%s/%s: %p\n",
657                 server, share, srv));
658
659         DLIST_ADD(context->internal->servers, srv);
660         return srv;
661 }
662
663 /*
664  * Connect to a server for getting/setting attributes, possibly on an existing
665  * connection.  This works similarly to SMBC_server().
666  */
667 SMBCSRV *
668 SMBC_attr_server(TALLOC_CTX *ctx,
669                  SMBCCTX *context,
670                  const char *server,
671                  const char *share,
672                  char **pp_workgroup,
673                  char **pp_username,
674                  char **pp_password)
675 {
676         int flags;
677         struct sockaddr_storage ss;
678         struct cli_state *ipc_cli = NULL;
679         struct rpc_pipe_client *pipe_hnd = NULL;
680         NTSTATUS nt_status;
681         SMBCSRV *srv=NULL;
682         SMBCSRV *ipc_srv=NULL;
683
684         /*
685          * Use srv->cli->desthost and srv->cli->share instead of
686          * server and share below to connect to the actual share,
687          * i.e., a normal share or a referred share from
688          * 'msdfs proxy' share.
689          */
690         srv = SMBC_server(ctx, context, true, server, share,
691                         pp_workgroup, pp_username, pp_password);
692         if (!srv) {
693                 return NULL;
694         }
695         server = srv->cli->desthost;
696         share = srv->cli->share;
697
698         /*
699          * See if we've already created this special connection.  Reference
700          * our "special" share name '*IPC$', which is an impossible real share
701          * name due to the leading asterisk.
702          */
703         ipc_srv = SMBC_find_server(ctx, context, server, "*IPC$",
704                                    pp_workgroup, pp_username, pp_password);
705         if (!ipc_srv) {
706
707                 /* We didn't find a cached connection.  Get the password */
708                 if (!*pp_password || (*pp_password)[0] == '\0') {
709                         /* ... then retrieve it now. */
710                         SMBC_call_auth_fn(ctx, context, server, share,
711                                           pp_workgroup,
712                                           pp_username,
713                                           pp_password);
714                         if (!*pp_workgroup || !*pp_username || !*pp_password) {
715                                 errno = ENOMEM;
716                                 return NULL;
717                         }
718                 }
719
720                 flags = 0;
721                 if (smbc_getOptionUseKerberos(context)) {
722                         flags |= CLI_FULL_CONNECTION_USE_KERBEROS;
723                 }
724                 if (smbc_getOptionUseCCache(context)) {
725                         flags |= CLI_FULL_CONNECTION_USE_CCACHE;
726                 }
727
728                 zero_sockaddr(&ss);
729                 nt_status = cli_full_connection(&ipc_cli,
730                                                 lp_netbios_name(), server,
731                                                 &ss, 0, "IPC$", "?????",
732                                                 *pp_username,
733                                                 *pp_workgroup,
734                                                 *pp_password,
735                                                 flags,
736                                                 Undefined);
737                 if (! NT_STATUS_IS_OK(nt_status)) {
738                         DEBUG(1,("cli_full_connection failed! (%s)\n",
739                                  nt_errstr(nt_status)));
740                         errno = ENOTSUP;
741                         return NULL;
742                 }
743
744                 if (context->internal->smb_encryption_level) {
745                         /* Attempt UNIX smb encryption. */
746                         if (!NT_STATUS_IS_OK(cli_force_encryption(ipc_cli,
747                                                                   *pp_username,
748                                                                   *pp_password,
749                                                                   *pp_workgroup))) {
750
751                                 /*
752                                  * context->smb_encryption_level ==
753                                  * 1 means don't fail if encryption can't be
754                                  * negotiated, == 2 means fail if encryption
755                                  * can't be negotiated.
756                                  */
757
758                                 DEBUG(4,(" SMB encrypt failed on IPC$\n"));
759
760                                 if (context->internal->smb_encryption_level == 2) {
761                                         cli_shutdown(ipc_cli);
762                                         errno = EPERM;
763                                         return NULL;
764                                 }
765                         }
766                         DEBUG(4,(" SMB encrypt ok on IPC$\n"));
767                 }
768
769                 ipc_srv = SMB_MALLOC_P(SMBCSRV);
770                 if (!ipc_srv) {
771                         errno = ENOMEM;
772                         cli_shutdown(ipc_cli);
773                         return NULL;
774                 }
775
776                 ZERO_STRUCTP(ipc_srv);
777                 ipc_srv->cli = ipc_cli;
778
779                 nt_status = cli_rpc_pipe_open_noauth(
780                         ipc_srv->cli, &ndr_table_lsarpc.syntax_id, &pipe_hnd);
781                 if (!NT_STATUS_IS_OK(nt_status)) {
782                         DEBUG(1, ("cli_nt_session_open fail!\n"));
783                         errno = ENOTSUP;
784                         cli_shutdown(ipc_srv->cli);
785                         free(ipc_srv);
786                         return NULL;
787                 }
788
789                 /*
790                  * Some systems don't support
791                  * SEC_FLAG_MAXIMUM_ALLOWED, but NT sends 0x2000000
792                  * so we might as well do it too.
793                  */
794
795                 nt_status = rpccli_lsa_open_policy(
796                         pipe_hnd,
797                         talloc_tos(),
798                         True,
799                         GENERIC_EXECUTE_ACCESS,
800                         &ipc_srv->pol);
801
802                 if (!NT_STATUS_IS_OK(nt_status)) {
803                         errno = SMBC_errno(context, ipc_srv->cli);
804                         cli_shutdown(ipc_srv->cli);
805                         return NULL;
806                 }
807
808                 /* now add it to the cache (internal or external) */
809
810                 errno = 0;      /* let cache function set errno if it likes */
811                 if (smbc_getFunctionAddCachedServer(context)(context, ipc_srv,
812                                                              server,
813                                                              "*IPC$",
814                                                              *pp_workgroup,
815                                                              *pp_username)) {
816                         DEBUG(3, (" Failed to add server to cache\n"));
817                         if (errno == 0) {
818                                 errno = ENOMEM;
819                         }
820                         cli_shutdown(ipc_srv->cli);
821                         free(ipc_srv);
822                         return NULL;
823                 }
824
825                 DLIST_ADD(context->internal->servers, ipc_srv);
826         }
827
828         return ipc_srv;
829 }