s4:auth/gensec_gssapi: add "gensec_gssapi:requested_life_time" option
[nivanova/samba-autobuild/.git] / source4 / auth / gensec / gensec_gssapi.c
1 /* 
2    Unix SMB/CIFS implementation.
3
4    Kerberos backend for GENSEC
5    
6    Copyright (C) Andrew Bartlett <abartlet@samba.org> 2004-2005
7    Copyright (C) Stefan Metzmacher <metze@samba.org> 2004-2005
8
9    This program is free software; you can redistribute it and/or modify
10    it under the terms of the GNU General Public License as published by
11    the Free Software Foundation; either version 3 of the License, or
12    (at your option) any later version.
13    
14    This program is distributed in the hope that it will be useful,
15    but WITHOUT ANY WARRANTY; without even the implied warranty of
16    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
17    GNU General Public License for more details.
18
19    
20    You should have received a copy of the GNU General Public License
21    along with this program.  If not, see <http://www.gnu.org/licenses/>.
22 */
23
24 #include "includes.h"
25 #include "lib/events/events.h"
26 #include "system/kerberos.h"
27 #include "system/gssapi.h"
28 #include "auth/kerberos/kerberos.h"
29 #include "librpc/gen_ndr/krb5pac.h"
30 #include "auth/auth.h"
31 #include <ldb.h>
32 #include "auth/auth_sam.h"
33 #include "librpc/rpc/dcerpc.h"
34 #include "auth/credentials/credentials.h"
35 #include "auth/credentials/credentials_krb5.h"
36 #include "auth/gensec/gensec.h"
37 #include "auth/gensec/gensec_proto.h"
38 #include "auth/gensec/gensec_toplevel_proto.h"
39 #include "param/param.h"
40 #include "auth/session_proto.h"
41 #include "gensec_gssapi.h"
42 #include "lib/util/util_net.h"
43 #include "auth/kerberos/pac_utils.h"
44
45 _PUBLIC_ NTSTATUS gensec_gssapi_init(void);
46
47 static size_t gensec_gssapi_max_input_size(struct gensec_security *gensec_security);
48 static size_t gensec_gssapi_max_wrapped_size(struct gensec_security *gensec_security);
49
50 static int gensec_gssapi_destructor(struct gensec_gssapi_state *gensec_gssapi_state)
51 {
52         OM_uint32 maj_stat, min_stat;
53         
54         if (gensec_gssapi_state->delegated_cred_handle != GSS_C_NO_CREDENTIAL) {
55                 maj_stat = gss_release_cred(&min_stat, 
56                                             &gensec_gssapi_state->delegated_cred_handle);
57         }
58
59         if (gensec_gssapi_state->gssapi_context != GSS_C_NO_CONTEXT) {
60                 maj_stat = gss_delete_sec_context (&min_stat,
61                                                    &gensec_gssapi_state->gssapi_context,
62                                                    GSS_C_NO_BUFFER);
63         }
64
65         if (gensec_gssapi_state->server_name != GSS_C_NO_NAME) {
66                 maj_stat = gss_release_name(&min_stat, &gensec_gssapi_state->server_name);
67         }
68         if (gensec_gssapi_state->client_name != GSS_C_NO_NAME) {
69                 maj_stat = gss_release_name(&min_stat, &gensec_gssapi_state->client_name);
70         }
71
72         if (gensec_gssapi_state->lucid) {
73                 gss_krb5_free_lucid_sec_context(&min_stat, gensec_gssapi_state->lucid);
74         }
75
76         return 0;
77 }
78
79 static NTSTATUS gensec_gssapi_init_lucid(struct gensec_gssapi_state *gensec_gssapi_state)
80 {
81         OM_uint32 maj_stat, min_stat;
82
83         if (gensec_gssapi_state->lucid) {
84                 return NT_STATUS_OK;
85         }
86
87         maj_stat = gss_krb5_export_lucid_sec_context(&min_stat,
88                                                      &gensec_gssapi_state->gssapi_context,
89                                                      1,
90                                                      (void **)&gensec_gssapi_state->lucid);
91         if (maj_stat != GSS_S_COMPLETE) {
92                 DEBUG(0,("gensec_gssapi_init_lucid: %s\n",
93                         gssapi_error_string(gensec_gssapi_state,
94                                             maj_stat, min_stat,
95                                             gensec_gssapi_state->gss_oid)));
96                 return NT_STATUS_INTERNAL_ERROR;
97         }
98
99         if (gensec_gssapi_state->lucid->version != 1) {
100                 DEBUG(0,("gensec_gssapi_init_lucid: lucid version[%d] != 1\n",
101                         gensec_gssapi_state->lucid->version));
102                 gss_krb5_free_lucid_sec_context(&min_stat, gensec_gssapi_state->lucid);
103                 gensec_gssapi_state->lucid = NULL;
104                 return NT_STATUS_INTERNAL_ERROR;
105         }
106
107         return NT_STATUS_OK;
108 }
109
110 static NTSTATUS gensec_gssapi_start(struct gensec_security *gensec_security)
111 {
112         struct gensec_gssapi_state *gensec_gssapi_state;
113         krb5_error_code ret;
114         const char *realm;
115
116         gensec_gssapi_state = talloc_zero(gensec_security, struct gensec_gssapi_state);
117         if (!gensec_gssapi_state) {
118                 return NT_STATUS_NO_MEMORY;
119         }
120
121         gensec_security->private_data = gensec_gssapi_state;
122
123         gensec_gssapi_state->gssapi_context = GSS_C_NO_CONTEXT;
124
125         /* TODO: Fill in channel bindings */
126         gensec_gssapi_state->input_chan_bindings = GSS_C_NO_CHANNEL_BINDINGS;
127
128         gensec_gssapi_state->server_name = GSS_C_NO_NAME;
129         gensec_gssapi_state->client_name = GSS_C_NO_NAME;
130         
131         gensec_gssapi_state->gss_want_flags = 0;
132         gensec_gssapi_state->expire_time = GENSEC_EXPIRE_TIME_INFINITY;
133
134         if (gensec_setting_bool(gensec_security->settings, "gensec_gssapi", "delegation_by_kdc_policy", true)) {
135                 gensec_gssapi_state->gss_want_flags |= GSS_C_DELEG_POLICY_FLAG;
136         }
137         if (gensec_setting_bool(gensec_security->settings, "gensec_gssapi", "mutual", true)) {
138                 gensec_gssapi_state->gss_want_flags |= GSS_C_MUTUAL_FLAG;
139         }
140         if (gensec_setting_bool(gensec_security->settings, "gensec_gssapi", "delegation", true)) {
141                 gensec_gssapi_state->gss_want_flags |= GSS_C_DELEG_FLAG;
142         }
143         if (gensec_setting_bool(gensec_security->settings, "gensec_gssapi", "replay", true)) {
144                 gensec_gssapi_state->gss_want_flags |= GSS_C_REPLAY_FLAG;
145         }
146         if (gensec_setting_bool(gensec_security->settings, "gensec_gssapi", "sequence", true)) {
147                 gensec_gssapi_state->gss_want_flags |= GSS_C_SEQUENCE_FLAG;
148         }
149
150         if (gensec_security->want_features & GENSEC_FEATURE_SIGN) {
151                 gensec_gssapi_state->gss_want_flags |= GSS_C_INTEG_FLAG;
152         }
153         if (gensec_security->want_features & GENSEC_FEATURE_SEAL) {
154                 gensec_gssapi_state->gss_want_flags |= GSS_C_INTEG_FLAG;
155                 gensec_gssapi_state->gss_want_flags |= GSS_C_CONF_FLAG;
156         }
157         if (gensec_security->want_features & GENSEC_FEATURE_DCE_STYLE) {
158                 gensec_gssapi_state->gss_want_flags |= GSS_C_DCE_STYLE;
159         }
160
161         gensec_gssapi_state->gss_got_flags = 0;
162
163         switch (gensec_security->ops->auth_type) {
164         case DCERPC_AUTH_TYPE_SPNEGO:
165                 gensec_gssapi_state->gss_oid = gss_mech_spnego;
166                 break;
167         case DCERPC_AUTH_TYPE_KRB5:
168         default:
169                 gensec_gssapi_state->gss_oid = gss_mech_krb5;
170                 break;
171         }
172
173         ret = smb_krb5_init_context(gensec_gssapi_state,
174                                     NULL,
175                                     gensec_security->settings->lp_ctx,
176                                     &gensec_gssapi_state->smb_krb5_context);
177         if (ret) {
178                 DEBUG(1,("gensec_krb5_start: krb5_init_context failed (%s)\n",
179                          error_message(ret)));
180                 talloc_free(gensec_gssapi_state);
181                 return NT_STATUS_INTERNAL_ERROR;
182         }
183
184         gensec_gssapi_state->client_cred = NULL;
185         gensec_gssapi_state->server_cred = NULL;
186
187         gensec_gssapi_state->lucid = NULL;
188
189         gensec_gssapi_state->delegated_cred_handle = GSS_C_NO_CREDENTIAL;
190
191         gensec_gssapi_state->sasl = false;
192         gensec_gssapi_state->sasl_state = STAGE_GSS_NEG;
193         gensec_gssapi_state->sasl_protection = 0;
194
195         gensec_gssapi_state->max_wrap_buf_size
196                 = gensec_setting_int(gensec_security->settings, "gensec_gssapi", "max wrap buf size", 65536);
197         gensec_gssapi_state->gss_exchange_count = 0;
198         gensec_gssapi_state->sig_size = 0;
199
200         talloc_set_destructor(gensec_gssapi_state, gensec_gssapi_destructor);
201
202         realm = lpcfg_realm(gensec_security->settings->lp_ctx);
203         if (realm != NULL) {
204                 ret = gsskrb5_set_default_realm(realm);
205                 if (ret) {
206                         DEBUG(1,("gensec_krb5_start: gsskrb5_set_default_realm failed\n"));
207                         talloc_free(gensec_gssapi_state);
208                         return NT_STATUS_INTERNAL_ERROR;
209                 }
210         }
211
212         /* don't do DNS lookups of any kind, it might/will fail for a netbios name */
213         ret = gsskrb5_set_dns_canonicalize(gensec_setting_bool(gensec_security->settings, "krb5", "set_dns_canonicalize", false));
214         if (ret) {
215                 DEBUG(1,("gensec_krb5_start: gsskrb5_set_dns_canonicalize failed\n"));
216                 talloc_free(gensec_gssapi_state);
217                 return NT_STATUS_INTERNAL_ERROR;
218         }
219
220         return NT_STATUS_OK;
221 }
222
223 static NTSTATUS gensec_gssapi_server_start(struct gensec_security *gensec_security)
224 {
225         NTSTATUS nt_status;
226         int ret;
227         struct gensec_gssapi_state *gensec_gssapi_state;
228         struct cli_credentials *machine_account;
229         struct gssapi_creds_container *gcc;
230
231         nt_status = gensec_gssapi_start(gensec_security);
232         if (!NT_STATUS_IS_OK(nt_status)) {
233                 return nt_status;
234         }
235
236         gensec_gssapi_state = talloc_get_type(gensec_security->private_data, struct gensec_gssapi_state);
237
238         machine_account = gensec_get_credentials(gensec_security);
239         
240         if (!machine_account) {
241                 DEBUG(3, ("No machine account credentials specified\n"));
242                 return NT_STATUS_CANT_ACCESS_DOMAIN_INFO;
243         } else {
244                 ret = cli_credentials_get_server_gss_creds(machine_account, 
245                                                            gensec_security->settings->lp_ctx, &gcc);
246                 if (ret) {
247                         DEBUG(1, ("Aquiring acceptor credentials failed: %s\n", 
248                                   error_message(ret)));
249                         return NT_STATUS_CANT_ACCESS_DOMAIN_INFO;
250                 }
251         }
252
253         gensec_gssapi_state->server_cred = gcc;
254         return NT_STATUS_OK;
255
256 }
257
258 static NTSTATUS gensec_gssapi_sasl_server_start(struct gensec_security *gensec_security)
259 {
260         NTSTATUS nt_status;
261         struct gensec_gssapi_state *gensec_gssapi_state;
262         nt_status = gensec_gssapi_server_start(gensec_security);
263
264         if (NT_STATUS_IS_OK(nt_status)) {
265                 gensec_gssapi_state = talloc_get_type(gensec_security->private_data, struct gensec_gssapi_state);
266                 gensec_gssapi_state->sasl = true;
267         }
268         return nt_status;
269 }
270
271 static NTSTATUS gensec_gssapi_client_creds(struct gensec_security *gensec_security,
272                                            struct tevent_context *ev)
273 {
274         struct gensec_gssapi_state *gensec_gssapi_state;
275         struct gssapi_creds_container *gcc;
276         struct cli_credentials *creds = gensec_get_credentials(gensec_security);
277         const char *error_string;
278         int ret;
279
280         gensec_gssapi_state = talloc_get_type(gensec_security->private_data, struct gensec_gssapi_state);
281
282         /* Only run this the first time the update() call is made */
283         if (gensec_gssapi_state->client_cred) {
284                 return NT_STATUS_OK;
285         }
286
287         ret = cli_credentials_get_client_gss_creds(creds,
288                                                    ev,
289                                                    gensec_security->settings->lp_ctx, &gcc, &error_string);
290         switch (ret) {
291         case 0:
292                 break;
293         case EINVAL:
294                 DEBUG(3, ("Cannot obtain client GSS credentials we need to contact %s : %s\n", gensec_gssapi_state->target_principal, error_string));
295                 return NT_STATUS_INVALID_PARAMETER;
296         case KRB5KDC_ERR_PREAUTH_FAILED:
297         case KRB5KDC_ERR_C_PRINCIPAL_UNKNOWN:
298                 DEBUG(1, ("Wrong username or password: %s\n", error_string));
299                 return NT_STATUS_LOGON_FAILURE;
300         case KRB5_KDC_UNREACH:
301                 DEBUG(3, ("Cannot reach a KDC we require to contact %s : %s\n", gensec_gssapi_state->target_principal, error_string));
302                 return NT_STATUS_NO_LOGON_SERVERS;
303         case KRB5_CC_NOTFOUND:
304         case KRB5_CC_END:
305                 DEBUG(2, ("Error obtaining ticket we require to contact %s: (possibly due to clock skew between us and the KDC) %s\n", gensec_gssapi_state->target_principal, error_string));
306                 return NT_STATUS_TIME_DIFFERENCE_AT_DC;
307         default:
308                 DEBUG(1, ("Aquiring initiator credentials failed: %s\n", error_string));
309                 return NT_STATUS_UNSUCCESSFUL;
310         }
311
312         gensec_gssapi_state->client_cred = gcc;
313         if (!talloc_reference(gensec_gssapi_state, gcc)) {
314                 return NT_STATUS_NO_MEMORY;
315         }
316
317         return NT_STATUS_OK;
318 }
319
320 static NTSTATUS gensec_gssapi_client_start(struct gensec_security *gensec_security)
321 {
322         struct gensec_gssapi_state *gensec_gssapi_state;
323         struct cli_credentials *creds = gensec_get_credentials(gensec_security);
324         NTSTATUS nt_status;
325         gss_buffer_desc name_token;
326         gss_OID name_type;
327         OM_uint32 maj_stat, min_stat;
328         const char *hostname = gensec_get_target_hostname(gensec_security);
329
330         if (!hostname) {
331                 DEBUG(1, ("Could not determine hostname for target computer, cannot use kerberos\n"));
332                 return NT_STATUS_INVALID_PARAMETER;
333         }
334         if (is_ipaddress(hostname)) {
335                 DEBUG(2, ("Cannot do GSSAPI to an IP address\n"));
336                 return NT_STATUS_INVALID_PARAMETER;
337         }
338         if (strcmp(hostname, "localhost") == 0) {
339                 DEBUG(2, ("GSSAPI to 'localhost' does not make sense\n"));
340                 return NT_STATUS_INVALID_PARAMETER;
341         }
342
343         nt_status = gensec_gssapi_start(gensec_security);
344         if (!NT_STATUS_IS_OK(nt_status)) {
345                 return nt_status;
346         }
347
348         gensec_gssapi_state = talloc_get_type(gensec_security->private_data, struct gensec_gssapi_state);
349
350         if (cli_credentials_get_impersonate_principal(creds)) {
351                 gensec_gssapi_state->gss_want_flags &= ~(GSS_C_DELEG_FLAG|GSS_C_DELEG_POLICY_FLAG);
352         }
353
354         gensec_gssapi_state->target_principal = gensec_get_target_principal(gensec_security);
355         if (gensec_gssapi_state->target_principal) {
356                 name_type = GSS_C_NULL_OID;
357         } else {
358                 gensec_gssapi_state->target_principal = talloc_asprintf(gensec_gssapi_state, "%s/%s@%s",
359                                             gensec_get_target_service(gensec_security), 
360                                             hostname, lpcfg_realm(gensec_security->settings->lp_ctx));
361
362                 name_type = GSS_C_NT_USER_NAME;
363         }
364         name_token.value  = discard_const_p(uint8_t, gensec_gssapi_state->target_principal);
365         name_token.length = strlen(gensec_gssapi_state->target_principal);
366
367
368         maj_stat = gss_import_name (&min_stat,
369                                     &name_token,
370                                     name_type,
371                                     &gensec_gssapi_state->server_name);
372         if (maj_stat) {
373                 DEBUG(2, ("GSS Import name of %s failed: %s\n",
374                           (char *)name_token.value,
375                           gssapi_error_string(gensec_gssapi_state, maj_stat, min_stat, gensec_gssapi_state->gss_oid)));
376                 return NT_STATUS_INVALID_PARAMETER;
377         }
378
379         return NT_STATUS_OK;
380 }
381
382 static NTSTATUS gensec_gssapi_sasl_client_start(struct gensec_security *gensec_security)
383 {
384         NTSTATUS nt_status;
385         struct gensec_gssapi_state *gensec_gssapi_state;
386         nt_status = gensec_gssapi_client_start(gensec_security);
387
388         if (NT_STATUS_IS_OK(nt_status)) {
389                 gensec_gssapi_state = talloc_get_type(gensec_security->private_data, struct gensec_gssapi_state);
390                 gensec_gssapi_state->sasl = true;
391         }
392         return nt_status;
393 }
394
395
396 /**
397  * Next state function for the GSSAPI GENSEC mechanism
398  * 
399  * @param gensec_gssapi_state GSSAPI State
400  * @param out_mem_ctx The TALLOC_CTX for *out to be allocated on
401  * @param in The request, as a DATA_BLOB
402  * @param out The reply, as an talloc()ed DATA_BLOB, on *out_mem_ctx
403  * @return Error, MORE_PROCESSING_REQUIRED if a reply is sent, 
404  *                or NT_STATUS_OK if the user is authenticated. 
405  */
406
407 static NTSTATUS gensec_gssapi_update(struct gensec_security *gensec_security, 
408                                      TALLOC_CTX *out_mem_ctx,
409                                      struct tevent_context *ev,
410                                      const DATA_BLOB in, DATA_BLOB *out)
411 {
412         struct gensec_gssapi_state *gensec_gssapi_state
413                 = talloc_get_type(gensec_security->private_data, struct gensec_gssapi_state);
414         NTSTATUS nt_status = NT_STATUS_LOGON_FAILURE;
415         OM_uint32 maj_stat, min_stat;
416         OM_uint32 min_stat2;
417         gss_buffer_desc input_token, output_token;
418         gss_OID gss_oid_p = NULL;
419         OM_uint32 time_req = 0;
420         OM_uint32 time_rec = 0;
421         struct timeval tv;
422
423         time_req = gensec_setting_int(gensec_security->settings,
424                                       "gensec_gssapi", "requested_life_time",
425                                       time_req);
426
427         input_token.length = in.length;
428         input_token.value = in.data;
429
430         switch (gensec_gssapi_state->sasl_state) {
431         case STAGE_GSS_NEG:
432         {
433                 switch (gensec_security->gensec_role) {
434                 case GENSEC_CLIENT:
435                 {
436                         struct gsskrb5_send_to_kdc send_to_kdc;
437                         krb5_error_code ret;
438
439                         nt_status = gensec_gssapi_client_creds(gensec_security, ev);
440                         if (!NT_STATUS_IS_OK(nt_status)) {
441                                 return nt_status;
442                         }
443
444 #ifdef SAMBA4_USES_HEIMDAL
445                         send_to_kdc.func = smb_krb5_send_and_recv_func;
446                         send_to_kdc.ptr = ev;
447 #endif
448
449                         min_stat = gsskrb5_set_send_to_kdc(&send_to_kdc);
450                         if (min_stat) {
451                                 DEBUG(1,("gensec_krb5_start: gsskrb5_set_send_to_kdc failed\n"));
452                                 return NT_STATUS_INTERNAL_ERROR;
453                         }
454
455                         maj_stat = gss_init_sec_context(&min_stat, 
456                                                         gensec_gssapi_state->client_cred->creds,
457                                                         &gensec_gssapi_state->gssapi_context, 
458                                                         gensec_gssapi_state->server_name, 
459                                                         gensec_gssapi_state->gss_oid,
460                                                         gensec_gssapi_state->gss_want_flags, 
461                                                         time_req,
462                                                         gensec_gssapi_state->input_chan_bindings,
463                                                         &input_token, 
464                                                         &gss_oid_p,
465                                                         &output_token, 
466                                                         &gensec_gssapi_state->gss_got_flags, /* ret flags */
467                                                         &time_rec);
468                         if (gss_oid_p) {
469                                 gensec_gssapi_state->gss_oid = gss_oid_p;
470                         }
471
472 #ifdef SAMBA4_USES_HEIMDAL
473                         send_to_kdc.func = smb_krb5_send_and_recv_func;
474                         send_to_kdc.ptr = NULL;
475 #endif
476
477                         ret = gsskrb5_set_send_to_kdc(&send_to_kdc);
478                         if (ret) {
479                                 DEBUG(1,("gensec_krb5_start: gsskrb5_set_send_to_kdc failed\n"));
480                                 return NT_STATUS_INTERNAL_ERROR;
481                         }
482
483                         break;
484                 }
485                 case GENSEC_SERVER:
486                 {
487                         maj_stat = gss_accept_sec_context(&min_stat, 
488                                                           &gensec_gssapi_state->gssapi_context, 
489                                                           gensec_gssapi_state->server_cred->creds,
490                                                           &input_token, 
491                                                           gensec_gssapi_state->input_chan_bindings,
492                                                           &gensec_gssapi_state->client_name, 
493                                                           &gss_oid_p,
494                                                           &output_token, 
495                                                           &gensec_gssapi_state->gss_got_flags, 
496                                                           &time_rec,
497                                                           &gensec_gssapi_state->delegated_cred_handle);
498                         if (gss_oid_p) {
499                                 gensec_gssapi_state->gss_oid = gss_oid_p;
500                         }
501                         break;
502                 }
503                 default:
504                         return NT_STATUS_INVALID_PARAMETER;
505                         
506                 }
507
508                 gensec_gssapi_state->gss_exchange_count++;
509
510                 if (maj_stat == GSS_S_COMPLETE) {
511                         *out = data_blob_talloc(out_mem_ctx, output_token.value, output_token.length);
512                         gss_release_buffer(&min_stat2, &output_token);
513                         
514                         if (gensec_gssapi_state->gss_got_flags & GSS_C_DELEG_FLAG) {
515                                 DEBUG(5, ("gensec_gssapi: credentials were delegated\n"));
516                         } else {
517                                 DEBUG(5, ("gensec_gssapi: NO credentials were delegated\n"));
518                         }
519
520                         tv = timeval_current_ofs(time_rec, 0);
521                         gensec_gssapi_state->expire_time = timeval_to_nttime(&tv);
522
523                         /* We may have been invoked as SASL, so there
524                          * is more work to do */
525                         if (gensec_gssapi_state->sasl) {
526                                 gensec_gssapi_state->sasl_state = STAGE_SASL_SSF_NEG;
527                                 return NT_STATUS_MORE_PROCESSING_REQUIRED;
528                         } else {
529                                 gensec_gssapi_state->sasl_state = STAGE_DONE;
530
531                                 if (gensec_have_feature(gensec_security, GENSEC_FEATURE_SEAL)) {
532                                         DEBUG(5, ("GSSAPI Connection will be cryptographically sealed\n"));
533                                 } else if (gensec_have_feature(gensec_security, GENSEC_FEATURE_SIGN)) {
534                                         DEBUG(5, ("GSSAPI Connection will be cryptographically signed\n"));
535                                 } else {
536                                         DEBUG(5, ("GSSAPI Connection will have no cryptographic protection\n"));
537                                 }
538
539                                 return NT_STATUS_OK;
540                         }
541                 } else if (maj_stat == GSS_S_CONTINUE_NEEDED) {
542                         *out = data_blob_talloc(out_mem_ctx, output_token.value, output_token.length);
543                         gss_release_buffer(&min_stat2, &output_token);
544                         
545                         return NT_STATUS_MORE_PROCESSING_REQUIRED;
546                 } else if (maj_stat == GSS_S_CONTEXT_EXPIRED) {
547                         gss_cred_id_t creds;
548                         gss_name_t name;
549                         gss_buffer_desc buffer;
550                         OM_uint32 lifetime = 0;
551                         gss_cred_usage_t usage;
552                         const char *role = NULL;
553                         DEBUG(0, ("GSS %s Update(krb5)(%d) Update failed, credentials expired during GSSAPI handshake!\n",
554                                   role,
555                                   gensec_gssapi_state->gss_exchange_count));
556
557                         
558                         switch (gensec_security->gensec_role) {
559                         case GENSEC_CLIENT:
560                                 creds = gensec_gssapi_state->client_cred->creds;
561                                 role = "client";
562                                 break;
563                         case GENSEC_SERVER:
564                                 creds = gensec_gssapi_state->server_cred->creds;
565                                 role = "server";
566                                 break;
567                         }
568
569                         maj_stat = gss_inquire_cred(&min_stat, 
570                                                     creds,
571                                                     &name, &lifetime, &usage, NULL);
572
573                         if (maj_stat == GSS_S_COMPLETE) {
574                                 const char *usage_string;
575                                 switch (usage) {
576                                 case GSS_C_BOTH:
577                                         usage_string = "GSS_C_BOTH";
578                                         break;
579                                 case GSS_C_ACCEPT:
580                                         usage_string = "GSS_C_ACCEPT";
581                                         break;
582                                 case GSS_C_INITIATE:
583                                         usage_string = "GSS_C_INITIATE";
584                                         break;
585                                 }
586                                 maj_stat = gss_display_name(&min_stat, name, &buffer, NULL);
587                                 if (maj_stat) {
588                                         buffer.value = NULL;
589                                         buffer.length = 0;
590                                 }
591                                 if (lifetime > 0) {
592                                         DEBUG(0, ("GSSAPI gss_inquire_cred indicates expiry of %*.*s in %u sec for %s\n", 
593                                                   (int)buffer.length, (int)buffer.length, (char *)buffer.value, 
594                                                   lifetime, usage_string));
595                                 } else {
596                                         DEBUG(0, ("GSSAPI gss_inquire_cred indicates %*.*s has already expired for %s\n", 
597                                                   (int)buffer.length, (int)buffer.length, (char *)buffer.value, 
598                                                   usage_string));
599                                 }
600                                 gss_release_buffer(&min_stat, &buffer);
601                                 gss_release_name(&min_stat, &name);
602                         } else if (maj_stat != GSS_S_COMPLETE) {
603                                 DEBUG(0, ("inquiry of credential lifefime via GSSAPI gss_inquire_cred failed: %s\n",
604                                           gssapi_error_string(out_mem_ctx, maj_stat, min_stat, gensec_gssapi_state->gss_oid)));
605                         }
606                         return NT_STATUS_INVALID_PARAMETER;
607                 } else if (gss_oid_equal(gensec_gssapi_state->gss_oid, gss_mech_krb5)) {
608                         switch (min_stat) {
609                         case KRB5KRB_AP_ERR_TKT_NYV:
610                                 DEBUG(1, ("Error with ticket to contact %s: possible clock skew between us and the KDC or target server: %s\n",
611                                           gensec_gssapi_state->target_principal,
612                                           gssapi_error_string(out_mem_ctx, maj_stat, min_stat, gensec_gssapi_state->gss_oid)));
613                                 return NT_STATUS_TIME_DIFFERENCE_AT_DC; /* Make SPNEGO ignore us, we can't go any further here */
614                         case KRB5KRB_AP_ERR_TKT_EXPIRED:
615                                 DEBUG(1, ("Error with ticket to contact %s: ticket is expired, possible clock skew between us and the KDC or target server: %s\n",
616                                           gensec_gssapi_state->target_principal,
617                                           gssapi_error_string(out_mem_ctx, maj_stat, min_stat, gensec_gssapi_state->gss_oid)));
618                                 return NT_STATUS_INVALID_PARAMETER; /* Make SPNEGO ignore us, we can't go any further here */
619                         case KRB5_KDC_UNREACH:
620                                 DEBUG(3, ("Cannot reach a KDC we require in order to obtain a ticetk to %s: %s\n",
621                                           gensec_gssapi_state->target_principal,
622                                           gssapi_error_string(out_mem_ctx, maj_stat, min_stat, gensec_gssapi_state->gss_oid)));
623                                 return NT_STATUS_NO_LOGON_SERVERS; /* Make SPNEGO ignore us, we can't go any further here */
624                         case KRB5KDC_ERR_S_PRINCIPAL_UNKNOWN:
625                                 DEBUG(3, ("Server %s is not registered with our KDC: %s\n",
626                                           gensec_gssapi_state->target_principal,
627                                           gssapi_error_string(out_mem_ctx, maj_stat, min_stat, gensec_gssapi_state->gss_oid)));
628                                 return NT_STATUS_INVALID_PARAMETER; /* Make SPNEGO ignore us, we can't go any further here */
629                         case KRB5KRB_AP_ERR_MSG_TYPE:
630                                 /* garbage input, possibly from the auto-mech detection */
631                                 return NT_STATUS_INVALID_PARAMETER;
632                         default:
633                                 DEBUG(1, ("GSS %s Update(krb5)(%d) Update failed: %s\n",
634                                           gensec_security->gensec_role == GENSEC_CLIENT ? "client" : "server",
635                                           gensec_gssapi_state->gss_exchange_count,
636                                           gssapi_error_string(out_mem_ctx, maj_stat, min_stat, gensec_gssapi_state->gss_oid)));
637                                 return nt_status;
638                         }
639                 } else {
640                         DEBUG(1, ("GSS %s Update(%d) failed: %s\n",
641                                   gensec_security->gensec_role == GENSEC_CLIENT ? "client" : "server",
642                                   gensec_gssapi_state->gss_exchange_count,
643                                   gssapi_error_string(out_mem_ctx, maj_stat, min_stat, gensec_gssapi_state->gss_oid)));
644                         return nt_status;
645                 }
646                 break;
647         }
648
649         /* These last two stages are only done if we were invoked as SASL */
650         case STAGE_SASL_SSF_NEG:
651         {
652                 switch (gensec_security->gensec_role) {
653                 case GENSEC_CLIENT:
654                 {
655                         uint8_t maxlength_proposed[4]; 
656                         uint8_t maxlength_accepted[4]; 
657                         uint8_t security_supported;
658                         int conf_state;
659                         gss_qop_t qop_state;
660                         input_token.length = in.length;
661                         input_token.value = in.data;
662
663                         /* As a client, we have just send a
664                          * zero-length blob to the server (after the
665                          * normal GSSAPI exchange), and it has replied
666                          * with it's SASL negotiation */
667                         
668                         maj_stat = gss_unwrap(&min_stat, 
669                                               gensec_gssapi_state->gssapi_context, 
670                                               &input_token,
671                                               &output_token, 
672                                               &conf_state,
673                                               &qop_state);
674                         if (GSS_ERROR(maj_stat)) {
675                                 DEBUG(1, ("gensec_gssapi_update: GSS UnWrap of SASL protection negotiation failed: %s\n", 
676                                           gssapi_error_string(out_mem_ctx, maj_stat, min_stat, gensec_gssapi_state->gss_oid)));
677                                 return NT_STATUS_ACCESS_DENIED;
678                         }
679                         
680                         if (output_token.length < 4) {
681                                 return NT_STATUS_INVALID_PARAMETER;
682                         }
683
684                         memcpy(maxlength_proposed, output_token.value, 4);
685                         gss_release_buffer(&min_stat, &output_token);
686
687                         /* first byte is the proposed security */
688                         security_supported = maxlength_proposed[0];
689                         maxlength_proposed[0] = '\0';
690                         
691                         /* Rest is the proposed max wrap length */
692                         gensec_gssapi_state->max_wrap_buf_size = MIN(RIVAL(maxlength_proposed, 0), 
693                                                                      gensec_gssapi_state->max_wrap_buf_size);
694                         gensec_gssapi_state->sasl_protection = 0;
695                         if (security_supported & NEG_SEAL) {
696                                 if (gensec_have_feature(gensec_security, GENSEC_FEATURE_SEAL)) {
697                                         gensec_gssapi_state->sasl_protection |= NEG_SEAL;
698                                 }
699                         }
700                         if (security_supported & NEG_SIGN) {
701                                 if (gensec_have_feature(gensec_security, GENSEC_FEATURE_SIGN)) {
702                                         gensec_gssapi_state->sasl_protection |= NEG_SIGN;
703                                 }
704                         }
705                         if (security_supported & NEG_NONE) {
706                                 gensec_gssapi_state->sasl_protection |= NEG_NONE;
707                         }
708                         if (gensec_gssapi_state->sasl_protection == 0) {
709                                 DEBUG(1, ("Remote server does not support unprotected connections\n"));
710                                 return NT_STATUS_ACCESS_DENIED;
711                         }
712
713                         /* Send back the negotiated max length */
714
715                         RSIVAL(maxlength_accepted, 0, gensec_gssapi_state->max_wrap_buf_size);
716
717                         maxlength_accepted[0] = gensec_gssapi_state->sasl_protection;
718                         
719                         input_token.value = maxlength_accepted;
720                         input_token.length = sizeof(maxlength_accepted);
721
722                         maj_stat = gss_wrap(&min_stat, 
723                                             gensec_gssapi_state->gssapi_context, 
724                                             false,
725                                             GSS_C_QOP_DEFAULT,
726                                             &input_token,
727                                             &conf_state,
728                                             &output_token);
729                         if (GSS_ERROR(maj_stat)) {
730                                 DEBUG(1, ("GSS Update(SSF_NEG): GSS Wrap failed: %s\n", 
731                                           gssapi_error_string(out_mem_ctx, maj_stat, min_stat, gensec_gssapi_state->gss_oid)));
732                                 return NT_STATUS_ACCESS_DENIED;
733                         }
734                         
735                         *out = data_blob_talloc(out_mem_ctx, output_token.value, output_token.length);
736                         gss_release_buffer(&min_stat, &output_token);
737
738                         /* quirk:  This changes the value that gensec_have_feature returns, to be that after SASL negotiation */
739                         gensec_gssapi_state->sasl_state = STAGE_DONE;
740
741                         if (gensec_have_feature(gensec_security, GENSEC_FEATURE_SEAL)) {
742                                 DEBUG(3, ("SASL/GSSAPI Connection to server will be cryptographically sealed\n"));
743                         } else if (gensec_have_feature(gensec_security, GENSEC_FEATURE_SIGN)) {
744                                 DEBUG(3, ("SASL/GSSAPI Connection to server will be cryptographically signed\n"));
745                         } else {
746                                 DEBUG(3, ("SASL/GSSAPI Connection to server will have no cryptographically protection\n"));
747                         }
748
749                         return NT_STATUS_OK;
750                 }
751                 case GENSEC_SERVER:
752                 {
753                         uint8_t maxlength_proposed[4]; 
754                         uint8_t security_supported = 0x0;
755                         int conf_state;
756
757                         /* As a server, we have just been sent a zero-length blob (note this, but it isn't fatal) */
758                         if (in.length != 0) {
759                                 DEBUG(1, ("SASL/GSSAPI: client sent non-zero length starting SASL negotiation!\n"));
760                         }
761                         
762                         /* Give the client some idea what we will support */
763                           
764                         RSIVAL(maxlength_proposed, 0, gensec_gssapi_state->max_wrap_buf_size);
765                         /* first byte is the proposed security */
766                         maxlength_proposed[0] = '\0';
767                         
768                         gensec_gssapi_state->sasl_protection = 0;
769                         if (gensec_have_feature(gensec_security, GENSEC_FEATURE_SEAL)) {
770                                 security_supported |= NEG_SEAL;
771                         } 
772                         if (gensec_have_feature(gensec_security, GENSEC_FEATURE_SIGN)) {
773                                 security_supported |= NEG_SIGN;
774                         }
775                         if (security_supported == 0) {
776                                 /* If we don't support anything, this must be 0 */
777                                 RSIVAL(maxlength_proposed, 0, 0x0);
778                         }
779
780                         /* TODO:  We may not wish to support this */
781                         security_supported |= NEG_NONE;
782                         maxlength_proposed[0] = security_supported;
783                         
784                         input_token.value = maxlength_proposed;
785                         input_token.length = sizeof(maxlength_proposed);
786
787                         maj_stat = gss_wrap(&min_stat, 
788                                             gensec_gssapi_state->gssapi_context, 
789                                             false,
790                                             GSS_C_QOP_DEFAULT,
791                                             &input_token,
792                                             &conf_state,
793                                             &output_token);
794                         if (GSS_ERROR(maj_stat)) {
795                                 DEBUG(1, ("GSS Update(SSF_NEG): GSS Wrap failed: %s\n", 
796                                           gssapi_error_string(out_mem_ctx, maj_stat, min_stat, gensec_gssapi_state->gss_oid)));
797                                 return NT_STATUS_ACCESS_DENIED;
798                         }
799                         
800                         *out = data_blob_talloc(out_mem_ctx, output_token.value, output_token.length);
801                         gss_release_buffer(&min_stat, &output_token);
802
803                         gensec_gssapi_state->sasl_state = STAGE_SASL_SSF_ACCEPT;
804                         return NT_STATUS_MORE_PROCESSING_REQUIRED;
805                 }
806                 default:
807                         return NT_STATUS_INVALID_PARAMETER;
808                         
809                 }
810         }
811         /* This is s server-only stage */
812         case STAGE_SASL_SSF_ACCEPT:
813         {
814                 uint8_t maxlength_accepted[4]; 
815                 uint8_t security_accepted;
816                 int conf_state;
817                 gss_qop_t qop_state;
818                 input_token.length = in.length;
819                 input_token.value = in.data;
820                         
821                 maj_stat = gss_unwrap(&min_stat, 
822                                       gensec_gssapi_state->gssapi_context, 
823                                       &input_token,
824                                       &output_token, 
825                                       &conf_state,
826                                       &qop_state);
827                 if (GSS_ERROR(maj_stat)) {
828                         DEBUG(1, ("gensec_gssapi_update: GSS UnWrap of SASL protection negotiation failed: %s\n", 
829                                   gssapi_error_string(out_mem_ctx, maj_stat, min_stat, gensec_gssapi_state->gss_oid)));
830                         return NT_STATUS_ACCESS_DENIED;
831                 }
832                         
833                 if (output_token.length < 4) {
834                         return NT_STATUS_INVALID_PARAMETER;
835                 }
836
837                 memcpy(maxlength_accepted, output_token.value, 4);
838                 gss_release_buffer(&min_stat, &output_token);
839                 
840                 /* first byte is the proposed security */
841                 security_accepted = maxlength_accepted[0];
842                 maxlength_accepted[0] = '\0';
843
844                 /* Rest is the proposed max wrap length */
845                 gensec_gssapi_state->max_wrap_buf_size = MIN(RIVAL(maxlength_accepted, 0), 
846                                                              gensec_gssapi_state->max_wrap_buf_size);
847
848                 gensec_gssapi_state->sasl_protection = 0;
849                 if (security_accepted & NEG_SEAL) {
850                         if (!gensec_have_feature(gensec_security, GENSEC_FEATURE_SEAL)) {
851                                 DEBUG(1, ("Remote client wanted seal, but gensec refused\n"));
852                                 return NT_STATUS_ACCESS_DENIED;
853                         }
854                         gensec_gssapi_state->sasl_protection |= NEG_SEAL;
855                 }
856                 if (security_accepted & NEG_SIGN) {
857                         if (!gensec_have_feature(gensec_security, GENSEC_FEATURE_SIGN)) {
858                                 DEBUG(1, ("Remote client wanted sign, but gensec refused\n"));
859                                 return NT_STATUS_ACCESS_DENIED;
860                         }
861                         gensec_gssapi_state->sasl_protection |= NEG_SIGN;
862                 }
863                 if (security_accepted & NEG_NONE) {
864                         gensec_gssapi_state->sasl_protection |= NEG_NONE;
865                 }
866
867                 /* quirk:  This changes the value that gensec_have_feature returns, to be that after SASL negotiation */
868                 gensec_gssapi_state->sasl_state = STAGE_DONE;
869                 if (gensec_have_feature(gensec_security, GENSEC_FEATURE_SEAL)) {
870                         DEBUG(5, ("SASL/GSSAPI Connection from client will be cryptographically sealed\n"));
871                 } else if (gensec_have_feature(gensec_security, GENSEC_FEATURE_SIGN)) {
872                         DEBUG(5, ("SASL/GSSAPI Connection from client will be cryptographically signed\n"));
873                 } else {
874                         DEBUG(5, ("SASL/GSSAPI Connection from client will have no cryptographic protection\n"));
875                 }
876
877                 *out = data_blob(NULL, 0);
878                 return NT_STATUS_OK;    
879         }
880         default:
881                 return NT_STATUS_INVALID_PARAMETER;
882         }
883 }
884
885 static NTSTATUS gensec_gssapi_wrap(struct gensec_security *gensec_security, 
886                                    TALLOC_CTX *mem_ctx, 
887                                    const DATA_BLOB *in, 
888                                    DATA_BLOB *out)
889 {
890         struct gensec_gssapi_state *gensec_gssapi_state
891                 = talloc_get_type(gensec_security->private_data, struct gensec_gssapi_state);
892         OM_uint32 maj_stat, min_stat;
893         gss_buffer_desc input_token, output_token;
894         int conf_state;
895         input_token.length = in->length;
896         input_token.value = in->data;
897
898         maj_stat = gss_wrap(&min_stat, 
899                             gensec_gssapi_state->gssapi_context, 
900                             gensec_have_feature(gensec_security, GENSEC_FEATURE_SEAL),
901                             GSS_C_QOP_DEFAULT,
902                             &input_token,
903                             &conf_state,
904                             &output_token);
905         if (GSS_ERROR(maj_stat)) {
906                 DEBUG(1, ("gensec_gssapi_wrap: GSS Wrap failed: %s\n", 
907                           gssapi_error_string(mem_ctx, maj_stat, min_stat, gensec_gssapi_state->gss_oid)));
908                 return NT_STATUS_ACCESS_DENIED;
909         }
910
911         *out = data_blob_talloc(mem_ctx, output_token.value, output_token.length);
912         gss_release_buffer(&min_stat, &output_token);
913
914         if (gensec_gssapi_state->sasl) {
915                 size_t max_wrapped_size = gensec_gssapi_max_wrapped_size(gensec_security);
916                 if (max_wrapped_size < out->length) {
917                         DEBUG(1, ("gensec_gssapi_wrap: when wrapped, INPUT data (%u) is grew to be larger than SASL negotiated maximum output size (%u > %u)\n",
918                                   (unsigned)in->length, 
919                                   (unsigned)out->length, 
920                                   (unsigned int)max_wrapped_size));
921                         return NT_STATUS_INVALID_PARAMETER;
922                 }
923         }
924         
925         if (gensec_have_feature(gensec_security, GENSEC_FEATURE_SEAL)
926             && !conf_state) {
927                 return NT_STATUS_ACCESS_DENIED;
928         }
929         return NT_STATUS_OK;
930 }
931
932 static NTSTATUS gensec_gssapi_unwrap(struct gensec_security *gensec_security, 
933                                      TALLOC_CTX *mem_ctx, 
934                                      const DATA_BLOB *in, 
935                                      DATA_BLOB *out)
936 {
937         struct gensec_gssapi_state *gensec_gssapi_state
938                 = talloc_get_type(gensec_security->private_data, struct gensec_gssapi_state);
939         OM_uint32 maj_stat, min_stat;
940         gss_buffer_desc input_token, output_token;
941         int conf_state;
942         gss_qop_t qop_state;
943         input_token.length = in->length;
944         input_token.value = in->data;
945         
946         if (gensec_gssapi_state->sasl) {
947                 size_t max_wrapped_size = gensec_gssapi_max_wrapped_size(gensec_security);
948                 if (max_wrapped_size < in->length) {
949                         DEBUG(1, ("gensec_gssapi_unwrap: WRAPPED data is larger than SASL negotiated maximum size\n"));
950                         return NT_STATUS_INVALID_PARAMETER;
951                 }
952         }
953         
954         maj_stat = gss_unwrap(&min_stat, 
955                               gensec_gssapi_state->gssapi_context, 
956                               &input_token,
957                               &output_token, 
958                               &conf_state,
959                               &qop_state);
960         if (GSS_ERROR(maj_stat)) {
961                 DEBUG(1, ("gensec_gssapi_unwrap: GSS UnWrap failed: %s\n", 
962                           gssapi_error_string(mem_ctx, maj_stat, min_stat, gensec_gssapi_state->gss_oid)));
963                 return NT_STATUS_ACCESS_DENIED;
964         }
965
966         *out = data_blob_talloc(mem_ctx, output_token.value, output_token.length);
967         gss_release_buffer(&min_stat, &output_token);
968         
969         if (gensec_have_feature(gensec_security, GENSEC_FEATURE_SEAL)
970             && !conf_state) {
971                 return NT_STATUS_ACCESS_DENIED;
972         }
973         return NT_STATUS_OK;
974 }
975
976 /* Find out the maximum input size negotiated on this connection */
977
978 static size_t gensec_gssapi_max_input_size(struct gensec_security *gensec_security) 
979 {
980         struct gensec_gssapi_state *gensec_gssapi_state
981                 = talloc_get_type(gensec_security->private_data, struct gensec_gssapi_state);
982         OM_uint32 maj_stat, min_stat;
983         OM_uint32 max_input_size;
984
985         maj_stat = gss_wrap_size_limit(&min_stat, 
986                                        gensec_gssapi_state->gssapi_context,
987                                        gensec_have_feature(gensec_security, GENSEC_FEATURE_SEAL),
988                                        GSS_C_QOP_DEFAULT,
989                                        gensec_gssapi_state->max_wrap_buf_size,
990                                        &max_input_size);
991         if (GSS_ERROR(maj_stat)) {
992                 TALLOC_CTX *mem_ctx = talloc_new(NULL); 
993                 DEBUG(1, ("gensec_gssapi_max_input_size: determinaing signature size with gss_wrap_size_limit failed: %s\n", 
994                           gssapi_error_string(mem_ctx, maj_stat, min_stat, gensec_gssapi_state->gss_oid)));
995                 talloc_free(mem_ctx);
996                 return 0;
997         }
998
999         return max_input_size;
1000 }
1001
1002 /* Find out the maximum output size negotiated on this connection */
1003 static size_t gensec_gssapi_max_wrapped_size(struct gensec_security *gensec_security) 
1004 {
1005         struct gensec_gssapi_state *gensec_gssapi_state = talloc_get_type(gensec_security->private_data, struct gensec_gssapi_state);;
1006         return gensec_gssapi_state->max_wrap_buf_size;
1007 }
1008
1009 static NTSTATUS gensec_gssapi_seal_packet(struct gensec_security *gensec_security, 
1010                                           TALLOC_CTX *mem_ctx, 
1011                                           uint8_t *data, size_t length, 
1012                                           const uint8_t *whole_pdu, size_t pdu_length, 
1013                                           DATA_BLOB *sig)
1014 {
1015         struct gensec_gssapi_state *gensec_gssapi_state
1016                 = talloc_get_type(gensec_security->private_data, struct gensec_gssapi_state);
1017         OM_uint32 maj_stat, min_stat;
1018         gss_buffer_desc input_token, output_token;
1019         int conf_state;
1020         ssize_t sig_length;
1021
1022         input_token.length = length;
1023         input_token.value = data;
1024         
1025         maj_stat = gss_wrap(&min_stat, 
1026                             gensec_gssapi_state->gssapi_context,
1027                             gensec_have_feature(gensec_security, GENSEC_FEATURE_SEAL),
1028                             GSS_C_QOP_DEFAULT,
1029                             &input_token,
1030                             &conf_state,
1031                             &output_token);
1032         if (GSS_ERROR(maj_stat)) {
1033                 DEBUG(1, ("gensec_gssapi_seal_packet: GSS Wrap failed: %s\n", 
1034                           gssapi_error_string(mem_ctx, maj_stat, min_stat, gensec_gssapi_state->gss_oid)));
1035                 return NT_STATUS_ACCESS_DENIED;
1036         }
1037
1038         if (output_token.length < input_token.length) {
1039                 DEBUG(1, ("gensec_gssapi_seal_packet: GSS Wrap length [%ld] *less* than caller length [%ld]\n", 
1040                           (long)output_token.length, (long)length));
1041                 return NT_STATUS_INTERNAL_ERROR;
1042         }
1043         sig_length = output_token.length - input_token.length;
1044
1045         memcpy(data, ((uint8_t *)output_token.value) + sig_length, length);
1046         *sig = data_blob_talloc(mem_ctx, (uint8_t *)output_token.value, sig_length);
1047
1048         dump_data_pw("gensec_gssapi_seal_packet: sig\n", sig->data, sig->length);
1049         dump_data_pw("gensec_gssapi_seal_packet: clear\n", data, length);
1050         dump_data_pw("gensec_gssapi_seal_packet: sealed\n", ((uint8_t *)output_token.value) + sig_length, output_token.length - sig_length);
1051
1052         gss_release_buffer(&min_stat, &output_token);
1053
1054         if (gensec_have_feature(gensec_security, GENSEC_FEATURE_SEAL)
1055             && !conf_state) {
1056                 return NT_STATUS_ACCESS_DENIED;
1057         }
1058         return NT_STATUS_OK;
1059 }
1060
1061 static NTSTATUS gensec_gssapi_unseal_packet(struct gensec_security *gensec_security, 
1062                                             uint8_t *data, size_t length, 
1063                                             const uint8_t *whole_pdu, size_t pdu_length,
1064                                             const DATA_BLOB *sig)
1065 {
1066         struct gensec_gssapi_state *gensec_gssapi_state
1067                 = talloc_get_type(gensec_security->private_data, struct gensec_gssapi_state);
1068         OM_uint32 maj_stat, min_stat;
1069         gss_buffer_desc input_token, output_token;
1070         int conf_state;
1071         gss_qop_t qop_state;
1072         DATA_BLOB in;
1073
1074         dump_data_pw("gensec_gssapi_unseal_packet: sig\n", sig->data, sig->length);
1075
1076         in = data_blob_talloc(gensec_security, NULL, sig->length + length);
1077
1078         memcpy(in.data, sig->data, sig->length);
1079         memcpy(in.data + sig->length, data, length);
1080
1081         input_token.length = in.length;
1082         input_token.value = in.data;
1083         
1084         maj_stat = gss_unwrap(&min_stat, 
1085                               gensec_gssapi_state->gssapi_context, 
1086                               &input_token,
1087                               &output_token, 
1088                               &conf_state,
1089                               &qop_state);
1090         talloc_free(in.data);
1091         if (GSS_ERROR(maj_stat)) {
1092                 char *error_string = gssapi_error_string(NULL, maj_stat, min_stat, gensec_gssapi_state->gss_oid);
1093                 DEBUG(1, ("gensec_gssapi_unseal_packet: GSS UnWrap failed: %s\n", 
1094                           error_string));
1095                 talloc_free(error_string);
1096                 return NT_STATUS_ACCESS_DENIED;
1097         }
1098
1099         if (output_token.length != length) {
1100                 return NT_STATUS_INTERNAL_ERROR;
1101         }
1102
1103         memcpy(data, output_token.value, length);
1104
1105         gss_release_buffer(&min_stat, &output_token);
1106         
1107         if (gensec_have_feature(gensec_security, GENSEC_FEATURE_SEAL)
1108             && !conf_state) {
1109                 return NT_STATUS_ACCESS_DENIED;
1110         }
1111         return NT_STATUS_OK;
1112 }
1113
1114 static NTSTATUS gensec_gssapi_sign_packet(struct gensec_security *gensec_security, 
1115                                           TALLOC_CTX *mem_ctx, 
1116                                           const uint8_t *data, size_t length, 
1117                                           const uint8_t *whole_pdu, size_t pdu_length, 
1118                                           DATA_BLOB *sig)
1119 {
1120         struct gensec_gssapi_state *gensec_gssapi_state
1121                 = talloc_get_type(gensec_security->private_data, struct gensec_gssapi_state);
1122         OM_uint32 maj_stat, min_stat;
1123         gss_buffer_desc input_token, output_token;
1124
1125         if (gensec_security->want_features & GENSEC_FEATURE_SIGN_PKT_HEADER) {
1126                 input_token.length = pdu_length;
1127                 input_token.value = discard_const_p(uint8_t *, whole_pdu);
1128         } else {
1129                 input_token.length = length;
1130                 input_token.value = discard_const_p(uint8_t *, data);
1131         }
1132
1133         maj_stat = gss_get_mic(&min_stat,
1134                             gensec_gssapi_state->gssapi_context,
1135                             GSS_C_QOP_DEFAULT,
1136                             &input_token,
1137                             &output_token);
1138         if (GSS_ERROR(maj_stat)) {
1139                 DEBUG(1, ("GSS GetMic failed: %s\n",
1140                           gssapi_error_string(mem_ctx, maj_stat, min_stat, gensec_gssapi_state->gss_oid)));
1141                 return NT_STATUS_ACCESS_DENIED;
1142         }
1143
1144         *sig = data_blob_talloc(mem_ctx, (uint8_t *)output_token.value, output_token.length);
1145
1146         dump_data_pw("gensec_gssapi_seal_packet: sig\n", sig->data, sig->length);
1147
1148         gss_release_buffer(&min_stat, &output_token);
1149
1150         return NT_STATUS_OK;
1151 }
1152
1153 static NTSTATUS gensec_gssapi_check_packet(struct gensec_security *gensec_security, 
1154                                            const uint8_t *data, size_t length, 
1155                                            const uint8_t *whole_pdu, size_t pdu_length, 
1156                                            const DATA_BLOB *sig)
1157 {
1158         struct gensec_gssapi_state *gensec_gssapi_state
1159                 = talloc_get_type(gensec_security->private_data, struct gensec_gssapi_state);
1160         OM_uint32 maj_stat, min_stat;
1161         gss_buffer_desc input_token;
1162         gss_buffer_desc input_message;
1163         gss_qop_t qop_state;
1164
1165         dump_data_pw("gensec_gssapi_seal_packet: sig\n", sig->data, sig->length);
1166
1167         if (gensec_security->want_features & GENSEC_FEATURE_SIGN_PKT_HEADER) {
1168                 input_message.length = pdu_length;
1169                 input_message.value = discard_const(whole_pdu);
1170         } else {
1171                 input_message.length = length;
1172                 input_message.value = discard_const(data);
1173         }
1174
1175         input_token.length = sig->length;
1176         input_token.value = sig->data;
1177
1178         maj_stat = gss_verify_mic(&min_stat,
1179                               gensec_gssapi_state->gssapi_context, 
1180                               &input_message,
1181                               &input_token,
1182                               &qop_state);
1183         if (GSS_ERROR(maj_stat)) {
1184                 char *error_string = gssapi_error_string(NULL, maj_stat, min_stat, gensec_gssapi_state->gss_oid);
1185                 DEBUG(1, ("GSS VerifyMic failed: %s\n", error_string));
1186                 talloc_free(error_string);
1187
1188                 return NT_STATUS_ACCESS_DENIED;
1189         }
1190
1191         return NT_STATUS_OK;
1192 }
1193
1194 /* Try to figure out what features we actually got on the connection */
1195 static bool gensec_gssapi_have_feature(struct gensec_security *gensec_security, 
1196                                        uint32_t feature) 
1197 {
1198         struct gensec_gssapi_state *gensec_gssapi_state
1199                 = talloc_get_type(gensec_security->private_data, struct gensec_gssapi_state);
1200         if (feature & GENSEC_FEATURE_SIGN) {
1201                 /* If we are going GSSAPI SASL, then we honour the second negotiation */
1202                 if (gensec_gssapi_state->sasl 
1203                     && gensec_gssapi_state->sasl_state == STAGE_DONE) {
1204                         return ((gensec_gssapi_state->sasl_protection & NEG_SIGN) 
1205                                 && (gensec_gssapi_state->gss_got_flags & GSS_C_INTEG_FLAG));
1206                 }
1207                 return gensec_gssapi_state->gss_got_flags & GSS_C_INTEG_FLAG;
1208         }
1209         if (feature & GENSEC_FEATURE_SEAL) {
1210                 /* If we are going GSSAPI SASL, then we honour the second negotiation */
1211                 if (gensec_gssapi_state->sasl 
1212                     && gensec_gssapi_state->sasl_state == STAGE_DONE) {
1213                         return ((gensec_gssapi_state->sasl_protection & NEG_SEAL) 
1214                                  && (gensec_gssapi_state->gss_got_flags & GSS_C_CONF_FLAG));
1215                 }
1216                 return gensec_gssapi_state->gss_got_flags & GSS_C_CONF_FLAG;
1217         }
1218         if (feature & GENSEC_FEATURE_SESSION_KEY) {
1219                 /* Only for GSSAPI/Krb5 */
1220                 if (gss_oid_equal(gensec_gssapi_state->gss_oid, gss_mech_krb5)) {
1221                         return true;
1222                 }
1223         }
1224         if (feature & GENSEC_FEATURE_DCE_STYLE) {
1225                 return gensec_gssapi_state->gss_got_flags & GSS_C_DCE_STYLE;
1226         }
1227         if (feature & GENSEC_FEATURE_NEW_SPNEGO) {
1228                 NTSTATUS status;
1229                 uint32_t keytype;
1230
1231                 if (!(gensec_gssapi_state->gss_got_flags & GSS_C_INTEG_FLAG)) {
1232                         return false;
1233                 }
1234
1235                 if (gensec_setting_bool(gensec_security->settings, "gensec_gssapi", "force_new_spnego", false)) {
1236                         return true;
1237                 }
1238                 if (gensec_setting_bool(gensec_security->settings, "gensec_gssapi", "disable_new_spnego", false)) {
1239                         return false;
1240                 }
1241
1242                 status = gssapi_get_session_key(gensec_gssapi_state,
1243                                                 gensec_gssapi_state->gssapi_context, NULL, &keytype);
1244                 /* 
1245                  * We should do a proper sig on the mechListMic unless
1246                  * we know we have to be backwards compatible with
1247                  * earlier windows versions.  
1248                  * 
1249                  * Negotiating a non-krb5
1250                  * mech for example should be regarded as having
1251                  * NEW_SPNEGO
1252                  */
1253                 if (NT_STATUS_IS_OK(status)) {
1254                         switch (keytype) {
1255                         case ENCTYPE_DES_CBC_CRC:
1256                         case ENCTYPE_DES_CBC_MD5:
1257                         case ENCTYPE_ARCFOUR_HMAC:
1258                         case ENCTYPE_DES3_CBC_SHA1:
1259                                 return false;
1260                         }
1261                 }
1262                 return true;
1263         }
1264         /* We can always do async (rather than strict request/reply) packets.  */
1265         if (feature & GENSEC_FEATURE_ASYNC_REPLIES) {
1266                 return true;
1267         }
1268         return false;
1269 }
1270
1271 static NTTIME gensec_gssapi_expire_time(struct gensec_security *gensec_security)
1272 {
1273         struct gensec_gssapi_state *gensec_gssapi_state =
1274                 talloc_get_type_abort(gensec_security->private_data,
1275                 struct gensec_gssapi_state);
1276
1277         return gensec_gssapi_state->expire_time;
1278 }
1279
1280 /*
1281  * Extract the 'sesssion key' needed by SMB signing and ncacn_np 
1282  * (for encrypting some passwords).
1283  * 
1284  * This breaks all the abstractions, but what do you expect...
1285  */
1286 static NTSTATUS gensec_gssapi_session_key(struct gensec_security *gensec_security, 
1287                                           TALLOC_CTX *mem_ctx,
1288                                           DATA_BLOB *session_key) 
1289 {
1290         struct gensec_gssapi_state *gensec_gssapi_state
1291                 = talloc_get_type(gensec_security->private_data, struct gensec_gssapi_state);
1292         return gssapi_get_session_key(mem_ctx, gensec_gssapi_state->gssapi_context, session_key, NULL);
1293 }
1294
1295 /* Get some basic (and authorization) information about the user on
1296  * this session.  This uses either the PAC (if present) or a local
1297  * database lookup */
1298 static NTSTATUS gensec_gssapi_session_info(struct gensec_security *gensec_security,
1299                                            TALLOC_CTX *mem_ctx,
1300                                            struct auth_session_info **_session_info) 
1301 {
1302         NTSTATUS nt_status;
1303         TALLOC_CTX *tmp_ctx;
1304         struct gensec_gssapi_state *gensec_gssapi_state
1305                 = talloc_get_type(gensec_security->private_data, struct gensec_gssapi_state);
1306         struct auth_session_info *session_info = NULL;
1307         OM_uint32 maj_stat, min_stat;
1308         DATA_BLOB pac_blob, *pac_blob_ptr = NULL;
1309
1310         gss_buffer_desc name_token;
1311         char *principal_string;
1312         
1313         tmp_ctx = talloc_named(mem_ctx, 0, "gensec_gssapi_session_info context");
1314         NT_STATUS_HAVE_NO_MEMORY(tmp_ctx);
1315
1316         maj_stat = gss_display_name (&min_stat,
1317                                      gensec_gssapi_state->client_name,
1318                                      &name_token,
1319                                      NULL);
1320         if (GSS_ERROR(maj_stat)) {
1321                 DEBUG(1, ("GSS display_name failed: %s\n",
1322                           gssapi_error_string(tmp_ctx, maj_stat, min_stat, gensec_gssapi_state->gss_oid)));
1323                 talloc_free(tmp_ctx);
1324                 return NT_STATUS_FOOBAR;
1325         }
1326
1327         principal_string = talloc_strndup(tmp_ctx,
1328                                           (const char *)name_token.value,
1329                                           name_token.length);
1330
1331         gss_release_buffer(&min_stat, &name_token);
1332
1333         if (!principal_string) {
1334                 talloc_free(tmp_ctx);
1335                 return NT_STATUS_NO_MEMORY;
1336         }
1337
1338         nt_status = gssapi_obtain_pac_blob(tmp_ctx,  gensec_gssapi_state->gssapi_context,
1339                                            gensec_gssapi_state->client_name,
1340                                            &pac_blob);
1341         
1342         /* IF we have the PAC - otherwise we need to get this
1343          * data from elsewere - local ldb, or (TODO) lookup of some
1344          * kind... 
1345          */
1346         if (NT_STATUS_IS_OK(nt_status)) {
1347                 pac_blob_ptr = &pac_blob;
1348         }
1349         nt_status = gensec_generate_session_info_pac(tmp_ctx,
1350                                                      gensec_security,
1351                                                      gensec_gssapi_state->smb_krb5_context,
1352                                                      pac_blob_ptr, principal_string,
1353                                                      gensec_get_remote_address(gensec_security),
1354                                                      &session_info);
1355         if (!NT_STATUS_IS_OK(nt_status)) {
1356                 talloc_free(tmp_ctx);
1357                 return nt_status;
1358         }
1359
1360         nt_status = gensec_gssapi_session_key(gensec_security, session_info, &session_info->session_key);
1361         if (!NT_STATUS_IS_OK(nt_status)) {
1362                 talloc_free(tmp_ctx);
1363                 return nt_status;
1364         }
1365
1366         if (!(gensec_gssapi_state->gss_got_flags & GSS_C_DELEG_FLAG)) {
1367                 DEBUG(10, ("gensec_gssapi: NO delegated credentials supplied by client\n"));
1368         } else {
1369                 krb5_error_code ret;
1370                 const char *error_string;
1371
1372                 DEBUG(10, ("gensec_gssapi: delegated credentials supplied by client\n"));
1373                 session_info->credentials = cli_credentials_init(session_info);
1374                 if (!session_info->credentials) {
1375                         talloc_free(tmp_ctx);
1376                         return NT_STATUS_NO_MEMORY;
1377                 }
1378
1379                 cli_credentials_set_conf(session_info->credentials, gensec_security->settings->lp_ctx);
1380                 /* Just so we don't segfault trying to get at a username */
1381                 cli_credentials_set_anonymous(session_info->credentials);
1382                 
1383                 ret = cli_credentials_set_client_gss_creds(session_info->credentials, 
1384                                                            gensec_security->settings->lp_ctx,
1385                                                            gensec_gssapi_state->delegated_cred_handle,
1386                                                            CRED_SPECIFIED, &error_string);
1387                 if (ret) {
1388                         talloc_free(tmp_ctx);
1389                         DEBUG(2,("Failed to get gss creds: %s\n", error_string));
1390                         return NT_STATUS_NO_MEMORY;
1391                 }
1392                 
1393                 /* This credential handle isn't useful for password authentication, so ensure nobody tries to do that */
1394                 cli_credentials_set_kerberos_state(session_info->credentials, CRED_MUST_USE_KERBEROS);
1395
1396                 /* It has been taken from this place... */
1397                 gensec_gssapi_state->delegated_cred_handle = GSS_C_NO_CREDENTIAL;
1398         }
1399         *_session_info = talloc_steal(mem_ctx, session_info);
1400         talloc_free(tmp_ctx);
1401
1402         return NT_STATUS_OK;
1403 }
1404
1405 static size_t gensec_gssapi_sig_size(struct gensec_security *gensec_security, size_t data_size)
1406 {
1407         struct gensec_gssapi_state *gensec_gssapi_state
1408                 = talloc_get_type(gensec_security->private_data, struct gensec_gssapi_state);
1409         NTSTATUS status;
1410
1411         if (gensec_gssapi_state->sig_size) {
1412                 return gensec_gssapi_state->sig_size;
1413         }
1414
1415         if (gensec_gssapi_state->gss_got_flags & GSS_C_CONF_FLAG) {
1416                 gensec_gssapi_state->sig_size = 45;
1417         } else {
1418                 gensec_gssapi_state->sig_size = 37;
1419         }
1420
1421         status = gensec_gssapi_init_lucid(gensec_gssapi_state);
1422         if (!NT_STATUS_IS_OK(status)) {
1423                 return gensec_gssapi_state->sig_size;
1424         }
1425
1426         if (gensec_gssapi_state->lucid->protocol == 1) {
1427                 if (gensec_gssapi_state->gss_got_flags & GSS_C_CONF_FLAG) {
1428                         /*
1429                          * TODO: windows uses 76 here, but we don't know
1430                          *       gss_wrap works with aes keys yet
1431                          */
1432                         gensec_gssapi_state->sig_size = 76;
1433                 } else {
1434                         gensec_gssapi_state->sig_size = 28;
1435                 }
1436         } else if (gensec_gssapi_state->lucid->protocol == 0) {
1437                 switch (gensec_gssapi_state->lucid->rfc1964_kd.ctx_key.type) {
1438                 case KEYTYPE_DES:
1439                 case KEYTYPE_ARCFOUR:
1440                 case KEYTYPE_ARCFOUR_56:
1441                         if (gensec_gssapi_state->gss_got_flags & GSS_C_CONF_FLAG) {
1442                                 gensec_gssapi_state->sig_size = 45;
1443                         } else {
1444                                 gensec_gssapi_state->sig_size = 37;
1445                         }
1446                         break;
1447                 case KEYTYPE_DES3:
1448                         if (gensec_gssapi_state->gss_got_flags & GSS_C_CONF_FLAG) {
1449                                 gensec_gssapi_state->sig_size = 57;
1450                         } else {
1451                                 gensec_gssapi_state->sig_size = 49;
1452                         }
1453                         break;
1454                 }
1455         }
1456
1457         return gensec_gssapi_state->sig_size;
1458 }
1459
1460 static const char *gensec_gssapi_krb5_oids[] = { 
1461         GENSEC_OID_KERBEROS5_OLD,
1462         GENSEC_OID_KERBEROS5,
1463         NULL 
1464 };
1465
1466 static const char *gensec_gssapi_spnego_oids[] = { 
1467         GENSEC_OID_SPNEGO,
1468         NULL 
1469 };
1470
1471 /* As a server, this could in theory accept any GSSAPI mech */
1472 static const struct gensec_security_ops gensec_gssapi_spnego_security_ops = {
1473         .name           = "gssapi_spnego",
1474         .sasl_name      = "GSS-SPNEGO",
1475         .auth_type      = DCERPC_AUTH_TYPE_SPNEGO,
1476         .oid            = gensec_gssapi_spnego_oids,
1477         .client_start   = gensec_gssapi_client_start,
1478         .server_start   = gensec_gssapi_server_start,
1479         .magic          = gensec_magic_check_krb5_oid,
1480         .update         = gensec_gssapi_update,
1481         .session_key    = gensec_gssapi_session_key,
1482         .session_info   = gensec_gssapi_session_info,
1483         .sign_packet    = gensec_gssapi_sign_packet,
1484         .check_packet   = gensec_gssapi_check_packet,
1485         .seal_packet    = gensec_gssapi_seal_packet,
1486         .unseal_packet  = gensec_gssapi_unseal_packet,
1487         .wrap           = gensec_gssapi_wrap,
1488         .unwrap         = gensec_gssapi_unwrap,
1489         .have_feature   = gensec_gssapi_have_feature,
1490         .expire_time    = gensec_gssapi_expire_time,
1491         .enabled        = false,
1492         .kerberos       = true,
1493         .priority       = GENSEC_GSSAPI
1494 };
1495
1496 /* As a server, this could in theory accept any GSSAPI mech */
1497 static const struct gensec_security_ops gensec_gssapi_krb5_security_ops = {
1498         .name           = "gssapi_krb5",
1499         .auth_type      = DCERPC_AUTH_TYPE_KRB5,
1500         .oid            = gensec_gssapi_krb5_oids,
1501         .client_start   = gensec_gssapi_client_start,
1502         .server_start   = gensec_gssapi_server_start,
1503         .magic          = gensec_magic_check_krb5_oid,
1504         .update         = gensec_gssapi_update,
1505         .session_key    = gensec_gssapi_session_key,
1506         .session_info   = gensec_gssapi_session_info,
1507         .sig_size       = gensec_gssapi_sig_size,
1508         .sign_packet    = gensec_gssapi_sign_packet,
1509         .check_packet   = gensec_gssapi_check_packet,
1510         .seal_packet    = gensec_gssapi_seal_packet,
1511         .unseal_packet  = gensec_gssapi_unseal_packet,
1512         .wrap           = gensec_gssapi_wrap,
1513         .unwrap         = gensec_gssapi_unwrap,
1514         .have_feature   = gensec_gssapi_have_feature,
1515         .expire_time    = gensec_gssapi_expire_time,
1516         .enabled        = true,
1517         .kerberos       = true,
1518         .priority       = GENSEC_GSSAPI
1519 };
1520
1521 /* As a server, this could in theory accept any GSSAPI mech */
1522 static const struct gensec_security_ops gensec_gssapi_sasl_krb5_security_ops = {
1523         .name             = "gssapi_krb5_sasl",
1524         .sasl_name        = "GSSAPI",
1525         .client_start     = gensec_gssapi_sasl_client_start,
1526         .server_start     = gensec_gssapi_sasl_server_start,
1527         .update           = gensec_gssapi_update,
1528         .session_key      = gensec_gssapi_session_key,
1529         .session_info     = gensec_gssapi_session_info,
1530         .max_input_size   = gensec_gssapi_max_input_size,
1531         .max_wrapped_size = gensec_gssapi_max_wrapped_size,
1532         .wrap             = gensec_gssapi_wrap,
1533         .unwrap           = gensec_gssapi_unwrap,
1534         .have_feature     = gensec_gssapi_have_feature,
1535         .expire_time      = gensec_gssapi_expire_time,
1536         .enabled          = true,
1537         .kerberos         = true,
1538         .priority         = GENSEC_GSSAPI
1539 };
1540
1541 _PUBLIC_ NTSTATUS gensec_gssapi_init(void)
1542 {
1543         NTSTATUS ret;
1544
1545         ret = gensec_register(&gensec_gssapi_spnego_security_ops);
1546         if (!NT_STATUS_IS_OK(ret)) {
1547                 DEBUG(0,("Failed to register '%s' gensec backend!\n",
1548                         gensec_gssapi_spnego_security_ops.name));
1549                 return ret;
1550         }
1551
1552         ret = gensec_register(&gensec_gssapi_krb5_security_ops);
1553         if (!NT_STATUS_IS_OK(ret)) {
1554                 DEBUG(0,("Failed to register '%s' gensec backend!\n",
1555                         gensec_gssapi_krb5_security_ops.name));
1556                 return ret;
1557         }
1558
1559         ret = gensec_register(&gensec_gssapi_sasl_krb5_security_ops);
1560         if (!NT_STATUS_IS_OK(ret)) {
1561                 DEBUG(0,("Failed to register '%s' gensec backend!\n",
1562                         gensec_gssapi_sasl_krb5_security_ops.name));
1563                 return ret;
1564         }
1565
1566         return ret;
1567 }