Fcalva/cyclone
1
0
Fork 0
mirror of https://github.com/justinethier/cyclone.git synced 2025-07-12 15:27:36 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

Fixed socket-accept

Browse source
This commit is contained in:
Justin Ethier 2016-09-23 17:28:04 -04:00
parent 33003a5813
commit 973a0672f2
1 changed files with 7 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
srfi/106.sld
View file

@ -6,6 +6,7 @@
(include-c-header "<arpa/inet.h>") (include-c-header "<arpa/inet.h>")
(include-c-header "<netdb.h>") (include-c-header "<netdb.h>")
(include-c-header "<unistd.h>") (include-c-header "<unistd.h>")
(include-c-header "<errno.h>")
(import (scheme base) (scheme cxr)) (import (scheme base) (scheme cxr))
(export (export
make-client-socket make-server-socket socket? make-client-socket make-server-socket socket?
@ -174,7 +175,7 @@
(when (not (socket? sock)) (when (not (socket? sock))
(error "Expected socket but received" sock)) (error "Expected socket but received" sock))
(let ((sockfd (%socket-accept sock))) (let ((sockfd (%socket-accept (socket->fd sock))))
(if (= sockfd -1) (if (= sockfd -1)
(error "An error occurred accepting a socket connection") (error "An error occurred accepting a socket connection")
(cons *socket-object-type* sockfd)))) (cons *socket-object-type* sockfd))))
@ -187,7 +188,12 @@
addr_size = sizeof(their_addr); addr_size = sizeof(their_addr);
set_thread_blocked(data, k); set_thread_blocked(data, k);
errno = 0;
new_fd = accept(obj_obj2int(sockfd), (struct sockaddr *)&their_addr, &addr_size); new_fd = accept(obj_obj2int(sockfd), (struct sockaddr *)&their_addr, &addr_size);
//if (new_fd < 0){
// // TODO: not so good. maybe we should build a string and send that if an error occurs
// fprintf(stderr, \"errno = %d\\n\", errno);
//}
return_thread_runnable(data, obj_int2obj(new_fd)); ") return_thread_runnable(data, obj_int2obj(new_fd)); ")
(define (socket-send sock bv . opts) (define (socket-send sock bv . opts)