1 | // |
---|
2 | // Cforall Version 1.0.0 Copyright (C) 2016 University of Waterloo |
---|
3 | // |
---|
4 | // The contents of this file are covered under the licence agreement in the |
---|
5 | // file "LICENCE" distributed with Cforall. |
---|
6 | // |
---|
7 | // clib/cfathread.h -- |
---|
8 | // |
---|
9 | // Author : Thierry Delisle |
---|
10 | // Created On : Tue Sep 22 15:31:20 2020 |
---|
11 | // Last Modified By : Peter A. Buhr |
---|
12 | // Last Modified On : Sat Feb 25 17:39:20 2023 |
---|
13 | // Update Count : 6 |
---|
14 | // |
---|
15 | |
---|
16 | #if defined(__cforall) || defined(__cplusplus) |
---|
17 | #include <unistd.h> |
---|
18 | #include <errno.h> |
---|
19 | #include <sys/socket.h> |
---|
20 | |
---|
21 | extern "C" { |
---|
22 | #endif |
---|
23 | //-------------------- |
---|
24 | // Basic types |
---|
25 | |
---|
26 | typedef struct cluster * cfathread_cluster_t; |
---|
27 | |
---|
28 | int cfathread_cluster_create(cfathread_cluster_t * cluster); |
---|
29 | cfathread_cluster_t cfathread_cluster_self(void); |
---|
30 | int cfathread_cluster_print_stats(cfathread_cluster_t cluster); |
---|
31 | int cfathread_cluster_add_worker(cfathread_cluster_t cluster, pthread_t* tid, void (*init_routine) (void *), void * arg); |
---|
32 | int cfathread_cluster_pause (cfathread_cluster_t cluster); |
---|
33 | int cfathread_cluster_resume(cfathread_cluster_t cluster); |
---|
34 | |
---|
35 | //-------------------- |
---|
36 | // thread attribute |
---|
37 | typedef struct cfathread_attr { |
---|
38 | cfathread_cluster_t cl; |
---|
39 | } cfathread_attr_t; |
---|
40 | |
---|
41 | int cfathread_attr_init(cfathread_attr_t * attr) __attribute__((nonnull (1))); |
---|
42 | static inline int cfathread_attr_destroy(cfathread_attr_t * attr) __attribute__((nonnull (1))); |
---|
43 | static inline int cfathread_attr_destroy(cfathread_attr_t * attr) { return 0; } |
---|
44 | static inline int cfathread_attr_setbackground(cfathread_attr_t * attr, int background) __attribute__((nonnull (1))); |
---|
45 | static inline int cfathread_attr_setbackground(cfathread_attr_t * attr, int background) { return 0; } |
---|
46 | static inline int cfathread_attr_setcluster(cfathread_attr_t * attr, cfathread_cluster_t cl) __attribute__((nonnull (1))); |
---|
47 | static inline int cfathread_attr_setcluster(cfathread_attr_t * attr, cfathread_cluster_t cl) { attr->cl = cl; return 0; } |
---|
48 | |
---|
49 | //-------------------- |
---|
50 | // thread type |
---|
51 | struct cfathread_object; |
---|
52 | typedef struct cfathread_object * cfathread_t; |
---|
53 | |
---|
54 | int cfathread_create( cfathread_t * h, const cfathread_attr_t * a, void *(*main)( void * ), void * arg ) __attribute__((nonnull (1))); |
---|
55 | int cfathread_join( cfathread_t, void ** retval ); |
---|
56 | |
---|
57 | int cfathread_get_errno(void); |
---|
58 | cfathread_t cfathread_self(void); |
---|
59 | |
---|
60 | int cfathread_usleep(useconds_t usecs); |
---|
61 | int cfathread_sleep(unsigned int secs); |
---|
62 | |
---|
63 | void cfathread_park( void ); |
---|
64 | void cfathread_unpark( cfathread_t ); |
---|
65 | void cfathread_yield( void ); |
---|
66 | |
---|
67 | //-------------------- |
---|
68 | // mutex and condition |
---|
69 | struct timespec; |
---|
70 | |
---|
71 | typedef struct cfathread_mutex_attr { |
---|
72 | } cfathread_mutexattr_t; |
---|
73 | typedef struct cfathread_mutex * cfathread_mutex_t; |
---|
74 | int cfathread_mutex_init(cfathread_mutex_t * restrict mut, const cfathread_mutexattr_t * restrict attr) __attribute__((nonnull (1))); |
---|
75 | int cfathread_mutex_destroy(cfathread_mutex_t *mut) __attribute__((nonnull (1))); |
---|
76 | int cfathread_mutex_lock(cfathread_mutex_t *mut) __attribute__((nonnull (1))); |
---|
77 | int cfathread_mutex_trylock(cfathread_mutex_t *mut) __attribute__((nonnull (1))); |
---|
78 | int cfathread_mutex_unlock(cfathread_mutex_t *mut) __attribute__((nonnull (1))); |
---|
79 | |
---|
80 | typedef struct cfathread_cond_attr { |
---|
81 | // WARNING: adding support for pthread_condattr_setclock would require keeping track of the clock |
---|
82 | // and reading it in cond_timedwait |
---|
83 | } cfathread_condattr_t; |
---|
84 | typedef struct cfathread_condition * cfathread_cond_t; |
---|
85 | int cfathread_cond_init(cfathread_cond_t *restrict cond, const cfathread_condattr_t *restrict attr) __attribute__((nonnull (1))); |
---|
86 | int cfathread_cond_wait(cfathread_cond_t *restrict cond, cfathread_mutex_t *restrict mut) __attribute__((nonnull (1,2))); |
---|
87 | int cfathread_cond_timedwait(cfathread_cond_t *restrict cond, cfathread_mutex_t *restrict mut, const struct timespec *restrict abstime) __attribute__((nonnull (1,2,3))); |
---|
88 | int cfathread_cond_signal(cfathread_cond_t *cond) __attribute__((nonnull (1))); |
---|
89 | |
---|
90 | //-------------------- |
---|
91 | // IO operations |
---|
92 | int cfathread_socket(int domain, int type, int protocol); |
---|
93 | int cfathread_bind(int socket, __CONST_SOCKADDR_ARG address, socklen_t address_len); |
---|
94 | int cfathread_listen(int socket, int backlog); |
---|
95 | int cfathread_accept(int socket, __SOCKADDR_ARG address, socklen_t * restrict address_len); |
---|
96 | int cfathread_connect(int socket, __CONST_SOCKADDR_ARG address, socklen_t address_len); |
---|
97 | int cfathread_dup(int fildes); |
---|
98 | int cfathread_close(int fildes); |
---|
99 | ssize_t cfathread_sendmsg(int socket, const struct msghdr *message, int flags); |
---|
100 | ssize_t cfathread_write(int fildes, const void *buf, size_t nbyte); |
---|
101 | ssize_t cfathread_recvfrom(int socket, void *restrict buffer, size_t length, int flags, struct sockaddr *restrict address, socklen_t *restrict address_len); |
---|
102 | ssize_t cfathread_read(int fildes, void *buf, size_t nbyte); |
---|
103 | |
---|
104 | #if defined(__cforall) || defined(__cplusplus) |
---|
105 | } |
---|
106 | #endif |
---|