Index: net/third_party/nss/ssl/sslsnce.c |
diff --git a/net/third_party/nss/ssl/sslsnce.c b/net/third_party/nss/ssl/sslsnce.c |
new file mode 100644 |
index 0000000000000000000000000000000000000000..115766cb60112f5a0ed0dbbd0175cf3322a24f07 |
--- /dev/null |
+++ b/net/third_party/nss/ssl/sslsnce.c |
@@ -0,0 +1,1952 @@ |
+/* This file implements the SERVER Session ID cache. |
+ * NOTE: The contents of this file are NOT used by the client. |
+ * |
+ * ***** BEGIN LICENSE BLOCK ***** |
+ * Version: MPL 1.1/GPL 2.0/LGPL 2.1 |
+ * |
+ * The contents of this file are subject to the Mozilla Public License Version |
+ * 1.1 (the "License"); you may not use this file except in compliance with |
+ * the License. You may obtain a copy of the License at |
+ * http://www.mozilla.org/MPL/ |
+ * |
+ * Software distributed under the License is distributed on an "AS IS" basis, |
+ * WITHOUT WARRANTY OF ANY KIND, either express or implied. See the License |
+ * for the specific language governing rights and limitations under the |
+ * License. |
+ * |
+ * The Original Code is the Netscape security libraries. |
+ * |
+ * The Initial Developer of the Original Code is |
+ * Netscape Communications Corporation. |
+ * Portions created by the Initial Developer are Copyright (C) 1994-2000 |
+ * the Initial Developer. All Rights Reserved. |
+ * |
+ * Contributor(s): |
+ * |
+ * Alternatively, the contents of this file may be used under the terms of |
+ * either the GNU General Public License Version 2 or later (the "GPL"), or |
+ * the GNU Lesser General Public License Version 2.1 or later (the "LGPL"), |
+ * in which case the provisions of the GPL or the LGPL are applicable instead |
+ * of those above. If you wish to allow use of your version of this file only |
+ * under the terms of either the GPL or the LGPL, and not to allow others to |
+ * use your version of this file under the terms of the MPL, indicate your |
+ * decision by deleting the provisions above and replace them with the notice |
+ * and other provisions required by the GPL or the LGPL. If you do not delete |
+ * the provisions above, a recipient may use your version of this file under |
+ * the terms of any one of the MPL, the GPL or the LGPL. |
+ * |
+ * ***** END LICENSE BLOCK ***** */ |
+/* $Id: sslsnce.c,v 1.51 2009/11/07 18:23:06 wtc%google.com Exp $ */ |
+ |
+/* Note: ssl_FreeSID() in sslnonce.c gets used for both client and server |
+ * cache sids! |
+ * |
+ * About record locking among different server processes: |
+ * |
+ * All processes that are part of the same conceptual server (serving on |
+ * the same address and port) MUST share a common SSL session cache. |
+ * This code makes the content of the shared cache accessible to all |
+ * processes on the same "server". This code works on Unix and Win32 only. |
+ * |
+ * We use NSPR anonymous shared memory and move data to & from shared memory. |
+ * We must do explicit locking of the records for all reads and writes. |
+ * The set of Cache entries are divided up into "sets" of 128 entries. |
+ * Each set is protected by a lock. There may be one or more sets protected |
+ * by each lock. That is, locks to sets are 1:N. |
+ * There is one lock for the entire cert cache. |
+ * There is one lock for the set of wrapped sym wrap keys. |
+ * |
+ * The anonymous shared memory is laid out as if it were declared like this: |
+ * |
+ * struct { |
+ * cacheDescriptor desc; |
+ * sidCacheLock sidCacheLocks[ numSIDCacheLocks]; |
+ * sidCacheLock keyCacheLock; |
+ * sidCacheLock certCacheLock; |
+ * sidCacheSet sidCacheSets[ numSIDCacheSets ]; |
+ * sidCacheEntry sidCacheData[ numSIDCacheEntries]; |
+ * certCacheEntry certCacheData[numCertCacheEntries]; |
+ * SSLWrappedSymWrappingKey keyCacheData[kt_kea_size][SSL_NUM_WRAP_MECHS]; |
+ * uint8 keyNameSuffix[SESS_TICKET_KEY_VAR_NAME_LEN] |
+ * encKeyCacheEntry ticketEncKey; // Wrapped in non-bypass mode |
+ * encKeyCacheEntry ticketMacKey; // Wrapped in non-bypass mode |
+ * PRBool ticketKeysValid; |
+ * } cacheMemCacheData; |
+ */ |
+#include "seccomon.h" |
+ |
+#if defined(XP_UNIX) || defined(XP_WIN32) || defined (XP_OS2) || defined(XP_BEOS) |
+ |
+#include "cert.h" |
+#include "ssl.h" |
+#include "sslimpl.h" |
+#include "sslproto.h" |
+#include "pk11func.h" |
+#include "base64.h" |
+#include "keyhi.h" |
+ |
+#include <stdio.h> |
+ |
+#if defined(XP_UNIX) || defined(XP_BEOS) |
+ |
+#include <syslog.h> |
+#include <fcntl.h> |
+#include <unistd.h> |
+#include <errno.h> |
+#include <signal.h> |
+#include "unix_err.h" |
+ |
+#else |
+ |
+#ifdef XP_WIN32 |
+#include <wtypes.h> |
+#include "win32err.h" |
+#endif |
+ |
+#endif |
+#include <sys/types.h> |
+ |
+#define SET_ERROR_CODE /* reminder */ |
+ |
+#include "nspr.h" |
+#include "sslmutex.h" |
+ |
+/* |
+** Format of a cache entry in the shared memory. |
+*/ |
+struct sidCacheEntryStr { |
+/* 16 */ PRIPv6Addr addr; /* client's IP address */ |
+/* 4 */ PRUint32 creationTime; |
+/* 4 */ PRUint32 lastAccessTime; |
+/* 4 */ PRUint32 expirationTime; |
+/* 2 */ PRUint16 version; |
+/* 1 */ PRUint8 valid; |
+/* 1 */ PRUint8 sessionIDLength; |
+/* 32 */ PRUint8 sessionID[SSL3_SESSIONID_BYTES]; |
+/* 2 */ PRUint16 authAlgorithm; |
+/* 2 */ PRUint16 authKeyBits; |
+/* 2 */ PRUint16 keaType; |
+/* 2 */ PRUint16 keaKeyBits; |
+/* 72 - common header total */ |
+ |
+ union { |
+ struct { |
+/* 64 */ PRUint8 masterKey[SSL_MAX_MASTER_KEY_BYTES]; |
+/* 32 */ PRUint8 cipherArg[SSL_MAX_CYPHER_ARG_BYTES]; |
+ |
+/* 1 */ PRUint8 cipherType; |
+/* 1 */ PRUint8 masterKeyLen; |
+/* 1 */ PRUint8 keyBits; |
+/* 1 */ PRUint8 secretKeyBits; |
+/* 1 */ PRUint8 cipherArgLen; |
+/*101 */} ssl2; |
+ |
+ struct { |
+/* 2 */ ssl3CipherSuite cipherSuite; |
+/* 2 */ PRUint16 compression; /* SSLCompressionMethod */ |
+ |
+/*100 */ ssl3SidKeys keys; /* keys and ivs, wrapped as needed. */ |
+ |
+/* 4 */ PRUint32 masterWrapMech; |
+/* 4 */ SSL3KEAType exchKeyType; |
+/* 4 */ PRInt32 certIndex; |
+/*116 */} ssl3; |
+/* force sizeof(sidCacheEntry) to be a multiple of cache line size */ |
+ struct { |
+/*120 */ PRUint8 filler[120]; /* 72+120==196, a multiple of 16 */ |
+ } forceSize; |
+ } u; |
+}; |
+typedef struct sidCacheEntryStr sidCacheEntry; |
+ |
+/* The length of this struct is supposed to be a power of 2, e.g. 4KB */ |
+struct certCacheEntryStr { |
+ PRUint16 certLength; /* 2 */ |
+ PRUint16 sessionIDLength; /* 2 */ |
+ PRUint8 sessionID[SSL3_SESSIONID_BYTES]; /* 32 */ |
+ PRUint8 cert[SSL_MAX_CACHED_CERT_LEN]; /* 4060 */ |
+}; /* total 4096 */ |
+typedef struct certCacheEntryStr certCacheEntry; |
+ |
+struct sidCacheLockStr { |
+ PRUint32 timeStamp; |
+ sslMutex mutex; |
+ sslPID pid; |
+}; |
+typedef struct sidCacheLockStr sidCacheLock; |
+ |
+struct sidCacheSetStr { |
+ PRIntn next; |
+}; |
+typedef struct sidCacheSetStr sidCacheSet; |
+ |
+struct encKeyCacheEntryStr { |
+ PRUint8 bytes[512]; |
+ PRInt32 length; |
+}; |
+typedef struct encKeyCacheEntryStr encKeyCacheEntry; |
+ |
+struct cacheDescStr { |
+ |
+ PRUint32 cacheMemSize; |
+ |
+ PRUint32 numSIDCacheLocks; |
+ PRUint32 numSIDCacheSets; |
+ PRUint32 numSIDCacheSetsPerLock; |
+ |
+ PRUint32 numSIDCacheEntries; |
+ PRUint32 sidCacheSize; |
+ |
+ PRUint32 numCertCacheEntries; |
+ PRUint32 certCacheSize; |
+ |
+ PRUint32 numKeyCacheEntries; |
+ PRUint32 keyCacheSize; |
+ |
+ PRUint32 ssl2Timeout; |
+ PRUint32 ssl3Timeout; |
+ |
+ PRUint32 numSIDCacheLocksInitialized; |
+ |
+ /* These values are volatile, and are accessed through sharedCache-> */ |
+ PRUint32 nextCertCacheEntry; /* certCacheLock protects */ |
+ PRBool stopPolling; |
+ PRBool everInherited; |
+ |
+ /* The private copies of these values are pointers into shared mem */ |
+ /* The copies of these values in shared memory are merely offsets */ |
+ sidCacheLock * sidCacheLocks; |
+ sidCacheLock * keyCacheLock; |
+ sidCacheLock * certCacheLock; |
+ sidCacheSet * sidCacheSets; |
+ sidCacheEntry * sidCacheData; |
+ certCacheEntry * certCacheData; |
+ SSLWrappedSymWrappingKey * keyCacheData; |
+ uint8 * ticketKeyNameSuffix; |
+ encKeyCacheEntry * ticketEncKey; |
+ encKeyCacheEntry * ticketMacKey; |
+ PRUint32 * ticketKeysValid; |
+ |
+ /* Only the private copies of these pointers are valid */ |
+ char * cacheMem; |
+ struct cacheDescStr * sharedCache; /* shared copy of this struct */ |
+ PRFileMap * cacheMemMap; |
+ PRThread * poller; |
+ PRUint32 mutexTimeout; |
+ PRBool shared; |
+}; |
+typedef struct cacheDescStr cacheDesc; |
+ |
+static cacheDesc globalCache; |
+ |
+static const char envVarName[] = { SSL_ENV_VAR_NAME }; |
+ |
+static PRBool isMultiProcess = PR_FALSE; |
+ |
+ |
+#define DEF_SID_CACHE_ENTRIES 10000 |
+#define DEF_CERT_CACHE_ENTRIES 250 |
+#define MIN_CERT_CACHE_ENTRIES 125 /* the effective size in old releases. */ |
+#define DEF_KEY_CACHE_ENTRIES 250 |
+ |
+#define SID_CACHE_ENTRIES_PER_SET 128 |
+#define SID_ALIGNMENT 16 |
+ |
+#define DEF_SSL2_TIMEOUT 100 /* seconds */ |
+#define MAX_SSL2_TIMEOUT 100 /* seconds */ |
+#define MIN_SSL2_TIMEOUT 5 /* seconds */ |
+ |
+#define DEF_SSL3_TIMEOUT 86400L /* 24 hours */ |
+#define MAX_SSL3_TIMEOUT 86400L /* 24 hours */ |
+#define MIN_SSL3_TIMEOUT 5 /* seconds */ |
+ |
+#if defined(AIX) || defined(LINUX) || defined(NETBSD) || defined(OPENBSD) |
+#define MAX_SID_CACHE_LOCKS 8 /* two FDs per lock */ |
+#elif defined(OSF1) |
+#define MAX_SID_CACHE_LOCKS 16 /* one FD per lock */ |
+#else |
+#define MAX_SID_CACHE_LOCKS 256 |
+#endif |
+ |
+#define SID_HOWMANY(val, size) (((val) + ((size) - 1)) / (size)) |
+#define SID_ROUNDUP(val, size) ((size) * SID_HOWMANY((val), (size))) |
+ |
+ |
+static sslPID myPid; |
+static PRUint32 ssl_max_sid_cache_locks = MAX_SID_CACHE_LOCKS; |
+ |
+/* forward static function declarations */ |
+static PRUint32 SIDindex(cacheDesc *cache, const PRIPv6Addr *addr, PRUint8 *s, |
+ unsigned nl); |
+static SECStatus LaunchLockPoller(cacheDesc *cache); |
+static SECStatus StopLockPoller(cacheDesc *cache); |
+ |
+ |
+struct inheritanceStr { |
+ PRUint32 cacheMemSize; |
+ PRUint32 fmStrLen; |
+}; |
+ |
+typedef struct inheritanceStr inheritance; |
+ |
+#if defined(_WIN32) || defined(XP_OS2) |
+ |
+#define DEFAULT_CACHE_DIRECTORY "\\temp" |
+ |
+#endif /* _win32 */ |
+ |
+#if defined(XP_UNIX) || defined(XP_BEOS) |
+ |
+#define DEFAULT_CACHE_DIRECTORY "/tmp" |
+ |
+#endif /* XP_UNIX || XP_BEOS */ |
+ |
+ |
+/************************************************************************/ |
+ |
+static PRUint32 |
+LockSidCacheLock(sidCacheLock *lock, PRUint32 now) |
+{ |
+ SECStatus rv = sslMutex_Lock(&lock->mutex); |
+ if (rv != SECSuccess) |
+ return 0; |
+ if (!now) |
+ now = ssl_Time(); |
+ lock->timeStamp = now; |
+ lock->pid = myPid; |
+ return now; |
+} |
+ |
+static SECStatus |
+UnlockSidCacheLock(sidCacheLock *lock) |
+{ |
+ SECStatus rv; |
+ |
+ lock->pid = 0; |
+ rv = sslMutex_Unlock(&lock->mutex); |
+ return rv; |
+} |
+ |
+/* returns the value of ssl_Time on success, zero on failure. */ |
+static PRUint32 |
+LockSet(cacheDesc *cache, PRUint32 set, PRUint32 now) |
+{ |
+ PRUint32 lockNum = set % cache->numSIDCacheLocks; |
+ sidCacheLock * lock = cache->sidCacheLocks + lockNum; |
+ |
+ return LockSidCacheLock(lock, now); |
+} |
+ |
+static SECStatus |
+UnlockSet(cacheDesc *cache, PRUint32 set) |
+{ |
+ PRUint32 lockNum = set % cache->numSIDCacheLocks; |
+ sidCacheLock * lock = cache->sidCacheLocks + lockNum; |
+ |
+ return UnlockSidCacheLock(lock); |
+} |
+ |
+/************************************************************************/ |
+ |
+ |
+/* Put a certificate in the cache. Update the cert index in the sce. |
+*/ |
+static PRUint32 |
+CacheCert(cacheDesc * cache, CERTCertificate *cert, sidCacheEntry *sce) |
+{ |
+ PRUint32 now; |
+ certCacheEntry cce; |
+ |
+ if ((cert->derCert.len > SSL_MAX_CACHED_CERT_LEN) || |
+ (cert->derCert.len <= 0) || |
+ (cert->derCert.data == NULL)) { |
+ PORT_SetError(SEC_ERROR_INVALID_ARGS); |
+ return 0; |
+ } |
+ |
+ cce.sessionIDLength = sce->sessionIDLength; |
+ PORT_Memcpy(cce.sessionID, sce->sessionID, cce.sessionIDLength); |
+ |
+ cce.certLength = cert->derCert.len; |
+ PORT_Memcpy(cce.cert, cert->derCert.data, cce.certLength); |
+ |
+ /* get lock on cert cache */ |
+ now = LockSidCacheLock(cache->certCacheLock, 0); |
+ if (now) { |
+ |
+ /* Find where to place the next cert cache entry. */ |
+ cacheDesc * sharedCache = cache->sharedCache; |
+ PRUint32 ndx = sharedCache->nextCertCacheEntry; |
+ |
+ /* write the entry */ |
+ cache->certCacheData[ndx] = cce; |
+ |
+ /* remember where we put it. */ |
+ sce->u.ssl3.certIndex = ndx; |
+ |
+ /* update the "next" cache entry index */ |
+ sharedCache->nextCertCacheEntry = |
+ (ndx + 1) % cache->numCertCacheEntries; |
+ |
+ UnlockSidCacheLock(cache->certCacheLock); |
+ } |
+ return now; |
+ |
+} |
+ |
+/* |
+** Convert local SID to shared memory one |
+*/ |
+static void |
+ConvertFromSID(sidCacheEntry *to, sslSessionID *from) |
+{ |
+ to->valid = 1; |
+ to->version = from->version; |
+ to->addr = from->addr; |
+ to->creationTime = from->creationTime; |
+ to->lastAccessTime = from->lastAccessTime; |
+ to->expirationTime = from->expirationTime; |
+ to->authAlgorithm = from->authAlgorithm; |
+ to->authKeyBits = from->authKeyBits; |
+ to->keaType = from->keaType; |
+ to->keaKeyBits = from->keaKeyBits; |
+ |
+ if (from->version < SSL_LIBRARY_VERSION_3_0) { |
+ if ((from->u.ssl2.masterKey.len > SSL_MAX_MASTER_KEY_BYTES) || |
+ (from->u.ssl2.cipherArg.len > SSL_MAX_CYPHER_ARG_BYTES)) { |
+ SSL_DBG(("%d: SSL: masterKeyLen=%d cipherArgLen=%d", |
+ myPid, from->u.ssl2.masterKey.len, |
+ from->u.ssl2.cipherArg.len)); |
+ to->valid = 0; |
+ return; |
+ } |
+ |
+ to->u.ssl2.cipherType = from->u.ssl2.cipherType; |
+ to->u.ssl2.masterKeyLen = from->u.ssl2.masterKey.len; |
+ to->u.ssl2.cipherArgLen = from->u.ssl2.cipherArg.len; |
+ to->u.ssl2.keyBits = from->u.ssl2.keyBits; |
+ to->u.ssl2.secretKeyBits = from->u.ssl2.secretKeyBits; |
+ to->sessionIDLength = SSL2_SESSIONID_BYTES; |
+ PORT_Memcpy(to->sessionID, from->u.ssl2.sessionID, SSL2_SESSIONID_BYTES); |
+ PORT_Memcpy(to->u.ssl2.masterKey, from->u.ssl2.masterKey.data, |
+ from->u.ssl2.masterKey.len); |
+ PORT_Memcpy(to->u.ssl2.cipherArg, from->u.ssl2.cipherArg.data, |
+ from->u.ssl2.cipherArg.len); |
+#ifdef DEBUG |
+ PORT_Memset(to->u.ssl2.masterKey+from->u.ssl2.masterKey.len, 0, |
+ sizeof(to->u.ssl2.masterKey) - from->u.ssl2.masterKey.len); |
+ PORT_Memset(to->u.ssl2.cipherArg+from->u.ssl2.cipherArg.len, 0, |
+ sizeof(to->u.ssl2.cipherArg) - from->u.ssl2.cipherArg.len); |
+#endif |
+ SSL_TRC(8, ("%d: SSL: ConvertSID: masterKeyLen=%d cipherArgLen=%d " |
+ "time=%d addr=0x%08x%08x%08x%08x cipherType=%d", myPid, |
+ to->u.ssl2.masterKeyLen, to->u.ssl2.cipherArgLen, |
+ to->creationTime, to->addr.pr_s6_addr32[0], |
+ to->addr.pr_s6_addr32[1], to->addr.pr_s6_addr32[2], |
+ to->addr.pr_s6_addr32[3], to->u.ssl2.cipherType)); |
+ } else { |
+ /* This is an SSL v3 session */ |
+ |
+ to->u.ssl3.cipherSuite = from->u.ssl3.cipherSuite; |
+ to->u.ssl3.compression = (uint16)from->u.ssl3.compression; |
+ to->u.ssl3.keys = from->u.ssl3.keys; |
+ to->u.ssl3.masterWrapMech = from->u.ssl3.masterWrapMech; |
+ to->u.ssl3.exchKeyType = from->u.ssl3.exchKeyType; |
+ to->sessionIDLength = from->u.ssl3.sessionIDLength; |
+ to->u.ssl3.certIndex = -1; |
+ |
+ PORT_Memcpy(to->sessionID, from->u.ssl3.sessionID, |
+ to->sessionIDLength); |
+ |
+ SSL_TRC(8, ("%d: SSL3: ConvertSID: time=%d addr=0x%08x%08x%08x%08x " |
+ "cipherSuite=%d", |
+ myPid, to->creationTime, to->addr.pr_s6_addr32[0], |
+ to->addr.pr_s6_addr32[1], to->addr.pr_s6_addr32[2], |
+ to->addr.pr_s6_addr32[3], to->u.ssl3.cipherSuite)); |
+ } |
+} |
+ |
+/* |
+** Convert shared memory cache-entry to local memory based one |
+** This is only called from ServerSessionIDLookup(). |
+** Caller must hold cache lock when calling this. |
+*/ |
+static sslSessionID * |
+ConvertToSID(sidCacheEntry *from, certCacheEntry *pcce, |
+ CERTCertDBHandle * dbHandle) |
+{ |
+ sslSessionID *to; |
+ uint16 version = from->version; |
+ |
+ to = (sslSessionID*) PORT_ZAlloc(sizeof(sslSessionID)); |
+ if (!to) { |
+ return 0; |
+ } |
+ |
+ if (version < SSL_LIBRARY_VERSION_3_0) { |
+ /* This is an SSL v2 session */ |
+ to->u.ssl2.masterKey.data = |
+ (unsigned char*) PORT_Alloc(from->u.ssl2.masterKeyLen); |
+ if (!to->u.ssl2.masterKey.data) { |
+ goto loser; |
+ } |
+ if (from->u.ssl2.cipherArgLen) { |
+ to->u.ssl2.cipherArg.data = |
+ (unsigned char*)PORT_Alloc(from->u.ssl2.cipherArgLen); |
+ if (!to->u.ssl2.cipherArg.data) { |
+ goto loser; |
+ } |
+ PORT_Memcpy(to->u.ssl2.cipherArg.data, from->u.ssl2.cipherArg, |
+ from->u.ssl2.cipherArgLen); |
+ } |
+ |
+ to->u.ssl2.cipherType = from->u.ssl2.cipherType; |
+ to->u.ssl2.masterKey.len = from->u.ssl2.masterKeyLen; |
+ to->u.ssl2.cipherArg.len = from->u.ssl2.cipherArgLen; |
+ to->u.ssl2.keyBits = from->u.ssl2.keyBits; |
+ to->u.ssl2.secretKeyBits = from->u.ssl2.secretKeyBits; |
+/* to->sessionIDLength = SSL2_SESSIONID_BYTES; */ |
+ PORT_Memcpy(to->u.ssl2.sessionID, from->sessionID, SSL2_SESSIONID_BYTES); |
+ PORT_Memcpy(to->u.ssl2.masterKey.data, from->u.ssl2.masterKey, |
+ from->u.ssl2.masterKeyLen); |
+ |
+ SSL_TRC(8, ("%d: SSL: ConvertToSID: masterKeyLen=%d cipherArgLen=%d " |
+ "time=%d addr=0x%08x%08x%08x%08x cipherType=%d", |
+ myPid, to->u.ssl2.masterKey.len, |
+ to->u.ssl2.cipherArg.len, to->creationTime, |
+ to->addr.pr_s6_addr32[0], to->addr.pr_s6_addr32[1], |
+ to->addr.pr_s6_addr32[2], to->addr.pr_s6_addr32[3], |
+ to->u.ssl2.cipherType)); |
+ } else { |
+ /* This is an SSL v3 session */ |
+ |
+ to->u.ssl3.sessionIDLength = from->sessionIDLength; |
+ to->u.ssl3.cipherSuite = from->u.ssl3.cipherSuite; |
+ to->u.ssl3.compression = (SSLCompressionMethod)from->u.ssl3.compression; |
+ to->u.ssl3.keys = from->u.ssl3.keys; |
+ to->u.ssl3.masterWrapMech = from->u.ssl3.masterWrapMech; |
+ to->u.ssl3.exchKeyType = from->u.ssl3.exchKeyType; |
+ |
+ PORT_Memcpy(to->u.ssl3.sessionID, from->sessionID, from->sessionIDLength); |
+ |
+ /* the portions of the SID that are only restored on the client |
+ * are set to invalid values on the server. |
+ */ |
+ to->u.ssl3.clientWriteKey = NULL; |
+ to->u.ssl3.serverWriteKey = NULL; |
+ |
+ to->urlSvrName = NULL; |
+ |
+ to->u.ssl3.masterModuleID = (SECMODModuleID)-1; /* invalid value */ |
+ to->u.ssl3.masterSlotID = (CK_SLOT_ID)-1; /* invalid value */ |
+ to->u.ssl3.masterWrapIndex = 0; |
+ to->u.ssl3.masterWrapSeries = 0; |
+ to->u.ssl3.masterValid = PR_FALSE; |
+ |
+ to->u.ssl3.clAuthModuleID = (SECMODModuleID)-1; /* invalid value */ |
+ to->u.ssl3.clAuthSlotID = (CK_SLOT_ID)-1; /* invalid value */ |
+ to->u.ssl3.clAuthSeries = 0; |
+ to->u.ssl3.clAuthValid = PR_FALSE; |
+ |
+ if (from->u.ssl3.certIndex != -1 && pcce) { |
+ SECItem derCert; |
+ |
+ derCert.len = pcce->certLength; |
+ derCert.data = pcce->cert; |
+ |
+ to->peerCert = CERT_NewTempCertificate(dbHandle, &derCert, NULL, |
+ PR_FALSE, PR_TRUE); |
+ if (to->peerCert == NULL) |
+ goto loser; |
+ } |
+ } |
+ |
+ to->version = from->version; |
+ to->creationTime = from->creationTime; |
+ to->lastAccessTime = from->lastAccessTime; |
+ to->expirationTime = from->expirationTime; |
+ to->cached = in_server_cache; |
+ to->addr = from->addr; |
+ to->references = 1; |
+ to->authAlgorithm = from->authAlgorithm; |
+ to->authKeyBits = from->authKeyBits; |
+ to->keaType = from->keaType; |
+ to->keaKeyBits = from->keaKeyBits; |
+ |
+ return to; |
+ |
+ loser: |
+ if (to) { |
+ if (version < SSL_LIBRARY_VERSION_3_0) { |
+ if (to->u.ssl2.masterKey.data) |
+ PORT_Free(to->u.ssl2.masterKey.data); |
+ if (to->u.ssl2.cipherArg.data) |
+ PORT_Free(to->u.ssl2.cipherArg.data); |
+ } |
+ PORT_Free(to); |
+ } |
+ return NULL; |
+} |
+ |
+ |
+ |
+/* |
+** Perform some mumbo jumbo on the ip-address and the session-id value to |
+** compute a hash value. |
+*/ |
+static PRUint32 |
+SIDindex(cacheDesc *cache, const PRIPv6Addr *addr, PRUint8 *s, unsigned nl) |
+{ |
+ PRUint32 rv; |
+ PRUint32 x[8]; |
+ |
+ memset(x, 0, sizeof x); |
+ if (nl > sizeof x) |
+ nl = sizeof x; |
+ memcpy(x, s, nl); |
+ |
+ rv = (addr->pr_s6_addr32[0] ^ addr->pr_s6_addr32[1] ^ |
+ addr->pr_s6_addr32[2] ^ addr->pr_s6_addr32[3] ^ |
+ x[0] ^ x[1] ^ x[2] ^ x[3] ^ x[4] ^ x[5] ^ x[6] ^ x[7]) |
+ % cache->numSIDCacheSets; |
+ return rv; |
+} |
+ |
+ |
+ |
+/* |
+** Look something up in the cache. This will invalidate old entries |
+** in the process. Caller has locked the cache set! |
+** Returns PR_TRUE if found a valid match. PR_FALSE otherwise. |
+*/ |
+static sidCacheEntry * |
+FindSID(cacheDesc *cache, PRUint32 setNum, PRUint32 now, |
+ const PRIPv6Addr *addr, unsigned char *sessionID, |
+ unsigned sessionIDLength) |
+{ |
+ PRUint32 ndx = cache->sidCacheSets[setNum].next; |
+ int i; |
+ |
+ sidCacheEntry * set = cache->sidCacheData + |
+ (setNum * SID_CACHE_ENTRIES_PER_SET); |
+ |
+ for (i = SID_CACHE_ENTRIES_PER_SET; i > 0; --i) { |
+ sidCacheEntry * sce; |
+ |
+ ndx = (ndx - 1) % SID_CACHE_ENTRIES_PER_SET; |
+ sce = set + ndx; |
+ |
+ if (!sce->valid) |
+ continue; |
+ |
+ if (now > sce->expirationTime) { |
+ /* SessionID has timed out. Invalidate the entry. */ |
+ SSL_TRC(7, ("%d: timed out sid entry addr=%08x%08x%08x%08x now=%x " |
+ "time+=%x", |
+ myPid, sce->addr.pr_s6_addr32[0], |
+ sce->addr.pr_s6_addr32[1], sce->addr.pr_s6_addr32[2], |
+ sce->addr.pr_s6_addr32[3], now, |
+ sce->expirationTime )); |
+ sce->valid = 0; |
+ continue; |
+ } |
+ |
+ /* |
+ ** Next, examine specific session-id/addr data to see if the cache |
+ ** entry matches our addr+session-id value |
+ */ |
+ if (sessionIDLength == sce->sessionIDLength && |
+ !memcmp(&sce->addr, addr, sizeof(PRIPv6Addr)) && |
+ !memcmp(sce->sessionID, sessionID, sessionIDLength)) { |
+ /* Found it */ |
+ return sce; |
+ } |
+ } |
+ |
+ PORT_SetError(SSL_ERROR_SESSION_NOT_FOUND); |
+ return NULL; |
+} |
+ |
+/************************************************************************/ |
+ |
+/* This is the primary function for finding entries in the server's sid cache. |
+ * Although it is static, this function is called via the global function |
+ * pointer ssl_sid_lookup. |
+ */ |
+static sslSessionID * |
+ServerSessionIDLookup(const PRIPv6Addr *addr, |
+ unsigned char *sessionID, |
+ unsigned int sessionIDLength, |
+ CERTCertDBHandle * dbHandle) |
+{ |
+ sslSessionID * sid = 0; |
+ sidCacheEntry * psce; |
+ certCacheEntry *pcce = 0; |
+ cacheDesc * cache = &globalCache; |
+ PRUint32 now; |
+ PRUint32 set; |
+ PRInt32 cndx; |
+ sidCacheEntry sce; |
+ certCacheEntry cce; |
+ |
+ set = SIDindex(cache, addr, sessionID, sessionIDLength); |
+ now = LockSet(cache, set, 0); |
+ if (!now) |
+ return NULL; |
+ |
+ psce = FindSID(cache, set, now, addr, sessionID, sessionIDLength); |
+ if (psce) { |
+ if (psce->version >= SSL_LIBRARY_VERSION_3_0 && |
+ (cndx = psce->u.ssl3.certIndex) != -1) { |
+ |
+ PRUint32 gotLock = LockSidCacheLock(cache->certCacheLock, now); |
+ if (gotLock) { |
+ pcce = &cache->certCacheData[cndx]; |
+ |
+ /* See if the cert's session ID matches the sce cache. */ |
+ if ((pcce->sessionIDLength == psce->sessionIDLength) && |
+ !PORT_Memcmp(pcce->sessionID, psce->sessionID, |
+ pcce->sessionIDLength)) { |
+ cce = *pcce; |
+ } else { |
+ /* The cert doesen't match the SID cache entry, |
+ ** so invalidate the SID cache entry. |
+ */ |
+ psce->valid = 0; |
+ psce = 0; |
+ pcce = 0; |
+ } |
+ UnlockSidCacheLock(cache->certCacheLock); |
+ } else { |
+ /* what the ??. Didn't get the cert cache lock. |
+ ** Don't invalidate the SID cache entry, but don't find it. |
+ */ |
+ PORT_Assert(!("Didn't get cert Cache Lock!")); |
+ psce = 0; |
+ pcce = 0; |
+ } |
+ } |
+ if (psce) { |
+ psce->lastAccessTime = now; |
+ sce = *psce; /* grab a copy while holding the lock */ |
+ } |
+ } |
+ UnlockSet(cache, set); |
+ if (psce) { |
+ /* sce conains a copy of the cache entry. |
+ ** Convert shared memory format to local format |
+ */ |
+ sid = ConvertToSID(&sce, pcce ? &cce : 0, dbHandle); |
+ } |
+ return sid; |
+} |
+ |
+/* |
+** Place a sid into the cache, if it isn't already there. |
+*/ |
+static void |
+ServerSessionIDCache(sslSessionID *sid) |
+{ |
+ sidCacheEntry sce; |
+ PRUint32 now = 0; |
+ uint16 version = sid->version; |
+ cacheDesc * cache = &globalCache; |
+ |
+ if ((version >= SSL_LIBRARY_VERSION_3_0) && |
+ (sid->u.ssl3.sessionIDLength == 0)) { |
+ return; |
+ } |
+ |
+ if (sid->cached == never_cached || sid->cached == invalid_cache) { |
+ PRUint32 set; |
+ |
+ PORT_Assert(sid->creationTime != 0); |
+ if (!sid->creationTime) |
+ sid->lastAccessTime = sid->creationTime = ssl_Time(); |
+ if (version < SSL_LIBRARY_VERSION_3_0) { |
+ /* override caller's expiration time, which uses client timeout |
+ * duration, not server timeout duration. |
+ */ |
+ sid->expirationTime = sid->creationTime + cache->ssl2Timeout; |
+ SSL_TRC(8, ("%d: SSL: CacheMT: cached=%d addr=0x%08x%08x%08x%08x time=%x " |
+ "cipher=%d", myPid, sid->cached, |
+ sid->addr.pr_s6_addr32[0], sid->addr.pr_s6_addr32[1], |
+ sid->addr.pr_s6_addr32[2], sid->addr.pr_s6_addr32[3], |
+ sid->creationTime, sid->u.ssl2.cipherType)); |
+ PRINT_BUF(8, (0, "sessionID:", sid->u.ssl2.sessionID, |
+ SSL2_SESSIONID_BYTES)); |
+ PRINT_BUF(8, (0, "masterKey:", sid->u.ssl2.masterKey.data, |
+ sid->u.ssl2.masterKey.len)); |
+ PRINT_BUF(8, (0, "cipherArg:", sid->u.ssl2.cipherArg.data, |
+ sid->u.ssl2.cipherArg.len)); |
+ |
+ } else { |
+ /* override caller's expiration time, which uses client timeout |
+ * duration, not server timeout duration. |
+ */ |
+ sid->expirationTime = sid->creationTime + cache->ssl3Timeout; |
+ SSL_TRC(8, ("%d: SSL: CacheMT: cached=%d addr=0x%08x%08x%08x%08x time=%x " |
+ "cipherSuite=%d", myPid, sid->cached, |
+ sid->addr.pr_s6_addr32[0], sid->addr.pr_s6_addr32[1], |
+ sid->addr.pr_s6_addr32[2], sid->addr.pr_s6_addr32[3], |
+ sid->creationTime, sid->u.ssl3.cipherSuite)); |
+ PRINT_BUF(8, (0, "sessionID:", sid->u.ssl3.sessionID, |
+ sid->u.ssl3.sessionIDLength)); |
+ } |
+ |
+ ConvertFromSID(&sce, sid); |
+ |
+ if ((version >= SSL_LIBRARY_VERSION_3_0) && |
+ (sid->peerCert != NULL)) { |
+ now = CacheCert(cache, sid->peerCert, &sce); |
+ } |
+ |
+ set = SIDindex(cache, &sce.addr, sce.sessionID, sce.sessionIDLength); |
+ now = LockSet(cache, set, now); |
+ if (now) { |
+ PRUint32 next = cache->sidCacheSets[set].next; |
+ PRUint32 ndx = set * SID_CACHE_ENTRIES_PER_SET + next; |
+ |
+ /* Write out new cache entry */ |
+ cache->sidCacheData[ndx] = sce; |
+ |
+ cache->sidCacheSets[set].next = |
+ (next + 1) % SID_CACHE_ENTRIES_PER_SET; |
+ |
+ UnlockSet(cache, set); |
+ sid->cached = in_server_cache; |
+ } |
+ } |
+} |
+ |
+/* |
+** Although this is static, it is called from ssl via global function pointer |
+** ssl_sid_uncache. This invalidates the referenced cache entry. |
+*/ |
+static void |
+ServerSessionIDUncache(sslSessionID *sid) |
+{ |
+ cacheDesc * cache = &globalCache; |
+ PRUint8 * sessionID; |
+ unsigned int sessionIDLength; |
+ PRErrorCode err; |
+ PRUint32 set; |
+ PRUint32 now; |
+ sidCacheEntry *psce; |
+ |
+ if (sid == NULL) |
+ return; |
+ |
+ /* Uncaching a SID should never change the error code. |
+ ** So save it here and restore it before exiting. |
+ */ |
+ err = PR_GetError(); |
+ |
+ if (sid->version < SSL_LIBRARY_VERSION_3_0) { |
+ sessionID = sid->u.ssl2.sessionID; |
+ sessionIDLength = SSL2_SESSIONID_BYTES; |
+ SSL_TRC(8, ("%d: SSL: UncacheMT: valid=%d addr=0x%08x%08x%08x%08x time=%x " |
+ "cipher=%d", myPid, sid->cached, |
+ sid->addr.pr_s6_addr32[0], sid->addr.pr_s6_addr32[1], |
+ sid->addr.pr_s6_addr32[2], sid->addr.pr_s6_addr32[3], |
+ sid->creationTime, sid->u.ssl2.cipherType)); |
+ PRINT_BUF(8, (0, "sessionID:", sessionID, sessionIDLength)); |
+ PRINT_BUF(8, (0, "masterKey:", sid->u.ssl2.masterKey.data, |
+ sid->u.ssl2.masterKey.len)); |
+ PRINT_BUF(8, (0, "cipherArg:", sid->u.ssl2.cipherArg.data, |
+ sid->u.ssl2.cipherArg.len)); |
+ } else { |
+ sessionID = sid->u.ssl3.sessionID; |
+ sessionIDLength = sid->u.ssl3.sessionIDLength; |
+ SSL_TRC(8, ("%d: SSL3: UncacheMT: valid=%d addr=0x%08x%08x%08x%08x time=%x " |
+ "cipherSuite=%d", myPid, sid->cached, |
+ sid->addr.pr_s6_addr32[0], sid->addr.pr_s6_addr32[1], |
+ sid->addr.pr_s6_addr32[2], sid->addr.pr_s6_addr32[3], |
+ sid->creationTime, sid->u.ssl3.cipherSuite)); |
+ PRINT_BUF(8, (0, "sessionID:", sessionID, sessionIDLength)); |
+ } |
+ set = SIDindex(cache, &sid->addr, sessionID, sessionIDLength); |
+ now = LockSet(cache, set, 0); |
+ if (now) { |
+ psce = FindSID(cache, set, now, &sid->addr, sessionID, sessionIDLength); |
+ if (psce) { |
+ psce->valid = 0; |
+ } |
+ UnlockSet(cache, set); |
+ } |
+ sid->cached = invalid_cache; |
+ PORT_SetError(err); |
+} |
+ |
+#ifdef XP_OS2 |
+ |
+#define INCL_DOSPROCESS |
+#include <os2.h> |
+ |
+long gettid(void) |
+{ |
+ PTIB ptib; |
+ PPIB ppib; |
+ DosGetInfoBlocks(&ptib, &ppib); |
+ return ((long)ptib->tib_ordinal); /* thread id */ |
+} |
+#endif |
+ |
+static void |
+CloseCache(cacheDesc *cache) |
+{ |
+ int locks_initialized = cache->numSIDCacheLocksInitialized; |
+ |
+ if (cache->cacheMem) { |
+ /* If everInherited is true, this shared cache was (and may still |
+ ** be) in use by multiple processes. We do not wish to destroy |
+ ** the mutexes while they are still in use. |
+ */ |
+ if (cache->sharedCache && |
+ PR_FALSE == cache->sharedCache->everInherited) { |
+ sidCacheLock *pLock = cache->sidCacheLocks; |
+ for (; locks_initialized > 0; --locks_initialized, ++pLock ) { |
+ sslMutex_Destroy(&pLock->mutex); |
+ } |
+ } |
+ if (cache->shared) { |
+ PR_MemUnmap(cache->cacheMem, cache->cacheMemSize); |
+ } else { |
+ PORT_Free(cache->cacheMem); |
+ } |
+ cache->cacheMem = NULL; |
+ } |
+ if (cache->cacheMemMap) { |
+ PR_CloseFileMap(cache->cacheMemMap); |
+ cache->cacheMemMap = NULL; |
+ } |
+ memset(cache, 0, sizeof *cache); |
+} |
+ |
+static SECStatus |
+InitCache(cacheDesc *cache, int maxCacheEntries, PRUint32 ssl2_timeout, |
+ PRUint32 ssl3_timeout, const char *directory, PRBool shared) |
+{ |
+ ptrdiff_t ptr; |
+ sidCacheLock *pLock; |
+ char * cacheMem; |
+ PRFileMap * cacheMemMap; |
+ char * cfn = NULL; /* cache file name */ |
+ int locks_initialized = 0; |
+ int locks_to_initialize = 0; |
+ PRUint32 init_time; |
+ |
+ if ( (!cache) || (maxCacheEntries < 0) || (!directory) ) { |
+ PORT_SetError(SEC_ERROR_INVALID_ARGS); |
+ return SECFailure; |
+ } |
+ |
+ if (cache->cacheMem) { |
+ /* Already done */ |
+ return SECSuccess; |
+ } |
+ |
+ /* make sure loser can clean up properly */ |
+ cache->shared = shared; |
+ cache->cacheMem = cacheMem = NULL; |
+ cache->cacheMemMap = cacheMemMap = NULL; |
+ cache->sharedCache = (cacheDesc *)0; |
+ |
+ cache->numSIDCacheLocksInitialized = 0; |
+ cache->nextCertCacheEntry = 0; |
+ cache->stopPolling = PR_FALSE; |
+ cache->everInherited = PR_FALSE; |
+ cache->poller = NULL; |
+ cache->mutexTimeout = 0; |
+ |
+ cache->numSIDCacheEntries = maxCacheEntries ? maxCacheEntries |
+ : DEF_SID_CACHE_ENTRIES; |
+ cache->numSIDCacheSets = |
+ SID_HOWMANY(cache->numSIDCacheEntries, SID_CACHE_ENTRIES_PER_SET); |
+ |
+ cache->numSIDCacheEntries = |
+ cache->numSIDCacheSets * SID_CACHE_ENTRIES_PER_SET; |
+ |
+ cache->numSIDCacheLocks = |
+ PR_MIN(cache->numSIDCacheSets, ssl_max_sid_cache_locks); |
+ |
+ cache->numSIDCacheSetsPerLock = |
+ SID_HOWMANY(cache->numSIDCacheSets, cache->numSIDCacheLocks); |
+ |
+ /* compute size of shared memory, and offsets of all pointers */ |
+ ptr = 0; |
+ cache->cacheMem = (char *)ptr; |
+ ptr += SID_ROUNDUP(sizeof(cacheDesc), SID_ALIGNMENT); |
+ |
+ cache->sidCacheLocks = (sidCacheLock *)ptr; |
+ cache->keyCacheLock = cache->sidCacheLocks + cache->numSIDCacheLocks; |
+ cache->certCacheLock = cache->keyCacheLock + 1; |
+ ptr = (ptrdiff_t)(cache->certCacheLock + 1); |
+ ptr = SID_ROUNDUP(ptr, SID_ALIGNMENT); |
+ |
+ cache->sidCacheSets = (sidCacheSet *)ptr; |
+ ptr = (ptrdiff_t)(cache->sidCacheSets + cache->numSIDCacheSets); |
+ ptr = SID_ROUNDUP(ptr, SID_ALIGNMENT); |
+ |
+ cache->sidCacheData = (sidCacheEntry *)ptr; |
+ ptr = (ptrdiff_t)(cache->sidCacheData + cache->numSIDCacheEntries); |
+ ptr = SID_ROUNDUP(ptr, SID_ALIGNMENT); |
+ |
+ cache->certCacheData = (certCacheEntry *)ptr; |
+ cache->sidCacheSize = |
+ (char *)cache->certCacheData - (char *)cache->sidCacheData; |
+ |
+ /* This is really a poor way to computer this! */ |
+ cache->numCertCacheEntries = cache->sidCacheSize / sizeof(certCacheEntry); |
+ if (cache->numCertCacheEntries < MIN_CERT_CACHE_ENTRIES) |
+ cache->numCertCacheEntries = MIN_CERT_CACHE_ENTRIES; |
+ ptr = (ptrdiff_t)(cache->certCacheData + cache->numCertCacheEntries); |
+ ptr = SID_ROUNDUP(ptr, SID_ALIGNMENT); |
+ |
+ cache->keyCacheData = (SSLWrappedSymWrappingKey *)ptr; |
+ cache->certCacheSize = |
+ (char *)cache->keyCacheData - (char *)cache->certCacheData; |
+ |
+ cache->numKeyCacheEntries = kt_kea_size * SSL_NUM_WRAP_MECHS; |
+ ptr = (ptrdiff_t)(cache->keyCacheData + cache->numKeyCacheEntries); |
+ ptr = SID_ROUNDUP(ptr, SID_ALIGNMENT); |
+ |
+ cache->keyCacheSize = (char *)ptr - (char *)cache->keyCacheData; |
+ |
+ cache->ticketKeyNameSuffix = (uint8 *)ptr; |
+ ptr = (ptrdiff_t)(cache->ticketKeyNameSuffix + |
+ SESS_TICKET_KEY_VAR_NAME_LEN); |
+ ptr = SID_ROUNDUP(ptr, SID_ALIGNMENT); |
+ |
+ cache->ticketEncKey = (encKeyCacheEntry *)ptr; |
+ ptr = (ptrdiff_t)(cache->ticketEncKey + 1); |
+ ptr = SID_ROUNDUP(ptr, SID_ALIGNMENT); |
+ |
+ cache->ticketMacKey = (encKeyCacheEntry *)ptr; |
+ ptr = (ptrdiff_t)(cache->ticketMacKey + 1); |
+ ptr = SID_ROUNDUP(ptr, SID_ALIGNMENT); |
+ |
+ cache->ticketKeysValid = (PRUint32 *)ptr; |
+ ptr = (ptrdiff_t)(cache->ticketKeysValid + 1); |
+ ptr = SID_ROUNDUP(ptr, SID_ALIGNMENT); |
+ |
+ cache->cacheMemSize = ptr; |
+ |
+ if (ssl2_timeout) { |
+ if (ssl2_timeout > MAX_SSL2_TIMEOUT) { |
+ ssl2_timeout = MAX_SSL2_TIMEOUT; |
+ } |
+ if (ssl2_timeout < MIN_SSL2_TIMEOUT) { |
+ ssl2_timeout = MIN_SSL2_TIMEOUT; |
+ } |
+ cache->ssl2Timeout = ssl2_timeout; |
+ } else { |
+ cache->ssl2Timeout = DEF_SSL2_TIMEOUT; |
+ } |
+ |
+ if (ssl3_timeout) { |
+ if (ssl3_timeout > MAX_SSL3_TIMEOUT) { |
+ ssl3_timeout = MAX_SSL3_TIMEOUT; |
+ } |
+ if (ssl3_timeout < MIN_SSL3_TIMEOUT) { |
+ ssl3_timeout = MIN_SSL3_TIMEOUT; |
+ } |
+ cache->ssl3Timeout = ssl3_timeout; |
+ } else { |
+ cache->ssl3Timeout = DEF_SSL3_TIMEOUT; |
+ } |
+ |
+ if (shared) { |
+ /* Create file names */ |
+#if defined(XP_UNIX) || defined(XP_BEOS) |
+ /* there's some confusion here about whether PR_OpenAnonFileMap wants |
+ ** a directory name or a file name for its first argument. |
+ cfn = PR_smprintf("%s/.sslsvrcache.%d", directory, myPid); |
+ */ |
+ cfn = PR_smprintf("%s", directory); |
+#elif defined(XP_WIN32) |
+ cfn = PR_smprintf("%s/svrcache_%d_%x.ssl", directory, myPid, |
+ GetCurrentThreadId()); |
+#elif defined(XP_OS2) |
+ cfn = PR_smprintf("%s/svrcache_%d_%x.ssl", directory, myPid, |
+ gettid()); |
+#else |
+#error "Don't know how to create file name for this platform!" |
+#endif |
+ if (!cfn) { |
+ goto loser; |
+ } |
+ |
+ /* Create cache */ |
+ cacheMemMap = PR_OpenAnonFileMap(cfn, cache->cacheMemSize, |
+ PR_PROT_READWRITE); |
+ |
+ PR_smprintf_free(cfn); |
+ if(!cacheMemMap) { |
+ goto loser; |
+ } |
+ |
+ cacheMem = PR_MemMap(cacheMemMap, 0, cache->cacheMemSize); |
+ } else { |
+ cacheMem = PORT_Alloc(cache->cacheMemSize); |
+ } |
+ |
+ if (! cacheMem) { |
+ goto loser; |
+ } |
+ |
+ /* Initialize shared memory. This may not be necessary on all platforms */ |
+ memset(cacheMem, 0, cache->cacheMemSize); |
+ |
+ /* Copy cache descriptor header into shared memory */ |
+ memcpy(cacheMem, cache, sizeof *cache); |
+ |
+ /* save private copies of these values */ |
+ cache->cacheMemMap = cacheMemMap; |
+ cache->cacheMem = cacheMem; |
+ cache->sharedCache = (cacheDesc *)cacheMem; |
+ |
+ /* Fix pointers in our private copy of cache descriptor to point to |
+ ** spaces in shared memory |
+ */ |
+ ptr = (ptrdiff_t)cache->cacheMem; |
+ *(ptrdiff_t *)(&cache->sidCacheLocks) += ptr; |
+ *(ptrdiff_t *)(&cache->keyCacheLock ) += ptr; |
+ *(ptrdiff_t *)(&cache->certCacheLock) += ptr; |
+ *(ptrdiff_t *)(&cache->sidCacheSets ) += ptr; |
+ *(ptrdiff_t *)(&cache->sidCacheData ) += ptr; |
+ *(ptrdiff_t *)(&cache->certCacheData) += ptr; |
+ *(ptrdiff_t *)(&cache->keyCacheData ) += ptr; |
+ *(ptrdiff_t *)(&cache->ticketKeyNameSuffix) += ptr; |
+ *(ptrdiff_t *)(&cache->ticketEncKey ) += ptr; |
+ *(ptrdiff_t *)(&cache->ticketMacKey ) += ptr; |
+ *(ptrdiff_t *)(&cache->ticketKeysValid) += ptr; |
+ |
+ /* initialize the locks */ |
+ init_time = ssl_Time(); |
+ pLock = cache->sidCacheLocks; |
+ for (locks_to_initialize = cache->numSIDCacheLocks + 2; |
+ locks_initialized < locks_to_initialize; |
+ ++locks_initialized, ++pLock ) { |
+ |
+ SECStatus err = sslMutex_Init(&pLock->mutex, shared); |
+ if (err) { |
+ cache->numSIDCacheLocksInitialized = locks_initialized; |
+ goto loser; |
+ } |
+ pLock->timeStamp = init_time; |
+ pLock->pid = 0; |
+ } |
+ cache->numSIDCacheLocksInitialized = locks_initialized; |
+ |
+ return SECSuccess; |
+ |
+loser: |
+ CloseCache(cache); |
+ return SECFailure; |
+} |
+ |
+PRUint32 |
+SSL_GetMaxServerCacheLocks(void) |
+{ |
+ return ssl_max_sid_cache_locks + 2; |
+ /* The extra two are the cert cache lock and the key cache lock. */ |
+} |
+ |
+SECStatus |
+SSL_SetMaxServerCacheLocks(PRUint32 maxLocks) |
+{ |
+ /* Minimum is 1 sid cache lock, 1 cert cache lock and 1 key cache lock. |
+ ** We'd like to test for a maximum value, but not all platforms' header |
+ ** files provide a symbol or function or other means of determining |
+ ** the maximum, other than trial and error. |
+ */ |
+ if (maxLocks < 3) { |
+ PORT_SetError(SEC_ERROR_INVALID_ARGS); |
+ return SECFailure; |
+ } |
+ ssl_max_sid_cache_locks = maxLocks - 2; |
+ /* The extra two are the cert cache lock and the key cache lock. */ |
+ return SECSuccess; |
+} |
+ |
+SECStatus |
+SSL_ConfigServerSessionIDCacheInstance( cacheDesc *cache, |
+ int maxCacheEntries, |
+ PRUint32 ssl2_timeout, |
+ PRUint32 ssl3_timeout, |
+ const char * directory, PRBool shared) |
+{ |
+ SECStatus rv; |
+ |
+ PORT_Assert(sizeof(sidCacheEntry) == 192); |
+ PORT_Assert(sizeof(certCacheEntry) == 4096); |
+ |
+ myPid = SSL_GETPID(); |
+ if (!directory) { |
+ directory = DEFAULT_CACHE_DIRECTORY; |
+ } |
+ rv = InitCache(cache, maxCacheEntries, ssl2_timeout, ssl3_timeout, |
+ directory, shared); |
+ if (rv) { |
+ SET_ERROR_CODE |
+ return SECFailure; |
+ } |
+ |
+ ssl_sid_lookup = ServerSessionIDLookup; |
+ ssl_sid_cache = ServerSessionIDCache; |
+ ssl_sid_uncache = ServerSessionIDUncache; |
+ return SECSuccess; |
+} |
+ |
+SECStatus |
+SSL_ConfigServerSessionIDCache( int maxCacheEntries, |
+ PRUint32 ssl2_timeout, |
+ PRUint32 ssl3_timeout, |
+ const char * directory) |
+{ |
+ ssl_InitSessionCacheLocks(PR_FALSE); |
+ return SSL_ConfigServerSessionIDCacheInstance(&globalCache, |
+ maxCacheEntries, ssl2_timeout, ssl3_timeout, directory, PR_FALSE); |
+} |
+ |
+SECStatus |
+SSL_ShutdownServerSessionIDCacheInstance(cacheDesc *cache) |
+{ |
+ CloseCache(cache); |
+ return SECSuccess; |
+} |
+ |
+SECStatus |
+SSL_ShutdownServerSessionIDCache(void) |
+{ |
+#if defined(XP_UNIX) || defined(XP_BEOS) |
+ /* Stop the thread that polls cache for expired locks on Unix */ |
+ StopLockPoller(&globalCache); |
+#endif |
+ SSL3_ShutdownServerCache(); |
+ return SSL_ShutdownServerSessionIDCacheInstance(&globalCache); |
+} |
+ |
+/* Use this function, instead of SSL_ConfigServerSessionIDCache, |
+ * if the cache will be shared by multiple processes. |
+ */ |
+SECStatus |
+SSL_ConfigMPServerSIDCache( int maxCacheEntries, |
+ PRUint32 ssl2_timeout, |
+ PRUint32 ssl3_timeout, |
+ const char * directory) |
+{ |
+ char * envValue; |
+ char * inhValue; |
+ cacheDesc * cache = &globalCache; |
+ PRUint32 fmStrLen; |
+ SECStatus result; |
+ PRStatus prStatus; |
+ SECStatus putEnvFailed; |
+ inheritance inherit; |
+ char fmString[PR_FILEMAP_STRING_BUFSIZE]; |
+ |
+ isMultiProcess = PR_TRUE; |
+ result = SSL_ConfigServerSessionIDCacheInstance(cache, maxCacheEntries, |
+ ssl2_timeout, ssl3_timeout, directory, PR_TRUE); |
+ if (result != SECSuccess) |
+ return result; |
+ |
+ prStatus = PR_ExportFileMapAsString(cache->cacheMemMap, |
+ sizeof fmString, fmString); |
+ if ((prStatus != PR_SUCCESS) || !(fmStrLen = strlen(fmString))) { |
+ SET_ERROR_CODE |
+ return SECFailure; |
+ } |
+ |
+ inherit.cacheMemSize = cache->cacheMemSize; |
+ inherit.fmStrLen = fmStrLen; |
+ |
+ inhValue = BTOA_DataToAscii((unsigned char *)&inherit, sizeof inherit); |
+ if (!inhValue || !strlen(inhValue)) { |
+ SET_ERROR_CODE |
+ return SECFailure; |
+ } |
+ envValue = PR_smprintf("%s,%s", inhValue, fmString); |
+ if (!envValue || !strlen(envValue)) { |
+ SET_ERROR_CODE |
+ return SECFailure; |
+ } |
+ PORT_Free(inhValue); |
+ |
+ putEnvFailed = (SECStatus)NSS_PutEnv(envVarName, envValue); |
+ PR_smprintf_free(envValue); |
+ if (putEnvFailed) { |
+ SET_ERROR_CODE |
+ result = SECFailure; |
+ } |
+ |
+#if defined(XP_UNIX) || defined(XP_BEOS) |
+ /* Launch thread to poll cache for expired locks on Unix */ |
+ LaunchLockPoller(cache); |
+#endif |
+ return result; |
+} |
+ |
+SECStatus |
+SSL_InheritMPServerSIDCacheInstance(cacheDesc *cache, const char * envString) |
+{ |
+ unsigned char * decoString = NULL; |
+ char * fmString = NULL; |
+ char * myEnvString = NULL; |
+ unsigned int decoLen; |
+ ptrdiff_t ptr; |
+ inheritance inherit; |
+ cacheDesc my; |
+#ifdef WINNT |
+ sidCacheLock* newLocks; |
+ int locks_initialized = 0; |
+ int locks_to_initialize = 0; |
+#endif |
+ |
+ myPid = SSL_GETPID(); |
+ |
+ /* If this child was created by fork(), and not by exec() on unix, |
+ ** then isMultiProcess will already be set. |
+ ** If not, we'll set it below. |
+ */ |
+ if (isMultiProcess) { |
+ if (cache && cache->sharedCache) { |
+ cache->sharedCache->everInherited = PR_TRUE; |
+ } |
+ return SECSuccess; /* already done. */ |
+ } |
+ |
+ ssl_InitSessionCacheLocks(PR_FALSE); |
+ |
+ ssl_sid_lookup = ServerSessionIDLookup; |
+ ssl_sid_cache = ServerSessionIDCache; |
+ ssl_sid_uncache = ServerSessionIDUncache; |
+ |
+ if (!envString) { |
+ envString = getenv(envVarName); |
+ if (!envString) { |
+ SET_ERROR_CODE |
+ return SECFailure; |
+ } |
+ } |
+ myEnvString = PORT_Strdup(envString); |
+ if (!myEnvString) |
+ return SECFailure; |
+ fmString = strchr(myEnvString, ','); |
+ if (!fmString) |
+ goto loser; |
+ *fmString++ = 0; |
+ |
+ decoString = ATOB_AsciiToData(myEnvString, &decoLen); |
+ if (!decoString) { |
+ SET_ERROR_CODE |
+ goto loser; |
+ } |
+ if (decoLen != sizeof inherit) { |
+ SET_ERROR_CODE |
+ goto loser; |
+ } |
+ |
+ PORT_Memcpy(&inherit, decoString, sizeof inherit); |
+ |
+ if (strlen(fmString) != inherit.fmStrLen ) { |
+ goto loser; |
+ } |
+ |
+ memset(cache, 0, sizeof *cache); |
+ cache->cacheMemSize = inherit.cacheMemSize; |
+ |
+ /* Create cache */ |
+ cache->cacheMemMap = PR_ImportFileMapFromString(fmString); |
+ if(! cache->cacheMemMap) { |
+ goto loser; |
+ } |
+ cache->cacheMem = PR_MemMap(cache->cacheMemMap, 0, cache->cacheMemSize); |
+ if (! cache->cacheMem) { |
+ goto loser; |
+ } |
+ cache->sharedCache = (cacheDesc *)cache->cacheMem; |
+ |
+ if (cache->sharedCache->cacheMemSize != cache->cacheMemSize) { |
+ SET_ERROR_CODE |
+ goto loser; |
+ } |
+ |
+ /* We're now going to overwrite the local cache instance with the |
+ ** shared copy of the cache struct, then update several values in |
+ ** the local cache using the values for cache->cacheMemMap and |
+ ** cache->cacheMem computed just above. So, we copy cache into |
+ ** the automatic variable "my", to preserve the variables while |
+ ** cache is overwritten. |
+ */ |
+ my = *cache; /* save values computed above. */ |
+ memcpy(cache, cache->sharedCache, sizeof *cache); /* overwrite */ |
+ |
+ /* Fix pointers in our private copy of cache descriptor to point to |
+ ** spaces in shared memory, whose address is now in "my". |
+ */ |
+ ptr = (ptrdiff_t)my.cacheMem; |
+ *(ptrdiff_t *)(&cache->sidCacheLocks) += ptr; |
+ *(ptrdiff_t *)(&cache->keyCacheLock ) += ptr; |
+ *(ptrdiff_t *)(&cache->certCacheLock) += ptr; |
+ *(ptrdiff_t *)(&cache->sidCacheSets ) += ptr; |
+ *(ptrdiff_t *)(&cache->sidCacheData ) += ptr; |
+ *(ptrdiff_t *)(&cache->certCacheData) += ptr; |
+ *(ptrdiff_t *)(&cache->keyCacheData ) += ptr; |
+ *(ptrdiff_t *)(&cache->ticketKeyNameSuffix) += ptr; |
+ *(ptrdiff_t *)(&cache->ticketEncKey ) += ptr; |
+ *(ptrdiff_t *)(&cache->ticketMacKey ) += ptr; |
+ *(ptrdiff_t *)(&cache->ticketKeysValid) += ptr; |
+ |
+ cache->cacheMemMap = my.cacheMemMap; |
+ cache->cacheMem = my.cacheMem; |
+ cache->sharedCache = (cacheDesc *)cache->cacheMem; |
+ |
+#ifdef WINNT |
+ /* On Windows NT we need to "fix" the sidCacheLocks here to support fibers |
+ ** When NT fibers are used in a multi-process server, a second level of |
+ ** locking is needed to prevent a deadlock, in case a fiber acquires the |
+ ** cross-process mutex, yields, and another fiber is later scheduled on |
+ ** the same native thread and tries to acquire the cross-process mutex. |
+ ** We do this by using a PRLock in the sslMutex. However, it is stored in |
+ ** shared memory as part of sidCacheLocks, and we don't want to overwrite |
+ ** the PRLock of the parent process. So we need to make new, private |
+ ** copies of sidCacheLocks before modifying the sslMutex with our own |
+ ** PRLock |
+ */ |
+ |
+ /* note from jpierre : this should be free'd in child processes when |
+ ** a function is added to delete the SSL session cache in the future. |
+ */ |
+ locks_to_initialize = cache->numSIDCacheLocks + 2; |
+ newLocks = PORT_NewArray(sidCacheLock, locks_to_initialize); |
+ if (!newLocks) |
+ goto loser; |
+ /* copy the old locks */ |
+ memcpy(newLocks, cache->sidCacheLocks, |
+ locks_to_initialize * sizeof(sidCacheLock)); |
+ cache->sidCacheLocks = newLocks; |
+ /* fix the locks */ |
+ for (; locks_initialized < locks_to_initialize; ++locks_initialized) { |
+ /* now, make a local PRLock in this sslMutex for this child process */ |
+ SECStatus err; |
+ err = sslMutex_2LevelInit(&newLocks[locks_initialized].mutex); |
+ if (err != SECSuccess) { |
+ cache->numSIDCacheLocksInitialized = locks_initialized; |
+ goto loser; |
+ } |
+ } |
+ cache->numSIDCacheLocksInitialized = locks_initialized; |
+ |
+ /* also fix the key and cert cache which use the last 2 lock entries */ |
+ cache->keyCacheLock = cache->sidCacheLocks + cache->numSIDCacheLocks; |
+ cache->certCacheLock = cache->keyCacheLock + 1; |
+#endif |
+ |
+ PORT_Free(myEnvString); |
+ PORT_Free(decoString); |
+ |
+ /* mark that we have inherited this. */ |
+ cache->sharedCache->everInherited = PR_TRUE; |
+ isMultiProcess = PR_TRUE; |
+ |
+ return SECSuccess; |
+ |
+loser: |
+ PORT_Free(myEnvString); |
+ if (decoString) |
+ PORT_Free(decoString); |
+ CloseCache(cache); |
+ return SECFailure; |
+} |
+ |
+SECStatus |
+SSL_InheritMPServerSIDCache(const char * envString) |
+{ |
+ return SSL_InheritMPServerSIDCacheInstance(&globalCache, envString); |
+} |
+ |
+#if defined(XP_UNIX) || defined(XP_BEOS) |
+ |
+#define SID_LOCK_EXPIRATION_TIMEOUT 30 /* seconds */ |
+ |
+static void |
+LockPoller(void * arg) |
+{ |
+ cacheDesc * cache = (cacheDesc *)arg; |
+ cacheDesc * sharedCache = cache->sharedCache; |
+ sidCacheLock * pLock; |
+ PRIntervalTime timeout; |
+ PRUint32 now; |
+ PRUint32 then; |
+ int locks_polled = 0; |
+ int locks_to_poll = cache->numSIDCacheLocks + 2; |
+ PRUint32 expiration = cache->mutexTimeout; |
+ |
+ timeout = PR_SecondsToInterval(expiration); |
+ while(!sharedCache->stopPolling) { |
+ PR_Sleep(timeout); |
+ if (sharedCache->stopPolling) |
+ break; |
+ |
+ now = ssl_Time(); |
+ then = now - expiration; |
+ for (pLock = cache->sidCacheLocks, locks_polled = 0; |
+ locks_to_poll > locks_polled && !sharedCache->stopPolling; |
+ ++locks_polled, ++pLock ) { |
+ pid_t pid; |
+ |
+ if (pLock->timeStamp < then && |
+ pLock->timeStamp != 0 && |
+ (pid = pLock->pid) != 0) { |
+ |
+ /* maybe we should try the lock? */ |
+ int result = kill(pid, 0); |
+ if (result < 0 && errno == ESRCH) { |
+ SECStatus rv; |
+ /* No process exists by that pid any more. |
+ ** Treat this mutex as abandoned. |
+ */ |
+ pLock->timeStamp = now; |
+ pLock->pid = 0; |
+ rv = sslMutex_Unlock(&pLock->mutex); |
+ if (rv != SECSuccess) { |
+ /* Now what? */ |
+ } |
+ } |
+ } |
+ } /* end of loop over locks */ |
+ } /* end of entire polling loop */ |
+} |
+ |
+/* Launch thread to poll cache for expired locks */ |
+static SECStatus |
+LaunchLockPoller(cacheDesc *cache) |
+{ |
+ const char * timeoutString; |
+ PRThread * pollerThread; |
+ |
+ cache->mutexTimeout = SID_LOCK_EXPIRATION_TIMEOUT; |
+ timeoutString = getenv("NSS_SSL_SERVER_CACHE_MUTEX_TIMEOUT"); |
+ if (timeoutString) { |
+ long newTime = strtol(timeoutString, 0, 0); |
+ if (newTime == 0) |
+ return SECSuccess; /* application doesn't want poller thread */ |
+ if (newTime > 0) |
+ cache->mutexTimeout = (PRUint32)newTime; |
+ /* if error (newTime < 0) ignore it and use default */ |
+ } |
+ |
+ pollerThread = |
+ PR_CreateThread(PR_USER_THREAD, LockPoller, cache, PR_PRIORITY_NORMAL, |
+ PR_GLOBAL_THREAD, PR_JOINABLE_THREAD, 0); |
+ if (!pollerThread) { |
+ return SECFailure; |
+ } |
+ cache->poller = pollerThread; |
+ return SECSuccess; |
+} |
+ |
+/* Stop the thread that polls cache for expired locks */ |
+static SECStatus |
+StopLockPoller(cacheDesc *cache) |
+{ |
+ if (!cache->poller) { |
+ return SECSuccess; |
+ } |
+ cache->sharedCache->stopPolling = PR_TRUE; |
+ if (PR_Interrupt(cache->poller) != PR_SUCCESS) { |
+ return SECFailure; |
+ } |
+ if (PR_JoinThread(cache->poller) != PR_SUCCESS) { |
+ return SECFailure; |
+ } |
+ cache->poller = NULL; |
+ return SECSuccess; |
+} |
+#endif |
+ |
+/************************************************************************ |
+ * Code dealing with shared wrapped symmetric wrapping keys below * |
+ ************************************************************************/ |
+ |
+/* If now is zero, it implies that the lock is not held, and must be |
+** aquired here. |
+*/ |
+static PRBool |
+getSvrWrappingKey(PRInt32 symWrapMechIndex, |
+ SSL3KEAType exchKeyType, |
+ SSLWrappedSymWrappingKey *wswk, |
+ cacheDesc * cache, |
+ PRUint32 lockTime) |
+{ |
+ PRUint32 ndx = (exchKeyType * SSL_NUM_WRAP_MECHS) + symWrapMechIndex; |
+ SSLWrappedSymWrappingKey * pwswk = cache->keyCacheData + ndx; |
+ PRUint32 now = 0; |
+ PRBool rv = PR_FALSE; |
+ |
+ if (!cache->cacheMem) { /* cache is uninitialized */ |
+ PORT_SetError(SSL_ERROR_SERVER_CACHE_NOT_CONFIGURED); |
+ return rv; |
+ } |
+ if (!lockTime) { |
+ lockTime = now = LockSidCacheLock(cache->keyCacheLock, now); |
+ if (!lockTime) { |
+ return rv; |
+ } |
+ } |
+ if (pwswk->exchKeyType == exchKeyType && |
+ pwswk->symWrapMechIndex == symWrapMechIndex && |
+ pwswk->wrappedSymKeyLen != 0) { |
+ *wswk = *pwswk; |
+ rv = PR_TRUE; |
+ } |
+ if (now) { |
+ UnlockSidCacheLock(cache->keyCacheLock); |
+ } |
+ return rv; |
+} |
+ |
+PRBool |
+ssl_GetWrappingKey( PRInt32 symWrapMechIndex, |
+ SSL3KEAType exchKeyType, |
+ SSLWrappedSymWrappingKey *wswk) |
+{ |
+ PRBool rv; |
+ |
+ PORT_Assert( (unsigned)exchKeyType < kt_kea_size); |
+ PORT_Assert( (unsigned)symWrapMechIndex < SSL_NUM_WRAP_MECHS); |
+ if ((unsigned)exchKeyType < kt_kea_size && |
+ (unsigned)symWrapMechIndex < SSL_NUM_WRAP_MECHS) { |
+ rv = getSvrWrappingKey(symWrapMechIndex, exchKeyType, wswk, |
+ &globalCache, 0); |
+ } else { |
+ rv = PR_FALSE; |
+ } |
+ |
+ return rv; |
+} |
+ |
+/* Wrap and cache a session ticket key. */ |
+static PRBool |
+WrapTicketKey(SECKEYPublicKey *svrPubKey, PK11SymKey *symKey, |
+ const char *keyName, encKeyCacheEntry* cacheEntry) |
+{ |
+ SECItem wrappedKey = {siBuffer, NULL, 0}; |
+ |
+ wrappedKey.len = SECKEY_PublicKeyStrength(svrPubKey); |
+ PORT_Assert(wrappedKey.len <= sizeof(cacheEntry->bytes)); |
+ if (wrappedKey.len > sizeof(cacheEntry->bytes)) |
+ return PR_FALSE; |
+ wrappedKey.data = cacheEntry->bytes; |
+ |
+ if (PK11_PubWrapSymKey(CKM_RSA_PKCS, svrPubKey, symKey, &wrappedKey) |
+ != SECSuccess) { |
+ SSL_DBG(("%d: SSL[%s]: Unable to wrap session ticket %s.", |
+ SSL_GETPID(), "unknown", keyName)); |
+ return PR_FALSE; |
+ } |
+ cacheEntry->length = wrappedKey.len; |
+ return PR_TRUE; |
+} |
+ |
+static PRBool |
+GenerateAndWrapTicketKeys(SECKEYPublicKey *svrPubKey, void *pwArg, |
+ unsigned char *keyName, PK11SymKey **aesKey, |
+ PK11SymKey **macKey) |
+{ |
+ PK11SlotInfo *slot; |
+ CK_MECHANISM_TYPE mechanismArray[2]; |
+ PK11SymKey *aesKeyTmp = NULL; |
+ PK11SymKey *macKeyTmp = NULL; |
+ cacheDesc *cache = &globalCache; |
+ |
+ if (PK11_GenerateRandom(cache->ticketKeyNameSuffix, |
+ SESS_TICKET_KEY_VAR_NAME_LEN) != SECSuccess) { |
+ SSL_DBG(("%d: SSL[%s]: Unable to generate random key name bytes.", |
+ SSL_GETPID(), "unknown")); |
+ goto loser; |
+ } |
+ |
+ mechanismArray[0] = CKM_AES_CBC; |
+ mechanismArray[1] = CKM_SHA256_HMAC; |
+ |
+ slot = PK11_GetBestSlotMultiple(mechanismArray, 2, pwArg); |
+ if (slot) { |
+ aesKeyTmp = PK11_KeyGen(slot, mechanismArray[0], NULL, 32, pwArg); |
+ macKeyTmp = PK11_KeyGen(slot, mechanismArray[1], NULL, SHA256_LENGTH, |
+ pwArg); |
+ PK11_FreeSlot(slot); |
+ } |
+ |
+ if (aesKeyTmp == NULL || macKeyTmp == NULL) { |
+ SSL_DBG(("%d: SSL[%s]: Unable to generate session ticket keys.", |
+ SSL_GETPID(), "unknown")); |
+ goto loser; |
+ } |
+ |
+ /* Export the keys to the shared cache in wrapped form. */ |
+ if (!WrapTicketKey(svrPubKey, aesKeyTmp, "enc key", cache->ticketEncKey)) |
+ goto loser; |
+ if (!WrapTicketKey(svrPubKey, macKeyTmp, "mac key", cache->ticketMacKey)) |
+ goto loser; |
+ |
+ PORT_Memcpy(keyName, cache->ticketKeyNameSuffix, |
+ SESS_TICKET_KEY_VAR_NAME_LEN); |
+ *aesKey = aesKeyTmp; |
+ *macKey = macKeyTmp; |
+ return PR_TRUE; |
+ |
+loser: |
+ if (aesKeyTmp) |
+ PK11_FreeSymKey(aesKeyTmp); |
+ if (macKeyTmp) |
+ PK11_FreeSymKey(macKeyTmp); |
+ return PR_FALSE; |
+} |
+ |
+static PRBool |
+UnwrapCachedTicketKeys(SECKEYPrivateKey *svrPrivKey, unsigned char *keyName, |
+ PK11SymKey **aesKey, PK11SymKey **macKey) |
+{ |
+ SECItem wrappedKey = {siBuffer, NULL, 0}; |
+ PK11SymKey *aesKeyTmp = NULL; |
+ PK11SymKey *macKeyTmp = NULL; |
+ cacheDesc *cache = &globalCache; |
+ |
+ wrappedKey.data = cache->ticketEncKey->bytes; |
+ wrappedKey.len = cache->ticketEncKey->length; |
+ PORT_Assert(wrappedKey.len <= sizeof(cache->ticketEncKey->bytes)); |
+ aesKeyTmp = PK11_PubUnwrapSymKey(svrPrivKey, &wrappedKey, |
+ CKM_AES_CBC, CKA_DECRYPT, 0); |
+ |
+ wrappedKey.data = cache->ticketMacKey->bytes; |
+ wrappedKey.len = cache->ticketMacKey->length; |
+ PORT_Assert(wrappedKey.len <= sizeof(cache->ticketMacKey->bytes)); |
+ macKeyTmp = PK11_PubUnwrapSymKey(svrPrivKey, &wrappedKey, |
+ CKM_SHA256_HMAC, CKA_SIGN, 0); |
+ |
+ if (aesKeyTmp == NULL || macKeyTmp == NULL) { |
+ SSL_DBG(("%d: SSL[%s]: Unable to unwrap session ticket keys.", |
+ SSL_GETPID(), "unknown")); |
+ goto loser; |
+ } |
+ SSL_DBG(("%d: SSL[%s]: Successfully unwrapped session ticket keys.", |
+ SSL_GETPID(), "unknown")); |
+ |
+ PORT_Memcpy(keyName, cache->ticketKeyNameSuffix, |
+ SESS_TICKET_KEY_VAR_NAME_LEN); |
+ *aesKey = aesKeyTmp; |
+ *macKey = macKeyTmp; |
+ return PR_TRUE; |
+ |
+loser: |
+ if (aesKeyTmp) |
+ PK11_FreeSymKey(aesKeyTmp); |
+ if (macKeyTmp) |
+ PK11_FreeSymKey(macKeyTmp); |
+ return PR_FALSE; |
+} |
+ |
+PRBool |
+ssl_GetSessionTicketKeysPKCS11(SECKEYPrivateKey *svrPrivKey, |
+ SECKEYPublicKey *svrPubKey, void *pwArg, |
+ unsigned char *keyName, PK11SymKey **aesKey, |
+ PK11SymKey **macKey) |
+{ |
+ PRUint32 now = 0; |
+ PRBool rv = PR_FALSE; |
+ PRBool keysGenerated = PR_FALSE; |
+ cacheDesc *cache = &globalCache; |
+ |
+ now = LockSidCacheLock(cache->keyCacheLock, now); |
+ if (!now) |
+ return rv; |
+ |
+ if (!*(cache->ticketKeysValid)) { |
+ /* Keys do not exist, create them. */ |
+ if (!GenerateAndWrapTicketKeys(svrPubKey, pwArg, keyName, |
+ aesKey, macKey)) |
+ goto loser; |
+ keysGenerated = PR_TRUE; |
+ *(cache->ticketKeysValid) = 1; |
+ } |
+ |
+ rv = PR_TRUE; |
+ |
+ loser: |
+ UnlockSidCacheLock(cache->keyCacheLock); |
+ if (rv && !keysGenerated) |
+ rv = UnwrapCachedTicketKeys(svrPrivKey, keyName, aesKey, macKey); |
+ return rv; |
+} |
+ |
+PRBool |
+ssl_GetSessionTicketKeys(unsigned char *keyName, unsigned char *encKey, |
+ unsigned char *macKey) |
+{ |
+ PRBool rv = PR_FALSE; |
+ PRUint32 now = 0; |
+ cacheDesc *cache = &globalCache; |
+ |
+ /* Grab lock. */ |
+ now = LockSidCacheLock(cache->keyCacheLock, now); |
+ if (!now) |
+ return rv; |
+ |
+ if (!*(cache->ticketKeysValid)) { |
+ if (PK11_GenerateRandom(cache->ticketKeyNameSuffix, |
+ SESS_TICKET_KEY_VAR_NAME_LEN) != SECSuccess) |
+ goto loser; |
+ if (PK11_GenerateRandom(cache->ticketEncKey->bytes, 32) != SECSuccess) |
+ goto loser; |
+ if (PK11_GenerateRandom(cache->ticketMacKey->bytes, |
+ SHA256_LENGTH) != SECSuccess) |
+ goto loser; |
+ *(cache->ticketKeysValid) = 1; |
+ } |
+ |
+ rv = PR_TRUE; |
+ |
+ loser: |
+ UnlockSidCacheLock(cache->keyCacheLock); |
+ if (rv) { |
+ PORT_Memcpy(keyName, cache->ticketKeyNameSuffix, |
+ SESS_TICKET_KEY_VAR_NAME_LEN); |
+ PORT_Memcpy(encKey, cache->ticketEncKey->bytes, 32); |
+ PORT_Memcpy(macKey, cache->ticketMacKey->bytes, SHA256_LENGTH); |
+ } |
+ return rv; |
+} |
+ |
+/* The caller passes in the new value it wants |
+ * to set. This code tests the wrapped sym key entry in the shared memory. |
+ * If it is uninitialized, this function writes the caller's value into |
+ * the disk entry, and returns false. |
+ * Otherwise, it overwrites the caller's wswk with the value obtained from |
+ * the disk, and returns PR_TRUE. |
+ * This is all done while holding the locks/mutexes necessary to make |
+ * the operation atomic. |
+ */ |
+PRBool |
+ssl_SetWrappingKey(SSLWrappedSymWrappingKey *wswk) |
+{ |
+ cacheDesc * cache = &globalCache; |
+ PRBool rv = PR_FALSE; |
+ SSL3KEAType exchKeyType = wswk->exchKeyType; |
+ /* type of keys used to wrap SymWrapKey*/ |
+ PRInt32 symWrapMechIndex = wswk->symWrapMechIndex; |
+ PRUint32 ndx; |
+ PRUint32 now = 0; |
+ SSLWrappedSymWrappingKey myWswk; |
+ |
+ if (!cache->cacheMem) { /* cache is uninitialized */ |
+ PORT_SetError(SSL_ERROR_SERVER_CACHE_NOT_CONFIGURED); |
+ return 0; |
+ } |
+ |
+ PORT_Assert( (unsigned)exchKeyType < kt_kea_size); |
+ if ((unsigned)exchKeyType >= kt_kea_size) |
+ return 0; |
+ |
+ PORT_Assert( (unsigned)symWrapMechIndex < SSL_NUM_WRAP_MECHS); |
+ if ((unsigned)symWrapMechIndex >= SSL_NUM_WRAP_MECHS) |
+ return 0; |
+ |
+ ndx = (exchKeyType * SSL_NUM_WRAP_MECHS) + symWrapMechIndex; |
+ PORT_Memset(&myWswk, 0, sizeof myWswk); /* eliminate UMRs. */ |
+ |
+ now = LockSidCacheLock(cache->keyCacheLock, now); |
+ if (now) { |
+ rv = getSvrWrappingKey(wswk->symWrapMechIndex, wswk->exchKeyType, |
+ &myWswk, cache, now); |
+ if (rv) { |
+ /* we found it on disk, copy it out to the caller. */ |
+ PORT_Memcpy(wswk, &myWswk, sizeof *wswk); |
+ } else { |
+ /* Wasn't on disk, and we're still holding the lock, so write it. */ |
+ cache->keyCacheData[ndx] = *wswk; |
+ } |
+ UnlockSidCacheLock(cache->keyCacheLock); |
+ } |
+ return rv; |
+} |
+ |
+#else /* MAC version or other platform */ |
+ |
+#include "seccomon.h" |
+#include "cert.h" |
+#include "ssl.h" |
+#include "sslimpl.h" |
+ |
+SECStatus |
+SSL_ConfigServerSessionIDCache( int maxCacheEntries, |
+ PRUint32 ssl2_timeout, |
+ PRUint32 ssl3_timeout, |
+ const char * directory) |
+{ |
+ PR_ASSERT(!"SSL servers are not supported on this platform. (SSL_ConfigServerSessionIDCache)"); |
+ return SECFailure; |
+} |
+ |
+SECStatus |
+SSL_ConfigMPServerSIDCache( int maxCacheEntries, |
+ PRUint32 ssl2_timeout, |
+ PRUint32 ssl3_timeout, |
+ const char * directory) |
+{ |
+ PR_ASSERT(!"SSL servers are not supported on this platform. (SSL_ConfigMPServerSIDCache)"); |
+ return SECFailure; |
+} |
+ |
+SECStatus |
+SSL_InheritMPServerSIDCache(const char * envString) |
+{ |
+ PR_ASSERT(!"SSL servers are not supported on this platform. (SSL_InheritMPServerSIDCache)"); |
+ return SECFailure; |
+} |
+ |
+PRBool |
+ssl_GetWrappingKey( PRInt32 symWrapMechIndex, |
+ SSL3KEAType exchKeyType, |
+ SSLWrappedSymWrappingKey *wswk) |
+{ |
+ PRBool rv = PR_FALSE; |
+ PR_ASSERT(!"SSL servers are not supported on this platform. (ssl_GetWrappingKey)"); |
+ return rv; |
+} |
+ |
+/* This is a kind of test-and-set. The caller passes in the new value it wants |
+ * to set. This code tests the wrapped sym key entry in the shared memory. |
+ * If it is uninitialized, this function writes the caller's value into |
+ * the disk entry, and returns false. |
+ * Otherwise, it overwrites the caller's wswk with the value obtained from |
+ * the disk, and returns PR_TRUE. |
+ * This is all done while holding the locks/mutexes necessary to make |
+ * the operation atomic. |
+ */ |
+PRBool |
+ssl_SetWrappingKey(SSLWrappedSymWrappingKey *wswk) |
+{ |
+ PRBool rv = PR_FALSE; |
+ PR_ASSERT(!"SSL servers are not supported on this platform. (ssl_SetWrappingKey)"); |
+ return rv; |
+} |
+ |
+PRUint32 |
+SSL_GetMaxServerCacheLocks(void) |
+{ |
+ PR_ASSERT(!"SSL servers are not supported on this platform. (SSL_GetMaxServerCacheLocks)"); |
+ return -1; |
+} |
+ |
+SECStatus |
+SSL_SetMaxServerCacheLocks(PRUint32 maxLocks) |
+{ |
+ PR_ASSERT(!"SSL servers are not supported on this platform. (SSL_SetMaxServerCacheLocks)"); |
+ return SECFailure; |
+} |
+ |
+#endif /* XP_UNIX || XP_WIN32 */ |