lib/common.c

   1 /* common.c - Functions that are common to server and clinet
   2  * Rob Siemborski
   3  * Tim Martin
   4  * $Id: common.c,v 1.114 2006/04/19 18:39:59 mel Exp $
   5  */
   6 /*
   7  * Copyright (c) 1998-2003 Carnegie Mellon University.  All rights reserved.
   8  *
   9  * Redistribution and use in source and binary forms, with or without
  10  * modification, are permitted provided that the following conditions
  11  * are met:
  12  *
  13  * 1. Redistributions of source code must retain the above copyright
  14  *    notice, this list of conditions and the following disclaimer.
  15  *
  16  * 2. Redistributions in binary form must reproduce the above copyright
  17  *    notice, this list of conditions and the following disclaimer in
  18  *    the documentation and/or other materials provided with the
  19  *    distribution.
  20  *
  21  * 3. The name "Carnegie Mellon University" must not be used to
  22  *    endorse or promote products derived from this software without
  23  *    prior written permission. For permission or any other legal
  24  *    details, please contact
  25  *      Office of Technology Transfer
  26  *      Carnegie Mellon University
  27  *      5000 Forbes Avenue
  28  *      Pittsburgh, PA  15213-3890
  29  *      (412) 268-4387, fax: (412) 268-7395
  30  *      tech-transfer@andrew.cmu.edu
  31  *
  32  * 4. Redistributions of any form whatsoever must retain the following
  33  *    acknowledgment:
  34  *    "This product includes software developed by Computing Services
  35  *     at Carnegie Mellon University (http://www.cmu.edu/computing/)."
  36  *
  37  * CARNEGIE MELLON UNIVERSITY DISCLAIMS ALL WARRANTIES WITH REGARD TO
  38  * THIS SOFTWARE, INCLUDING ALL IMPLIED WARRANTIES OF MERCHANTABILITY
  39  * AND FITNESS, IN NO EVENT SHALL CARNEGIE MELLON UNIVERSITY BE LIABLE
  40  * FOR ANY SPECIAL, INDIRECT OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
  41  * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN
  42  * AN ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING
  43  * OUT OF OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
  44  */
  45
  46 #include <config.h>
  47 #include <stdio.h>
  48 #include <string.h>
  49 #include <stdlib.h>
  50 #include <limits.h>
  51 #ifdef HAVE_SYSLOG
  52 #include <syslog.h>
  53 #endif
  54 #include <stdarg.h>
  55 #include <ctype.h>
  56 #include <assert.h>
  57
  58 #include <sasl.h>
  59 #include <saslutil.h>
  60 #include <saslplug.h>
  61 #include "saslint.h"
  62
  63 #ifdef HAVE_UNISTD_H
  64 #include <unistd.h>
  65 #endif
  66
  67 static const char *implementation_string = "Cyrus SASL";
  68
  69 #define VSTR0(maj, min, step)   #maj "." #min "." #step
  70 #define VSTR(maj, min, step)    VSTR0(maj, min, step)
  71 #define SASL_VERSION_STRING     VSTR(SASL_VERSION_MAJOR, SASL_VERSION_MINOR, \
  72                                 SASL_VERSION_STEP)
  73
  74 static int _sasl_getpath(void *context __attribute__((unused)), const char **path);
  75 static int _sasl_getpath_simple(void *context __attribute__((unused)), const char **path);
  76 static int _sasl_getconfpath(void *context __attribute__((unused)), char ** path);
  77 static int _sasl_getconfpath_simple(void *context __attribute__((unused)), const char **path);
  78
  79 #if !defined(WIN32)
  80 static char * _sasl_get_default_unix_path(void *context __attribute__((unused)),
  81                             char * env_var_name, char * default_value);
  82 #else
  83 /* NB: Always returned allocated value */
  84 static char * _sasl_get_default_win_path(void *context __attribute__((unused)),
  85                             char * reg_attr_name, char * default_value);
  86 #endif
  87
  88
  89 static const char build_ident[] = "$Build: libsasl " PACKAGE "-" VERSION " $";
  90
  91 /* It turns out to be convenient to have a shared sasl_utils_t */
  92 LIBSASL_VAR const sasl_utils_t *sasl_global_utils = NULL;
  93
  94 /* Should be a null-terminated array that lists the available mechanisms */
  95 static char **global_mech_list = NULL;
  96
  97 void *free_mutex = NULL;
  98
  99 int (*_sasl_client_cleanup_hook)(void) = NULL;
 100 int (*_sasl_server_cleanup_hook)(void) = NULL;
 101 int (*_sasl_client_idle_hook)(sasl_conn_t *conn) = NULL;
 102 int (*_sasl_server_idle_hook)(sasl_conn_t *conn) = NULL;
 103
 104 sasl_allocation_utils_t _sasl_allocation_utils={
 105   (sasl_malloc_t *)  &malloc,
 106   (sasl_calloc_t *)  &calloc,
 107   (sasl_realloc_t *) &realloc,
 108   (sasl_free_t *) &free
 109 };
 110
 111 #define SASL_ENCODEV_EXTRA  4096
 112
 113 /* Default getpath/getconfpath callbacks. These can be edited by sasl_set_path(). */
 114 static sasl_callback_t default_getpath_cb = {
 115     SASL_CB_GETPATH, &_sasl_getpath, NULL
 116 };
 117 static sasl_callback_t default_getconfpath_cb = {
 118     SASL_CB_GETCONFPATH, &_sasl_getconfpath, NULL
 119 };
 120
 121 static char * default_plugin_path = NULL;
 122 static char * default_conf_path = NULL;
 123
 124 /* Intenal mutex functions do as little as possible (no thread protection) */
 125 static void *sasl_mutex_alloc(void)
 126 {
 127   return (void *)0x1;
 128 }
 129
 130 static int sasl_mutex_lock(void *mutex __attribute__((unused)))
 131 {
 132     return SASL_OK;
 133 }
 134
 135 static int sasl_mutex_unlock(void *mutex __attribute__((unused)))
 136 {
 137     return SASL_OK;
 138 }
 139
 140 static void sasl_mutex_free(void *mutex __attribute__((unused)))
 141 {
 142     return;
 143 }
 144
 145 sasl_mutex_utils_t _sasl_mutex_utils={
 146   &sasl_mutex_alloc,
 147   &sasl_mutex_lock,
 148   &sasl_mutex_unlock,
 149   &sasl_mutex_free
 150 };
 151
 152 void sasl_set_mutex(sasl_mutex_alloc_t *n, sasl_mutex_lock_t *l,
 153                     sasl_mutex_unlock_t *u, sasl_mutex_free_t *d)
 154 {
 155   _sasl_mutex_utils.alloc=n;
 156   _sasl_mutex_utils.lock=l;
 157   _sasl_mutex_utils.unlock=u;
 158   _sasl_mutex_utils.free=d;
 159 }
 160
 161 /* copy a string to malloced memory */
 162 int _sasl_strdup(const char *in, char **out, size_t *outlen)
 163 {
 164   size_t len = strlen(in);
 165   if (outlen) *outlen = len;
 166   *out=sasl_ALLOC((unsigned) len + 1);
 167   if (! *out) return SASL_NOMEM;
 168   strcpy((char *) *out, in);
 169   return SASL_OK;
 170 }
 171
 172 /* adds a string to the buffer; reallocing if need be */
 173 int _sasl_add_string(char **out, size_t *alloclen,
 174                      size_t *outlen, const char *add)
 175 {
 176   size_t addlen;
 177
 178   if (add==NULL) add = "(null)";
 179
 180   addlen=strlen(add); /* only compute once */
 181   if (_buf_alloc(out, alloclen, (*outlen)+addlen)!=SASL_OK)
 182     return SASL_NOMEM;
 183
 184   strncpy(*out + *outlen, add, addlen);
 185   *outlen += addlen;
 186
 187   return SASL_OK;
 188 }
 189
 190 /* a simpler way to set plugin path or configuration file path
 191  * without the need to set sasl_getpath_t callback.
 192  *
 193  * This function can be called before sasl_server_init/sasl_client_init.
 194  *
 195  * Don't call this function without locking in a multithreaded application.
 196  */
 197 int sasl_set_path (int path_type, char * path)
 198 {
 199     int result;
 200
 201     if (path == NULL) {
 202         return (SASL_FAIL);
 203     }
 204
 205     switch (path_type) {
 206         case SASL_PATH_TYPE_PLUGIN:
 207             if (default_plugin_path != NULL) {
 208                 sasl_FREE (default_plugin_path);
 209                 default_plugin_path = NULL;
 210             }
 211             result = _sasl_strdup (path, &default_plugin_path, NULL);
 212             if (result != SASL_OK) {
 213                 return (result);
 214             }
 215
 216             /* Update the default getpath_t callback */
 217             default_getpath_cb.proc = (int (*)()) &_sasl_getpath_simple;
 218             break;
 219
 220         case SASL_PATH_TYPE_CONFIG:
 221             if (default_conf_path != NULL) {
 222                 sasl_FREE (default_conf_path);
 223                 default_conf_path = NULL;
 224             }
 225             result = _sasl_strdup (path, &default_conf_path, NULL);
 226             if (result != SASL_OK) {
 227                 return (result);
 228             }
 229
 230             /* Update the default getpath_t callback */
 231             default_getconfpath_cb.proc = (int (*)()) &_sasl_getconfpath_simple;
 232             break;
 233
 234         default:
 235             return (SASL_FAIL);
 236     }
 237
 238     return (SASL_OK);
 239 }
 240
 241 /* return the version of the cyrus sasl library as compiled,
 242  * using 32 bits: high byte is major version, second byte is minor version,
 243  * low 16 bits are step # */
 244 void sasl_version(const char **implementation, int *version)
 245 {
 246     if(implementation) *implementation = implementation_string;
 247     /* NB: the format is not the same as in SASL_VERSION_FULL */
 248     if(version) *version = (SASL_VERSION_MAJOR << 24) |
 249                            (SASL_VERSION_MINOR << 16) |
 250                            (SASL_VERSION_STEP);
 251 }
 252
 253 /* Extended version of sasl_version above */
 254 void sasl_version_info (const char **implementation, const char **version_string,
 255                     int *version_major, int *version_minor, int *version_step,
 256                     int *version_patch)
 257 {
 258     if (implementation) *implementation = implementation_string;
 259     if (version_string) *version_string = SASL_VERSION_STRING;
 260     if (version_major) *version_major = SASL_VERSION_MAJOR;
 261     if (version_minor) *version_minor = SASL_VERSION_MINOR;
 262     if (version_step) *version_step = SASL_VERSION_STEP;
 263     /* Version patch is always 0 for CMU SASL */
 264     if (version_patch) *version_patch = 0;
 265 }
 266
 267 /* security-encode a regular string.  Mostly a wrapper for sasl_encodev */
 268 /* output is only valid until next call to sasl_encode or sasl_encodev */
 269 int sasl_encode(sasl_conn_t *conn, const char *input,
 270                 unsigned inputlen,
 271                 const char **output, unsigned *outputlen)
 272 {
 273     int result;
 274     struct iovec tmp;
 275
 276     if(!conn) return SASL_BADPARAM;
 277     if(!input || !inputlen || !output || !outputlen)
 278         PARAMERROR(conn);
 279
 280     /* maxoutbuf checking is done in sasl_encodev */
 281
 282     /* Note: We are casting a const pointer here, but it's okay
 283      * because we believe people downstream of us are well-behaved, and the
 284      * alternative is an absolute mess, performance-wise. */
 285     tmp.iov_base = (void *)input;
 286     tmp.iov_len = inputlen;
 287
 288     result = sasl_encodev(conn, &tmp, 1, output, outputlen);
 289
 290     RETURN(conn, result);
 291 }
 292
 293 /* Internal function that doesn't do any verification */
 294 static int
 295 _sasl_encodev (sasl_conn_t *conn,
 296                const struct iovec *invec,
 297                unsigned numiov,
 298                int * p_num_packets,     /* number of packets generated so far */
 299                const char **output,     /* previous output, if *p_num_packets > 0 */
 300                unsigned *outputlen)
 301 {
 302     int result;
 303     char * new_buf;
 304
 305     assert (conn->oparams.encode != NULL);
 306
 307     if (*p_num_packets == 1) {
 308         /* This is the second call to this function,
 309            so we need to allocate a new output buffer
 310            and copy existing data there. */
 311         conn->multipacket_encoded_data.curlen = *outputlen;
 312         if (conn->multipacket_encoded_data.data == NULL) {
 313             conn->multipacket_encoded_data.reallen =
 314                  conn->multipacket_encoded_data.curlen + SASL_ENCODEV_EXTRA;
 315             conn->multipacket_encoded_data.data =
 316                  sasl_ALLOC(conn->multipacket_encoded_data.reallen + 1);
 317
 318             if (conn->multipacket_encoded_data.data == NULL) {
 319                 MEMERROR(conn);
 320             }
 321         } else {
 322             /* A buffer left from a previous sasl_encodev call.
 323                Make sure it is big enough. */
 324             if (conn->multipacket_encoded_data.curlen >
 325                 conn->multipacket_encoded_data.reallen) {
 326                 conn->multipacket_encoded_data.reallen =
 327                     conn->multipacket_encoded_data.curlen + SASL_ENCODEV_EXTRA;
 328
 329                 new_buf = sasl_REALLOC(conn->multipacket_encoded_data.data,
 330                             conn->multipacket_encoded_data.reallen + 1);
 331                 if (new_buf == NULL) {
 332                     MEMERROR(conn);
 333                 }
 334                 conn->multipacket_encoded_data.data = new_buf;
 335             }
 336         }
 337
 338         memcpy (conn->multipacket_encoded_data.data,
 339                 *output,
 340                 *outputlen);
 341     }
 342
 343     result = conn->oparams.encode(conn->context,
 344                                   invec,
 345                                   numiov,
 346                                   output,
 347                                   outputlen);
 348
 349     if (*p_num_packets > 0 && result == SASL_OK) {
 350         /* Is the allocated buffer big enough? If not, grow it. */
 351         if ((conn->multipacket_encoded_data.curlen + *outputlen) >
 352              conn->multipacket_encoded_data.reallen) {
 353             conn->multipacket_encoded_data.reallen =
 354                 conn->multipacket_encoded_data.curlen + *outputlen;
 355             new_buf = sasl_REALLOC(conn->multipacket_encoded_data.data,
 356                         conn->multipacket_encoded_data.reallen + 1);
 357             if (new_buf == NULL) {
 358                 MEMERROR(conn);
 359             }
 360             conn->multipacket_encoded_data.data = new_buf;
 361         }
 362
 363         /* Append new data to the end of the buffer */
 364         memcpy (conn->multipacket_encoded_data.data +
 365                 conn->multipacket_encoded_data.curlen,
 366                 *output,
 367                 *outputlen);
 368         conn->multipacket_encoded_data.curlen += *outputlen;
 369
 370         *output = conn->multipacket_encoded_data.data;
 371         *outputlen = conn->multipacket_encoded_data.curlen;
 372     }
 373
 374     (*p_num_packets)++;
 375
 376     RETURN(conn, result);
 377 }
 378
 379 /* security-encode an iovec */
 380 /* output is only valid until the next call to sasl_encode or sasl_encodev */
 381 int sasl_encodev(sasl_conn_t *conn,
 382                  const struct iovec *invec,
 383                  unsigned numiov,
 384                  const char **output,
 385                  unsigned *outputlen)
 386 {
 387     int result;
 388     unsigned i;
 389     unsigned j;
 390     size_t total_size = 0;
 391     struct iovec *cur_invec = NULL;
 392     struct iovec last_invec;
 393     unsigned cur_numiov;
 394     char * next_buf = NULL;
 395     unsigned remainder_len;
 396     unsigned index_offset;
 397     unsigned allocated = 0;
 398     /* Number of generated SASL packets */
 399     int num_packets = 0;
 400
 401     if (!conn) return SASL_BADPARAM;
 402     if (! invec || ! output || ! outputlen || numiov < 1) {
 403         PARAMERROR(conn);
 404     }
 405
 406     if (!conn->props.maxbufsize) {
 407         sasl_seterror(conn, 0,
 408                       "called sasl_encode[v] with application that does not support security layers");
 409         return SASL_TOOWEAK;
 410     }
 411
 412     /* If oparams.encode is NULL, this means there is no SASL security
 413        layer in effect, so no SASL framing is needed. */
 414     if (conn->oparams.encode == NULL)  {
 415         result = _iovec_to_buf(invec, numiov, &conn->encode_buf);
 416         if (result != SASL_OK) INTERROR(conn, result);
 417
 418         *output = conn->encode_buf->data;
 419         *outputlen = (unsigned) conn->encode_buf->curlen;
 420
 421         RETURN(conn, result);
 422     }
 423
 424     /* This might be better to check on a per-plugin basis, but I think
 425      * it's cleaner and more effective here.  It also encourages plugins
 426      * to be honest about what they accept */
 427
 428     last_invec.iov_base = NULL;
 429     remainder_len = 0;
 430     next_buf = NULL;
 431     i = 0;
 432     while (i < numiov) {
 433         if ((total_size + invec[i].iov_len) > conn->oparams.maxoutbuf) {
 434
 435             /* CLAIM: total_size < conn->oparams.maxoutbuf */
 436
 437             /* Fit as many bytes in last_invec, so that we have conn->oparams.maxoutbuf
 438                bytes in total. */
 439             last_invec.iov_len = conn->oparams.maxoutbuf - total_size;
 440             /* Point to the first byte of the current record. */
 441             last_invec.iov_base = invec[i].iov_base;
 442
 443             /* Note that total_size < conn->oparams.maxoutbuf */
 444             /* The total size of the iov is bigger then the other end can accept.
 445                So we allocate a new iov that contains just enough. */
 446
 447             /* +1 --- for the tail record */
 448             cur_numiov = i + 1;
 449
 450             /* +1 --- just in case we need the head record */
 451             if ((cur_numiov + 1) > allocated) {
 452                 struct iovec *new_invec;
 453
 454                 allocated = cur_numiov + 1;
 455                 new_invec = sasl_REALLOC (cur_invec, sizeof(struct iovec) * allocated);
 456                 if (new_invec == NULL) {
 457                     if (cur_invec != NULL) {
 458                         sasl_FREE(cur_invec);
 459                     }
 460                     MEMERROR(conn);
 461                 }
 462                 cur_invec = new_invec;
 463             }
 464
 465             if (next_buf != NULL) {
 466                 cur_invec[0].iov_base = next_buf;
 467                 cur_invec[0].iov_len = remainder_len;
 468                 cur_numiov++;
 469                 index_offset = 1;
 470             } else {
 471                 index_offset = 0;
 472             }
 473
 474             if (i > 0) {
 475                 /* Copy all previous chunks */
 476                 /* NOTE - The starting index in invec is always 0 */
 477                 for (j = 0; j < i; j++) {
 478                     cur_invec[j + index_offset] = invec[j];
 479                 }
 480             }
 481
 482             /* Initialize the last record */
 483             cur_invec[i + index_offset] = last_invec;
 484
 485             result = _sasl_encodev (conn,
 486                                     cur_invec,
 487                                     cur_numiov,
 488                                     &num_packets,
 489                                     output,
 490                                     outputlen);
 491
 492             if (result != SASL_OK) {
 493                 goto cleanup;
 494             }
 495
 496             /* Point to the first byte that wouldn't fit into
 497                the conn->oparams.maxoutbuf buffer. */
 498             /* Note, if next_buf points to the very end of the IOV record,
 499                it will be reset to NULL below */
 500             next_buf = last_invec.iov_base + last_invec.iov_len;
 501             /* Note - remainder_len is how many bytes left to be encoded in
 502                the current IOV slot. */
 503             remainder_len = (total_size + invec[i].iov_len) - conn->oparams.maxoutbuf;
 504
 505             /* Skip all consumed IOV records */
 506             invec += i + 1;
 507             numiov = numiov - (i + 1);
 508             i = 0;
 509
 510             while (remainder_len > conn->oparams.maxoutbuf) {
 511                 last_invec.iov_base = next_buf;
 512                 last_invec.iov_len = conn->oparams.maxoutbuf;
 513
 514                 /* Note, if next_buf points to the very end of the IOV record,
 515                    it will be reset to NULL below */
 516                 next_buf = last_invec.iov_base + last_invec.iov_len;
 517                 remainder_len = remainder_len - conn->oparams.maxoutbuf;
 518
 519                 result = _sasl_encodev (conn,
 520                                         &last_invec,
 521                                         1,
 522                                         &num_packets,
 523                                         output,
 524                                         outputlen);
 525                 if (result != SASL_OK) {
 526                     goto cleanup;
 527                 }
 528             }
 529
 530             total_size = remainder_len;
 531
 532             if (remainder_len == 0) {
 533                 /* Just clear next_buf */
 534                 next_buf = NULL;
 535             }
 536         } else {
 537             total_size += invec[i].iov_len;
 538             i++;
 539         }
 540     }
 541
 542     /* CLAIM - The remaining data is shorter then conn->oparams.maxoutbuf. */
 543
 544     /* Force encoding of any partial buffer. Might not be optimal on the wire. */
 545     if (next_buf != NULL) {
 546         last_invec.iov_base = next_buf;
 547         last_invec.iov_len = remainder_len;
 548
 549         result = _sasl_encodev (conn,
 550                                 &last_invec,
 551                                 1,
 552                                 &num_packets,
 553                                 output,
 554                                 outputlen);
 555
 556         if (result != SASL_OK) {
 557             goto cleanup;
 558         }
 559     }
 560
 561     if (numiov > 0) {
 562         result = _sasl_encodev (conn,
 563                                 invec,
 564                                 numiov,
 565                                 &num_packets,
 566                                 output,
 567                                 outputlen);
 568     }
 569
 570 cleanup:
 571     if (cur_invec != NULL) {
 572         sasl_FREE(cur_invec);
 573     }
 574
 575     RETURN(conn, result);
 576 }
 577
 578 /* output is only valid until next call to sasl_decode */
 579 int sasl_decode(sasl_conn_t *conn,
 580                 const char *input, unsigned inputlen,
 581                 const char **output, unsigned *outputlen)
 582 {
 583     int result;
 584
 585     if(!conn) return SASL_BADPARAM;
 586     if(!input || !output || !outputlen)
 587         PARAMERROR(conn);
 588
 589     if(!conn->props.maxbufsize) {
 590         sasl_seterror(conn, 0,
 591                       "called sasl_decode with application that does not support security layers");
 592         RETURN(conn, SASL_TOOWEAK);
 593     }
 594
 595     if(conn->oparams.decode == NULL)
 596     {
 597         /* Since we know how long the output is maximally, we can
 598          * just allocate it to begin with, and never need another
 599          * allocation! */
 600
 601         /* However, if they pass us more than they actually can take,
 602          * we cannot help them... */
 603         if(inputlen > conn->props.maxbufsize) {
 604             sasl_seterror(conn, 0,
 605                           "input too large for default sasl_decode");
 606             RETURN(conn,SASL_BUFOVER);
 607         }
 608
 609         if(!conn->decode_buf)
 610             conn->decode_buf = sasl_ALLOC(conn->props.maxbufsize + 1);
 611         if(!conn->decode_buf)
 612             MEMERROR(conn);
 613
 614         memcpy(conn->decode_buf, input, inputlen);
 615         conn->decode_buf[inputlen] = '\0';
 616         *output = conn->decode_buf;
 617         *outputlen = inputlen;
 618
 619         return SASL_OK;
 620     } else {
 621         result = conn->oparams.decode(conn->context, input, inputlen,
 622                                       output, outputlen);
 623
 624         /* NULL an empty buffer (for misbehaved applications) */
 625         if (*outputlen == 0) *output = NULL;
 626
 627         RETURN(conn, result);
 628     }
 629
 630     INTERROR(conn, SASL_FAIL);
 631 }
 632
 633
 634 void
 635 sasl_set_alloc(sasl_malloc_t *m,
 636                sasl_calloc_t *c,
 637                sasl_realloc_t *r,
 638                sasl_free_t *f)
 639 {
 640   _sasl_allocation_utils.malloc=m;
 641   _sasl_allocation_utils.calloc=c;
 642   _sasl_allocation_utils.realloc=r;
 643   _sasl_allocation_utils.free=f;
 644 }
 645
 646 void sasl_done(void)
 647 {
 648     if (_sasl_server_cleanup_hook && _sasl_server_cleanup_hook() == SASL_OK) {
 649         _sasl_server_idle_hook = NULL;
 650         _sasl_server_cleanup_hook = NULL;
 651     }
 652
 653     if (_sasl_client_cleanup_hook && _sasl_client_cleanup_hook() == SASL_OK) {
 654         _sasl_client_idle_hook = NULL;
 655         _sasl_client_cleanup_hook = NULL;
 656     }
 657
 658     if (_sasl_server_cleanup_hook || _sasl_client_cleanup_hook) {
 659         return;
 660     }
 661
 662     /* NOTE - the caller will need to reinitialize the values,
 663        if it is going to call sasl_client_init/sasl_server_init again. */
 664     if (default_plugin_path != NULL) {
 665         sasl_FREE (default_plugin_path);
 666         default_plugin_path = NULL;
 667     }
 668     if (default_conf_path != NULL) {
 669         sasl_FREE (default_conf_path);
 670         default_conf_path = NULL;
 671     }
 672
 673     _sasl_canonuser_free();
 674     _sasl_done_with_plugins();
 675
 676     sasl_MUTEX_FREE(free_mutex);
 677     free_mutex = NULL;
 678
 679     _sasl_free_utils(&sasl_global_utils);
 680
 681     if(global_mech_list) sasl_FREE(global_mech_list);
 682     global_mech_list = NULL;
 683 }
 684
 685 /* fills in the base sasl_conn_t info */
 686 int _sasl_conn_init(sasl_conn_t *conn,
 687                     const char *service,
 688                     unsigned int flags,
 689                     enum Sasl_conn_type type,
 690                     int (*idle_hook)(sasl_conn_t *conn),
 691                     const char *serverFQDN,
 692                     const char *iplocalport,
 693                     const char *ipremoteport,
 694                     const sasl_callback_t *callbacks,
 695                     const sasl_global_callbacks_t *global_callbacks) {
 696   int result = SASL_OK;
 697
 698   conn->type = type;
 699
 700   result = _sasl_strdup(service, &conn->service, NULL);
 701   if (result != SASL_OK)
 702       MEMERROR(conn);
 703
 704   memset(&conn->oparams, 0, sizeof(sasl_out_params_t));
 705   memset(&conn->external, 0, sizeof(_sasl_external_properties_t));
 706
 707   conn->flags = flags;
 708
 709   result = sasl_setprop(conn, SASL_IPLOCALPORT, iplocalport);
 710   if(result != SASL_OK)
 711       RETURN(conn, result);
 712
 713   result = sasl_setprop(conn, SASL_IPREMOTEPORT, ipremoteport);
 714   if(result != SASL_OK)
 715       RETURN(conn, result);
 716
 717   conn->encode_buf = NULL;
 718   conn->context = NULL;
 719   conn->secret = NULL;
 720   conn->idle_hook = idle_hook;
 721   conn->callbacks = callbacks;
 722   conn->global_callbacks = global_callbacks;
 723
 724   memset(&conn->props, 0, sizeof(conn->props));
 725
 726   /* Start this buffer out as an empty string */
 727   conn->error_code = SASL_OK;
 728   conn->errdetail_buf = conn->error_buf = NULL;
 729   conn->errdetail_buf_len = conn->error_buf_len = 150;
 730
 731   result = _buf_alloc(&conn->error_buf, &conn->error_buf_len, 150);
 732   if(result != SASL_OK) MEMERROR(conn);
 733   result = _buf_alloc(&conn->errdetail_buf, &conn->errdetail_buf_len, 150);
 734   if(result != SASL_OK) MEMERROR(conn);
 735
 736   conn->error_buf[0] = '\0';
 737   conn->errdetail_buf[0] = '\0';
 738
 739   conn->decode_buf = NULL;
 740
 741   if(serverFQDN) {
 742       result = _sasl_strdup(serverFQDN, &conn->serverFQDN, NULL);
 743   } else if (conn->type == SASL_CONN_SERVER) {
 744       /* We can fake it because we *are* the server */
 745       char name[MAXHOSTNAMELEN];
 746       memset(name, 0, sizeof(name));
 747       gethostname(name, MAXHOSTNAMELEN);
 748
 749       result = _sasl_strdup(name, &conn->serverFQDN, NULL);
 750   } else {
 751       conn->serverFQDN = NULL;
 752   }
 753
 754
 755   if(result != SASL_OK) MEMERROR( conn );
 756
 757   RETURN(conn, SASL_OK);
 758 }
 759
 760 int _sasl_common_init(sasl_global_callbacks_t *global_callbacks)
 761 {
 762     int result;
 763
 764     /* Setup the global utilities */
 765     if(!sasl_global_utils) {
 766         sasl_global_utils = _sasl_alloc_utils(NULL, global_callbacks);
 767         if(sasl_global_utils == NULL) return SASL_NOMEM;
 768     }
 769
 770     /* Init the canon_user plugin */
 771     result = sasl_canonuser_add_plugin("INTERNAL", internal_canonuser_init);
 772     if(result != SASL_OK) return result;
 773
 774     if (!free_mutex)
 775         free_mutex = sasl_MUTEX_ALLOC();
 776     if (!free_mutex) return SASL_FAIL;
 777
 778     return SASL_OK;
 779 }
 780
 781 /* dispose connection state, sets it to NULL
 782  *  checks for pointer to NULL
 783  */
 784 void sasl_dispose(sasl_conn_t **pconn)
 785 {
 786   int result;
 787
 788   if (! pconn) return;
 789   if (! *pconn) return;
 790
 791   /* serialize disposes. this is necessary because we can't
 792      dispose of conn->mutex if someone else is locked on it */
 793   result = sasl_MUTEX_LOCK(free_mutex);
 794   if (result!=SASL_OK) return;
 795
 796   /* *pconn might have become NULL by now */
 797   if (! (*pconn)) return;
 798
 799   (*pconn)->destroy_conn(*pconn);
 800   sasl_FREE(*pconn);
 801   *pconn=NULL;
 802
 803   sasl_MUTEX_UNLOCK(free_mutex);
 804 }
 805
 806 void _sasl_conn_dispose(sasl_conn_t *conn) {
 807   if (conn->serverFQDN)
 808       sasl_FREE(conn->serverFQDN);
 809
 810   if (conn->external.auth_id)
 811       sasl_FREE(conn->external.auth_id);
 812
 813   if(conn->encode_buf) {
 814       if(conn->encode_buf->data) sasl_FREE(conn->encode_buf->data);
 815       sasl_FREE(conn->encode_buf);
 816   }
 817
 818   if(conn->error_buf)
 819       sasl_FREE(conn->error_buf);
 820
 821   if(conn->errdetail_buf)
 822       sasl_FREE(conn->errdetail_buf);
 823
 824   if(conn->decode_buf)
 825       sasl_FREE(conn->decode_buf);
 826
 827   if(conn->mechlist_buf)
 828       sasl_FREE(conn->mechlist_buf);
 829
 830   if(conn->service)
 831       sasl_FREE(conn->service);
 832
 833   if (conn->multipacket_encoded_data.data) {
 834       sasl_FREE(conn->multipacket_encoded_data.data);
 835   }
 836
 837   /* oparams sub-members should be freed by the plugin, in so much
 838    * as they were allocated by the plugin */
 839 }
 840
 841
 842 /* get property from SASL connection state
 843  *  propnum       -- property number
 844  *  pvalue        -- pointer to value
 845  * returns:
 846  *  SASL_OK       -- no error
 847  *  SASL_NOTDONE  -- property not available yet
 848  *  SASL_BADPARAM -- bad property number
 849  */
 850 int sasl_getprop(sasl_conn_t *conn, int propnum, const void **pvalue)
 851 {
 852   int result = SASL_OK;
 853   sasl_getopt_t *getopt;
 854   void *context;
 855
 856   if (! conn) return SASL_BADPARAM;
 857   if (! pvalue) PARAMERROR(conn);
 858
 859   switch(propnum)
 860   {
 861   case SASL_SSF:
 862       *(sasl_ssf_t **)pvalue= &conn->oparams.mech_ssf;
 863       break;
 864   case SASL_MAXOUTBUF:
 865       *(unsigned **)pvalue = &conn->oparams.maxoutbuf;
 866       break;
 867   case SASL_GETOPTCTX:
 868       result = _sasl_getcallback(conn, SASL_CB_GETOPT, &getopt, &context);
 869       if(result != SASL_OK) break;
 870
 871       *(void **)pvalue = context;
 872       break;
 873   case SASL_CALLBACK:
 874       *(const sasl_callback_t **)pvalue = conn->callbacks;
 875       break;
 876   case SASL_IPLOCALPORT:
 877       if(conn->got_ip_local)
 878           *(const char **)pvalue = conn->iplocalport;
 879       else {
 880           *(const char **)pvalue = NULL;
 881           result = SASL_NOTDONE;
 882       }
 883       break;
 884   case SASL_IPREMOTEPORT:
 885       if(conn->got_ip_remote)
 886           *(const char **)pvalue = conn->ipremoteport;
 887       else {
 888           *(const char **)pvalue = NULL;
 889           result = SASL_NOTDONE;
 890       }
 891       break;
 892   case SASL_USERNAME:
 893       if(! conn->oparams.user)
 894           result = SASL_NOTDONE;
 895       else
 896           *((const char **)pvalue) = conn->oparams.user;
 897       break;
 898   case SASL_AUTHUSER:
 899       if(! conn->oparams.authid)
 900           result = SASL_NOTDONE;
 901       else
 902           *((const char **)pvalue) = conn->oparams.authid;
 903       break;
 904   case SASL_APPNAME:
 905       /* Currently we only support server side contexts, but we should
 906          be able to extend this to support client side contexts as well */
 907       if(conn->type != SASL_CONN_SERVER) result = SASL_BADPROT;
 908       else
 909           *((const char **)pvalue) = ((sasl_server_conn_t *)conn)->sparams->appname;
 910       break;
 911   case SASL_SERVERFQDN:
 912       *((const char **)pvalue) = conn->serverFQDN;
 913       break;
 914   case SASL_DEFUSERREALM:
 915       if(conn->type != SASL_CONN_SERVER) result = SASL_BADPROT;
 916       else
 917           *((const char **)pvalue) = ((sasl_server_conn_t *)conn)->user_realm;
 918       break;
 919   case SASL_SERVICE:
 920       *((const char **)pvalue) = conn->service;
 921       break;
 922   case SASL_AUTHSOURCE: /* name of plugin (not name of mech) */
 923       if(conn->type == SASL_CONN_CLIENT) {
 924           if(!((sasl_client_conn_t *)conn)->mech) {
 925               result = SASL_NOTDONE;
 926               break;
 927           }
 928           *((const char **)pvalue) =
 929               ((sasl_client_conn_t *)conn)->mech->m.plugname;
 930       } else if (conn->type == SASL_CONN_SERVER) {
 931           if(!((sasl_server_conn_t *)conn)->mech) {
 932               result = SASL_NOTDONE;
 933               break;
 934           }
 935           *((const char **)pvalue) =
 936               ((sasl_server_conn_t *)conn)->mech->m.plugname;
 937       } else {
 938           result = SASL_BADPARAM;
 939       }
 940       break;
 941   case SASL_MECHNAME: /* name of mech */
 942       if(conn->type == SASL_CONN_CLIENT) {
 943           if(!((sasl_client_conn_t *)conn)->mech) {
 944               result = SASL_NOTDONE;
 945               break;
 946           }
 947           *((const char **)pvalue) =
 948               ((sasl_client_conn_t *)conn)->mech->m.plug->mech_name;
 949       } else if (conn->type == SASL_CONN_SERVER) {
 950           if(!((sasl_server_conn_t *)conn)->mech) {
 951               result = SASL_NOTDONE;
 952               break;
 953           }
 954           *((const char **)pvalue) =
 955               ((sasl_server_conn_t *)conn)->mech->m.plug->mech_name;
 956       } else {
 957           result = SASL_BADPARAM;
 958       }
 959
 960       if(!(*pvalue) && result == SASL_OK) result = SASL_NOTDONE;
 961       break;
 962   case SASL_PLUGERR:
 963       *((const char **)pvalue) = conn->error_buf;
 964       break;
 965   case SASL_DELEGATEDCREDS:
 966       /* We can't really distinguish between "no delegated credentials"
 967          and "authentication not finished" */
 968       if(! conn->oparams.client_creds)
 969           result = SASL_NOTDONE;
 970       else
 971           *((const char **)pvalue) = conn->oparams.client_creds;
 972       break;
 973   case SASL_GSS_PEER_NAME:
 974       if(! conn->oparams.gss_peer_name)
 975           result = SASL_NOTDONE;
 976       else
 977           *((const char **)pvalue) = conn->oparams.gss_peer_name;
 978       break;
 979   case SASL_GSS_LOCAL_NAME:
 980       if(! conn->oparams.gss_peer_name)
 981           result = SASL_NOTDONE;
 982       else
 983           *((const char **)pvalue) = conn->oparams.gss_local_name;
 984       break;
 985   case SASL_SSF_EXTERNAL:
 986       *((const sasl_ssf_t **)pvalue) = &conn->external.ssf;
 987       break;
 988   case SASL_AUTH_EXTERNAL:
 989       *((const char **)pvalue) = conn->external.auth_id;
 990       break;
 991   case SASL_SEC_PROPS:
 992       *((const sasl_security_properties_t **)pvalue) = &conn->props;
 993       break;
 994   default:
 995       result = SASL_BADPARAM;
 996   }
 997
 998   if(result == SASL_BADPARAM) {
 999       PARAMERROR(conn);
1000   } else if(result == SASL_NOTDONE) {
1001       sasl_seterror(conn, SASL_NOLOG,
1002                     "Information that was requested is not yet available.");
1003       RETURN(conn, result);
1004   } else if(result != SASL_OK) {
1005       INTERROR(conn, result);
1006   } else
1007       RETURN(conn, result);
1008 }
1009
1010 /* set property in SASL connection state
1011  * returns:
1012  *  SASL_OK       -- value set
1013  *  SASL_BADPARAM -- invalid property or value
1014  */
1015 int sasl_setprop(sasl_conn_t *conn, int propnum, const void *value)
1016 {
1017   int result = SASL_OK;
1018   char *str;
1019
1020   /* make sure the sasl context is valid */
1021   if (!conn)
1022     return SASL_BADPARAM;
1023
1024   switch(propnum)
1025   {
1026   case SASL_SSF_EXTERNAL:
1027       conn->external.ssf = *((sasl_ssf_t *)value);
1028       if(conn->type == SASL_CONN_SERVER) {
1029         ((sasl_server_conn_t*)conn)->sparams->external_ssf =
1030           conn->external.ssf;
1031       } else {
1032         ((sasl_client_conn_t*)conn)->cparams->external_ssf =
1033           conn->external.ssf;
1034       }
1035       break;
1036
1037   case SASL_AUTH_EXTERNAL:
1038       if(value && strlen(value)) {
1039           result = _sasl_strdup(value, &str, NULL);
1040           if(result != SASL_OK) MEMERROR(conn);
1041       } else {
1042           str = NULL;
1043       }
1044
1045       if(conn->external.auth_id)
1046           sasl_FREE(conn->external.auth_id);
1047
1048       conn->external.auth_id = str;
1049
1050       break;
1051
1052   case SASL_DEFUSERREALM:
1053       if(conn->type != SASL_CONN_SERVER) {
1054         sasl_seterror(conn, 0, "Tried to set realm on non-server connection");
1055         result = SASL_BADPROT;
1056         break;
1057       }
1058
1059       if(value && strlen(value)) {
1060           result = _sasl_strdup(value, &str, NULL);
1061           if(result != SASL_OK) MEMERROR(conn);
1062       } else {
1063           PARAMERROR(conn);
1064       }
1065
1066       if(((sasl_server_conn_t *)conn)->user_realm)
1067           sasl_FREE(((sasl_server_conn_t *)conn)->user_realm);
1068
1069       ((sasl_server_conn_t *)conn)->user_realm = str;
1070       ((sasl_server_conn_t *)conn)->sparams->user_realm = str;
1071
1072       break;
1073
1074   case SASL_SEC_PROPS:
1075   {
1076       sasl_security_properties_t *props = (sasl_security_properties_t *)value;
1077
1078       if(props->maxbufsize == 0 && props->min_ssf != 0) {
1079           sasl_seterror(conn, 0,
1080                         "Attempt to disable security layers (maxoutbuf == 0) with min_ssf > 0");
1081           RETURN(conn, SASL_TOOWEAK);
1082       }
1083
1084       conn->props = *props;
1085
1086       if(conn->type == SASL_CONN_SERVER) {
1087         ((sasl_server_conn_t*)conn)->sparams->props = *props;
1088       } else {
1089         ((sasl_client_conn_t*)conn)->cparams->props = *props;
1090       }
1091
1092       break;
1093   }
1094
1095   case SASL_IPREMOTEPORT:
1096   {
1097       const char *ipremoteport = (const char *)value;
1098       if(!value) {
1099           conn->got_ip_remote = 0;
1100       } else if (_sasl_ipfromstring(ipremoteport, NULL, 0)
1101                  != SASL_OK) {
1102           sasl_seterror(conn, 0, "Bad IPREMOTEPORT value");
1103           RETURN(conn, SASL_BADPARAM);
1104       } else {
1105           strcpy(conn->ipremoteport, ipremoteport);
1106           conn->got_ip_remote = 1;
1107       }
1108
1109       if(conn->got_ip_remote) {
1110           if(conn->type == SASL_CONN_CLIENT) {
1111               ((sasl_client_conn_t *)conn)->cparams->ipremoteport
1112                   = conn->ipremoteport;
1113               ((sasl_client_conn_t *)conn)->cparams->ipremlen =
1114                   (unsigned) strlen(conn->ipremoteport);
1115           } else if (conn->type == SASL_CONN_SERVER) {
1116               ((sasl_server_conn_t *)conn)->sparams->ipremoteport
1117                   = conn->ipremoteport;
1118               ((sasl_server_conn_t *)conn)->sparams->ipremlen =
1119                   (unsigned) strlen(conn->ipremoteport);
1120           }
1121       } else {
1122           if(conn->type == SASL_CONN_CLIENT) {
1123               ((sasl_client_conn_t *)conn)->cparams->ipremoteport
1124                   = NULL;
1125               ((sasl_client_conn_t *)conn)->cparams->ipremlen = 0;
1126           } else if (conn->type == SASL_CONN_SERVER) {
1127               ((sasl_server_conn_t *)conn)->sparams->ipremoteport
1128                   = NULL;
1129               ((sasl_server_conn_t *)conn)->sparams->ipremlen = 0;
1130           }
1131       }
1132
1133       break;
1134   }
1135
1136   case SASL_IPLOCALPORT:
1137   {
1138       const char *iplocalport = (const char *)value;
1139       if(!value) {
1140           conn->got_ip_local = 0;
1141       } else if (_sasl_ipfromstring(iplocalport, NULL, 0)
1142                  != SASL_OK) {
1143           sasl_seterror(conn, 0, "Bad IPLOCALPORT value");
1144           RETURN(conn, SASL_BADPARAM);
1145       } else {
1146           strcpy(conn->iplocalport, iplocalport);
1147           conn->got_ip_local = 1;
1148       }
1149
1150       if(conn->got_ip_local) {
1151           if(conn->type == SASL_CONN_CLIENT) {
1152               ((sasl_client_conn_t *)conn)->cparams->iplocalport
1153                   = conn->iplocalport;
1154               ((sasl_client_conn_t *)conn)->cparams->iploclen
1155                   = (unsigned) strlen(conn->iplocalport);
1156           } else if (conn->type == SASL_CONN_SERVER) {
1157               ((sasl_server_conn_t *)conn)->sparams->iplocalport
1158                   = conn->iplocalport;
1159               ((sasl_server_conn_t *)conn)->sparams->iploclen
1160                   = (unsigned) strlen(conn->iplocalport);
1161           }
1162       } else {
1163           if(conn->type == SASL_CONN_CLIENT) {
1164               ((sasl_client_conn_t *)conn)->cparams->iplocalport
1165                   = NULL;
1166               ((sasl_client_conn_t *)conn)->cparams->iploclen = 0;
1167           } else if (conn->type == SASL_CONN_SERVER) {
1168               ((sasl_server_conn_t *)conn)->sparams->iplocalport
1169                   = NULL;
1170               ((sasl_server_conn_t *)conn)->sparams->iploclen = 0;
1171           }
1172       }
1173       break;
1174   }
1175
1176   case SASL_APPNAME:
1177       /* Currently we only support server side contexts, but we should
1178          be able to extend this to support client side contexts as well */
1179       if(conn->type != SASL_CONN_SERVER) {
1180         sasl_seterror(conn, 0, "Tried to set application name on non-server connection");
1181         result = SASL_BADPROT;
1182         break;
1183       }
1184
1185       if(((sasl_server_conn_t *)conn)->appname) {
1186           sasl_FREE(((sasl_server_conn_t *)conn)->appname);
1187           ((sasl_server_conn_t *)conn)->appname = NULL;
1188       }
1189
1190       if(value && strlen(value)) {
1191           result = _sasl_strdup(value,
1192                                 &(((sasl_server_conn_t *)conn)->appname),
1193                                 NULL);
1194           if(result != SASL_OK) MEMERROR(conn);
1195           ((sasl_server_conn_t *)conn)->sparams->appname =
1196               ((sasl_server_conn_t *)conn)->appname;
1197           ((sasl_server_conn_t *)conn)->sparams->applen =
1198               (unsigned) strlen(((sasl_server_conn_t *)conn)->appname);
1199       } else {
1200           ((sasl_server_conn_t *)conn)->sparams->appname = NULL;
1201           ((sasl_server_conn_t *)conn)->sparams->applen = 0;
1202       }
1203       break;
1204
1205   case SASL_GSS_CREDS:
1206     if (conn->type == SASL_CONN_SERVER)
1207         ((sasl_server_conn_t *)conn)->sparams->gss_creds = (void *)value;
1208     else
1209         ((sasl_client_conn_t *)conn)->cparams->gss_creds = (void *)value;
1210     break;
1211   case SASL_CHANNEL_BINDING: {
1212     const struct sasl_channel_binding *cb = (const struct sasl_channel_binding *)value;
1213
1214     if (conn->type == SASL_CONN_SERVER)
1215         ((sasl_server_conn_t *)conn)->sparams->cbinding = cb;
1216     else
1217         ((sasl_client_conn_t *)conn)->cparams->cbinding = cb;
1218     break;
1219   }
1220   default:
1221       sasl_seterror(conn, 0, "Unknown parameter type");
1222       result = SASL_BADPARAM;
1223   }
1224
1225   RETURN(conn, result);
1226 }
1227
1228 /* this is apparently no longer a user function */
1229 static int sasl_usererr(int saslerr)
1230 {
1231     /* Hide the difference in a username failure and a password failure */
1232     if (saslerr == SASL_NOUSER)
1233         return SASL_BADAUTH;
1234
1235     /* otherwise return the error given; no transform necessary */
1236     return saslerr;
1237 }
1238
1239 const char *sasl_errstring(int saslerr,
1240                            const char *langlist __attribute__((unused)),
1241                            const char **outlang)
1242 {
1243   if (outlang) *outlang="en-us";
1244
1245   switch(saslerr)
1246     {
1247     case SASL_CONTINUE: return "another step is needed in authentication";
1248     case SASL_OK:       return "successful result";
1249     case SASL_FAIL:     return "generic failure";
1250     case SASL_NOMEM:    return "no memory available";
1251     case SASL_BUFOVER:  return "overflowed buffer";
1252     case SASL_NOMECH:   return "no mechanism available";
1253     case SASL_BADPROT:  return "bad protocol / cancel";
1254     case SASL_NOTDONE:  return "can't request info until later in exchange";
1255     case SASL_BADPARAM: return "invalid parameter supplied";
1256     case SASL_TRYAGAIN: return "transient failure (e.g., weak key)";
1257     case SASL_BADMAC:   return "integrity check failed";
1258     case SASL_NOTINIT:  return "SASL library not initialized";
1259                              /* -- client only codes -- */
1260     case SASL_INTERACT:   return "needs user interaction";
1261     case SASL_BADSERV:    return "server failed mutual authentication step";
1262     case SASL_WRONGMECH:  return "mechanism doesn't support requested feature";
1263                              /* -- server only codes -- */
1264     case SASL_BADAUTH:    return "authentication failure";
1265     case SASL_NOAUTHZ:    return "authorization failure";
1266     case SASL_TOOWEAK:    return "mechanism too weak for this user";
1267     case SASL_ENCRYPT:    return "encryption needed to use mechanism";
1268     case SASL_TRANS:      return "One time use of a plaintext password will enable requested mechanism for user";
1269     case SASL_EXPIRED:    return "passphrase expired, has to be reset";
1270     case SASL_DISABLED:   return "account disabled";
1271     case SASL_NOUSER:     return "user not found";
1272     case SASL_BADVERS:    return "version mismatch with plug-in";
1273     case SASL_UNAVAIL:    return "remote authentication server unavailable";
1274     case SASL_NOVERIFY:   return "user exists, but no verifier for user";
1275     case SASL_PWLOCK:     return "passphrase locked";
1276     case SASL_NOCHANGE:   return "requested change was not needed";
1277     case SASL_WEAKPASS:   return "passphrase is too weak for security policy";
1278     case SASL_NOUSERPASS: return "user supplied passwords are not permitted";
1279
1280     default:   return "undefined error!";
1281     }
1282
1283 }
1284
1285 /* Return the sanitized error detail about the last error that occured for
1286  * a connection */
1287 const char *sasl_errdetail(sasl_conn_t *conn)
1288 {
1289     unsigned need_len;
1290     const char *errstr;
1291     char leader[128];
1292
1293     if(!conn) return NULL;
1294
1295     errstr = sasl_errstring(conn->error_code, NULL, NULL);
1296     snprintf(leader,128,"SASL(%d): %s: ",
1297              sasl_usererr(conn->error_code), errstr);
1298
1299     need_len = (unsigned) (strlen(leader) + strlen(conn->error_buf) + 12);
1300     _buf_alloc(&conn->errdetail_buf, &conn->errdetail_buf_len, need_len);
1301
1302     snprintf(conn->errdetail_buf, need_len, "%s%s", leader, conn->error_buf);
1303
1304     return conn->errdetail_buf;
1305 }
1306
1307
1308 /* Note that this needs the global callbacks, so if you don't give getcallbacks
1309  * a sasl_conn_t, you're going to need to pass it yourself (or else we couldn't
1310  * have client and server at the same time */
1311 static int _sasl_global_getopt(void *context,
1312                                const char *plugin_name,
1313                                const char *option,
1314                                const char ** result,
1315                                unsigned *len)
1316 {
1317   const sasl_global_callbacks_t * global_callbacks;
1318   const sasl_callback_t *callback;
1319
1320   global_callbacks = (const sasl_global_callbacks_t *) context;
1321
1322   if (global_callbacks && global_callbacks->callbacks) {
1323       for (callback = global_callbacks->callbacks;
1324            callback->id != SASL_CB_LIST_END;
1325            callback++) {
1326         if (callback->id == SASL_CB_GETOPT) {
1327           if (!callback->proc) return SASL_FAIL;
1328           if (((sasl_getopt_t *)(callback->proc))(callback->context,
1329                                                   plugin_name,
1330                                                   option,
1331                                                   result,
1332                                                   len)
1333               == SASL_OK)
1334             return SASL_OK;
1335         }
1336       }
1337   }
1338
1339   /* look it up in our configuration file */
1340   *result = sasl_config_getstring(option, NULL);
1341   if (*result != NULL) {
1342       if (len) { *len = (unsigned) strlen(*result); }
1343       return SASL_OK;
1344   }
1345
1346   return SASL_FAIL;
1347 }
1348
1349 static int
1350 _sasl_conn_getopt(void *context,
1351                   const char *plugin_name,
1352                   const char *option,
1353                   const char ** result,
1354                   unsigned *len)
1355 {
1356   sasl_conn_t * conn;
1357   const sasl_callback_t *callback;
1358
1359   if (! context)
1360     return SASL_BADPARAM;
1361
1362   conn = (sasl_conn_t *) context;
1363
1364   if (conn->callbacks)
1365     for (callback = conn->callbacks;
1366          callback->id != SASL_CB_LIST_END;
1367          callback++)
1368       if (callback->id == SASL_CB_GETOPT
1369           && (((sasl_getopt_t *)(callback->proc))(callback->context,
1370                                                   plugin_name,
1371                                                   option,
1372                                                   result,
1373                                                   len)
1374               == SASL_OK))
1375         return SASL_OK;
1376
1377   /* If we made it here, we didn't find an appropriate callback
1378    * in the connection's callback list, or the callback we did
1379    * find didn't return SASL_OK.  So we attempt to use the
1380    * global callback for this connection... */
1381   return _sasl_global_getopt((void *)conn->global_callbacks,
1382                              plugin_name,
1383                              option,
1384                              result,
1385                              len);
1386 }
1387
1388 #ifdef HAVE_SYSLOG
1389 /* this is the default logging */
1390 static int _sasl_syslog(void *context,
1391                         int priority,
1392                         const char *message)
1393 {
1394     int syslog_priority;
1395     sasl_server_conn_t *sconn;
1396
1397     if (context) {
1398         if (((sasl_conn_t *)context)->type == SASL_CONN_SERVER) {
1399             sconn = (sasl_server_conn_t *)context;
1400             if (sconn->sparams->log_level < priority)
1401                 return SASL_OK;
1402         }
1403     }
1404
1405     /* set syslog priority */
1406     switch(priority) {
1407     case SASL_LOG_NONE:
1408         return SASL_OK;
1409         break;
1410     case SASL_LOG_ERR:
1411         syslog_priority = LOG_ERR;
1412         break;
1413     case SASL_LOG_WARN:
1414         syslog_priority = LOG_WARNING;
1415         break;
1416     case SASL_LOG_NOTE:
1417     case SASL_LOG_FAIL:
1418         syslog_priority = LOG_NOTICE;
1419         break;
1420     case SASL_LOG_PASS:
1421     case SASL_LOG_TRACE:
1422     case SASL_LOG_DEBUG:
1423     default:
1424         syslog_priority = LOG_DEBUG;
1425         break;
1426     }
1427
1428     /* do the syslog call. Do not need to call openlog? */
1429     syslog(syslog_priority | LOG_AUTH, "%s", message);
1430
1431     return SASL_OK;
1432 }
1433 #endif                          /* HAVE_SYSLOG */
1434
1435 static int
1436 _sasl_getsimple(void *context,
1437                 int id,
1438                 const char ** result,
1439                 size_t *len)
1440 {
1441   const char *userid;
1442   sasl_conn_t *conn;
1443
1444   if (! context || ! result) return SASL_BADPARAM;
1445
1446   conn = (sasl_conn_t *)context;
1447
1448   switch(id) {
1449   case SASL_CB_AUTHNAME:
1450     userid = getenv("USER");
1451     if (userid != NULL) {
1452         *result = userid;
1453         if (len) *len = strlen(userid);
1454         return SASL_OK;
1455     }
1456     userid = getenv("USERNAME");
1457     if (userid != NULL) {
1458         *result = userid;
1459         if (len) *len = strlen(userid);
1460         return SASL_OK;
1461     }
1462 #ifdef WIN32
1463     /* for win32, try using the GetUserName standard call */
1464     {
1465         DWORD i;
1466         BOOL rval;
1467         static char sender[128];
1468
1469         i = sizeof(sender);
1470         rval = GetUserName(sender, &i);
1471         if ( rval) { /* got a userid */
1472                 *result = sender;
1473                 if (len) *len = strlen(sender);
1474                 return SASL_OK;
1475         }
1476     }
1477 #endif /* WIN32 */
1478     return SASL_FAIL;
1479   default:
1480     return SASL_BADPARAM;
1481   }
1482 }
1483
1484 static int
1485 _sasl_getpath(void *context __attribute__((unused)),
1486               const char ** path_dest)
1487 {
1488 #if !defined(WIN32)
1489     char *path;
1490 #endif
1491     int res = SASL_OK;
1492
1493     if (! path_dest) {
1494         return SASL_BADPARAM;
1495     }
1496
1497     /* Only calculate the path once. */
1498     if (default_plugin_path == NULL) {
1499
1500 #if defined(WIN32)
1501         /* NB: On Windows platforms this value is always allocated */
1502         default_plugin_path = _sasl_get_default_win_path(context,
1503                                                          SASL_PLUGIN_PATH_ATTR,
1504                                                          PLUGINDIR);
1505 #else
1506         /* NB: On Unix platforms this value is never allocated */
1507         path = _sasl_get_default_unix_path(context,
1508                                            SASL_PATH_ENV_VAR,
1509                                            PLUGINDIR);
1510
1511         res = _sasl_strdup(path, &default_plugin_path, NULL);
1512 #endif
1513     }
1514
1515     if (res == SASL_OK) {
1516         *path_dest = default_plugin_path;
1517     }
1518
1519     return res;
1520 }
1521
1522 static int
1523 _sasl_getpath_simple(void *context __attribute__((unused)),
1524                      const char **path)
1525 {
1526     if (! path) {
1527         return SASL_BADPARAM;
1528     }
1529
1530     if (default_plugin_path == NULL) {
1531         return SASL_FAIL;
1532     }
1533
1534     *path = default_plugin_path;
1535
1536     return SASL_OK;
1537 }
1538
1539 static int
1540 _sasl_getconfpath(void *context __attribute__((unused)),
1541                   char ** path_dest)
1542 {
1543 #if !defined(WIN32)
1544     char *path;
1545 #endif
1546     int res = SASL_OK;
1547
1548     if (! path_dest) {
1549         return SASL_BADPARAM;
1550     }
1551
1552   /* Only calculate the path once. */
1553     if (default_conf_path == NULL) {
1554
1555 #if defined(WIN32)
1556         /* NB: On Windows platforms this value is always allocated */
1557         default_conf_path = _sasl_get_default_win_path(context,
1558                                                        SASL_CONF_PATH_ATTR,
1559                                                        CONFIGDIR);
1560 #else
1561         /* NB: On Unix platforms this value is never allocated */
1562         path = _sasl_get_default_unix_path(context,
1563                                            SASL_CONF_PATH_ENV_VAR,
1564                                            CONFIGDIR);
1565
1566         res = _sasl_strdup(path, &default_conf_path, NULL);
1567 #endif
1568     }
1569
1570     if (res == SASL_OK) {
1571         *path_dest = default_conf_path;
1572     }
1573
1574     return res;
1575 }
1576
1577 static int
1578 _sasl_getconfpath_simple(void *context __attribute__((unused)),
1579                          const char **path)
1580 {
1581     if (! path) {
1582         return SASL_BADPARAM;
1583     }
1584
1585     if (default_conf_path == NULL) {
1586         return SASL_FAIL;
1587     }
1588
1589     *path = default_conf_path;
1590
1591     return SASL_OK;
1592 }
1593
1594 static int
1595 _sasl_verifyfile(void *context __attribute__((unused)),
1596                  char *file  __attribute__((unused)),
1597                  int type  __attribute__((unused)))
1598 {
1599   /* always say ok */
1600   return SASL_OK;
1601 }
1602
1603
1604 static int
1605 _sasl_proxy_policy(sasl_conn_t *conn,
1606                    void *context __attribute__((unused)),
1607                    const char *requested_user, unsigned rlen,
1608                    const char *auth_identity, unsigned alen,
1609                    const char *def_realm __attribute__((unused)),
1610                    unsigned urlen __attribute__((unused)),
1611                    struct propctx *propctx __attribute__((unused)))
1612 {
1613     if (!conn)
1614         return SASL_BADPARAM;
1615
1616     if (!requested_user || *requested_user == '\0')
1617         return SASL_OK;
1618
1619     if (!auth_identity || !requested_user || rlen != alen ||
1620         (memcmp(auth_identity, requested_user, rlen) != 0)) {
1621         sasl_seterror(conn, 0,
1622                       "Requested identity not authenticated identity");
1623         RETURN(conn, SASL_BADAUTH);
1624     }
1625
1626     return SASL_OK;
1627 }
1628
1629 int _sasl_getcallback(sasl_conn_t * conn,
1630                       unsigned long callbackid,
1631                       int (**pproc)(),
1632                       void **pcontext)
1633 {
1634   const sasl_callback_t *callback;
1635
1636   if (!pproc || !pcontext)
1637       PARAMERROR(conn);
1638
1639   /* Some callbacks are always provided by the library */
1640   switch (callbackid) {
1641   case SASL_CB_LIST_END:
1642     /* Nothing ever gets to provide this */
1643       INTERROR(conn, SASL_FAIL);
1644   case SASL_CB_GETOPT:
1645       if (conn) {
1646           *pproc = &_sasl_conn_getopt;
1647           *pcontext = conn;
1648       } else {
1649           *pproc = &_sasl_global_getopt;
1650           *pcontext = NULL;
1651       }
1652       return SASL_OK;
1653   }
1654
1655   /* If it's not always provided by the library, see if there's
1656    * a version provided by the application for this connection... */
1657   if (conn && conn->callbacks) {
1658     for (callback = conn->callbacks; callback->id != SASL_CB_LIST_END;
1659          callback++) {
1660         if (callback->id == callbackid) {
1661             *pproc = callback->proc;
1662             *pcontext = callback->context;
1663             if (callback->proc) {
1664                 return SASL_OK;
1665             } else {
1666                 return SASL_INTERACT;
1667             }
1668         }
1669     }
1670   }
1671
1672   /* And, if not for this connection, see if there's one
1673    * for all {server,client} connections... */
1674   if (conn && conn->global_callbacks && conn->global_callbacks->callbacks) {
1675       for (callback = conn->global_callbacks->callbacks;
1676            callback->id != SASL_CB_LIST_END;
1677            callback++) {
1678           if (callback->id == callbackid) {
1679               *pproc = callback->proc;
1680               *pcontext = callback->context;
1681               if (callback->proc) {
1682                   return SASL_OK;
1683               } else {
1684                   return SASL_INTERACT;
1685               }
1686           }
1687       }
1688   }
1689
1690   /* Otherwise, see if the library provides a default callback. */
1691   switch (callbackid) {
1692 #ifdef HAVE_SYSLOG
1693   case SASL_CB_LOG:
1694     *pproc = (int (*)()) &_sasl_syslog;
1695     *pcontext = conn;
1696     return SASL_OK;
1697 #endif /* HAVE_SYSLOG */
1698   case SASL_CB_GETPATH:
1699     *pproc = default_getpath_cb.proc;
1700     *pcontext = default_getpath_cb.context;
1701     return SASL_OK;
1702   case SASL_CB_GETCONFPATH:
1703     *pproc = default_getconfpath_cb.proc;
1704     *pcontext = default_getconfpath_cb.context;
1705     return SASL_OK;
1706   case SASL_CB_AUTHNAME:
1707     *pproc = (int (*)()) &_sasl_getsimple;
1708     *pcontext = conn;
1709     return SASL_OK;
1710   case SASL_CB_VERIFYFILE:
1711     *pproc = & _sasl_verifyfile;
1712     *pcontext = NULL;
1713     return SASL_OK;
1714   case SASL_CB_PROXY_POLICY:
1715     *pproc = (int (*)()) &_sasl_proxy_policy;
1716     *pcontext = NULL;
1717     return SASL_OK;
1718   }
1719
1720   /* Unable to find a callback... */
1721   *pproc = NULL;
1722   *pcontext = NULL;
1723   sasl_seterror(conn, SASL_NOLOG, "Unable to find a callback: %d", callbackid);
1724   RETURN(conn,SASL_FAIL);
1725 }
1726
1727
1728 /*
1729  * This function is typically called from a plugin.
1730  * It creates a string from the formatting and varargs given
1731  * and calls the logging callback (syslog by default)
1732  *
1733  * %m will parse the value in the next argument as an errno string
1734  * %z will parse the next argument as a SASL error code.
1735  */
1736
1737 void
1738 _sasl_log (sasl_conn_t *conn,
1739            int level,
1740            const char *fmt,
1741            ...)
1742 {
1743   char *out=(char *) sasl_ALLOC(250);
1744   size_t alloclen=100; /* current allocated length */
1745   size_t outlen=0; /* current length of output buffer */
1746   size_t formatlen;
1747   size_t pos=0; /* current position in format string */
1748   int result;
1749   sasl_log_t *log_cb;
1750   void *log_ctx;
1751
1752   int ival;
1753   unsigned int uval;
1754   char *cval;
1755   va_list ap; /* varargs thing */
1756
1757   if(!fmt) goto done;
1758   if(!out) return;
1759
1760   formatlen = strlen(fmt);
1761
1762   /* See if we have a logging callback... */
1763   result = _sasl_getcallback(conn, SASL_CB_LOG, &log_cb, &log_ctx);
1764   if (result == SASL_OK && ! log_cb)
1765     result = SASL_FAIL;
1766   if (result != SASL_OK) goto done;
1767
1768   va_start(ap, fmt); /* start varargs */
1769
1770   while(pos<formatlen)
1771   {
1772     if (fmt[pos]!='%') /* regular character */
1773     {
1774       result = _buf_alloc(&out, &alloclen, outlen+1);
1775       if (result != SASL_OK) goto done;
1776       out[outlen]=fmt[pos];
1777       outlen++;
1778       pos++;
1779
1780     } else { /* formating thing */
1781       int done=0;
1782       char frmt[10];
1783       int frmtpos=1;
1784       char tempbuf[21];
1785       frmt[0]='%';
1786       pos++;
1787
1788       while (done==0)
1789       {
1790         switch(fmt[pos])
1791           {
1792           case 's': /* need to handle this */
1793             cval = va_arg(ap, char *); /* get the next arg */
1794             result = _sasl_add_string(&out, &alloclen,
1795                                 &outlen, cval);
1796
1797             if (result != SASL_OK) /* add the string */
1798                 goto done;
1799
1800             done=1;
1801             break;
1802
1803           case '%': /* double % output the '%' character */
1804             result = _buf_alloc(&out,&alloclen,outlen+1);
1805             if (result != SASL_OK)
1806                 goto done;
1807
1808             out[outlen]='%';
1809             outlen++;
1810             done=1;
1811             break;
1812
1813           case 'm': /* insert the errno string */
1814             result = _sasl_add_string(&out, &alloclen, &outlen,
1815                                 strerror(va_arg(ap, int)));
1816             if (result != SASL_OK)
1817                 goto done;
1818
1819             done=1;
1820             break;
1821
1822           case 'z': /* insert the sasl error string */
1823             result = _sasl_add_string(&out, &alloclen, &outlen,
1824                                 (char *) sasl_errstring(va_arg(ap, int),NULL,NULL));
1825             if (result != SASL_OK)
1826                 goto done;
1827
1828             done=1;
1829             break;
1830
1831           case 'c':
1832             frmt[frmtpos++]=fmt[pos];
1833             frmt[frmtpos]=0;
1834             tempbuf[0] = (char) va_arg(ap, int); /* get the next arg */
1835             tempbuf[1]='\0';
1836
1837             /* now add the character */
1838             result = _sasl_add_string(&out, &alloclen, &outlen, tempbuf);
1839             if (result != SASL_OK)
1840                 goto done;
1841
1842             done=1;
1843             break;
1844
1845           case 'd':
1846           case 'i':
1847             frmt[frmtpos++]=fmt[pos];
1848             frmt[frmtpos]=0;
1849             ival = va_arg(ap, int); /* get the next arg */
1850
1851             snprintf(tempbuf,20,frmt,ival); /* have snprintf do the work */
1852             /* now add the string */
1853             result = _sasl_add_string(&out, &alloclen, &outlen, tempbuf);
1854             if (result != SASL_OK)
1855                 goto done;
1856
1857             done=1;
1858             break;
1859
1860           case 'o':
1861           case 'u':
1862           case 'x':
1863           case 'X':
1864             frmt[frmtpos++]=fmt[pos];
1865             frmt[frmtpos]=0;
1866             uval = va_arg(ap, unsigned int); /* get the next arg */
1867
1868             snprintf(tempbuf,20,frmt,uval); /* have snprintf do the work */
1869             /* now add the string */
1870             result = _sasl_add_string(&out, &alloclen, &outlen, tempbuf);
1871             if (result != SASL_OK)
1872                 goto done;
1873
1874             done=1;
1875             break;
1876
1877           default:
1878             frmt[frmtpos++]=fmt[pos]; /* add to the formating */
1879             frmt[frmtpos]=0;
1880             if (frmtpos>9)
1881               done=1;
1882           }
1883         pos++;
1884         if (pos>formatlen)
1885           done=1;
1886       }
1887
1888     }
1889   }
1890
1891   /* put 0 at end */
1892   result = _buf_alloc(&out, &alloclen, outlen+1);
1893   if (result != SASL_OK) goto done;
1894   out[outlen]=0;
1895
1896   va_end(ap);
1897
1898   /* send log message */
1899   result = log_cb(log_ctx, level, out);
1900
1901  done:
1902   if(out) sasl_FREE(out);
1903 }
1904
1905
1906
1907 /* Allocate and Init a sasl_utils_t structure */
1908 sasl_utils_t *
1909 _sasl_alloc_utils(sasl_conn_t *conn,
1910                   sasl_global_callbacks_t *global_callbacks)
1911 {
1912   sasl_utils_t *utils;
1913   /* set util functions - need to do rest*/
1914   utils=sasl_ALLOC(sizeof(sasl_utils_t));
1915   if (utils==NULL)
1916     return NULL;
1917
1918   utils->conn = conn;
1919
1920   sasl_randcreate(&utils->rpool);
1921
1922   if (conn) {
1923     utils->getopt = &_sasl_conn_getopt;
1924     utils->getopt_context = conn;
1925   } else {
1926     utils->getopt = &_sasl_global_getopt;
1927     utils->getopt_context = global_callbacks;
1928   }
1929
1930   utils->malloc=_sasl_allocation_utils.malloc;
1931   utils->calloc=_sasl_allocation_utils.calloc;
1932   utils->realloc=_sasl_allocation_utils.realloc;
1933   utils->free=_sasl_allocation_utils.free;
1934
1935   utils->mutex_alloc = _sasl_mutex_utils.alloc;
1936   utils->mutex_lock = _sasl_mutex_utils.lock;
1937   utils->mutex_unlock = _sasl_mutex_utils.unlock;
1938   utils->mutex_free = _sasl_mutex_utils.free;
1939
1940   utils->MD5Init  = &_sasl_MD5Init;
1941   utils->MD5Update= &_sasl_MD5Update;
1942   utils->MD5Final = &_sasl_MD5Final;
1943   utils->hmac_md5 = &_sasl_hmac_md5;
1944   utils->hmac_md5_init = &_sasl_hmac_md5_init;
1945   utils->hmac_md5_final = &_sasl_hmac_md5_final;
1946   utils->hmac_md5_precalc = &_sasl_hmac_md5_precalc;
1947   utils->hmac_md5_import = &_sasl_hmac_md5_import;
1948   utils->mkchal = &sasl_mkchal;
1949   utils->utf8verify = &sasl_utf8verify;
1950   utils->rand=&sasl_rand;
1951   utils->churn=&sasl_churn;
1952   utils->checkpass=NULL;
1953
1954   utils->encode64=&sasl_encode64;
1955   utils->decode64=&sasl_decode64;
1956
1957   utils->erasebuffer=&sasl_erasebuffer;
1958
1959   utils->getprop=&sasl_getprop;
1960   utils->setprop=&sasl_setprop;
1961
1962   utils->getcallback=&_sasl_getcallback;
1963
1964   utils->log=&_sasl_log;
1965
1966   utils->seterror=&sasl_seterror;
1967
1968 #ifndef macintosh
1969   /* Aux Property Utilities */
1970   utils->prop_new=&prop_new;
1971   utils->prop_dup=&prop_dup;
1972   utils->prop_request=&prop_request;
1973   utils->prop_get=&prop_get;
1974   utils->prop_getnames=&prop_getnames;
1975   utils->prop_clear=&prop_clear;
1976   utils->prop_dispose=&prop_dispose;
1977   utils->prop_format=&prop_format;
1978   utils->prop_set=&prop_set;
1979   utils->prop_setvals=&prop_setvals;
1980   utils->prop_erase=&prop_erase;
1981   utils->auxprop_store=&sasl_auxprop_store;
1982 #endif
1983
1984   /* Spares */
1985   utils->spare_fptr = NULL;
1986   utils->spare_fptr1 = utils->spare_fptr2 = NULL;
1987
1988   return utils;
1989 }
1990
1991 int
1992 _sasl_free_utils(const sasl_utils_t ** utils)
1993 {
1994     sasl_utils_t *nonconst;
1995
1996     if(!utils) return SASL_BADPARAM;
1997     if(!*utils) return SASL_OK;
1998
1999     /* I wish we could avoid this cast, it's pretty gratuitous but it
2000      * does make life easier to have it const everywhere else. */
2001     nonconst = (sasl_utils_t *)(*utils);
2002
2003     sasl_randfree(&(nonconst->rpool));
2004     sasl_FREE(nonconst);
2005
2006     *utils = NULL;
2007     return SASL_OK;
2008 }
2009
2010 int sasl_idle(sasl_conn_t *conn)
2011 {
2012   if (! conn) {
2013     if (_sasl_server_idle_hook
2014         && _sasl_server_idle_hook(NULL))
2015       return 1;
2016     if (_sasl_client_idle_hook
2017         && _sasl_client_idle_hook(NULL))
2018       return 1;
2019     return 0;
2020   }
2021
2022   if (conn->idle_hook)
2023     return conn->idle_hook(conn);
2024
2025   return 0;
2026 }
2027
2028 static const sasl_callback_t *
2029 _sasl_find_callback_by_type (const sasl_callback_t *callbacks,
2030                              unsigned long id)
2031 {
2032     if (callbacks) {
2033         while (callbacks->id != SASL_CB_LIST_END) {
2034             if (callbacks->id == id) {
2035                 return callbacks;
2036             } else {
2037                 ++callbacks;
2038             }
2039         }
2040     }
2041     return NULL;
2042 }
2043
2044 const sasl_callback_t *
2045 _sasl_find_getpath_callback(const sasl_callback_t *callbacks)
2046 {
2047   callbacks = _sasl_find_callback_by_type (callbacks, SASL_CB_GETPATH);
2048   if (callbacks != NULL) {
2049     return callbacks;
2050   } else {
2051     return &default_getpath_cb;
2052   }
2053 }
2054
2055 const sasl_callback_t *
2056 _sasl_find_getconfpath_callback(const sasl_callback_t *callbacks)
2057 {
2058   callbacks = _sasl_find_callback_by_type (callbacks, SASL_CB_GETCONFPATH);
2059   if (callbacks != NULL) {
2060     return callbacks;
2061   } else {
2062     return &default_getconfpath_cb;
2063   }
2064 }
2065
2066 const sasl_callback_t *
2067 _sasl_find_verifyfile_callback(const sasl_callback_t *callbacks)
2068 {
2069   static const sasl_callback_t default_verifyfile_cb = {
2070     SASL_CB_VERIFYFILE,
2071     &_sasl_verifyfile,
2072     NULL
2073   };
2074
2075   callbacks = _sasl_find_callback_by_type (callbacks, SASL_CB_VERIFYFILE);
2076   if (callbacks != NULL) {
2077     return callbacks;
2078   } else {
2079     return &default_verifyfile_cb;
2080   }
2081 }
2082
2083 /* Basically a conditional call to realloc(), if we need more */
2084 int _buf_alloc(char **rwbuf, size_t *curlen, size_t newlen)
2085 {
2086     if(!(*rwbuf)) {
2087         *rwbuf = sasl_ALLOC((unsigned)newlen);
2088         if (*rwbuf == NULL) {
2089             *curlen = 0;
2090             return SASL_NOMEM;
2091         }
2092         *curlen = newlen;
2093     } else if(*rwbuf && *curlen < newlen) {
2094         size_t needed = 2*(*curlen);
2095
2096         while(needed < newlen)
2097             needed *= 2;
2098
2099         /* WARN - We will leak the old buffer on failure */
2100         *rwbuf = sasl_REALLOC(*rwbuf, (unsigned)needed);
2101
2102         if (*rwbuf == NULL) {
2103             *curlen = 0;
2104             return SASL_NOMEM;
2105         }
2106         *curlen = needed;
2107     }
2108
2109     return SASL_OK;
2110 }
2111
2112 /* for the mac os x cfm glue: this lets the calling function
2113    get pointers to the error buffer without having to touch the sasl_conn_t struct */
2114 void _sasl_get_errorbuf(sasl_conn_t *conn, char ***bufhdl, size_t **lenhdl)
2115 {
2116         *bufhdl = &conn->error_buf;
2117         *lenhdl = &conn->error_buf_len;
2118 }
2119
2120 /* convert an iovec to a single buffer */
2121 int _iovec_to_buf(const struct iovec *vec,
2122                   unsigned numiov, buffer_info_t **output)
2123 {
2124     unsigned i;
2125     int ret;
2126     buffer_info_t *out;
2127     char *pos;
2128
2129     if (!vec || !output) return SASL_BADPARAM;
2130
2131     if (!(*output)) {
2132         *output = sasl_ALLOC(sizeof(buffer_info_t));
2133         if (!*output) return SASL_NOMEM;
2134         memset(*output,0,sizeof(buffer_info_t));
2135     }
2136
2137     out = *output;
2138
2139     out->curlen = 0;
2140     for (i = 0; i < numiov; i++) {
2141         out->curlen += vec[i].iov_len;
2142     }
2143
2144     ret = _buf_alloc(&out->data, &out->reallen, out->curlen);
2145
2146     if (ret != SASL_OK) return SASL_NOMEM;
2147
2148     memset(out->data, 0, out->reallen);
2149     pos = out->data;
2150
2151     for (i = 0; i < numiov; i++) {
2152         memcpy(pos, vec[i].iov_base, vec[i].iov_len);
2153         pos += vec[i].iov_len;
2154     }
2155
2156     return SASL_OK;
2157 }
2158
2159 /* This code might be useful in the future, but it isn't now, so.... */
2160 #if 0
2161 int _sasl_iptostring(const struct sockaddr *addr, socklen_t addrlen,
2162                      char *out, unsigned outlen) {
2163     char hbuf[NI_MAXHOST], pbuf[NI_MAXSERV];
2164     int niflags;
2165
2166     if(!addr || !out) return SASL_BADPARAM;
2167
2168     niflags = (NI_NUMERICHOST | NI_NUMERICSERV);
2169 #ifdef NI_WITHSCOPEID
2170     if (addr->sa_family == AF_INET6)
2171         niflags |= NI_WITHSCOPEID;
2172 #endif
2173     if (getnameinfo(addr, addrlen, hbuf, sizeof(hbuf), pbuf, sizeof(pbuf),
2174                     niflags) != 0)
2175         return SASL_BADPARAM;
2176
2177     if(outlen < strlen(hbuf) + strlen(pbuf) + 2)
2178         return SASL_BUFOVER;
2179
2180     snprintf(out, outlen, "%s;%s", hbuf, pbuf);
2181
2182     return SASL_OK;
2183 }
2184 #endif
2185
2186 int _sasl_ipfromstring(const char *addr,
2187                        struct sockaddr *out, socklen_t outlen)
2188 {
2189     int i, j;
2190     struct addrinfo hints, *ai = NULL;
2191     char hbuf[NI_MAXHOST];
2192
2193     /* A NULL out pointer just implies we don't do a copy, just verify it */
2194
2195     if(!addr) return SASL_BADPARAM;
2196
2197     /* Parse the address */
2198     for (i = 0; addr[i] != '\0' && addr[i] != ';'; i++) {
2199         if (i >= NI_MAXHOST)
2200             return SASL_BADPARAM;
2201         hbuf[i] = addr[i];
2202     }
2203     hbuf[i] = '\0';
2204
2205     if (addr[i] == ';')
2206         i++;
2207     /* XXX: Do we need this check? */
2208     for (j = i; addr[j] != '\0'; j++)
2209         if (!isdigit((int)(addr[j])))
2210             return SASL_BADPARAM;
2211
2212     memset(&hints, 0, sizeof(hints));
2213     hints.ai_family = PF_UNSPEC;
2214     hints.ai_socktype = SOCK_STREAM;
2215     hints.ai_flags = AI_PASSIVE | AI_NUMERICHOST;
2216     if (getaddrinfo(hbuf, &addr[i], &hints, &ai) != 0)
2217         return SASL_BADPARAM;
2218
2219     if (out) {
2220         if (outlen < (socklen_t)ai->ai_addrlen) {
2221             freeaddrinfo(ai);
2222             return SASL_BUFOVER;
2223         }
2224         memcpy(out, ai->ai_addr, ai->ai_addrlen);
2225     }
2226
2227     freeaddrinfo(ai);
2228
2229     return SASL_OK;
2230 }
2231
2232 int _sasl_build_mechlist(void)
2233 {
2234     int count = 0;
2235     sasl_string_list_t *clist = NULL, *slist = NULL, *olist = NULL;
2236     sasl_string_list_t *p, *q, **last, *p_next;
2237
2238     clist = _sasl_client_mechs();
2239     slist = _sasl_server_mechs();
2240
2241     if(!clist) {
2242         olist = slist;
2243     } else {
2244         int flag;
2245
2246         /* append slist to clist, and set olist to clist */
2247         for(p = slist; p; p = p_next) {
2248             flag = 0;
2249             p_next = p->next;
2250
2251             last = &clist;
2252             for(q = clist; q; q = q->next) {
2253                 if(!strcmp(q->d, p->d)) {
2254                     /* They match, set the flag */
2255                     flag = 1;
2256                     break;
2257                 }
2258                 last = &(q->next);
2259             }
2260
2261             if(!flag) {
2262                 *last = p;
2263                 p->next = NULL;
2264             } else {
2265                 sasl_FREE(p);
2266             }
2267         }
2268
2269         olist = clist;
2270     }
2271
2272     if(!olist) {
2273         printf ("no olist");
2274         return SASL_FAIL;
2275     }
2276
2277     for (p = olist; p; p = p->next) count++;
2278
2279     if(global_mech_list) {
2280         sasl_FREE(global_mech_list);
2281         global_mech_list = NULL;
2282     }
2283
2284     global_mech_list = sasl_ALLOC((count + 1) * sizeof(char *));
2285     if(!global_mech_list) return SASL_NOMEM;
2286
2287     memset(global_mech_list, 0, (count + 1) * sizeof(char *));
2288
2289     count = 0;
2290     for (p = olist; p; p = p_next) {
2291         p_next = p->next;
2292
2293         global_mech_list[count++] = (char *) p->d;
2294
2295         sasl_FREE(p);
2296     }
2297
2298     return SASL_OK;
2299 }
2300
2301 const char ** sasl_global_listmech(void)
2302 {
2303     return (const char **)global_mech_list;
2304 }
2305
2306 int sasl_listmech(sasl_conn_t *conn,
2307                   const char *user,
2308                   const char *prefix,
2309                   const char *sep,
2310                   const char *suffix,
2311                   const char **result,
2312                   unsigned *plen,
2313                   int *pcount)
2314 {
2315     if(!conn) {
2316         return SASL_BADPARAM;
2317     } else if(conn->type == SASL_CONN_SERVER) {
2318         RETURN(conn, _sasl_server_listmech(conn, user, prefix, sep, suffix,
2319                                            result, plen, pcount));
2320     } else if (conn->type == SASL_CONN_CLIENT) {
2321         RETURN(conn, _sasl_client_listmech(conn, prefix, sep, suffix,
2322                                            result, plen, pcount));
2323     }
2324
2325     PARAMERROR(conn);
2326 }
2327
2328 int _sasl_is_equal_mech(const char *req_mech,
2329                         const char *plug_mech,
2330                         int *plus)
2331 {
2332     size_t len = strlen(req_mech);
2333     size_t n;
2334
2335     if (len > 5 &&
2336         strcasecmp(&req_mech[len - 5], "-PLUS") == 0) {
2337         n = len - 5;
2338         *plus = 1;
2339     } else {
2340         n = len;
2341         *plus = 0;
2342     }
2343
2344     return (strncasecmp(req_mech, plug_mech, n) == 0);
2345 }
2346
2347 #ifndef WIN32
2348 static char *
2349 _sasl_get_default_unix_path(void *context __attribute__((unused)),
2350                             char * env_var_name,
2351                             char * default_value)
2352 {
2353     char *path = NULL;
2354
2355     /* Honor external variable only in a safe environment */
2356     if (getuid() == geteuid() && getgid() == getegid()) {
2357         path = getenv(env_var_name);
2358     }
2359     if (! path) {
2360         path = default_value;
2361     }
2362
2363     return path;
2364 }
2365
2366 #else
2367 /* Return NULL on failure */
2368 static char *
2369 _sasl_get_default_win_path(void *context __attribute__((unused)),
2370                            char * reg_attr_name,
2371                            char * default_value)
2372 {
2373     /* Open registry entry, and find all registered SASL libraries.
2374      *
2375      * Registry location:
2376      *
2377      *     SOFTWARE\\Carnegie Mellon\\Project Cyrus\\SASL Library
2378      *
2379      * Key - value:
2380      *
2381      *     "SearchPath" - value: PATH like (';' delimited) list
2382      *                    of directories where to search for plugins
2383      *                    The list may contain references to environment
2384      *                    variables (e.g. %PATH%).
2385      *
2386      */
2387     HKEY  hKey;
2388     DWORD ret;
2389     DWORD ValueType;                /* value type */
2390     DWORD cbData;                   /* value size */
2391     BYTE * ValueData;               /* value */
2392     DWORD cbExpandedData;           /* "expanded" value size */
2393     BYTE * ExpandedValueData;       /* "expanded" value */
2394     char * return_value;            /* function return value */
2395     char * tmp;
2396
2397     /* Initialization */
2398     ExpandedValueData = NULL;
2399     ValueData = NULL;
2400     return_value = NULL;
2401
2402     /* Open the registry */
2403     ret = RegOpenKeyEx(HKEY_LOCAL_MACHINE,
2404                        SASL_ROOT_KEY,
2405                        0,
2406                        KEY_READ,
2407                        &hKey);
2408
2409     if (ret != ERROR_SUCCESS) {
2410         /* no registry entry */
2411         (void) _sasl_strdup (default_value, &return_value, NULL);
2412         return return_value;
2413     }
2414
2415     /* figure out value type and required buffer size */
2416     /* the size will include space for terminating NUL if required */
2417     RegQueryValueEx (hKey,
2418                      reg_attr_name,
2419                      NULL,          /* reserved */
2420                      &ValueType,
2421                      NULL,
2422                      &cbData);
2423
2424     /* Only accept string related types */
2425     if (ValueType != REG_EXPAND_SZ &&
2426         ValueType != REG_MULTI_SZ &&
2427         ValueType != REG_SZ) {
2428         return_value = NULL;
2429         goto CLEANUP;
2430     }
2431
2432     /* Any high water mark? */
2433     ValueData = sasl_ALLOC(cbData);
2434     if (ValueData == NULL) {
2435         return_value = NULL;
2436         goto CLEANUP;
2437     };
2438
2439     RegQueryValueEx (hKey,
2440                      reg_attr_name,
2441                      NULL,          /* reserved */
2442                      &ValueType,
2443                      ValueData,
2444                      &cbData);
2445
2446     switch (ValueType) {
2447     case REG_EXPAND_SZ:
2448         /* : A random starting guess */
2449         cbExpandedData = cbData + 1024;
2450         ExpandedValueData = sasl_ALLOC(cbExpandedData);
2451         if (ExpandedValueData == NULL) {
2452             return_value = NULL;
2453             goto CLEANUP;
2454         };
2455
2456         cbExpandedData = ExpandEnvironmentStrings(
2457                                                   ValueData,
2458                                                   ExpandedValueData,
2459                                                   cbExpandedData);
2460
2461         if (cbExpandedData == 0) {
2462             /* : GetLastError() contains the reason for failure */
2463             return_value = NULL;
2464             goto CLEANUP;
2465         }
2466
2467         /* : Must retry expansion with the bigger buffer */
2468         if (cbExpandedData > cbData + 1024) {
2469             /* : Memory leak here if can't realloc */
2470             ExpandedValueData = sasl_REALLOC(ExpandedValueData, cbExpandedData);
2471             if (ExpandedValueData == NULL) {
2472                 return_value = NULL;
2473                 goto CLEANUP;
2474             };
2475
2476             cbExpandedData = ExpandEnvironmentStrings(
2477                                                       ValueData,
2478                                                       ExpandedValueData,
2479                                                       cbExpandedData);
2480
2481             /* : This should not happen */
2482             if (cbExpandedData == 0) {
2483                 /* : GetLastError() contains the reason for failure */
2484                 return_value = NULL;
2485                 goto CLEANUP;
2486             }
2487         }
2488
2489         sasl_FREE(ValueData);
2490         ValueData = ExpandedValueData;
2491         /* : This is to prevent automatical freeing of this block on cleanup */
2492         ExpandedValueData = NULL;
2493
2494         break;
2495
2496     case REG_MULTI_SZ:
2497         tmp = ValueData;
2498
2499         /* : We shouldn't overflow here, as the buffer is guarantied
2500            : to contain at least two consequent NULs */
2501         while (1) {
2502             if (tmp[0] == '\0') {
2503                 /* : Stop the process if we found the end of the string (two consequent NULs) */
2504                 if (tmp[1] == '\0') {
2505                     break;
2506                 }
2507
2508                 /* : Replace delimiting NUL with our delimiter characted */
2509                 tmp[0] = PATHS_DELIMITER;
2510             }
2511             tmp += strlen(tmp);
2512         }
2513         break;
2514
2515     case REG_SZ:
2516         /* Do nothing, it is good as is */
2517         break;
2518
2519     default:
2520         return_value = NULL;
2521         goto CLEANUP;
2522     }
2523
2524     return_value = ValueData;
2525
2526 CLEANUP:
2527     RegCloseKey(hKey);
2528     if (ExpandedValueData != NULL) sasl_FREE(ExpandedValueData);
2529     if (return_value == NULL) {
2530         if (ValueData != NULL) sasl_FREE(ValueData);
2531     }
2532
2533     return (return_value);
2534 }
2535 #endif