FilesExpand file tree

 master

/

thread_solaris.h

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

174 lines (151 loc) · 3.04 KB

 master

/

thread_solaris.h

Copy path

Top

File metadata and controls

• Code
• Blame

174 lines (151 loc) · 3.04 KB

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

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

127

128

129

130

131

132

133

134

135

136

137

138

139

140

141

142

143

144

145

146

147

148

149

150

151

152

153

154

155

156

157

158

159

160

161

162

163

164

165

166

167

168

169

170

171

172

173

174

#include <stdlib.h>

#include <stdio.h>

#include <errno.h>

#include </usr/include/thread.h>

#undef _POSIX_THREADS

/*

* Initialization.

*/

static void PyThread__init_thread(void)

{

}

/*

* Thread support.

*/

struct func_arg {

void (*func)(void *);

void *arg;

};

static void *

new_func(void *funcarg)

{

void (*func)(void *);

void *arg;

func = ((struct func_arg *) funcarg)->func;

arg = ((struct func_arg *) funcarg)->arg;

free(funcarg);

(*func)(arg);

return 0;

}

long

PyThread_start_new_thread(void (*func)(void *), void *arg)

{

thread_t tid;

struct func_arg *funcarg;

dprintf(("PyThread_start_new_thread called\n"));

if (!initialized)

PyThread_init_thread();

funcarg = (struct func_arg *) malloc(sizeof(struct func_arg));

funcarg->func = func;

funcarg->arg = arg;

if (thr_create(0, 0, new_func, funcarg,

THR_DETACHED | THR_NEW_LWP, &tid)) {

perror("thr_create");

free((void *) funcarg);

return -1;

}

return tid;

}

long

PyThread_get_thread_ident(void)

{

if (!initialized)

PyThread_init_thread();

return thr_self();

}

static void

do_PyThread_exit_thread(int no_cleanup)

{

dprintf(("PyThread_exit_thread called\n"));

if (!initialized)

if (no_cleanup)

_exit(0);

else

exit(0);

thr_exit(0);

}

void

PyThread_exit_thread(void)

{

do_PyThread_exit_thread(0);

}

void

PyThread__exit_thread(void)

{

do_PyThread_exit_thread(1);

}

#ifndef NO_EXIT_PROG

static void

do_PyThread_exit_prog(int status, int no_cleanup)

{

dprintf(("PyThread_exit_prog(%d) called\n", status));

if (!initialized)

if (no_cleanup)

_exit(status);

else

exit(status);

if (no_cleanup)

_exit(status);

else

exit(status);

}

void

PyThread_exit_prog(int status)

{

do_PyThread_exit_prog(status, 0);

}

void

PyThread__exit_prog(int status)

{

do_PyThread_exit_prog(status, 1);

}

#endif /* NO_EXIT_PROG */

/*

* Lock support.

*/

PyThread_type_lock

PyThread_allocate_lock(void)

{

mutex_t *lock;

dprintf(("PyThread_allocate_lock called\n"));

if (!initialized)

PyThread_init_thread();

lock = (mutex_t *) malloc(sizeof(mutex_t));

if (mutex_init(lock, USYNC_THREAD, 0)) {

perror("mutex_init");

free((void *) lock);

lock = 0;

}

dprintf(("PyThread_allocate_lock() -> %p\n", lock));

return (PyThread_type_lock) lock;

}

void

PyThread_free_lock(PyThread_type_lock lock)

{

dprintf(("PyThread_free_lock(%p) called\n", lock));

mutex_destroy((mutex_t *) lock);

free((void *) lock);

}

int

PyThread_acquire_lock(PyThread_type_lock lock, int waitflag)

{

int success;

dprintf(("PyThread_acquire_lock(%p, %d) called\n", lock, waitflag));

if (waitflag)

success = mutex_lock((mutex_t *) lock);

else

success = mutex_trylock((mutex_t *) lock);

if (success < 0)

perror(waitflag ? "mutex_lock" : "mutex_trylock");

else

success = !success; /* solaris does it the other way round */

dprintf(("PyThread_acquire_lock(%p, %d) -> %d\n", lock, waitflag, success));

return success;

}

void

PyThread_release_lock(PyThread_type_lock lock)

{

dprintf(("PyThread_release_lock(%p) called\n", lock));

if (mutex_unlock((mutex_t *) lock))

perror("mutex_unlock");

}