crl.c 42 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501
  1. /* crl.c
  2. *
  3. * Copyright (C) 2006-2023 wolfSSL Inc.
  4. *
  5. * This file is part of wolfSSL.
  6. *
  7. * wolfSSL is free software; you can redistribute it and/or modify
  8. * it under the terms of the GNU General Public License as published by
  9. * the Free Software Foundation; either version 2 of the License, or
  10. * (at your option) any later version.
  11. *
  12. * wolfSSL is distributed in the hope that it will be useful,
  13. * but WITHOUT ANY WARRANTY; without even the implied warranty of
  14. * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  15. * GNU General Public License for more details.
  16. *
  17. * You should have received a copy of the GNU General Public License
  18. * along with this program; if not, write to the Free Software
  19. * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1335, USA
  20. */
  21. /*
  22. CRL Options:
  23. * CRL_STATIC_REVOKED_LIST: default: off
  24. * Enables fixed static list of RevokedCerts to allow
  25. * for a binary search.
  26. * CRL_MAX_REVOKED_CERTS: default: 4
  27. * Specifies the number of buffers to hold RevokedCerts.
  28. * The default value is set to 4.
  29. */
  30. #ifdef HAVE_CONFIG_H
  31. #include <config.h>
  32. #endif
  33. #include <wolfssl/wolfcrypt/settings.h>
  34. #ifndef WOLFCRYPT_ONLY
  35. #ifdef HAVE_CRL
  36. #include <wolfssl/internal.h>
  37. #include <wolfssl/error-ssl.h>
  38. #ifndef WOLFSSL_LINUXKM
  39. #include <string.h>
  40. #endif
  41. #ifdef HAVE_CRL_MONITOR
  42. #if (defined(__MACH__) || defined(__FreeBSD__) || defined(__linux__))
  43. static int StopMonitor(int mfd);
  44. #else
  45. #error "CRL monitor only currently supported on linux or mach"
  46. #endif
  47. #endif /* HAVE_CRL_MONITOR */
  48. /* Initialize CRL members */
  49. int InitCRL(WOLFSSL_CRL* crl, WOLFSSL_CERT_MANAGER* cm)
  50. {
  51. WOLFSSL_ENTER("InitCRL");
  52. if(cm != NULL)
  53. crl->heap = cm->heap;
  54. else
  55. crl->heap = NULL;
  56. crl->cm = cm;
  57. crl->crlList = NULL;
  58. crl->currentEntry = NULL;
  59. crl->monitors[0].path = NULL;
  60. crl->monitors[1].path = NULL;
  61. #ifdef HAVE_CRL_MONITOR
  62. crl->tid = 0;
  63. crl->mfd = -1; /* mfd for bsd is kqueue fd, eventfd for linux */
  64. crl->setup = 0; /* thread setup done predicate */
  65. if (pthread_cond_init(&crl->cond, 0) != 0) {
  66. WOLFSSL_MSG("Pthread condition init failed");
  67. return BAD_COND_E;
  68. }
  69. #endif
  70. #ifdef HAVE_CRL_IO
  71. crl->crlIOCb = NULL;
  72. #endif
  73. if (wc_InitMutex(&crl->crlLock) != 0) {
  74. WOLFSSL_MSG("Init Mutex failed");
  75. return BAD_MUTEX_E;
  76. }
  77. return 0;
  78. }
  79. /* Initialize CRL Entry */
  80. static int InitCRL_Entry(CRL_Entry* crle, DecodedCRL* dcrl, const byte* buff,
  81. int verified, void* heap)
  82. {
  83. WOLFSSL_ENTER("InitCRL_Entry");
  84. XMEMCPY(crle->issuerHash, dcrl->issuerHash, CRL_DIGEST_SIZE);
  85. /* XMEMCPY(crle->crlHash, dcrl->crlHash, CRL_DIGEST_SIZE);
  86. * copy the hash here if needed for optimized comparisons */
  87. XMEMCPY(crle->lastDate, dcrl->lastDate, MAX_DATE_SIZE);
  88. XMEMCPY(crle->nextDate, dcrl->nextDate, MAX_DATE_SIZE);
  89. crle->lastDateFormat = dcrl->lastDateFormat;
  90. crle->nextDateFormat = dcrl->nextDateFormat;
  91. crle->version = dcrl->version;
  92. #if defined(OPENSSL_EXTRA)
  93. crle->lastDateAsn1.length = MAX_DATE_SIZE;
  94. XMEMCPY (crle->lastDateAsn1.data, crle->lastDate,
  95. crle->lastDateAsn1.length);
  96. crle->lastDateAsn1.type = crle->lastDateFormat;
  97. crle->nextDateAsn1.length = MAX_DATE_SIZE;
  98. XMEMCPY (crle->nextDateAsn1.data, crle->nextDate,
  99. crle->nextDateAsn1.length);
  100. crle->nextDateAsn1.type = crle->nextDateFormat;
  101. crle->issuer = NULL;
  102. wolfSSL_d2i_X509_NAME(&crle->issuer, (unsigned char**)&dcrl->issuer,
  103. dcrl->issuerSz);
  104. if (crle->issuer == NULL) {
  105. return WOLFSSL_FAILURE;
  106. }
  107. #endif
  108. #ifdef CRL_STATIC_REVOKED_LIST
  109. /* ParseCRL_CertList() has already cached the Revoked certs into
  110. the crle->certs array */
  111. #else
  112. crle->certs = dcrl->certs; /* take ownership */
  113. #endif
  114. dcrl->certs = NULL;
  115. crle->totalCerts = dcrl->totalCerts;
  116. crle->crlNumber = dcrl->crlNumber;
  117. crle->verified = verified;
  118. if (!verified) {
  119. crle->tbsSz = dcrl->sigIndex - dcrl->certBegin;
  120. crle->signatureSz = dcrl->sigLength;
  121. crle->signatureOID = dcrl->signatureOID;
  122. crle->toBeSigned = (byte*)XMALLOC(crle->tbsSz, heap,
  123. DYNAMIC_TYPE_CRL_ENTRY);
  124. if (crle->toBeSigned == NULL)
  125. return -1;
  126. crle->signature = (byte*)XMALLOC(crle->signatureSz, heap,
  127. DYNAMIC_TYPE_CRL_ENTRY);
  128. if (crle->signature == NULL) {
  129. XFREE(crle->toBeSigned, heap, DYNAMIC_TYPE_CRL_ENTRY);
  130. return -1;
  131. }
  132. XMEMCPY(crle->toBeSigned, buff + dcrl->certBegin, crle->tbsSz);
  133. XMEMCPY(crle->signature, dcrl->signature, crle->signatureSz);
  134. #ifndef NO_SKID
  135. crle->extAuthKeyIdSet = dcrl->extAuthKeyIdSet;
  136. if (crle->extAuthKeyIdSet)
  137. XMEMCPY(crle->extAuthKeyId, dcrl->extAuthKeyId, KEYID_SIZE);
  138. #endif
  139. }
  140. else {
  141. crle->toBeSigned = NULL;
  142. crle->signature = NULL;
  143. }
  144. (void)verified;
  145. (void)heap;
  146. return 0;
  147. }
  148. /* Free all CRL Entry resources */
  149. static void FreeCRL_Entry(CRL_Entry* crle, void* heap)
  150. {
  151. #ifdef CRL_STATIC_REVOKED_LIST
  152. if (crle != NULL) {
  153. XMEMSET(crle->certs, 0, CRL_MAX_REVOKED_CERTS*sizeof(RevokedCert));
  154. }
  155. #else
  156. RevokedCert* tmp = crle->certs;
  157. RevokedCert* next;
  158. WOLFSSL_ENTER("FreeCRL_Entry");
  159. while (tmp) {
  160. next = tmp->next;
  161. XFREE(tmp, heap, DYNAMIC_TYPE_REVOKED);
  162. tmp = next;
  163. }
  164. #endif
  165. if (crle->signature != NULL)
  166. XFREE(crle->signature, heap, DYNAMIC_TYPE_CRL_ENTRY);
  167. if (crle->toBeSigned != NULL)
  168. XFREE(crle->toBeSigned, heap, DYNAMIC_TYPE_CRL_ENTRY);
  169. #if defined(OPENSSL_EXTRA)
  170. if (crle->issuer != NULL) {
  171. FreeX509Name(crle->issuer);
  172. XFREE(crle->issuer, heap, DYNAMIC_TYPE_X509);
  173. }
  174. #endif
  175. (void)heap;
  176. }
  177. /* Free all CRL resources */
  178. void FreeCRL(WOLFSSL_CRL* crl, int dynamic)
  179. {
  180. CRL_Entry* tmp = crl->crlList;
  181. WOLFSSL_ENTER("FreeCRL");
  182. if (crl->monitors[0].path)
  183. XFREE(crl->monitors[0].path, crl->heap, DYNAMIC_TYPE_CRL_MONITOR);
  184. if (crl->monitors[1].path)
  185. XFREE(crl->monitors[1].path, crl->heap, DYNAMIC_TYPE_CRL_MONITOR);
  186. XFREE(crl->currentEntry, crl->heap, DYNAMIC_TYPE_CRL_ENTRY);
  187. crl->currentEntry = NULL;
  188. while(tmp) {
  189. CRL_Entry* next = tmp->next;
  190. FreeCRL_Entry(tmp, crl->heap);
  191. XFREE(tmp, crl->heap, DYNAMIC_TYPE_CRL_ENTRY);
  192. tmp = next;
  193. }
  194. #ifdef HAVE_CRL_MONITOR
  195. if (crl->tid != 0) {
  196. WOLFSSL_MSG("stopping monitor thread");
  197. if (StopMonitor(crl->mfd) == 0) {
  198. int _pthread_ret = pthread_join(crl->tid, NULL);
  199. if (_pthread_ret != 0)
  200. WOLFSSL_MSG("stop monitor failed in pthread_join");
  201. }
  202. else {
  203. WOLFSSL_MSG("stop monitor failed");
  204. }
  205. }
  206. {
  207. int _pthread_ret = pthread_cond_destroy(&crl->cond);
  208. if (_pthread_ret != 0)
  209. WOLFSSL_MSG("pthread_cond_destroy failed in FreeCRL");
  210. }
  211. #endif
  212. wc_FreeMutex(&crl->crlLock);
  213. if (dynamic) /* free self */
  214. XFREE(crl, crl->heap, DYNAMIC_TYPE_CRL);
  215. }
  216. static int FindRevokedSerial(DecodedCert* cert, RevokedCert* rc, int totalCerts)
  217. {
  218. int ret = 0;
  219. #ifdef CRL_STATIC_REVOKED_LIST
  220. /* do binary search */
  221. int low, high, mid;
  222. low = 0;
  223. high = totalCerts - 1;
  224. while (low <= high) {
  225. mid = (low + high) / 2;
  226. if (XMEMCMP(rc[mid].serialNumber, cert->serial, rc->serialSz) < 0) {
  227. low = mid + 1;
  228. }
  229. else if (XMEMCMP(rc[mid].serialNumber, cert->serial,
  230. rc->serialSz) > 0) {
  231. high = mid - 1;
  232. }
  233. else {
  234. WOLFSSL_MSG("Cert revoked");
  235. ret = CRL_CERT_REVOKED;
  236. break;
  237. }
  238. }
  239. #else
  240. (void)totalCerts;
  241. /* search in the linked list*/
  242. while (rc) {
  243. if (rc->serialSz == cert->serialSz &&
  244. XMEMCMP(rc->serialNumber, cert->serial, rc->serialSz) == 0) {
  245. WOLFSSL_MSG("Cert revoked");
  246. ret = CRL_CERT_REVOKED;
  247. break;
  248. }
  249. rc = rc->next;
  250. }
  251. #endif
  252. return ret;
  253. }
  254. static int CheckCertCRLList(WOLFSSL_CRL* crl, DecodedCert* cert, int *pFoundEntry)
  255. {
  256. CRL_Entry* crle;
  257. int foundEntry = 0;
  258. int ret = 0;
  259. if (wc_LockMutex(&crl->crlLock) != 0) {
  260. WOLFSSL_MSG("wc_LockMutex failed");
  261. return BAD_MUTEX_E;
  262. }
  263. crle = crl->crlList;
  264. while (crle) {
  265. if (XMEMCMP(crle->issuerHash, cert->issuerHash, CRL_DIGEST_SIZE) == 0) {
  266. WOLFSSL_MSG("Found CRL Entry on list");
  267. if (crle->verified == 0) {
  268. Signer* ca = NULL;
  269. #ifndef NO_SKID
  270. byte extAuthKeyId[KEYID_SIZE];
  271. #endif
  272. byte issuerHash[CRL_DIGEST_SIZE];
  273. byte* tbs;
  274. word32 tbsSz = crle->tbsSz;
  275. byte* sig = NULL;
  276. word32 sigSz = crle->signatureSz;
  277. word32 sigOID = crle->signatureOID;
  278. SignatureCtx sigCtx;
  279. tbs = (byte*)XMALLOC(tbsSz, crl->heap, DYNAMIC_TYPE_CRL_ENTRY);
  280. if (tbs == NULL) {
  281. wc_UnLockMutex(&crl->crlLock);
  282. return MEMORY_E;
  283. }
  284. sig = (byte*)XMALLOC(sigSz, crl->heap, DYNAMIC_TYPE_CRL_ENTRY);
  285. if (sig == NULL) {
  286. XFREE(tbs, crl->heap, DYNAMIC_TYPE_CRL_ENTRY);
  287. wc_UnLockMutex(&crl->crlLock);
  288. return MEMORY_E;
  289. }
  290. XMEMCPY(tbs, crle->toBeSigned, tbsSz);
  291. XMEMCPY(sig, crle->signature, sigSz);
  292. #ifndef NO_SKID
  293. XMEMCPY(extAuthKeyId, crle->extAuthKeyId,
  294. sizeof(extAuthKeyId));
  295. #endif
  296. XMEMCPY(issuerHash, crle->issuerHash, sizeof(issuerHash));
  297. wc_UnLockMutex(&crl->crlLock);
  298. #ifndef NO_SKID
  299. if (crle->extAuthKeyIdSet)
  300. ca = GetCA(crl->cm, extAuthKeyId);
  301. if (ca == NULL)
  302. ca = GetCAByName(crl->cm, issuerHash);
  303. #else /* NO_SKID */
  304. ca = GetCA(crl->cm, issuerHash);
  305. #endif /* NO_SKID */
  306. if (ca == NULL) {
  307. XFREE(sig, crl->heap, DYNAMIC_TYPE_CRL_ENTRY);
  308. XFREE(tbs, crl->heap, DYNAMIC_TYPE_CRL_ENTRY);
  309. WOLFSSL_MSG("Did NOT find CRL issuer CA");
  310. return ASN_CRL_NO_SIGNER_E;
  311. }
  312. ret = VerifyCRL_Signature(&sigCtx, tbs, tbsSz, sig, sigSz,
  313. sigOID, ca, crl->heap);
  314. XFREE(sig, crl->heap, DYNAMIC_TYPE_CRL_ENTRY);
  315. XFREE(tbs, crl->heap, DYNAMIC_TYPE_CRL_ENTRY);
  316. if (wc_LockMutex(&crl->crlLock) != 0) {
  317. WOLFSSL_MSG("wc_LockMutex failed");
  318. return BAD_MUTEX_E;
  319. }
  320. crle = crl->crlList;
  321. while (crle) {
  322. if (XMEMCMP(crle->issuerHash, cert->issuerHash,
  323. CRL_DIGEST_SIZE) == 0) {
  324. if (ret == 0)
  325. crle->verified = 1;
  326. else
  327. crle->verified = ret;
  328. XFREE(crle->toBeSigned, crl->heap,
  329. DYNAMIC_TYPE_CRL_ENTRY);
  330. crle->toBeSigned = NULL;
  331. XFREE(crle->signature, crl->heap,
  332. DYNAMIC_TYPE_CRL_ENTRY);
  333. crle->signature = NULL;
  334. break;
  335. }
  336. crle = crle->next;
  337. }
  338. if (crle == NULL || crle->verified < 0)
  339. break;
  340. }
  341. else if (crle->verified < 0) {
  342. WOLFSSL_MSG("Cannot use CRL as it didn't verify");
  343. ret = crle->verified;
  344. break;
  345. }
  346. WOLFSSL_MSG("Checking next date validity");
  347. #ifdef WOLFSSL_NO_CRL_NEXT_DATE
  348. if (crle->nextDateFormat != ASN_OTHER_TYPE)
  349. #endif
  350. {
  351. #ifndef NO_ASN_TIME
  352. if (!XVALIDATE_DATE(crle->nextDate,crle->nextDateFormat, AFTER)) {
  353. WOLFSSL_MSG("CRL next date is no longer valid");
  354. ret = ASN_AFTER_DATE_E;
  355. }
  356. #endif
  357. }
  358. if (ret == 0) {
  359. foundEntry = 1;
  360. }
  361. break;
  362. }
  363. crle = crle->next;
  364. }
  365. if (foundEntry) {
  366. ret = FindRevokedSerial(cert, crle->certs, crle->totalCerts);
  367. }
  368. wc_UnLockMutex(&crl->crlLock);
  369. *pFoundEntry = foundEntry;
  370. return ret;
  371. }
  372. /* Is the cert ok with CRL, return 0 on success */
  373. int CheckCertCRL(WOLFSSL_CRL* crl, DecodedCert* cert)
  374. {
  375. int foundEntry = 0;
  376. int ret = 0;
  377. WOLFSSL_ENTER("CheckCertCRL");
  378. #ifdef WOLFSSL_CRL_ALLOW_MISSING_CDP
  379. /* Skip CRL verification in case no CDP in peer cert */
  380. if (!cert->extCrlInfo) {
  381. return ret;
  382. }
  383. #endif
  384. ret = CheckCertCRLList(crl, cert, &foundEntry);
  385. #ifdef HAVE_CRL_IO
  386. if (foundEntry == 0) {
  387. /* perform embedded lookup */
  388. if (crl->crlIOCb) {
  389. ret = crl->crlIOCb(crl, (const char*)cert->extCrlInfo,
  390. cert->extCrlInfoSz);
  391. if (ret == WOLFSSL_CBIO_ERR_WANT_READ) {
  392. ret = OCSP_WANT_READ;
  393. }
  394. else if (ret >= 0) {
  395. /* try again */
  396. ret = CheckCertCRLList(crl, cert, &foundEntry);
  397. }
  398. }
  399. }
  400. #endif
  401. #if defined(OPENSSL_ALL) && defined(WOLFSSL_CERT_GEN) && \
  402. (defined(WOLFSSL_CERT_REQ) || defined(WOLFSSL_CERT_EXT)) && \
  403. !defined(NO_FILESYSTEM) && !defined(NO_WOLFSSL_DIR)
  404. /* if not find entry in the CRL list, it looks at the folder that sets */
  405. /* by LOOKUP_ctrl because user would want to use hash_dir. */
  406. /* Loading <issuer-hash>.rN form CRL file if find at the folder, */
  407. /* and try again checking Cert in the CRL list. */
  408. /* When not set the folder or not use hash_dir, do nothing. */
  409. if ((foundEntry == 0) && (ret != OCSP_WANT_READ)) {
  410. if (crl->cm->x509_store_p != NULL) {
  411. ret = LoadCertByIssuer(crl->cm->x509_store_p,
  412. (WOLFSSL_X509_NAME*)cert->issuerName, X509_LU_CRL);
  413. if (ret == WOLFSSL_SUCCESS) {
  414. /* try again */
  415. ret = CheckCertCRLList(crl, cert, &foundEntry);
  416. }
  417. }
  418. }
  419. #endif
  420. if (foundEntry == 0) {
  421. WOLFSSL_MSG("Couldn't find CRL for status check");
  422. if (ret != CRL_CERT_DATE_ERR) {
  423. ret = CRL_MISSING;
  424. }
  425. if (crl->cm->cbMissingCRL) {
  426. char url[256];
  427. WOLFSSL_MSG("Issuing missing CRL callback");
  428. url[0] = '\0';
  429. if (cert->extCrlInfo) {
  430. if (cert->extCrlInfoSz < (int)sizeof(url) -1 ) {
  431. XMEMCPY(url, cert->extCrlInfo, cert->extCrlInfoSz);
  432. url[cert->extCrlInfoSz] = '\0';
  433. }
  434. else {
  435. WOLFSSL_MSG("CRL url too long");
  436. }
  437. }
  438. crl->cm->cbMissingCRL(url);
  439. }
  440. }
  441. return ret;
  442. }
  443. /* Add Decoded CRL, 0 on success */
  444. static int AddCRL(WOLFSSL_CRL* crl, DecodedCRL* dcrl, const byte* buff,
  445. int verified)
  446. {
  447. CRL_Entry* crle = NULL;
  448. WOLFSSL_ENTER("AddCRL");
  449. if (crl == NULL)
  450. return -1;
  451. crle = crl->currentEntry;
  452. if (crle == NULL) {
  453. crle = (CRL_Entry*)XMALLOC(sizeof(CRL_Entry), crl->heap,
  454. DYNAMIC_TYPE_CRL_ENTRY);
  455. if (crle == NULL) {
  456. WOLFSSL_MSG("alloc CRL Entry failed");
  457. return MEMORY_E;
  458. }
  459. }
  460. if (InitCRL_Entry(crle, dcrl, buff, verified, crl->heap) < 0) {
  461. WOLFSSL_MSG("Init CRL Entry failed");
  462. XFREE(crle, crl->heap, DYNAMIC_TYPE_CRL_ENTRY);
  463. return -1;
  464. }
  465. if (wc_LockMutex(&crl->crlLock) != 0) {
  466. WOLFSSL_MSG("wc_LockMutex failed");
  467. FreeCRL_Entry(crle, crl->heap);
  468. XFREE(crle, crl->heap, DYNAMIC_TYPE_CRL_ENTRY);
  469. return BAD_MUTEX_E;
  470. }
  471. crle->next = crl->crlList;
  472. crl->crlList = crle;
  473. wc_UnLockMutex(&crl->crlLock);
  474. /* Avoid heap-use-after-free after crl->crlList is released */
  475. crl->currentEntry = NULL;
  476. return 0;
  477. }
  478. /* Load CRL File of type, WOLFSSL_SUCCESS on ok */
  479. int BufferLoadCRL(WOLFSSL_CRL* crl, const byte* buff, long sz, int type,
  480. int verify)
  481. {
  482. int ret = WOLFSSL_SUCCESS;
  483. const byte* myBuffer = buff; /* if DER ok, otherwise switch */
  484. DerBuffer* der = NULL;
  485. #ifdef WOLFSSL_SMALL_STACK
  486. DecodedCRL* dcrl;
  487. #else
  488. DecodedCRL dcrl[1];
  489. #endif
  490. WOLFSSL_ENTER("BufferLoadCRL");
  491. if (crl == NULL || buff == NULL || sz == 0)
  492. return BAD_FUNC_ARG;
  493. if (type == WOLFSSL_FILETYPE_PEM) {
  494. #ifdef WOLFSSL_PEM_TO_DER
  495. ret = PemToDer(buff, sz, CRL_TYPE, &der, NULL, NULL, NULL);
  496. if (ret == 0) {
  497. myBuffer = der->buffer;
  498. sz = der->length;
  499. }
  500. else {
  501. WOLFSSL_MSG("Pem to Der failed");
  502. FreeDer(&der);
  503. return -1;
  504. }
  505. #else
  506. ret = NOT_COMPILED_IN;
  507. #endif
  508. }
  509. #ifdef WOLFSSL_SMALL_STACK
  510. dcrl = (DecodedCRL*)XMALLOC(sizeof(DecodedCRL), NULL, DYNAMIC_TYPE_TMP_BUFFER);
  511. if (dcrl == NULL) {
  512. FreeDer(&der);
  513. return MEMORY_E;
  514. }
  515. #endif
  516. crl->currentEntry = (CRL_Entry*)XMALLOC(sizeof(CRL_Entry), crl->heap,
  517. DYNAMIC_TYPE_CRL_ENTRY);
  518. if (crl->currentEntry == NULL) {
  519. WOLFSSL_MSG("alloc CRL Entry failed");
  520. #ifdef WOLFSSL_SMALL_STACK
  521. XFREE(dcrl, NULL, DYNAMIC_TYPE_TMP_BUFFER);
  522. #endif
  523. FreeDer(&der);
  524. return MEMORY_E;
  525. }
  526. XMEMSET(crl->currentEntry, 0, sizeof(CRL_Entry));
  527. InitDecodedCRL(dcrl, crl->heap);
  528. ret = ParseCRL(crl->currentEntry->certs, dcrl, myBuffer, (word32)sz,
  529. verify, crl->cm);
  530. if (ret != 0 && !(ret == ASN_CRL_NO_SIGNER_E && verify == NO_VERIFY)) {
  531. WOLFSSL_MSG("ParseCRL error");
  532. XFREE(crl->currentEntry, crl->heap, DYNAMIC_TYPE_CRL_ENTRY);
  533. crl->currentEntry = NULL;
  534. }
  535. else {
  536. ret = AddCRL(crl, dcrl, myBuffer, ret != ASN_CRL_NO_SIGNER_E);
  537. if (ret != 0) {
  538. WOLFSSL_MSG("AddCRL error");
  539. }
  540. }
  541. FreeDecodedCRL(dcrl);
  542. #ifdef WOLFSSL_SMALL_STACK
  543. XFREE(dcrl, NULL, DYNAMIC_TYPE_TMP_BUFFER);
  544. #endif
  545. FreeDer(&der);
  546. return ret ? ret : WOLFSSL_SUCCESS; /* convert 0 to WOLFSSL_SUCCESS */
  547. }
  548. #if defined(OPENSSL_EXTRA) && defined(HAVE_CRL)
  549. /* helper function to create a new dynamic WOLFSSL_X509_CRL structure */
  550. static WOLFSSL_X509_CRL* wolfSSL_X509_crl_new(WOLFSSL_CERT_MANAGER* cm)
  551. {
  552. WOLFSSL_X509_CRL* ret;
  553. ret = (WOLFSSL_X509_CRL*)XMALLOC(sizeof(WOLFSSL_X509_CRL), cm->heap,
  554. DYNAMIC_TYPE_CRL);
  555. if (ret != NULL) {
  556. if (InitCRL(ret, cm) < 0) {
  557. WOLFSSL_MSG("Unable to initialize new CRL structure");
  558. XFREE(ret, cm->heap, DYNAMIC_TYPE_CRL);
  559. ret = NULL;
  560. }
  561. }
  562. return ret;
  563. }
  564. #ifndef CRL_STATIC_REVOKED_LIST
  565. /* returns head of copied list that was alloc'd */
  566. static RevokedCert *DupRevokedCertList(RevokedCert* in, void* heap)
  567. {
  568. RevokedCert* head = NULL;
  569. RevokedCert* current = in;
  570. RevokedCert* prev = NULL;
  571. while (current) {
  572. RevokedCert* tmp = (RevokedCert*)XMALLOC(sizeof(RevokedCert), heap,
  573. DYNAMIC_TYPE_REVOKED);
  574. if (tmp != NULL) {
  575. XMEMCPY(tmp->serialNumber, current->serialNumber,
  576. EXTERNAL_SERIAL_SIZE);
  577. tmp->serialSz = current->serialSz;
  578. XMEMCPY(tmp->revDate, current->revDate,
  579. MAX_DATE_SIZE);
  580. tmp->revDateFormat = current->revDateFormat;
  581. tmp->next = NULL;
  582. if (prev != NULL)
  583. prev->next = tmp;
  584. if (head == NULL)
  585. head = tmp;
  586. prev = tmp;
  587. }
  588. else {
  589. WOLFSSL_MSG("Failed to allocate new RevokedCert structure");
  590. /* free up any existing list */
  591. while (head != NULL) {
  592. current = head;
  593. head = head->next;
  594. XFREE(current, heap, DYNAMIC_TYPE_REVOKED);
  595. }
  596. return NULL;
  597. }
  598. current = current->next;
  599. }
  600. (void)heap;
  601. return head;
  602. }
  603. #endif /* CRL_STATIC_REVOKED_LIST */
  604. /* returns a deep copy of ent on success and null on fail */
  605. static CRL_Entry* DupCRL_Entry(const CRL_Entry* ent, void* heap)
  606. {
  607. CRL_Entry *dupl;
  608. #ifdef CRL_STATIC_REVOKED_LIST
  609. if (ent->totalCerts > CRL_MAX_REVOKED_CERTS) {
  610. return NULL;
  611. }
  612. #endif
  613. dupl = (CRL_Entry*)XMALLOC(sizeof(CRL_Entry), heap, DYNAMIC_TYPE_CRL_ENTRY);
  614. if (dupl == NULL) {
  615. WOLFSSL_MSG("alloc CRL Entry failed");
  616. return NULL;
  617. }
  618. XMEMSET(dupl, 0, sizeof(CRL_Entry));
  619. XMEMCPY(dupl->issuerHash, ent->issuerHash, CRL_DIGEST_SIZE);
  620. XMEMCPY(dupl->lastDate, ent->lastDate, MAX_DATE_SIZE);
  621. XMEMCPY(dupl->nextDate, ent->nextDate, MAX_DATE_SIZE);
  622. dupl->lastDateFormat = ent->lastDateFormat;
  623. dupl->nextDateFormat = ent->nextDateFormat;
  624. #if defined(OPENSSL_EXTRA)
  625. dupl->lastDateAsn1.length = MAX_DATE_SIZE;
  626. XMEMCPY (dupl->lastDateAsn1.data, dupl->lastDate,
  627. dupl->lastDateAsn1.length);
  628. dupl->lastDateAsn1.type = dupl->lastDateFormat;
  629. dupl->nextDateAsn1.length = MAX_DATE_SIZE;
  630. XMEMCPY (dupl->nextDateAsn1.data, dupl->nextDate,
  631. dupl->nextDateAsn1.length);
  632. dupl->nextDateAsn1.type = dupl->nextDateFormat;
  633. #endif
  634. #ifdef CRL_STATIC_REVOKED_LIST
  635. XMEMCPY(dupl->certs, ent->certs, ent->totalCerts*sizeof(RevokedCert));
  636. #else
  637. dupl->certs = DupRevokedCertList(ent->certs, heap);
  638. #endif
  639. dupl->totalCerts = ent->totalCerts;
  640. dupl->verified = ent->verified;
  641. if (!ent->verified) {
  642. dupl->tbsSz = ent->tbsSz;
  643. dupl->signatureSz = ent->signatureSz;
  644. dupl->signatureOID = ent->signatureOID;
  645. dupl->toBeSigned = (byte*)XMALLOC(dupl->tbsSz, heap,
  646. DYNAMIC_TYPE_CRL_ENTRY);
  647. if (dupl->toBeSigned == NULL) {
  648. FreeCRL_Entry(dupl, heap);
  649. XFREE(dupl, heap, DYNAMIC_TYPE_CRL_ENTRY);
  650. return NULL;
  651. }
  652. dupl->signature = (byte*)XMALLOC(dupl->signatureSz, heap,
  653. DYNAMIC_TYPE_CRL_ENTRY);
  654. if (dupl->signature == NULL) {
  655. FreeCRL_Entry(dupl, heap);
  656. XFREE(dupl, heap, DYNAMIC_TYPE_CRL_ENTRY);
  657. return NULL;
  658. }
  659. XMEMCPY(dupl->toBeSigned, ent->toBeSigned, dupl->tbsSz);
  660. XMEMCPY(dupl->signature, ent->signature, dupl->signatureSz);
  661. #ifndef NO_SKID
  662. dupl->extAuthKeyIdSet = ent->extAuthKeyIdSet;
  663. if (dupl->extAuthKeyIdSet)
  664. XMEMCPY(dupl->extAuthKeyId, ent->extAuthKeyId, KEYID_SIZE);
  665. #endif
  666. }
  667. else {
  668. dupl->toBeSigned = NULL;
  669. dupl->tbsSz = 0;
  670. dupl->signature = NULL;
  671. dupl->signatureSz = 0;
  672. }
  673. return dupl;
  674. }
  675. /* returns the head of a deep copy of the list on success and null on fail */
  676. static CRL_Entry* DupCRL_list(CRL_Entry* crl, void* heap)
  677. {
  678. CRL_Entry* current;
  679. CRL_Entry* head = NULL;
  680. CRL_Entry* prev = NULL;
  681. current = crl;
  682. while (current != NULL) {
  683. CRL_Entry* tmp = DupCRL_Entry(current, heap);
  684. if (tmp != NULL) {
  685. tmp->next = NULL;
  686. if (head == NULL)
  687. head = tmp;
  688. if (prev != NULL)
  689. prev->next = tmp;
  690. prev = tmp;
  691. }
  692. else {
  693. WOLFSSL_MSG("Failed to allocate new CRL_Entry structure");
  694. /* free up any existing list */
  695. while (head != NULL) {
  696. current = head;
  697. head = head->next;
  698. FreeCRL_Entry(current, heap);
  699. XFREE(current, heap, DYNAMIC_TYPE_CRL_ENTRY);
  700. }
  701. return NULL;
  702. }
  703. current = current->next;
  704. }
  705. return head;
  706. }
  707. /* Duplicates everything except the parent cm pointed to.
  708. * Expects that Init has already been done to 'dupl'
  709. * return 0 on success */
  710. static int DupX509_CRL(WOLFSSL_X509_CRL *dupl, const WOLFSSL_X509_CRL* crl)
  711. {
  712. if (dupl == NULL || crl == NULL) {
  713. return BAD_FUNC_ARG;
  714. }
  715. if (crl->monitors[0].path) {
  716. int pathSz = (int)XSTRLEN(crl->monitors[0].path) + 1;
  717. dupl->monitors[0].path = (char*)XMALLOC(pathSz, dupl->heap,
  718. DYNAMIC_TYPE_CRL_MONITOR);
  719. if (dupl->monitors[0].path != NULL) {
  720. XSTRNCPY(dupl->monitors[0].path, crl->monitors[0].path, pathSz);
  721. }
  722. else {
  723. return MEMORY_E;
  724. }
  725. }
  726. if (crl->monitors[1].path) {
  727. int pathSz = (int)XSTRLEN(crl->monitors[1].path) + 1;
  728. dupl->monitors[1].path = (char*)XMALLOC(pathSz, dupl->heap,
  729. DYNAMIC_TYPE_CRL_MONITOR);
  730. if (dupl->monitors[1].path != NULL) {
  731. XSTRNCPY(dupl->monitors[1].path, crl->monitors[1].path, pathSz);
  732. }
  733. else {
  734. if (dupl->monitors[0].path != NULL) {
  735. XFREE(dupl->monitors[0].path, dupl->heap,
  736. DYNAMIC_TYPE_CRL_MONITOR);
  737. }
  738. return MEMORY_E;
  739. }
  740. }
  741. dupl->crlList = DupCRL_list(crl->crlList, dupl->heap);
  742. #ifdef HAVE_CRL_IO
  743. dupl->crlIOCb = crl->crlIOCb;
  744. #endif
  745. return 0;
  746. }
  747. /* returns WOLFSSL_SUCCESS on success. Does not take ownership of newcrl */
  748. int wolfSSL_X509_STORE_add_crl(WOLFSSL_X509_STORE *store, WOLFSSL_X509_CRL *newcrl)
  749. {
  750. CRL_Entry *crle;
  751. WOLFSSL_X509_CRL *crl;
  752. WOLFSSL_ENTER("wolfSSL_X509_STORE_add_crl");
  753. if (store == NULL || newcrl == NULL || store->cm == NULL)
  754. return BAD_FUNC_ARG;
  755. if (store->cm->crl == NULL) {
  756. crl = wolfSSL_X509_crl_new(store->cm);
  757. if (DupX509_CRL(crl, newcrl) != 0) {
  758. if (crl != NULL)
  759. FreeCRL(crl, 1);
  760. return WOLFSSL_FAILURE;
  761. }
  762. store->crl = store->cm->crl = crl;
  763. if (wolfSSL_CertManagerEnableCRL(store->cm, WOLFSSL_CRL_CHECKALL)
  764. != WOLFSSL_SUCCESS) {
  765. WOLFSSL_MSG("wolfSSL_CertManagerEnableCRL error");
  766. return WOLFSSL_FAILURE;
  767. }
  768. return WOLFSSL_SUCCESS;
  769. }
  770. /* find tail of current list and add new list */
  771. crl = store->cm->crl;
  772. crle = crl->crlList;
  773. if (newcrl->crlList != NULL) {
  774. CRL_Entry *tail = crle;
  775. CRL_Entry *toAdd;
  776. if (wc_LockMutex(&crl->crlLock) != 0)
  777. {
  778. WOLFSSL_MSG("wc_LockMutex failed");
  779. return BAD_MUTEX_E;
  780. }
  781. toAdd = DupCRL_list(newcrl->crlList, crl->heap);
  782. if (tail == NULL) {
  783. crl->crlList = toAdd;
  784. }
  785. else {
  786. while (tail->next != NULL) tail = tail->next;
  787. tail->next = toAdd;
  788. }
  789. wc_UnLockMutex(&crl->crlLock);
  790. }
  791. if (wolfSSL_CertManagerEnableCRL(store->cm, WOLFSSL_CRL_CHECKALL)
  792. != WOLFSSL_SUCCESS) {
  793. WOLFSSL_MSG("wolfSSL_CertManagerEnableCRL error");
  794. return WOLFSSL_FAILURE;
  795. }
  796. WOLFSSL_LEAVE("wolfSSL_X509_STORE_add_crl", WOLFSSL_SUCCESS);
  797. return WOLFSSL_SUCCESS;
  798. }
  799. #endif
  800. #ifdef HAVE_CRL_MONITOR
  801. /* Signal Monitor thread is setup, save status to setup flag, 0 on success */
  802. static int SignalSetup(WOLFSSL_CRL* crl, int status)
  803. {
  804. int ret;
  805. /* signal to calling thread we're setup */
  806. if (wc_LockMutex(&crl->crlLock) != 0) {
  807. WOLFSSL_MSG("wc_LockMutex crlLock failed");
  808. return BAD_MUTEX_E;
  809. }
  810. crl->setup = status;
  811. ret = pthread_cond_signal(&crl->cond);
  812. wc_UnLockMutex(&crl->crlLock);
  813. if (ret != 0)
  814. return BAD_COND_E;
  815. return 0;
  816. }
  817. /* read in new CRL entries and save new list */
  818. static int SwapLists(WOLFSSL_CRL* crl)
  819. {
  820. int ret;
  821. CRL_Entry* newList;
  822. #ifdef WOLFSSL_SMALL_STACK
  823. WOLFSSL_CRL* tmp;
  824. #else
  825. WOLFSSL_CRL tmp[1];
  826. #endif
  827. #ifdef WOLFSSL_SMALL_STACK
  828. tmp = (WOLFSSL_CRL*)XMALLOC(sizeof(WOLFSSL_CRL), NULL, DYNAMIC_TYPE_TMP_BUFFER);
  829. if (tmp == NULL)
  830. return MEMORY_E;
  831. #endif
  832. if (InitCRL(tmp, crl->cm) < 0) {
  833. WOLFSSL_MSG("Init tmp CRL failed");
  834. #ifdef WOLFSSL_SMALL_STACK
  835. XFREE(tmp, NULL, DYNAMIC_TYPE_TMP_BUFFER);
  836. #endif
  837. return -1;
  838. }
  839. if (crl->monitors[0].path) {
  840. ret = LoadCRL(tmp, crl->monitors[0].path, WOLFSSL_FILETYPE_PEM, 0);
  841. if (ret != WOLFSSL_SUCCESS) {
  842. WOLFSSL_MSG("PEM LoadCRL on dir change failed");
  843. FreeCRL(tmp, 0);
  844. #ifdef WOLFSSL_SMALL_STACK
  845. XFREE(tmp, NULL, DYNAMIC_TYPE_TMP_BUFFER);
  846. #endif
  847. return -1;
  848. }
  849. }
  850. if (crl->monitors[1].path) {
  851. ret = LoadCRL(tmp, crl->monitors[1].path, WOLFSSL_FILETYPE_ASN1, 0);
  852. if (ret != WOLFSSL_SUCCESS) {
  853. WOLFSSL_MSG("DER LoadCRL on dir change failed");
  854. FreeCRL(tmp, 0);
  855. #ifdef WOLFSSL_SMALL_STACK
  856. XFREE(tmp, NULL, DYNAMIC_TYPE_TMP_BUFFER);
  857. #endif
  858. return -1;
  859. }
  860. }
  861. if (wc_LockMutex(&crl->crlLock) != 0) {
  862. WOLFSSL_MSG("wc_LockMutex failed");
  863. FreeCRL(tmp, 0);
  864. #ifdef WOLFSSL_SMALL_STACK
  865. XFREE(tmp, NULL, DYNAMIC_TYPE_TMP_BUFFER);
  866. #endif
  867. return -1;
  868. }
  869. newList = tmp->crlList;
  870. /* swap lists */
  871. tmp->crlList = crl->crlList;
  872. crl->crlList = newList;
  873. wc_UnLockMutex(&crl->crlLock);
  874. FreeCRL(tmp, 0);
  875. #ifdef WOLFSSL_SMALL_STACK
  876. XFREE(tmp, NULL, DYNAMIC_TYPE_TMP_BUFFER);
  877. #endif
  878. return 0;
  879. }
  880. #if (defined(__MACH__) || defined(__FreeBSD__))
  881. #include <sys/types.h>
  882. #include <sys/event.h>
  883. #include <sys/time.h>
  884. #include <fcntl.h>
  885. #include <unistd.h>
  886. #ifdef __MACH__
  887. #define XEVENT_MODE O_EVTONLY
  888. #elif defined(__FreeBSD__)
  889. #define XEVENT_MODE EVFILT_VNODE
  890. #endif
  891. /* we need a unique kqueue user filter fd for crl in case user is doing custom
  892. * events too */
  893. #ifndef CRL_CUSTOM_FD
  894. #define CRL_CUSTOM_FD 123456
  895. #endif
  896. /* shutdown monitor thread, 0 on success */
  897. static int StopMonitor(int mfd)
  898. {
  899. struct kevent change;
  900. /* trigger custom shutdown */
  901. EV_SET(&change, CRL_CUSTOM_FD, EVFILT_USER, 0, NOTE_TRIGGER, 0, NULL);
  902. if (kevent(mfd, &change, 1, NULL, 0, NULL) < 0) {
  903. WOLFSSL_MSG("kevent trigger customer event failed");
  904. return -1;
  905. }
  906. return 0;
  907. }
  908. /* OS X monitoring */
  909. static void* DoMonitor(void* arg)
  910. {
  911. int fPEM, fDER;
  912. struct kevent change;
  913. WOLFSSL_CRL* crl = (WOLFSSL_CRL*)arg;
  914. WOLFSSL_ENTER("DoMonitor");
  915. crl->mfd = kqueue();
  916. if (crl->mfd == -1) {
  917. WOLFSSL_MSG("kqueue failed");
  918. SignalSetup(crl, MONITOR_SETUP_E);
  919. return NULL;
  920. }
  921. /* listen for custom shutdown event */
  922. EV_SET(&change, CRL_CUSTOM_FD, EVFILT_USER, EV_ADD, 0, 0, NULL);
  923. if (kevent(crl->mfd, &change, 1, NULL, 0, NULL) < 0) {
  924. WOLFSSL_MSG("kevent monitor customer event failed");
  925. SignalSetup(crl, MONITOR_SETUP_E);
  926. (void)close(crl->mfd);
  927. return NULL;
  928. }
  929. fPEM = -1;
  930. fDER = -1;
  931. if (crl->monitors[0].path) {
  932. fPEM = open(crl->monitors[0].path, XEVENT_MODE);
  933. if (fPEM == -1) {
  934. WOLFSSL_MSG("PEM event dir open failed");
  935. SignalSetup(crl, MONITOR_SETUP_E);
  936. (void)close(crl->mfd);
  937. return NULL;
  938. }
  939. }
  940. if (crl->monitors[1].path) {
  941. fDER = open(crl->monitors[1].path, XEVENT_MODE);
  942. if (fDER == -1) {
  943. WOLFSSL_MSG("DER event dir open failed");
  944. if (fPEM != -1)
  945. (void)close(fPEM);
  946. (void)close(crl->mfd);
  947. SignalSetup(crl, MONITOR_SETUP_E);
  948. return NULL;
  949. }
  950. }
  951. if (fPEM != -1)
  952. EV_SET(&change, fPEM, EVFILT_VNODE, EV_ADD | EV_ENABLE | EV_ONESHOT,
  953. NOTE_DELETE | NOTE_EXTEND | NOTE_WRITE | NOTE_ATTRIB, 0, 0);
  954. if (fDER != -1)
  955. EV_SET(&change, fDER, EVFILT_VNODE, EV_ADD | EV_ENABLE | EV_ONESHOT,
  956. NOTE_DELETE | NOTE_EXTEND | NOTE_WRITE | NOTE_ATTRIB, 0, 0);
  957. /* signal to calling thread we're setup */
  958. if (SignalSetup(crl, 1) != 0) {
  959. if (fPEM != -1)
  960. (void)close(fPEM);
  961. if (fDER != -1)
  962. (void)close(fDER);
  963. (void)close(crl->mfd);
  964. return NULL;
  965. }
  966. for (;;) {
  967. struct kevent event;
  968. int numEvents = kevent(crl->mfd, &change, 1, &event, 1, NULL);
  969. WOLFSSL_MSG("Got kevent");
  970. if (numEvents == -1) {
  971. WOLFSSL_MSG("kevent problem, continue");
  972. continue;
  973. }
  974. if (event.filter == EVFILT_USER) {
  975. WOLFSSL_MSG("Got user shutdown event, breaking out");
  976. break;
  977. }
  978. if (SwapLists(crl) < 0) {
  979. WOLFSSL_MSG("SwapLists problem, continue");
  980. }
  981. }
  982. if (fPEM != -1)
  983. (void)close(fPEM);
  984. if (fDER != -1)
  985. (void)close(fDER);
  986. (void)close(crl->mfd);
  987. return NULL;
  988. }
  989. #elif defined(__linux__)
  990. #include <sys/types.h>
  991. #include <sys/inotify.h>
  992. #include <sys/eventfd.h>
  993. #include <unistd.h>
  994. #ifndef max
  995. static WC_INLINE int max(int a, int b)
  996. {
  997. return a > b ? a : b;
  998. }
  999. #endif /* max */
  1000. /* shutdown monitor thread, 0 on success */
  1001. static int StopMonitor(int mfd)
  1002. {
  1003. word64 w64 = 1;
  1004. /* write to our custom event */
  1005. if (write(mfd, &w64, sizeof(w64)) < 0) {
  1006. WOLFSSL_MSG("StopMonitor write failed");
  1007. return -1;
  1008. }
  1009. return 0;
  1010. }
  1011. /* linux monitoring */
  1012. static void* DoMonitor(void* arg)
  1013. {
  1014. int notifyFd;
  1015. int wd = -1;
  1016. WOLFSSL_CRL* crl = (WOLFSSL_CRL*)arg;
  1017. #ifdef WOLFSSL_SMALL_STACK
  1018. char* buff;
  1019. #else
  1020. char buff[8192];
  1021. #endif
  1022. WOLFSSL_ENTER("DoMonitor");
  1023. crl->mfd = eventfd(0, 0); /* our custom shutdown event */
  1024. if (crl->mfd < 0) {
  1025. WOLFSSL_MSG("eventfd failed");
  1026. SignalSetup(crl, MONITOR_SETUP_E);
  1027. return NULL;
  1028. }
  1029. notifyFd = inotify_init();
  1030. if (notifyFd < 0) {
  1031. WOLFSSL_MSG("inotify failed");
  1032. (void)close(crl->mfd);
  1033. SignalSetup(crl, MONITOR_SETUP_E);
  1034. return NULL;
  1035. }
  1036. if (crl->monitors[0].path) {
  1037. wd = inotify_add_watch(notifyFd, crl->monitors[0].path, IN_CLOSE_WRITE |
  1038. IN_DELETE);
  1039. if (wd < 0) {
  1040. WOLFSSL_MSG("PEM notify add watch failed");
  1041. (void)close(crl->mfd);
  1042. (void)close(notifyFd);
  1043. SignalSetup(crl, MONITOR_SETUP_E);
  1044. return NULL;
  1045. }
  1046. }
  1047. if (crl->monitors[1].path) {
  1048. wd = inotify_add_watch(notifyFd, crl->monitors[1].path, IN_CLOSE_WRITE |
  1049. IN_DELETE);
  1050. if (wd < 0) {
  1051. WOLFSSL_MSG("DER notify add watch failed");
  1052. (void)close(crl->mfd);
  1053. (void)close(notifyFd);
  1054. SignalSetup(crl, MONITOR_SETUP_E);
  1055. return NULL;
  1056. }
  1057. }
  1058. #ifdef WOLFSSL_SMALL_STACK
  1059. buff = (char*)XMALLOC(8192, NULL, DYNAMIC_TYPE_TMP_BUFFER);
  1060. if (buff == NULL)
  1061. return NULL;
  1062. #endif
  1063. /* signal to calling thread we're setup */
  1064. if (SignalSetup(crl, 1) != 0) {
  1065. #ifdef WOLFSSL_SMALL_STACK
  1066. XFREE(buff, NULL, DYNAMIC_TYPE_TMP_BUFFER);
  1067. #endif
  1068. if (wd > 0) {
  1069. if (inotify_rm_watch(notifyFd, wd) < 0)
  1070. WOLFSSL_MSG("inotify_rm_watch #1 failed in DoMonitor");
  1071. }
  1072. (void)close(crl->mfd);
  1073. (void)close(notifyFd);
  1074. return NULL;
  1075. }
  1076. for (;;) {
  1077. fd_set readfds;
  1078. int result;
  1079. int length;
  1080. FD_ZERO(&readfds);
  1081. FD_SET(notifyFd, &readfds);
  1082. FD_SET(crl->mfd, &readfds);
  1083. result = select(max(notifyFd, crl->mfd) + 1, &readfds, NULL, NULL,NULL);
  1084. WOLFSSL_MSG("Got notify event");
  1085. if (result < 0) {
  1086. WOLFSSL_MSG("select problem, continue");
  1087. continue;
  1088. }
  1089. if (FD_ISSET(crl->mfd, &readfds)) {
  1090. word64 r64;
  1091. int rlen;
  1092. WOLFSSL_MSG("got custom shutdown event, breaking out");
  1093. /* read out the bytes written to the event to clean up */
  1094. rlen = (int) read(crl->mfd, &r64, sizeof(r64));
  1095. if (rlen < 0) {
  1096. WOLFSSL_MSG("read custom event failure");
  1097. }
  1098. break;
  1099. }
  1100. length = (int) read(notifyFd, buff, 8192);
  1101. if (length < 0) {
  1102. WOLFSSL_MSG("notify read problem, continue");
  1103. continue;
  1104. }
  1105. if (SwapLists(crl) < 0) {
  1106. WOLFSSL_MSG("SwapLists problem, continue");
  1107. }
  1108. }
  1109. #ifdef WOLFSSL_SMALL_STACK
  1110. XFREE(buff, NULL, DYNAMIC_TYPE_TMP_BUFFER);
  1111. #endif
  1112. if (wd > 0) {
  1113. if (inotify_rm_watch(notifyFd, wd) < 0)
  1114. WOLFSSL_MSG("inotify_rm_watch #2 failed in DoMonitor");
  1115. }
  1116. (void)close(crl->mfd);
  1117. (void)close(notifyFd);
  1118. return NULL;
  1119. }
  1120. #endif /* MACH or linux */
  1121. /* Start Monitoring the CRL path(s) in a thread */
  1122. static int StartMonitorCRL(WOLFSSL_CRL* crl)
  1123. {
  1124. int ret = WOLFSSL_SUCCESS;
  1125. WOLFSSL_ENTER("StartMonitorCRL");
  1126. if (crl == NULL)
  1127. return BAD_FUNC_ARG;
  1128. if (crl->tid != 0) {
  1129. WOLFSSL_MSG("Monitor thread already running");
  1130. return ret; /* that's ok, someone already started */
  1131. }
  1132. if (pthread_create(&crl->tid, NULL, DoMonitor, crl) != 0) {
  1133. WOLFSSL_MSG("Thread creation error");
  1134. return THREAD_CREATE_E;
  1135. }
  1136. /* wait for setup to complete */
  1137. if (wc_LockMutex(&crl->crlLock) != 0) {
  1138. WOLFSSL_MSG("wc_LockMutex crlLock error");
  1139. return BAD_MUTEX_E;
  1140. }
  1141. while (crl->setup == 0) {
  1142. if (pthread_cond_wait(&crl->cond, &crl->crlLock) != 0) {
  1143. ret = BAD_COND_E;
  1144. break;
  1145. }
  1146. }
  1147. if (crl->setup < 0)
  1148. ret = crl->setup; /* store setup error */
  1149. wc_UnLockMutex(&crl->crlLock);
  1150. if (ret < 0) {
  1151. WOLFSSL_MSG("DoMonitor setup failure");
  1152. crl->tid = 0; /* thread already done */
  1153. }
  1154. return ret;
  1155. }
  1156. #else /* HAVE_CRL_MONITOR */
  1157. #if !defined(NO_FILESYSTEM) && !defined(NO_WOLFSSL_DIR)
  1158. static int StartMonitorCRL(WOLFSSL_CRL* crl)
  1159. {
  1160. (void)crl;
  1161. WOLFSSL_ENTER("StartMonitorCRL");
  1162. WOLFSSL_MSG("Not compiled in");
  1163. return NOT_COMPILED_IN;
  1164. }
  1165. #endif /* !NO_FILESYSTEM && !NO_WOLFSSL_DIR */
  1166. #endif /* HAVE_CRL_MONITOR */
  1167. #if !defined(NO_FILESYSTEM) && !defined(NO_WOLFSSL_DIR)
  1168. /* Load CRL path files of type, WOLFSSL_SUCCESS on ok */
  1169. int LoadCRL(WOLFSSL_CRL* crl, const char* path, int type, int monitor)
  1170. {
  1171. int ret = WOLFSSL_SUCCESS;
  1172. char* name = NULL;
  1173. #ifdef WOLFSSL_SMALL_STACK
  1174. ReadDirCtx* readCtx = NULL;
  1175. #else
  1176. ReadDirCtx readCtx[1];
  1177. #endif
  1178. WOLFSSL_ENTER("LoadCRL");
  1179. if (crl == NULL)
  1180. return BAD_FUNC_ARG;
  1181. #ifdef WOLFSSL_SMALL_STACK
  1182. readCtx = (ReadDirCtx*)XMALLOC(sizeof(ReadDirCtx), crl->heap,
  1183. DYNAMIC_TYPE_TMP_BUFFER);
  1184. if (readCtx == NULL)
  1185. return MEMORY_E;
  1186. #endif
  1187. /* try to load each regular file in path */
  1188. ret = wc_ReadDirFirst(readCtx, path, &name);
  1189. while (ret == 0 && name) {
  1190. int skip = 0;
  1191. if (type == WOLFSSL_FILETYPE_PEM) {
  1192. if (XSTRSTR(name, ".pem") == NULL) {
  1193. WOLFSSL_MSG("not .pem file, skipping");
  1194. skip = 1;
  1195. }
  1196. }
  1197. else {
  1198. if (XSTRSTR(name, ".der") == NULL &&
  1199. XSTRSTR(name, ".crl") == NULL)
  1200. {
  1201. WOLFSSL_MSG("not .der or .crl file, skipping");
  1202. skip = 1;
  1203. }
  1204. }
  1205. if (!skip && ProcessFile(NULL, name, type, CRL_TYPE, NULL, 0, crl,
  1206. VERIFY) != WOLFSSL_SUCCESS) {
  1207. WOLFSSL_MSG("CRL file load failed, continuing");
  1208. }
  1209. ret = wc_ReadDirNext(readCtx, path, &name);
  1210. }
  1211. wc_ReadDirClose(readCtx);
  1212. ret = WOLFSSL_SUCCESS; /* load failures not reported, for backwards compat */
  1213. #ifdef WOLFSSL_SMALL_STACK
  1214. XFREE(readCtx, crl->heap, DYNAMIC_TYPE_TMP_BUFFER);
  1215. #endif
  1216. if (monitor & WOLFSSL_CRL_MONITOR) {
  1217. word32 pathLen;
  1218. char* pathBuf;
  1219. WOLFSSL_MSG("monitor path requested");
  1220. pathLen = (word32)XSTRLEN(path);
  1221. pathBuf = (char*)XMALLOC(pathLen+1, crl->heap,DYNAMIC_TYPE_CRL_MONITOR);
  1222. if (pathBuf) {
  1223. XMEMCPY(pathBuf, path, pathLen+1);
  1224. if (type == WOLFSSL_FILETYPE_PEM) {
  1225. /* free old path before setting a new one */
  1226. if (crl->monitors[0].path) {
  1227. XFREE(crl->monitors[0].path, crl->heap,
  1228. DYNAMIC_TYPE_CRL_MONITOR);
  1229. }
  1230. crl->monitors[0].path = pathBuf;
  1231. crl->monitors[0].type = WOLFSSL_FILETYPE_PEM;
  1232. } else {
  1233. /* free old path before setting a new one */
  1234. if (crl->monitors[1].path) {
  1235. XFREE(crl->monitors[1].path, crl->heap,
  1236. DYNAMIC_TYPE_CRL_MONITOR);
  1237. }
  1238. crl->monitors[1].path = pathBuf;
  1239. crl->monitors[1].type = WOLFSSL_FILETYPE_ASN1;
  1240. }
  1241. if (monitor & WOLFSSL_CRL_START_MON) {
  1242. WOLFSSL_MSG("start monitoring requested");
  1243. ret = StartMonitorCRL(crl);
  1244. }
  1245. }
  1246. else {
  1247. ret = MEMORY_E;
  1248. }
  1249. }
  1250. return ret;
  1251. }
  1252. #else
  1253. int LoadCRL(WOLFSSL_CRL* crl, const char* path, int type, int monitor)
  1254. {
  1255. (void)crl;
  1256. (void)path;
  1257. (void)type;
  1258. (void)monitor;
  1259. /* stub for scenario where file system is not supported */
  1260. return NOT_COMPILED_IN;
  1261. }
  1262. #endif /* !NO_FILESYSTEM && !NO_WOLFSSL_DIR */
  1263. #endif /* HAVE_CRL */
  1264. #endif /* !WOLFCRYPT_ONLY */