tls_server.c

Branch :
Show log
Commit
Author : Thomas de Grivel
Date : 2026-07-27 14:28:34
Hash : 2c090a7f
Message : wip memleaks
libkc3/tls_server.c
/* kc3
 * Copyright from 2022 to 2026 kmx.io <contact@kmx.io>
 *
 * Permission is hereby granted to use this software granted the above
 * copyright notice and this permission paragraph are included in all
 * copies and substantial portions of this software.
 *
 * THIS SOFTWARE IS PROVIDED "AS-IS" WITHOUT ANY GUARANTEE OF
 * PURPOSE AND PERFORMANCE. IN NO EVENT WHATSOEVER SHALL THE
 * AUTHOR BE CONSIDERED LIABLE FOR THE USE AND PERFORMANCE OF
 * THIS SOFTWARE.
 */
#include <unistd.h>
#include <tls.h>
#include "kc3.h"
#include "socket.h"
#include "socket_buf.h"
#include "tls_buf.h"
#include "tls_server.h"

void kc3_tls_server_clean (s_tls_server *tls_server)
{
  p_tls ctx;
  s_tls_buf *tls_buf;
  buf_flush(tls_server->socket_buf->buf_rw.w);
  tls_buf = tls_server->socket_buf->buf_rw.w->user_ptr;
  ctx = tls_buf->ctx;
  tls_close(ctx);
  tls_buf_close(tls_server->socket_buf->buf_rw.r);
  tls_buf_close(tls_server->socket_buf->buf_rw.w);
  tls_free(ctx);
  buf_rw_clean(&tls_server->socket_buf->buf_rw);
  tls_server->socket_buf->buf_rw.r = NULL;
  tls_server->socket_buf->buf_rw.w = NULL;
  close(tls_server->socket_buf->sockfd);
  tls_server->socket_buf->sockfd = -1;
  socket_buf_clean(tls_server->socket_buf);
  alloc_free(tls_server->socket_buf);
}

s_tls_server * kc3_tls_server_init_accept (s_tls_server *tls_server,
                                           p_socket socket,
                                           p_tls *ctx)
{
  sw r;
  p_tls tmp_ctx = NULL;
  assert(tls_server);
  assert(ctx);
  assert(*ctx);
  *tls_server = (s_tls_server) {0};
  tls_server->socket_buf = alloc(sizeof(s_socket_buf));
  if (! tls_server->socket_buf)
    return NULL;
  if (! socket_buf_init_accept(tls_server->socket_buf, socket)) {
    alloc_free(tls_server->socket_buf);
    return NULL;
  }
  if (false)
    err_puts("kc3_tls_server_init_accept: accept: OK");
  if (tls_accept_socket(*ctx, &tmp_ctx, tls_server->socket_buf->sockfd)) {
    err_write_1("kc3_tls_server_init_accept: tls_accept_socket: ");
    err_puts(tls_error(*ctx));
    assert(! "kc3_tls_server_init_accept: tls_accept_socket");
    goto clean;
  }
  if (false)
    err_puts("kc3_tls_server_init_accept: tls_accept_socket: OK");
  buf_rw_fd_close(&tls_server->socket_buf->buf_rw);
  if (! tls_buf_open_r(tls_server->socket_buf->buf_rw.r, tmp_ctx)) {
    err_puts("kc3_tls_server_init_accept: tls_buf_open_r");
    assert(! "kc3_tls_server_init_accept: tls_buf_open_r");
    goto clean;
  }
  if (! tls_buf_open_w(tls_server->socket_buf->buf_rw.w, tmp_ctx)) {
    err_puts("kc3_tls_server_init_accept: tls_buf_open_w");
    assert(! "kc3_tls_server_init_accept: tls_buf_open_w");
    tls_buf_close(tls_server->socket_buf->buf_rw.r);
    goto clean;
  }
  while ((r = tls_handshake(tmp_ctx)) == TLS_WANT_POLLIN ||
         r == TLS_WANT_POLLOUT)
    ;
  if (r) {
    err_write_1("kc3_tls_server_init_accept: tls_handshake: ");
    err_puts(tls_error(tmp_ctx));
    assert(! "kc3_tls_server_init_accept: tls_handshake");
    tls_buf_close(tls_server->socket_buf->buf_rw.w);
    tls_buf_close(tls_server->socket_buf->buf_rw.r);
    goto clean;
  }
  return tls_server;
 clean:
  if (tmp_ctx) {
    tls_close(tmp_ctx);
    tls_free(tmp_ctx);
  }
  if (tls_server->socket_buf->sockfd >= 0)
    close(tls_server->socket_buf->sockfd);
  socket_buf_clean(tls_server->socket_buf);
  alloc_free(tls_server->socket_buf);
  tls_server->socket_buf = NULL;
  return NULL;
}
kc3-lang/kc3/libkc3/tls_server.c

Commit
