r7415: * big change -- volker's new async winbindd from trunk
[samba.git] / source / nsswitch / winbindd_misc.c
index 448af3ac95783c6dc6ec2fe7cebcc01d1f973ca6..9cfa4c6fcc4eeb9c53401a63255609e4fa745fdf 100644 (file)
    Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
 */
 
+#include "includes.h"
 #include "winbindd.h"
 
-extern pstring global_myname;
+#undef DBGC_CLASS
+#define DBGC_CLASS DBGC_WINBIND
 
-/************************************************************************
- Routine to get the trust account password for a domain
-************************************************************************/
-static BOOL _get_trust_account_password(char *domain, unsigned char *ret_pwd, 
-                                       time_t *pass_last_set_time)
+/* Check the machine account password is valid */
+
+enum winbindd_result winbindd_check_machine_acct(struct winbindd_cli_state *state)
 {
-       if (!secrets_fetch_trust_account_password(domain, ret_pwd, pass_last_set_time)) {
-                return False;
-       }
+       DEBUG(3, ("[%5lu]: check machine account\n",
+                 (unsigned long)state->pid));
 
-       return True;
+       async_domain_request(state->mem_ctx, find_our_domain(),
+                            &state->request, &state->response,
+                            request_finished_cont, state);
+       return WINBINDD_PENDING;
 }
 
-/* Check the machine account password is valid */
-
-enum winbindd_result winbindd_check_machine_acct(struct winbindd_cli_state *state)
+enum winbindd_result winbindd_dual_check_machine_acct(struct winbindd_domain *domain,
+                                                     struct winbindd_cli_state *state)
 {
        NTSTATUS result = NT_STATUS_UNSUCCESSFUL;
-       uchar trust_passwd[16];
         int num_retries = 0;
-        struct cli_state *cli;
-       DEBUG(3, ("[%5d]: check machine account\n", state->pid));
+       struct winbindd_domain *contact_domain;
+
+       DEBUG(3, ("[%5lu]: check machine account\n", (unsigned long)state->pid));
 
        /* Get trust account password */
 
  again:
-       if (!_get_trust_account_password(lp_workgroup(), trust_passwd, 
-                                         NULL)) {
-               result = NT_STATUS_INTERNAL_ERROR;
-               goto done;
-       }
 
+       contact_domain = find_our_domain();
+       
         /* This call does a cli_nt_setup_creds() which implicitly checks
            the trust account password. */
 
-        result = cm_get_netlogon_cli(lp_workgroup(), trust_passwd, &cli);
+       invalidate_cm_connection(&contact_domain->conn);
+
+       {
+               struct rpc_pipe_client *cli;
+               unsigned char *session_key;
+               DOM_CRED *creds;
+
+               result = cm_connect_netlogon(contact_domain, state->mem_ctx,
+                                            &cli, &session_key, &creds);
+       }
 
         if (!NT_STATUS_IS_OK(result)) {
                 DEBUG(3, ("could not open handle to NETLOGON pipe\n"));
                 goto done;
         }
 
-        cli_shutdown(cli);
-
         /* There is a race condition between fetching the trust account
-           password and joining the domain so it's possible that the trust
-           account password has been changed on us.  We are returned
-           NT_STATUS_ACCESS_DENIED if this happens. */
+           password and the periodic machine password change.  So it's 
+          possible that the trust account password has been changed on us.  
+          We are returned NT_STATUS_ACCESS_DENIED if this happens. */
 
 #define MAX_RETRIES 8
 
@@ -89,66 +94,358 @@ enum winbindd_result winbindd_check_machine_acct(struct winbindd_cli_state *stat
                   "good" : "bad"));
 
  done:
-       state->response.data.num_entries = NT_STATUS_V(result);
+       state->response.data.auth.nt_status = NT_STATUS_V(result);
+       fstrcpy(state->response.data.auth.nt_status_string, nt_errstr(result));
+       fstrcpy(state->response.data.auth.error_string, nt_errstr(result));
+       state->response.data.auth.pam_error = nt_status_to_pam(result);
+
+       DEBUG(NT_STATUS_IS_OK(result) ? 5 : 2, ("Checking the trust account password returned %s\n", 
+                                               state->response.data.auth.nt_status_string));
+
+       return NT_STATUS_IS_OK(result) ? WINBINDD_OK : WINBINDD_ERROR;
+}
+
+enum winbindd_result winbindd_list_trusted_domains(struct winbindd_cli_state *state)
+{
+       DEBUG(3, ("[%5lu]: list trusted domains\n",
+                 (unsigned long)state->pid));
+
+       async_domain_request(state->mem_ctx, find_our_domain(),
+                            &state->request, &state->response,
+                            request_finished_cont, state);
+       return WINBINDD_PENDING;
+}
+
+enum winbindd_result winbindd_dual_list_trusted_domains(struct winbindd_domain *domain,
+                                                       struct winbindd_cli_state *state)
+{
+       uint32 i, num_domains;
+       char **names, **alt_names;
+       DOM_SID *sids;
+       int extra_data_len = 0;
+       char *extra_data;
+       NTSTATUS result;
+
+       DEBUG(3, ("[%5lu]: list trusted domains\n",
+                 (unsigned long)state->pid));
+
+       result = domain->methods->trusted_domains(domain, state->mem_ctx,
+                                                 &num_domains, &names,
+                                                 &alt_names, &sids);
+
+       extra_data = talloc_strdup(state->mem_ctx, "");
+
+       if (num_domains > 0)
+               extra_data = talloc_asprintf(state->mem_ctx, "%s\\%s\\%s",
+                                            names[0], alt_names[0],
+                                            sid_string_static(&sids[0]));
+
+       for (i=1; i<num_domains; i++)
+               extra_data = talloc_asprintf(state->mem_ctx, "%s\n%s\\%s\\%s",
+                                            extra_data,
+                                            names[i], alt_names[i],
+                                            sid_string_static(&sids[i]));
+
+       /* This is a bit excessive, but the extra data sooner or later will be
+          talloc'ed */
+
+       extra_data_len = strlen(extra_data);
+
+       if (extra_data_len > 0) {
+               state->response.extra_data = SMB_STRDUP(extra_data);
+               state->response.length += extra_data_len+1;
+       }
 
        return WINBINDD_OK;
 }
 
-enum winbindd_result winbindd_list_trusted_domains(struct winbindd_cli_state
-                                                  *state)
+enum winbindd_result winbindd_getdcname(struct winbindd_cli_state *state)
 {
-       struct winbindd_domain *domain;
-       int total_entries = 0, extra_data_len = 0;
-       char *ted, *extra_data = NULL;
+       state->request.domain_name
+               [sizeof(state->request.domain_name)-1] = '\0';
+
+       DEBUG(3, ("[%5lu]: Get DC name for %s\n", (unsigned long)state->pid,
+                 state->request.domain_name));
+
+       async_domain_request(state->mem_ctx, find_our_domain(),
+                            &state->request, &state->response,
+                            request_finished_cont, state);
+       return WINBINDD_PENDING;
+}
+
+enum winbindd_result winbindd_dual_getdcname(struct winbindd_domain *domain,
+                                            struct winbindd_cli_state *state)
+{
+       fstring dcname_slash;
+       char *p;
+       struct rpc_pipe_client *cli;
+       NTSTATUS result;
+
+       state->request.domain_name
+               [sizeof(state->request.domain_name)-1] = '\0';
+
+       DEBUG(3, ("[%5lu]: Get DC name for %s\n", (unsigned long)state->pid,
+                 state->request.domain_name));
+
+       {
+               /* These var's can be ignored -- we're not requesting
+                  anything in the credential chain here */
+               unsigned char *session_key;
+               DOM_CRED *creds;
+               result = cm_connect_netlogon(domain, state->mem_ctx, &cli,
+                                            &session_key, &creds);
+       }
+
+       if (!NT_STATUS_IS_OK(result)) {
+               DEBUG(1, ("Can't contact our the NETLOGON pipe\n"));
+               return WINBINDD_ERROR;
+       }
 
-       DEBUG(3, ("[%5d]: list trusted domains\n", state->pid));
+       result = rpccli_netlogon_getdcname(cli, state->mem_ctx, domain->dcname,
+                                          state->request.domain_name,
+                                          dcname_slash);
 
-       /* We need to refresh the trusted domain list as the domains may
-          have changed since we last looked.  There may be a sequence
-          number or something we should use but I haven't found it yet. */
+       if (!NT_STATUS_IS_OK(result)) {
+               DEBUG(5, ("Error requesting DCname: %s\n", nt_errstr(result)));
+               return WINBINDD_ERROR;
+       }
 
-       init_domain_list();
+       p = dcname_slash;
+       if (*p == '\\') p+=1;
+       if (*p == '\\') p+=1;
 
-       for(domain = domain_list(); domain; domain = domain->next) {
+       fstrcpy(state->response.data.dc_name, p);
 
-               /* Skip own domain */
+       return WINBINDD_OK;
+}
 
-               if (strequal(domain->name, lp_workgroup())) continue;
+struct sequence_state {
+       TALLOC_CTX *mem_ctx;
+       struct winbindd_cli_state *cli_state;
+       struct winbindd_domain *domain;
+       struct winbindd_request *request;
+       struct winbindd_response *response;
+       char *extra_data;
+};
 
-               /* Add domain to list */
+static void sequence_recv(void *private, BOOL success);
 
-               total_entries++;
-               ted = Realloc(extra_data, sizeof(fstring) * 
-                              total_entries);
+enum winbindd_result winbindd_show_sequence(struct winbindd_cli_state *state)
+{
+       struct sequence_state *seq;
+
+       /* Ensure null termination */
+       state->request.domain_name[sizeof(state->request.domain_name)-1]='\0';
 
-               if (!ted) {
-                       DEBUG(0,("winbindd_list_trusted_domains: failed to enlarge buffer!\n"));
-                       SAFE_FREE(extra_data);
+       if (strlen(state->request.domain_name) > 0) {
+               struct winbindd_domain *domain;
+               domain = find_domain_from_name_noinit(
+                       state->request.domain_name);
+               if (domain == NULL)
                        return WINBINDD_ERROR;
-               } else 
-                        extra_data = ted;
+               async_domain_request(state->mem_ctx, domain,
+                                    &state->request, &state->response,
+                                    request_finished_cont, state);
+               return WINBINDD_PENDING;
+       }
+
+       /* Ask all domains in sequence, collect the results in sequence_recv */
+
+       seq = TALLOC_P(state->mem_ctx, struct sequence_state);
+       if (seq == NULL) {
+               DEBUG(0, ("talloc failed\n"));
+               return WINBINDD_ERROR;
+       }
+
+       seq->mem_ctx = state->mem_ctx;
+       seq->cli_state = state;
+       seq->domain = domain_list();
+       if (seq->domain == NULL) {
+               DEBUG(0, ("domain list empty\n"));
+               return WINBINDD_ERROR;
+       }
+       seq->request = TALLOC_ZERO_P(state->mem_ctx,
+                                    struct winbindd_request);
+       seq->response = TALLOC_ZERO_P(state->mem_ctx,
+                                     struct winbindd_response);
+       seq->extra_data = talloc_strdup(state->mem_ctx, "");
+
+       if ((seq->request == NULL) || (seq->response == NULL) ||
+           (seq->extra_data == NULL)) {
+               DEBUG(0, ("talloc failed\n"));
+               return WINBINDD_ERROR;
+       }
+
+       seq->request->length = sizeof(*seq->request);
+       seq->request->cmd = WINBINDD_SHOW_SEQUENCE;
+       fstrcpy(seq->request->domain_name, seq->domain->name);
 
-               memcpy(&extra_data[extra_data_len], domain->name,
-                      strlen(domain->name));
+       async_domain_request(state->mem_ctx, seq->domain,
+                            seq->request, seq->response,
+                            sequence_recv, seq);
+       return WINBINDD_PENDING;
+}
+
+static void sequence_recv(void *private, BOOL success)
+{
+       struct sequence_state *state = private;
+       uint32 seq = DOM_SEQUENCE_NONE;
+
+       if ((success) && (state->response->result == WINBINDD_OK))
+               seq = state->response->data.domain_info.sequence_number;
+
+       if (seq == DOM_SEQUENCE_NONE) {
+               state->extra_data = talloc_asprintf(state->mem_ctx,
+                                                   "%s%s : DISCONNECTED\n",
+                                                   state->extra_data,
+                                                   state->domain->name);
+       } else {
+               state->extra_data = talloc_asprintf(state->mem_ctx,
+                                                   "%s%s : %d\n",
+                                                   state->extra_data,
+                                                   state->domain->name, seq);
+       }
+
+       state->domain->sequence_number = seq;
+
+       state->domain = state->domain->next;
+
+       if (state->domain == NULL) {
+               struct winbindd_cli_state *cli_state = state->cli_state;
+               cli_state->response.result = WINBINDD_OK;
+               cli_state->response.length =
+                       sizeof(cli_state->response) +
+                       strlen(state->extra_data) + 1;
+               cli_state->response.extra_data =
+                       SMB_STRDUP(state->extra_data);
+               request_finished(cli_state);
+               return;
+       }
+
+       /* Ask the next domain */
+       fstrcpy(state->request->domain_name, state->domain->name);
+       async_domain_request(state->mem_ctx, state->domain,
+                            state->request, state->response,
+                            sequence_recv, state);
+}
+
+/* This is the child-only version of --sequence. It only allows for a single
+ * domain (ie "our" one) to be displayed. */
+
+enum winbindd_result winbindd_dual_show_sequence(struct winbindd_domain *domain,
+                                                struct winbindd_cli_state *state)
+{
+       DEBUG(3, ("[%5lu]: show sequence\n", (unsigned long)state->pid));
+
+       /* Ensure null termination */
+       state->request.domain_name[sizeof(state->request.domain_name)-1]='\0';
 
-               extra_data_len  += strlen(domain->name);
-               extra_data[extra_data_len++] = ',';
+       domain->methods->sequence_number(domain, &domain->sequence_number);
+
+       state->response.data.domain_info.sequence_number =
+               domain->sequence_number;
+
+       return WINBINDD_OK;
+}
+
+struct domain_info_state {
+       struct winbindd_domain *domain;
+       struct winbindd_cli_state *cli_state;
+};
+
+static void domain_info_init_recv(void *private, BOOL success);
+
+enum winbindd_result winbindd_domain_info(struct winbindd_cli_state *state)
+{
+       struct winbindd_domain *domain;
+
+       DEBUG(3, ("[%5lu]: domain_info [%s]\n", (unsigned long)state->pid,
+                 state->request.domain_name));
+
+       domain = find_domain_from_name_noinit(state->request.domain_name);
+
+       if (domain == NULL) {
+               DEBUG(3, ("Did not find domain [%s]\n",
+                         state->request.domain_name));
+               return WINBINDD_ERROR;
        }
 
-       if (extra_data) {
-               if (extra_data_len > 1) 
-                        extra_data[extra_data_len - 1] = '\0';
-               state->response.extra_data = extra_data;
-               state->response.length += extra_data_len;
+       if (!domain->initialized) {
+               struct domain_info_state *istate;
+
+               istate = TALLOC_P(state->mem_ctx, struct domain_info_state);
+               if (istate == NULL) {
+                       DEBUG(0, ("talloc failed\n"));
+                       return WINBINDD_ERROR;
+               }
+
+               istate->cli_state = state;
+               istate->domain = domain;
+
+               init_child_connection(domain, domain_info_init_recv, istate);
+                                     
+               return WINBINDD_PENDING;
        }
 
+       fstrcpy(state->response.data.domain_info.name,
+               domain->name);
+       fstrcpy(state->response.data.domain_info.alt_name,
+               domain->alt_name);
+       fstrcpy(state->response.data.domain_info.sid,
+               sid_string_static(&domain->sid));
+       
+       state->response.data.domain_info.native_mode =
+               domain->native_mode;
+       state->response.data.domain_info.active_directory =
+               domain->active_directory;
+       state->response.data.domain_info.primary =
+               domain->primary;
+       state->response.data.domain_info.sequence_number =
+               domain->sequence_number;
+
        return WINBINDD_OK;
 }
 
+static void domain_info_init_recv(void *private, BOOL success)
+{
+       struct domain_info_state *istate = private;
+       struct winbindd_cli_state *state = istate->cli_state;
+       struct winbindd_domain *domain = istate->domain;
+
+       DEBUG(10, ("Got back from child init: %d\n", success));
+
+       if ((!success) || (!domain->initialized)) {
+               DEBUG(5, ("Could not init child for domain %s\n",
+                         domain->name));
+               state->response.result = WINBINDD_ERROR;
+               request_finished_cont(state, False);
+               return;
+       }
+
+       fstrcpy(state->response.data.domain_info.name,
+               domain->name);
+       fstrcpy(state->response.data.domain_info.alt_name,
+               domain->alt_name);
+       fstrcpy(state->response.data.domain_info.sid,
+               sid_string_static(&domain->sid));
+       
+       state->response.data.domain_info.native_mode =
+               domain->native_mode;
+       state->response.data.domain_info.active_directory =
+               domain->active_directory;
+       state->response.data.domain_info.primary =
+               domain->primary;
+       state->response.data.domain_info.sequence_number =
+               domain->sequence_number;
+
+       state->response.result = WINBINDD_OK;
+       request_finished_cont(state, True);
+}
+
 enum winbindd_result winbindd_ping(struct winbindd_cli_state
                                                   *state)
 {
-       DEBUG(3, ("[%5d]: ping\n", state->pid));
+       DEBUG(3, ("[%5lu]: ping\n", (unsigned long)state->pid));
 
        return WINBINDD_OK;
 }
@@ -158,10 +455,10 @@ enum winbindd_result winbindd_ping(struct winbindd_cli_state
 enum winbindd_result winbindd_info(struct winbindd_cli_state *state)
 {
 
-       DEBUG(3, ("[%5d]: request misc info\n", state->pid));
+       DEBUG(3, ("[%5lu]: request misc info\n", (unsigned long)state->pid));
 
        state->response.data.info.winbind_separator = *lp_winbind_separator();
-       fstrcpy(state->response.data.info.samba_version, VERSION);
+       fstrcpy(state->response.data.info.samba_version, SAMBA_VERSION_STRING);
 
        return WINBINDD_OK;
 }
@@ -171,7 +468,7 @@ enum winbindd_result winbindd_info(struct winbindd_cli_state *state)
 enum winbindd_result winbindd_interface_version(struct winbindd_cli_state *state)
 {
 
-       DEBUG(3, ("[%5d]: request interface version\n", state->pid));
+       DEBUG(3, ("[%5lu]: request interface version\n", (unsigned long)state->pid));
        
        state->response.data.interface_version = WINBIND_INTERFACE_VERSION;
 
@@ -183,9 +480,38 @@ enum winbindd_result winbindd_interface_version(struct winbindd_cli_state *state
 enum winbindd_result winbindd_domain_name(struct winbindd_cli_state *state)
 {
 
-       DEBUG(3, ("[%5d]: request domain name\n", state->pid));
+       DEBUG(3, ("[%5lu]: request domain name\n", (unsigned long)state->pid));
        
        fstrcpy(state->response.data.domain_name, lp_workgroup());
 
        return WINBINDD_OK;
 }
+
+/* What's my name again? */
+
+enum winbindd_result winbindd_netbios_name(struct winbindd_cli_state *state)
+{
+
+       DEBUG(3, ("[%5lu]: request netbios name\n", (unsigned long)state->pid));
+       
+       fstrcpy(state->response.data.netbios_name, global_myname());
+
+       return WINBINDD_OK;
+}
+
+/* Where can I find the privilaged pipe? */
+
+enum winbindd_result winbindd_priv_pipe_dir(struct winbindd_cli_state *state)
+{
+
+       DEBUG(3, ("[%5lu]: request location of privileged pipe\n", (unsigned long)state->pid));
+       
+       state->response.extra_data = SMB_STRDUP(get_winbind_priv_pipe_dir());
+       if (!state->response.extra_data)
+               return WINBINDD_ERROR;
+
+       /* must add one to length to copy the 0 for string termination */
+       state->response.length += strlen((char *)state->response.extra_data) + 1;
+
+       return WINBINDD_OK;
+}