X-Git-Url: http://www.project-moonshot.org/gitweb/?a=blobdiff_plain;f=util_radius.cpp;h=3aef0db72eb27c09d8188ed6abc6227ffff613f4;hb=15c93f06ee6ddefa7e7b095351f6e66698c7cc9e;hp=ac568a02d07eea90106b2736c62a07f85f1b6a26;hpb=c73a7d0a65c2cbef63cbdd53a860bcbda2b10d93;p=mech_eap.git diff --git a/util_radius.cpp b/util_radius.cpp index ac568a0..3aef0db 100644 --- a/util_radius.cpp +++ b/util_radius.cpp @@ -32,55 +32,30 @@ #include "gssapiP_eap.h" -static gss_buffer_desc radiusUrnPrefix = { - sizeof("urn:radius:") - 1, - (void *)"urn:radius:" -}; +/* stuff that should be provided by libradsec/libfreeradius-radius */ +#define VENDORATTR(vendor, attr) (((vendor) << 16) | (attr)) -VALUE_PAIR * -gss_eap_radius_attr_provider::copyAvps(const VALUE_PAIR *src) -{ - const VALUE_PAIR *vp; - VALUE_PAIR *dst = NULL, **pDst = &dst; +#ifndef ATTRID +#define ATTRID(attr) ((attr) & 0xFFFF) +#endif - for (vp = src; vp != NULL; vp = vp->next) { - VALUE_PAIR *vp2; - - vp2 = (VALUE_PAIR *)GSSEAP_CALLOC(1, sizeof(*vp2)); - if (vp2 == NULL) { - rc_avpair_free(dst); - return NULL; - } - memcpy(vp2, vp, sizeof(*vp)); - vp2->next = NULL; - *pDst = vp2; - pDst = &vp2->next; - } +static gss_buffer_desc radiusUrnPrefix = { + sizeof("urn:x-radius:") - 1, + (void *)"urn:x-radius:" +}; - return dst; -} +static VALUE_PAIR *copyAvps(const VALUE_PAIR *src); gss_eap_radius_attr_provider::gss_eap_radius_attr_provider(void) { - m_rh = NULL; - m_avps = NULL; + m_vps = NULL; m_authenticated = false; } gss_eap_radius_attr_provider::~gss_eap_radius_attr_provider(void) { - if (m_rh != NULL) - rc_config_free(m_rh); - if (m_avps != NULL) - rc_avpair_free(m_avps); -} - -bool -gss_eap_radius_attr_provider::initFromGssCred(const gss_cred_id_t cred) -{ - OM_uint32 minor; - - return !GSS_ERROR(gssEapRadiusAllocHandle(&minor, cred, &m_rh)); + if (m_vps != NULL) + pairfree(&m_vps); } bool @@ -92,13 +67,12 @@ gss_eap_radius_attr_provider::initFromExistingContext(const gss_eap_attr_ctx *ma if (!gss_eap_attr_provider::initFromExistingContext(manager, ctx)) return false; - if (!initFromGssCred(GSS_C_NO_CREDENTIAL)) - return false; - radius = static_cast(ctx); - if (radius->m_avps != NULL) { - m_avps = copyAvps(radius->getAvps()); - } + + if (radius->m_vps != NULL) + m_vps = copyAvps(const_cast(radius->getAvps())); + + m_authenticated = radius->m_authenticated; return true; } @@ -111,14 +85,15 @@ gss_eap_radius_attr_provider::initFromGssContext(const gss_eap_attr_ctx *manager if (!gss_eap_attr_provider::initFromGssContext(manager, gssCred, gssCtx)) return false; - if (!initFromGssCred(gssCred)) - return false; - if (gssCtx != GSS_C_NO_CONTEXT) { - if (gssCtx->acceptorCtx.avps != NULL) { - m_avps = copyAvps(gssCtx->acceptorCtx.avps); - if (m_avps == NULL) + if (gssCtx->acceptorCtx.vps != NULL) { + m_vps = copyAvps(gssCtx->acceptorCtx.vps); + if (m_vps == NULL) return false; + + /* We assume libradsec validated this for us */ + assert(pairfind(m_vps, PW_MESSAGE_AUTHENTICATOR) != NULL); + m_authenticated = true; } } @@ -139,21 +114,43 @@ alreadyAddedAttributeP(std::vector &attrs, VALUE_PAIR *vp) } static bool -isHiddenAttributeP(int attrid, int vendor) +isSecretAttributeP(uint16_t attrid, uint16_t vendor) { bool ret = false; switch (vendor) { - case VENDOR_ID_MICROSOFT: + case VENDORPEC_MS: switch (attrid) { - case VENDOR_ATTR_MS_MPPE_SEND_KEY: - case VENDOR_ATTR_MS_MPPE_RECV_KEY: + case PW_MS_MPPE_SEND_KEY: + case PW_MS_MPPE_RECV_KEY: ret = true; break; default: break; } - case VENDOR_ID_UKERNA: + default: + break; + } + + return ret; +} + +static bool +isSecretAttributeP(uint32_t attribute) +{ + return isSecretAttributeP(ATTRID(attribute), VENDOR(attribute)); +} + +static bool +isHiddenAttributeP(uint16_t attrid, uint16_t vendor) +{ + bool ret = false; + + /* should have been filtered */ + assert(!isSecretAttributeP(attrid, vendor)); + + switch (vendor) { + case VENDORPEC_UKERNA: ret = true; break; default: @@ -163,16 +160,52 @@ isHiddenAttributeP(int attrid, int vendor) return ret; } +static bool +isHiddenAttributeP(uint32_t attribute) +{ + return isHiddenAttributeP(ATTRID(attribute), VENDOR(attribute)); +} + +/* + * Copy AVP list, same as paircopy except it filters out attributes + * containing keys. + */ +static VALUE_PAIR * +copyAvps(const VALUE_PAIR *src) +{ + const VALUE_PAIR *vp; + VALUE_PAIR *dst = NULL, **pDst = &dst; + + for (vp = src; vp != NULL; vp = vp->next) { + VALUE_PAIR *vpcopy; + + if (isSecretAttributeP(vp->attribute)) + continue; + + vpcopy = paircopyvp(vp); + if (vpcopy == NULL) { + pairfree(&dst); + throw new std::bad_alloc; + return NULL; + } + *pDst = vpcopy; + pDst = &vpcopy->next; + } + + return dst; +} + bool gss_eap_radius_attr_provider::getAttributeTypes(gss_eap_attr_enumeration_cb addAttribute, void *data) const { VALUE_PAIR *vp; std::vector seen; - for (vp = m_avps; vp != NULL; vp = vp->next) { + for (vp = m_vps; vp != NULL; vp = vp->next) { gss_buffer_desc attribute; char attrid[64]; - if (isHiddenAttributeP(ATTRID(vp->attribute), VENDOR(vp->attribute))) + + if (isHiddenAttributeP(vp->attribute)) continue; if (alreadyAddedAttributeP(seen, vp)) @@ -215,11 +248,10 @@ gss_eap_radius_attr_provider::getAttribute(const gss_buffer_t attr, { OM_uint32 tmpMinor; gss_buffer_desc strAttr = GSS_C_EMPTY_BUFFER; - DICT_ATTR *d; - int attrid; + DICT_ATTR *da; + uint32_t attrid; char *s; - /* XXX vendor */ duplicateBuffer(*attr, &strAttr); s = (char *)strAttr.value; @@ -232,12 +264,12 @@ gss_eap_radius_attr_provider::getAttribute(const gss_buffer_t attr, if (isdigit(*s)) { attrid = strtoul(s, NULL, 10); } else { - d = rc_dict_findattr(m_rh, (char *)s); - if (d == NULL) { + da = dict_attrbyname(s); + if (da == NULL) { gss_release_buffer(&tmpMinor, &strAttr); return false; } - attrid = d->value; + attrid = da->attr; } gss_release_buffer(&tmpMinor, &strAttr); @@ -246,56 +278,30 @@ gss_eap_radius_attr_provider::getAttribute(const gss_buffer_t attr, value, display_value, more); } -static bool -isPrintableAttributeP(VALUE_PAIR *vp) -{ - size_t i; - int gotChar = 0; - - for (i = 0; i < sizeof(vp->strvalue); i++) { - if (gotChar && vp->strvalue[i] == '\0') - return true; - - if (!isprint(vp->strvalue[i])) - return false; - - if (!gotChar) - gotChar++; - } - - return true; -} - bool -gss_eap_radius_attr_provider::getAttribute(int attrid, - int vendor, +gss_eap_radius_attr_provider::getAttribute(uint32_t attrid, int *authenticated, int *complete, gss_buffer_t value, gss_buffer_t display_value, int *more) const { - OM_uint32 tmpMinor; VALUE_PAIR *vp; int i = *more, count = 0; - char name[NAME_LENGTH + 1]; - char displayString[AUTH_STRING_LEN + 1]; - gss_buffer_desc valueBuf = GSS_C_EMPTY_BUFFER; - gss_buffer_desc displayBuf = GSS_C_EMPTY_BUFFER; *more = 0; - if (isHiddenAttributeP(attrid, vendor)) + if (isHiddenAttributeP(attrid)) return false; if (i == -1) i = 0; - for (vp = rc_avpair_get(m_avps, attrid, vendor); + for (vp = pairfind(m_vps, attrid); vp != NULL; - vp = rc_avpair_get(vp->next, attrid, vendor)) { + vp = pairfind(vp->next, attrid)) { if (count++ == i) { - if (rc_avpair_get(vp->next, attrid, vendor) != NULL) + if (pairfind(vp->next, attrid) != NULL) *more = count; break; } @@ -304,27 +310,22 @@ gss_eap_radius_attr_provider::getAttribute(int attrid, if (vp == NULL && *more == 0) return false; - if (vp->type == PW_TYPE_STRING) { - valueBuf.value = (void *)vp->strvalue; - valueBuf.length = vp->lvalue; - } else { - valueBuf.value = (void *)&vp->lvalue; - valueBuf.length = 4; - } + if (value != GSS_C_NO_BUFFER) { + gss_buffer_desc valueBuf; + + valueBuf.value = (void *)vp->vp_octets; + valueBuf.length = vp->length; - if (value != GSS_C_NO_BUFFER) duplicateBuffer(valueBuf, value); + } - if (display_value != GSS_C_NO_BUFFER && - isPrintableAttributeP(vp)) { - if (rc_avpair_tostr(m_rh, vp, name, NAME_LENGTH, - displayString, AUTH_STRING_LEN) != 0) { - gss_release_buffer(&tmpMinor, value); - return false; - } + if (display_value != GSS_C_NO_BUFFER) { + char displayString[MAX_STRING_LEN]; + gss_buffer_desc displayBuf; + displayBuf.length = vp_prints_value(displayString, + sizeof(displayString), vp, 0); displayBuf.value = (void *)displayString; - displayBuf.length = strlen(displayString); duplicateBuffer(displayBuf, display_value); } @@ -338,15 +339,15 @@ gss_eap_radius_attr_provider::getAttribute(int attrid, } bool -gss_eap_radius_attr_provider::getFragmentedAttribute(int attribute, - int vendor, +gss_eap_radius_attr_provider::getFragmentedAttribute(uint16_t attribute, + uint16_t vendor, int *authenticated, int *complete, gss_buffer_t value) const { OM_uint32 major, minor; - major = getBufferFromAvps(&minor, m_avps, attribute, vendor, value, TRUE); + major = gssEapRadiusGetAvp(&minor, m_vps, attribute, vendor, value, TRUE); if (authenticated != NULL) *authenticated = m_authenticated; @@ -357,7 +358,8 @@ gss_eap_radius_attr_provider::getFragmentedAttribute(int attribute, } bool -gss_eap_radius_attr_provider::getAttribute(int attrid, +gss_eap_radius_attr_provider::getAttribute(uint16_t attribute, + uint16_t vendor, int *authenticated, int *complete, gss_buffer_t value, @@ -365,7 +367,7 @@ gss_eap_radius_attr_provider::getAttribute(int attrid, int *more) const { - return getAttribute(ATTRID(attrid), VENDOR(attrid), + return getAttribute(VENDORATTR(attribute, vendor), authenticated, complete, value, display_value, more); } @@ -377,14 +379,14 @@ gss_eap_radius_attr_provider::mapToAny(int authenticated, if (authenticated && !m_authenticated) return (gss_any_t)NULL; - return (gss_any_t)copyAvps(m_avps); + return (gss_any_t)copyAvps(m_vps); } void gss_eap_radius_attr_provider::releaseAnyNameMapping(gss_buffer_t type_id, gss_any_t input) const { - rc_avpair_free((VALUE_PAIR *)input); + pairfree((VALUE_PAIR **)&input); } bool @@ -409,42 +411,77 @@ gss_eap_radius_attr_provider::createAttrContext(void) } OM_uint32 -addAvpFromBuffer(OM_uint32 *minor, - rc_handle *rh, - VALUE_PAIR **vp, - int type, - int vendor, - gss_buffer_t buffer) -{ - if (rc_avpair_add(rh, vp, type, - buffer->value, buffer->length, vendor) == NULL) { - return GSS_S_FAILURE; - } +gssEapRadiusAddAvp(OM_uint32 *minor, + VALUE_PAIR **vps, + uint16_t attribute, + uint16_t vendor, + gss_buffer_t buffer) +{ + uint32_t attrid = VENDORATTR(vendor, attribute); + unsigned char *p = (unsigned char *)buffer->value; + size_t remain = buffer->length; + + do { + VALUE_PAIR *vp; + size_t n = remain; + + if (n > MAX_STRING_LEN) + n = MAX_STRING_LEN; + + vp = paircreate(attrid, PW_TYPE_OCTETS); + if (vp == NULL) { + *minor = ENOMEM; + return GSS_S_FAILURE; + } + + memcpy(vp->vp_octets, p, n); + vp->length = n; + + pairadd(vps, vp); + + p += n; + remain -= n; + } while (remain != 0); return GSS_S_COMPLETE; } OM_uint32 -getBufferFromAvps(OM_uint32 *minor, - VALUE_PAIR *vps, - int type, - int vendor, - gss_buffer_t buffer, - int concat) +gssEapRadiusGetRawAvp(OM_uint32 *minor, + VALUE_PAIR *vps, + uint16_t attribute, + uint16_t vendor, + VALUE_PAIR **vp) +{ + uint32_t attr = VENDORATTR(vendor, attribute); + + *vp = pairfind(vps, attr); + + return (*vp == NULL) ? GSS_S_UNAVAILABLE : GSS_S_COMPLETE; +} + +OM_uint32 +gssEapRadiusGetAvp(OM_uint32 *minor, + VALUE_PAIR *vps, + uint16_t attribute, + uint16_t vendor, + gss_buffer_t buffer, + int concat) { VALUE_PAIR *vp; unsigned char *p; + uint32_t attr = VENDORATTR(vendor, attribute); buffer->length = 0; buffer->value = NULL; - vp = rc_avpair_get(vps, type, vendor); + vp = pairfind(vps, attr); if (vp == NULL) return GSS_S_UNAVAILABLE; do { - buffer->length += vp->lvalue; - } while (concat && (vp = rc_avpair_get(vp->next, type, vendor)) != NULL); + buffer->length += vp->length; + } while (concat && (vp = pairfind(vp->next, attr)) != NULL); buffer->value = GSSEAP_MALLOC(buffer->length); if (buffer->value == NULL) { @@ -454,11 +491,11 @@ getBufferFromAvps(OM_uint32 *minor, p = (unsigned char *)buffer->value; - for (vp = rc_avpair_get(vps, type, vendor); + for (vp = pairfind(vps, attr); concat && vp != NULL; - vp = rc_avpair_get(vp->next, type, vendor)) { - memcpy(p, vp->strvalue, vp->lvalue); - p += vp->lvalue; + vp = pairfind(vp->next, attr)) { + memcpy(p, vp->vp_octets, vp->length); + p += vp->length; } *minor = 0; @@ -466,56 +503,45 @@ getBufferFromAvps(OM_uint32 *minor, } OM_uint32 -gssEapRadiusAttrProviderInit(OM_uint32 *minor) +gssEapRadiusFreeAvps(OM_uint32 *minor, + VALUE_PAIR **vps) { - return gss_eap_radius_attr_provider::init() - ? GSS_S_COMPLETE : GSS_S_FAILURE; -} - -OM_uint32 -gssEapRadiusAttrProviderFinalize(OM_uint32 *minor) -{ - gss_eap_radius_attr_provider::finalize(); + pairfree(vps); + *minor = 0; return GSS_S_COMPLETE; } OM_uint32 -gssEapRadiusAllocHandle(OM_uint32 *minor, - const gss_cred_id_t cred, - rc_handle **pHandle) +gssEapRadiusAttrProviderInit(OM_uint32 *minor) { - rc_handle *rh; - const char *config = RC_CONFIG_FILE; - - *pHandle = NULL; - - if (cred != GSS_C_NO_CREDENTIAL && cred->radiusConfigFile != NULL) - config = cred->radiusConfigFile; - - rh = rc_read_config((char *)config); - if (rh == NULL) { - *minor = errno; - rc_config_free(rh); + if (!gss_eap_radius_attr_provider::init()) { + *minor = GSSEAP_RADSEC_INIT_FAILURE; return GSS_S_FAILURE; } - if (rc_read_dictionary(rh, rc_conf_str(rh, (char *)"dictionary")) != 0) { - *minor = errno; - return GSS_S_FAILURE; - } + return GSS_S_COMPLETE; +} - *pHandle = rh; +OM_uint32 +gssEapRadiusAttrProviderFinalize(OM_uint32 *minor) +{ + gss_eap_radius_attr_provider::finalize(); return GSS_S_COMPLETE; } /* - * This is a super-inefficient coding but the API is going to change - * as are the data structures, so not putting a lot of work in now. + * Encoding is: + * 4 octet NBO attribute ID | 4 octet attribute length | attribute data */ static size_t avpSize(const VALUE_PAIR *vp) { - return NAME_LENGTH + 1 + 12 + AUTH_STRING_LEN + 1; + size_t size = 4 + 1; + + if (vp != NULL) + size += vp->length; + + return size; } static bool @@ -528,23 +554,24 @@ avpExport(const VALUE_PAIR *vp, assert(remain >= avpSize(vp)); - memcpy(p, vp->name, NAME_LENGTH + 1); - p += NAME_LENGTH + 1; - remain -= NAME_LENGTH + 1; - - store_uint32_be(vp->attribute, &p[0]); - store_uint32_be(vp->type, &p[4]); - store_uint32_be(vp->lvalue, &p[8]); + store_uint32_be(vp->attribute, p); - p += 12; - remain -= 12; - - memcpy(p, vp->strvalue, AUTH_STRING_LEN + 1); - p += AUTH_STRING_LEN + 1; - remain -= AUTH_STRING_LEN + 1; + switch (vp->type) { + case PW_TYPE_INTEGER: + case PW_TYPE_IPADDR: + case PW_TYPE_DATE: + p[4] = 4; + store_uint32_be(vp->lvalue, p + 5); + break; + default: + assert(vp->length <= MAX_STRING_LEN); + p[4] = (uint8_t)vp->length; + memcpy(p + 5, vp->vp_octets, vp->length); + break; + } - *pBuffer = p; - *pRemain = remain; + *pBuffer += 5 + p[4]; + *pRemain -= 5 + p[4]; return true; @@ -557,39 +584,72 @@ avpImport(VALUE_PAIR **pVp, { unsigned char *p = *pBuffer; size_t remain = *pRemain; - VALUE_PAIR *vp; + VALUE_PAIR *vp = NULL; + DICT_ATTR *da; + uint32_t attrid; - if (remain < avpSize(NULL)) { - return false; - } + if (remain < avpSize(NULL)) + goto fail; + + attrid = load_uint32_be(p); + p += 4; + remain -= 4; - vp = (VALUE_PAIR *)GSSEAP_CALLOC(1, sizeof(*vp)); + da = dict_attrbyvalue(attrid); + if (da == NULL) + goto fail; + + vp = pairalloc(da); if (vp == NULL) { throw new std::bad_alloc; - return false; + goto fail; } - vp->next = NULL; - memcpy(vp->name, p, NAME_LENGTH + 1); - p += NAME_LENGTH + 1; - remain -= NAME_LENGTH + 1; + if (remain < p[0]) + goto fail; + + switch (vp->type) { + case PW_TYPE_INTEGER: + case PW_TYPE_IPADDR: + case PW_TYPE_DATE: + if (p[0] != 4) + goto fail; - vp->attribute = load_uint32_be(&p[0]); - vp->type = load_uint32_be(&p[4]); - vp->lvalue = load_uint32_be(&p[8]); + vp->length = 4; + vp->lvalue = load_uint32_be(p + 1); + p += 5; + remain -= 5; + break; + case PW_TYPE_STRING: + /* check enough room to NUL terminate */ + if (p[0] == MAX_STRING_LEN) + goto fail; + else + /* fallthrough */ + default: + if (p[0] > MAX_STRING_LEN) + goto fail; - p += 12; - remain -= 12; + vp->length = (uint32_t)p[0]; + memcpy(vp->vp_octets, p + 1, vp->length); - memcpy(vp->strvalue, p, AUTH_STRING_LEN + 1); - p += AUTH_STRING_LEN + 1; - remain -= AUTH_STRING_LEN + 1; + if (vp->type == PW_TYPE_STRING) + vp->vp_strvalue[vp->length] = '\0'; + + p += 1 + vp->length; + remain -= 1 + vp->length; + break; + } *pVp = vp; *pBuffer = p; *pRemain = remain; return true; + +fail: + pairbasicfree(vp); + return false; } bool @@ -598,22 +658,11 @@ gss_eap_radius_attr_provider::initFromBuffer(const gss_eap_attr_ctx *ctx, { unsigned char *p = (unsigned char *)buffer->value; size_t remain = buffer->length; - OM_uint32 count; - VALUE_PAIR **pNext = &m_avps; + VALUE_PAIR **pNext = &m_vps; if (!gss_eap_attr_provider::initFromBuffer(ctx, buffer)) return false; - if (!initFromGssCred(GSS_C_NO_CREDENTIAL)) - return false; - - if (remain < 4) - return false; - - count = load_uint32_be(p); - p += 4; - remain -= 4; - do { VALUE_PAIR *attr; @@ -622,27 +671,20 @@ gss_eap_radius_attr_provider::initFromBuffer(const gss_eap_attr_ctx *ctx, *pNext = attr; pNext = &attr->next; - - count--; } while (remain != 0); - if (count != 0) - return false; - return true; } void gss_eap_radius_attr_provider::exportToBuffer(gss_buffer_t buffer) const { - OM_uint32 count = 0; VALUE_PAIR *vp; unsigned char *p; - size_t remain = 4; + size_t remain = 0; - for (vp = m_avps; vp != NULL; vp = vp->next) { + for (vp = m_vps; vp != NULL; vp = vp->next) { remain += avpSize(vp); - count++; } buffer->value = GSSEAP_MALLOC(remain); @@ -654,11 +696,7 @@ gss_eap_radius_attr_provider::exportToBuffer(gss_buffer_t buffer) const p = (unsigned char *)buffer->value; - store_uint32_be(count, p); - p += 4; - remain -= 4; - - for (vp = m_avps; vp != NULL; vp = vp->next) { + for (vp = m_vps; vp != NULL; vp = vp->next) { avpExport(vp, &p, &remain); } @@ -670,9 +708,34 @@ gss_eap_radius_attr_provider::getExpiryTime(void) const { VALUE_PAIR *vp; - vp = rc_avpair_get(m_avps, PW_SESSION_TIMEOUT, 0); + vp = pairfind(m_vps, PW_SESSION_TIMEOUT); if (vp == NULL || vp->lvalue == 0) return 0; return time(NULL) + vp->lvalue; } + +/* partition error namespace so it does not conflict with krb5 */ +#define RS_TO_COM_ERR(rse) ((rse) == RSE_OK ? 0 : (rse) + ERROR_TABLE_BASE_rse) +#define COM_TO_RS_ERR(err) ((err) > ERROR_TABLE_BASE_rse && \ + (err) <= (ERROR_TABLE_BASE_rse + RSE_SOME_ERROR) ? \ + (err) - ERROR_TABLE_BASE_rse : RSE_SOME_ERROR) + +OM_uint32 +gssEapRadiusMapError(OM_uint32 *minor, + struct rs_error *err) +{ + int code = RSE_OK; + + if (err != NULL) + code = rs_err_code(err, 0); + else + code = RSE_SOME_ERROR; + + *minor = RS_TO_COM_ERR(code); + + gssEapSaveStatusInfo(*minor, "%s", rs_err_msg(err, 0)); + + rs_err_free(err); + return GSS_S_FAILURE; +}