wip

Author: mickel8

c_src/ex_dtls/dtls.c

@@ -35,34 +35,46 @@ SSL *create_ssl(SSL_CTX *ssl_ctx, int mode) {
     return NULL;
   }
 
-  BIO *frag_bio = BIO_new(BIO_f_frag());
-  if (frag_bio == NULL) {
-    DEBUG("Cannot create frag bio");
-    return NULL;
-  }
+  // BIO *frag_bio = BIO_new(BIO_f_frag());
+  // if (frag_bio == NULL) {
+  //   DEBUG("Cannot create frag bio");
+  //   return NULL;
+  // }
 
-  BIO *wmem_bio = BIO_new(BIO_s_mem());
-  if (wmem_bio == NULL) {
-    DEBUG("Cannot create write mem bio");
-    return NULL;
-  }
+  // BIO *wmem_bio = BIO_new(BIO_s_mem());
+  // if (wmem_bio == NULL) {
+  //   DEBUG("Cannot create write mem bio");
+  //   return NULL;
+  // }
 
-  BIO *wchain = BIO_push(frag_bio, wmem_bio);
+  // BIO *wchain = BIO_push(frag_bio, wmem_bio);
 
   BIO *rmem_bio = BIO_new(BIO_s_mem());
   if (rmem_bio == NULL) {
     DEBUG("Cannot create read mem bio");
     return NULL;
   }
 
-  SSL_set_bio(ssl, rmem_bio, wchain);
+  BIO *rbio = BIO_new(BIO_s_dgram_mem());
+  if (rbio == NULL) {
+    DEBUG("Cannot create read dgram mem bio");
+    return NULL;
+  }
+
+  BIO *wbio = BIO_new(BIO_s_dgram_mem());
+  if (wbio == NULL) {
+    DEBUG("Cannot create write dgram mem bio");
+    return NULL;
+  }
+
+  // SSL_set_bio(ssl, rmem_bio, wchain);
+  SSL_set_bio(ssl, rbio, wbio);
 
   // printf("Setting MTU to 1000\n");
   // if (SSL_set_mtu(ssl, 1500) == 0) {
   //   return NULL;
   // } 
 
-
   return ssl;
 }
 

c_src/ex_dtls/native.c

@@ -444,6 +444,19 @@ UNIFEX_TERM handle_handshake_in_progress(State *state, int ret) {
       UNIFEX_TERM res_term = handle_data_result_handshake_packets(
           state->env, &gen_packets, timeout);
       unifex_payload_release(&gen_packets);
+
+      ssl_error = SSL_get_error(state->ssl, ret);
+      switch (ssl_error) {
+        case SSL_ERROR_WANT_READ:
+          DEBUG("SSL WANT READ 2");
+          pending_data_len = BIO_ctrl_pending(SSL_get_wbio(state->ssl));
+          DEBUG("WBIO: pending data 2: %ld bytes", pending_data_len);
+          break;
+        default:
+          DEBUG("SSL error: %d", ssl_error);
+      }
+  
+
       return res_term;
     } else {
       return handle_data_result_handshake_want_read(state->env);
@@ -513,6 +526,24 @@ static int verify_cb(int preverify_ok, X509_STORE_CTX *ctx) {
 
 static int read_pending_data(UnifexPayload *gen_packets, int pending_data_len,
                              State *state) {
+
+
+
+                              int ssl_error = SSL_get_error(state->ssl, ret);
+                              switch (ssl_error) {
+                              case SSL_ERROR_WANT_READ:
+                                DEBUG("SSL WANT READ");
+                                size_t pending_data_len = BIO_ctrl_pending(SSL_get_wbio(state->ssl));
+                                DEBUG("WBIO: pending data: %ld bytes", pending_data_len);
+                            
+                              default:
+                                return handle_read_error(state, ret);
+                              }
+
+
+
+
+
   char *pending_data = (char *)malloc(pending_data_len * sizeof(char));
   memset(pending_data, 0, pending_data_len);
   BIO *wbio = SSL_get_wbio(state->ssl);