asys: Allow multiple results to be received
[Samba.git] / source3 / winbindd / winbindd_msrpc.c
blob426d64cf1f930166f3cac5d85e596888d29c8abb
1 /*
2 Unix SMB/CIFS implementation.
4 Winbind rpc backend functions
6 Copyright (C) Tim Potter 2000-2001,2003
7 Copyright (C) Andrew Tridgell 2001
8 Copyright (C) Volker Lendecke 2005
9 Copyright (C) Guenther Deschner 2008 (pidl conversion)
11 This program is free software; you can redistribute it and/or modify
12 it under the terms of the GNU General Public License as published by
13 the Free Software Foundation; either version 3 of the License, or
14 (at your option) any later version.
16 This program is distributed in the hope that it will be useful,
17 but WITHOUT ANY WARRANTY; without even the implied warranty of
18 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
19 GNU General Public License for more details.
21 You should have received a copy of the GNU General Public License
22 along with this program. If not, see <http://www.gnu.org/licenses/>.
25 #include "includes.h"
26 #include "winbindd.h"
27 #include "winbindd_rpc.h"
29 #include "../librpc/gen_ndr/ndr_samr_c.h"
30 #include "rpc_client/cli_pipe.h"
31 #include "rpc_client/cli_samr.h"
32 #include "rpc_client/cli_lsarpc.h"
33 #include "../libcli/security/security.h"
35 #undef DBGC_CLASS
36 #define DBGC_CLASS DBGC_WINBIND
38 static NTSTATUS winbindd_lookup_names(TALLOC_CTX *mem_ctx,
39 struct winbindd_domain *domain,
40 uint32_t num_names,
41 const char **names,
42 const char ***domains,
43 struct dom_sid **sids,
44 enum lsa_SidType **types);
46 /* Query display info for a domain. This returns enough information plus a
47 bit extra to give an overview of domain users for the User Manager
48 application. */
49 static NTSTATUS msrpc_query_user_list(struct winbindd_domain *domain,
50 TALLOC_CTX *mem_ctx,
51 uint32_t *pnum_info,
52 struct wbint_userinfo **pinfo)
54 struct rpc_pipe_client *samr_pipe = NULL;
55 struct policy_handle dom_pol;
56 struct wbint_userinfo *info = NULL;
57 uint32_t num_info = 0;
58 TALLOC_CTX *tmp_ctx;
59 NTSTATUS status;
61 DEBUG(3, ("msrpc_query_user_list\n"));
63 if (pnum_info) {
64 *pnum_info = 0;
67 tmp_ctx = talloc_stackframe();
68 if (tmp_ctx == NULL) {
69 return NT_STATUS_NO_MEMORY;
72 if ( !winbindd_can_contact_domain( domain ) ) {
73 DEBUG(10,("query_user_list: No incoming trust for domain %s\n",
74 domain->name));
75 status = NT_STATUS_OK;
76 goto done;
79 status = cm_connect_sam(domain, tmp_ctx, &samr_pipe, &dom_pol);
80 if (!NT_STATUS_IS_OK(status)) {
81 goto done;
84 status = rpc_query_user_list(tmp_ctx,
85 samr_pipe,
86 &dom_pol,
87 &domain->sid,
88 &num_info,
89 &info);
90 if (!NT_STATUS_IS_OK(status)) {
91 goto done;
94 if (pnum_info) {
95 *pnum_info = num_info;
98 if (pinfo) {
99 *pinfo = talloc_move(mem_ctx, &info);
102 done:
103 TALLOC_FREE(tmp_ctx);
104 return status;
107 /* list all domain groups */
108 static NTSTATUS msrpc_enum_dom_groups(struct winbindd_domain *domain,
109 TALLOC_CTX *mem_ctx,
110 uint32_t *pnum_info,
111 struct wb_acct_info **pinfo)
113 struct rpc_pipe_client *samr_pipe;
114 struct policy_handle dom_pol;
115 struct wb_acct_info *info = NULL;
116 uint32_t num_info = 0;
117 TALLOC_CTX *tmp_ctx;
118 NTSTATUS status;
120 DEBUG(3,("msrpc_enum_dom_groups\n"));
122 if (pnum_info) {
123 *pnum_info = 0;
126 tmp_ctx = talloc_stackframe();
127 if (tmp_ctx == NULL) {
128 return NT_STATUS_NO_MEMORY;
131 if ( !winbindd_can_contact_domain( domain ) ) {
132 DEBUG(10,("enum_domain_groups: No incoming trust for domain %s\n",
133 domain->name));
134 status = NT_STATUS_OK;
135 goto done;
138 status = cm_connect_sam(domain, tmp_ctx, &samr_pipe, &dom_pol);
139 if (!NT_STATUS_IS_OK(status)) {
140 goto done;
143 status = rpc_enum_dom_groups(tmp_ctx,
144 samr_pipe,
145 &dom_pol,
146 &num_info,
147 &info);
148 if (!NT_STATUS_IS_OK(status)) {
149 goto done;
152 if (pnum_info) {
153 *pnum_info = num_info;
156 if (pinfo) {
157 *pinfo = talloc_move(mem_ctx, &info);
160 done:
161 TALLOC_FREE(tmp_ctx);
162 return status;
165 /* List all domain groups */
167 static NTSTATUS msrpc_enum_local_groups(struct winbindd_domain *domain,
168 TALLOC_CTX *mem_ctx,
169 uint32_t *pnum_info,
170 struct wb_acct_info **pinfo)
172 struct rpc_pipe_client *samr_pipe;
173 struct policy_handle dom_pol;
174 struct wb_acct_info *info = NULL;
175 uint32_t num_info = 0;
176 TALLOC_CTX *tmp_ctx;
177 NTSTATUS status;
179 DEBUG(3,("msrpc_enum_local_groups\n"));
181 if (pnum_info) {
182 *pnum_info = 0;
185 tmp_ctx = talloc_stackframe();
186 if (tmp_ctx == NULL) {
187 return NT_STATUS_NO_MEMORY;
190 if ( !winbindd_can_contact_domain( domain ) ) {
191 DEBUG(10,("enum_local_groups: No incoming trust for domain %s\n",
192 domain->name));
193 status = NT_STATUS_OK;
194 goto done;
197 status = cm_connect_sam(domain, tmp_ctx, &samr_pipe, &dom_pol);
198 if (!NT_STATUS_IS_OK(status)) {
199 goto done;
202 status = rpc_enum_local_groups(mem_ctx,
203 samr_pipe,
204 &dom_pol,
205 &num_info,
206 &info);
207 if (!NT_STATUS_IS_OK(status)) {
208 goto done;
211 if (pnum_info) {
212 *pnum_info = num_info;
215 if (pinfo) {
216 *pinfo = talloc_move(mem_ctx, &info);
219 done:
220 TALLOC_FREE(tmp_ctx);
221 return status;
224 /* convert a single name to a sid in a domain */
225 static NTSTATUS msrpc_name_to_sid(struct winbindd_domain *domain,
226 TALLOC_CTX *mem_ctx,
227 const char *domain_name,
228 const char *name,
229 uint32_t flags,
230 struct dom_sid *sid,
231 enum lsa_SidType *type)
233 NTSTATUS result;
234 struct dom_sid *sids = NULL;
235 enum lsa_SidType *types = NULL;
236 char *full_name = NULL;
237 NTSTATUS name_map_status = NT_STATUS_UNSUCCESSFUL;
238 char *mapped_name = NULL;
240 if (name == NULL || *name=='\0') {
241 full_name = talloc_asprintf(mem_ctx, "%s", domain_name);
242 } else if (domain_name == NULL || *domain_name == '\0') {
243 full_name = talloc_asprintf(mem_ctx, "%s", name);
244 } else {
245 full_name = talloc_asprintf(mem_ctx, "%s\\%s", domain_name, name);
247 if (!full_name) {
248 DEBUG(0, ("talloc_asprintf failed!\n"));
249 return NT_STATUS_NO_MEMORY;
252 DEBUG(3, ("msrpc_name_to_sid: name=%s\n", full_name));
254 name_map_status = normalize_name_unmap(mem_ctx, full_name,
255 &mapped_name);
257 /* Reset the full_name pointer if we mapped anything */
259 if (NT_STATUS_IS_OK(name_map_status) ||
260 NT_STATUS_EQUAL(name_map_status, NT_STATUS_FILE_RENAMED))
262 full_name = mapped_name;
265 DEBUG(3,("name_to_sid [rpc] %s for domain %s\n",
266 full_name?full_name:"", domain_name ));
268 result = winbindd_lookup_names(mem_ctx, domain, 1,
269 (const char **)&full_name, NULL,
270 &sids, &types);
271 if (!NT_STATUS_IS_OK(result))
272 return result;
274 /* Return rid and type if lookup successful */
276 sid_copy(sid, &sids[0]);
277 *type = types[0];
279 return NT_STATUS_OK;
283 convert a domain SID to a user or group name
285 static NTSTATUS msrpc_sid_to_name(struct winbindd_domain *domain,
286 TALLOC_CTX *mem_ctx,
287 const struct dom_sid *sid,
288 char **domain_name,
289 char **name,
290 enum lsa_SidType *type)
292 char **domains;
293 char **names;
294 enum lsa_SidType *types = NULL;
295 NTSTATUS result;
296 NTSTATUS name_map_status = NT_STATUS_UNSUCCESSFUL;
297 char *mapped_name = NULL;
299 DEBUG(3, ("msrpc_sid_to_name: %s for domain %s\n", sid_string_dbg(sid),
300 domain->name ));
302 result = winbindd_lookup_sids(mem_ctx,
303 domain,
305 sid,
306 &domains,
307 &names,
308 &types);
309 if (!NT_STATUS_IS_OK(result)) {
310 DEBUG(2,("msrpc_sid_to_name: failed to lookup sids: %s\n",
311 nt_errstr(result)));
312 return result;
316 *type = (enum lsa_SidType)types[0];
317 *domain_name = domains[0];
318 *name = names[0];
320 DEBUG(5,("Mapped sid to [%s]\\[%s]\n", domains[0], *name));
322 name_map_status = normalize_name_map(mem_ctx, domain, *name,
323 &mapped_name);
324 if (NT_STATUS_IS_OK(name_map_status) ||
325 NT_STATUS_EQUAL(name_map_status, NT_STATUS_FILE_RENAMED))
327 *name = mapped_name;
328 DEBUG(5,("returning mapped name -- %s\n", *name));
331 return NT_STATUS_OK;
334 static NTSTATUS msrpc_rids_to_names(struct winbindd_domain *domain,
335 TALLOC_CTX *mem_ctx,
336 const struct dom_sid *sid,
337 uint32 *rids,
338 size_t num_rids,
339 char **domain_name,
340 char ***names,
341 enum lsa_SidType **types)
343 char **domains;
344 NTSTATUS result;
345 struct dom_sid *sids;
346 size_t i;
347 char **ret_names;
349 DEBUG(3, ("msrpc_rids_to_names: domain %s\n", domain->name ));
351 if (num_rids) {
352 sids = talloc_array(mem_ctx, struct dom_sid, num_rids);
353 if (sids == NULL) {
354 return NT_STATUS_NO_MEMORY;
356 } else {
357 sids = NULL;
360 for (i=0; i<num_rids; i++) {
361 if (!sid_compose(&sids[i], sid, rids[i])) {
362 return NT_STATUS_INTERNAL_ERROR;
366 result = winbindd_lookup_sids(mem_ctx,
367 domain,
368 num_rids,
369 sids,
370 &domains,
371 names,
372 types);
374 if (!NT_STATUS_IS_OK(result) &&
375 !NT_STATUS_EQUAL(result, STATUS_SOME_UNMAPPED)) {
376 return result;
379 ret_names = *names;
380 for (i=0; i<num_rids; i++) {
381 NTSTATUS name_map_status = NT_STATUS_UNSUCCESSFUL;
382 char *mapped_name = NULL;
384 if ((*types)[i] != SID_NAME_UNKNOWN) {
385 name_map_status = normalize_name_map(mem_ctx,
386 domain,
387 ret_names[i],
388 &mapped_name);
389 if (NT_STATUS_IS_OK(name_map_status) ||
390 NT_STATUS_EQUAL(name_map_status, NT_STATUS_FILE_RENAMED))
392 ret_names[i] = mapped_name;
395 *domain_name = domains[i];
399 return result;
402 /* Lookup user information from a rid or username. */
403 static NTSTATUS msrpc_query_user(struct winbindd_domain *domain,
404 TALLOC_CTX *mem_ctx,
405 const struct dom_sid *user_sid,
406 struct wbint_userinfo *user_info)
408 struct rpc_pipe_client *samr_pipe;
409 struct policy_handle dom_pol;
410 struct netr_SamInfo3 *user;
411 TALLOC_CTX *tmp_ctx;
412 NTSTATUS status;
414 DEBUG(3,("msrpc_query_user sid=%s\n", sid_string_dbg(user_sid)));
416 tmp_ctx = talloc_stackframe();
417 if (tmp_ctx == NULL) {
418 return NT_STATUS_NO_MEMORY;
421 if (user_info) {
422 user_info->homedir = NULL;
423 user_info->shell = NULL;
424 user_info->primary_gid = (gid_t)-1;
427 /* try netsamlogon cache first */
428 user = netsamlogon_cache_get(tmp_ctx, user_sid);
429 if (user != NULL) {
430 DEBUG(5,("msrpc_query_user: Cache lookup succeeded for %s\n",
431 sid_string_dbg(user_sid)));
433 sid_compose(&user_info->user_sid, &domain->sid, user->base.rid);
434 sid_compose(&user_info->group_sid, &domain->sid,
435 user->base.primary_gid);
437 user_info->acct_name = talloc_strdup(user_info,
438 user->base.account_name.string);
439 user_info->full_name = talloc_strdup(user_info,
440 user->base.full_name.string);
442 status = NT_STATUS_OK;
443 goto done;
446 if ( !winbindd_can_contact_domain( domain ) ) {
447 DEBUG(10,("query_user: No incoming trust for domain %s\n",
448 domain->name));
449 /* Tell the cache manager not to remember this one */
450 status = NT_STATUS_SYNCHRONIZATION_REQUIRED;
451 goto done;
454 /* no cache; hit the wire */
455 status = cm_connect_sam(domain, tmp_ctx, &samr_pipe, &dom_pol);
456 if (!NT_STATUS_IS_OK(status)) {
457 goto done;
460 status = rpc_query_user(tmp_ctx,
461 samr_pipe,
462 &dom_pol,
463 &domain->sid,
464 user_sid,
465 user_info);
467 done:
468 TALLOC_FREE(tmp_ctx);
469 return status;
472 /* Lookup groups a user is a member of. I wish Unix had a call like this! */
473 static NTSTATUS msrpc_lookup_usergroups(struct winbindd_domain *domain,
474 TALLOC_CTX *mem_ctx,
475 const struct dom_sid *user_sid,
476 uint32_t *pnum_groups,
477 struct dom_sid **puser_grpsids)
479 struct rpc_pipe_client *samr_pipe;
480 struct policy_handle dom_pol;
481 struct dom_sid *user_grpsids = NULL;
482 uint32_t num_groups = 0;
483 TALLOC_CTX *tmp_ctx;
484 NTSTATUS status;
486 DEBUG(3,("msrpc_lookup_usergroups sid=%s\n", sid_string_dbg(user_sid)));
488 *pnum_groups = 0;
490 tmp_ctx = talloc_stackframe();
491 if (tmp_ctx == NULL) {
492 return NT_STATUS_NO_MEMORY;
495 /* Check if we have a cached user_info_3 */
496 status = lookup_usergroups_cached(domain,
497 tmp_ctx,
498 user_sid,
499 &num_groups,
500 &user_grpsids);
501 if (NT_STATUS_IS_OK(status)) {
502 goto cached;
505 if ( !winbindd_can_contact_domain( domain ) ) {
506 DEBUG(10,("lookup_usergroups: No incoming trust for domain %s\n",
507 domain->name));
509 /* Tell the cache manager not to remember this one */
510 status = NT_STATUS_SYNCHRONIZATION_REQUIRED;
511 goto done;
514 /* no cache; hit the wire */
515 status = cm_connect_sam(domain, tmp_ctx, &samr_pipe, &dom_pol);
516 if (!NT_STATUS_IS_OK(status)) {
517 goto done;
520 status = rpc_lookup_usergroups(tmp_ctx,
521 samr_pipe,
522 &dom_pol,
523 &domain->sid,
524 user_sid,
525 &num_groups,
526 &user_grpsids);
527 if (!NT_STATUS_IS_OK(status)) {
528 goto done;
531 cached:
532 *pnum_groups = num_groups;
534 if (puser_grpsids) {
535 *puser_grpsids = talloc_move(mem_ctx, &user_grpsids);
538 done:
539 TALLOC_FREE(tmp_ctx);
540 return status;
541 return NT_STATUS_OK;
544 #define MAX_SAM_ENTRIES_W2K 0x400 /* 1024 */
546 static NTSTATUS msrpc_lookup_useraliases(struct winbindd_domain *domain,
547 TALLOC_CTX *mem_ctx,
548 uint32 num_sids, const struct dom_sid *sids,
549 uint32 *pnum_aliases,
550 uint32 **palias_rids)
552 struct rpc_pipe_client *samr_pipe;
553 struct policy_handle dom_pol;
554 uint32_t num_aliases = 0;
555 uint32_t *alias_rids = NULL;
556 TALLOC_CTX *tmp_ctx;
557 NTSTATUS status;
559 DEBUG(3,("msrpc_lookup_useraliases\n"));
561 if (pnum_aliases) {
562 *pnum_aliases = 0;
565 tmp_ctx = talloc_stackframe();
566 if (tmp_ctx == NULL) {
567 return NT_STATUS_NO_MEMORY;
570 if (!winbindd_can_contact_domain(domain)) {
571 DEBUG(10,("msrpc_lookup_useraliases: No incoming trust for domain %s\n",
572 domain->name));
573 /* Tell the cache manager not to remember this one */
574 status = NT_STATUS_SYNCHRONIZATION_REQUIRED;
575 goto done;
578 status = cm_connect_sam(domain, tmp_ctx, &samr_pipe, &dom_pol);
579 if (!NT_STATUS_IS_OK(status)) {
580 goto done;
583 status = rpc_lookup_useraliases(tmp_ctx,
584 samr_pipe,
585 &dom_pol,
586 num_sids,
587 sids,
588 &num_aliases,
589 &alias_rids);
590 if (!NT_STATUS_IS_OK(status)) {
591 goto done;
594 if (pnum_aliases) {
595 *pnum_aliases = num_aliases;
598 if (palias_rids) {
599 *palias_rids = talloc_move(mem_ctx, &alias_rids);
602 done:
603 TALLOC_FREE(tmp_ctx);
604 return status;
608 /* Lookup group membership given a rid. */
609 static NTSTATUS msrpc_lookup_groupmem(struct winbindd_domain *domain,
610 TALLOC_CTX *mem_ctx,
611 const struct dom_sid *group_sid,
612 enum lsa_SidType type,
613 uint32_t *num_names,
614 struct dom_sid **sid_mem,
615 char ***names,
616 uint32_t **name_types)
618 NTSTATUS status, result;
619 uint32 i, total_names = 0;
620 struct policy_handle dom_pol, group_pol;
621 uint32 des_access = SEC_FLAG_MAXIMUM_ALLOWED;
622 uint32 *rid_mem = NULL;
623 uint32 group_rid;
624 unsigned int j, r;
625 struct rpc_pipe_client *cli;
626 unsigned int orig_timeout;
627 struct samr_RidAttrArray *rids = NULL;
628 struct dcerpc_binding_handle *b;
630 DEBUG(3,("msrpc_lookup_groupmem: %s sid=%s\n", domain->name,
631 sid_string_dbg(group_sid)));
633 if ( !winbindd_can_contact_domain( domain ) ) {
634 DEBUG(10,("lookup_groupmem: No incoming trust for domain %s\n",
635 domain->name));
636 return NT_STATUS_OK;
639 if (!sid_peek_check_rid(&domain->sid, group_sid, &group_rid))
640 return NT_STATUS_UNSUCCESSFUL;
642 *num_names = 0;
644 result = cm_connect_sam(domain, mem_ctx, &cli, &dom_pol);
645 if (!NT_STATUS_IS_OK(result))
646 return result;
648 b = cli->binding_handle;
650 status = dcerpc_samr_OpenGroup(b, mem_ctx,
651 &dom_pol,
652 des_access,
653 group_rid,
654 &group_pol,
655 &result);
656 if (!NT_STATUS_IS_OK(status)) {
657 return status;
659 if (!NT_STATUS_IS_OK(result)) {
660 return result;
663 /* Step #1: Get a list of user rids that are the members of the
664 group. */
666 /* This call can take a long time - allow the server to time out.
667 35 seconds should do it. */
669 orig_timeout = rpccli_set_timeout(cli, 35000);
671 status = dcerpc_samr_QueryGroupMember(b, mem_ctx,
672 &group_pol,
673 &rids,
674 &result);
676 /* And restore our original timeout. */
677 rpccli_set_timeout(cli, orig_timeout);
680 NTSTATUS _result;
681 dcerpc_samr_Close(b, mem_ctx, &group_pol, &_result);
684 if (!NT_STATUS_IS_OK(status)) {
685 return status;
688 if (!NT_STATUS_IS_OK(result)) {
689 return result;
692 if (!rids || !rids->count) {
693 names = NULL;
694 name_types = NULL;
695 sid_mem = NULL;
696 return NT_STATUS_OK;
699 *num_names = rids->count;
700 rid_mem = rids->rids;
702 /* Step #2: Convert list of rids into list of usernames. Do this
703 in bunches of ~1000 to avoid crashing NT4. It looks like there
704 is a buffer overflow or something like that lurking around
705 somewhere. */
707 #define MAX_LOOKUP_RIDS 900
709 *names = talloc_zero_array(mem_ctx, char *, *num_names);
710 *name_types = talloc_zero_array(mem_ctx, uint32, *num_names);
711 *sid_mem = talloc_zero_array(mem_ctx, struct dom_sid, *num_names);
713 for (j=0;j<(*num_names);j++)
714 sid_compose(&(*sid_mem)[j], &domain->sid, rid_mem[j]);
716 if (*num_names>0 && (!*names || !*name_types))
717 return NT_STATUS_NO_MEMORY;
719 for (i = 0; i < *num_names; i += MAX_LOOKUP_RIDS) {
720 int num_lookup_rids = MIN(*num_names - i, MAX_LOOKUP_RIDS);
721 struct lsa_Strings tmp_names;
722 struct samr_Ids tmp_types;
724 /* Lookup a chunk of rids */
726 status = dcerpc_samr_LookupRids(b, mem_ctx,
727 &dom_pol,
728 num_lookup_rids,
729 &rid_mem[i],
730 &tmp_names,
731 &tmp_types,
732 &result);
733 if (!NT_STATUS_IS_OK(status)) {
734 return status;
737 /* see if we have a real error (and yes the
738 STATUS_SOME_UNMAPPED is the one returned from 2k) */
740 if (!NT_STATUS_IS_OK(result) &&
741 !NT_STATUS_EQUAL(result, STATUS_SOME_UNMAPPED))
742 return result;
744 /* Copy result into array. The talloc system will take
745 care of freeing the temporary arrays later on. */
747 if (tmp_names.count != num_lookup_rids) {
748 return NT_STATUS_INVALID_NETWORK_RESPONSE;
750 if (tmp_types.count != num_lookup_rids) {
751 return NT_STATUS_INVALID_NETWORK_RESPONSE;
754 for (r=0; r<tmp_names.count; r++) {
755 if (tmp_types.ids[r] == SID_NAME_UNKNOWN) {
756 continue;
758 if (total_names >= *num_names) {
759 break;
761 (*names)[total_names] = fill_domain_username_talloc(
762 mem_ctx, domain->name,
763 tmp_names.names[r].string, true);
764 (*name_types)[total_names] = tmp_types.ids[r];
765 total_names += 1;
769 *num_names = total_names;
771 return NT_STATUS_OK;
774 #ifdef HAVE_LDAP
776 #include "ads.h"
778 static int get_ldap_seq(const char *server, struct sockaddr_storage *ss, int port, uint32 *seq)
780 int ret = -1;
781 struct timeval to;
782 const char *attrs[] = {"highestCommittedUSN", NULL};
783 LDAPMessage *res = NULL;
784 char **values = NULL;
785 LDAP *ldp = NULL;
787 *seq = DOM_SEQUENCE_NONE;
790 * Parameterised (5) second timeout on open. This is needed as the
791 * search timeout doesn't seem to apply to doing an open as well. JRA.
794 ldp = ldap_open_with_timeout(server, ss, port, lp_ldap_timeout());
795 if (ldp == NULL)
796 return -1;
798 /* Timeout if no response within 20 seconds. */
799 to.tv_sec = 10;
800 to.tv_usec = 0;
802 if (ldap_search_st(ldp, "", LDAP_SCOPE_BASE, "(objectclass=*)",
803 discard_const_p(char *, attrs), 0, &to, &res))
804 goto done;
806 if (ldap_count_entries(ldp, res) != 1)
807 goto done;
809 values = ldap_get_values(ldp, res, "highestCommittedUSN");
810 if (!values || !values[0])
811 goto done;
813 *seq = atoi(values[0]);
814 ret = 0;
816 done:
818 if (values)
819 ldap_value_free(values);
820 if (res)
821 ldap_msgfree(res);
822 if (ldp)
823 ldap_unbind(ldp);
824 return ret;
827 /**********************************************************************
828 Get the sequence number for a Windows AD native mode domain using
829 LDAP queries.
830 **********************************************************************/
832 static int get_ldap_sequence_number(struct winbindd_domain *domain, uint32 *seq)
834 int ret = -1;
835 char addr[INET6_ADDRSTRLEN];
837 print_sockaddr(addr, sizeof(addr), &domain->dcaddr);
838 if ((ret = get_ldap_seq(addr, &domain->dcaddr, LDAP_PORT, seq)) == 0) {
839 DEBUG(3, ("get_ldap_sequence_number: Retrieved sequence "
840 "number for Domain (%s) from DC (%s)\n",
841 domain->name, addr));
843 return ret;
846 #endif /* HAVE_LDAP */
848 /* find the sequence number for a domain */
849 static NTSTATUS msrpc_sequence_number(struct winbindd_domain *domain,
850 uint32_t *pseq)
852 struct rpc_pipe_client *samr_pipe;
853 struct policy_handle dom_pol;
854 uint32_t seq;
855 TALLOC_CTX *tmp_ctx;
856 NTSTATUS status;
858 DEBUG(3, ("msrpc_sequence_number: fetch sequence_number for %s\n", domain->name));
860 if (pseq) {
861 *pseq = DOM_SEQUENCE_NONE;
864 tmp_ctx = talloc_stackframe();
865 if (tmp_ctx == NULL) {
866 return NT_STATUS_NO_MEMORY;
869 if ( !winbindd_can_contact_domain( domain ) ) {
870 DEBUG(10,("sequence_number: No incoming trust for domain %s\n",
871 domain->name));
872 if (pseq) {
873 *pseq = time(NULL);
875 status = NT_STATUS_OK;
876 goto done;
879 #ifdef HAVE_LDAP
880 if (domain->active_directory) {
881 int rc;
883 DEBUG(8,("using get_ldap_seq() to retrieve the "
884 "sequence number\n"));
886 rc = get_ldap_sequence_number(domain, &seq);
887 if (rc == 0) {
888 DEBUG(10,("domain_sequence_number: LDAP for "
889 "domain %s is %u\n",
890 domain->name, seq));
892 if (pseq) {
893 *pseq = seq;
896 status = NT_STATUS_OK;
897 goto done;
900 DEBUG(10,("domain_sequence_number: failed to get LDAP "
901 "sequence number for domain %s\n",
902 domain->name ));
904 #endif /* HAVE_LDAP */
906 status = cm_connect_sam(domain, tmp_ctx, &samr_pipe, &dom_pol);
907 if (!NT_STATUS_IS_OK(status)) {
908 goto done;
911 status = rpc_sequence_number(tmp_ctx,
912 samr_pipe,
913 &dom_pol,
914 domain->name,
915 &seq);
916 if (!NT_STATUS_IS_OK(status)) {
917 goto done;
920 if (pseq) {
921 *pseq = seq;
924 done:
925 TALLOC_FREE(tmp_ctx);
926 return status;
929 /* get a list of trusted domains */
930 static NTSTATUS msrpc_trusted_domains(struct winbindd_domain *domain,
931 TALLOC_CTX *mem_ctx,
932 struct netr_DomainTrustList *ptrust_list)
934 struct rpc_pipe_client *lsa_pipe;
935 struct policy_handle lsa_policy;
936 struct netr_DomainTrust *trusts = NULL;
937 uint32_t num_trusts = 0;
938 TALLOC_CTX *tmp_ctx;
939 NTSTATUS status;
941 DEBUG(3,("msrpc_trusted_domains\n"));
943 if (ptrust_list) {
944 ZERO_STRUCTP(ptrust_list);
947 tmp_ctx = talloc_stackframe();
948 if (tmp_ctx == NULL) {
949 return NT_STATUS_NO_MEMORY;
952 status = cm_connect_lsa(domain, tmp_ctx, &lsa_pipe, &lsa_policy);
953 if (!NT_STATUS_IS_OK(status)) {
954 goto done;
957 status = rpc_trusted_domains(tmp_ctx,
958 lsa_pipe,
959 &lsa_policy,
960 &num_trusts,
961 &trusts);
962 if (!NT_STATUS_IS_OK(status)) {
963 goto done;
966 if (ptrust_list) {
967 ptrust_list->count = num_trusts;
968 ptrust_list->array = talloc_move(mem_ctx, &trusts);
971 done:
972 TALLOC_FREE(tmp_ctx);
973 return status;
976 /* find the lockout policy for a domain */
977 static NTSTATUS msrpc_lockout_policy(struct winbindd_domain *domain,
978 TALLOC_CTX *mem_ctx,
979 struct samr_DomInfo12 *lockout_policy)
981 NTSTATUS status, result;
982 struct rpc_pipe_client *cli;
983 struct policy_handle dom_pol;
984 union samr_DomainInfo *info = NULL;
985 struct dcerpc_binding_handle *b;
987 DEBUG(3, ("msrpc_lockout_policy: fetch lockout policy for %s\n", domain->name));
989 if ( !winbindd_can_contact_domain( domain ) ) {
990 DEBUG(10,("msrpc_lockout_policy: No incoming trust for domain %s\n",
991 domain->name));
992 return NT_STATUS_NOT_SUPPORTED;
995 status = cm_connect_sam(domain, mem_ctx, &cli, &dom_pol);
996 if (!NT_STATUS_IS_OK(status)) {
997 goto done;
1000 b = cli->binding_handle;
1002 status = dcerpc_samr_QueryDomainInfo(b, mem_ctx,
1003 &dom_pol,
1004 DomainLockoutInformation,
1005 &info,
1006 &result);
1007 if (!NT_STATUS_IS_OK(status)) {
1008 goto done;
1010 if (!NT_STATUS_IS_OK(result)) {
1011 status = result;
1012 goto done;
1015 *lockout_policy = info->info12;
1017 DEBUG(10,("msrpc_lockout_policy: lockout_threshold %d\n",
1018 info->info12.lockout_threshold));
1020 done:
1022 return status;
1025 /* find the password policy for a domain */
1026 static NTSTATUS msrpc_password_policy(struct winbindd_domain *domain,
1027 TALLOC_CTX *mem_ctx,
1028 struct samr_DomInfo1 *password_policy)
1030 NTSTATUS status, result;
1031 struct rpc_pipe_client *cli;
1032 struct policy_handle dom_pol;
1033 union samr_DomainInfo *info = NULL;
1034 struct dcerpc_binding_handle *b;
1036 DEBUG(3, ("msrpc_password_policy: fetch password policy for %s\n",
1037 domain->name));
1039 if ( !winbindd_can_contact_domain( domain ) ) {
1040 DEBUG(10,("msrpc_password_policy: No incoming trust for domain %s\n",
1041 domain->name));
1042 return NT_STATUS_NOT_SUPPORTED;
1045 status = cm_connect_sam(domain, mem_ctx, &cli, &dom_pol);
1046 if (!NT_STATUS_IS_OK(status)) {
1047 goto done;
1050 b = cli->binding_handle;
1052 status = dcerpc_samr_QueryDomainInfo(b, mem_ctx,
1053 &dom_pol,
1054 DomainPasswordInformation,
1055 &info,
1056 &result);
1057 if (!NT_STATUS_IS_OK(status)) {
1058 goto done;
1060 if (!NT_STATUS_IS_OK(result)) {
1061 goto done;
1064 *password_policy = info->info1;
1066 DEBUG(10,("msrpc_password_policy: min_length_password %d\n",
1067 info->info1.min_password_length));
1069 done:
1071 return status;
1074 NTSTATUS winbindd_lookup_sids(TALLOC_CTX *mem_ctx,
1075 struct winbindd_domain *domain,
1076 uint32_t num_sids,
1077 const struct dom_sid *sids,
1078 char ***domains,
1079 char ***names,
1080 enum lsa_SidType **types)
1082 NTSTATUS status;
1083 NTSTATUS result;
1084 struct rpc_pipe_client *cli = NULL;
1085 struct dcerpc_binding_handle *b = NULL;
1086 struct policy_handle lsa_policy;
1087 unsigned int orig_timeout;
1088 bool use_lookupsids3 = false;
1089 bool retried = false;
1091 connect:
1092 status = cm_connect_lsat(domain, mem_ctx, &cli, &lsa_policy);
1093 if (!NT_STATUS_IS_OK(status)) {
1094 return status;
1097 b = cli->binding_handle;
1099 if (cli->transport->transport == NCACN_IP_TCP) {
1100 use_lookupsids3 = true;
1104 * This call can take a long time
1105 * allow the server to time out.
1106 * 35 seconds should do it.
1108 orig_timeout = dcerpc_binding_handle_set_timeout(b, 35000);
1110 status = dcerpc_lsa_lookup_sids_generic(b,
1111 mem_ctx,
1112 &lsa_policy,
1113 num_sids,
1114 sids,
1115 domains,
1116 names,
1117 types,
1118 use_lookupsids3,
1119 &result);
1121 /* And restore our original timeout. */
1122 dcerpc_binding_handle_set_timeout(b, orig_timeout);
1124 if (NT_STATUS_EQUAL(status, NT_STATUS_ACCESS_DENIED) ||
1125 NT_STATUS_EQUAL(status, NT_STATUS_RPC_SEC_PKG_ERROR) ||
1126 NT_STATUS_EQUAL(status, NT_STATUS_NETWORK_ACCESS_DENIED)) {
1128 * This can happen if the schannel key is not
1129 * valid anymore, we need to invalidate the
1130 * all connections to the dc and reestablish
1131 * a netlogon connection first.
1133 invalidate_cm_connection(&domain->conn);
1134 domain->can_do_ncacn_ip_tcp = domain->active_directory;
1135 if (!retried) {
1136 retried = true;
1137 goto connect;
1139 status = NT_STATUS_ACCESS_DENIED;
1142 if (!NT_STATUS_IS_OK(status)) {
1143 return status;
1146 if (!NT_STATUS_IS_OK(result)) {
1147 return result;
1150 return NT_STATUS_OK;
1153 static NTSTATUS winbindd_lookup_names(TALLOC_CTX *mem_ctx,
1154 struct winbindd_domain *domain,
1155 uint32_t num_names,
1156 const char **names,
1157 const char ***domains,
1158 struct dom_sid **sids,
1159 enum lsa_SidType **types)
1161 NTSTATUS status;
1162 NTSTATUS result;
1163 struct rpc_pipe_client *cli = NULL;
1164 struct dcerpc_binding_handle *b = NULL;
1165 struct policy_handle lsa_policy;
1166 unsigned int orig_timeout = 0;
1167 bool use_lookupnames4 = false;
1168 bool retried = false;
1170 connect:
1171 status = cm_connect_lsat(domain, mem_ctx, &cli, &lsa_policy);
1172 if (!NT_STATUS_IS_OK(status)) {
1173 return status;
1176 b = cli->binding_handle;
1178 if (cli->transport->transport == NCACN_IP_TCP) {
1179 use_lookupnames4 = true;
1183 * This call can take a long time
1184 * allow the server to time out.
1185 * 35 seconds should do it.
1187 orig_timeout = dcerpc_binding_handle_set_timeout(b, 35000);
1189 status = dcerpc_lsa_lookup_names_generic(b,
1190 mem_ctx,
1191 &lsa_policy,
1192 num_names,
1193 (const char **) names,
1194 domains,
1196 sids,
1197 types,
1198 use_lookupnames4,
1199 &result);
1201 /* And restore our original timeout. */
1202 dcerpc_binding_handle_set_timeout(b, orig_timeout);
1204 if (NT_STATUS_EQUAL(status, NT_STATUS_ACCESS_DENIED) ||
1205 NT_STATUS_EQUAL(status, NT_STATUS_RPC_SEC_PKG_ERROR) ||
1206 NT_STATUS_EQUAL(status, NT_STATUS_NETWORK_ACCESS_DENIED)) {
1208 * This can happen if the schannel key is not
1209 * valid anymore, we need to invalidate the
1210 * all connections to the dc and reestablish
1211 * a netlogon connection first.
1213 invalidate_cm_connection(&domain->conn);
1214 if (!retried) {
1215 retried = true;
1216 goto connect;
1218 status = NT_STATUS_ACCESS_DENIED;
1221 if (!NT_STATUS_IS_OK(status)) {
1222 return status;
1225 if (!NT_STATUS_IS_OK(result)) {
1226 return result;
1229 return NT_STATUS_OK;
1232 /* the rpc backend methods are exposed via this structure */
1233 struct winbindd_methods msrpc_methods = {
1234 False,
1235 msrpc_query_user_list,
1236 msrpc_enum_dom_groups,
1237 msrpc_enum_local_groups,
1238 msrpc_name_to_sid,
1239 msrpc_sid_to_name,
1240 msrpc_rids_to_names,
1241 msrpc_query_user,
1242 msrpc_lookup_usergroups,
1243 msrpc_lookup_useraliases,
1244 msrpc_lookup_groupmem,
1245 msrpc_sequence_number,
1246 msrpc_lockout_policy,
1247 msrpc_password_policy,
1248 msrpc_trusted_domains,