/[svn]/liblscp/trunk/src/thread.c
ViewVC logotype

Annotation of /liblscp/trunk/src/thread.c

Parent Directory Parent Directory | Revision Log Revision Log


Revision 869 - (hide annotations) (download)
Thu Jun 1 08:32:16 2006 UTC (17 years, 10 months ago) by capela
File MIME type: text/plain
File size: 4744 byte(s)
* Fixed some compilation warnings due to suspicious type
  casting and unsused header macros.

* Changed deprecated copyright attribute to license
  and added ldconfig to post-(un)install steps
  to liblscp.spec (RPM).

1 capela 100 // thread.c
2     //
3     /****************************************************************************
4     liblscp - LinuxSampler Control Protocol API
5 capela 869 Copyright (C) 2004-2006, rncbc aka Rui Nuno Capela. All rights reserved.
6 capela 100
7     This library is free software; you can redistribute it and/or
8     modify it under the terms of the GNU Lesser General Public
9     License as published by the Free Software Foundation; either
10     version 2.1 of the License, or (at your option) any later version.
11    
12     This library is distributed in the hope that it will be useful,
13     but WITHOUT ANY WARRANTY; without even the implied warranty of
14     MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
15     Lesser General Public License for more details.
16    
17     You should have received a copy of the GNU Lesser General Public
18     License along with this library; if not, write to the Free Software
19     Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
20    
21     *****************************************************************************/
22    
23     #include "lscp/thread.h"
24    
25    
26     //-------------------------------------------------------------------------
27     // Threads.
28    
29     struct _lscp_thread_t {
30     #if defined(WIN32)
31     HANDLE hThread;
32     DWORD dwThreadID;
33     #else
34     pthread_t pthread;
35     #endif
36     lscp_thread_proc_t pfnProc;
37     void *pvData;
38     int iDetach;
39     };
40    
41    
42     #if defined(WIN32)
43     static DWORD WINAPI _lscp_thread_start ( LPVOID pvThread )
44     #else
45     static void *_lscp_thread_start ( void *pvThread )
46     #endif
47     {
48     lscp_thread_t *pThread = (lscp_thread_t *) pvThread;
49     if (pThread) {
50     // fprintf(stderr, "_lscp_thread_start: pThread=%p started.\n", pThread);
51     pThread->pfnProc(pThread->pvData);
52     // fprintf(stderr, "_lscp_thread_start: pThread=%p terminated.\n", pThread);
53     if (pThread->iDetach)
54     free(pThread);
55     }
56     #if defined(WIN32)
57     return 0;
58     #else
59     return NULL;
60     #endif
61     }
62    
63     lscp_thread_t *lscp_thread_create ( lscp_thread_proc_t pfnProc, void *pvData, int iDetach )
64     {
65     lscp_thread_t *pThread;
66     #if !defined(WIN32)
67     pthread_attr_t attr;
68     #endif
69    
70     if (pfnProc == NULL) {
71     fprintf(stderr, "lcsp_thread_create: Invalid thread function.\n");
72     return NULL;
73     }
74    
75     pThread = (lscp_thread_t *) malloc(sizeof(lscp_thread_t));
76     if (pThread == NULL) {
77     fprintf(stderr, "lcsp_thread_create: Out of memory.\n");
78     return NULL;
79     }
80     memset(pThread, 0, sizeof(lscp_thread_t));
81    
82     pThread->pvData = pvData;
83     pThread->pfnProc = pfnProc;
84     pThread->iDetach = iDetach;
85    
86     // fprintf(stderr, "lscp_thread_create: pThread=%p.\n", pThread);
87    
88     #if defined(WIN32)
89     pThread->hThread = CreateThread(NULL, 0, _lscp_thread_start, (LPVOID) pThread, 0, &(pThread->dwThreadID));
90     if (pThread->hThread == NULL) {
91     fprintf(stderr, "lcsp_thread_create: Failed to create thread.\n");
92     free(pThread);
93     return NULL;
94     }
95     #else
96     pthread_attr_init(&attr);
97     if (iDetach)
98     pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_DETACHED);
99     if (pthread_create(&pThread->pthread, &attr, _lscp_thread_start, pThread)) {
100     fprintf(stderr, "lcsp_thread_create: Failed to create thread.\n");
101     free(pThread);
102     return NULL;
103     }
104     #endif
105    
106     return pThread;
107     }
108    
109    
110     lscp_status_t lscp_thread_join( lscp_thread_t *pThread )
111     {
112     lscp_status_t ret = LSCP_FAILED;
113    
114     if (pThread == NULL)
115     return ret;
116    
117     // fprintf(stderr, "lscp_thread_join: pThread=%p.\n", pThread);
118    
119     #if defined(WIN32)
120     if (pThread->hThread && WaitForSingleObject(pThread->hThread, INFINITE) == WAIT_OBJECT_0) {
121     pThread->hThread = NULL;
122     ret = LSCP_OK;
123     }
124     #else
125     if (pThread->pthread && pthread_join(pThread->pthread, NULL) == 0) {
126     pThread->pthread = 0;
127     ret = LSCP_OK;
128     }
129     #endif
130    
131     return ret;
132     }
133    
134    
135     lscp_status_t lscp_thread_cancel ( lscp_thread_t *pThread )
136     {
137     lscp_status_t ret = LSCP_FAILED;
138    
139     if (pThread == NULL)
140     return ret;
141    
142     // fprintf(stderr, "lscp_thread_cancel: pThread=%p.\n", pThread);
143    
144     #if defined(WIN32)
145 capela 179 if (pThread->hThread) { // Should we TerminateThread(pThread->hThread, 0) ?
146     /* pThread->hThread = NULL; */
147 capela 100 ret = LSCP_OK;
148     }
149     #else
150     if (pThread->pthread && pthread_cancel(pThread->pthread) == 0) {
151     pThread->pthread = 0;
152     ret = LSCP_OK;
153     }
154     #endif
155    
156     return ret;
157     }
158    
159    
160     lscp_status_t lscp_thread_destroy ( lscp_thread_t *pThread )
161     {
162 capela 179 lscp_status_t ret = lscp_thread_cancel(pThread);
163 capela 100
164 capela 179 if (ret == LSCP_OK)
165     ret = lscp_thread_join(pThread);
166    
167 capela 100 // fprintf(stderr, "lscp_thread_destroy: pThread=%p.\n", pThread);
168    
169 capela 178 if (ret == LSCP_OK)
170     free(pThread);
171 capela 100
172     return ret;
173     }
174    
175    
176     // end of thread.c

  ViewVC Help
Powered by ViewVC