conn-ssl.c 18 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719
  1. /*
  2. * ngIRCd -- The Next Generation IRC Daemon
  3. * Copyright (c) 2005-2008 Florian Westphal <fw@strlen.de>
  4. */
  5. #include "portab.h"
  6. /**
  7. * @file
  8. * SSL wrapper functions
  9. */
  10. #include "imp.h"
  11. #include "conf-ssl.h"
  12. #ifdef SSL_SUPPORT
  13. #include "io.h"
  14. #include <assert.h>
  15. #include <stdio.h>
  16. #include <string.h>
  17. #include <stdlib.h>
  18. #include <errno.h>
  19. #define CONN_MODULE
  20. #include "conn.h"
  21. #include "conf.h"
  22. #include "conn-func.h"
  23. #include "conn-ssl.h"
  24. #include "log.h"
  25. #include "exp.h"
  26. #include "defines.h"
  27. extern struct SSLOptions Conf_SSLOptions;
  28. #ifdef HAVE_LIBSSL
  29. #include <openssl/err.h>
  30. #include <openssl/rand.h>
  31. static SSL_CTX * ssl_ctx;
  32. static DH *dh_params;
  33. static bool ConnSSL_LoadServerKey_openssl PARAMS(( SSL_CTX *c ));
  34. #endif
  35. #ifdef HAVE_LIBGNUTLS
  36. #include <sys/types.h>
  37. #include <sys/stat.h>
  38. #include <fcntl.h>
  39. #include <unistd.h>
  40. #include <gnutls/x509.h>
  41. #define DH_BITS 2048
  42. #define DH_BITS_MIN 1024
  43. static gnutls_certificate_credentials_t x509_cred;
  44. static gnutls_dh_params_t dh_params;
  45. static bool ConnSSL_LoadServerKey_gnutls PARAMS(( void ));
  46. #endif
  47. static bool ConnSSL_Init_SSL PARAMS(( CONNECTION *c ));
  48. static int ConnectAccept PARAMS(( CONNECTION *c, bool connect ));
  49. static int ConnSSL_HandleError PARAMS(( CONNECTION *c, const int code, const char *fname ));
  50. #ifdef HAVE_LIBGNUTLS
  51. static char * openreadclose(const char *name, size_t *len)
  52. {
  53. char *buf = NULL;
  54. struct stat s;
  55. ssize_t br;
  56. int fd = open(name, O_RDONLY);
  57. if (fd < 0) {
  58. Log(LOG_ERR, "Could not open %s: %s", name, strerror(errno));
  59. return NULL;
  60. }
  61. if (fstat(fd, &s)) {
  62. Log(LOG_ERR, "Could not fstat %s: %s", name, strerror(errno));
  63. goto out;
  64. }
  65. if (!S_ISREG(s.st_mode)) {
  66. Log(LOG_ERR, "%s: Not a regular file", name);
  67. goto out;
  68. }
  69. if (s.st_size <= 0) {
  70. Log(LOG_ERR, "%s: invalid file length (size %ld <= 0)", name, (long) s.st_size);
  71. goto out;
  72. }
  73. buf = malloc(s.st_size);
  74. if (!buf) {
  75. Log(LOG_ERR, "Could not malloc %lu bytes for file %s: %s", s.st_size, name, strerror(errno));
  76. goto out;
  77. }
  78. br = read(fd, buf, s.st_size);
  79. if (br != (ssize_t)s.st_size) {
  80. Log(LOG_ERR, "Could not read file %s: read returned %ld, expected %ld: %s",
  81. name, (long) br, (long) s.st_size, br == -1 ? strerror(errno):"short read?!");
  82. memset(buf, 0, s.st_size);
  83. free(buf);
  84. buf = NULL;
  85. } else {
  86. *len = br;
  87. }
  88. out:
  89. close(fd);
  90. return buf;
  91. }
  92. #endif
  93. #ifdef HAVE_LIBSSL
  94. static void
  95. LogOpenSSLError( const char *msg, const char *msg2 )
  96. {
  97. unsigned long err = ERR_get_error();
  98. char * errmsg = err ? ERR_error_string(err, NULL) : "Unable to determine error";
  99. if (!msg) msg = "SSL Error";
  100. if (msg2)
  101. Log( LOG_ERR, "%s: %s: %s", msg, msg2, errmsg);
  102. else
  103. Log( LOG_ERR, "%s: %s", msg, errmsg);
  104. }
  105. static int
  106. pem_passwd_cb(char *buf, int size, int rwflag, void *password)
  107. {
  108. array *pass = password;
  109. int passlen;
  110. (void)rwflag; /* rwflag is unused if DEBUG is not set. */
  111. assert(rwflag == 0); /* 0 -> callback used for decryption.
  112. * See SSL_CTX_set_default_passwd_cb(3) */
  113. passlen = (int) array_bytes(pass);
  114. LogDebug("pem_passwd_cb buf size %d, array size %d", size, passlen);
  115. assert(passlen >= 0);
  116. if (passlen <= 0) {
  117. Log(LOG_ERR, "pem_passwd_cb: password required, but not set");
  118. return 0;
  119. }
  120. size = passlen > size ? size : passlen;
  121. memcpy(buf, (char *)(array_start(pass)), size);
  122. return size;
  123. }
  124. #endif
  125. static bool
  126. Load_DH_params(void)
  127. {
  128. #ifdef HAVE_LIBSSL
  129. FILE *fp;
  130. bool ret = true;
  131. if (!Conf_SSLOptions.DHFile) {
  132. Log(LOG_NOTICE, "Configuration option \"SSLDHFile\" not set!");
  133. return false;
  134. }
  135. fp = fopen(Conf_SSLOptions.DHFile, "r");
  136. if (!fp) {
  137. Log(LOG_ERR, "%s: %s", Conf_SSLOptions.DHFile, strerror(errno));
  138. return false;
  139. }
  140. dh_params = PEM_read_DHparams(fp, NULL, NULL, NULL);
  141. if (!dh_params) {
  142. Log(LOG_ERR, "%s: PEM_read_DHparams failed!",
  143. Conf_SSLOptions.DHFile);
  144. ret = false;
  145. }
  146. fclose(fp);
  147. return ret;
  148. #endif
  149. #ifdef HAVE_LIBGNUTLS
  150. bool need_dhgenerate = true;
  151. int err;
  152. gnutls_dh_params_t tmp_dh_params;
  153. err = gnutls_dh_params_init(&tmp_dh_params);
  154. if (err < 0) {
  155. Log(LOG_ERR, "gnutls_dh_params_init: %s", gnutls_strerror(err));
  156. return false;
  157. }
  158. if (Conf_SSLOptions.DHFile) {
  159. gnutls_datum_t dhparms;
  160. size_t size;
  161. dhparms.data = (unsigned char *) openreadclose(Conf_SSLOptions.DHFile, &size);
  162. if (dhparms.data) {
  163. dhparms.size = size;
  164. err = gnutls_dh_params_import_pkcs3(tmp_dh_params, &dhparms, GNUTLS_X509_FMT_PEM);
  165. if (err == 0)
  166. need_dhgenerate = false;
  167. else
  168. Log(LOG_ERR, "gnutls_dh_params_init: %s", gnutls_strerror(err));
  169. memset(dhparms.data, 0, size);
  170. free(dhparms.data);
  171. }
  172. }
  173. if (need_dhgenerate) {
  174. Log(LOG_WARNING,
  175. "SSLDHFile not set, generating %u bit DH parameters. This may take a while ...",
  176. DH_BITS);
  177. err = gnutls_dh_params_generate2(tmp_dh_params, DH_BITS);
  178. if (err < 0) {
  179. Log(LOG_ERR, "gnutls_dh_params_generate2: %s", gnutls_strerror(err));
  180. return false;
  181. }
  182. }
  183. dh_params = tmp_dh_params;
  184. return true;
  185. #endif
  186. }
  187. void ConnSSL_Free(CONNECTION *c)
  188. {
  189. #ifdef HAVE_LIBSSL
  190. SSL *ssl = c->ssl_state.ssl;
  191. if (ssl) {
  192. SSL_shutdown(ssl);
  193. SSL_free(ssl);
  194. c->ssl_state.ssl = NULL;
  195. }
  196. #endif
  197. #ifdef HAVE_LIBGNUTLS
  198. gnutls_session_t sess = c->ssl_state.gnutls_session;
  199. if (Conn_OPTION_ISSET(c, CONN_SSL)) {
  200. gnutls_bye(sess, GNUTLS_SHUT_RDWR);
  201. gnutls_deinit(sess);
  202. }
  203. #endif
  204. assert(Conn_OPTION_ISSET(c, CONN_SSL));
  205. /* can't just set bitmask to 0 -- there are other, non-ssl related flags, e.g. CONN_ZIP. */
  206. Conn_OPTION_DEL(c, CONN_SSL_FLAGS_ALL);
  207. }
  208. bool
  209. ConnSSL_InitLibrary( void )
  210. {
  211. #ifdef HAVE_LIBSSL
  212. SSL_CTX *newctx;
  213. if (!ssl_ctx) {
  214. SSL_library_init();
  215. SSL_load_error_strings();
  216. }
  217. if (!RAND_status()) {
  218. Log(LOG_ERR, "OpenSSL PRNG not seeded: /dev/urandom missing?");
  219. /*
  220. * it is probably best to fail and let the user install EGD or a similar program if no kernel random device is available.
  221. * According to OpenSSL RAND_egd(3): "The automatic query of /var/run/egd-pool et al was added in OpenSSL 0.9.7";
  222. * so it makes little sense to deal with PRNGD seeding ourselves.
  223. */
  224. return false;
  225. }
  226. newctx = SSL_CTX_new(SSLv23_method());
  227. if (!newctx) {
  228. LogOpenSSLError("SSL_CTX_new()", NULL);
  229. return false;
  230. }
  231. if (!ConnSSL_LoadServerKey_openssl(newctx))
  232. goto out;
  233. SSL_CTX_set_options(newctx, SSL_OP_SINGLE_DH_USE|SSL_OP_NO_SSLv2);
  234. SSL_CTX_set_mode(newctx, SSL_MODE_ENABLE_PARTIAL_WRITE);
  235. SSL_CTX_free(ssl_ctx);
  236. ssl_ctx = newctx;
  237. Log(LOG_INFO, "%s initialized.", SSLeay_version(SSLEAY_VERSION));
  238. return true;
  239. out:
  240. SSL_CTX_free(newctx);
  241. return false;
  242. #endif
  243. #ifdef HAVE_LIBGNUTLS
  244. int err;
  245. static bool initialized;
  246. if (initialized) /* TODO: cannot reload gnutls keys: can't simply free x509 context -- it may still be in use */
  247. return false;
  248. err = gnutls_global_init();
  249. if (err) {
  250. Log(LOG_ERR, "gnutls_global_init(): %s", gnutls_strerror(err));
  251. return false;
  252. }
  253. if (!ConnSSL_LoadServerKey_gnutls())
  254. return false;
  255. Log(LOG_INFO, "gnutls %s initialized.", gnutls_check_version(NULL));
  256. initialized = true;
  257. return true;
  258. #endif
  259. }
  260. #ifdef HAVE_LIBGNUTLS
  261. static bool
  262. ConnSSL_LoadServerKey_gnutls(void)
  263. {
  264. int err;
  265. const char *cert_file;
  266. err = gnutls_certificate_allocate_credentials(&x509_cred);
  267. if (err < 0) {
  268. Log(LOG_ERR, "gnutls_certificate_allocate_credentials: %s", gnutls_strerror(err));
  269. return false;
  270. }
  271. cert_file = Conf_SSLOptions.CertFile ? Conf_SSLOptions.CertFile:Conf_SSLOptions.KeyFile;
  272. if (!cert_file) {
  273. Log(LOG_NOTICE, "No SSL server key configured, SSL disabled.");
  274. return false;
  275. }
  276. if (array_bytes(&Conf_SSLOptions.KeyFilePassword))
  277. Log(LOG_WARNING,
  278. "Ignoring KeyFilePassword: Not supported by GNUTLS.");
  279. if (!Load_DH_params())
  280. return false;
  281. gnutls_certificate_set_dh_params(x509_cred, dh_params);
  282. err = gnutls_certificate_set_x509_key_file(x509_cred, cert_file, Conf_SSLOptions.KeyFile, GNUTLS_X509_FMT_PEM);
  283. if (err < 0) {
  284. Log(LOG_ERR, "gnutls_certificate_set_x509_key_file (cert %s, key %s): %s",
  285. cert_file, Conf_SSLOptions.KeyFile ? Conf_SSLOptions.KeyFile : "(NULL)", gnutls_strerror(err));
  286. return false;
  287. }
  288. return true;
  289. }
  290. #endif
  291. #ifdef HAVE_LIBSSL
  292. static bool
  293. ConnSSL_LoadServerKey_openssl(SSL_CTX *ctx)
  294. {
  295. char *cert_key;
  296. assert(ctx);
  297. if (!Conf_SSLOptions.KeyFile) {
  298. Log(LOG_NOTICE, "No SSL server key configured, SSL disabled.");
  299. return false;
  300. }
  301. SSL_CTX_set_default_passwd_cb(ctx, pem_passwd_cb);
  302. SSL_CTX_set_default_passwd_cb_userdata(ctx, &Conf_SSLOptions.KeyFilePassword);
  303. if (SSL_CTX_use_PrivateKey_file(ctx, Conf_SSLOptions.KeyFile, SSL_FILETYPE_PEM) != 1) {
  304. array_free_wipe(&Conf_SSLOptions.KeyFilePassword);
  305. LogOpenSSLError("SSL_CTX_use_PrivateKey_file", Conf_SSLOptions.KeyFile);
  306. return false;
  307. }
  308. cert_key = Conf_SSLOptions.CertFile ? Conf_SSLOptions.CertFile:Conf_SSLOptions.KeyFile;
  309. if (SSL_CTX_use_certificate_chain_file(ctx, cert_key) != 1) {
  310. array_free_wipe(&Conf_SSLOptions.KeyFilePassword);
  311. LogOpenSSLError("SSL_CTX_use_certificate_file", cert_key);
  312. return false;
  313. }
  314. array_free_wipe(&Conf_SSLOptions.KeyFilePassword);
  315. if (!SSL_CTX_check_private_key(ctx)) {
  316. LogOpenSSLError("Server Private Key does not match certificate", NULL);
  317. return false;
  318. }
  319. if (Load_DH_params()) {
  320. if (SSL_CTX_set_tmp_dh(ctx, dh_params) != 1)
  321. LogOpenSSLError("Error setting DH Parameters", Conf_SSLOptions.DHFile);
  322. /* don't return false here: the non-DH modes will still work */
  323. DH_free(dh_params);
  324. dh_params = NULL;
  325. }
  326. return true;
  327. }
  328. #endif
  329. static bool
  330. ConnSSL_Init_SSL(CONNECTION *c)
  331. {
  332. int ret;
  333. assert(c != NULL);
  334. #ifdef HAVE_LIBSSL
  335. if (!ssl_ctx) {
  336. Log(LOG_ERR, "Cannot init ssl_ctx: OpenSSL initialization failed at startup");
  337. return false;
  338. }
  339. assert(c->ssl_state.ssl == NULL);
  340. c->ssl_state.ssl = SSL_new(ssl_ctx);
  341. if (!c->ssl_state.ssl) {
  342. LogOpenSSLError("SSL_new()", NULL);
  343. return false;
  344. }
  345. ret = SSL_set_fd(c->ssl_state.ssl, c->sock);
  346. if (ret != 1) {
  347. LogOpenSSLError("SSL_set_fd()", NULL);
  348. ConnSSL_Free(c);
  349. return false;
  350. }
  351. #endif
  352. #ifdef HAVE_LIBGNUTLS
  353. ret = gnutls_set_default_priority(c->ssl_state.gnutls_session);
  354. if (ret < 0) {
  355. Log(LOG_ERR, "gnutls_set_default_priority: %s", gnutls_strerror(ret));
  356. ConnSSL_Free(c);
  357. return false;
  358. }
  359. /*
  360. * The intermediate (long) cast is here to avoid a warning like:
  361. * "cast to pointer from integer of different size" on 64-bit platforms.
  362. * There doesn't seem to be an alternate GNUTLS API we could use instead, see e.g.
  363. * http://www.mail-archive.com/help-gnutls@gnu.org/msg00286.html
  364. */
  365. gnutls_transport_set_ptr(c->ssl_state.gnutls_session, (gnutls_transport_ptr_t) (long) c->sock);
  366. ret = gnutls_credentials_set(c->ssl_state.gnutls_session, GNUTLS_CRD_CERTIFICATE, x509_cred);
  367. if (ret < 0) {
  368. Log(LOG_ERR, "gnutls_credentials_set: %s", gnutls_strerror(ret));
  369. ConnSSL_Free(c);
  370. return false;
  371. }
  372. gnutls_dh_set_prime_bits(c->ssl_state.gnutls_session, DH_BITS_MIN);
  373. #endif
  374. Conn_OPTION_ADD(c, CONN_SSL);
  375. return true;
  376. }
  377. bool
  378. ConnSSL_PrepareConnect(CONNECTION *c, UNUSED CONF_SERVER *s)
  379. {
  380. bool ret;
  381. #ifdef HAVE_LIBGNUTLS
  382. int err;
  383. err = gnutls_init(&c->ssl_state.gnutls_session, GNUTLS_CLIENT);
  384. if (err) {
  385. Log(LOG_ERR, "gnutls_init: %s", gnutls_strerror(err));
  386. return false;
  387. }
  388. #endif
  389. ret = ConnSSL_Init_SSL(c);
  390. if (!ret)
  391. return false;
  392. Conn_OPTION_ADD(c, CONN_SSL_CONNECT);
  393. #ifdef HAVE_LIBSSL
  394. assert(c->ssl_state.ssl);
  395. SSL_set_verify(c->ssl_state.ssl, SSL_VERIFY_NONE, NULL);
  396. #endif
  397. return true;
  398. }
  399. /*
  400. Check an Handle Error return code after failed calls to ssl/tls functions.
  401. OpenSSL:
  402. SSL_connect(), SSL_accept(), SSL_do_handshake(), SSL_read(), SSL_peek(), or SSL_write() on ssl.
  403. GNUTLS:
  404. gnutlsssl_read(), gnutls_write() or gnutls_handshake().
  405. Return: -1 on fatal error, 0 if we can try again later.
  406. */
  407. static int
  408. ConnSSL_HandleError( CONNECTION *c, const int code, const char *fname )
  409. {
  410. #ifdef HAVE_LIBSSL
  411. int ret = SSL_ERROR_SYSCALL;
  412. unsigned long sslerr;
  413. int real_errno = errno;
  414. ret = SSL_get_error(c->ssl_state.ssl, code);
  415. switch (ret) {
  416. case SSL_ERROR_WANT_READ:
  417. io_event_del(c->sock, IO_WANTWRITE);
  418. Conn_OPTION_ADD(c, CONN_SSL_WANT_READ);
  419. return 0; /* try again later */
  420. case SSL_ERROR_WANT_WRITE:
  421. io_event_del(c->sock, IO_WANTREAD);
  422. Conn_OPTION_ADD(c, CONN_SSL_WANT_WRITE); /* fall through */
  423. case SSL_ERROR_NONE:
  424. return 0; /* try again later */
  425. case SSL_ERROR_ZERO_RETURN:
  426. LogDebug("TLS/SSL connection shut down normally");
  427. break;
  428. /*
  429. SSL_ERROR_WANT_CONNECT, SSL_ERROR_WANT_ACCEPT, SSL_ERROR_WANT_X509_LOOKUP
  430. */
  431. case SSL_ERROR_SYSCALL:
  432. sslerr = ERR_get_error();
  433. if (sslerr) {
  434. Log( LOG_ERR, "%s: %s", fname, ERR_error_string(sslerr, NULL ));
  435. } else {
  436. switch (code) { /* EOF that violated protocol */
  437. case 0:
  438. Log(LOG_ERR, "%s: Client Disconnected", fname );
  439. break;
  440. case -1: /* low level socket I/O error, check errno */
  441. Log(LOG_ERR, "%s: %s", fname, strerror(real_errno));
  442. }
  443. }
  444. break;
  445. case SSL_ERROR_SSL:
  446. LogOpenSSLError("TLS/SSL Protocol Error", fname);
  447. break;
  448. default:
  449. Log( LOG_ERR, "%s: Unknown error %d!", fname, ret);
  450. }
  451. ConnSSL_Free(c);
  452. return -1;
  453. #endif
  454. #ifdef HAVE_LIBGNUTLS
  455. switch (code) {
  456. case GNUTLS_E_AGAIN:
  457. case GNUTLS_E_INTERRUPTED:
  458. if (gnutls_record_get_direction(c->ssl_state.gnutls_session)) {
  459. Conn_OPTION_ADD(c, CONN_SSL_WANT_WRITE);
  460. io_event_del(c->sock, IO_WANTREAD);
  461. } else {
  462. Conn_OPTION_ADD(c, CONN_SSL_WANT_READ);
  463. io_event_del(c->sock, IO_WANTWRITE);
  464. }
  465. break;
  466. default:
  467. assert(code < 0);
  468. if (gnutls_error_is_fatal(code)) {
  469. Log(LOG_ERR, "%s: %s", fname, gnutls_strerror(code));
  470. ConnSSL_Free(c);
  471. return -1;
  472. }
  473. }
  474. return 0;
  475. #endif
  476. }
  477. static void
  478. ConnSSL_LogCertInfo( CONNECTION *c )
  479. {
  480. #ifdef HAVE_LIBSSL
  481. SSL *ssl = c->ssl_state.ssl;
  482. assert(ssl);
  483. Log(LOG_INFO, "Connection %d: initialized %s using cipher %s.",
  484. c->sock, SSL_get_version(ssl), SSL_get_cipher(ssl));
  485. #endif
  486. #ifdef HAVE_LIBGNUTLS
  487. gnutls_session_t sess = c->ssl_state.gnutls_session;
  488. gnutls_cipher_algorithm_t cipher = gnutls_cipher_get(sess);
  489. Log(LOG_INFO, "Connection %d: initialized %s using cipher %s-%s.",
  490. c->sock,
  491. gnutls_protocol_get_name(gnutls_protocol_get_version(sess)),
  492. gnutls_cipher_get_name(cipher),
  493. gnutls_mac_get_name(gnutls_mac_get(sess)));
  494. #endif
  495. }
  496. /*
  497. Accept incoming SSL connection.
  498. Return Values:
  499. 1: SSL Connection established
  500. 0: try again
  501. -1: SSL Connection not established due to fatal error.
  502. */
  503. int
  504. ConnSSL_Accept( CONNECTION *c )
  505. {
  506. assert(c != NULL);
  507. if (!Conn_OPTION_ISSET(c, CONN_SSL)) {
  508. #ifdef HAVE_LIBGNUTLS
  509. int err = gnutls_init(&c->ssl_state.gnutls_session, GNUTLS_SERVER);
  510. if (err) {
  511. Log(LOG_ERR, "gnutls_init: %s", gnutls_strerror(err));
  512. return false;
  513. }
  514. #endif
  515. LogDebug("ConnSSL_Accept: Initializing SSL data");
  516. if (!ConnSSL_Init_SSL(c))
  517. return -1;
  518. }
  519. return ConnectAccept(c, false );
  520. }
  521. int
  522. ConnSSL_Connect( CONNECTION *c )
  523. {
  524. assert(c != NULL);
  525. #ifdef HAVE_LIBSSL
  526. assert(c->ssl_state.ssl);
  527. #endif
  528. assert(Conn_OPTION_ISSET(c, CONN_SSL));
  529. return ConnectAccept(c, true);
  530. }
  531. /* accept/connect wrapper. if connect is true, connect to peer, otherwise wait for incoming connection */
  532. static int
  533. ConnectAccept( CONNECTION *c, bool connect)
  534. {
  535. int ret;
  536. #ifdef HAVE_LIBSSL
  537. SSL *ssl = c->ssl_state.ssl;
  538. assert(ssl != NULL);
  539. ret = connect ? SSL_connect(ssl) : SSL_accept(ssl);
  540. if (1 != ret)
  541. return ConnSSL_HandleError(c, ret, connect ? "SSL_connect": "SSL_accept");
  542. #endif
  543. #ifdef HAVE_LIBGNUTLS
  544. (void) connect;
  545. ret = gnutls_handshake(c->ssl_state.gnutls_session);
  546. if (ret)
  547. return ConnSSL_HandleError(c, ret, "gnutls_handshake");
  548. #endif /* _GNUTLS */
  549. Conn_OPTION_DEL(c, (CONN_SSL_WANT_WRITE|CONN_SSL_WANT_READ|CONN_SSL_CONNECT));
  550. ConnSSL_LogCertInfo(c);
  551. return 1;
  552. }
  553. ssize_t
  554. ConnSSL_Write(CONNECTION *c, const void *buf, size_t count)
  555. {
  556. ssize_t bw;
  557. Conn_OPTION_DEL(c, CONN_SSL_WANT_WRITE|CONN_SSL_WANT_READ);
  558. assert(count > 0);
  559. #ifdef HAVE_LIBSSL
  560. bw = (ssize_t) SSL_write(c->ssl_state.ssl, buf, count);
  561. #endif
  562. #ifdef HAVE_LIBGNUTLS
  563. bw = gnutls_write(c->ssl_state.gnutls_session, buf, count);
  564. #endif
  565. if (bw > 0)
  566. return bw;
  567. if (ConnSSL_HandleError( c, bw, "ConnSSL_Write") == 0)
  568. errno = EAGAIN; /* try again */
  569. return -1;
  570. }
  571. ssize_t
  572. ConnSSL_Read(CONNECTION *c, void * buf, size_t count)
  573. {
  574. ssize_t br;
  575. Conn_OPTION_DEL(c, CONN_SSL_WANT_WRITE|CONN_SSL_WANT_READ);
  576. #ifdef HAVE_LIBSSL
  577. br = (ssize_t) SSL_read(c->ssl_state.ssl, buf, count);
  578. if (br > 0) /* on EOF we have to call ConnSSL_HandleError(), see SSL_read(3) */
  579. return br;
  580. #endif
  581. #ifdef HAVE_LIBGNUTLS
  582. br = gnutls_read(c->ssl_state.gnutls_session, buf, count);
  583. if (br >= 0) /* on EOF we must _not_ call ConnSSL_HandleError, see gnutls_record_recv(3) */
  584. return br;
  585. #endif
  586. /* error on read: switch ConnSSL_HandleError() return values -> 0 is "try again", so return -1 and set EAGAIN */
  587. if (ConnSSL_HandleError(c, br, "ConnSSL_Read") == 0) {
  588. errno = EAGAIN;
  589. return -1;
  590. }
  591. return 0;
  592. }
  593. bool
  594. ConnSSL_GetCipherInfo(CONNECTION *c, char *buf, size_t len)
  595. {
  596. #ifdef HAVE_LIBSSL
  597. char *nl;
  598. SSL *ssl = c->ssl_state.ssl;
  599. if (!ssl)
  600. return false;
  601. *buf = 0;
  602. SSL_CIPHER_description(SSL_get_current_cipher(ssl), buf, len);
  603. nl = strchr(buf, '\n');
  604. if (nl)
  605. *nl = 0;
  606. return true;
  607. #endif
  608. #ifdef HAVE_LIBGNUTLS
  609. if (Conn_OPTION_ISSET(c, CONN_SSL)) {
  610. const char *name_cipher, *name_mac, *name_proto, *name_keyexchange;
  611. unsigned keysize;
  612. gnutls_session_t sess = c->ssl_state.gnutls_session;
  613. gnutls_cipher_algorithm_t cipher = gnutls_cipher_get(sess);
  614. name_cipher = gnutls_cipher_get_name(cipher);
  615. name_mac = gnutls_mac_get_name(gnutls_mac_get(sess));
  616. keysize = gnutls_cipher_get_key_size(cipher) * 8;
  617. name_proto = gnutls_protocol_get_name(gnutls_protocol_get_version(sess));
  618. name_keyexchange = gnutls_kx_get_name(gnutls_kx_get(sess));
  619. return snprintf(buf, len, "%s-%s%15s Kx=%s Enc=%s(%u) Mac=%s",
  620. name_cipher, name_mac, name_proto, name_keyexchange, name_cipher, keysize, name_mac) > 0;
  621. }
  622. return false;
  623. #endif
  624. }
  625. #endif /* SSL_SUPPORT */
  626. /* -eof- */