/* Unix SMB/CIFS implementation. test suite for netlogon rpc operations Copyright (C) Andrew Tridgell 2003 Copyright (C) Andrew Bartlett 2003-2004 Copyright (C) Tim Potter 2003 Copyright (C) Matthias Dieter Wallnöfer 2009 This program is free software; you can redistribute it and/or modify it under the terms of the GNU General Public License as published by the Free Software Foundation; either version 3 of the License, or (at your option) any later version. This program is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details. You should have received a copy of the GNU General Public License along with this program. If not, see . */ #include "includes.h" #include "version.h" #include "torture/torture.h" #include "lib/events/events.h" #include "auth/auth.h" #include "auth/gensec/gensec.h" #include "lib/cmdline/popt_common.h" #include "torture/rpc/rpc.h" #include "torture/rpc/netlogon.h" #include "../lib/crypto/crypto.h" #include "libcli/auth/libcli_auth.h" #include "librpc/gen_ndr/ndr_netlogon_c.h" #include "librpc/gen_ndr/ndr_netlogon.h" #include "librpc/gen_ndr/ndr_lsa_c.h" #include "param/param.h" #include "libcli/security/security.h" #include "lib/ldb/include/ldb.h" #include "lib/util/util_ldb.h" #include "lib/ldb_wrap.h" #define TEST_MACHINE_NAME "torturetest" #define TEST_MACHINE_DNS_SUFFIX "torturedomain" static bool test_LogonUasLogon(struct torture_context *tctx, struct dcerpc_pipe *p) { NTSTATUS status; struct netr_LogonUasLogon r; struct netr_UasInfo *info = NULL; r.in.server_name = NULL; r.in.account_name = cli_credentials_get_username(cmdline_credentials); r.in.workstation = TEST_MACHINE_NAME; r.out.info = &info; status = dcerpc_netr_LogonUasLogon(p, tctx, &r); torture_assert_ntstatus_ok(tctx, status, "LogonUasLogon"); return true; } static bool test_LogonUasLogoff(struct torture_context *tctx, struct dcerpc_pipe *p) { NTSTATUS status; struct netr_LogonUasLogoff r; struct netr_UasLogoffInfo info; r.in.server_name = NULL; r.in.account_name = cli_credentials_get_username(cmdline_credentials); r.in.workstation = TEST_MACHINE_NAME; r.out.info = &info; status = dcerpc_netr_LogonUasLogoff(p, tctx, &r); torture_assert_ntstatus_ok(tctx, status, "LogonUasLogoff"); return true; } bool test_SetupCredentials(struct dcerpc_pipe *p, struct torture_context *tctx, struct cli_credentials *credentials, struct netlogon_creds_CredentialState **creds_out) { NTSTATUS status; struct netr_ServerReqChallenge r; struct netr_ServerAuthenticate a; struct netr_Credential credentials1, credentials2, credentials3; struct netlogon_creds_CredentialState *creds; const struct samr_Password *mach_password; const char *machine_name; mach_password = cli_credentials_get_nt_hash(credentials, tctx); machine_name = cli_credentials_get_workstation(credentials); torture_comment(tctx, "Testing ServerReqChallenge\n"); r.in.server_name = NULL; r.in.computer_name = machine_name; r.in.credentials = &credentials1; r.out.return_credentials = &credentials2; generate_random_buffer(credentials1.data, sizeof(credentials1.data)); status = dcerpc_netr_ServerReqChallenge(p, tctx, &r); torture_assert_ntstatus_ok(tctx, status, "ServerReqChallenge"); a.in.server_name = NULL; a.in.account_name = talloc_asprintf(tctx, "%s$", machine_name); a.in.secure_channel_type = SEC_CHAN_BDC; a.in.computer_name = machine_name; a.in.credentials = &credentials3; a.out.return_credentials = &credentials3; creds = netlogon_creds_client_init(tctx, a.in.account_name, a.in.computer_name, &credentials1, &credentials2, mach_password, &credentials3, 0); torture_assert(tctx, creds != NULL, "memory allocation"); torture_comment(tctx, "Testing ServerAuthenticate\n"); status = dcerpc_netr_ServerAuthenticate(p, tctx, &a); /* This allows the tests to continue against the more fussy windows 2008 */ if (NT_STATUS_EQUAL(status, NT_STATUS_DOWNGRADE_DETECTED)) { return test_SetupCredentials2(p, tctx, NETLOGON_NEG_AUTH2_ADS_FLAGS, credentials, SEC_CHAN_BDC, creds_out); } torture_assert_ntstatus_ok(tctx, status, "ServerAuthenticate"); torture_assert(tctx, netlogon_creds_client_check(creds, &credentials3), "Credential chaining failed"); *creds_out = creds; return true; } bool test_SetupCredentials2(struct dcerpc_pipe *p, struct torture_context *tctx, uint32_t negotiate_flags, struct cli_credentials *machine_credentials, int sec_chan_type, struct netlogon_creds_CredentialState **creds_out) { NTSTATUS status; struct netr_ServerReqChallenge r; struct netr_ServerAuthenticate2 a; struct netr_Credential credentials1, credentials2, credentials3; struct netlogon_creds_CredentialState *creds; const struct samr_Password *mach_password; const char *machine_name; mach_password = cli_credentials_get_nt_hash(machine_credentials, tctx); machine_name = cli_credentials_get_workstation(machine_credentials); torture_comment(tctx, "Testing ServerReqChallenge\n"); r.in.server_name = NULL; r.in.computer_name = machine_name; r.in.credentials = &credentials1; r.out.return_credentials = &credentials2; generate_random_buffer(credentials1.data, sizeof(credentials1.data)); status = dcerpc_netr_ServerReqChallenge(p, tctx, &r); torture_assert_ntstatus_ok(tctx, status, "ServerReqChallenge"); a.in.server_name = NULL; a.in.account_name = talloc_asprintf(tctx, "%s$", machine_name); a.in.secure_channel_type = sec_chan_type; a.in.computer_name = machine_name; a.in.negotiate_flags = &negotiate_flags; a.out.negotiate_flags = &negotiate_flags; a.in.credentials = &credentials3; a.out.return_credentials = &credentials3; creds = netlogon_creds_client_init(tctx, a.in.account_name, a.in.computer_name, &credentials1, &credentials2, mach_password, &credentials3, negotiate_flags); torture_assert(tctx, creds != NULL, "memory allocation"); torture_comment(tctx, "Testing ServerAuthenticate2\n"); status = dcerpc_netr_ServerAuthenticate2(p, tctx, &a); torture_assert_ntstatus_ok(tctx, status, "ServerAuthenticate2"); torture_assert(tctx, netlogon_creds_client_check(creds, &credentials3), "Credential chaining failed"); torture_comment(tctx, "negotiate_flags=0x%08x\n", negotiate_flags); *creds_out = creds; return true; } static bool test_SetupCredentials3(struct dcerpc_pipe *p, struct torture_context *tctx, uint32_t negotiate_flags, struct cli_credentials *machine_credentials, struct netlogon_creds_CredentialState **creds_out) { NTSTATUS status; struct netr_ServerReqChallenge r; struct netr_ServerAuthenticate3 a; struct netr_Credential credentials1, credentials2, credentials3; struct netlogon_creds_CredentialState *creds; struct samr_Password mach_password; uint32_t rid; const char *machine_name; const char *plain_pass; machine_name = cli_credentials_get_workstation(machine_credentials); plain_pass = cli_credentials_get_password(machine_credentials); torture_comment(tctx, "Testing ServerReqChallenge\n"); r.in.server_name = NULL; r.in.computer_name = machine_name; r.in.credentials = &credentials1; r.out.return_credentials = &credentials2; generate_random_buffer(credentials1.data, sizeof(credentials1.data)); status = dcerpc_netr_ServerReqChallenge(p, tctx, &r); torture_assert_ntstatus_ok(tctx, status, "ServerReqChallenge"); E_md4hash(plain_pass, mach_password.hash); a.in.server_name = NULL; a.in.account_name = talloc_asprintf(tctx, "%s$", machine_name); a.in.secure_channel_type = SEC_CHAN_BDC; a.in.computer_name = machine_name; a.in.negotiate_flags = &negotiate_flags; a.in.credentials = &credentials3; a.out.return_credentials = &credentials3; a.out.negotiate_flags = &negotiate_flags; a.out.rid = &rid; creds = netlogon_creds_client_init(tctx, a.in.account_name, a.in.computer_name, &credentials1, &credentials2, &mach_password, &credentials3, negotiate_flags); torture_assert(tctx, creds != NULL, "memory allocation"); torture_comment(tctx, "Testing ServerAuthenticate3\n"); status = dcerpc_netr_ServerAuthenticate3(p, tctx, &a); torture_assert_ntstatus_ok(tctx, status, "ServerAuthenticate3"); torture_assert(tctx, netlogon_creds_client_check(creds, &credentials3), "Credential chaining failed"); torture_comment(tctx, "negotiate_flags=0x%08x\n", negotiate_flags); /* Prove that requesting a challenge again won't break it */ status = dcerpc_netr_ServerReqChallenge(p, tctx, &r); torture_assert_ntstatus_ok(tctx, status, "ServerReqChallenge"); *creds_out = creds; return true; } /* try a change password for our machine account */ static bool test_SetPassword(struct torture_context *tctx, struct dcerpc_pipe *p, struct cli_credentials *machine_credentials) { NTSTATUS status; struct netr_ServerPasswordSet r; const char *password; struct netlogon_creds_CredentialState *creds; struct netr_Authenticator credential, return_authenticator; struct samr_Password new_password; if (!test_SetupCredentials(p, tctx, machine_credentials, &creds)) { return false; } r.in.server_name = talloc_asprintf(tctx, "\\\\%s", dcerpc_server_name(p)); r.in.account_name = talloc_asprintf(tctx, "%s$", TEST_MACHINE_NAME); r.in.secure_channel_type = SEC_CHAN_BDC; r.in.computer_name = TEST_MACHINE_NAME; r.in.credential = &credential; r.in.new_password = &new_password; r.out.return_authenticator = &return_authenticator; password = generate_random_str(tctx, 8); E_md4hash(password, new_password.hash); netlogon_creds_des_encrypt(creds, &new_password); torture_comment(tctx, "Testing ServerPasswordSet on machine account\n"); torture_comment(tctx, "Changing machine account password to '%s'\n", password); netlogon_creds_client_authenticator(creds, &credential); status = dcerpc_netr_ServerPasswordSet(p, tctx, &r); torture_assert_ntstatus_ok(tctx, status, "ServerPasswordSet"); if (!netlogon_creds_client_check(creds, &r.out.return_authenticator->cred)) { torture_comment(tctx, "Credential chaining failed\n"); } /* by changing the machine password twice we test the credentials chaining fully, and we verify that the server allows the password to be set to the same value twice in a row (match win2k3) */ torture_comment(tctx, "Testing a second ServerPasswordSet on machine account\n"); torture_comment(tctx, "Changing machine account password to '%s' (same as previous run)\n", password); netlogon_creds_client_authenticator(creds, &credential); status = dcerpc_netr_ServerPasswordSet(p, tctx, &r); torture_assert_ntstatus_ok(tctx, status, "ServerPasswordSet (2)"); if (!netlogon_creds_client_check(creds, &r.out.return_authenticator->cred)) { torture_comment(tctx, "Credential chaining failed\n"); } cli_credentials_set_password(machine_credentials, password, CRED_SPECIFIED); torture_assert(tctx, test_SetupCredentials(p, tctx, machine_credentials, &creds), "ServerPasswordSet failed to actually change the password"); return true; } /* generate a random password for password change tests */ static DATA_BLOB netlogon_very_rand_pass(TALLOC_CTX *mem_ctx, int len) { int i; DATA_BLOB password = data_blob_talloc(mem_ctx, NULL, len * 2 /* number of unicode chars */); generate_random_buffer(password.data, password.length); for (i=0; i < len; i++) { if (((uint16_t *)password.data)[i] == 0) { ((uint16_t *)password.data)[i] = 1; } } return password; } /* try a change password for our machine account */ static bool test_SetPassword2(struct torture_context *tctx, struct dcerpc_pipe *p, struct cli_credentials *machine_credentials) { NTSTATUS status; struct netr_ServerPasswordSet2 r; const char *password; DATA_BLOB new_random_pass; struct netlogon_creds_CredentialState *creds; struct samr_CryptPassword password_buf; struct samr_Password nt_hash; struct netr_Authenticator credential, return_authenticator; struct netr_CryptPassword new_password; if (!test_SetupCredentials(p, tctx, machine_credentials, &creds)) { return false; } r.in.server_name = talloc_asprintf(tctx, "\\\\%s", dcerpc_server_name(p)); r.in.account_name = talloc_asprintf(tctx, "%s$", TEST_MACHINE_NAME); r.in.secure_channel_type = SEC_CHAN_BDC; r.in.computer_name = TEST_MACHINE_NAME; r.in.credential = &credential; r.in.new_password = &new_password; r.out.return_authenticator = &return_authenticator; password = generate_random_str(tctx, 8); encode_pw_buffer(password_buf.data, password, STR_UNICODE); netlogon_creds_arcfour_crypt(creds, password_buf.data, 516); memcpy(new_password.data, password_buf.data, 512); new_password.length = IVAL(password_buf.data, 512); torture_comment(tctx, "Testing ServerPasswordSet2 on machine account\n"); torture_comment(tctx, "Changing machine account password to '%s'\n", password); netlogon_creds_client_authenticator(creds, &credential); status = dcerpc_netr_ServerPasswordSet2(p, tctx, &r); torture_assert_ntstatus_ok(tctx, status, "ServerPasswordSet2"); if (!netlogon_creds_client_check(creds, &r.out.return_authenticator->cred)) { torture_comment(tctx, "Credential chaining failed\n"); } cli_credentials_set_password(machine_credentials, password, CRED_SPECIFIED); if (!torture_setting_bool(tctx, "dangerous", false)) { torture_comment(tctx, "Not testing ability to set password to '', enable dangerous tests to perform this test\n"); } else { /* by changing the machine password to "" * we check if the server uses password restrictions * for ServerPasswordSet2 * (win2k3 accepts "") */ password = ""; encode_pw_buffer(password_buf.data, password, STR_UNICODE); netlogon_creds_arcfour_crypt(creds, password_buf.data, 516); memcpy(new_password.data, password_buf.data, 512); new_password.length = IVAL(password_buf.data, 512); torture_comment(tctx, "Testing ServerPasswordSet2 on machine account\n"); torture_comment(tctx, "Changing machine account password to '%s'\n", password); netlogon_creds_client_authenticator(creds, &credential); status = dcerpc_netr_ServerPasswordSet2(p, tctx, &r); torture_assert_ntstatus_ok(tctx, status, "ServerPasswordSet2"); if (!netlogon_creds_client_check(creds, &r.out.return_authenticator->cred)) { torture_comment(tctx, "Credential chaining failed\n"); } cli_credentials_set_password(machine_credentials, password, CRED_SPECIFIED); } torture_assert(tctx, test_SetupCredentials(p, tctx, machine_credentials, &creds), "ServerPasswordSet failed to actually change the password"); /* now try a random password */ password = generate_random_str(tctx, 8); encode_pw_buffer(password_buf.data, password, STR_UNICODE); netlogon_creds_arcfour_crypt(creds, password_buf.data, 516); memcpy(new_password.data, password_buf.data, 512); new_password.length = IVAL(password_buf.data, 512); torture_comment(tctx, "Testing second ServerPasswordSet2 on machine account\n"); torture_comment(tctx, "Changing machine account password to '%s'\n", password); netlogon_creds_client_authenticator(creds, &credential); status = dcerpc_netr_ServerPasswordSet2(p, tctx, &r); torture_assert_ntstatus_ok(tctx, status, "ServerPasswordSet2 (2)"); if (!netlogon_creds_client_check(creds, &r.out.return_authenticator->cred)) { torture_comment(tctx, "Credential chaining failed\n"); } /* by changing the machine password twice we test the credentials chaining fully, and we verify that the server allows the password to be set to the same value twice in a row (match win2k3) */ torture_comment(tctx, "Testing a second ServerPasswordSet2 on machine account\n"); torture_comment(tctx, "Changing machine account password to '%s' (same as previous run)\n", password); netlogon_creds_client_authenticator(creds, &credential); status = dcerpc_netr_ServerPasswordSet2(p, tctx, &r); torture_assert_ntstatus_ok(tctx, status, "ServerPasswordSet (3)"); if (!netlogon_creds_client_check(creds, &r.out.return_authenticator->cred)) { torture_comment(tctx, "Credential chaining failed\n"); } cli_credentials_set_password(machine_credentials, password, CRED_SPECIFIED); torture_assert (tctx, test_SetupCredentials(p, tctx, machine_credentials, &creds), "ServerPasswordSet failed to actually change the password"); new_random_pass = netlogon_very_rand_pass(tctx, 128); /* now try a random stream of bytes for a password */ set_pw_in_buffer(password_buf.data, &new_random_pass); netlogon_creds_arcfour_crypt(creds, password_buf.data, 516); memcpy(new_password.data, password_buf.data, 512); new_password.length = IVAL(password_buf.data, 512); torture_comment(tctx, "Testing a third ServerPasswordSet2 on machine account, with a compleatly random password\n"); netlogon_creds_client_authenticator(creds, &credential); status = dcerpc_netr_ServerPasswordSet2(p, tctx, &r); torture_assert_ntstatus_ok(tctx, status, "ServerPasswordSet (3)"); if (!netlogon_creds_client_check(creds, &r.out.return_authenticator->cred)) { torture_comment(tctx, "Credential chaining failed\n"); } mdfour(nt_hash.hash, new_random_pass.data, new_random_pass.length); cli_credentials_set_password(machine_credentials, NULL, CRED_UNINITIALISED); cli_credentials_set_nt_hash(machine_credentials, &nt_hash, CRED_SPECIFIED); torture_assert (tctx, test_SetupCredentials(p, tctx, machine_credentials, &creds), "ServerPasswordSet failed to actually change the password"); return true; } static bool test_GetPassword(struct torture_context *tctx, struct dcerpc_pipe *p, struct cli_credentials *machine_credentials) { struct netr_ServerPasswordGet r; struct netlogon_creds_CredentialState *creds; struct netr_Authenticator credential; NTSTATUS status; struct netr_Authenticator return_authenticator; struct samr_Password password; if (!test_SetupCredentials(p, tctx, machine_credentials, &creds)) { return false; } netlogon_creds_client_authenticator(creds, &credential); r.in.server_name = talloc_asprintf(tctx, "\\\\%s", dcerpc_server_name(p)); r.in.account_name = talloc_asprintf(tctx, "%s$", TEST_MACHINE_NAME); r.in.secure_channel_type = SEC_CHAN_BDC; r.in.computer_name = TEST_MACHINE_NAME; r.in.credential = &credential; r.out.return_authenticator = &return_authenticator; r.out.password = &password; status = dcerpc_netr_ServerPasswordGet(p, tctx, &r); torture_assert_ntstatus_ok(tctx, status, "ServerPasswordGet"); return true; } static bool test_GetTrustPasswords(struct torture_context *tctx, struct dcerpc_pipe *p, struct cli_credentials *machine_credentials) { struct netr_ServerTrustPasswordsGet r; struct netlogon_creds_CredentialState *creds; struct netr_Authenticator credential; NTSTATUS status; struct netr_Authenticator return_authenticator; struct samr_Password password, password2; if (!test_SetupCredentials(p, tctx, machine_credentials, &creds)) { return false; } netlogon_creds_client_authenticator(creds, &credential); r.in.server_name = talloc_asprintf(tctx, "\\\\%s", dcerpc_server_name(p)); r.in.account_name = talloc_asprintf(tctx, "%s$", TEST_MACHINE_NAME); r.in.secure_channel_type = SEC_CHAN_BDC; r.in.computer_name = TEST_MACHINE_NAME; r.in.credential = &credential; r.out.return_authenticator = &return_authenticator; r.out.password = &password; r.out.password2 = &password2; status = dcerpc_netr_ServerTrustPasswordsGet(p, tctx, &r); torture_assert_ntstatus_ok(tctx, status, "ServerTrustPasswordsGet"); return true; } /* try a netlogon SamLogon */ bool test_netlogon_ops(struct dcerpc_pipe *p, struct torture_context *tctx, struct cli_credentials *credentials, struct netlogon_creds_CredentialState *creds) { NTSTATUS status; struct netr_LogonSamLogon r; struct netr_Authenticator auth, auth2; union netr_LogonLevel logon; union netr_Validation validation; uint8_t authoritative; struct netr_NetworkInfo ninfo; DATA_BLOB names_blob, chal, lm_resp, nt_resp; int i; int flags = CLI_CRED_NTLM_AUTH; if (lp_client_lanman_auth(tctx->lp_ctx)) { flags |= CLI_CRED_LANMAN_AUTH; } if (lp_client_ntlmv2_auth(tctx->lp_ctx)) { flags |= CLI_CRED_NTLMv2_AUTH; } cli_credentials_get_ntlm_username_domain(cmdline_credentials, tctx, &ninfo.identity_info.account_name.string, &ninfo.identity_info.domain_name.string); generate_random_buffer(ninfo.challenge, sizeof(ninfo.challenge)); chal = data_blob_const(ninfo.challenge, sizeof(ninfo.challenge)); names_blob = NTLMv2_generate_names_blob(tctx, cli_credentials_get_workstation(credentials), cli_credentials_get_domain(credentials)); status = cli_credentials_get_ntlm_response(cmdline_credentials, tctx, &flags, chal, names_blob, &lm_resp, &nt_resp, NULL, NULL); torture_assert_ntstatus_ok(tctx, status, "cli_credentials_get_ntlm_response failed"); ninfo.lm.data = lm_resp.data; ninfo.lm.length = lm_resp.length; ninfo.nt.data = nt_resp.data; ninfo.nt.length = nt_resp.length; ninfo.identity_info.parameter_control = 0; ninfo.identity_info.logon_id_low = 0; ninfo.identity_info.logon_id_high = 0; ninfo.identity_info.workstation.string = cli_credentials_get_workstation(credentials); logon.network = &ninfo; r.in.server_name = talloc_asprintf(tctx, "\\\\%s", dcerpc_server_name(p)); r.in.computer_name = cli_credentials_get_workstation(credentials); r.in.credential = &auth; r.in.return_authenticator = &auth2; r.in.logon_level = 2; r.in.logon = &logon; r.out.validation = &validation; r.out.authoritative = &authoritative; d_printf("Testing LogonSamLogon with name %s\n", ninfo.identity_info.account_name.string); for (i=2;i<3;i++) { ZERO_STRUCT(auth2); netlogon_creds_client_authenticator(creds, &auth); r.in.validation_level = i; status = dcerpc_netr_LogonSamLogon(p, tctx, &r); torture_assert_ntstatus_ok(tctx, status, "LogonSamLogon failed"); torture_assert(tctx, netlogon_creds_client_check(creds, &r.out.return_authenticator->cred), "Credential chaining failed"); } r.in.credential = NULL; for (i=2;i<=3;i++) { r.in.validation_level = i; torture_comment(tctx, "Testing SamLogon with validation level %d and a NULL credential\n", i); status = dcerpc_netr_LogonSamLogon(p, tctx, &r); torture_assert_ntstatus_equal(tctx, status, NT_STATUS_INVALID_PARAMETER, "LogonSamLogon expected INVALID_PARAMETER"); } return true; } /* try a netlogon SamLogon */ static bool test_SamLogon(struct torture_context *tctx, struct dcerpc_pipe *p, struct cli_credentials *credentials) { struct netlogon_creds_CredentialState *creds; if (!test_SetupCredentials(p, tctx, credentials, &creds)) { return false; } return test_netlogon_ops(p, tctx, credentials, creds); } /* we remember the sequence numbers so we can easily do a DatabaseDelta */ static uint64_t sequence_nums[3]; /* try a netlogon DatabaseSync */ static bool test_DatabaseSync(struct torture_context *tctx, struct dcerpc_pipe *p, struct cli_credentials *machine_credentials) { NTSTATUS status; struct netr_DatabaseSync r; struct netlogon_creds_CredentialState *creds; const uint32_t database_ids[] = {SAM_DATABASE_DOMAIN, SAM_DATABASE_BUILTIN, SAM_DATABASE_PRIVS}; int i; struct netr_DELTA_ENUM_ARRAY *delta_enum_array = NULL; struct netr_Authenticator credential, return_authenticator; if (!test_SetupCredentials(p, tctx, machine_credentials, &creds)) { return false; } ZERO_STRUCT(return_authenticator); r.in.logon_server = talloc_asprintf(tctx, "\\\\%s", dcerpc_server_name(p)); r.in.computername = TEST_MACHINE_NAME; r.in.preferredmaximumlength = (uint32_t)-1; r.in.return_authenticator = &return_authenticator; r.out.delta_enum_array = &delta_enum_array; r.out.return_authenticator = &return_authenticator; for (i=0;icred)) { torture_comment(tctx, "Credential chaining failed\n"); } if (delta_enum_array && delta_enum_array->num_deltas > 0 && delta_enum_array->delta_enum[0].delta_type == NETR_DELTA_DOMAIN && delta_enum_array->delta_enum[0].delta_union.domain) { sequence_nums[r.in.database_id] = delta_enum_array->delta_enum[0].delta_union.domain->sequence_num; torture_comment(tctx, "\tsequence_nums[%d]=%llu\n", r.in.database_id, (unsigned long long)sequence_nums[r.in.database_id]); } } while (NT_STATUS_EQUAL(status, STATUS_MORE_ENTRIES)); } return true; } /* try a netlogon DatabaseDeltas */ static bool test_DatabaseDeltas(struct torture_context *tctx, struct dcerpc_pipe *p, struct cli_credentials *machine_credentials) { NTSTATUS status; struct netr_DatabaseDeltas r; struct netlogon_creds_CredentialState *creds; struct netr_Authenticator credential; struct netr_Authenticator return_authenticator; struct netr_DELTA_ENUM_ARRAY *delta_enum_array = NULL; const uint32_t database_ids[] = {0, 1, 2}; int i; if (!test_SetupCredentials(p, tctx, machine_credentials, &creds)) { return false; } r.in.logon_server = talloc_asprintf(tctx, "\\\\%s", dcerpc_server_name(p)); r.in.computername = TEST_MACHINE_NAME; r.in.preferredmaximumlength = (uint32_t)-1; ZERO_STRUCT(r.in.return_authenticator); r.out.return_authenticator = &return_authenticator; r.out.delta_enum_array = &delta_enum_array; for (i=0;inum_deltas, changes[i].expected_num_results, changes[i].comment); if (delta_enum_array->num_deltas > 0) { torture_assert_int_equal(tctx, delta_enum_array->delta_enum[0].delta_type, changes[i].expected_delta_type_1, changes[i].comment); } if (delta_enum_array->num_deltas > 1) { torture_assert_int_equal(tctx, delta_enum_array->delta_enum[1].delta_type, changes[i].expected_delta_type_2, changes[i].comment); } } if (!netlogon_creds_client_check(creds, &return_authenticator.cred)) { torture_comment(tctx, "Credential chaining failed\n"); if (!test_SetupCredentials(p, tctx, machine_credentials, &creds)) { return false; } } } } } return true; } /* try a netlogon AccountDeltas */ static bool test_AccountDeltas(struct torture_context *tctx, struct dcerpc_pipe *p, struct cli_credentials *machine_credentials) { NTSTATUS status; struct netr_AccountDeltas r; struct netlogon_creds_CredentialState *creds; struct netr_AccountBuffer buffer; uint32_t count_returned = 0; uint32_t total_entries = 0; struct netr_UAS_INFO_0 recordid; struct netr_Authenticator return_authenticator; if (!test_SetupCredentials(p, tctx, machine_credentials, &creds)) { return false; } ZERO_STRUCT(return_authenticator); r.in.logon_server = talloc_asprintf(tctx, "\\\\%s", dcerpc_server_name(p)); r.in.computername = TEST_MACHINE_NAME; r.in.return_authenticator = &return_authenticator; netlogon_creds_client_authenticator(creds, &r.in.credential); ZERO_STRUCT(r.in.uas); r.in.count=10; r.in.level=0; r.in.buffersize=100; r.out.buffer = &buffer; r.out.count_returned = &count_returned; r.out.total_entries = &total_entries; r.out.recordid = &recordid; r.out.return_authenticator = &return_authenticator; /* w2k3 returns "NOT IMPLEMENTED" for this call */ status = dcerpc_netr_AccountDeltas(p, tctx, &r); torture_assert_ntstatus_equal(tctx, status, NT_STATUS_NOT_IMPLEMENTED, "AccountDeltas"); return true; } /* try a netlogon AccountSync */ static bool test_AccountSync(struct torture_context *tctx, struct dcerpc_pipe *p, struct cli_credentials *machine_credentials) { NTSTATUS status; struct netr_AccountSync r; struct netlogon_creds_CredentialState *creds; struct netr_AccountBuffer buffer; uint32_t count_returned = 0; uint32_t total_entries = 0; uint32_t next_reference = 0; struct netr_UAS_INFO_0 recordid; struct netr_Authenticator return_authenticator; ZERO_STRUCT(recordid); ZERO_STRUCT(return_authenticator); if (!test_SetupCredentials(p, tctx, machine_credentials, &creds)) { return false; } r.in.logon_server = talloc_asprintf(tctx, "\\\\%s", dcerpc_server_name(p)); r.in.computername = TEST_MACHINE_NAME; r.in.return_authenticator = &return_authenticator; netlogon_creds_client_authenticator(creds, &r.in.credential); r.in.recordid = &recordid; r.in.reference=0; r.in.level=0; r.in.buffersize=100; r.out.buffer = &buffer; r.out.count_returned = &count_returned; r.out.total_entries = &total_entries; r.out.next_reference = &next_reference; r.out.recordid = &recordid; r.out.return_authenticator = &return_authenticator; /* w2k3 returns "NOT IMPLEMENTED" for this call */ status = dcerpc_netr_AccountSync(p, tctx, &r); torture_assert_ntstatus_equal(tctx, status, NT_STATUS_NOT_IMPLEMENTED, "AccountSync"); return true; } /* try a netlogon GetDcName */ static bool test_GetDcName(struct torture_context *tctx, struct dcerpc_pipe *p) { NTSTATUS status; struct netr_GetDcName r; const char *dcname = NULL; r.in.logon_server = talloc_asprintf(tctx, "\\\\%s", dcerpc_server_name(p)); r.in.domainname = lp_workgroup(tctx->lp_ctx); r.out.dcname = &dcname; status = dcerpc_netr_GetDcName(p, tctx, &r); torture_assert_ntstatus_ok(tctx, status, "GetDcName"); torture_assert_werr_ok(tctx, r.out.result, "GetDcName"); torture_comment(tctx, "\tDC is at '%s'\n", dcname); return true; } /* try a netlogon LogonControl */ static bool test_LogonControl(struct torture_context *tctx, struct dcerpc_pipe *p) { NTSTATUS status; struct netr_LogonControl r; union netr_CONTROL_QUERY_INFORMATION query; int i; r.in.logon_server = talloc_asprintf(tctx, "\\\\%s", dcerpc_server_name(p)); r.in.function_code = 1; r.out.query = &query; for (i=1;i<4;i++) { r.in.level = i; torture_comment(tctx, "Testing LogonControl level %d\n", i); status = dcerpc_netr_LogonControl(p, tctx, &r); torture_assert_ntstatus_ok(tctx, status, "LogonControl"); } return true; } /* try a netlogon GetAnyDCName */ static bool test_GetAnyDCName(struct torture_context *tctx, struct dcerpc_pipe *p) { NTSTATUS status; struct netr_GetAnyDCName r; const char *dcname = NULL; r.in.logon_server = talloc_asprintf(tctx, "\\\\%s", dcerpc_server_name(p)); r.in.domainname = lp_workgroup(tctx->lp_ctx); r.out.dcname = &dcname; status = dcerpc_netr_GetAnyDCName(p, tctx, &r); torture_assert_ntstatus_ok(tctx, status, "GetAnyDCName"); torture_assert_werr_ok(tctx, r.out.result, "GetAnyDCName"); if (dcname) { torture_comment(tctx, "\tDC is at '%s'\n", dcname); } return true; } /* try a netlogon LogonControl2 */ static bool test_LogonControl2(struct torture_context *tctx, struct dcerpc_pipe *p) { NTSTATUS status; struct netr_LogonControl2 r; union netr_CONTROL_DATA_INFORMATION data; union netr_CONTROL_QUERY_INFORMATION query; int i; data.domain = lp_workgroup(tctx->lp_ctx); r.in.logon_server = talloc_asprintf(tctx, "\\\\%s", dcerpc_server_name(p)); r.in.function_code = NETLOGON_CONTROL_REDISCOVER; r.in.data = &data; r.out.query = &query; for (i=1;i<4;i++) { r.in.level = i; torture_comment(tctx, "Testing LogonControl2 level %d function %d\n", i, r.in.function_code); status = dcerpc_netr_LogonControl2(p, tctx, &r); torture_assert_ntstatus_ok(tctx, status, "LogonControl"); } data.domain = lp_workgroup(tctx->lp_ctx); r.in.function_code = NETLOGON_CONTROL_TC_QUERY; r.in.data = &data; for (i=1;i<4;i++) { r.in.level = i; torture_comment(tctx, "Testing LogonControl2 level %d function %d\n", i, r.in.function_code); status = dcerpc_netr_LogonControl2(p, tctx, &r); torture_assert_ntstatus_ok(tctx, status, "LogonControl"); } data.domain = lp_workgroup(tctx->lp_ctx); r.in.function_code = NETLOGON_CONTROL_TRANSPORT_NOTIFY; r.in.data = &data; for (i=1;i<4;i++) { r.in.level = i; torture_comment(tctx, "Testing LogonControl2 level %d function %d\n", i, r.in.function_code); status = dcerpc_netr_LogonControl2(p, tctx, &r); torture_assert_ntstatus_ok(tctx, status, "LogonControl"); } data.debug_level = ~0; r.in.function_code = NETLOGON_CONTROL_SET_DBFLAG; r.in.data = &data; for (i=1;i<4;i++) { r.in.level = i; torture_comment(tctx, "Testing LogonControl2 level %d function %d\n", i, r.in.function_code); status = dcerpc_netr_LogonControl2(p, tctx, &r); torture_assert_ntstatus_ok(tctx, status, "LogonControl"); } return true; } /* try a netlogon DatabaseSync2 */ static bool test_DatabaseSync2(struct torture_context *tctx, struct dcerpc_pipe *p, struct cli_credentials *machine_credentials) { NTSTATUS status; struct netr_DatabaseSync2 r; struct netr_DELTA_ENUM_ARRAY *delta_enum_array = NULL; struct netr_Authenticator return_authenticator, credential; struct netlogon_creds_CredentialState *creds; const uint32_t database_ids[] = {0, 1, 2}; int i; if (!test_SetupCredentials2(p, tctx, NETLOGON_NEG_AUTH2_FLAGS, machine_credentials, SEC_CHAN_BDC, &creds)) { return false; } ZERO_STRUCT(return_authenticator); r.in.logon_server = talloc_asprintf(tctx, "\\\\%s", dcerpc_server_name(p)); r.in.computername = TEST_MACHINE_NAME; r.in.preferredmaximumlength = (uint32_t)-1; r.in.return_authenticator = &return_authenticator; r.out.return_authenticator = &return_authenticator; r.out.delta_enum_array = &delta_enum_array; for (i=0;icred)) { torture_comment(tctx, "Credential chaining failed\n"); } } while (NT_STATUS_EQUAL(status, STATUS_MORE_ENTRIES)); } return true; } /* try a netlogon LogonControl2Ex */ static bool test_LogonControl2Ex(struct torture_context *tctx, struct dcerpc_pipe *p) { NTSTATUS status; struct netr_LogonControl2Ex r; union netr_CONTROL_DATA_INFORMATION data; union netr_CONTROL_QUERY_INFORMATION query; int i; data.domain = lp_workgroup(tctx->lp_ctx); r.in.logon_server = talloc_asprintf(tctx, "\\\\%s", dcerpc_server_name(p)); r.in.function_code = NETLOGON_CONTROL_REDISCOVER; r.in.data = &data; r.out.query = &query; for (i=1;i<4;i++) { r.in.level = i; torture_comment(tctx, "Testing LogonControl2Ex level %d function %d\n", i, r.in.function_code); status = dcerpc_netr_LogonControl2Ex(p, tctx, &r); torture_assert_ntstatus_ok(tctx, status, "LogonControl"); } data.domain = lp_workgroup(tctx->lp_ctx); r.in.function_code = NETLOGON_CONTROL_TC_QUERY; r.in.data = &data; for (i=1;i<4;i++) { r.in.level = i; torture_comment(tctx, "Testing LogonControl2Ex level %d function %d\n", i, r.in.function_code); status = dcerpc_netr_LogonControl2Ex(p, tctx, &r); torture_assert_ntstatus_ok(tctx, status, "LogonControl"); } data.domain = lp_workgroup(tctx->lp_ctx); r.in.function_code = NETLOGON_CONTROL_TRANSPORT_NOTIFY; r.in.data = &data; for (i=1;i<4;i++) { r.in.level = i; torture_comment(tctx, "Testing LogonControl2Ex level %d function %d\n", i, r.in.function_code); status = dcerpc_netr_LogonControl2Ex(p, tctx, &r); torture_assert_ntstatus_ok(tctx, status, "LogonControl"); } data.debug_level = ~0; r.in.function_code = NETLOGON_CONTROL_SET_DBFLAG; r.in.data = &data; for (i=1;i<4;i++) { r.in.level = i; torture_comment(tctx, "Testing LogonControl2Ex level %d function %d\n", i, r.in.function_code); status = dcerpc_netr_LogonControl2Ex(p, tctx, &r); torture_assert_ntstatus_ok(tctx, status, "LogonControl"); } return true; } static bool test_netr_DsRGetForestTrustInformation(struct torture_context *tctx, struct dcerpc_pipe *p, const char *trusted_domain_name) { NTSTATUS status; struct netr_DsRGetForestTrustInformation r; struct lsa_ForestTrustInformation info, *info_ptr; info_ptr = &info; r.in.server_name = talloc_asprintf(tctx, "\\\\%s", dcerpc_server_name(p)); r.in.trusted_domain_name = trusted_domain_name; r.in.flags = 0; r.out.forest_trust_info = &info_ptr; torture_comment(tctx ,"Testing netr_DsRGetForestTrustInformation\n"); status = dcerpc_netr_DsRGetForestTrustInformation(p, tctx, &r); torture_assert_ntstatus_ok(tctx, status, "DsRGetForestTrustInformation"); torture_assert_werr_ok(tctx, r.out.result, "DsRGetForestTrustInformation"); return true; } /* try a netlogon netr_DsrEnumerateDomainTrusts */ static bool test_DsrEnumerateDomainTrusts(struct torture_context *tctx, struct dcerpc_pipe *p) { NTSTATUS status; struct netr_DsrEnumerateDomainTrusts r; struct netr_DomainTrustList trusts; int i; r.in.server_name = talloc_asprintf(tctx, "\\\\%s", dcerpc_server_name(p)); r.in.trust_flags = 0x3f; r.out.trusts = &trusts; status = dcerpc_netr_DsrEnumerateDomainTrusts(p, tctx, &r); torture_assert_ntstatus_ok(tctx, status, "DsrEnumerateDomaintrusts"); torture_assert_werr_ok(tctx, r.out.result, "DsrEnumerateDomaintrusts"); /* when trusted_domain_name is NULL, netr_DsRGetForestTrustInformation * will show non-forest trusts and all UPN suffixes of the own forest * as LSA_FOREST_TRUST_TOP_LEVEL_NAME types */ if (r.out.trusts->count) { if (!test_netr_DsRGetForestTrustInformation(tctx, p, NULL)) { return false; } } for (i=0; icount; i++) { /* get info for transitive forest trusts */ if (r.out.trusts->array[i].trust_attributes & NETR_TRUST_ATTRIBUTE_FOREST_TRANSITIVE) { if (!test_netr_DsRGetForestTrustInformation(tctx, p, r.out.trusts->array[i].dns_name)) { return false; } } } return true; } static bool test_netr_NetrEnumerateTrustedDomains(struct torture_context *tctx, struct dcerpc_pipe *p) { NTSTATUS status; struct netr_NetrEnumerateTrustedDomains r; struct netr_Blob trusted_domains_blob; r.in.server_name = talloc_asprintf(tctx, "\\\\%s", dcerpc_server_name(p)); r.out.trusted_domains_blob = &trusted_domains_blob; status = dcerpc_netr_NetrEnumerateTrustedDomains(p, tctx, &r); torture_assert_ntstatus_ok(tctx, status, "netr_NetrEnumerateTrustedDomains"); torture_assert_werr_ok(tctx, r.out.result, "NetrEnumerateTrustedDomains"); return true; } static bool test_netr_NetrEnumerateTrustedDomainsEx(struct torture_context *tctx, struct dcerpc_pipe *p) { NTSTATUS status; struct netr_NetrEnumerateTrustedDomainsEx r; struct netr_DomainTrustList dom_trust_list; r.in.server_name = talloc_asprintf(tctx, "\\\\%s", dcerpc_server_name(p)); r.out.dom_trust_list = &dom_trust_list; status = dcerpc_netr_NetrEnumerateTrustedDomainsEx(p, tctx, &r); torture_assert_ntstatus_ok(tctx, status, "netr_NetrEnumerateTrustedDomainsEx"); torture_assert_werr_ok(tctx, r.out.result, "NetrEnumerateTrustedDomainsEx"); return true; } static bool test_netr_DsRGetSiteName(struct dcerpc_pipe *p, struct torture_context *tctx, const char *computer_name, const char *expected_site) { NTSTATUS status; struct netr_DsRGetSiteName r; const char *site = NULL; if (torture_setting_bool(tctx, "samba4", false)) torture_skip(tctx, "skipping DsRGetSiteName test against Samba4"); r.in.computer_name = computer_name; r.out.site = &site; torture_comment(tctx, "Testing netr_DsRGetSiteName\n"); status = dcerpc_netr_DsRGetSiteName(p, tctx, &r); torture_assert_ntstatus_ok(tctx, status, "DsRGetSiteName"); torture_assert_werr_ok(tctx, r.out.result, "DsRGetSiteName"); torture_assert_str_equal(tctx, expected_site, site, "netr_DsRGetSiteName"); r.in.computer_name = talloc_asprintf(tctx, "\\\\%s", computer_name); torture_comment(tctx, "Testing netr_DsRGetSiteName with broken computer name: %s\n", r.in.computer_name); status = dcerpc_netr_DsRGetSiteName(p, tctx, &r); torture_assert_ntstatus_ok(tctx, status, "DsRGetSiteName"); torture_assert_werr_equal(tctx, r.out.result, WERR_INVALID_COMPUTERNAME, "netr_DsRGetSiteName"); return true; } /* try a netlogon netr_DsRGetDCName */ static bool test_netr_DsRGetDCName(struct torture_context *tctx, struct dcerpc_pipe *p) { NTSTATUS status; struct netr_DsRGetDCName r; struct netr_DsRGetDCNameInfo *info = NULL; r.in.server_unc = talloc_asprintf(tctx, "\\\\%s", dcerpc_server_name(p)); r.in.domain_name = talloc_asprintf(tctx, "%s", lp_realm(tctx->lp_ctx)); r.in.domain_guid = NULL; r.in.site_guid = NULL; r.in.flags = DS_RETURN_DNS_NAME; r.out.info = &info; status = dcerpc_netr_DsRGetDCName(p, tctx, &r); torture_assert_ntstatus_ok(tctx, status, "DsRGetDCName"); torture_assert_werr_ok(tctx, r.out.result, "DsRGetDCName"); return test_netr_DsRGetSiteName(p, tctx, info->dc_unc, info->dc_site_name); } /* try a netlogon netr_DsRGetDCNameEx */ static bool test_netr_DsRGetDCNameEx(struct torture_context *tctx, struct dcerpc_pipe *p) { NTSTATUS status; struct netr_DsRGetDCNameEx r; struct netr_DsRGetDCNameInfo *info = NULL; r.in.server_unc = talloc_asprintf(tctx, "\\\\%s", dcerpc_server_name(p)); r.in.domain_name = talloc_asprintf(tctx, "%s", lp_realm(tctx->lp_ctx)); r.in.domain_guid = NULL; r.in.site_name = NULL; r.in.flags = DS_RETURN_DNS_NAME; r.out.info = &info; status = dcerpc_netr_DsRGetDCNameEx(p, tctx, &r); torture_assert_ntstatus_ok(tctx, status, "netr_DsRGetDCNameEx"); torture_assert_werr_ok(tctx, r.out.result, "netr_DsRGetDCNameEx"); return test_netr_DsRGetSiteName(p, tctx, info->dc_unc, info->dc_site_name); } /* try a netlogon netr_DsRGetDCNameEx2 */ static bool test_netr_DsRGetDCNameEx2(struct torture_context *tctx, struct dcerpc_pipe *p) { NTSTATUS status; struct netr_DsRGetDCNameEx2 r; struct netr_DsRGetDCNameInfo *info = NULL; r.in.server_unc = talloc_asprintf(tctx, "\\\\%s", dcerpc_server_name(p)); r.in.client_account = NULL; r.in.mask = 0x00000000; r.in.domain_name = talloc_asprintf(tctx, "%s", lp_realm(tctx->lp_ctx)); r.in.domain_guid = NULL; r.in.site_name = NULL; r.in.flags = DS_RETURN_DNS_NAME; r.out.info = &info; torture_comment(tctx, "Testing netr_DsRGetDCNameEx2 without client account\n"); status = dcerpc_netr_DsRGetDCNameEx2(p, tctx, &r); torture_assert_ntstatus_ok(tctx, status, "netr_DsRGetDCNameEx2"); torture_assert_werr_ok(tctx, r.out.result, "netr_DsRGetDCNameEx2"); torture_comment(tctx, "Testing netr_DsRGetDCNameEx2 with client acount\n"); r.in.client_account = TEST_MACHINE_NAME"$"; r.in.mask = ACB_SVRTRUST; r.in.flags = DS_RETURN_FLAT_NAME; r.out.info = &info; status = dcerpc_netr_DsRGetDCNameEx2(p, tctx, &r); torture_assert_ntstatus_ok(tctx, status, "netr_DsRGetDCNameEx2"); torture_assert_werr_ok(tctx, r.out.result, "netr_DsRGetDCNameEx2"); return test_netr_DsRGetSiteName(p, tctx, info->dc_unc, info->dc_site_name); } static bool test_netr_DsrGetDcSiteCoverageW(struct torture_context *tctx, struct dcerpc_pipe *p) { NTSTATUS status; struct netr_DsrGetDcSiteCoverageW r; struct DcSitesCtr *ctr = NULL; r.in.server_name = talloc_asprintf(tctx, "\\\\%s", dcerpc_server_name(p)); r.out.ctr = &ctr; status = dcerpc_netr_DsrGetDcSiteCoverageW(p, tctx, &r); torture_assert_ntstatus_ok(tctx, status, "failed"); torture_assert_werr_ok(tctx, r.out.result, "failed"); return true; } static bool test_netr_DsRAddressToSitenamesW(struct torture_context *tctx, struct dcerpc_pipe *p) { NTSTATUS status; struct netr_DsRAddressToSitenamesW r; struct netr_DsRAddress addr; struct netr_DsRAddressToSitenamesWCtr *ctr; ctr = talloc(tctx, struct netr_DsRAddressToSitenamesWCtr); addr.size = 16; addr.buffer = talloc_zero_array(tctx, uint8_t, addr.size); addr.buffer[0] = 2; /* AF_INET */ addr.buffer[4] = 127; addr.buffer[5] = 0; addr.buffer[6] = 0; addr.buffer[7] = 1; r.in.server_name = talloc_asprintf(tctx, "\\\\%s", dcerpc_server_name(p)); r.in.count = 1; r.in.addresses = talloc_zero_array(tctx, struct netr_DsRAddress, r.in.count); r.in.addresses[0] = addr; r.out.ctr = &ctr; status = dcerpc_netr_DsRAddressToSitenamesW(p, tctx, &r); torture_assert_ntstatus_ok(tctx, status, "failed"); torture_assert_werr_ok(tctx, r.out.result, "failed"); return true; } static bool test_netr_DsRAddressToSitenamesExW(struct torture_context *tctx, struct dcerpc_pipe *p) { NTSTATUS status; struct netr_DsRAddressToSitenamesExW r; struct netr_DsRAddress addr; struct netr_DsRAddressToSitenamesExWCtr *ctr; ctr = talloc(tctx, struct netr_DsRAddressToSitenamesExWCtr); addr.size = 16; addr.buffer = talloc_zero_array(tctx, uint8_t, addr.size); addr.buffer[0] = 2; /* AF_INET */ addr.buffer[4] = 127; addr.buffer[5] = 0; addr.buffer[6] = 0; addr.buffer[7] = 1; r.in.server_name = talloc_asprintf(tctx, "\\\\%s", dcerpc_server_name(p)); r.in.count = 1; r.in.addresses = talloc_zero_array(tctx, struct netr_DsRAddress, r.in.count); r.in.addresses[0] = addr; r.out.ctr = &ctr; status = dcerpc_netr_DsRAddressToSitenamesExW(p, tctx, &r); torture_assert_ntstatus_ok(tctx, status, "failed"); torture_assert_werr_ok(tctx, r.out.result, "failed"); return true; } static bool test_netr_ServerGetTrustInfo(struct torture_context *tctx, struct dcerpc_pipe *p, struct cli_credentials *machine_credentials) { NTSTATUS status; struct netr_ServerGetTrustInfo r; struct netr_Authenticator a; struct netr_Authenticator return_authenticator; struct samr_Password new_owf_password; struct samr_Password old_owf_password; struct netr_TrustInfo *trust_info; struct netlogon_creds_CredentialState *creds; if (!test_SetupCredentials3(p, tctx, NETLOGON_NEG_AUTH2_ADS_FLAGS, machine_credentials, &creds)) { return false; } netlogon_creds_client_authenticator(creds, &a); r.in.server_name = talloc_asprintf(tctx, "\\\\%s", dcerpc_server_name(p)); r.in.account_name = talloc_asprintf(tctx, "%s$", TEST_MACHINE_NAME); r.in.secure_channel_type = SEC_CHAN_BDC; r.in.computer_name = TEST_MACHINE_NAME; r.in.credential = &a; r.out.return_authenticator = &return_authenticator; r.out.new_owf_password = &new_owf_password; r.out.old_owf_password = &old_owf_password; r.out.trust_info = &trust_info; status = dcerpc_netr_ServerGetTrustInfo(p, tctx, &r); torture_assert_ntstatus_ok(tctx, status, "failed"); torture_assert(tctx, netlogon_creds_client_check(creds, &return_authenticator.cred), "Credential chaining failed"); return true; } static bool test_GetDomainInfo(struct torture_context *tctx, struct dcerpc_pipe *p, struct cli_credentials *machine_credentials) { NTSTATUS status; struct netr_LogonGetDomainInfo r; struct netr_WorkstationInformation q1; struct netr_Authenticator a; struct netlogon_creds_CredentialState *creds; struct netr_OsVersion os; union netr_WorkstationInfo query; union netr_DomainInfo info; const char* const attrs[] = { "dNSHostName", "operatingSystem", "operatingSystemServicePack", "operatingSystemVersion", "servicePrincipalName", NULL }; char *url; struct ldb_context *sam_ctx = NULL; struct ldb_message **res; struct ldb_message_element *spn_el; int ret, i; char *version_str; const char *old_dnsname; char **spns = NULL; int num_spns = 0; char *temp_str; torture_comment(tctx, "Testing netr_LogonGetDomainInfo\n"); if (!test_SetupCredentials3(p, tctx, NETLOGON_NEG_AUTH2_ADS_FLAGS, machine_credentials, &creds)) { return false; } /* We won't double-check this when we are over 'local' transports */ if (dcerpc_server_name(p)) { /* Set up connection to SAMDB on DC */ url = talloc_asprintf(tctx, "ldap://%s", dcerpc_server_name(p)); sam_ctx = ldb_wrap_connect(tctx, tctx->ev, tctx->lp_ctx, url, NULL, cmdline_credentials, 0, NULL); torture_assert(tctx, sam_ctx, "Connection to the SAMDB on DC failed!"); } torture_comment(tctx, "Testing netr_LogonGetDomainInfo 1st call (no variation of DNS hostname)\n"); netlogon_creds_client_authenticator(creds, &a); ZERO_STRUCT(r); r.in.server_name = talloc_asprintf(tctx, "\\\\%s", dcerpc_server_name(p)); r.in.computer_name = TEST_MACHINE_NAME; r.in.credential = &a; r.in.level = 1; r.in.return_authenticator = &a; r.in.query = &query; r.out.return_authenticator = &a; r.out.info = &info; ZERO_STRUCT(os); os.os.MajorVersion = 123; os.os.MinorVersion = 456; os.os.BuildNumber = 789; os.os.CSDVersion = "Service Pack 10"; os.os.ServicePackMajor = 10; os.os.ServicePackMinor = 1; os.os.SuiteMask = NETR_VER_SUITE_SINGLEUSERTS; os.os.ProductType = NETR_VER_NT_SERVER; os.os.Reserved = 0; version_str = talloc_asprintf(tctx, "%d.%d (%d)", os.os.MajorVersion, os.os.MinorVersion, os.os.BuildNumber); ZERO_STRUCT(q1); q1.dns_hostname = talloc_asprintf(tctx, "%s.%s", TEST_MACHINE_NAME, TEST_MACHINE_DNS_SUFFIX); q1.sitename = "Default-First-Site-Name"; q1.os_version.os = &os; q1.os_name.string = talloc_asprintf(tctx, "Tortured by Samba4 RPC-NETLOGON: %s", timestring(tctx, time(NULL))); /* The workstation handles the "servicePrincipalName" and DNS hostname updates */ q1.workstation_flags = NETR_WS_FLAG_HANDLES_SPN_UPDATE; query.workstation_info = &q1; if (sam_ctx) { /* Gets back the old DNS hostname in AD */ ret = gendb_search(sam_ctx, tctx, NULL, &res, attrs, "(sAMAccountName=%s$)", TEST_MACHINE_NAME); old_dnsname = ldb_msg_find_attr_as_string(res[0], "dNSHostName", NULL); /* Gets back the "servicePrincipalName"s in AD */ spn_el = ldb_msg_find_element(res[0], "servicePrincipalName"); if (spn_el != NULL) { for (i=0; i < spn_el->num_values; i++) { spns = talloc_realloc(tctx, spns, char *, i + 1); spns[i] = (char *) spn_el->values[i].data; } num_spns = i; } } status = dcerpc_netr_LogonGetDomainInfo(p, tctx, &r); torture_assert_ntstatus_ok(tctx, status, "netr_LogonGetDomainInfo"); torture_assert(tctx, netlogon_creds_client_check(creds, &a.cred), "Credential chaining failed"); msleep(250); if (sam_ctx) { /* AD workstation infos entry check */ ret = gendb_search(sam_ctx, tctx, NULL, &res, attrs, "(sAMAccountName=%s$)", TEST_MACHINE_NAME); torture_assert(tctx, ret == 1, "Test machine account not found in SAMDB on DC! Has the workstation been joined?"); torture_assert_str_equal(tctx, ldb_msg_find_attr_as_string(res[0], "operatingSystem", NULL), q1.os_name.string, "'operatingSystem' wrong!"); torture_assert_str_equal(tctx, ldb_msg_find_attr_as_string(res[0], "operatingSystemServicePack", NULL), os.os.CSDVersion, "'operatingSystemServicePack' wrong!"); torture_assert_str_equal(tctx, ldb_msg_find_attr_as_string(res[0], "operatingSystemVersion", NULL), version_str, "'operatingSystemVersion' wrong!"); if (old_dnsname != NULL) { /* If before a DNS hostname was set then it should remain the same in combination with the "servicePrincipalName"s. The DNS hostname should also be returned by our "LogonGetDomainInfo" call (in the domain info structure). */ torture_assert_str_equal(tctx, ldb_msg_find_attr_as_string(res[0], "dNSHostName", NULL), old_dnsname, "'DNS hostname' was not set!"); spn_el = ldb_msg_find_element(res[0], "servicePrincipalName"); torture_assert(tctx, ((spns != NULL) && (spn_el != NULL)), "'servicePrincipalName's not set!"); torture_assert(tctx, spn_el->num_values == num_spns, "'servicePrincipalName's incorrect!"); for (i=0; (i < spn_el->num_values) && (i < num_spns); i++) torture_assert_str_equal(tctx, (char *) spn_el->values[i].data, spns[i], "'servicePrincipalName's incorrect!"); torture_assert_str_equal(tctx, info.domain_info->dns_hostname.string, old_dnsname, "Out 'DNS hostname' doesn't match the old one!"); } else { /* If no DNS hostname was set then also now none should be set, the "servicePrincipalName"s should remain empty and no DNS hostname should be returned by our "LogonGetDomainInfo" call (in the domain info structure). */ torture_assert(tctx, ldb_msg_find_attr_as_string(res[0], "dNSHostName", NULL) == NULL, "'DNS hostname' was set!"); spn_el = ldb_msg_find_element(res[0], "servicePrincipalName"); torture_assert(tctx, ((spns == NULL) && (spn_el == NULL)), "'servicePrincipalName's were set!"); torture_assert(tctx, info.domain_info->dns_hostname.string == NULL, "Out 'DNS host name' was set!"); } } /* Checks "workstation flags" */ torture_assert(tctx, info.domain_info->workstation_flags == NETR_WS_FLAG_HANDLES_SPN_UPDATE, "Out 'workstation flags' don't match!"); torture_comment(tctx, "Testing netr_LogonGetDomainInfo 2nd call (variation of DNS hostname)\n"); netlogon_creds_client_authenticator(creds, &a); /* Wipe out the osVersion, and prove which values still 'stick' */ q1.os_version.os = NULL; /* Change also the DNS hostname to test differences in behaviour */ q1.dns_hostname = talloc_asprintf(tctx, "%s.newdomain", TEST_MACHINE_NAME); /* Let the DC handle the "servicePrincipalName" and DNS hostname updates */ q1.workstation_flags = 0; status = dcerpc_netr_LogonGetDomainInfo(p, tctx, &r); torture_assert_ntstatus_ok(tctx, status, "netr_LogonGetDomainInfo"); torture_assert(tctx, netlogon_creds_client_check(creds, &a.cred), "Credential chaining failed"); msleep(250); if (sam_ctx) { /* AD workstation infos entry check */ ret = gendb_search(sam_ctx, tctx, NULL, &res, attrs, "(sAMAccountName=%s$)", TEST_MACHINE_NAME); torture_assert(tctx, ret == 1, "Test machine account not found in SAMDB on DC! Has the workstation been joined?"); torture_assert_str_equal(tctx, ldb_msg_find_attr_as_string(res[0], "operatingSystem", NULL), q1.os_name.string, "'operatingSystem' should stick!"); torture_assert(tctx, ldb_msg_find_attr_as_string(res[0], "operatingSystemServicePack", NULL) == NULL, "'operatingSystemServicePack' shouldn't stick!"); torture_assert(tctx, ldb_msg_find_attr_as_string(res[0], "operatingSystemVersion", NULL) == NULL, "'operatingSystemVersion' shouldn't stick!"); /* The DNS host name should have been updated now by the server */ torture_assert_str_equal(tctx, ldb_msg_find_attr_as_string(res[0], "dNSHostName", NULL), q1.dns_hostname, "'DNS host name' didn't change!"); /* Find the two "servicePrincipalName"s which the DC should have been updated (HOST/ and HOST/) - see MS-NRPC 3.5.4.3.9 */ spn_el = ldb_msg_find_element(res[0], "servicePrincipalName"); torture_assert(tctx, spn_el != NULL, "There should exist 'servicePrincipalName's in AD!"); temp_str = talloc_asprintf(tctx, "HOST/%s", TEST_MACHINE_NAME); for (i=0; i < spn_el->num_values; i++) if (strcmp((char *) spn_el->values[i].data, temp_str) == 0) break; torture_assert(tctx, i != spn_el->num_values, "'servicePrincipalName' HOST/ not found!"); temp_str = talloc_asprintf(tctx, "HOST/%s", q1.dns_hostname); for (i=0; i < spn_el->num_values; i++) if (strcmp((char *) spn_el->values[i].data, temp_str) == 0) break; torture_assert(tctx, i != spn_el->num_values, "'servicePrincipalName' HOST/ not found!"); /* Check that the out DNS hostname was set properly */ torture_assert_str_equal(tctx, info.domain_info->dns_hostname.string, old_dnsname, "Out 'DNS hostname' doesn't match the old one!"); } /* Checks "workstation flags" */ torture_assert(tctx, info.domain_info->workstation_flags == 0, "Out 'workstation flags' don't match!"); torture_comment(tctx, "Testing netr_LogonGetDomainInfo 3rd call (verification of DNS hostname and check for trusted domains)\n"); netlogon_creds_client_authenticator(creds, &a); /* The workstation handles the "servicePrincipalName" and DNS hostname updates */ q1.workstation_flags = NETR_WS_FLAG_HANDLES_SPN_UPDATE; status = dcerpc_netr_LogonGetDomainInfo(p, tctx, &r); torture_assert_ntstatus_ok(tctx, status, "netr_LogonGetDomainInfo"); torture_assert(tctx, netlogon_creds_client_check(creds, &a.cred), "Credential chaining failed"); msleep(250); /* Now the in/out DNS hostnames should be the same */ torture_assert_str_equal(tctx, info.domain_info->dns_hostname.string, query.workstation_info->dns_hostname, "In/Out 'DNS hostnames' don't match!"); /* Checks "workstation flags" */ torture_assert(tctx, info.domain_info->workstation_flags == NETR_WS_FLAG_HANDLES_SPN_UPDATE, "Out 'workstation flags' don't match!"); /* Checks for trusted domains */ torture_assert(tctx, (info.domain_info->trusted_domain_count != 0) && (info.domain_info->trusted_domains != NULL), "Trusted domains have been requested!"); torture_comment(tctx, "Testing netr_LogonGetDomainInfo 4th call (check for trusted domains)\n"); netlogon_creds_client_authenticator(creds, &a); /* The workstation handles the "servicePrincipalName" and DNS hostname updates and requests inbound trusts */ q1.workstation_flags = NETR_WS_FLAG_HANDLES_SPN_UPDATE | NETR_WS_FLAG_HANDLES_INBOUND_TRUSTS; status = dcerpc_netr_LogonGetDomainInfo(p, tctx, &r); torture_assert_ntstatus_ok(tctx, status, "netr_LogonGetDomainInfo"); torture_assert(tctx, netlogon_creds_client_check(creds, &a.cred), "Credential chaining failed"); msleep(250); /* Checks "workstation flags" */ torture_assert(tctx, info.domain_info->workstation_flags == (NETR_WS_FLAG_HANDLES_SPN_UPDATE | NETR_WS_FLAG_HANDLES_INBOUND_TRUSTS), "Out 'workstation flags' don't match!"); /* Checks for trusted domains */ torture_assert(tctx, (info.domain_info->trusted_domain_count != 0) && (info.domain_info->trusted_domains != NULL), "Trusted domains have been requested!"); return true; } static void async_callback(struct rpc_request *req) { int *counter = (int *)req->async.private_data; if (NT_STATUS_IS_OK(req->status)) { (*counter)++; } } static bool test_GetDomainInfo_async(struct torture_context *tctx, struct dcerpc_pipe *p, struct cli_credentials *machine_credentials) { NTSTATUS status; struct netr_LogonGetDomainInfo r; struct netr_WorkstationInformation q1; struct netr_Authenticator a; #define ASYNC_COUNT 100 struct netlogon_creds_CredentialState *creds; struct netlogon_creds_CredentialState *creds_async[ASYNC_COUNT]; struct rpc_request *req[ASYNC_COUNT]; int i; int *async_counter = talloc(tctx, int); union netr_WorkstationInfo query; union netr_DomainInfo info; torture_comment(tctx, "Testing netr_LogonGetDomainInfo - async count %d\n", ASYNC_COUNT); if (!test_SetupCredentials3(p, tctx, NETLOGON_NEG_AUTH2_ADS_FLAGS, machine_credentials, &creds)) { return false; } ZERO_STRUCT(r); r.in.server_name = talloc_asprintf(tctx, "\\\\%s", dcerpc_server_name(p)); r.in.computer_name = TEST_MACHINE_NAME; r.in.credential = &a; r.in.level = 1; r.in.return_authenticator = &a; r.in.query = &query; r.out.return_authenticator = &a; r.out.info = &info; ZERO_STRUCT(q1); q1.dns_hostname = talloc_asprintf(tctx, "%s.%s", TEST_MACHINE_NAME, TEST_MACHINE_DNS_SUFFIX); q1.sitename = "Default-First-Site-Name"; q1.os_name.string = "UNIX/Linux or similar"; query.workstation_info = &q1; *async_counter = 0; for (i=0;iasync.callback = async_callback; req[i]->async.private_data = async_counter; /* even with this flush per request a w2k3 server seems to clag with multiple outstanding requests. bleergh. */ torture_assert_int_equal(tctx, event_loop_once(dcerpc_event_context(p)), 0, "event_loop_once failed"); } for (i=0;iconn->transport.transport != NCACN_NP) { return true; } torture_comment(tctx, "Torturing GetDCName\n"); status = dcerpc_secondary_connection(p, &p2, p->binding); torture_assert_ntstatus_ok(tctx, status, "Failed to create secondary connection"); status = dcerpc_bind_auth_none(p2, &ndr_table_lsarpc); torture_assert_ntstatus_ok(tctx, status, "Failed to create bind on secondary connection"); qos.len = 0; qos.impersonation_level = 2; qos.context_mode = 1; qos.effective_only = 0; attr.len = 0; attr.root_dir = NULL; attr.object_name = NULL; attr.attributes = 0; attr.sec_desc = NULL; attr.sec_qos = &qos; o.in.system_name = "\\"; o.in.attr = &attr; o.in.access_mask = SEC_FLAG_MAXIMUM_ALLOWED; o.out.handle = &lsa_handle; status = dcerpc_lsa_OpenPolicy2(p2, tctx, &o); torture_assert_ntstatus_ok(tctx, status, "OpenPolicy2 failed"); t.in.handle = &lsa_handle; t.in.resume_handle = &resume_handle; t.in.max_size = 1000; t.out.domains = &domains; t.out.resume_handle = &resume_handle; status = dcerpc_lsa_EnumTrustDom(p2, tctx, &t); if ((!NT_STATUS_IS_OK(status) && (!NT_STATUS_EQUAL(status, NT_STATUS_NO_MORE_ENTRIES)))) torture_fail(tctx, "Could not list domains"); talloc_free(p2); d.in.logon_server = talloc_asprintf(tctx, "\\\\%s", dcerpc_server_name(p)); d.out.dcname = &dcname; for (i=0; iname.string; status = dcerpc_netr_GetAnyDCName(p, tctx, &d); torture_assert_ntstatus_ok(tctx, status, "GetAnyDCName"); torture_comment(tctx, "\tDC for domain %s is %s\n", info->name.string, dcname ? dcname : "unknown"); } return true; } struct torture_suite *torture_rpc_netlogon(TALLOC_CTX *mem_ctx) { struct torture_suite *suite = torture_suite_create(mem_ctx, "NETLOGON"); struct torture_rpc_tcase *tcase; struct torture_test *test; tcase = torture_suite_add_machine_bdc_rpc_iface_tcase(suite, "netlogon", &ndr_table_netlogon, TEST_MACHINE_NAME); torture_rpc_tcase_add_test(tcase, "LogonUasLogon", test_LogonUasLogon); torture_rpc_tcase_add_test(tcase, "LogonUasLogoff", test_LogonUasLogoff); torture_rpc_tcase_add_test_creds(tcase, "SamLogon", test_SamLogon); torture_rpc_tcase_add_test_creds(tcase, "SetPassword", test_SetPassword); torture_rpc_tcase_add_test_creds(tcase, "SetPassword2", test_SetPassword2); torture_rpc_tcase_add_test_creds(tcase, "GetPassword", test_GetPassword); torture_rpc_tcase_add_test_creds(tcase, "GetTrustPasswords", test_GetTrustPasswords); torture_rpc_tcase_add_test_creds(tcase, "GetDomainInfo", test_GetDomainInfo); torture_rpc_tcase_add_test_creds(tcase, "DatabaseSync", test_DatabaseSync); torture_rpc_tcase_add_test_creds(tcase, "DatabaseDeltas", test_DatabaseDeltas); torture_rpc_tcase_add_test_creds(tcase, "DatabaseRedo", test_DatabaseRedo); torture_rpc_tcase_add_test_creds(tcase, "AccountDeltas", test_AccountDeltas); torture_rpc_tcase_add_test_creds(tcase, "AccountSync", test_AccountSync); torture_rpc_tcase_add_test(tcase, "GetDcName", test_GetDcName); torture_rpc_tcase_add_test(tcase, "ManyGetDCName", test_ManyGetDCName); torture_rpc_tcase_add_test(tcase, "LogonControl", test_LogonControl); torture_rpc_tcase_add_test(tcase, "GetAnyDCName", test_GetAnyDCName); torture_rpc_tcase_add_test(tcase, "LogonControl2", test_LogonControl2); torture_rpc_tcase_add_test_creds(tcase, "DatabaseSync2", test_DatabaseSync2); torture_rpc_tcase_add_test(tcase, "LogonControl2Ex", test_LogonControl2Ex); torture_rpc_tcase_add_test(tcase, "DsrEnumerateDomainTrusts", test_DsrEnumerateDomainTrusts); torture_rpc_tcase_add_test(tcase, "NetrEnumerateTrustedDomains", test_netr_NetrEnumerateTrustedDomains); torture_rpc_tcase_add_test(tcase, "NetrEnumerateTrustedDomainsEx", test_netr_NetrEnumerateTrustedDomainsEx); test = torture_rpc_tcase_add_test_creds(tcase, "GetDomainInfo_async", test_GetDomainInfo_async); test->dangerous = true; torture_rpc_tcase_add_test(tcase, "DsRGetDCName", test_netr_DsRGetDCName); torture_rpc_tcase_add_test(tcase, "DsRGetDCNameEx", test_netr_DsRGetDCNameEx); torture_rpc_tcase_add_test(tcase, "DsRGetDCNameEx2", test_netr_DsRGetDCNameEx2); torture_rpc_tcase_add_test(tcase, "DsrGetDcSiteCoverageW", test_netr_DsrGetDcSiteCoverageW); torture_rpc_tcase_add_test(tcase, "DsRAddressToSitenamesW", test_netr_DsRAddressToSitenamesW); torture_rpc_tcase_add_test(tcase, "DsRAddressToSitenamesExW", test_netr_DsRAddressToSitenamesExW); torture_rpc_tcase_add_test_creds(tcase, "ServerGetTrustInfo", test_netr_ServerGetTrustInfo); return suite; }