Few missing merges from cleaning out the Centeris winbindd tree.
[metze/old/v3-2-winbind-ndr.git] / source / nsswitch / winbindd_rpc.c
index f4676cc2fe0703df0f916e306b14c061dfef5505..4a6448348e9d943eeeb2194a30903d75731807b1 100644 (file)
@@ -48,6 +48,12 @@ static NTSTATUS query_user_list(struct winbindd_domain *domain,
        *num_entries = 0;
        *info = NULL;
 
+       if ( !winbindd_can_contact_domain( domain ) ) {
+               DEBUG(10,("query_user_list: No incoming trust for domain %s\n",
+                         domain->name));
+               return NT_STATUS_OK;
+       }
+
        result = cm_connect_sam(domain, mem_ctx, &cli, &dom_pol);
        if (!NT_STATUS_IS_OK(result))
                return result;
@@ -140,6 +146,12 @@ static NTSTATUS enum_dom_groups(struct winbindd_domain *domain,
 
        DEBUG(3,("rpc: enum_dom_groups\n"));
 
+       if ( !winbindd_can_contact_domain( domain ) ) {
+               DEBUG(10,("enum_domain_groups: No incoming trust for domain %s\n",
+                         domain->name));
+               return NT_STATUS_OK;
+       }
+
        status = cm_connect_sam(domain, mem_ctx, &cli, &dom_pol);
        if (!NT_STATUS_IS_OK(status))
                return status;
@@ -196,6 +208,12 @@ static NTSTATUS enum_local_groups(struct winbindd_domain *domain,
 
        DEBUG(3,("rpc: enum_local_groups\n"));
 
+       if ( !winbindd_can_contact_domain( domain ) ) {
+               DEBUG(10,("enum_local_groups: No incoming trust for domain %s\n",
+                         domain->name));
+               return NT_STATUS_OK;
+       }
+
        result = cm_connect_sam(domain, mem_ctx, &cli, &dom_pol);
        if (!NT_STATUS_IS_OK(result))
                return result;
@@ -241,12 +259,12 @@ NTSTATUS msrpc_name_to_sid(struct winbindd_domain *domain,
                            const char *domain_name,
                            const char *name,
                            DOM_SID *sid,
-                           enum SID_NAME_USE *type)
+                           enum lsa_SidType *type)
 {
        NTSTATUS result;
        DOM_SID *sids = NULL;
-       enum SID_NAME_USE *types = NULL;
-       const char *full_name;
+       enum lsa_SidType *types = NULL;
+       char *full_name = NULL;
        struct rpc_pipe_client *cli;
        POLICY_HND lsa_policy;
 
@@ -262,6 +280,8 @@ NTSTATUS msrpc_name_to_sid(struct winbindd_domain *domain,
                return NT_STATUS_NO_MEMORY;
        }
 
+       ws_name_return( full_name, WB_REPLACE_CHAR );
+
        DEBUG(3,("name_to_sid [rpc] %s for domain %s\n", full_name?full_name:"", domain_name ));
 
        result = cm_connect_lsa(domain, mem_ctx, &cli, &lsa_policy);
@@ -269,7 +289,7 @@ NTSTATUS msrpc_name_to_sid(struct winbindd_domain *domain,
                return result;
 
        result = rpccli_lsa_lookup_names(cli, mem_ctx, &lsa_policy, 1, 
-                                        &full_name, NULL, &sids, &types);
+                                        (const char**) &full_name, NULL, &sids, &types);
         
        if (!NT_STATUS_IS_OK(result))
                return result;
@@ -290,11 +310,11 @@ NTSTATUS msrpc_sid_to_name(struct winbindd_domain *domain,
                            const DOM_SID *sid,
                            char **domain_name,
                            char **name,
-                           enum SID_NAME_USE *type)
+                           enum lsa_SidType *type)
 {
        char **domains;
        char **names;
-       enum SID_NAME_USE *types;
+       enum lsa_SidType *types;
        NTSTATUS result;
        struct rpc_pipe_client *cli;
        POLICY_HND lsa_policy;
@@ -303,17 +323,27 @@ NTSTATUS msrpc_sid_to_name(struct winbindd_domain *domain,
                        domain->name ));
 
        result = cm_connect_lsa(domain, mem_ctx, &cli, &lsa_policy);
-       if (!NT_STATUS_IS_OK(result))
+       if (!NT_STATUS_IS_OK(result)) {
+               DEBUG(2,("msrpc_sid_to_name: cm_connect_lsa() failed (%s)\n",
+                        nt_errstr(result)));           
                return result;
+       }
+       
 
        result = rpccli_lsa_lookup_sids(cli, mem_ctx, &lsa_policy,
                                        1, sid, &domains, &names, &types);
-       if (!NT_STATUS_IS_OK(result))
+       if (!NT_STATUS_IS_OK(result)) {         
+               DEBUG(2,("msrpc_sid_to_name: rpccli_lsa_lookup_sids()  failed (%s)\n",
+                        nt_errstr(result)));           
                return result;
+       }
 
-       *type = (enum SID_NAME_USE)types[0];
+       *type = (enum lsa_SidType)types[0];
        *domain_name = domains[0];
        *name = names[0];
+
+       ws_name_replace( *name, WB_REPLACE_CHAR );      
+               
        DEBUG(5,("Mapped sid to [%s]\\[%s]\n", domains[0], *name));
        return NT_STATUS_OK;
 }
@@ -325,7 +355,7 @@ NTSTATUS msrpc_rids_to_names(struct winbindd_domain *domain,
                             size_t num_rids,
                             char **domain_name,
                             char ***names,
-                            enum SID_NAME_USE **types)
+                            enum lsa_SidType **types)
 {
        char **domains;
        NTSTATUS result;
@@ -333,12 +363,17 @@ NTSTATUS msrpc_rids_to_names(struct winbindd_domain *domain,
        POLICY_HND lsa_policy;
        DOM_SID *sids;
        size_t i;
+       char **ret_names;
 
        DEBUG(3, ("rids_to_names [rpc] for domain %s\n", domain->name ));
 
-       sids = TALLOC_ARRAY(mem_ctx, DOM_SID, num_rids);
-       if (sids == NULL) {
-               return NT_STATUS_NO_MEMORY;
+       if (num_rids) {
+               sids = TALLOC_ARRAY(mem_ctx, DOM_SID, num_rids);
+               if (sids == NULL) {
+                       return NT_STATUS_NO_MEMORY;
+               }
+       } else {
+               sids = NULL;
        }
 
        for (i=0; i<num_rids; i++) {
@@ -360,10 +395,11 @@ NTSTATUS msrpc_rids_to_names(struct winbindd_domain *domain,
                return result;
        }
 
+       ret_names = *names;
        for (i=0; i<num_rids; i++) {
                if ((*types)[i] != SID_NAME_UNKNOWN) {
+                       ws_name_replace( ret_names[i], WB_REPLACE_CHAR );
                        *domain_name = domains[i];
-                       break;
                }
        }
 
@@ -384,12 +420,16 @@ static NTSTATUS query_user(struct winbindd_domain *domain,
        NET_USER_INFO_3 *user;
        struct rpc_pipe_client *cli;
 
-       DEBUG(3,("rpc: query_user rid=%s\n",
+       DEBUG(3,("rpc: query_user sid=%s\n",
                 sid_to_string(sid_string, user_sid)));
 
        if (!sid_peek_check_rid(&domain->sid, user_sid, &user_rid))
                return NT_STATUS_UNSUCCESSFUL;
        
+       user_info->homedir = NULL;
+       user_info->shell = NULL;
+       user_info->primary_gid = (gid_t)-1;
+                                               
        /* try netsamlogon cache first */
                        
        if ( (user = netsamlogon_cache_get( mem_ctx, user_sid )) != NULL ) 
@@ -398,7 +438,7 @@ static NTSTATUS query_user(struct winbindd_domain *domain,
                DEBUG(5,("query_user: Cache lookup succeeded for %s\n", 
                        sid_string_static(user_sid)));
 
-               sid_compose(&user_info->user_sid, &domain->sid, user_rid);
+               sid_compose(&user_info->user_sid, &domain->sid, user->user_rid);
                sid_compose(&user_info->group_sid, &domain->sid,
                            user->group_rid);
                                
@@ -407,11 +447,20 @@ static NTSTATUS query_user(struct winbindd_domain *domain,
                user_info->full_name = unistr2_tdup(mem_ctx,
                                                    &user->uni_full_name);
                
-               user_info->homedir = NULL;
-               user_info->shell = NULL;
+               TALLOC_FREE(user);
                                                
-               SAFE_FREE(user);
+               return NT_STATUS_OK;
+       }
                                
+       if ( !winbindd_can_contact_domain( domain ) ) {
+               DEBUG(10,("query_user: No incoming trust for domain %s\n",
+                         domain->name));
+               return NT_STATUS_OK;
+       }
+       
+       if ( !winbindd_can_contact_domain( domain ) ) {
+               DEBUG(10,("query_user: No incoming trust for domain %s\n",
+                         domain->name));
                return NT_STATUS_OK;
        }
        
@@ -447,6 +496,7 @@ static NTSTATUS query_user(struct winbindd_domain *domain,
                                            &ctr->info.id21->uni_full_name);
        user_info->homedir = NULL;
        user_info->shell = NULL;
+       user_info->primary_gid = (gid_t)-1;
 
        return NT_STATUS_OK;
 }                                   
@@ -483,6 +533,15 @@ static NTSTATUS lookup_usergroups(struct winbindd_domain *domain,
                return NT_STATUS_OK;
        }
 
+       if ( !winbindd_can_contact_domain( domain ) ) {
+               DEBUG(10,("lookup_usergroups: No incoming trust for domain %s\n",
+                         domain->name));
+
+               /* Tell the cache manager not to remember this one */
+
+               return NT_STATUS_SYNCHRONIZATION_REQUIRED;
+       }
+
        /* no cache; hit the wire */
        
        result = cm_connect_sam(domain, mem_ctx, &cli, &dom_pol);
@@ -539,6 +598,12 @@ NTSTATUS msrpc_lookup_useraliases(struct winbindd_domain *domain,
 
        DEBUG(3,("rpc: lookup_useraliases\n"));
 
+       if ( !winbindd_can_contact_domain( domain ) ) {
+               DEBUG(10,("msrpc_lookup_useraliases: No incoming trust for domain %s\n",
+                         domain->name));
+               return NT_STATUS_OK;
+       }
+
        result = cm_connect_sam(domain, mem_ctx, &cli, &dom_pol);
        if (!NT_STATUS_IS_OK(result))
                return result;
@@ -551,10 +616,13 @@ NTSTATUS msrpc_lookup_useraliases(struct winbindd_domain *domain,
                DEBUG(10,("rpc: lookup_useraliases: entering query %d for %d sids\n", 
                        num_queries, num_query_sids));  
 
-
-               query_sids = TALLOC_ARRAY(mem_ctx, DOM_SID2, num_query_sids);
-               if (query_sids == NULL) {
-                       return NT_STATUS_NO_MEMORY;
+               if (num_query_sids) {
+                       query_sids = TALLOC_ARRAY(mem_ctx, DOM_SID2, num_query_sids);
+                       if (query_sids == NULL) {
+                               return NT_STATUS_NO_MEMORY;
+                       }
+               } else {
+                       query_sids = NULL;
                }
 
                for (i=0; i<num_query_sids; i++) {
@@ -580,8 +648,10 @@ NTSTATUS msrpc_lookup_useraliases(struct winbindd_domain *domain,
 
                for (i=0; i<num_aliases_query; i++) {
                        size_t na = *num_aliases;
-                       add_rid_to_array_unique(mem_ctx, alias_rids_query[i], 
-                                               alias_rids, &na);
+                       if (!add_rid_to_array_unique(mem_ctx, alias_rids_query[i], 
+                                               alias_rids, &na)) {
+                               return NT_STATUS_NO_MEMORY;
+                       }
                        *num_aliases = na;
                }
 
@@ -615,10 +685,17 @@ static NTSTATUS lookup_groupmem(struct winbindd_domain *domain,
        unsigned int j;
        fstring sid_string;
        struct rpc_pipe_client *cli;
+       unsigned int orig_timeout;
 
        DEBUG(10,("rpc: lookup_groupmem %s sid=%s\n", domain->name,
                  sid_to_string(sid_string, group_sid)));
 
+       if ( !winbindd_can_contact_domain( domain ) ) {
+               DEBUG(10,("lookup_groupmem: No incoming trust for domain %s\n",
+                         domain->name));
+               return NT_STATUS_OK;
+       }
+
        if (!sid_peek_check_rid(&domain->sid, group_sid, &group_rid))
                return NT_STATUS_UNSUCCESSFUL;
 
@@ -637,10 +714,18 @@ static NTSTATUS lookup_groupmem(struct winbindd_domain *domain,
         /* Step #1: Get a list of user rids that are the members of the
            group. */
 
+       /* This call can take a long time - allow the server to time out.
+          35 seconds should do it. */
+
+       orig_timeout = cli_set_timeout(cli->cli, 35000);
+
         result = rpccli_samr_query_groupmem(cli, mem_ctx,
                                            &group_pol, num_names, &rid_mem,
                                            name_types);
 
+       /* And restore our original timeout. */
+       cli_set_timeout(cli->cli, orig_timeout);
+
        rpccli_samr_close(cli, mem_ctx, &group_pol);
 
         if (!NT_STATUS_IS_OK(result))
@@ -764,54 +849,20 @@ static int get_ldap_seq(const char *server, int port, uint32 *seq)
 
 /**********************************************************************
  Get the sequence number for a Windows AD native mode domain using
- LDAP queries
+ LDAP queries
 **********************************************************************/
 
-static int get_ldap_sequence_number( const char* domain, uint32 *seq)
+static int get_ldap_sequence_number(struct winbindd_domain *domain, uint32 *seq)
 {
        int ret = -1;
-       int i, port = LDAP_PORT;
-       struct ip_service *ip_list = NULL;
-       int count;
-       
-       if ( !NT_STATUS_IS_OK(get_sorted_dc_list(domain, &ip_list, &count,
-                                                False)) ) {
-               DEBUG(3, ("Could not look up dc's for domain %s\n", domain));
-               return False;
-       }
-
-       /* Finally return first DC that we can contact */
-
-       for (i = 0; i < count; i++) {
-               fstring ipstr;
-
-               /* since the is an LDAP lookup, default to the LDAP_PORT is
-                * not set */
-               port = (ip_list[i].port!= PORT_NONE) ?
-                       ip_list[i].port : LDAP_PORT;
+       fstring ipstr;
 
-               fstrcpy( ipstr, inet_ntoa(ip_list[i].ip) );
-               
-               if (is_zero_ip(ip_list[i].ip))
-                       continue;
-
-               if ( (ret = get_ldap_seq( ipstr, port,  seq)) == 0 )
-                       goto done;
-
-               /* add to failed connection cache */
-               add_failed_connection_entry( domain, ipstr,
-                                            NT_STATUS_UNSUCCESSFUL );
-       }
-
-done:
-       if ( ret == 0 ) {
+       fstrcpy( ipstr, inet_ntoa(domain->dcaddr.sin_addr));
+       if ((ret = get_ldap_seq( ipstr, LDAP_PORT, seq)) == 0) {
                DEBUG(3, ("get_ldap_sequence_number: Retrieved sequence "
-                         "number for Domain (%s) from DC (%s:%d)\n", 
-                       domain, inet_ntoa(ip_list[i].ip), port));
-       }
-
-       SAFE_FREE(ip_list);
-
+                         "number for Domain (%s) from DC (%s)\n", 
+                       domain->name, ipstr));
+       } 
        return ret;
 }
 
@@ -829,20 +880,27 @@ static NTSTATUS sequence_number(struct winbindd_domain *domain, uint32 *seq)
 
        DEBUG(10,("rpc: fetch sequence_number for %s\n", domain->name));
 
+       if ( !winbindd_can_contact_domain( domain ) ) {
+               DEBUG(10,("sequence_number: No incoming trust for domain %s\n",
+                         domain->name));
+               *seq = time(NULL);              
+               return NT_STATUS_OK;
+       }
+
        *seq = DOM_SEQUENCE_NONE;
 
        if (!(mem_ctx = talloc_init("sequence_number[rpc]")))
                return NT_STATUS_NO_MEMORY;
 
 #ifdef HAVE_LDAP
-       if ( domain->native_mode ) 
+       if ( domain->active_directory ) 
        {
                int res;
 
                DEBUG(8,("using get_ldap_seq() to retrieve the "
                         "sequence number\n"));
 
-               res =  get_ldap_sequence_number( domain->name, seq );
+               res =  get_ldap_sequence_number( domain, seq );
                if (res == 0)
                {                       
                        result = NT_STATUS_OK;
@@ -868,7 +926,7 @@ static NTSTATUS sequence_number(struct winbindd_domain *domain, uint32 *seq)
        result = rpccli_samr_query_dom_info(cli, mem_ctx, &dom_pol, 8, &ctr);
 
        if (NT_STATUS_IS_OK(result)) {
-               *seq = ctr.info.inf8.seq_num.low;
+               *seq = ctr.info.inf8.seq_num;
                got_seq_num = True;
                goto seq_num;
        }
@@ -879,7 +937,7 @@ static NTSTATUS sequence_number(struct winbindd_domain *domain, uint32 *seq)
        result = rpccli_samr_query_dom_info(cli, mem_ctx, &dom_pol, 2, &ctr);
        
        if (NT_STATUS_IS_OK(result)) {
-               *seq = ctr.info.inf2.seq_num.low;
+               *seq = ctr.info.inf2.seq_num;
                got_seq_num = True;
        }
 
@@ -974,6 +1032,12 @@ NTSTATUS msrpc_lockout_policy(struct winbindd_domain *domain,
 
        DEBUG(10,("rpc: fetch lockout policy for %s\n", domain->name));
 
+       if ( !winbindd_can_contact_domain( domain ) ) {
+               DEBUG(10,("msrpc_lockout_policy: No incoming trust for domain %s\n",
+                         domain->name));
+               return NT_STATUS_NOT_SUPPORTED;
+       }
+
        result = cm_connect_sam(domain, mem_ctx, &cli, &dom_pol);
        if (!NT_STATUS_IS_OK(result)) {
                goto done;
@@ -1006,6 +1070,12 @@ NTSTATUS msrpc_password_policy(struct winbindd_domain *domain,
 
        DEBUG(10,("rpc: fetch password policy for %s\n", domain->name));
 
+       if ( !winbindd_can_contact_domain( domain ) ) {
+               DEBUG(10,("msrpc_password_policy: No incoming trust for domain %s\n",
+                         domain->name));
+               return NT_STATUS_NOT_SUPPORTED;
+       }
+
        result = cm_connect_sam(domain, mem_ctx, &cli, &dom_pol);
        if (!NT_STATUS_IS_OK(result)) {
                goto done;