Changes in libcfa/src/concurrency/clib/cfathread.cfa [a0a949c:95dab9e]

File:

• libcfa/src/concurrency/clib/cfathread.cfa (modified) (8 diffs)

libcfa/src/concurrency/clib/cfathread.cfa

@@ -16 +16 @@
 // #define EPOLL_FOR_SOCKETS
 
-#include <string.h>
-
 #include "fstream.hfa"
 #include "locks.hfa"
@@ -25 +23 @@
 #include "time.hfa"
 #include "stdlib.hfa"
-#include "iofwd.hfa"
+
 #include "cfathread.h"
+
+extern "C" {
+                #include <string.h>
+                #include <errno.h>
+}
 
 extern void ?{}(processor &, const char[], cluster &, thread$ *);
 extern "C" {
-        extern void __cfactx_invoke_thread(void (*main)(void *), void * this);
+      extern void __cfactx_invoke_thread(void (*main)(void *), void * this);
+        extern int accept4(int sockfd, struct sockaddr *addr, socklen_t *addrlen, int flags);
 }
 
@@ -435 +439 @@
         // Mutex
         struct cfathread_mutex {
-                exp_backoff_then_block_lock impl;
+                linear_backoff_then_block_lock impl;
         };
         int cfathread_mutex_init(cfathread_mutex_t *restrict mut, const cfathread_mutexattr_t *restrict) __attribute__((nonnull (1))) { *mut = new(); return 0; }
@@ -450 +454 @@
         // Condition
         struct cfathread_condition {
-                condition_variable(exp_backoff_then_block_lock) impl;
+                condition_variable(linear_backoff_then_block_lock) impl;
         };
         int cfathread_cond_init(cfathread_cond_t *restrict cond, const cfathread_condattr_t *restrict) __attribute__((nonnull (1))) { *cond = new(); return 0; }
@@ -468 +472 @@
 }
 
+#include <iofwd.hfa>
+
 extern "C" {
+        #include <unistd.h>
+        #include <sys/types.h>
+        #include <sys/socket.h>
+
         //--------------------
         // IO operations
@@ -478 +488 @@
                 , protocol);
         }
-        int cfathread_bind(int socket, __CONST_SOCKADDR_ARG address, socklen_t address_len) {
+        int cfathread_bind(int socket, const struct sockaddr *address, socklen_t address_len) {
                 return bind(socket, address, address_len);
         }
@@ -486 +496 @@
         }
 
-        int cfathread_accept(int socket, __SOCKADDR_ARG address, socklen_t *restrict address_len) {
+        int cfathread_accept(int socket, struct sockaddr *restrict address, socklen_t *restrict address_len) {
                 #if defined(EPOLL_FOR_SOCKETS)
                         int ret;
@@ -503 +513 @@
         }
 
-        int cfathread_connect(int socket, __CONST_SOCKADDR_ARG address, socklen_t address_len) {
+        int cfathread_connect(int socket, const struct sockaddr *address, socklen_t address_len) {
                 #if defined(EPOLL_FOR_SOCKETS)
                         int ret;