#ifdef HAVE_CONFIG_H
#include <config.h>
#endif
#ifdef OPENSSL
#include <stdio.h>
#include <sys/types.h>
#include <sys/param.h>
#include <unistd.h>
#include <fcntl.h>
#include "ntpd.h"
#include "ntp_stdlib.h"
#include "ntp_unixtime.h"
#include "ntp_string.h"
#include <ntp_random.h>
#include "openssl/asn1_mac.h"
#include "openssl/bn.h"
#include "openssl/err.h"
#include "openssl/evp.h"
#include "openssl/pem.h"
#include "openssl/rand.h"
#include "openssl/x509v3.h"
#ifdef KERNEL_PLL
#include "ntp_syscall.h"
#endif
#define TAI_1972 10
#define MAX_LEAP 100
#define VALUE_LEN (6 * 4)
#define YEAR (60 * 60 * 24 * 365)
u_int32 crypto_flags = 0x0;
struct cert_info *cinfo = NULL;
struct value hostval;
struct value pubkey;
struct value tai_leap;
EVP_PKEY *iffpar_pkey = NULL;
EVP_PKEY *gqpar_pkey = NULL;
EVP_PKEY *mvpar_pkey = NULL;
char *iffpar_file = NULL;
char *gqpar_file = NULL;
char *mvpar_file = NULL;
static char *passwd = NULL;
static EVP_PKEY *host_pkey = NULL;
static EVP_PKEY *sign_pkey = NULL;
static const EVP_MD *sign_digest = NULL;
static u_int sign_siglen;
static char *rand_file = NULL;
static char *host_file = NULL;
static char *sign_file = NULL;
static char *cert_file = NULL;
static char *leap_file = NULL;
static tstamp_t if_fstamp = 0;
static tstamp_t gq_fstamp = 0;
static tstamp_t mv_fstamp = 0;
static u_int ident_scheme = 0;
static int crypto_verify P((struct exten *, struct value *,
struct peer *));
static int crypto_encrypt P((struct exten *, struct value *,
keyid_t *));
static int crypto_alice P((struct peer *, struct value *));
static int crypto_alice2 P((struct peer *, struct value *));
static int crypto_alice3 P((struct peer *, struct value *));
static int crypto_bob P((struct exten *, struct value *));
static int crypto_bob2 P((struct exten *, struct value *));
static int crypto_bob3 P((struct exten *, struct value *));
static int crypto_iff P((struct exten *, struct peer *));
static int crypto_gq P((struct exten *, struct peer *));
static int crypto_mv P((struct exten *, struct peer *));
static u_int crypto_send P((struct exten *, struct value *));
static tstamp_t crypto_time P((void));
static u_long asn2ntp P((ASN1_TIME *));
static struct cert_info *cert_parse P((u_char *, u_int, tstamp_t));
static int cert_sign P((struct exten *, struct value *));
static int cert_valid P((struct cert_info *, EVP_PKEY *));
static int cert_install P((struct exten *, struct peer *));
static void cert_free P((struct cert_info *));
static EVP_PKEY *crypto_key P((char *, tstamp_t *));
static int bighash P((BIGNUM *, BIGNUM *));
static struct cert_info *crypto_cert P((char *));
static void crypto_tai P((char *));
#ifdef SYS_WINNT
int
readlink(char * link, char * file, int len) {
return (-1);
}
#endif
keyid_t
session_key(
struct sockaddr_storage *srcadr,
struct sockaddr_storage *dstadr,
keyid_t keyno,
keyid_t private,
u_long lifetime
)
{
EVP_MD_CTX ctx;
u_char dgst[EVP_MAX_MD_SIZE];
keyid_t keyid;
u_int32 header[10];
u_int hdlen, len;
if (!dstadr)
return 0;
hdlen = 0;
switch(srcadr->ss_family) {
case AF_INET:
header[0] = ((struct sockaddr_in *)srcadr)->sin_addr.s_addr;
header[1] = ((struct sockaddr_in *)dstadr)->sin_addr.s_addr;
header[2] = htonl(keyno);
header[3] = htonl(private);
hdlen = 4 * sizeof(u_int32);
break;
case AF_INET6:
memcpy(&header[0], &GET_INADDR6(*srcadr),
sizeof(struct in6_addr));
memcpy(&header[4], &GET_INADDR6(*dstadr),
sizeof(struct in6_addr));
header[8] = htonl(keyno);
header[9] = htonl(private);
hdlen = 10 * sizeof(u_int32);
break;
}
EVP_DigestInit(&ctx, EVP_md5());
EVP_DigestUpdate(&ctx, (u_char *)header, hdlen);
EVP_DigestFinal(&ctx, dgst, &len);
memcpy(&keyid, dgst, 4);
keyid = ntohl(keyid);
if (lifetime != 0) {
MD5auth_setkey(keyno, dgst, len);
authtrust(keyno, lifetime);
}
#ifdef DEBUG
if (debug > 1)
printf(
"session_key: %s > %s %08x %08x hash %08x life %lu\n",
stoa(srcadr), stoa(dstadr), keyno,
private, keyid, lifetime);
#endif
return (keyid);
}
int
make_keylist(
struct peer *peer,
struct interface *dstadr
)
{
EVP_MD_CTX ctx;
tstamp_t tstamp;
struct autokey *ap;
struct value *vp;
keyid_t keyid = 0;
keyid_t cookie;
u_long lifetime;
u_int len, mpoll;
int i;
if (!dstadr)
return XEVNT_OK;
tstamp = crypto_time();
if (peer->keylist == NULL)
peer->keylist = emalloc(sizeof(keyid_t) *
NTP_MAXSESSION);
while (1) {
keyid = (ntp_random() + NTP_MAXKEY + 1) & ((1 <<
sizeof(keyid_t)) - 1);
if (authhavekey(keyid))
continue;
break;
}
mpoll = 1 << min(peer->ppoll, peer->hpoll);
lifetime = min(sys_automax, NTP_MAXSESSION * mpoll);
if (peer->hmode == MODE_BROADCAST)
cookie = 0;
else
cookie = peer->pcookie;
for (i = 0; i < NTP_MAXSESSION; i++) {
peer->keylist[i] = keyid;
peer->keynumber = i;
keyid = session_key(&dstadr->sin, &peer->srcadr, keyid,
cookie, lifetime);
lifetime -= mpoll;
if (auth_havekey(keyid) || keyid <= NTP_MAXKEY ||
lifetime <= mpoll)
break;
}
vp = &peer->sndval;
if (vp->ptr == NULL)
vp->ptr = emalloc(sizeof(struct autokey));
ap = (struct autokey *)vp->ptr;
ap->seq = htonl(peer->keynumber);
ap->key = htonl(keyid);
vp->tstamp = htonl(tstamp);
vp->fstamp = hostval.tstamp;
vp->vallen = htonl(sizeof(struct autokey));
vp->siglen = 0;
if (tstamp != 0) {
if (tstamp < cinfo->first || tstamp > cinfo->last)
return (XEVNT_PER);
if (vp->sig == NULL)
vp->sig = emalloc(sign_siglen);
EVP_SignInit(&ctx, sign_digest);
EVP_SignUpdate(&ctx, (u_char *)vp, 12);
EVP_SignUpdate(&ctx, vp->ptr, sizeof(struct autokey));
if (EVP_SignFinal(&ctx, vp->sig, &len, sign_pkey))
vp->siglen = htonl(len);
else
msyslog(LOG_ERR, "make_keys %s\n",
ERR_error_string(ERR_get_error(), NULL));
peer->flags |= FLAG_ASSOC;
}
#ifdef DEBUG
if (debug)
printf("make_keys: %d %08x %08x ts %u fs %u poll %d\n",
ntohl(ap->seq), ntohl(ap->key), cookie,
ntohl(vp->tstamp), ntohl(vp->fstamp), peer->hpoll);
#endif
return (XEVNT_OK);
}
int
crypto_recv(
struct peer *peer,
struct recvbuf *rbufp
)
{
const EVP_MD *dp;
u_int32 *pkt;
struct autokey *ap, *bp;
struct exten *ep, *fp;
int has_mac;
int authlen;
associd_t associd;
tstamp_t tstamp = 0;
tstamp_t fstamp = 0;
u_int len;
u_int code;
u_int vallen = 0;
X509 *cert;
char statstr[NTP_MAXSTRLEN];
keyid_t cookie;
int hismode;
int rval = XEVNT_OK;
u_char *ptr;
u_int32 temp32;
authlen = LEN_PKT_NOMAC;
hismode = (int)PKT_MODE((&rbufp->recv_pkt)->li_vn_mode);
while ((has_mac = rbufp->recv_length - authlen) > MAX_MAC_LEN) {
pkt = (u_int32 *)&rbufp->recv_pkt + authlen / 4;
ep = (struct exten *)pkt;
code = ntohl(ep->opcode) & 0xffff0000;
len = ntohl(ep->opcode) & 0x0000ffff;
associd = (associd_t) ntohl(pkt[1]);
rval = XEVNT_OK;
#ifdef DEBUG
if (debug)
printf(
"crypto_recv: flags 0x%x ext offset %d len %u code 0x%x assocID %d\n",
peer->crypto, authlen, len, code >> 16,
associd);
#endif
if (((code >> 24) & 0x3f) != CRYPTO_VN || len < 8) {
sys_unknownversion++;
code |= CRYPTO_ERROR;
}
if (code & CRYPTO_RESP) {
if (peer->assoc == 0)
peer->assoc = associd;
else if (peer->assoc != associd)
code |= CRYPTO_ERROR;
}
if (len >= VALUE_LEN) {
tstamp = ntohl(ep->tstamp);
fstamp = ntohl(ep->fstamp);
vallen = ntohl(ep->vallen);
}
switch (code) {
case CRYPTO_ASSOC:
if (peer->crypto) {
rval = XEVNT_ERR;
break;
}
fp = emalloc(len);
memcpy(fp, ep, len);
temp32 = CRYPTO_RESP;
fp->opcode |= htonl(temp32);
peer->cmmd = fp;
case CRYPTO_ASSOC | CRYPTO_RESP:
if (peer->crypto)
break;
if (vallen == 0 || vallen > MAXHOSTNAME ||
len < VALUE_LEN + vallen) {
rval = XEVNT_LEN;
break;
}
#ifdef DEBUG
if (debug)
printf(
"crypto_recv: ident host 0x%x server 0x%x\n",
crypto_flags, fstamp);
#endif
temp32 = (crypto_flags | ident_scheme) &
fstamp & CRYPTO_FLAG_MASK;
if (crypto_flags & CRYPTO_FLAG_PRIV) {
if (!(fstamp & CRYPTO_FLAG_PRIV)) {
rval = XEVNT_KEY;
break;
} else {
fstamp |= CRYPTO_FLAG_VALID |
CRYPTO_FLAG_VRFY |
CRYPTO_FLAG_SIGN;
}
} else if ((hismode == MODE_ACTIVE || hismode ==
MODE_PASSIVE) && ((crypto_flags | fstamp) &
CRYPTO_FLAG_MASK) && !temp32) {
rval = XEVNT_KEY;
break;
} else if (hismode == MODE_CLIENT && (fstamp &
CRYPTO_FLAG_MASK) && !temp32) {
rval = XEVNT_KEY;
break;
}
fstamp = temp32 | (fstamp & ~CRYPTO_FLAG_MASK);
temp32 = (fstamp >> 16) & 0xffff;
dp =
(const EVP_MD *)EVP_get_digestbynid(temp32);
if (dp == NULL) {
rval = XEVNT_MD;
break;
}
peer->crypto = fstamp;
peer->digest = dp;
peer->subject = emalloc(vallen + 1);
memcpy(peer->subject, ep->pkt, vallen);
peer->subject[vallen] = '\0';
peer->issuer = emalloc(vallen + 1);
strcpy(peer->issuer, peer->subject);
temp32 = (fstamp >> 16) & 0xffff;
sprintf(statstr,
"flags 0x%x host %s signature %s", fstamp,
peer->subject, OBJ_nid2ln(temp32));
record_crypto_stats(&peer->srcadr, statstr);
#ifdef DEBUG
if (debug)
printf("crypto_recv: %s\n", statstr);
#endif
break;
case CRYPTO_CERT | CRYPTO_RESP:
if ((rval = crypto_verify(ep, NULL, peer)) !=
XEVNT_OK)
break;
if ((rval = cert_install(ep, peer)) != XEVNT_OK)
break;
if (peer->issuer != NULL)
free(peer->issuer);
peer->issuer = emalloc(strlen(cinfo->issuer) +
1);
strcpy(peer->issuer, cinfo->issuer);
if (peer->pkey == NULL) {
ptr = (u_char *)cinfo->cert.ptr;
cert = d2i_X509(NULL, &ptr,
ntohl(cinfo->cert.vallen));
peer->pkey = X509_get_pubkey(cert);
X509_free(cert);
}
peer->flash &= ~TEST8;
temp32 = cinfo->nid;
sprintf(statstr, "cert %s 0x%x %s (%u) fs %u",
cinfo->subject, cinfo->flags,
OBJ_nid2ln(temp32), temp32,
ntohl(ep->fstamp));
record_crypto_stats(&peer->srcadr, statstr);
#ifdef DEBUG
if (debug)
printf("crypto_recv: %s\n", statstr);
#endif
break;
case CRYPTO_IFF | CRYPTO_RESP:
if (!(peer->crypto & CRYPTO_FLAG_VALID)) {
rval = XEVNT_ERR;
break;
}
if ((rval = crypto_verify(ep, NULL, peer)) !=
XEVNT_OK)
break;
if ((rval = crypto_iff(ep, peer)) != XEVNT_OK)
break;
peer->crypto |= CRYPTO_FLAG_VRFY |
CRYPTO_FLAG_PROV;
peer->flash &= ~TEST8;
sprintf(statstr, "iff fs %u",
ntohl(ep->fstamp));
record_crypto_stats(&peer->srcadr, statstr);
#ifdef DEBUG
if (debug)
printf("crypto_recv: %s\n", statstr);
#endif
break;
case CRYPTO_GQ | CRYPTO_RESP:
if (!(peer->crypto & CRYPTO_FLAG_VALID)) {
rval = XEVNT_ERR;
break;
}
if ((rval = crypto_verify(ep, NULL, peer)) !=
XEVNT_OK)
break;
if ((rval = crypto_gq(ep, peer)) != XEVNT_OK)
break;
peer->crypto |= CRYPTO_FLAG_VRFY |
CRYPTO_FLAG_PROV;
peer->flash &= ~TEST8;
sprintf(statstr, "gq fs %u",
ntohl(ep->fstamp));
record_crypto_stats(&peer->srcadr, statstr);
#ifdef DEBUG
if (debug)
printf("crypto_recv: %s\n", statstr);
#endif
break;
case CRYPTO_MV | CRYPTO_RESP:
if (!(peer->crypto & CRYPTO_FLAG_VALID)) {
rval = XEVNT_ERR;
break;
}
if ((rval = crypto_verify(ep, NULL, peer)) !=
XEVNT_OK)
break;
if ((rval = crypto_mv(ep, peer)) != XEVNT_OK)
break;
peer->crypto |= CRYPTO_FLAG_VRFY |
CRYPTO_FLAG_PROV;
peer->flash &= ~TEST8;
sprintf(statstr, "mv fs %u",
ntohl(ep->fstamp));
record_crypto_stats(&peer->srcadr, statstr);
#ifdef DEBUG
if (debug)
printf("crypto_recv: %s\n", statstr);
#endif
break;
case CRYPTO_COOK:
if (!(peer->crypto & CRYPTO_FLAG_VALID)) {
rval = XEVNT_ERR;
break;
}
if ((rval = crypto_verify(ep, NULL, peer)) !=
XEVNT_OK)
break;
fp = emalloc(len);
memcpy(fp, ep, len);
temp32 = CRYPTO_RESP;
fp->opcode |= htonl(temp32);
peer->cmmd = fp;
if (peer->crypto & CRYPTO_FLAG_AGREE) {
peer->flash &= ~TEST8;
break;
}
key_expire(peer);
peer->cookval.tstamp = ep->tstamp;
peer->cookval.fstamp = ep->fstamp;
RAND_bytes((u_char *)&peer->pcookie, 4);
peer->crypto &= ~CRYPTO_FLAG_AUTO;
peer->crypto |= CRYPTO_FLAG_AGREE;
peer->flash &= ~TEST8;
sprintf(statstr, "cook %x ts %u fs %u",
peer->pcookie, ntohl(ep->tstamp),
ntohl(ep->fstamp));
record_crypto_stats(&peer->srcadr, statstr);
#ifdef DEBUG
if (debug)
printf("crypto_recv: %s\n", statstr);
#endif
break;
case CRYPTO_COOK | CRYPTO_RESP:
if (!(peer->crypto & CRYPTO_FLAG_VRFY)) {
rval = XEVNT_ERR;
break;
}
if ((rval = crypto_verify(ep, &peer->cookval,
peer)) != XEVNT_OK)
break;
if (vallen == (u_int) EVP_PKEY_size(host_pkey)) {
RSA_private_decrypt(vallen,
(u_char *)ep->pkt,
(u_char *)&temp32,
host_pkey->pkey.rsa,
RSA_PKCS1_OAEP_PADDING);
cookie = ntohl(temp32);
} else {
rval = XEVNT_CKY;
break;
}
key_expire(peer);
peer->cookval.tstamp = ep->tstamp;
peer->cookval.fstamp = ep->fstamp;
if (peer->crypto & CRYPTO_FLAG_AGREE)
peer->pcookie ^= cookie;
else
peer->pcookie = cookie;
if (peer->hmode == MODE_CLIENT &&
!(peer->cast_flags & MDF_BCLNT))
peer->crypto |= CRYPTO_FLAG_AUTO;
else
peer->crypto &= ~CRYPTO_FLAG_AUTO;
peer->crypto |= CRYPTO_FLAG_AGREE;
peer->flash &= ~TEST8;
sprintf(statstr, "cook %x ts %u fs %u",
peer->pcookie, ntohl(ep->tstamp),
ntohl(ep->fstamp));
record_crypto_stats(&peer->srcadr, statstr);
#ifdef DEBUG
if (debug)
printf("crypto_recv: %s\n", statstr);
#endif
break;
case CRYPTO_AUTO | CRYPTO_RESP:
if (!(peer->crypto & CRYPTO_FLAG_VRFY)) {
rval = XEVNT_ERR;
break;
}
if ((rval = crypto_verify(ep, &peer->recval,
peer)) != XEVNT_OK)
break;
if (peer->recval.ptr == NULL)
peer->recval.ptr =
emalloc(sizeof(struct autokey));
bp = (struct autokey *)peer->recval.ptr;
peer->recval.tstamp = ep->tstamp;
peer->recval.fstamp = ep->fstamp;
ap = (struct autokey *)ep->pkt;
bp->seq = ntohl(ap->seq);
bp->key = ntohl(ap->key);
peer->pkeyid = bp->key;
peer->crypto |= CRYPTO_FLAG_AUTO;
peer->flash &= ~TEST8;
sprintf(statstr,
"auto seq %d key %x ts %u fs %u", bp->seq,
bp->key, ntohl(ep->tstamp),
ntohl(ep->fstamp));
record_crypto_stats(&peer->srcadr, statstr);
#ifdef DEBUG
if (debug)
printf("crypto_recv: %s\n", statstr);
#endif
break;
case CRYPTO_SIGN | CRYPTO_RESP:
if (!(peer->crypto & CRYPTO_FLAG_PROV)) {
rval = XEVNT_ERR;
break;
}
if ((rval = crypto_verify(ep, NULL, peer)) !=
XEVNT_OK)
break;
if ((rval = cert_install(ep, peer)) != XEVNT_OK)
break;
peer->crypto |= CRYPTO_FLAG_SIGN;
peer->flash &= ~TEST8;
temp32 = cinfo->nid;
sprintf(statstr, "sign %s 0x%x %s (%u) fs %u",
cinfo->issuer, cinfo->flags,
OBJ_nid2ln(temp32), temp32,
ntohl(ep->fstamp));
record_crypto_stats(&peer->srcadr, statstr);
#ifdef DEBUG
if (debug)
printf("crypto_recv: %s\n", statstr);
#endif
break;
case CRYPTO_TAI:
if ((rval = crypto_verify(ep, NULL, peer)) !=
XEVNT_OK)
break;
fp = emalloc(len);
memcpy(fp, ep, len);
temp32 = CRYPTO_RESP;
fp->opcode |= htonl(temp32);
peer->cmmd = fp;
if (len <= VALUE_LEN) {
peer->flash &= ~TEST8;
break;
}
case CRYPTO_TAI | CRYPTO_RESP:
if (peer->cmmd == NULL) {
if ((rval = crypto_verify(ep,
&peer->tai_leap, peer)) != XEVNT_OK)
break;
}
peer->tai_leap.tstamp = ep->tstamp;
peer->tai_leap.fstamp = ep->fstamp;
peer->tai_leap.vallen = ep->vallen;
if (ntohl(peer->tai_leap.fstamp) >
ntohl(tai_leap.fstamp)) {
tai_leap.fstamp = ep->fstamp;
tai_leap.vallen = ep->vallen;
if (tai_leap.ptr != NULL)
free(tai_leap.ptr);
tai_leap.ptr = emalloc(vallen);
memcpy(tai_leap.ptr, ep->pkt, vallen);
crypto_update();
}
crypto_flags |= CRYPTO_FLAG_TAI;
peer->crypto |= CRYPTO_FLAG_LEAP;
peer->flash &= ~TEST8;
sprintf(statstr, "leap %u ts %u fs %u", vallen,
ntohl(ep->tstamp), ntohl(ep->fstamp));
record_crypto_stats(&peer->srcadr, statstr);
#ifdef DEBUG
if (debug)
printf("crypto_recv: %s\n", statstr);
#endif
break;
case CRYPTO_CERT:
case CRYPTO_IFF:
case CRYPTO_GQ:
case CRYPTO_MV:
case CRYPTO_SIGN:
if (len < VALUE_LEN) {
rval = XEVNT_LEN;
break;
}
default:
if (code & (CRYPTO_RESP | CRYPTO_ERROR)) {
rval = XEVNT_ERR;
} else if ((rval = crypto_verify(ep, NULL,
peer)) == XEVNT_OK) {
fp = emalloc(len);
memcpy(fp, ep, len);
temp32 = CRYPTO_RESP;
fp->opcode |= htonl(temp32);
peer->cmmd = fp;
}
}
if (rval > XEVNT_TSP) {
sprintf(statstr,
"error %x opcode %x ts %u fs %u", rval,
code, tstamp, fstamp);
record_crypto_stats(&peer->srcadr, statstr);
report_event(rval, peer);
#ifdef DEBUG
if (debug)
printf("crypto_recv: %s\n", statstr);
#endif
break;
} else if (rval > XEVNT_OK && (code & CRYPTO_RESP)) {
rval = XEVNT_OK;
}
authlen += len;
}
return (rval);
}
int
crypto_xmit(
struct pkt *xpkt,
struct sockaddr_storage *srcadr_sin,
int start,
struct exten *ep,
keyid_t cookie
)
{
u_int32 *pkt;
struct peer *peer;
u_int opcode;
struct exten *fp;
struct cert_info *cp, *xp;
char certname[MAXHOSTNAME + 1];
char statstr[NTP_MAXSTRLEN];
tstamp_t tstamp;
u_int vallen;
u_int len;
struct value vtemp;
associd_t associd;
int rval;
keyid_t tcookie;
pkt = (u_int32 *)xpkt + start / 4;
fp = (struct exten *)pkt;
opcode = ntohl(ep->opcode);
associd = (associd_t) ntohl(ep->associd);
fp->associd = htonl(associd);
len = 8;
rval = XEVNT_OK;
tstamp = crypto_time();
switch (opcode & 0xffff0000) {
case CRYPTO_ASSOC | CRYPTO_RESP:
len += crypto_send(fp, &hostval);
fp->fstamp = htonl(crypto_flags);
break;
case CRYPTO_ASSOC:
len += crypto_send(fp, &hostval);
fp->fstamp = htonl(crypto_flags | ident_scheme);
break;
case CRYPTO_CERT:
memset(&vtemp, 0, sizeof(vtemp));
vtemp.tstamp = ep->tstamp;
vtemp.fstamp = ep->fstamp;
vtemp.vallen = ep->vallen;
vtemp.ptr = (u_char *)ep->pkt;
len += crypto_send(fp, &vtemp);
break;
case CRYPTO_SIGN:
case CRYPTO_CERT | CRYPTO_RESP:
vallen = ntohl(ep->vallen);
if (vallen == 8) {
strcpy(certname, sys_hostname);
} else if (vallen == 0 || vallen > MAXHOSTNAME) {
rval = XEVNT_LEN;
break;
} else {
memcpy(certname, ep->pkt, vallen);
certname[vallen] = '\0';
}
xp = NULL;
for (cp = cinfo; cp != NULL; cp = cp->link) {
if (cp->flags & CERT_PRIV)
continue;
if (strcmp(certname, cp->subject) == 0) {
if (xp == NULL)
xp = cp;
if (strcmp(certname, cp->issuer) ==
0 && cp->flags & CERT_TRUST) {
xp = cp;
break;
}
}
}
if (tstamp == 0)
break;
if (xp == NULL)
rval = XEVNT_CRT;
else if (tstamp < xp->first || tstamp > xp->last)
rval = XEVNT_SRV;
else
len += crypto_send(fp, &xp->cert);
break;
case CRYPTO_IFF:
if ((peer = findpeerbyassoc(ep->pkt[0])) == NULL) {
rval = XEVNT_ERR;
break;
}
if ((rval = crypto_alice(peer, &vtemp)) == XEVNT_OK) {
len += crypto_send(fp, &vtemp);
value_free(&vtemp);
}
break;
case CRYPTO_IFF | CRYPTO_RESP:
if ((rval = crypto_bob(ep, &vtemp)) == XEVNT_OK) {
len += crypto_send(fp, &vtemp);
value_free(&vtemp);
}
break;
case CRYPTO_GQ:
if ((peer = findpeerbyassoc(ep->pkt[0])) == NULL) {
rval = XEVNT_ERR;
break;
}
if ((rval = crypto_alice2(peer, &vtemp)) == XEVNT_OK) {
len += crypto_send(fp, &vtemp);
value_free(&vtemp);
}
break;
case CRYPTO_GQ | CRYPTO_RESP:
if ((rval = crypto_bob2(ep, &vtemp)) == XEVNT_OK) {
len += crypto_send(fp, &vtemp);
value_free(&vtemp);
}
break;
case CRYPTO_MV:
if ((peer = findpeerbyassoc(ep->pkt[0])) == NULL) {
rval = XEVNT_ERR;
break;
}
if ((rval = crypto_alice3(peer, &vtemp)) == XEVNT_OK) {
len += crypto_send(fp, &vtemp);
value_free(&vtemp);
}
break;
case CRYPTO_MV | CRYPTO_RESP:
if ((rval = crypto_bob3(ep, &vtemp)) == XEVNT_OK) {
len += crypto_send(fp, &vtemp);
value_free(&vtemp);
}
break;
case CRYPTO_SIGN | CRYPTO_RESP:
if ((rval = cert_sign(ep, &vtemp)) == XEVNT_OK)
len += crypto_send(fp, &vtemp);
value_free(&vtemp);
break;
case CRYPTO_COOK:
len += crypto_send(fp, &pubkey);
break;
case CRYPTO_COOK | CRYPTO_RESP:
if ((opcode & 0xffff) < VALUE_LEN) {
rval = XEVNT_LEN;
break;
}
if (PKT_MODE(xpkt->li_vn_mode) == MODE_SERVER) {
tcookie = cookie;
} else {
if ((peer = findpeerbyassoc(associd)) == NULL) {
rval = XEVNT_ERR;
break;
}
tcookie = peer->pcookie;
}
if ((rval = crypto_encrypt(ep, &vtemp, &tcookie)) ==
XEVNT_OK)
len += crypto_send(fp, &vtemp);
value_free(&vtemp);
break;
case CRYPTO_AUTO | CRYPTO_RESP:
if ((peer = findpeerbyassoc(associd)) == NULL) {
rval = XEVNT_ERR;
break;
}
peer->flags &= ~FLAG_ASSOC;
len += crypto_send(fp, &peer->sndval);
break;
case CRYPTO_TAI:
case CRYPTO_TAI | CRYPTO_RESP:
if (crypto_flags & CRYPTO_FLAG_TAI)
len += crypto_send(fp, &tai_leap);
break;
default:
if (opcode & CRYPTO_RESP)
rval = XEVNT_ERR;
}
if (rval != XEVNT_OK) {
opcode |= CRYPTO_ERROR;
sprintf(statstr, "error %x opcode %x", rval, opcode);
record_crypto_stats(srcadr_sin, statstr);
report_event(rval, NULL);
#ifdef DEBUG
if (debug)
printf("crypto_xmit: %s\n", statstr);
#endif
if (!(opcode & CRYPTO_RESP))
return (0);
}
len = ((len + 7) / 8) * 8;
fp->opcode = htonl((opcode & 0xffff0000) | len);
#ifdef DEBUG
if (debug)
printf(
"crypto_xmit: flags 0x%x ext offset %d len %u code 0x%x assocID %d\n",
crypto_flags, start, len, opcode >> 16, associd);
#endif
return (len);
}
static int
crypto_verify(
struct exten *ep,
struct value *vp,
struct peer *peer
)
{
EVP_PKEY *pkey;
EVP_MD_CTX ctx;
tstamp_t tstamp, tstamp1 = 0;
tstamp_t fstamp, fstamp1 = 0;
u_int vallen;
u_int siglen;
u_int opcode, len;
int i;
len = ntohl(ep->opcode) & 0x0000ffff;
opcode = ntohl(ep->opcode) & 0xffff0000;
if (opcode & CRYPTO_ERROR)
return (XEVNT_ERR);
if (opcode & CRYPTO_RESP) {
if (len < VALUE_LEN)
return (XEVNT_LEN);
} else {
if (len < VALUE_LEN)
return (XEVNT_OK);
}
vallen = ntohl(ep->vallen);
i = (vallen + 3) / 4;
siglen = ntohl(ep->pkt[i++]);
if (len < VALUE_LEN + ((vallen + 3) / 4) * 4 + ((siglen + 3) /
4) * 4)
return (XEVNT_LEN);
if (opcode & CRYPTO_RESP) {
if (vallen == 0)
return (XEVNT_LEN);
} else {
if (peer->cmmd != NULL)
return (XEVNT_LEN);
}
tstamp = ntohl(ep->tstamp);
fstamp = ntohl(ep->fstamp);
if (tstamp == 0)
return (XEVNT_OK);
if (tstamp < fstamp)
return (XEVNT_TSP);
if (vp != NULL) {
tstamp1 = ntohl(vp->tstamp);
fstamp1 = ntohl(vp->fstamp);
if ((tstamp < tstamp1 || (tstamp == tstamp1 &&
(peer->crypto & CRYPTO_FLAG_AUTO))))
return (XEVNT_TSP);
if ((tstamp < fstamp1 || fstamp < fstamp1))
return (XEVNT_FSP);
}
if (crypto_flags & peer->crypto & CRYPTO_FLAG_PRIV)
pkey = sign_pkey;
else
pkey = peer->pkey;
if (siglen == 0 || pkey == NULL || peer->digest == NULL)
return (XEVNT_OK);
if (siglen != (u_int)EVP_PKEY_size(pkey))
return (XEVNT_SGL);
EVP_VerifyInit(&ctx, peer->digest);
EVP_VerifyUpdate(&ctx, (u_char *)&ep->tstamp, vallen + 12);
if (1 != EVP_VerifyFinal(&ctx, (u_char *)&ep->pkt[i], siglen, pkey))
return (XEVNT_SIG);
if (peer->crypto & CRYPTO_FLAG_VRFY) {
peer->crypto |= CRYPTO_FLAG_PROV;
if (!(crypto_flags & CRYPTO_FLAG_MASK))
peer->crypto |= CRYPTO_FLAG_SIGN;
}
return (XEVNT_OK);
}
static int
crypto_encrypt(
struct exten *ep,
struct value *vp,
keyid_t *cookie
)
{
EVP_PKEY *pkey;
EVP_MD_CTX ctx;
tstamp_t tstamp;
u_int32 temp32;
u_int len;
u_char *ptr;
len = ntohl(ep->vallen);
ptr = (u_char *)ep->pkt;
pkey = d2i_PublicKey(EVP_PKEY_RSA, NULL, &ptr, len);
if (pkey == NULL) {
msyslog(LOG_ERR, "crypto_encrypt %s\n",
ERR_error_string(ERR_get_error(), NULL));
return (XEVNT_PUB);
}
tstamp = crypto_time();
memset(vp, 0, sizeof(struct value));
vp->tstamp = htonl(tstamp);
vp->fstamp = hostval.tstamp;
len = EVP_PKEY_size(pkey);
vp->vallen = htonl(len);
vp->ptr = emalloc(len);
temp32 = htonl(*cookie);
if (!RSA_public_encrypt(4, (u_char *)&temp32, vp->ptr,
pkey->pkey.rsa, RSA_PKCS1_OAEP_PADDING)) {
msyslog(LOG_ERR, "crypto_encrypt %s\n",
ERR_error_string(ERR_get_error(), NULL));
EVP_PKEY_free(pkey);
return (XEVNT_CKY);
}
EVP_PKEY_free(pkey);
vp->siglen = 0;
if (tstamp == 0)
return (XEVNT_OK);
if (tstamp < cinfo->first || tstamp > cinfo->last)
return (XEVNT_PER);
vp->sig = emalloc(sign_siglen);
EVP_SignInit(&ctx, sign_digest);
EVP_SignUpdate(&ctx, (u_char *)&vp->tstamp, 12);
EVP_SignUpdate(&ctx, vp->ptr, len);
if (EVP_SignFinal(&ctx, vp->sig, &len, sign_pkey))
vp->siglen = htonl(len);
return (XEVNT_OK);
}
u_int
crypto_ident(
struct peer *peer
)
{
char filename[MAXFILENAME + 1];
if (peer->ident_pkey != NULL)
EVP_PKEY_free(peer->ident_pkey);
if (peer->crypto & CRYPTO_FLAG_GQ) {
snprintf(filename, MAXFILENAME, "ntpkey_gq_%s",
peer->issuer);
peer->ident_pkey = crypto_key(filename, &peer->fstamp);
if (peer->ident_pkey != NULL)
return (CRYPTO_GQ);
snprintf(filename, MAXFILENAME, "ntpkey_gq_%s",
sys_hostname);
peer->ident_pkey = crypto_key(filename, &peer->fstamp);
if (peer->ident_pkey != NULL)
return (CRYPTO_GQ);
}
if (peer->crypto & CRYPTO_FLAG_IFF) {
snprintf(filename, MAXFILENAME, "ntpkey_iff_%s",
peer->issuer);
peer->ident_pkey = crypto_key(filename, &peer->fstamp);
if (peer->ident_pkey != NULL)
return (CRYPTO_IFF);
snprintf(filename, MAXFILENAME, "ntpkey_iff_%s",
sys_hostname);
peer->ident_pkey = crypto_key(filename, &peer->fstamp);
if (peer->ident_pkey != NULL)
return (CRYPTO_IFF);
}
if (peer->crypto & CRYPTO_FLAG_MV) {
snprintf(filename, MAXFILENAME, "ntpkey_mv_%s",
peer->issuer);
peer->ident_pkey = crypto_key(filename, &peer->fstamp);
if (peer->ident_pkey != NULL)
return (CRYPTO_MV);
snprintf(filename, MAXFILENAME, "ntpkey_mv_%s",
sys_hostname);
peer->ident_pkey = crypto_key(filename, &peer->fstamp);
if (peer->ident_pkey != NULL)
return (CRYPTO_MV);
}
msyslog(LOG_INFO,
"crypto_ident: no compatible identity scheme found");
return (0);
}
struct exten *
crypto_args(
struct peer *peer,
u_int opcode,
char *str
)
{
tstamp_t tstamp;
struct exten *ep;
u_int len;
tstamp = crypto_time();
len = sizeof(struct exten);
if (str != NULL)
len += strlen(str);
ep = emalloc(len);
memset(ep, 0, len);
if (opcode == 0)
return (ep);
ep->opcode = htonl(opcode + len);
if (opcode & CRYPTO_RESP)
ep->associd = htonl(peer->associd);
else
ep->associd = htonl(peer->assoc);
ep->tstamp = htonl(tstamp);
ep->fstamp = hostval.tstamp;
ep->vallen = 0;
if (str != NULL) {
ep->vallen = htonl(strlen(str));
memcpy((char *)ep->pkt, str, strlen(str));
} else {
ep->pkt[0] = peer->associd;
}
return (ep);
}
u_int
crypto_send(
struct exten *ep,
struct value *vp
)
{
u_int len, temp32;
int i;
ep->tstamp = vp->tstamp;
ep->fstamp = vp->fstamp;
ep->vallen = vp->vallen;
len = 12;
temp32 = ntohl(vp->vallen);
if (temp32 > 0 && vp->ptr != NULL)
memcpy(ep->pkt, vp->ptr, temp32);
i = (temp32 + 3) / 4;
len += i * 4 + 4;
ep->pkt[i++] = vp->siglen;
temp32 = ntohl(vp->siglen);
if (temp32 > 0 && vp->sig != NULL)
memcpy(&ep->pkt[i], vp->sig, temp32);
len += temp32;
return (len);
}
void
crypto_update(void)
{
EVP_MD_CTX ctx;
struct cert_info *cp, *cpn;
char statstr[NTP_MAXSTRLEN];
tstamp_t tstamp;
u_int len;
if ((tstamp = crypto_time()) == 0)
return;
hostval.tstamp = htonl(tstamp);
if (pubkey.vallen != 0) {
pubkey.tstamp = hostval.tstamp;
pubkey.siglen = 0;
if (pubkey.sig == NULL)
pubkey.sig = emalloc(sign_siglen);
EVP_SignInit(&ctx, sign_digest);
EVP_SignUpdate(&ctx, (u_char *)&pubkey, 12);
EVP_SignUpdate(&ctx, pubkey.ptr, ntohl(pubkey.vallen));
if (EVP_SignFinal(&ctx, pubkey.sig, &len, sign_pkey))
pubkey.siglen = htonl(len);
}
for (cp = cinfo; cp != NULL; cp = cpn) {
cpn = cp->link;
cp->cert.tstamp = hostval.tstamp;
cp->cert.siglen = 0;
if (cp->cert.sig == NULL)
cp->cert.sig = emalloc(sign_siglen);
EVP_SignInit(&ctx, sign_digest);
EVP_SignUpdate(&ctx, (u_char *)&cp->cert, 12);
EVP_SignUpdate(&ctx, cp->cert.ptr,
ntohl(cp->cert.vallen));
if (EVP_SignFinal(&ctx, cp->cert.sig, &len, sign_pkey))
cp->cert.siglen = htonl(len);
}
if (tai_leap.vallen != 0) {
tai_leap.tstamp = hostval.tstamp;
tai_leap.siglen = 0;
if (tai_leap.sig == NULL)
tai_leap.sig = emalloc(sign_siglen);
EVP_SignInit(&ctx, sign_digest);
EVP_SignUpdate(&ctx, (u_char *)&tai_leap, 12);
EVP_SignUpdate(&ctx, tai_leap.ptr,
ntohl(tai_leap.vallen));
if (EVP_SignFinal(&ctx, tai_leap.sig, &len, sign_pkey))
tai_leap.siglen = htonl(len);
}
sprintf(statstr, "update ts %u", ntohl(hostval.tstamp));
record_crypto_stats(NULL, statstr);
#ifdef DEBUG
if (debug)
printf("crypto_update: %s\n", statstr);
#endif
}
void
value_free(
struct value *vp
)
{
if (vp->ptr != NULL)
free(vp->ptr);
if (vp->sig != NULL)
free(vp->sig);
memset(vp, 0, sizeof(struct value));
}
tstamp_t
crypto_time()
{
l_fp tstamp; L_CLR(&tstamp);
L_CLR(&tstamp);
if (sys_leap != LEAP_NOTINSYNC)
get_systime(&tstamp);
return (tstamp.l_ui);
}
u_long
asn2ntp (
ASN1_TIME *asn1time
)
{
char *v;
struct tm tm;
if (asn1time->length > 13)
return ((u_long)(~0));
v = (char *)asn1time->data;
tm.tm_year = (v[0] - '0') * 10 + v[1] - '0';
if (tm.tm_year < 50)
tm.tm_year += 100;
tm.tm_mon = (v[2] - '0') * 10 + v[3] - '0' - 1;
tm.tm_mday = (v[4] - '0') * 10 + v[5] - '0';
tm.tm_hour = (v[6] - '0') * 10 + v[7] - '0';
tm.tm_min = (v[8] - '0') * 10 + v[9] - '0';
tm.tm_sec = (v[10] - '0') * 10 + v[11] - '0';
tm.tm_wday = 0;
tm.tm_yday = 0;
tm.tm_isdst = 0;
return (timegm(&tm) + JAN_1970);
}
static int
bighash(
BIGNUM *bn,
BIGNUM *bk
)
{
EVP_MD_CTX ctx;
u_char dgst[EVP_MAX_MD_SIZE];
u_char *ptr;
u_int len;
len = BN_num_bytes(bn);
ptr = emalloc(len);
BN_bn2bin(bn, ptr);
EVP_DigestInit(&ctx, EVP_md5());
EVP_DigestUpdate(&ctx, ptr, len);
EVP_DigestFinal(&ctx, dgst, &len);
BN_bin2bn(dgst, len, bk);
return (1);
}
static int
crypto_alice(
struct peer *peer,
struct value *vp
)
{
DSA *dsa;
BN_CTX *bctx;
EVP_MD_CTX ctx;
tstamp_t tstamp;
u_int len;
if (peer->ident_pkey == NULL)
return (XEVNT_ID);
if ((dsa = peer->ident_pkey->pkey.dsa) == NULL) {
msyslog(LOG_INFO, "crypto_alice: defective key");
return (XEVNT_PUB);
}
bctx = BN_CTX_new();
len = BN_num_bytes(dsa->q);
if (peer->iffval != NULL)
BN_free(peer->iffval);
peer->iffval = BN_new();
BN_rand(peer->iffval, len * 8, -1, 1);
BN_mod(peer->iffval, peer->iffval, dsa->q, bctx);
BN_CTX_free(bctx);
tstamp = crypto_time();
memset(vp, 0, sizeof(struct value));
vp->tstamp = htonl(tstamp);
vp->fstamp = htonl(peer->fstamp);
vp->vallen = htonl(len);
vp->ptr = emalloc(len);
BN_bn2bin(peer->iffval, vp->ptr);
vp->siglen = 0;
if (tstamp == 0)
return (XEVNT_OK);
if (tstamp < cinfo->first || tstamp > cinfo->last)
return (XEVNT_PER);
vp->sig = emalloc(sign_siglen);
EVP_SignInit(&ctx, sign_digest);
EVP_SignUpdate(&ctx, (u_char *)&vp->tstamp, 12);
EVP_SignUpdate(&ctx, vp->ptr, len);
if (EVP_SignFinal(&ctx, vp->sig, &len, sign_pkey))
vp->siglen = htonl(len);
return (XEVNT_OK);
}
static int
crypto_bob(
struct exten *ep,
struct value *vp
)
{
DSA *dsa;
DSA_SIG *sdsa;
BN_CTX *bctx;
EVP_MD_CTX ctx;
tstamp_t tstamp;
BIGNUM *bn, *bk, *r;
u_char *ptr;
u_int len;
if (iffpar_pkey == NULL) {
msyslog(LOG_INFO, "crypto_bob: scheme unavailable");
return (XEVNT_ID);
}
dsa = iffpar_pkey->pkey.dsa;
len = ntohl(ep->vallen);
if ((r = BN_bin2bn((u_char *)ep->pkt, len, NULL)) == NULL) {
msyslog(LOG_ERR, "crypto_bob %s\n",
ERR_error_string(ERR_get_error(), NULL));
return (XEVNT_ERR);
}
bctx = BN_CTX_new(); bk = BN_new(); bn = BN_new();
sdsa = DSA_SIG_new();
BN_rand(bk, len * 8, -1, 1);
BN_mod_mul(bn, dsa->priv_key, r, dsa->q, bctx);
BN_add(bn, bn, bk);
BN_mod(bn, bn, dsa->q, bctx);
sdsa->r = BN_dup(bn);
BN_mod_exp(bk, dsa->g, bk, dsa->p, bctx);
bighash(bk, bk);
sdsa->s = BN_dup(bk);
BN_CTX_free(bctx);
BN_free(r); BN_free(bn); BN_free(bk);
tstamp = crypto_time();
memset(vp, 0, sizeof(struct value));
vp->tstamp = htonl(tstamp);
vp->fstamp = htonl(if_fstamp);
len = i2d_DSA_SIG(sdsa, NULL);
if (len <= 0) {
msyslog(LOG_ERR, "crypto_bob %s\n",
ERR_error_string(ERR_get_error(), NULL));
DSA_SIG_free(sdsa);
return (XEVNT_ERR);
}
vp->vallen = htonl(len);
ptr = emalloc(len);
vp->ptr = ptr;
i2d_DSA_SIG(sdsa, &ptr);
DSA_SIG_free(sdsa);
vp->siglen = 0;
if (tstamp == 0)
return (XEVNT_OK);
if (tstamp < cinfo->first || tstamp > cinfo->last)
return (XEVNT_PER);
vp->sig = emalloc(sign_siglen);
EVP_SignInit(&ctx, sign_digest);
EVP_SignUpdate(&ctx, (u_char *)&vp->tstamp, 12);
EVP_SignUpdate(&ctx, vp->ptr, len);
if (EVP_SignFinal(&ctx, vp->sig, &len, sign_pkey))
vp->siglen = htonl(len);
return (XEVNT_OK);
}
int
crypto_iff(
struct exten *ep,
struct peer *peer
)
{
DSA *dsa;
BN_CTX *bctx;
DSA_SIG *sdsa;
BIGNUM *bn, *bk;
u_int len;
const u_char *ptr;
int temp;
if (peer->ident_pkey == NULL) {
msyslog(LOG_INFO, "crypto_iff: scheme unavailable");
return (XEVNT_ID);
}
if (ntohl(ep->fstamp) != peer->fstamp) {
msyslog(LOG_INFO, "crypto_iff: invalid filestamp %u",
ntohl(ep->fstamp));
return (XEVNT_FSP);
}
if ((dsa = peer->ident_pkey->pkey.dsa) == NULL) {
msyslog(LOG_INFO, "crypto_iff: defective key");
return (XEVNT_PUB);
}
if (peer->iffval == NULL) {
msyslog(LOG_INFO, "crypto_iff: missing challenge");
return (XEVNT_ID);
}
bctx = BN_CTX_new(); bk = BN_new(); bn = BN_new();
len = ntohl(ep->vallen);
ptr = (const u_char *)ep->pkt;
if ((sdsa = d2i_DSA_SIG(NULL, &ptr, len)) == NULL) {
msyslog(LOG_ERR, "crypto_iff %s\n",
ERR_error_string(ERR_get_error(), NULL));
return (XEVNT_ERR);
}
BN_mod_exp(bn, dsa->pub_key, peer->iffval, dsa->p, bctx);
BN_mod_exp(bk, dsa->g, sdsa->r, dsa->p, bctx);
BN_mod_mul(bn, bn, bk, dsa->p, bctx);
bighash(bn, bn);
temp = BN_cmp(bn, sdsa->s);
BN_free(bn); BN_free(bk); BN_CTX_free(bctx);
BN_free(peer->iffval);
peer->iffval = NULL;
DSA_SIG_free(sdsa);
if (temp == 0)
return (XEVNT_OK);
else
return (XEVNT_ID);
}
static int
crypto_alice2(
struct peer *peer,
struct value *vp
)
{
RSA *rsa;
BN_CTX *bctx;
EVP_MD_CTX ctx;
tstamp_t tstamp;
u_int len;
if (peer->ident_pkey == NULL)
return (XEVNT_ID);
if ((rsa = peer->ident_pkey->pkey.rsa) == NULL) {
msyslog(LOG_INFO, "crypto_alice2: defective key");
return (XEVNT_PUB);
}
bctx = BN_CTX_new();
len = BN_num_bytes(rsa->n);
if (peer->iffval != NULL)
BN_free(peer->iffval);
peer->iffval = BN_new();
BN_rand(peer->iffval, len * 8, -1, 1);
BN_mod(peer->iffval, peer->iffval, rsa->n, bctx);
BN_CTX_free(bctx);
tstamp = crypto_time();
memset(vp, 0, sizeof(struct value));
vp->tstamp = htonl(tstamp);
vp->fstamp = htonl(peer->fstamp);
vp->vallen = htonl(len);
vp->ptr = emalloc(len);
BN_bn2bin(peer->iffval, vp->ptr);
vp->siglen = 0;
if (tstamp == 0)
return (XEVNT_OK);
if (tstamp < cinfo->first || tstamp > cinfo->last)
return (XEVNT_PER);
vp->sig = emalloc(sign_siglen);
EVP_SignInit(&ctx, sign_digest);
EVP_SignUpdate(&ctx, (u_char *)&vp->tstamp, 12);
EVP_SignUpdate(&ctx, vp->ptr, len);
if (EVP_SignFinal(&ctx, vp->sig, &len, sign_pkey))
vp->siglen = htonl(len);
return (XEVNT_OK);
}
static int
crypto_bob2(
struct exten *ep,
struct value *vp
)
{
RSA *rsa;
DSA_SIG *sdsa;
BN_CTX *bctx;
EVP_MD_CTX ctx;
tstamp_t tstamp;
BIGNUM *r, *k, *g, *y;
u_char *ptr;
u_int len;
if (gqpar_pkey == NULL) {
msyslog(LOG_INFO, "crypto_bob2: scheme unavailable");
return (XEVNT_ID);
}
rsa = gqpar_pkey->pkey.rsa;
len = ntohl(ep->vallen);
if ((r = BN_bin2bn((u_char *)ep->pkt, len, NULL)) == NULL) {
msyslog(LOG_ERR, "crypto_bob2 %s\n",
ERR_error_string(ERR_get_error(), NULL));
return (XEVNT_ERR);
}
bctx = BN_CTX_new(); k = BN_new(); g = BN_new(); y = BN_new();
sdsa = DSA_SIG_new();
BN_rand(k, len * 8, -1, 1);
BN_mod(k, k, rsa->n, bctx);
BN_mod_exp(y, rsa->p, r, rsa->n, bctx);
BN_mod_mul(y, k, y, rsa->n, bctx);
sdsa->r = BN_dup(y);
BN_mod_exp(g, k, rsa->e, rsa->n, bctx);
bighash(g, g);
sdsa->s = BN_dup(g);
BN_CTX_free(bctx);
BN_free(r); BN_free(k); BN_free(g); BN_free(y);
tstamp = crypto_time();
memset(vp, 0, sizeof(struct value));
vp->tstamp = htonl(tstamp);
vp->fstamp = htonl(gq_fstamp);
len = i2d_DSA_SIG(sdsa, NULL);
if (len <= 0) {
msyslog(LOG_ERR, "crypto_bob2 %s\n",
ERR_error_string(ERR_get_error(), NULL));
DSA_SIG_free(sdsa);
return (XEVNT_ERR);
}
vp->vallen = htonl(len);
ptr = emalloc(len);
vp->ptr = ptr;
i2d_DSA_SIG(sdsa, &ptr);
DSA_SIG_free(sdsa);
vp->siglen = 0;
if (tstamp == 0)
return (XEVNT_OK);
if (tstamp < cinfo->first || tstamp > cinfo->last)
return (XEVNT_PER);
vp->sig = emalloc(sign_siglen);
EVP_SignInit(&ctx, sign_digest);
EVP_SignUpdate(&ctx, (u_char *)&vp->tstamp, 12);
EVP_SignUpdate(&ctx, vp->ptr, len);
if (EVP_SignFinal(&ctx, vp->sig, &len, sign_pkey))
vp->siglen = htonl(len);
return (XEVNT_OK);
}
int
crypto_gq(
struct exten *ep,
struct peer *peer
)
{
RSA *rsa;
BN_CTX *bctx;
DSA_SIG *sdsa;
BIGNUM *y, *v;
const u_char *ptr;
u_int len;
int temp;
if (peer->ident_pkey == NULL) {
msyslog(LOG_INFO, "crypto_gq: scheme unavailable");
return (XEVNT_ID);
}
if (ntohl(ep->fstamp) != peer->fstamp) {
msyslog(LOG_INFO, "crypto_gq: invalid filestamp %u",
ntohl(ep->fstamp));
return (XEVNT_FSP);
}
if ((rsa = peer->ident_pkey->pkey.rsa) == NULL) {
msyslog(LOG_INFO, "crypto_gq: defective key");
return (XEVNT_PUB);
}
if (peer->iffval == NULL) {
msyslog(LOG_INFO, "crypto_gq: missing challenge");
return (XEVNT_ID);
}
bctx = BN_CTX_new(); y = BN_new(); v = BN_new();
len = ntohl(ep->vallen);
ptr = (const u_char *)ep->pkt;
if ((sdsa = d2i_DSA_SIG(NULL, &ptr, len)) == NULL) {
msyslog(LOG_ERR, "crypto_gq %s\n",
ERR_error_string(ERR_get_error(), NULL));
return (XEVNT_ERR);
}
BN_mod_exp(v, peer->grpkey, peer->iffval, rsa->n, bctx);
BN_mod_exp(y, sdsa->r, rsa->e, rsa->n, bctx);
BN_mod_mul(y, v, y, rsa->n, bctx);
bighash(y, y);
temp = BN_cmp(y, sdsa->s);
BN_CTX_free(bctx); BN_free(y); BN_free(v);
BN_free(peer->iffval);
peer->iffval = NULL;
DSA_SIG_free(sdsa);
if (temp == 0)
return (XEVNT_OK);
else
return (XEVNT_ID);
}
static int
crypto_alice3(
struct peer *peer,
struct value *vp
)
{
DSA *dsa;
BN_CTX *bctx;
EVP_MD_CTX ctx;
tstamp_t tstamp;
u_int len;
if (peer->ident_pkey == NULL)
return (XEVNT_ID);
if ((dsa = peer->ident_pkey->pkey.dsa) == NULL) {
msyslog(LOG_INFO, "crypto_alice3: defective key");
return (XEVNT_PUB);
}
bctx = BN_CTX_new();
len = BN_num_bytes(dsa->p);
if (peer->iffval != NULL)
BN_free(peer->iffval);
peer->iffval = BN_new();
BN_rand(peer->iffval, len * 8, -1, 1);
BN_mod(peer->iffval, peer->iffval, dsa->p, bctx);
BN_CTX_free(bctx);
tstamp = crypto_time();
memset(vp, 0, sizeof(struct value));
vp->tstamp = htonl(tstamp);
vp->fstamp = htonl(peer->fstamp);
vp->vallen = htonl(len);
vp->ptr = emalloc(len);
BN_bn2bin(peer->iffval, vp->ptr);
vp->siglen = 0;
if (tstamp == 0)
return (XEVNT_OK);
if (tstamp < cinfo->first || tstamp > cinfo->last)
return (XEVNT_PER);
vp->sig = emalloc(sign_siglen);
EVP_SignInit(&ctx, sign_digest);
EVP_SignUpdate(&ctx, (u_char *)&vp->tstamp, 12);
EVP_SignUpdate(&ctx, vp->ptr, len);
if (EVP_SignFinal(&ctx, vp->sig, &len, sign_pkey))
vp->siglen = htonl(len);
return (XEVNT_OK);
}
static int
crypto_bob3(
struct exten *ep,
struct value *vp
)
{
DSA *dsa;
DSA *sdsa;
BN_CTX *bctx;
EVP_MD_CTX ctx;
tstamp_t tstamp;
BIGNUM *r, *k, *u;
u_char *ptr;
u_int len;
if (mvpar_pkey == NULL) {
msyslog(LOG_INFO, "crypto_bob3: scheme unavailable");
return (XEVNT_ID);
}
dsa = mvpar_pkey->pkey.dsa;
len = ntohl(ep->vallen);
if ((r = BN_bin2bn((u_char *)ep->pkt, len, NULL)) == NULL) {
msyslog(LOG_ERR, "crypto_bob3 %s\n",
ERR_error_string(ERR_get_error(), NULL));
return (XEVNT_ERR);
}
bctx = BN_CTX_new(); k = BN_new(); u = BN_new();
sdsa = DSA_new();
sdsa->p = BN_new(); sdsa->q = BN_new(); sdsa->g = BN_new();
while (1) {
BN_rand(k, BN_num_bits(dsa->q), 0, 0);
BN_mod(k, k, dsa->q, bctx);
BN_gcd(u, k, dsa->q, bctx);
if (BN_is_one(u))
break;
}
BN_mod_exp(u, dsa->g, k, dsa->p, bctx);
BN_mod_mul(u, u, r, dsa->p, bctx);
bighash(u, sdsa->p);
BN_mod_exp(sdsa->q, dsa->priv_key, k, dsa->p, bctx);
BN_mod_exp(sdsa->g, dsa->pub_key, k, dsa->p, bctx);
BN_CTX_free(bctx); BN_free(k); BN_free(r); BN_free(u);
tstamp = crypto_time();
memset(vp, 0, sizeof(struct value));
vp->tstamp = htonl(tstamp);
vp->fstamp = htonl(mv_fstamp);
len = i2d_DSAparams(sdsa, NULL);
if (len <= 0) {
msyslog(LOG_ERR, "crypto_bob3 %s\n",
ERR_error_string(ERR_get_error(), NULL));
DSA_free(sdsa);
return (XEVNT_ERR);
}
vp->vallen = htonl(len);
ptr = emalloc(len);
vp->ptr = ptr;
i2d_DSAparams(sdsa, &ptr);
DSA_free(sdsa);
vp->siglen = 0;
if (tstamp == 0)
return (XEVNT_OK);
if (tstamp < cinfo->first || tstamp > cinfo->last)
return (XEVNT_PER);
vp->sig = emalloc(sign_siglen);
EVP_SignInit(&ctx, sign_digest);
EVP_SignUpdate(&ctx, (u_char *)&vp->tstamp, 12);
EVP_SignUpdate(&ctx, vp->ptr, len);
if (EVP_SignFinal(&ctx, vp->sig, &len, sign_pkey))
vp->siglen = htonl(len);
return (XEVNT_OK);
}
int
crypto_mv(
struct exten *ep,
struct peer *peer
)
{
DSA *dsa;
DSA *sdsa;
BN_CTX *bctx;
BIGNUM *k, *u, *v;
u_int len;
const u_char *ptr;
int temp;
if (peer->ident_pkey == NULL) {
msyslog(LOG_INFO, "crypto_mv: scheme unavailable");
return (XEVNT_ID);
}
if (ntohl(ep->fstamp) != peer->fstamp) {
msyslog(LOG_INFO, "crypto_mv: invalid filestamp %u",
ntohl(ep->fstamp));
return (XEVNT_FSP);
}
if ((dsa = peer->ident_pkey->pkey.dsa) == NULL) {
msyslog(LOG_INFO, "crypto_mv: defective key");
return (XEVNT_PUB);
}
if (peer->iffval == NULL) {
msyslog(LOG_INFO, "crypto_mv: missing challenge");
return (XEVNT_ID);
}
bctx = BN_CTX_new(); k = BN_new(); u = BN_new(); v = BN_new();
len = ntohl(ep->vallen);
ptr = (const u_char *)ep->pkt;
if ((sdsa = d2i_DSAparams(NULL, &ptr, len)) == NULL) {
msyslog(LOG_ERR, "crypto_mv %s\n",
ERR_error_string(ERR_get_error(), NULL));
return (XEVNT_ERR);
}
BN_mod_exp(u, sdsa->q, dsa->pub_key, dsa->p, bctx);
BN_mod_exp(v, sdsa->g, dsa->priv_key, dsa->p, bctx);
BN_mod_mul(u, u, v, dsa->p, bctx);
BN_mod_inverse(u, u, dsa->p, bctx);
BN_mod_mul(v, u, peer->iffval, dsa->p, bctx);
bighash(v, v);
temp = BN_cmp(v, sdsa->p);
BN_CTX_free(bctx); BN_free(k); BN_free(u); BN_free(v);
BN_free(peer->iffval);
peer->iffval = NULL;
DSA_free(sdsa);
if (temp == 0)
return (XEVNT_OK);
else
return (XEVNT_ID);
}
struct cert_info *
cert_parse(
u_char *asn1cert,
u_int len,
tstamp_t fstamp
)
{
X509 *cert;
X509_EXTENSION *ext;
struct cert_info *ret;
BIO *bp;
X509V3_EXT_METHOD *method;
char pathbuf[MAXFILENAME];
u_char *uptr;
char *ptr;
int temp, cnt, i;
uptr = asn1cert;
if ((cert = d2i_X509(NULL, &uptr, len)) == NULL) {
msyslog(LOG_ERR, "cert_parse %s\n",
ERR_error_string(ERR_get_error(), NULL));
return (NULL);
}
ret = emalloc(sizeof(struct cert_info));
memset(ret, 0, sizeof(struct cert_info));
if ((ret->pkey = X509_get_pubkey(cert)) == NULL) {
msyslog(LOG_ERR, "cert_parse %s\n",
ERR_error_string(ERR_get_error(), NULL));
cert_free(ret);
X509_free(cert);
return (NULL);
}
ret->version = X509_get_version(cert);
X509_NAME_oneline(X509_get_subject_name(cert), pathbuf,
MAXFILENAME - 1);
ptr = strstr(pathbuf, "CN=");
if (ptr == NULL) {
msyslog(LOG_INFO, "cert_parse: invalid subject %s",
pathbuf);
cert_free(ret);
X509_free(cert);
return (NULL);
}
ret->subject = emalloc(strlen(ptr) + 1);
strcpy(ret->subject, ptr + 3);
ret->nid = OBJ_obj2nid(cert->cert_info->signature->algorithm);
ret->digest = (const EVP_MD *)EVP_get_digestbynid(ret->nid);
ret->serial =
(u_long)ASN1_INTEGER_get(X509_get_serialNumber(cert));
X509_NAME_oneline(X509_get_issuer_name(cert), pathbuf,
MAXFILENAME);
if ((ptr = strstr(pathbuf, "CN=")) == NULL) {
msyslog(LOG_INFO, "cert_parse: invalid issuer %s",
pathbuf);
cert_free(ret);
X509_free(cert);
return (NULL);
}
ret->issuer = emalloc(strlen(ptr) + 1);
strcpy(ret->issuer, ptr + 3);
ret->first = asn2ntp(X509_get_notBefore(cert));
ret->last = asn2ntp(X509_get_notAfter(cert));
cnt = X509_get_ext_count(cert);
for (i = 0; i < cnt; i++) {
ext = X509_get_ext(cert, i);
method = X509V3_EXT_get(ext);
temp = OBJ_obj2nid(ext->object);
switch (temp) {
case NID_ext_key_usage:
bp = BIO_new(BIO_s_mem());
X509V3_EXT_print(bp, ext, 0, 0);
BIO_gets(bp, pathbuf, MAXFILENAME);
BIO_free(bp);
#if DEBUG
if (debug)
printf("cert_parse: %s: %s\n",
OBJ_nid2ln(temp), pathbuf);
#endif
if (strcmp(pathbuf, "Trust Root") == 0)
ret->flags |= CERT_TRUST;
else if (strcmp(pathbuf, "Private") == 0)
ret->flags |= CERT_PRIV;
break;
case NID_subject_key_identifier:
ret->grplen = ext->value->length - 2;
ret->grpkey = emalloc(ret->grplen);
memcpy(ret->grpkey, &ext->value->data[2],
ret->grplen);
break;
}
}
if (strcmp(ret->subject, ret->issuer) == 0) {
if (!X509_verify(cert, ret->pkey)) {
msyslog(LOG_INFO,
"cert_parse: signature not verified %s",
pathbuf);
cert_free(ret);
X509_free(cert);
return (NULL);
}
}
if (ret->first > ret->last || ret->first < fstamp) {
msyslog(LOG_INFO,
"cert_parse: invalid certificate %s first %u last %u fstamp %u",
ret->subject, ret->first, ret->last, fstamp);
cert_free(ret);
X509_free(cert);
return (NULL);
}
ret->cert.fstamp = htonl(fstamp);
ret->cert.vallen = htonl(len);
ret->cert.ptr = emalloc(len);
memcpy(ret->cert.ptr, asn1cert, len);
#ifdef DEBUG
if (debug > 1)
X509_print_fp(stdout, cert);
#endif
X509_free(cert);
return (ret);
}
static int
cert_sign(
struct exten *ep,
struct value *vp
)
{
X509 *req;
X509 *cert;
X509_EXTENSION *ext;
ASN1_INTEGER *serial;
X509_NAME *subj;
EVP_PKEY *pkey;
EVP_MD_CTX ctx;
tstamp_t tstamp;
u_int len;
u_char *ptr;
int i, temp;
tstamp = crypto_time();
if (tstamp == 0)
return (XEVNT_TSP);
if (tstamp < cinfo->first || tstamp > cinfo->last)
return (XEVNT_PER);
ptr = (u_char *)ep->pkt;
if ((req = d2i_X509(NULL, &ptr, ntohl(ep->vallen))) == NULL) {
msyslog(LOG_ERR, "cert_sign %s\n",
ERR_error_string(ERR_get_error(), NULL));
return (XEVNT_CRT);
}
if ((pkey = X509_get_pubkey(req)) == NULL) {
msyslog(LOG_ERR, "cert_sign %s\n",
ERR_error_string(ERR_get_error(), NULL));
X509_free(req);
return (XEVNT_PUB);
}
cert = X509_new();
X509_set_version(cert, X509_get_version(req));
serial = ASN1_INTEGER_new();
ASN1_INTEGER_set(serial, tstamp);
X509_set_serialNumber(cert, serial);
X509_gmtime_adj(X509_get_notBefore(cert), 0L);
X509_gmtime_adj(X509_get_notAfter(cert), YEAR);
subj = X509_get_issuer_name(cert);
X509_NAME_add_entry_by_txt(subj, "commonName", MBSTRING_ASC,
(u_char *)sys_hostname, strlen(sys_hostname), -1, 0);
subj = X509_get_subject_name(req);
X509_set_subject_name(cert, subj);
X509_set_pubkey(cert, pkey);
ext = X509_get_ext(req, 0);
temp = X509_get_ext_count(req);
for (i = 0; i < temp; i++) {
ext = X509_get_ext(req, i);
X509_add_ext(cert, ext, -1);
}
X509_free(req);
X509_sign(cert, sign_pkey, sign_digest);
if (!X509_verify(cert, sign_pkey)) {
printf("cert_sign\n%s\n",
ERR_error_string(ERR_get_error(), NULL));
X509_free(cert);
return (XEVNT_VFY);
}
len = i2d_X509(cert, NULL);
memset(vp, 0, sizeof(struct value));
vp->tstamp = htonl(tstamp);
vp->fstamp = ep->fstamp;
vp->vallen = htonl(len);
vp->ptr = emalloc(len);
ptr = vp->ptr;
i2d_X509(cert, &ptr);
vp->siglen = 0;
vp->sig = emalloc(sign_siglen);
EVP_SignInit(&ctx, sign_digest);
EVP_SignUpdate(&ctx, (u_char *)vp, 12);
EVP_SignUpdate(&ctx, vp->ptr, len);
if (EVP_SignFinal(&ctx, vp->sig, &len, sign_pkey))
vp->siglen = htonl(len);
#ifdef DEBUG
if (debug > 1)
X509_print_fp(stdout, cert);
#endif
X509_free(cert);
return (XEVNT_OK);
}
int
cert_valid(
struct cert_info *cinf,
EVP_PKEY *pkey
)
{
X509 *cert;
u_char *ptr;
if (cinf->flags & CERT_SIGN)
return (XEVNT_OK);
ptr = (u_char *)cinf->cert.ptr;
cert = d2i_X509(NULL, &ptr, ntohl(cinf->cert.vallen));
if (cert == NULL || !X509_verify(cert, pkey))
return (XEVNT_VFY);
X509_free(cert);
return (XEVNT_OK);
}
int
cert_install(
struct exten *ep,
struct peer *peer
)
{
struct cert_info *cp, *xp, *yp, **zp;
if ((cp = cert_parse((u_char *)ep->pkt, ntohl(ep->vallen),
ntohl(ep->fstamp))) == NULL)
return (XEVNT_CRT);
yp = cp;
zp = &cinfo;
for (xp = cinfo; xp != NULL; xp = xp->link) {
if (strcmp(cp->subject, xp->subject) == 0 &&
strcmp(cp->issuer, xp->issuer) == 0) {
if (ntohl(cp->cert.fstamp) <=
ntohl(xp->cert.fstamp)) {
*zp = xp->link;;
cert_free(xp);
} else {
cert_free(cp);
return (XEVNT_FSP);
}
break;
}
zp = &xp->link;
}
yp->link = cinfo;
cinfo = yp;
for (yp = cinfo; yp != NULL; yp = yp->link) {
for (xp = cinfo; xp != NULL; xp = xp->link) {
if (strcmp(yp->issuer, xp->subject) != 0 ||
xp->flags & CERT_ERROR)
continue;
if (cert_valid(yp, xp->pkey) != XEVNT_OK) {
yp->flags |= CERT_ERROR;
continue;
}
if (yp->first < xp->first || yp->first >
xp->last)
continue;
yp->flags |= CERT_SIGN;
if (!(xp->flags & (CERT_TRUST | CERT_VALID)))
continue;
yp->flags |= CERT_VALID;
if (strcmp(yp->subject, peer->subject) != 0)
continue;
if (yp->grpkey != NULL) {
if (peer->grpkey != NULL)
BN_free(peer->grpkey);
peer->grpkey = BN_bin2bn(yp->grpkey,
yp->grplen, NULL);
}
peer->crypto |= CRYPTO_FLAG_VALID;
if (peer->crypto & (CRYPTO_FLAG_GQ |
CRYPTO_FLAG_IFF | CRYPTO_FLAG_MV))
continue;
peer->crypto |= CRYPTO_FLAG_VRFY;
}
}
crypto_update();
return (XEVNT_OK);
}
void
cert_free(
struct cert_info *cinf
)
{
if (cinf->pkey != NULL)
EVP_PKEY_free(cinf->pkey);
if (cinf->subject != NULL)
free(cinf->subject);
if (cinf->issuer != NULL)
free(cinf->issuer);
if (cinf->grpkey != NULL)
free(cinf->grpkey);
value_free(&cinf->cert);
free(cinf);
}
static EVP_PKEY *
crypto_key(
char *cp,
tstamp_t *fstamp
)
{
FILE *str;
EVP_PKEY *pkey = NULL;
char filename[MAXFILENAME];
char linkname[MAXFILENAME];
char statstr[NTP_MAXSTRLEN];
char *ptr;
if (*cp == '/')
strcpy(filename, cp);
else
snprintf(filename, MAXFILENAME, "%s/%s", keysdir, cp);
str = fopen(filename, "r");
if (str == NULL)
return (NULL);
if ((ptr = fgets(linkname, MAXFILENAME, str)) == NULL) {
msyslog(LOG_ERR, "crypto_key: no data %s\n",
filename);
(void)fclose(str);
return (NULL);
}
if ((ptr = strrchr(ptr, '.')) == NULL) {
msyslog(LOG_ERR, "crypto_key: no filestamp %s\n",
filename);
(void)fclose(str);
return (NULL);
}
if (sscanf(++ptr, "%u", fstamp) != 1) {
msyslog(LOG_ERR, "crypto_key: invalid timestamp %s\n",
filename);
(void)fclose(str);
return (NULL);
}
pkey = PEM_read_PrivateKey(str, NULL, NULL, passwd);
fclose(str);
if (pkey == NULL) {
msyslog(LOG_ERR, "crypto_key %s\n",
ERR_error_string(ERR_get_error(), NULL));
return (NULL);
}
if ((ptr = strrchr(linkname, '\n')) != NULL)
*ptr = '\0';
sprintf(statstr, "%s mod %d", &linkname[2],
EVP_PKEY_size(pkey) * 8);
record_crypto_stats(NULL, statstr);
#ifdef DEBUG
if (debug)
printf("crypto_key: %s\n", statstr);
if (debug > 1) {
if (EVP_MD_type(pkey) == EVP_PKEY_DSA)
DSA_print_fp(stdout, pkey->pkey.dsa, 0);
else
RSA_print_fp(stdout, pkey->pkey.rsa, 0);
}
#endif
return (pkey);
}
static struct cert_info *
crypto_cert(
char *cp
)
{
struct cert_info *ret;
FILE *str;
char filename[MAXFILENAME];
char linkname[MAXFILENAME];
char statstr[NTP_MAXSTRLEN];
tstamp_t fstamp;
long len;
char *ptr;
char *name, *header;
u_char *data;
if (*cp == '/')
strcpy(filename, cp);
else
snprintf(filename, MAXFILENAME, "%s/%s", keysdir, cp);
str = fopen(filename, "r");
if (str == NULL)
return (NULL);
if ((ptr = fgets(linkname, MAXFILENAME, str)) == NULL) {
msyslog(LOG_ERR, "crypto_cert: no data %s\n",
filename);
(void)fclose(str);
return (NULL);
}
if ((ptr = strrchr(ptr, '.')) == NULL) {
msyslog(LOG_ERR, "crypto_cert: no filestamp %s\n",
filename);
(void)fclose(str);
return (NULL);
}
if (sscanf(++ptr, "%u", &fstamp) != 1) {
msyslog(LOG_ERR, "crypto_cert: invalid filestamp %s\n",
filename);
(void)fclose(str);
return (NULL);
}
if (!PEM_read(str, &name, &header, &data, &len)) {
msyslog(LOG_ERR, "crypto_cert %s\n",
ERR_error_string(ERR_get_error(), NULL));
(void)fclose(str);
return (NULL);
}
free(header);
if (strcmp(name, "CERTIFICATE") !=0) {
msyslog(LOG_INFO, "crypto_cert: wrong PEM type %s",
name);
free(name);
free(data);
(void)fclose(str);
return (NULL);
}
free(name);
ret = cert_parse(data, len, fstamp);
free(data);
(void)fclose(str);
if (ret == NULL)
return (NULL);
if ((ptr = strrchr(linkname, '\n')) != NULL)
*ptr = '\0';
sprintf(statstr, "%s 0x%x len %lu", &linkname[2], ret->flags,
len);
record_crypto_stats(NULL, statstr);
#ifdef DEBUG
if (debug)
printf("crypto_cert: %s\n", statstr);
#endif
return (ret);
}
static void
crypto_tai(
char *cp
)
{
FILE *str;
char buf[NTP_MAXSTRLEN];
u_int32 leapsec[MAX_LEAP];
int offset;
char filename[MAXFILENAME];
char linkname[MAXFILENAME];
char statstr[NTP_MAXSTRLEN];
tstamp_t fstamp;
u_int len;
u_int32 *ptr;
char *dp;
int rval, i, j;
if (*cp == '/')
strcpy(filename, cp);
else
snprintf(filename, MAXFILENAME, "%s/%s", keysdir, cp);
if ((str = fopen(filename, "r")) == NULL)
return;
rval = readlink(filename, linkname, MAXFILENAME - 1);
if (rval > 0) {
linkname[rval] = '\0';
dp = strrchr(linkname, '.');
} else {
dp = strrchr(filename, '.');
}
if (dp != NULL)
sscanf(++dp, "%u", &fstamp);
else
fstamp = 0;
tai_leap.fstamp = htonl(fstamp);
i = 0;
while (i < MAX_LEAP) {
dp = fgets(buf, NTP_MAXSTRLEN - 1, str);
if (dp == NULL)
break;
if (strlen(buf) < 1)
continue;
if (*buf == '#')
continue;
if (sscanf(buf, "%u %d", &leapsec[i], &offset) != 2)
continue;
if (i != offset - TAI_1972)
break;
i++;
}
fclose(str);
if (dp != NULL) {
msyslog(LOG_INFO,
"crypto_tai: leapseconds file %s error %d", cp,
rval);
exit (-1);
}
len = i * sizeof(u_int32);
tai_leap.vallen = htonl(len);
ptr = emalloc(len);
tai_leap.ptr = (u_char *)ptr;
for (j = 0; j < i; j++)
*ptr++ = htonl(leapsec[j]);
crypto_flags |= CRYPTO_FLAG_TAI;
sprintf(statstr, "%s fs %u leap %u len %u", cp, fstamp,
leapsec[--j], len);
record_crypto_stats(NULL, statstr);
#ifdef DEBUG
if (debug)
printf("crypto_tai: %s\n", statstr);
#endif
}
void
crypto_setup(void)
{
EVP_PKEY *pkey;
char filename[MAXFILENAME];
l_fp seed;
tstamp_t fstamp;
tstamp_t sstamp;
u_int len, bytes;
u_char *ptr;
if (!crypto_flags)
return;
gethostname(filename, MAXFILENAME);
bytes = strlen(filename) + 1;
sys_hostname = emalloc(bytes);
memcpy(sys_hostname, filename, bytes);
if (passwd == NULL)
passwd = sys_hostname;
memset(&hostval, 0, sizeof(hostval));
memset(&pubkey, 0, sizeof(pubkey));
memset(&tai_leap, 0, sizeof(tai_leap));
ERR_load_crypto_strings();
if (rand_file == NULL) {
if ((RAND_file_name(filename, MAXFILENAME)) != NULL) {
rand_file = emalloc(strlen(filename) + 1);
strcpy(rand_file, filename);
}
} else if (*rand_file != '/') {
snprintf(filename, MAXFILENAME, "%s/%s", keysdir,
rand_file);
free(rand_file);
rand_file = emalloc(strlen(filename) + 1);
strcpy(rand_file, filename);
}
if (rand_file == NULL) {
msyslog(LOG_ERR,
"crypto_setup: random seed file not specified");
exit (-1);
}
if ((bytes = RAND_load_file(rand_file, -1)) == 0) {
msyslog(LOG_ERR,
"crypto_setup: random seed file %s not found\n",
rand_file);
exit (-1);
}
get_systime(&seed);
RAND_seed(&seed, sizeof(l_fp));
RAND_write_file(rand_file);
OpenSSL_add_all_algorithms();
#ifdef DEBUG
if (debug)
printf(
"crypto_setup: OpenSSL version %lx random seed file %s bytes read %d\n",
SSLeay(), rand_file, bytes);
#endif
if (host_file == NULL) {
snprintf(filename, MAXFILENAME, "ntpkey_host_%s",
sys_hostname);
host_file = emalloc(strlen(filename) + 1);
strcpy(host_file, filename);
}
pkey = crypto_key(host_file, &fstamp);
if (pkey == NULL) {
msyslog(LOG_ERR,
"crypto_setup: host key file %s not found or corrupt",
host_file);
exit (-1);
}
host_pkey = pkey;
sign_pkey = pkey;
sstamp = fstamp;
hostval.fstamp = htonl(fstamp);
if (EVP_MD_type(host_pkey) != EVP_PKEY_RSA) {
msyslog(LOG_ERR,
"crypto_setup: host key is not RSA key type");
exit (-1);
}
hostval.vallen = htonl(strlen(sys_hostname));
hostval.ptr = (u_char *)sys_hostname;
len = i2d_PublicKey(host_pkey, NULL);
ptr = emalloc(len);
pubkey.ptr = ptr;
i2d_PublicKey(host_pkey, &ptr);
pubkey.vallen = htonl(len);
pubkey.fstamp = hostval.fstamp;
if (sign_file == NULL) {
snprintf(filename, MAXFILENAME, "ntpkey_sign_%s",
sys_hostname);
sign_file = emalloc(strlen(filename) + 1);
strcpy(sign_file, filename);
}
pkey = crypto_key(sign_file, &fstamp);
if (pkey != NULL) {
sign_pkey = pkey;
sstamp = fstamp;
}
sign_siglen = EVP_PKEY_size(sign_pkey);
if (iffpar_file == NULL) {
snprintf(filename, MAXFILENAME, "ntpkey_iff_%s",
sys_hostname);
iffpar_file = emalloc(strlen(filename) + 1);
strcpy(iffpar_file, filename);
}
iffpar_pkey = crypto_key(iffpar_file, &if_fstamp);
if (iffpar_pkey != NULL)
crypto_flags |= CRYPTO_FLAG_IFF;
if (gqpar_file == NULL) {
snprintf(filename, MAXFILENAME, "ntpkey_gq_%s",
sys_hostname);
gqpar_file = emalloc(strlen(filename) + 1);
strcpy(gqpar_file, filename);
}
gqpar_pkey = crypto_key(gqpar_file, &gq_fstamp);
if (gqpar_pkey != NULL)
crypto_flags |= CRYPTO_FLAG_GQ;
if (mvpar_file == NULL) {
snprintf(filename, MAXFILENAME, "ntpkey_mv_%s",
sys_hostname);
mvpar_file = emalloc(strlen(filename) + 1);
strcpy(mvpar_file, filename);
}
mvpar_pkey = crypto_key(mvpar_file, &mv_fstamp);
if (mvpar_pkey != NULL)
crypto_flags |= CRYPTO_FLAG_MV;
if (cert_file == NULL) {
snprintf(filename, MAXFILENAME, "ntpkey_cert_%s",
sys_hostname);
cert_file = emalloc(strlen(filename) + 1);
strcpy(cert_file, filename);
}
if ((cinfo = crypto_cert(cert_file)) == NULL) {
msyslog(LOG_ERR,
"certificate file %s not found or corrupt",
cert_file);
exit (-1);
}
if (!(cinfo->flags & CERT_PRIV) && strcmp(cinfo->subject,
sys_hostname) != 0) {
msyslog(LOG_ERR,
"crypto_setup: certificate %s not for this host",
cert_file);
cert_free(cinfo);
exit (-1);
}
if (cinfo->flags & CERT_TRUST && strcmp(cinfo->subject,
cinfo->issuer) != 0) {
if (cert_valid(cinfo, sign_pkey) != XEVNT_OK) {
msyslog(LOG_ERR,
"crypto_setup: certificate %s is trusted, but not self signed.",
cert_file);
cert_free(cinfo);
exit (-1);
}
}
sign_digest = cinfo->digest;
if (cinfo->flags & CERT_PRIV)
crypto_flags |= CRYPTO_FLAG_PRIV;
crypto_flags |= cinfo->nid << 16;
if (leap_file == NULL)
leap_file = "ntpkey_leap";
crypto_tai(leap_file);
#ifdef DEBUG
if (debug)
printf(
"crypto_setup: flags 0x%x host %s signature %s\n",
crypto_flags, sys_hostname, OBJ_nid2ln(cinfo->nid));
#endif
}
void
crypto_config(
int item,
char *cp
)
{
switch (item) {
case CRYPTO_CONF_RAND:
rand_file = emalloc(strlen(cp) + 1);
strcpy(rand_file, cp);
break;
case CRYPTO_CONF_PW:
passwd = emalloc(strlen(cp) + 1);
strcpy(passwd, cp);
break;
case CRYPTO_CONF_PRIV:
host_file = emalloc(strlen(cp) + 1);
strcpy(host_file, cp);
break;
case CRYPTO_CONF_SIGN:
sign_file = emalloc(strlen(cp) + 1);
strcpy(sign_file, cp);
break;
case CRYPTO_CONF_IFFPAR:
iffpar_file = emalloc(strlen(cp) + 1);
strcpy(iffpar_file, cp);
break;
case CRYPTO_CONF_GQPAR:
gqpar_file = emalloc(strlen(cp) + 1);
strcpy(gqpar_file, cp);
break;
case CRYPTO_CONF_MVPAR:
mvpar_file = emalloc(strlen(cp) + 1);
strcpy(mvpar_file, cp);
break;
case CRYPTO_CONF_IDENT:
if (!strcasecmp(cp, "iff"))
ident_scheme |= CRYPTO_FLAG_IFF;
else if (!strcasecmp(cp, "gq"))
ident_scheme |= CRYPTO_FLAG_GQ;
else if (!strcasecmp(cp, "mv"))
ident_scheme |= CRYPTO_FLAG_MV;
break;
case CRYPTO_CONF_CERT:
cert_file = emalloc(strlen(cp) + 1);
strcpy(cert_file, cp);
break;
case CRYPTO_CONF_LEAP:
leap_file = emalloc(strlen(cp) + 1);
strcpy(leap_file, cp);
break;
}
crypto_flags |= CRYPTO_FLAG_ENAB;
}
# else
int ntp_crypto_bs_pubkey;
# endif