1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
|
/* Copyright (C) 2001-2023 Artifex Software, Inc.
All Rights Reserved.
This software is provided AS-IS with no warranty, either express or
implied.
This software is distributed under license and may not be copied,
modified or distributed except as expressly authorized under the terms
of the license contained in the file LICENSE in this distribution.
Refer to licensing information at http://www.artifex.com or contact
Artifex Software, Inc., 39 Mesa Street, Suite 108A, San Francisco,
CA 94129, USA, for further information.
*/
/* Interface to platform-dependent synchronization primitives */
#if !defined(gpsync_INCLUDED)
# define gpsync_INCLUDED
#include "stdint_.h" /* make sure stdint types are available - for int64_t */
/* Initial version 4/1/98 by John Desrosiers (soho@crl.com). */
/* 8/9/98 L. Peter Deutsch (ghost@aladdin.com) Changed ...sizeof to
procedures, added some comments. */
/* Maximum number of threads, although render threads assume a main instance */
/* so each main instance (rare) could have MAX_THREADS-2 render threads */
#ifndef MAX_THREADS
# define MAX_THREADS 50 /* Arbitrary, but does affect ICC_CACHE_MAXLINKS */
#endif
/* -------- Synchronization primitives ------- */
/*
* Semaphores support wait/signal semantics: a wait operation will allow
* control to proceed iff the number of signals since semaphore creation
* is greater than the number of waits.
*/
/* Needs to have maximum alignment */
typedef union {
void *dummy1;
double dummy2;
long dummy3;
int64_t dummy4;
} gp_semaphore;
uint gp_semaphore_sizeof(void);
/*
* Hack: gp_semaphore_open(0) succeeds iff it's OK for the memory manager
* to move a gp_semaphore in memory.
*/
int gp_semaphore_open(gp_semaphore * sema);
int gp_semaphore_close(gp_semaphore * sema);
int gp_semaphore_wait(gp_semaphore * sema);
int gp_semaphore_signal(gp_semaphore * sema);
void gp_semaphore_label(gp_semaphore * sema, const char *name);
#ifndef BOBBIN
#define gp_semaphore_label(A,B) do {} while (0)
#endif
/*
* Monitors support enter/leave semantics: at most one thread can have
* entered and not yet left a given monitor.
* 32-bit Solaris also requires maximum alignment. Bug 693147.
*/
typedef union {
void *dummy_;
double dummy2;
long dummy3;
int64_t dummy4;
} gp_monitor;
uint gp_monitor_sizeof(void);
/*
* Hack: gp_monitor_open(0) succeeds iff it's OK for the memory manager
* to move a gp_monitor in memory.
*/
int gp_monitor_open(gp_monitor * mon);
int gp_monitor_close(gp_monitor * mon);
int gp_monitor_enter(gp_monitor * mon);
int gp_monitor_leave(gp_monitor * mon);
void gp_monitor_label(gp_monitor * mon, const char *name);
#ifndef BOBBIN
#define gp_monitor_label(A,B) do {} while (0)
#endif
/*
* A new thread starts by calling a procedure, passing it a void * that
* allows it to gain access to whatever data it needs.
*
* NOW DEPRECATED: USE gs_create_handled_thread instead.
*/
typedef void (*gp_thread_creation_callback_t) (void *);
int gp_create_thread(gp_thread_creation_callback_t, void *);
/*
* Start a new thread in which the given callback procedure (fun) is called,
* passing it the given void * (arg) that allows it to gain access to whatever
* data it needs. If thread creation succeeds, this returns 0, and a thread id
* is placed in *thread. Otherwise a negative value is returned and *thread
* becomes NULL.
*
* This thread id cannot simply be discarded, it must be gp_thread_finished to
* avoid resource leakage or even crashes.
*/
typedef void *gp_thread_id;
int gp_thread_start(gp_thread_creation_callback_t fun, void *arg, gp_thread_id *thread);
/*
* Given a thread id created by gp_thread_start, this causes the current
* thread to wait until that thread has completed, and to discard
* the thread id. No further operations on the thread id are permitted.
*/
void gp_thread_finish(gp_thread_id thread);
void gp_thread_label(gp_thread_id thread, const char *name);
#ifndef BOBBIN
#define gp_thread_label(A,B) do {} while(0)
#endif
#endif /* !defined(gpsync_INCLUDED) */
|
