wrapper.c

这是一个进程通信和手机数据处理程序, 与以前发的手机界面一起构成一个简单手机系统,是我们做的第一个版本,供大家一起学习

#ifndef _WRAPPER_C_
#define _WRAPPER_C_ 0

#include     "SysHeaders.h"
#include 	"Error.c"

FILE *Fopen( const char *path,const char *mode )
{
	FILE *fp;
	if( (fp = fopen(path,mode)) == NULL )	
		err_sys("Error occurred when  opening file!");
	return fp;

}

void Fwrite( const void *ptr,size_t size,size_t nmemb,FILE *stream )
{
	if( fwrite(ptr,size,nmemb,stream) != 1 )
		err_sys("Error occurred when  writing file!");
	
}
/* I don't kown why we can't use the wrapper function here 
size_t  Fread( const void *ptr,size_t size,size_t nmemb,FILE *stream )
{
	return fread(ptr,size,nmemb,stream);
}*/


void Fclose( FILE *stream )
{
	if( fclose(stream) != 0 )
		err_sys("Error occurred when  closing file!");
}


int
set_concurrency(int level)
{
#ifdef	HAVE_THR_SETCONCURRENCY_PROTO
	int		thr_setconcurrency(int);

	return(thr_setconcurrency(level));
#else
	return(0);
#endif
}

void
Set_concurrency(int level)
{
	if (set_concurrency(level) != 0)
		err_sys("set_concurrency error");
}


void
Pthread_create(pthread_t *tid, const pthread_attr_t *attr,
			   void * (*func)(void *), void *arg)
{
	int		n;

	if ( (n = pthread_create(tid, attr, func, arg)) == 0)
		return;
	errno = n;
	err_sys("pthread_create error");
}

void
Pthread_join(pthread_t tid, void **status)
{
	int		n;

	if ( (n = pthread_join(tid, status)) == 0)
		return;
	errno = n;
	err_sys("pthread_join error");
}


void
Pthread_mutexattr_init(pthread_mutexattr_t *attr)
{
	int		n;

	if ( (n = pthread_mutexattr_init(attr)) == 0)
		return;
	errno = n;
	err_sys("pthread_mutexattr_init error");
}

void
Pthread_mutexattr_destroy(pthread_mutexattr_t *attr)
{
	int		n;

	if ( (n = pthread_mutexattr_destroy(attr)) == 0)
		return;
	errno = n;
	err_sys("pthread_mutexattr_destroy error");
}

#ifdef	_POSIX_THREAD_PROCESS_SHARED
void
Pthread_mutexattr_setpshared(pthread_mutexattr_t *attr, int flag)
{
	int		n;

	if ( (n = pthread_mutexattr_setpshared(attr, flag)) == 0)
		return;
	errno = n;
	err_sys("pthread_mutexattr_setpshared error");
}
#endif

void
Pthread_mutex_init(pthread_mutex_t *mptr, pthread_mutexattr_t *attr)
{
	int		n;

	if ( (n = pthread_mutex_init(mptr, attr)) == 0)
		return;
	errno = n;
	err_sys("pthread_mutex_init error");
}


/* include Pthread_mutex_lock */
void
Pthread_mutex_lock(pthread_mutex_t *mptr)
{
	int		n;

	if ( (n = pthread_mutex_lock(mptr)) == 0)
		return;
	errno = n;
	err_sys("pthread_mutex_lock error");
}
/* end Pthread_mutex_lock */


int
Pthread_mutex_trylock(pthread_mutex_t *mptr)
{
	
	return pthread_mutex_trylock(mptr);
}

void
Pthread_mutex_unlock(pthread_mutex_t *mptr)
{
	int		n;

	if ( (n = pthread_mutex_unlock(mptr)) == 0)
		return;
	errno = n;
	err_sys("pthread_mutex_unlock error");
}

void
Pthread_condattr_init(pthread_condattr_t *attr)
{
	int		n;

	if ( (n = pthread_condattr_init(attr)) == 0)
		return;
	errno = n;
	err_sys("pthread_condattr_init error");
}

void
Pthread_condattr_destroy(pthread_condattr_t *attr)
{
	int		n;

	if ( (n = pthread_condattr_destroy(attr)) == 0)
		return;
	errno = n;
	err_sys("pthread_condattr_destroy error");
}

#ifdef	_POSIX_THREAD_PROCESS_SHARED
void
Pthread_condattr_setpshared(pthread_condattr_t *attr, int flag)
{
	int		n;

	if ( (n = pthread_condattr_setpshared(attr, flag)) == 0)
		return;
	errno = n;
	err_sys("pthread_condattr_setpshared error");
}
#endif




void
Pthread_cond_signal(pthread_cond_t *cptr)
{
	int		n;

	if ( (n = pthread_cond_signal(cptr)) == 0)
		return;
	errno = n;
	err_sys("pthread_cond_signal error");
}

void
Pthread_cond_wait(pthread_cond_t *cptr, pthread_mutex_t *mptr)
{
	int		n;

	if ( (n = pthread_cond_wait(cptr, mptr)) == 0)
		return;
	errno = n;
	err_sys("pthread_cond_wait error");
}

#endif