source: libcfa/src/concurrency/clib/cfathread.h @ d971c8d

arm-ehjacob/cs343-translationnew-ast-unique-expr
Last change on this file since d971c8d was d971c8d, checked in by Thierry Delisle <tdelisle@…>, 7 months ago

Temporary hack to allow printing stats in memcached

  • Property mode set to 100644
File size: 4.6 KB
RevLine 
[bb662027]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 :
12// Last Modified On :
13// Update Count     :
14//
15
[038110a]16#if defined(__cforall) || defined(__cplusplus)
[bb662027]17extern "C" {
18#endif
[a1538cd]19        #include <asm/types.h>
20        #include <errno.h>
21        #include <unistd.h>
22
23
[bb662027]24        //--------------------
25        // Basic types
[a1538cd]26
27        typedef struct cluster * cfathread_cluster_t;
28
[9e27f69]29        int cfathread_cluster_create(cfathread_cluster_t * cluster);
[a1538cd]30        cfathread_cluster_t cfathread_cluster_self(void);
[d971c8d]31        int cfathread_cluster_print_stats(cfathread_cluster_t cluster);
[a1538cd]32        int cfathread_cluster_add_worker(cfathread_cluster_t cluster, pthread_t* tid, void (*init_routine) (void *), void * arg);
33        int cfathread_cluster_pause (cfathread_cluster_t cluster);
34        int cfathread_cluster_resume(cfathread_cluster_t cluster);
35
36        //--------------------
37        // thread attribute
38        typedef struct cfathread_attr {
39                cfathread_cluster_t cl;
40        } cfathread_attr_t;
41
42        int cfathread_attr_init(cfathread_attr_t * attr) __attribute__((nonnull (1)));
[9e27f69]43        static inline int cfathread_attr_destroy(cfathread_attr_t * attr) __attribute__((nonnull (1)));
44        static inline int cfathread_attr_destroy(cfathread_attr_t * attr) { return 0; }
45        static inline int cfathread_attr_setbackground(cfathread_attr_t * attr, int background) __attribute__((nonnull (1)));
46        static inline int cfathread_attr_setbackground(cfathread_attr_t * attr, int background) { return 0; }
47        static inline int cfathread_attr_setcluster(cfathread_attr_t * attr, cfathread_cluster_t cl) __attribute__((nonnull (1)));
48        static inline int cfathread_attr_setcluster(cfathread_attr_t * attr, cfathread_cluster_t cl) { attr->cl = cl; return 0; }
[bb662027]49
50        //--------------------
[a1538cd]51        // thread type
52        struct cfathread_object;
53        typedef struct cfathread_object * cfathread_t;
54
[9e27f69]55        int cfathread_create( cfathread_t * h, const cfathread_attr_t * a, void *(*main)( void * ), void * arg ) __attribute__((nonnull (1)));
[a1538cd]56        int cfathread_join( cfathread_t, void ** retval );
57
58        int cfathread_get_errno(void);
59        cfathread_t cfathread_self(void);
60
61        int cfathread_usleep(useconds_t usecs);
62        int cfathread_sleep(unsigned int secs);
[bb662027]63
64        void cfathread_park( void );
65        void cfathread_unpark( cfathread_t );
66        void cfathread_yield( void );
67
68        //--------------------
[a1538cd]69        // mutex and condition
70        struct timespec;
71
72        typedef struct cfathread_mutex_attr {
73        } cfathread_mutexattr_t;
74        typedef struct cfathread_mutex * cfathread_mutex_t;
75        int cfathread_mutex_init(cfathread_mutex_t *restrict mut, const cfathread_mutexattr_t *restrict attr) __attribute__((nonnull (1)));
76        int cfathread_mutex_destroy(cfathread_mutex_t *mut) __attribute__((nonnull (1)));
77        int cfathread_mutex_lock(cfathread_mutex_t *mut) __attribute__((nonnull (1)));
78        int cfathread_mutex_trylock(cfathread_mutex_t *mut) __attribute__((nonnull (1)));
79        int cfathread_mutex_unlock(cfathread_mutex_t *mut) __attribute__((nonnull (1)));
80
81        typedef struct cfathread_cond_attr {
82        } cfathread_condattr_t;
83        typedef struct cfathread_condition * cfathread_cond_t;
84        int cfathread_cond_init(cfathread_cond_t *restrict cond, const cfathread_condattr_t *restrict attr) __attribute__((nonnull (1)));
85        int cfathread_cond_wait(cfathread_cond_t *restrict cond, cfathread_mutex_t *restrict mut) __attribute__((nonnull (1,2)));
86        int cfathread_cond_timedwait(cfathread_cond_t *restrict cond, cfathread_mutex_t *restrict mut, const struct timespec *restrict abstime) __attribute__((nonnull (1,2,3)));
87        int cfathread_cond_signal(cfathread_cond_t *cond) __attribute__((nonnull (1)));
88
89        //--------------------
90        // IO operations
91        struct sockaddr;
92        struct msghdr;
93        int cfathread_socket(int domain, int type, int protocol);
94        int cfathread_bind(int socket, const struct sockaddr *address, socklen_t address_len);
95        int cfathread_listen(int socket, int backlog);
96        int cfathread_accept(int socket, struct sockaddr *restrict address, socklen_t *restrict address_len);
97        int cfathread_connect(int socket, const struct sockaddr *address, socklen_t address_len);
98        int cfathread_dup(int fildes);
99        int cfathread_close(int fildes);
100        ssize_t cfathread_sendmsg(int socket, const struct msghdr *message, int flags);
101        ssize_t cfathread_write(int fildes, const void *buf, size_t nbyte);
102        ssize_t cfathread_recvfrom(int socket, void *restrict buffer, size_t length, int flags, struct sockaddr *restrict address, socklen_t *restrict address_len);
103        ssize_t cfathread_read(int fildes, void *buf, size_t nbyte);
[bb662027]104
[038110a]105#if defined(__cforall) || defined(__cplusplus)
[bb662027]106}
107#endif
Note: See TracBrowser for help on using the repository browser.