r4326: fix memory leak
[samba.git] / source4 / libcli / auth / spnego.c
index de71814354e88f075419fd9f2329ce32e6ea3be5..01757a04873cacf631f1623c8f01ab93e3537bd8 100644 (file)
@@ -23,6 +23,7 @@
 */
 
 #include "includes.h"
+#include "auth/auth.h"
 
 #undef DBGC_CLASS
 #define DBGC_CLASS DBGC_AUTH
@@ -37,7 +38,6 @@ enum spnego_state_position {
 };
 
 struct spnego_state {
-       TALLOC_CTX *mem_ctx;
        uint_t ref_count;
        enum spnego_message_type expected_packet;
        enum spnego_state_position state_position;
@@ -47,19 +47,14 @@ struct spnego_state {
 static NTSTATUS gensec_spnego_client_start(struct gensec_security *gensec_security)
 {
        struct spnego_state *spnego_state;
-       TALLOC_CTX *mem_ctx = talloc_init("gensec_spnego_client_start");
-       if (!mem_ctx) {
-               return NT_STATUS_NO_MEMORY;
-       }
-       spnego_state = talloc_p(mem_ctx, struct spnego_state);
-               
+
+       spnego_state = talloc_p(gensec_security, struct spnego_state);          
        if (!spnego_state) {
                return NT_STATUS_NO_MEMORY;
        }
 
        spnego_state->expected_packet = SPNEGO_NEG_TOKEN_INIT;
        spnego_state->state_position = SPNEGO_CLIENT_START;
-       spnego_state->mem_ctx = mem_ctx;
        spnego_state->sub_sec_security = NULL;
 
        gensec_security->private_data = spnego_state;
@@ -69,19 +64,14 @@ static NTSTATUS gensec_spnego_client_start(struct gensec_security *gensec_securi
 static NTSTATUS gensec_spnego_server_start(struct gensec_security *gensec_security)
 {
        struct spnego_state *spnego_state;
-       TALLOC_CTX *mem_ctx = talloc_init("gensec_spnego_server_start");
-       if (!mem_ctx) {
-               return NT_STATUS_NO_MEMORY;
-       }
-       spnego_state = talloc_p(mem_ctx, struct spnego_state);
-               
+
+       spnego_state = talloc_p(gensec_security, struct spnego_state);          
        if (!spnego_state) {
                return NT_STATUS_NO_MEMORY;
        }
 
        spnego_state->expected_packet = SPNEGO_NEG_TOKEN_INIT;
        spnego_state->state_position = SPNEGO_SERVER_START;
-       spnego_state->mem_ctx = mem_ctx;
        spnego_state->sub_sec_security = NULL;
 
        gensec_security->private_data = spnego_state;
@@ -92,8 +82,10 @@ static NTSTATUS gensec_spnego_server_start(struct gensec_security *gensec_securi
   wrappers for the spnego_*() functions
 */
 static NTSTATUS gensec_spnego_unseal_packet(struct gensec_security *gensec_security, 
-                                    TALLOC_CTX *mem_ctx, 
-                                    uint8_t *data, size_t length, DATA_BLOB *sig)
+                                           TALLOC_CTX *mem_ctx, 
+                                           uint8_t *data, size_t length, 
+                                           const uint8_t *whole_pdu, size_t pdu_length, 
+                                           DATA_BLOB *sig)
 {
        struct spnego_state *spnego_state = gensec_security->private_data;
 
@@ -103,47 +95,57 @@ static NTSTATUS gensec_spnego_unseal_packet(struct gensec_security *gensec_secur
        }
        
        return gensec_unseal_packet(spnego_state->sub_sec_security, 
-                                   mem_ctx, data, length, sig); 
+                                   mem_ctx, 
+                                   data, length, 
+                                   whole_pdu, pdu_length,
+                                   sig); 
 }
 
 static NTSTATUS gensec_spnego_check_packet(struct gensec_security *gensec_security, 
-                                    TALLOC_CTX *mem_ctx, 
-                                    const uint8_t *data, size_t length, 
-                                    const DATA_BLOB *sig)
+                                          TALLOC_CTX *mem_ctx, 
+                                          const uint8_t *data, size_t length, 
+                                          const uint8_t *whole_pdu, size_t pdu_length, 
+                                          const DATA_BLOB *sig)
 {
        struct spnego_state *spnego_state = gensec_security->private_data;
 
-       return NT_STATUS_NOT_IMPLEMENTED;
        if (spnego_state->state_position != SPNEGO_DONE 
            && spnego_state->state_position != SPNEGO_FALLBACK) {
                return NT_STATUS_INVALID_PARAMETER;
        }
        
        return gensec_check_packet(spnego_state->sub_sec_security, 
-                               mem_ctx, data, length, sig);
+                                  mem_ctx, 
+                                  data, length, 
+                                  whole_pdu, pdu_length,
+                                  sig);
 }
 
 static NTSTATUS gensec_spnego_seal_packet(struct gensec_security *gensec_security, 
-                                   TALLOC_CTX *mem_ctx, 
-                                   uint8_t *data, size_t length, 
-                                   DATA_BLOB *sig)
+                                         TALLOC_CTX *mem_ctx, 
+                                         uint8_t *data, size_t length, 
+                                         const uint8_t *whole_pdu, size_t pdu_length, 
+                                         DATA_BLOB *sig)
 {
        struct spnego_state *spnego_state = gensec_security->private_data;
 
-       return NT_STATUS_NOT_IMPLEMENTED;
        if (spnego_state->state_position != SPNEGO_DONE 
            && spnego_state->state_position != SPNEGO_FALLBACK) {
                return NT_STATUS_INVALID_PARAMETER;
        }
        
        return gensec_seal_packet(spnego_state->sub_sec_security, 
-                                 mem_ctx, data, length, sig);
+                                 mem_ctx, 
+                                 data, length, 
+                                 whole_pdu, pdu_length,
+                                 sig);
 }
 
 static NTSTATUS gensec_spnego_sign_packet(struct gensec_security *gensec_security, 
-                                   TALLOC_CTX *mem_ctx, 
-                                   const uint8_t *data, size_t length, 
-                                   DATA_BLOB *sig)
+                                         TALLOC_CTX *mem_ctx, 
+                                         const uint8_t *data, size_t length, 
+                                         const uint8_t *whole_pdu, size_t pdu_length, 
+                                         DATA_BLOB *sig)
 {
        struct spnego_state *spnego_state = gensec_security->private_data;
 
@@ -153,11 +155,26 @@ static NTSTATUS gensec_spnego_sign_packet(struct gensec_security *gensec_securit
        }
        
        return gensec_sign_packet(spnego_state->sub_sec_security, 
-                                 mem_ctx, data, length, sig);
+                                 mem_ctx, 
+                                 data, length, 
+                                 whole_pdu, pdu_length,
+                                 sig);
+}
+
+static size_t gensec_spnego_sig_size(struct gensec_security *gensec_security) 
+{
+       struct spnego_state *spnego_state = gensec_security->private_data;
+
+       if (spnego_state->state_position != SPNEGO_DONE 
+           && spnego_state->state_position != SPNEGO_FALLBACK) {
+               return 0;
+       }
+       
+       return gensec_sig_size(spnego_state->sub_sec_security);
 }
 
 static NTSTATUS gensec_spnego_session_key(struct gensec_security *gensec_security, 
-                                   DATA_BLOB *session_key)
+                                         DATA_BLOB *session_key)
 {
        struct spnego_state *spnego_state = gensec_security->private_data;
        if (!spnego_state->sub_sec_security) {
@@ -200,6 +217,10 @@ static NTSTATUS gensec_spnego_server_try_fallback(struct gensec_security *gensec
                if (!all_ops[i]->oid) {
                        continue;
                }
+               if (strcasecmp(GENSEC_OID_SPNEGO,all_ops[i]->oid) == 0) {
+                       continue;
+               }
+
                nt_status = gensec_subcontext_start(gensec_security, 
                                                    &spnego_state->sub_sec_security);
                if (!NT_STATUS_IS_OK(nt_status)) {
@@ -264,15 +285,14 @@ static NTSTATUS gensec_spnego_parse_negTokenInit(struct gensec_security *gensec_
                if (!NT_STATUS_EQUAL(nt_status, NT_STATUS_MORE_PROCESSING_REQUIRED) && !NT_STATUS_IS_OK(nt_status)) {
                        DEBUG(1, ("SPNEGO(%s) NEG_TOKEN_INIT failed: %s\n", 
                                  spnego_state->sub_sec_security->ops->name, nt_errstr(nt_status)));
-                               gensec_end(&spnego_state->sub_sec_security);
-               } else {
-                       break;
+                       gensec_end(&spnego_state->sub_sec_security);
                }
+               return nt_status;
        }
        if (!mechType || !mechType[i]) {
                DEBUG(1, ("SPNEGO: Could not find a suitable mechtype in NEG_TOKEN_INIT\n"));
        }
-       return nt_status;
+       return NT_STATUS_INVALID_PARAMETER;
 }
 
 /** create a client negTokenInit 
@@ -290,7 +310,7 @@ static NTSTATUS gensec_spnego_client_negTokenInit(struct gensec_security *gensec
        const char **mechTypes = NULL;
        DATA_BLOB unwrapped_out = data_blob(NULL,0);
 
-       mechTypes = gensec_security_oids(out_mem_ctx, OID_SPNEGO);
+       mechTypes = gensec_security_oids(out_mem_ctx, GENSEC_OID_SPNEGO);
 
        if (!mechTypes) {
                DEBUG(1, ("no GENSEC OID backends available\n"));
@@ -352,25 +372,28 @@ static NTSTATUS gensec_spnego_server_negTokenTarg(struct gensec_security *gensec
 
        /* compose reply */
        spnego_out.type = SPNEGO_NEG_TOKEN_TARG;
-       spnego_out.negTokenTarg.supportedMech 
-               = spnego_state->sub_sec_security->ops->oid;
        spnego_out.negTokenTarg.responseToken = unwrapped_out;
        spnego_out.negTokenTarg.mechListMIC = null_data_blob;
-       
+       spnego_out.negTokenTarg.supportedMech = NULL;
+
        if (NT_STATUS_EQUAL(nt_status, NT_STATUS_MORE_PROCESSING_REQUIRED)) {
+               spnego_out.negTokenTarg.supportedMech
+                       = spnego_state->sub_sec_security->ops->oid;
                spnego_out.negTokenTarg.negResult = SPNEGO_ACCEPT_INCOMPLETE;
                spnego_state->state_position = SPNEGO_SERVER_TARG;
        } else if (NT_STATUS_IS_OK(nt_status)) {
+               if (unwrapped_out.data) {
+                       spnego_out.negTokenTarg.supportedMech
+                               = spnego_state->sub_sec_security->ops->oid;
+               }
                spnego_out.negTokenTarg.negResult = SPNEGO_ACCEPT_COMPLETED;
                spnego_state->state_position = SPNEGO_DONE;
        } else {
                spnego_out.negTokenTarg.negResult = SPNEGO_REJECT;
-               DEBUG(1, ("SPNEGO(%s) login failed: %s\n", 
-                         spnego_state->sub_sec_security->ops->name, 
-                         nt_errstr(nt_status)));
+               DEBUG(1, ("SPNEGO login failed: %s\n", nt_errstr(nt_status)));
                spnego_state->state_position = SPNEGO_DONE;
        }
-       
+
        if (spnego_write_data(out_mem_ctx, out, &spnego_out) == -1) {
                DEBUG(1, ("Failed to write SPNEGO reply to NEG_TOKEN_TARG\n"));
                return NT_STATUS_INVALID_PARAMETER;
@@ -383,7 +406,7 @@ static NTSTATUS gensec_spnego_server_negTokenTarg(struct gensec_security *gensec
 
 
 static NTSTATUS gensec_spnego_update(struct gensec_security *gensec_security, TALLOC_CTX *out_mem_ctx, 
-                              const DATA_BLOB in, DATA_BLOB *out) 
+                                    const DATA_BLOB in, DATA_BLOB *out) 
 {
        struct spnego_state *spnego_state = gensec_security->private_data;
        DATA_BLOB null_data_blob = data_blob(NULL, 0);
@@ -396,7 +419,7 @@ static NTSTATUS gensec_spnego_update(struct gensec_security *gensec_security, TA
        *out = data_blob(NULL, 0);
 
        if (!out_mem_ctx) {
-               out_mem_ctx = spnego_state->mem_ctx;
+               out_mem_ctx = spnego_state;
        }
 
        /* and switch into the state machine */
@@ -420,7 +443,7 @@ static NTSTATUS gensec_spnego_update(struct gensec_security *gensec_security, TA
                        if (spnego.type != spnego_state->expected_packet) {
                                DEBUG(1, ("Invalid SPNEGO request: %d, expected %d\n", spnego.type, 
                                          spnego_state->expected_packet));
-                               dump_data(1, (const char *)in.data, in.length);
+                               dump_data(1, in.data, in.length);
                                spnego_free_data(&spnego);
                                return NT_STATUS_INVALID_PARAMETER;
                        }
@@ -443,12 +466,20 @@ static NTSTATUS gensec_spnego_update(struct gensec_security *gensec_security, TA
                        
                        return nt_status;
                } else {
-                       const char **mechlist = gensec_security_oids(out_mem_ctx, OID_SPNEGO);
+                       const char **mechlist = gensec_security_oids(out_mem_ctx, GENSEC_OID_SPNEGO);
+                       const char *mechListMIC;
+
+                       mechListMIC = talloc_asprintf(out_mem_ctx,"%s$@%s",
+                                                       lp_netbios_name(),
+                                                       lp_realm());
+                       if (!mechListMIC) {
+                               return NT_STATUS_NO_MEMORY;
+                       }
 
                        spnego_out.type = SPNEGO_NEG_TOKEN_INIT;
                        spnego_out.negTokenInit.mechTypes = mechlist;
                        spnego_out.negTokenInit.reqFlags = 0;
-                       spnego_out.negTokenInit.mechListMIC = null_data_blob;
+                       spnego_out.negTokenInit.mechListMIC = data_blob_string_const(mechListMIC);
                        spnego_out.negTokenInit.mechToken = unwrapped_out;
                        
                        if (spnego_write_data(out_mem_ctx, out, &spnego_out) == -1) {
@@ -468,7 +499,7 @@ static NTSTATUS gensec_spnego_update(struct gensec_security *gensec_security, TA
        {
                /* The server offers a list of mechanisms */
                
-               char *my_mechs[] = {NULL, NULL};
+               const char *my_mechs[] = {NULL, NULL};
                NTSTATUS nt_status = NT_STATUS_INVALID_PARAMETER;
 
                if (!in.length) {
@@ -480,7 +511,7 @@ static NTSTATUS gensec_spnego_update(struct gensec_security *gensec_security, TA
                
                if (len == -1) {
                        DEBUG(1, ("Invalid SPNEGO request:\n"));
-                       dump_data(1, (const char *)in.data, in.length);
+                       dump_data(1, in.data, in.length);
                        return NT_STATUS_INVALID_PARAMETER;
                }
                
@@ -488,7 +519,7 @@ static NTSTATUS gensec_spnego_update(struct gensec_security *gensec_security, TA
                if (spnego.type != spnego_state->expected_packet) {
                        DEBUG(1, ("Invalid SPNEGO request: %d, expected %d\n", spnego.type, 
                                  spnego_state->expected_packet));
-                       dump_data(1, (const char *)in.data, in.length);
+                       dump_data(1, in.data, in.length);
                        spnego_free_data(&spnego);
                        return NT_STATUS_INVALID_PARAMETER;
                }
@@ -498,6 +529,7 @@ static NTSTATUS gensec_spnego_update(struct gensec_security *gensec_security, TA
                        nt_status = gensec_set_target_principal(gensec_security, 
                                                                spnego.negTokenInit.targetPrincipal);
                        if (!NT_STATUS_IS_OK(nt_status)) {
+                               spnego_free_data(&spnego);
                                return nt_status;
                        }
                }
@@ -510,6 +542,7 @@ static NTSTATUS gensec_spnego_update(struct gensec_security *gensec_security, TA
                                                             &unwrapped_out);
 
                if (!NT_STATUS_EQUAL(nt_status, NT_STATUS_MORE_PROCESSING_REQUIRED) && !NT_STATUS_IS_OK(nt_status)) {
+                       spnego_free_data(&spnego);
                        return nt_status;
                }
 
@@ -544,7 +577,7 @@ static NTSTATUS gensec_spnego_update(struct gensec_security *gensec_security, TA
                
                if (len == -1) {
                        DEBUG(1, ("Invalid SPNEGO request:\n"));
-                       dump_data(1, (const char *)in.data, in.length);
+                       dump_data(1, in.data, in.length);
                        return NT_STATUS_INVALID_PARAMETER;
                }
                
@@ -552,7 +585,7 @@ static NTSTATUS gensec_spnego_update(struct gensec_security *gensec_security, TA
                if (spnego.type != spnego_state->expected_packet) {
                        DEBUG(1, ("Invalid SPNEGO request: %d, expected %d\n", spnego.type, 
                                  spnego_state->expected_packet));
-                       dump_data(1, (const char *)in.data, in.length);
+                       dump_data(1, in.data, in.length);
                        spnego_free_data(&spnego);
                        return NT_STATUS_INVALID_PARAMETER;
                }
@@ -584,7 +617,7 @@ static NTSTATUS gensec_spnego_update(struct gensec_security *gensec_security, TA
                
                if (len == -1) {
                        DEBUG(1, ("Invalid SPNEGO request:\n"));
-                       dump_data(1, (const char *)in.data, in.length);
+                       dump_data(1, in.data, in.length);
                        return NT_STATUS_INVALID_PARAMETER;
                }
                
@@ -592,7 +625,7 @@ static NTSTATUS gensec_spnego_update(struct gensec_security *gensec_security, TA
                if (spnego.type != spnego_state->expected_packet) {
                        DEBUG(1, ("Invalid SPNEGO request: %d, expected %d\n", spnego.type, 
                                  spnego_state->expected_packet));
-                       dump_data(1, (const char *)in.data, in.length);
+                       dump_data(1, in.data, in.length);
                        spnego_free_data(&spnego);
                        return NT_STATUS_INVALID_PARAMETER;
                }
@@ -669,7 +702,7 @@ static void gensec_spnego_end(struct gensec_security *gensec_security)
                gensec_end(&spnego_state->sub_sec_security);
        }
 
-       talloc_destroy(spnego_state->mem_ctx);
+       talloc_free(spnego_state);
 
        gensec_security->private_data = NULL;
 }
@@ -678,12 +711,13 @@ static const struct gensec_security_ops gensec_spnego_security_ops = {
        .name           = "spnego",
        .sasl_name      = "GSS-SPNEGO",
        .auth_type      = DCERPC_AUTH_TYPE_SPNEGO,
-       .oid            = OID_SPNEGO,
+       .oid            = GENSEC_OID_SPNEGO,
        .client_start   = gensec_spnego_client_start,
        .server_start   = gensec_spnego_server_start,
        .update         = gensec_spnego_update,
        .seal_packet    = gensec_spnego_seal_packet,
        .sign_packet    = gensec_spnego_sign_packet,
+       .sig_size       = gensec_spnego_sig_size,
        .check_packet   = gensec_spnego_check_packet,
        .unseal_packet  = gensec_spnego_unseal_packet,
        .session_key    = gensec_spnego_session_key,
@@ -694,7 +728,7 @@ static const struct gensec_security_ops gensec_spnego_security_ops = {
 NTSTATUS gensec_spnego_init(void)
 {
        NTSTATUS ret;
-       ret = register_backend("gensec", &gensec_spnego_security_ops);
+       ret = gensec_register(&gensec_spnego_security_ops);
        if (!NT_STATUS_IS_OK(ret)) {
                DEBUG(0,("Failed to register '%s' gensec backend!\n",
                        gensec_spnego_security_ops.name));