kc3-lang/kc3/tls/tls_client.c

Branch - branch -masterpdfv0.1- tag -v0.1.9v0.1.8v0.1.7v0.1.6v0.1.5v0.1.4v0.1.3v0.1.2v0.1.15v0.1.14v0.1.13v0.1.12v0.1.11v0.1.10v0.1.1v0.1.0v0HTTPd-v0.2.0HTTPd-v0.1.1HTTPd-v0.1.0

• Show log

  Commit

• Hash : 8415fa90
  Author :
  Date : 2025-10-07T18:39:01
  

  fix: function name
  

Download

• tls/tls_client.c

• /* kc3
   * Copyright from 2022 to 2025 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 "../libkc3/kc3.h"
  #include "../socket/socket.h"
  #include "tls_buf.h"
  #include "tls_client.h"
  
  void kc3_tls_client_clean (s_tls_client *tls_client)
  {
    s_tls_buf *tls_buf;
    buf_flush(tls_client->socket_buf.buf_rw.w);
    tls_buf = tls_client->socket_buf.buf_rw.r->user_ptr;
    tls_close(tls_buf->ctx);
    tls_buf_close(tls_client->socket_buf.buf_rw.r);
    tls_buf_close(tls_client->socket_buf.buf_rw.w);
    buf_rw_clean(&tls_client->socket_buf.buf_rw);
  
    // TODO: check if tests leak without that
    close(tls_client->socket_buf.sockfd);
  }
  
  s_tls_client * kc3_tls_client_init_connect (s_tls_client *tls_client,
                                              p_tls *ctx, s_str *host,
                                              s_str *port)
  {
    sw r;
    s_tls_client tmp = {0};
    assert(tls_client);
    assert(ctx);
    assert(*ctx);
    assert(host);
    assert(port);
    if (! socket_init_connect(&tmp.socket_buf.sockfd, host, port)) {
      err_puts("kc3_tls_client_init_connect: socket_init_connect");
      assert(! "kc3_tls_client_init_connect: socket_init_connect");
      return NULL;
    }
    if (tls_connect_socket(*ctx, tmp.socket_buf.sockfd, host->ptr.pchar)) {
      err_write_1("kc3_tls_client_init_connect: tls_connect_socket: ");
      err_puts(tls_error(*ctx));
      assert(! "kc3_tls_client_init_connect: tls_connect_socket");
      return NULL;
    }
    if (! (tmp.socket_buf.buf_rw.r = buf_new_alloc(BUF_SIZE))) {
      err_puts("kc3_tls_client_init_connect: buf_new_alloc r");
      assert(! "kc3_tls_client_init_connect: buf_new_alloc r");
      return NULL;
    }
    if (! (tmp.socket_buf.buf_rw.w = buf_new_alloc(BUF_SIZE))) {
      err_puts("kc3_tls_client_init_connect: buf_new_alloc w");
      assert(! "kc3_tls_client_init_connect: buf_new_alloc w");
      buf_delete(tmp.socket_buf.buf_rw.r);
      return NULL;
    }
    while ((r = tls_handshake(*ctx)) == TLS_WANT_POLLIN ||
           r == TLS_WANT_POLLOUT)
      ;
    if (r) {
      err_write_1("kc3_tls_client_init_connect: tls_handshake: ");
      err_puts(tls_error(*ctx));
      assert(! "kc3_tls_client_init_connect: tls_handshake");
      tls_buf_close(tmp.socket_buf.buf_rw.w);
      tls_buf_close(tmp.socket_buf.buf_rw.r);
      buf_delete(tmp.socket_buf.buf_rw.w);
      buf_delete(tmp.socket_buf.buf_rw.r);
      return NULL;
    }
    if (! tls_buf_open_r(tmp.socket_buf.buf_rw.r, *ctx)) {
      err_puts("kc3_tls_client_init_connect: tls_buf_open_r");
      assert(! "kc3_tls_client_init_connect: tls_buf_open_r");
      buf_delete(tmp.socket_buf.buf_rw.w);
      buf_delete(tmp.socket_buf.buf_rw.r);
      return NULL;
    }
    if (! tls_buf_open_w(tmp.socket_buf.buf_rw.w, *ctx)) {
      err_puts("kc3_tls_client_init_connect: ");
      assert(! "kc3_tls_client_init_connect: ");
      tls_buf_close(tmp.socket_buf.buf_rw.r);
      buf_delete(tmp.socket_buf.buf_rw.w);
      buf_delete(tmp.socket_buf.buf_rw.r);
      return NULL;
    }
    *tls_client = tmp;
    return tls_client;
  }
  

Download