79 lines
		
	
	
		
			1.7 KiB
		
	
	
	
		
			C
		
	
	
	
	
	
			
		
		
	
	
			79 lines
		
	
	
		
			1.7 KiB
		
	
	
	
		
			C
		
	
	
	
	
	
| /*
 | |
|  * This file is distributed as part of the SkySQL Gateway.  It is free
 | |
|  * software: you can redistribute it and/or modify it under the terms of the
 | |
|  * GNU General Public License as published by the Free Software Foundation,
 | |
|  * version 2.
 | |
|  *
 | |
|  * This program is distributed in the hope that it will be useful, but WITHOUT
 | |
|  * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS
 | |
|  * FOR A PARTICULAR PURPOSE.  See the GNU General Public License for more
 | |
|  * details.
 | |
|  *
 | |
|  * You should have received a copy of the GNU General Public License along with
 | |
|  * this program; if not, write to the Free Software Foundation, Inc., 51
 | |
|  * Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
 | |
|  *
 | |
|  * Copyright SkySQL Ab 2013
 | |
|  */
 | |
| #include <thread.h>
 | |
| #include <pthread.h>
 | |
| /**
 | |
|  * @file thread.c  - Implementation of thread related operations
 | |
|  *
 | |
|  * @verbatim
 | |
|  * Revision History
 | |
|  *
 | |
|  * Date		Who		Description
 | |
|  * 25/06/13	Mark Riddoch	Initial implementation
 | |
|  *
 | |
|  * @endverbatim
 | |
|  */
 | |
| 
 | |
| 
 | |
| /**
 | |
|  * Start a polling thread
 | |
|  *
 | |
|  * @param entry		The entry point to call
 | |
|  * @param arg		The argument to pass the thread entry point
 | |
|  * @return	The thread handle
 | |
|  */
 | |
| void *
 | |
| thread_start(void (*entry)(void *), void *arg)
 | |
| {
 | |
| pthread_t	thd;
 | |
| 
 | |
| 	if (pthread_create(&thd, NULL, (void *(*)(void *))entry, arg) != 0)
 | |
| 	{
 | |
| 		return NULL;
 | |
| 	}
 | |
| 	return (void *)thd;
 | |
| }
 | |
| 
 | |
| /**
 | |
|  * Wait for a running threads to complete.
 | |
|  *
 | |
|  * @param thd	The thread handle
 | |
|  */
 | |
| void
 | |
| thread_wait(void *thd)
 | |
| {
 | |
| void	*rval;
 | |
| 
 | |
| 	pthread_join((pthread_t)thd, &rval);
 | |
| }
 | |
| 
 | |
| /**
 | |
|  * Put the thread to sleep for a number of milliseconds
 | |
|  *
 | |
|  * @param ms	Number of milliseconds to sleep
 | |
|  */
 | |
| void
 | |
| thread_millisleep(int ms)
 | |
| {
 | |
| struct timespec req;
 | |
| 
 | |
| 	req.tv_sec = ms / 1000;
 | |
| 	req.tv_nsec = (ms % 1000) * 1000000;
 | |
| 	nanosleep(&req, NULL);
 | |
| }
 | 
