conn-ssl.c 18 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737
  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 \"DHFile\" 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. "DHFile 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. if (!array_bytes(&Conf_SSLOptions.ListenPorts))
  212. return true;
  213. #ifdef HAVE_LIBSSL
  214. SSL_CTX *newctx;
  215. if (!ssl_ctx) {
  216. SSL_library_init();
  217. SSL_load_error_strings();
  218. }
  219. if (!RAND_status()) {
  220. Log(LOG_ERR, "OpenSSL PRNG not seeded: /dev/urandom missing?");
  221. /*
  222. * it is probably best to fail and let the user install EGD or a similar program if no kernel random device is available.
  223. * According to OpenSSL RAND_egd(3): "The automatic query of /var/run/egd-pool et al was added in OpenSSL 0.9.7";
  224. * so it makes little sense to deal with PRNGD seeding ourselves.
  225. */
  226. array_free(&Conf_SSLOptions.ListenPorts);
  227. return false;
  228. }
  229. newctx = SSL_CTX_new(SSLv23_method());
  230. if (!newctx) {
  231. LogOpenSSLError("SSL_CTX_new()", NULL);
  232. array_free(&Conf_SSLOptions.ListenPorts);
  233. return false;
  234. }
  235. if (!ConnSSL_LoadServerKey_openssl(newctx))
  236. goto out;
  237. SSL_CTX_set_options(newctx, SSL_OP_SINGLE_DH_USE|SSL_OP_NO_SSLv2);
  238. SSL_CTX_set_mode(newctx, SSL_MODE_ENABLE_PARTIAL_WRITE);
  239. SSL_CTX_free(ssl_ctx);
  240. ssl_ctx = newctx;
  241. Log(LOG_INFO, "%s initialized.", SSLeay_version(SSLEAY_VERSION));
  242. return true;
  243. out:
  244. SSL_CTX_free(newctx);
  245. array_free(&Conf_SSLOptions.ListenPorts);
  246. return false;
  247. #endif
  248. #ifdef HAVE_LIBGNUTLS
  249. int err;
  250. static bool initialized;
  251. if (initialized) /* TODO: cannot reload gnutls keys: can't simply free x509 context -- it may still be in use */
  252. return false;
  253. err = gnutls_global_init();
  254. if (err) {
  255. Log(LOG_ERR, "gnutls_global_init(): %s", gnutls_strerror(err));
  256. array_free(&Conf_SSLOptions.ListenPorts);
  257. return false;
  258. }
  259. if (!ConnSSL_LoadServerKey_gnutls()) {
  260. array_free(&Conf_SSLOptions.ListenPorts);
  261. return false;
  262. }
  263. Log(LOG_INFO, "gnutls %s initialized.", gnutls_check_version(NULL));
  264. initialized = true;
  265. return true;
  266. #endif
  267. }
  268. #ifdef HAVE_LIBGNUTLS
  269. static bool
  270. ConnSSL_LoadServerKey_gnutls(void)
  271. {
  272. int err;
  273. const char *cert_file;
  274. err = gnutls_certificate_allocate_credentials(&x509_cred);
  275. if (err < 0) {
  276. Log(LOG_ERR, "gnutls_certificate_allocate_credentials: %s", gnutls_strerror(err));
  277. return false;
  278. }
  279. cert_file = Conf_SSLOptions.CertFile ? Conf_SSLOptions.CertFile:Conf_SSLOptions.KeyFile;
  280. if (!cert_file) {
  281. Log(LOG_ERR, "No SSL server key configured!");
  282. return false;
  283. }
  284. if (array_bytes(&Conf_SSLOptions.KeyFilePassword))
  285. Log(LOG_WARNING,
  286. "Ignoring KeyFilePassword: Not supported by GNUTLS.");
  287. if (!Load_DH_params())
  288. return false;
  289. gnutls_certificate_set_dh_params(x509_cred, dh_params);
  290. err = gnutls_certificate_set_x509_key_file(x509_cred, cert_file, Conf_SSLOptions.KeyFile, GNUTLS_X509_FMT_PEM);
  291. if (err < 0) {
  292. Log(LOG_ERR, "gnutls_certificate_set_x509_key_file (cert %s, key %s): %s",
  293. cert_file, Conf_SSLOptions.KeyFile ? Conf_SSLOptions.KeyFile : "(NULL)", gnutls_strerror(err));
  294. return false;
  295. }
  296. return true;
  297. }
  298. #endif
  299. #ifdef HAVE_LIBSSL
  300. static bool
  301. ConnSSL_LoadServerKey_openssl(SSL_CTX *ctx)
  302. {
  303. char *cert_key;
  304. assert(ctx);
  305. if (!Conf_SSLOptions.KeyFile) {
  306. Log(LOG_ERR, "No SSL server key configured!");
  307. return false;
  308. }
  309. SSL_CTX_set_default_passwd_cb(ctx, pem_passwd_cb);
  310. SSL_CTX_set_default_passwd_cb_userdata(ctx, &Conf_SSLOptions.KeyFilePassword);
  311. if (SSL_CTX_use_PrivateKey_file(ctx, Conf_SSLOptions.KeyFile, SSL_FILETYPE_PEM) != 1) {
  312. array_free_wipe(&Conf_SSLOptions.KeyFilePassword);
  313. LogOpenSSLError("SSL_CTX_use_PrivateKey_file", Conf_SSLOptions.KeyFile);
  314. return false;
  315. }
  316. cert_key = Conf_SSLOptions.CertFile ? Conf_SSLOptions.CertFile:Conf_SSLOptions.KeyFile;
  317. if (SSL_CTX_use_certificate_chain_file(ctx, cert_key) != 1) {
  318. array_free_wipe(&Conf_SSLOptions.KeyFilePassword);
  319. LogOpenSSLError("SSL_CTX_use_certificate_file", cert_key);
  320. return false;
  321. }
  322. array_free_wipe(&Conf_SSLOptions.KeyFilePassword);
  323. if (!SSL_CTX_check_private_key(ctx)) {
  324. LogOpenSSLError("Server Private Key does not match certificate", NULL);
  325. return false;
  326. }
  327. if (Load_DH_params()) {
  328. if (SSL_CTX_set_tmp_dh(ctx, dh_params) != 1)
  329. LogOpenSSLError("Error setting DH Parameters", Conf_SSLOptions.DHFile);
  330. /* don't return false here: the non-DH modes will still work */
  331. DH_free(dh_params);
  332. dh_params = NULL;
  333. }
  334. return true;
  335. }
  336. #endif
  337. static bool
  338. ConnSSL_Init_SSL(CONNECTION *c)
  339. {
  340. int ret;
  341. assert(c != NULL);
  342. #ifdef HAVE_LIBSSL
  343. if (!ssl_ctx) {
  344. Log(LOG_ERR, "Cannot init ssl_ctx: OpenSSL initialization failed at startup");
  345. return false;
  346. }
  347. assert(c->ssl_state.ssl == NULL);
  348. c->ssl_state.ssl = SSL_new(ssl_ctx);
  349. if (!c->ssl_state.ssl) {
  350. LogOpenSSLError("SSL_new()", NULL);
  351. return false;
  352. }
  353. ret = SSL_set_fd(c->ssl_state.ssl, c->sock);
  354. if (ret != 1) {
  355. LogOpenSSLError("SSL_set_fd()", NULL);
  356. ConnSSL_Free(c);
  357. return false;
  358. }
  359. #endif
  360. #ifdef HAVE_LIBGNUTLS
  361. ret = gnutls_set_default_priority(c->ssl_state.gnutls_session);
  362. if (ret < 0) {
  363. Log(LOG_ERR, "gnutls_set_default_priority: %s", gnutls_strerror(ret));
  364. ConnSSL_Free(c);
  365. return false;
  366. }
  367. /*
  368. * The intermediate (long) cast is here to avoid a warning like:
  369. * "cast to pointer from integer of different size" on 64-bit platforms.
  370. * There doesn't seem to be an alternate GNUTLS API we could use instead, see e.g.
  371. * http://www.mail-archive.com/help-gnutls@gnu.org/msg00286.html
  372. */
  373. gnutls_transport_set_ptr(c->ssl_state.gnutls_session, (gnutls_transport_ptr_t) (long) c->sock);
  374. ret = gnutls_credentials_set(c->ssl_state.gnutls_session, GNUTLS_CRD_CERTIFICATE, x509_cred);
  375. if (ret < 0) {
  376. Log(LOG_ERR, "gnutls_credentials_set: %s", gnutls_strerror(ret));
  377. ConnSSL_Free(c);
  378. return false;
  379. }
  380. gnutls_dh_set_prime_bits(c->ssl_state.gnutls_session, DH_BITS_MIN);
  381. #endif
  382. Conn_OPTION_ADD(c, CONN_SSL);
  383. return true;
  384. }
  385. bool
  386. ConnSSL_PrepareConnect(CONNECTION *c, UNUSED CONF_SERVER *s)
  387. {
  388. bool ret;
  389. #ifdef HAVE_LIBGNUTLS
  390. int err;
  391. err = gnutls_init(&c->ssl_state.gnutls_session, GNUTLS_CLIENT);
  392. if (err) {
  393. Log(LOG_ERR, "gnutls_init: %s", gnutls_strerror(err));
  394. return false;
  395. }
  396. #endif
  397. ret = ConnSSL_Init_SSL(c);
  398. if (!ret)
  399. return false;
  400. Conn_OPTION_ADD(c, CONN_SSL_CONNECT);
  401. #ifdef HAVE_LIBSSL
  402. assert(c->ssl_state.ssl);
  403. SSL_set_verify(c->ssl_state.ssl, SSL_VERIFY_NONE, NULL);
  404. #endif
  405. return true;
  406. }
  407. /*
  408. Check an Handle Error return code after failed calls to ssl/tls functions.
  409. OpenSSL:
  410. SSL_connect(), SSL_accept(), SSL_do_handshake(), SSL_read(), SSL_peek(), or SSL_write() on ssl.
  411. GNUTLS:
  412. gnutlsssl_read(), gnutls_write() or gnutls_handshake().
  413. Return: -1 on fatal error, 0 if we can try again later.
  414. */
  415. static int
  416. ConnSSL_HandleError( CONNECTION *c, const int code, const char *fname )
  417. {
  418. #ifdef HAVE_LIBSSL
  419. int ret = SSL_ERROR_SYSCALL;
  420. unsigned long sslerr;
  421. int real_errno = errno;
  422. ret = SSL_get_error(c->ssl_state.ssl, code);
  423. switch (ret) {
  424. case SSL_ERROR_WANT_READ:
  425. io_event_del(c->sock, IO_WANTWRITE);
  426. Conn_OPTION_ADD(c, CONN_SSL_WANT_READ);
  427. return 0; /* try again later */
  428. case SSL_ERROR_WANT_WRITE:
  429. io_event_del(c->sock, IO_WANTREAD);
  430. Conn_OPTION_ADD(c, CONN_SSL_WANT_WRITE); /* fall through */
  431. case SSL_ERROR_NONE:
  432. return 0; /* try again later */
  433. case SSL_ERROR_ZERO_RETURN:
  434. LogDebug("TLS/SSL connection shut down normally");
  435. break;
  436. /*
  437. SSL_ERROR_WANT_CONNECT, SSL_ERROR_WANT_ACCEPT, SSL_ERROR_WANT_X509_LOOKUP
  438. */
  439. case SSL_ERROR_SYSCALL:
  440. sslerr = ERR_get_error();
  441. if (sslerr) {
  442. Log( LOG_ERR, "%s: %s", fname, ERR_error_string(sslerr, NULL ));
  443. } else {
  444. switch (code) { /* EOF that violated protocol */
  445. case 0:
  446. Log(LOG_ERR, "%s: Client Disconnected", fname );
  447. break;
  448. case -1: /* low level socket I/O error, check errno */
  449. Log(LOG_ERR, "%s: %s", fname, strerror(real_errno));
  450. }
  451. }
  452. break;
  453. case SSL_ERROR_SSL:
  454. LogOpenSSLError("TLS/SSL Protocol Error", fname);
  455. break;
  456. default:
  457. Log( LOG_ERR, "%s: Unknown error %d!", fname, ret);
  458. }
  459. ConnSSL_Free(c);
  460. return -1;
  461. #endif
  462. #ifdef HAVE_LIBGNUTLS
  463. switch (code) {
  464. case GNUTLS_E_AGAIN:
  465. case GNUTLS_E_INTERRUPTED:
  466. if (gnutls_record_get_direction(c->ssl_state.gnutls_session)) {
  467. Conn_OPTION_ADD(c, CONN_SSL_WANT_WRITE);
  468. io_event_del(c->sock, IO_WANTREAD);
  469. } else {
  470. Conn_OPTION_ADD(c, CONN_SSL_WANT_READ);
  471. io_event_del(c->sock, IO_WANTWRITE);
  472. }
  473. break;
  474. default:
  475. assert(code < 0);
  476. if (gnutls_error_is_fatal(code)) {
  477. Log(LOG_ERR, "%s: %s", fname, gnutls_strerror(code));
  478. ConnSSL_Free(c);
  479. return -1;
  480. }
  481. }
  482. return 0;
  483. #endif
  484. }
  485. static void
  486. ConnSSL_LogCertInfo( CONNECTION *c )
  487. {
  488. #ifdef HAVE_LIBSSL
  489. SSL *ssl = c->ssl_state.ssl;
  490. assert(ssl);
  491. Log(LOG_INFO, "Connection %d: initialized %s using cipher %s.",
  492. c->sock, SSL_get_version(ssl), SSL_get_cipher(ssl));
  493. #endif
  494. #ifdef HAVE_LIBGNUTLS
  495. gnutls_session_t sess = c->ssl_state.gnutls_session;
  496. gnutls_cipher_algorithm_t cipher = gnutls_cipher_get(sess);
  497. Log(LOG_INFO, "Connection %d: initialized %s using cipher %s-%s.",
  498. c->sock,
  499. gnutls_protocol_get_name(gnutls_protocol_get_version(sess)),
  500. gnutls_cipher_get_name(cipher),
  501. gnutls_mac_get_name(gnutls_mac_get(sess)));
  502. #endif
  503. }
  504. /*
  505. Accept incoming SSL connection.
  506. Return Values:
  507. 1: SSL Connection established
  508. 0: try again
  509. -1: SSL Connection not established due to fatal error.
  510. */
  511. int
  512. ConnSSL_Accept( CONNECTION *c )
  513. {
  514. assert(c != NULL);
  515. if (!Conn_OPTION_ISSET(c, CONN_SSL)) {
  516. #ifdef HAVE_LIBGNUTLS
  517. int err = gnutls_init(&c->ssl_state.gnutls_session, GNUTLS_SERVER);
  518. if (err) {
  519. Log(LOG_ERR, "gnutls_init: %s", gnutls_strerror(err));
  520. return false;
  521. }
  522. #endif
  523. LogDebug("ConnSSL_Accept: Initializing SSL data");
  524. if (!ConnSSL_Init_SSL(c))
  525. return -1;
  526. }
  527. return ConnectAccept(c, false );
  528. }
  529. int
  530. ConnSSL_Connect( CONNECTION *c )
  531. {
  532. assert(c != NULL);
  533. #ifdef HAVE_LIBSSL
  534. assert(c->ssl_state.ssl);
  535. #endif
  536. assert(Conn_OPTION_ISSET(c, CONN_SSL));
  537. return ConnectAccept(c, true);
  538. }
  539. /* accept/connect wrapper. if connect is true, connect to peer, otherwise wait for incoming connection */
  540. static int
  541. ConnectAccept( CONNECTION *c, bool connect)
  542. {
  543. int ret;
  544. #ifdef HAVE_LIBSSL
  545. SSL *ssl = c->ssl_state.ssl;
  546. assert(ssl != NULL);
  547. ret = connect ? SSL_connect(ssl) : SSL_accept(ssl);
  548. if (1 != ret)
  549. return ConnSSL_HandleError(c, ret, connect ? "SSL_connect": "SSL_accept");
  550. #endif
  551. #ifdef HAVE_LIBGNUTLS
  552. (void) connect;
  553. ret = gnutls_handshake(c->ssl_state.gnutls_session);
  554. if (ret)
  555. return ConnSSL_HandleError(c, ret, "gnutls_handshake");
  556. #endif /* _GNUTLS */
  557. Conn_OPTION_DEL(c, (CONN_SSL_WANT_WRITE|CONN_SSL_WANT_READ|CONN_SSL_CONNECT));
  558. ConnSSL_LogCertInfo(c);
  559. Conn_StartLogin(CONNECTION2ID(c));
  560. return 1;
  561. }
  562. ssize_t
  563. ConnSSL_Write(CONNECTION *c, const void *buf, size_t count)
  564. {
  565. ssize_t bw;
  566. Conn_OPTION_DEL(c, CONN_SSL_WANT_WRITE|CONN_SSL_WANT_READ);
  567. assert(count > 0);
  568. #ifdef HAVE_LIBSSL
  569. bw = (ssize_t) SSL_write(c->ssl_state.ssl, buf, count);
  570. #endif
  571. #ifdef HAVE_LIBGNUTLS
  572. bw = gnutls_write(c->ssl_state.gnutls_session, buf, count);
  573. #endif
  574. if (bw > 0)
  575. return bw;
  576. if (ConnSSL_HandleError( c, bw, "ConnSSL_Write") == 0)
  577. errno = EAGAIN; /* try again */
  578. return -1;
  579. }
  580. ssize_t
  581. ConnSSL_Read(CONNECTION *c, void * buf, size_t count)
  582. {
  583. ssize_t br;
  584. Conn_OPTION_DEL(c, CONN_SSL_WANT_WRITE|CONN_SSL_WANT_READ);
  585. #ifdef HAVE_LIBSSL
  586. br = (ssize_t) SSL_read(c->ssl_state.ssl, buf, count);
  587. if (br > 0) /* on EOF we have to call ConnSSL_HandleError(), see SSL_read(3) */
  588. return br;
  589. #endif
  590. #ifdef HAVE_LIBGNUTLS
  591. br = gnutls_read(c->ssl_state.gnutls_session, buf, count);
  592. if (br >= 0) /* on EOF we must _not_ call ConnSSL_HandleError, see gnutls_record_recv(3) */
  593. return br;
  594. #endif
  595. /* error on read: switch ConnSSL_HandleError() return values -> 0 is "try again", so return -1 and set EAGAIN */
  596. if (ConnSSL_HandleError(c, br, "ConnSSL_Read") == 0) {
  597. errno = EAGAIN;
  598. return -1;
  599. }
  600. return 0;
  601. }
  602. bool
  603. ConnSSL_GetCipherInfo(CONNECTION *c, char *buf, size_t len)
  604. {
  605. #ifdef HAVE_LIBSSL
  606. char *nl;
  607. SSL *ssl = c->ssl_state.ssl;
  608. if (!ssl)
  609. return false;
  610. *buf = 0;
  611. SSL_CIPHER_description(SSL_get_current_cipher(ssl), buf, len);
  612. nl = strchr(buf, '\n');
  613. if (nl)
  614. *nl = 0;
  615. return true;
  616. #endif
  617. #ifdef HAVE_LIBGNUTLS
  618. if (Conn_OPTION_ISSET(c, CONN_SSL)) {
  619. const char *name_cipher, *name_mac, *name_proto, *name_keyexchange;
  620. unsigned keysize;
  621. gnutls_session_t sess = c->ssl_state.gnutls_session;
  622. gnutls_cipher_algorithm_t cipher = gnutls_cipher_get(sess);
  623. name_cipher = gnutls_cipher_get_name(cipher);
  624. name_mac = gnutls_mac_get_name(gnutls_mac_get(sess));
  625. keysize = gnutls_cipher_get_key_size(cipher) * 8;
  626. name_proto = gnutls_protocol_get_name(gnutls_protocol_get_version(sess));
  627. name_keyexchange = gnutls_kx_get_name(gnutls_kx_get(sess));
  628. return snprintf(buf, len, "%s-%s%15s Kx=%s Enc=%s(%u) Mac=%s",
  629. name_cipher, name_mac, name_proto, name_keyexchange, name_cipher, keysize, name_mac) > 0;
  630. }
  631. return false;
  632. #endif
  633. }
  634. #else
  635. bool
  636. ConnSSL_InitLibrary(void)
  637. {
  638. return true;
  639. }
  640. #endif /* SSL_SUPPORT */
  641. /* -eof- */