1
0
mirror of https://github.com/samba-team/samba.git synced 2025-08-26 01:49:31 +03:00

s3:winbindd: implement _winbind_LogonControl*()

This implements NETLOGON_CONTROL_{REDISCOVER,TC_QUERY,TC_VERIFY,CHANGE_PASSWORD}.
These are triggered by the netlogon server (currently only as AD DC) via IRPC.

While NETLOGON_CONTROL_REDISCOVER ignores an optional '\dcname' at the end of
the specified domain name for now.

Signed-off-by: Stefan Metzmacher <metze@samba.org>
Reviewed-by: Andrew Bartlett <abartlet@samba.org>
This commit is contained in:
Stefan Metzmacher
2014-12-23 09:04:42 +01:00
parent ee5e25b5b3
commit 03e846bc27

View File

@ -27,9 +27,12 @@
#include "ntdomain.h"
#include "librpc/gen_ndr/srv_winbind.h"
#include "../librpc/gen_ndr/ndr_netlogon_c.h"
#include "../librpc/gen_ndr/ndr_lsa_c.h"
#include "idmap.h"
#include "../libcli/security/security.h"
#include "../libcli/auth/netlogon_creds_cli.h"
#include "passdb.h"
#include "../source4/dsdb/samdb/samdb.h"
void _wbint_Ping(struct pipes_struct *p, struct wbint_Ping *r)
{
@ -871,6 +874,559 @@ NTSTATUS _winbind_SamLogon(struct pipes_struct *p,
return status;
}
static WERROR _winbind_LogonControl_REDISCOVER(struct pipes_struct *p,
struct winbindd_domain *domain,
struct winbind_LogonControl *r)
{
NTSTATUS status;
struct rpc_pipe_client *netlogon_pipe = NULL;
struct netr_NETLOGON_INFO_2 *info2 = NULL;
WERROR check_result = WERR_INTERNAL_ERROR;
info2 = talloc_zero(p->mem_ctx, struct netr_NETLOGON_INFO_2);
if (info2 == NULL) {
return WERR_NOMEM;
}
if (domain->internal) {
check_result = WERR_OK;
goto check_return;
}
/*
* For now we just force a reconnect
*
* TODO: take care of the optional '\dcname'
*/
invalidate_cm_connection(domain);
domain->conn.netlogon_force_reauth = true;
status = cm_connect_netlogon(domain, &netlogon_pipe);
reset_cm_connection_on_error(domain, status);
if (NT_STATUS_EQUAL(status, NT_STATUS_DOMAIN_CONTROLLER_NOT_FOUND)) {
status = NT_STATUS_NO_LOGON_SERVERS;
}
if (!NT_STATUS_IS_OK(status)) {
DEBUG(2, ("%s: domain[%s/%s] cm_connect_netlogon() returned %s\n",
__func__, domain->name, domain->alt_name,
nt_errstr(status)));
/*
* Here we return a top level error!
* This is different than TC_QUERY or TC_VERIFY.
*/
return ntstatus_to_werror(status);
}
check_result = WERR_OK;
check_return:
info2->pdc_connection_status = WERR_OK;
if (domain->dcname != NULL) {
info2->flags |= NETLOGON_HAS_IP;
info2->flags |= NETLOGON_HAS_TIMESERV;
info2->trusted_dc_name = talloc_asprintf(info2, "\\\\%s",
domain->dcname);
if (info2->trusted_dc_name == NULL) {
return WERR_NOMEM;
}
} else {
info2->trusted_dc_name = talloc_strdup(info2, "");
if (info2->trusted_dc_name == NULL) {
return WERR_NOMEM;
}
}
info2->tc_connection_status = check_result;
if (!W_ERROR_IS_OK(info2->pdc_connection_status)) {
DEBUG(2, ("%s: domain[%s/%s] dcname[%s] "
"pdc_connection[%s] tc_connection[%s]\n",
__func__, domain->name, domain->alt_name,
domain->dcname,
win_errstr(info2->pdc_connection_status),
win_errstr(info2->tc_connection_status)));
}
r->out.query->info2 = info2;
DEBUG(5, ("%s: succeeded.\n", __func__));
return WERR_OK;
}
static WERROR _winbind_LogonControl_TC_QUERY(struct pipes_struct *p,
struct winbindd_domain *domain,
struct winbind_LogonControl *r)
{
NTSTATUS status;
struct rpc_pipe_client *netlogon_pipe = NULL;
struct netr_NETLOGON_INFO_2 *info2 = NULL;
WERROR check_result = WERR_INTERNAL_ERROR;
info2 = talloc_zero(p->mem_ctx, struct netr_NETLOGON_INFO_2);
if (info2 == NULL) {
return WERR_NOMEM;
}
if (domain->internal) {
check_result = WERR_OK;
goto check_return;
}
status = cm_connect_netlogon(domain, &netlogon_pipe);
reset_cm_connection_on_error(domain, status);
if (NT_STATUS_EQUAL(status, NT_STATUS_DOMAIN_CONTROLLER_NOT_FOUND)) {
status = NT_STATUS_NO_LOGON_SERVERS;
}
if (!NT_STATUS_IS_OK(status)) {
DEBUG(3, ("could not open handle to NETLOGON pipe: %s\n",
nt_errstr(status)));
check_result = ntstatus_to_werror(status);
goto check_return;
}
check_result = WERR_OK;
check_return:
info2->pdc_connection_status = WERR_OK;
if (domain->dcname != NULL) {
info2->flags |= NETLOGON_HAS_IP;
info2->flags |= NETLOGON_HAS_TIMESERV;
info2->trusted_dc_name = talloc_asprintf(info2, "\\\\%s",
domain->dcname);
if (info2->trusted_dc_name == NULL) {
return WERR_NOMEM;
}
} else {
info2->trusted_dc_name = talloc_strdup(info2, "");
if (info2->trusted_dc_name == NULL) {
return WERR_NOMEM;
}
}
info2->tc_connection_status = check_result;
if (!W_ERROR_IS_OK(info2->pdc_connection_status)) {
DEBUG(2, ("%s: domain[%s/%s] dcname[%s] "
"pdc_connection[%s] tc_connection[%s]\n",
__func__, domain->name, domain->alt_name,
domain->dcname,
win_errstr(info2->pdc_connection_status),
win_errstr(info2->tc_connection_status)));
}
r->out.query->info2 = info2;
DEBUG(5, ("%s: succeeded.\n", __func__));
return WERR_OK;
}
static WERROR _winbind_LogonControl_TC_VERIFY(struct pipes_struct *p,
struct winbindd_domain *domain,
struct winbind_LogonControl *r)
{
TALLOC_CTX *frame = talloc_stackframe();
NTSTATUS status;
NTSTATUS result;
struct lsa_String trusted_domain_name = {};
struct lsa_StringLarge trusted_domain_name_l = {};
struct rpc_pipe_client *local_lsa_pipe = NULL;
struct policy_handle local_lsa_policy = {};
struct dcerpc_binding_handle *local_lsa = NULL;
struct rpc_pipe_client *netlogon_pipe = NULL;
struct cli_credentials *creds = NULL;
struct samr_Password *cur_nt_hash = NULL;
uint32_t trust_attributes = 0;
struct samr_Password new_owf_password = {};
int cmp_new = -1;
struct samr_Password old_owf_password = {};
int cmp_old = -1;
const struct lsa_TrustDomainInfoInfoEx *local_tdo = NULL;
bool fetch_fti = false;
struct lsa_ForestTrustInformation *new_fti = NULL;
struct netr_TrustInfo *trust_info = NULL;
struct netr_NETLOGON_INFO_2 *info2 = NULL;
struct dcerpc_binding_handle *b = NULL;
WERROR check_result = WERR_INTERNAL_ERROR;
WERROR verify_result = WERR_INTERNAL_ERROR;
bool retry = false;
trusted_domain_name.string = domain->name;
trusted_domain_name_l.string = domain->name;
info2 = talloc_zero(p->mem_ctx, struct netr_NETLOGON_INFO_2);
if (info2 == NULL) {
TALLOC_FREE(frame);
return WERR_NOMEM;
}
if (domain->internal) {
check_result = WERR_OK;
goto check_return;
}
status = pdb_get_trust_credentials(domain->name,
domain->alt_name,
frame,
&creds);
if (NT_STATUS_IS_OK(status)) {
cur_nt_hash = cli_credentials_get_nt_hash(creds, frame);
TALLOC_FREE(creds);
}
if (!domain->primary) {
union lsa_TrustedDomainInfo *tdi = NULL;
status = open_internal_lsa_conn(frame, &local_lsa_pipe,
&local_lsa_policy);
if (!NT_STATUS_IS_OK(status)) {
DEBUG(0,("%s:%s: open_internal_lsa_conn() failed - %s\n",
__location__, __func__, nt_errstr(status)));
TALLOC_FREE(frame);
return WERR_INTERNAL_ERROR;
}
local_lsa = local_lsa_pipe->binding_handle;
status = dcerpc_lsa_QueryTrustedDomainInfoByName(local_lsa, frame,
&local_lsa_policy,
&trusted_domain_name,
LSA_TRUSTED_DOMAIN_INFO_INFO_EX,
&tdi, &result);
if (!NT_STATUS_IS_OK(status)) {
DEBUG(0,("%s:%s: local_lsa.QueryTrustedDomainInfoByName(%s) failed - %s\n",
__location__, __func__, domain->name, nt_errstr(status)));
TALLOC_FREE(frame);
return WERR_INTERNAL_ERROR;
}
if (NT_STATUS_EQUAL(result, NT_STATUS_OBJECT_NAME_NOT_FOUND)) {
DEBUG(1,("%s:%s: domain[%s] not found via LSA, might be removed already.\n",
__location__, __func__, domain->name));
TALLOC_FREE(frame);
return WERR_NO_SUCH_DOMAIN;
}
if (!NT_STATUS_IS_OK(result)) {
DEBUG(0,("%s:%s: local_lsa.QueryTrustedDomainInfoByName(%s) returned %s\n",
__location__, __func__, domain->name, nt_errstr(result)));
TALLOC_FREE(frame);
return WERR_INTERNAL_ERROR;
}
if (tdi == NULL) {
DEBUG(0,("%s:%s: local_lsa.QueryTrustedDomainInfoByName() "
"returned no trusted domain information\n",
__location__, __func__));
TALLOC_FREE(frame);
return WERR_INTERNAL_ERROR;
}
local_tdo = &tdi->info_ex;
trust_attributes = local_tdo->trust_attributes;
}
if (trust_attributes & LSA_TRUST_ATTRIBUTE_FOREST_TRANSITIVE) {
struct lsa_ForestTrustInformation *old_fti = NULL;
status = dcerpc_lsa_lsaRQueryForestTrustInformation(local_lsa, frame,
&local_lsa_policy,
&trusted_domain_name,
LSA_FOREST_TRUST_DOMAIN_INFO,
&old_fti, &result);
if (!NT_STATUS_IS_OK(status)) {
DEBUG(0,("%s:%s: local_lsa.lsaRQueryForestTrustInformation(%s) failed %s\n",
__location__, __func__, domain->name, nt_errstr(status)));
TALLOC_FREE(frame);
return WERR_INTERNAL_ERROR;
}
if (NT_STATUS_EQUAL(result, NT_STATUS_NOT_FOUND)) {
DEBUG(2,("%s: no forest trust information available for domain[%s] yet.\n",
__func__, domain->name));
old_fti = NULL;
fetch_fti = true;
result = NT_STATUS_OK;
}
if (!NT_STATUS_IS_OK(result)) {
DEBUG(0,("%s:%s: local_lsa.lsaRQueryForestTrustInformation(%s) returned %s\n",
__location__, __func__, domain->name, nt_errstr(result)));
TALLOC_FREE(frame);
return WERR_INTERNAL_ERROR;
}
TALLOC_FREE(old_fti);
}
reconnect:
status = cm_connect_netlogon(domain, &netlogon_pipe);
reset_cm_connection_on_error(domain, status);
if (NT_STATUS_EQUAL(status, NT_STATUS_DOMAIN_CONTROLLER_NOT_FOUND)) {
status = NT_STATUS_NO_LOGON_SERVERS;
}
if (!NT_STATUS_IS_OK(status)) {
DEBUG(3, ("could not open handle to NETLOGON pipe: %s\n",
nt_errstr(status)));
check_result = ntstatus_to_werror(status);
goto check_return;
}
check_result = WERR_OK;
b = netlogon_pipe->binding_handle;
if (cur_nt_hash == NULL) {
verify_result = WERR_NO_TRUST_LSA_SECRET;
goto verify_return;
}
if (fetch_fti) {
status = netlogon_creds_cli_GetForestTrustInformation(domain->conn.netlogon_creds,
b, frame,
&new_fti);
if (NT_STATUS_EQUAL(status, NT_STATUS_RPC_PROCNUM_OUT_OF_RANGE)) {
status = NT_STATUS_NOT_SUPPORTED;
}
if (NT_STATUS_EQUAL(status, NT_STATUS_NOT_SUPPORTED)) {
new_fti = NULL;
status = NT_STATUS_OK;
}
if (!NT_STATUS_IS_OK(status)) {
if (!retry && dcerpc_binding_handle_is_connected(b)) {
invalidate_cm_connection(domain);
retry = true;
goto reconnect;
}
DEBUG(2, ("netlogon_creds_cli_GetForestTrustInformation(%s)"
"failed: %s\n",
domain->name, nt_errstr(status)));
check_result = ntstatus_to_werror(status);
goto check_return;
}
}
if (new_fti != NULL) {
struct lsa_ForestTrustInformation old_fti = {};
struct lsa_ForestTrustInformation *merged_fti = NULL;
struct lsa_ForestTrustCollisionInfo *collision_info = NULL;
status = dsdb_trust_merge_forest_info(frame, local_tdo,
&old_fti, new_fti,
&merged_fti);
if (!NT_STATUS_IS_OK(status)) {
DEBUG(0,("%s:%s: dsdb_trust_merge_forest_info(%s) failed %s\n",
__location__, __func__,
domain->name, nt_errstr(status)));
TALLOC_FREE(frame);
return ntstatus_to_werror(status);
}
status = dcerpc_lsa_lsaRSetForestTrustInformation(local_lsa, frame,
&local_lsa_policy,
&trusted_domain_name_l,
LSA_FOREST_TRUST_DOMAIN_INFO,
merged_fti,
0, /* check_only=0 => store it! */
&collision_info,
&result);
if (!NT_STATUS_IS_OK(status)) {
DEBUG(0,("%s:%s: local_lsa.lsaRSetForestTrustInformation(%s) failed %s\n",
__location__, __func__, domain->name, nt_errstr(status)));
TALLOC_FREE(frame);
return WERR_INTERNAL_ERROR;
}
if (!NT_STATUS_IS_OK(result)) {
DEBUG(0,("%s:%s: local_lsa.lsaRSetForestTrustInformation(%s) returned %s\n",
__location__, __func__, domain->name, nt_errstr(result)));
TALLOC_FREE(frame);
return ntstatus_to_werror(status);
}
}
status = netlogon_creds_cli_ServerGetTrustInfo(domain->conn.netlogon_creds,
b, frame,
&new_owf_password,
&old_owf_password,
&trust_info);
if (NT_STATUS_EQUAL(status, NT_STATUS_RPC_PROCNUM_OUT_OF_RANGE)) {
status = NT_STATUS_NOT_SUPPORTED;
}
if (NT_STATUS_EQUAL(status, NT_STATUS_NOT_SUPPORTED)) {
DEBUG(5, ("netlogon_creds_cli_ServerGetTrustInfo failed: %s\n",
nt_errstr(status)));
verify_result = WERR_OK;
goto verify_return;
}
if (!NT_STATUS_IS_OK(status)) {
if (!retry && dcerpc_binding_handle_is_connected(b)) {
invalidate_cm_connection(domain);
retry = true;
goto reconnect;
}
DEBUG(2, ("netlogon_creds_cli_ServerGetTrustInfo failed: %s\n",
nt_errstr(status)));
if (!dcerpc_binding_handle_is_connected(b)) {
check_result = ntstatus_to_werror(status);
goto check_return;
} else {
verify_result = ntstatus_to_werror(status);
goto verify_return;
}
}
if (trust_info != NULL && trust_info->count >= 1) {
uint32_t diff = trust_info->data[0] ^ trust_attributes;
if (diff & LSA_TRUST_ATTRIBUTE_FOREST_TRANSITIVE) {
verify_result = WERR_DOMAIN_TRUST_INCONSISTENT;
goto verify_return;
}
}
cmp_new = memcmp(new_owf_password.hash,
cur_nt_hash->hash,
sizeof(cur_nt_hash->hash));
cmp_old = memcmp(old_owf_password.hash,
cur_nt_hash->hash,
sizeof(cur_nt_hash->hash));
if (cmp_new != 0 && cmp_old != 0) {
DEBUG(1,("%s:Error: credentials for domain[%s/%s] doesn't match "
"any password known to dcname[%s]\n",
__func__, domain->name, domain->alt_name,
domain->dcname));
verify_result = WERR_WRONG_PASSWORD;
goto verify_return;
}
if (cmp_new != 0) {
DEBUG(2,("%s:Warning: credentials for domain[%s/%s] only match "
"against the old password known to dcname[%s]\n",
__func__, domain->name, domain->alt_name,
domain->dcname));
}
verify_result = WERR_OK;
goto verify_return;
check_return:
verify_result = check_result;
verify_return:
info2->flags |= NETLOGON_VERIFY_STATUS_RETURNED;
info2->pdc_connection_status = verify_result;
if (domain->dcname != NULL) {
info2->flags |= NETLOGON_HAS_IP;
info2->flags |= NETLOGON_HAS_TIMESERV;
info2->trusted_dc_name = talloc_asprintf(info2, "\\\\%s",
domain->dcname);
if (info2->trusted_dc_name == NULL) {
TALLOC_FREE(frame);
return WERR_NOMEM;
}
} else {
info2->trusted_dc_name = talloc_strdup(info2, "");
if (info2->trusted_dc_name == NULL) {
TALLOC_FREE(frame);
return WERR_NOMEM;
}
}
info2->tc_connection_status = check_result;
if (!W_ERROR_IS_OK(info2->pdc_connection_status)) {
DEBUG(2, ("%s: domain[%s/%s] dcname[%s] "
"pdc_connection[%s] tc_connection[%s]\n",
__func__, domain->name, domain->alt_name,
domain->dcname,
win_errstr(info2->pdc_connection_status),
win_errstr(info2->tc_connection_status)));
}
r->out.query->info2 = info2;
DEBUG(5, ("%s: succeeded.\n", __func__));
TALLOC_FREE(frame);
return WERR_OK;
}
static WERROR _winbind_LogonControl_CHANGE_PASSWORD(struct pipes_struct *p,
struct winbindd_domain *domain,
struct winbind_LogonControl *r)
{
struct messaging_context *msg_ctx = winbind_messaging_context();
NTSTATUS status;
struct rpc_pipe_client *netlogon_pipe;
struct cli_credentials *creds = NULL;
struct samr_Password *cur_nt_hash = NULL;
struct netr_NETLOGON_INFO_1 *info1 = NULL;
struct dcerpc_binding_handle *b;
WERROR change_result = WERR_OK;
bool retry = false;
info1 = talloc_zero(p->mem_ctx, struct netr_NETLOGON_INFO_1);
if (info1 == NULL) {
return WERR_NOMEM;
}
if (domain->internal) {
return WERR_NOT_SUPPORTED;
}
status = pdb_get_trust_credentials(domain->name,
domain->alt_name,
p->mem_ctx,
&creds);
if (NT_STATUS_IS_OK(status)) {
cur_nt_hash = cli_credentials_get_nt_hash(creds, p->mem_ctx);
TALLOC_FREE(creds);
}
reconnect:
status = cm_connect_netlogon(domain, &netlogon_pipe);
reset_cm_connection_on_error(domain, status);
if (NT_STATUS_EQUAL(status, NT_STATUS_DOMAIN_CONTROLLER_NOT_FOUND)) {
status = NT_STATUS_NO_LOGON_SERVERS;
}
if (!NT_STATUS_IS_OK(status)) {
DEBUG(2, ("%s: domain[%s/%s] cm_connect_netlogon() returned %s\n",
__func__, domain->name, domain->alt_name,
nt_errstr(status)));
/*
* Here we return a top level error!
* This is different than TC_QUERY or TC_VERIFY.
*/
return ntstatus_to_werror(status);
}
b = netlogon_pipe->binding_handle;
if (cur_nt_hash == NULL) {
change_result = WERR_NO_TRUST_LSA_SECRET;
goto change_return;
}
TALLOC_FREE(cur_nt_hash);
status = trust_pw_change(domain->conn.netlogon_creds,
msg_ctx, b, domain->name,
true); /* force */
if (!NT_STATUS_IS_OK(status)) {
if (!retry && dcerpc_binding_handle_is_connected(b)) {
invalidate_cm_connection(domain);
retry = true;
goto reconnect;
}
DEBUG(1, ("trust_pw_change(%s): %s\n",
domain->name, nt_errstr(status)));
change_result = ntstatus_to_werror(status);
goto change_return;
}
change_result = WERR_OK;
change_return:
info1->pdc_connection_status = change_result;
if (!W_ERROR_IS_OK(info1->pdc_connection_status)) {
DEBUG(2, ("%s: domain[%s/%s] dcname[%s] "
"pdc_connection[%s]\n",
__func__, domain->name, domain->alt_name,
domain->dcname,
win_errstr(info1->pdc_connection_status)));
}
r->out.query->info1 = info1;
DEBUG(5, ("%s: succeeded.\n", __func__));
return WERR_OK;
}
WERROR _winbind_LogonControl(struct pipes_struct *p,
struct winbind_LogonControl *r)
{
@ -881,5 +1437,32 @@ WERROR _winbind_LogonControl(struct pipes_struct *p,
return WERR_NO_SUCH_DOMAIN;
}
switch (r->in.function_code) {
case NETLOGON_CONTROL_REDISCOVER:
if (r->in.level != 2) {
return WERR_INVALID_PARAMETER;
}
return _winbind_LogonControl_REDISCOVER(p, domain, r);
case NETLOGON_CONTROL_TC_QUERY:
if (r->in.level != 2) {
return WERR_INVALID_PARAMETER;
}
return _winbind_LogonControl_TC_QUERY(p, domain, r);
case NETLOGON_CONTROL_TC_VERIFY:
if (r->in.level != 2) {
return WERR_INVALID_PARAMETER;
}
return _winbind_LogonControl_TC_VERIFY(p, domain, r);
case NETLOGON_CONTROL_CHANGE_PASSWORD:
if (r->in.level != 1) {
return WERR_INVALID_PARAMETER;
}
return _winbind_LogonControl_CHANGE_PASSWORD(p, domain, r);
default:
break;
}
DEBUG(4, ("%s: function_code[0x%x] not supported\n",
__func__, r->in.function_code));
return WERR_NOT_SUPPORTED;
}