]> git.meshlink.io Git - meshlink/blobdiff - src/utcp.c
Add meshlink_set_channel_listen_cb().
[meshlink] / src / utcp.c
index 7ac96c626d6dedbf9849d4fe41eb11e7a24763ac..65e6be7a2de4e19ac42401ef2696a1590561435d 100644 (file)
@@ -1293,7 +1293,7 @@ ssize_t utcp_recv(struct utcp *utcp, const void *data, size_t len) {
 
                if(hdr.ctl & SYN && !(hdr.ctl & ACK) && utcp->accept) {
                        // If we don't want to accept it, send a RST back
-                       if((utcp->pre_accept && !utcp->pre_accept(utcp, hdr.dst))) {
+                       if((utcp->listen && !utcp->listen(utcp, hdr.dst))) {
                                len = 1;
                                goto reset;
                        }
@@ -2158,7 +2158,7 @@ bool utcp_is_active(struct utcp *utcp) {
        return false;
 }
 
-struct utcp *utcp_init(utcp_accept_t accept, utcp_pre_accept_t pre_accept, utcp_send_t send, void *priv) {
+struct utcp *utcp_init(utcp_accept_t accept, utcp_listen_t listen, utcp_send_t send, void *priv) {
        if(!send) {
                errno = EFAULT;
                return NULL;
@@ -2184,7 +2184,7 @@ struct utcp *utcp_init(utcp_accept_t accept, utcp_pre_accept_t pre_accept, utcp_
        }
 
        utcp->accept = accept;
-       utcp->pre_accept = pre_accept;
+       utcp->listen = listen;
        utcp->send = send;
        utcp->priv = priv;
        utcp->timeout = DEFAULT_USER_TIMEOUT; // sec
@@ -2401,10 +2401,10 @@ void utcp_set_poll_cb(struct utcp_connection *c, utcp_poll_t poll) {
        }
 }
 
-void utcp_set_accept_cb(struct utcp *utcp, utcp_accept_t accept, utcp_pre_accept_t pre_accept) {
+void utcp_set_accept_cb(struct utcp *utcp, utcp_accept_t accept, utcp_listen_t listen) {
        if(utcp) {
                utcp->accept = accept;
-               utcp->pre_accept = pre_accept;
+               utcp->listen = listen;
        }
 }