6 changed files with 586 additions and 31 deletions
-
433ext/mysql/libmysql/libmysql.dsp
-
139ext/mysql/libmysql/my_wincond.c
-
3main/config.w32.h
-
4main/internal_functions_win32.c
-
20php4dllts.dsp
-
18php4ts.dsw
@ -0,0 +1,139 @@ |
|||
/* Copyright (C) 2000 Monty Program KB |
|||
|
|||
This software is distributed with NO WARRANTY OF ANY KIND. No author or |
|||
distributor accepts any responsibility for the consequences of using it, or |
|||
for whether it serves any particular purpose or works at all, unless he or |
|||
she says so in writing. Refer to the Free Public License (the "License") |
|||
for full details. |
|||
|
|||
Every copy of this file must include a copy of the License, normally in a |
|||
plain ASCII text file named PUBLIC. The License grants you the right to |
|||
copy, modify and redistribute this file, but only under certain conditions |
|||
described in the License. Among other things, the License requires that |
|||
the copyright notice and this notice be preserved on all copies. */ |
|||
|
|||
|
|||
/***************************************************************************** |
|||
** The following is a simple implementation of posix conditions |
|||
*****************************************************************************/ |
|||
|
|||
#include "mysys_priv.h" |
|||
#if defined(THREAD) && defined(__WIN32__) |
|||
#include <m_string.h> |
|||
#undef getpid |
|||
#include <process.h> |
|||
#include <sys/timeb.h> |
|||
|
|||
int pthread_cond_init(pthread_cond_t *cond, const pthread_condattr_t *attr) |
|||
{ |
|||
cond->waiting=0; |
|||
cond->semaphore=CreateSemaphore(NULL,0,0x7FFFFFFF,NullS); |
|||
if (!cond->semaphore) |
|||
return ENOMEM; |
|||
return 0; |
|||
} |
|||
|
|||
int pthread_cond_destroy(pthread_cond_t *cond) |
|||
{ |
|||
return CloseHandle(cond->semaphore) ? 0 : EINVAL; |
|||
} |
|||
|
|||
|
|||
int pthread_cond_wait(pthread_cond_t *cond, pthread_mutex_t *mutex) |
|||
{ |
|||
InterlockedIncrement(&cond->waiting); |
|||
LeaveCriticalSection(mutex); |
|||
WaitForSingleObject(cond->semaphore,INFINITE); |
|||
InterlockedDecrement(&cond->waiting); |
|||
EnterCriticalSection(mutex); |
|||
return 0 ; |
|||
} |
|||
|
|||
int pthread_cond_timedwait(pthread_cond_t *cond, pthread_mutex_t *mutex, |
|||
struct timespec *abstime) |
|||
{ |
|||
struct _timeb curtime; |
|||
int result; |
|||
long timeout; |
|||
_ftime(&curtime); |
|||
timeout= ((long) (abstime->tv_sec - curtime.time)*1000L + |
|||
(long)((abstime->tv_nsec/1000) - curtime.millitm)/1000L); |
|||
if (timeout < 0) /* Some safety */ |
|||
timeout = 0L; |
|||
InterlockedIncrement(&cond->waiting); |
|||
LeaveCriticalSection(mutex); |
|||
result=WaitForSingleObject(cond->semaphore,timeout); |
|||
InterlockedDecrement(&cond->waiting); |
|||
EnterCriticalSection(mutex); |
|||
|
|||
return result == WAIT_TIMEOUT ? ETIMEDOUT : 0; |
|||
} |
|||
|
|||
|
|||
int pthread_cond_signal(pthread_cond_t *cond) |
|||
{ |
|||
long prev_count; |
|||
if (cond->waiting) |
|||
ReleaseSemaphore(cond->semaphore,1,&prev_count); |
|||
return 0; |
|||
} |
|||
|
|||
|
|||
int pthread_cond_broadcast(pthread_cond_t *cond) |
|||
{ |
|||
long prev_count; |
|||
if (cond->waiting) |
|||
ReleaseSemaphore(cond->semaphore,cond->waiting,&prev_count); |
|||
return 0 ; |
|||
} |
|||
|
|||
|
|||
int pthread_attr_init(pthread_attr_t *connect_att) |
|||
{ |
|||
connect_att->dwStackSize = 0; |
|||
connect_att->dwCreatingFlag = 0; |
|||
connect_att->priority = 0; |
|||
return 0; |
|||
} |
|||
|
|||
int pthread_attr_setstacksize(pthread_attr_t *connect_att,DWORD stack) |
|||
{ |
|||
connect_att->dwStackSize=stack; |
|||
return 0; |
|||
} |
|||
|
|||
int pthread_attr_setprio(pthread_attr_t *connect_att,int priority) |
|||
{ |
|||
connect_att->priority=priority; |
|||
return 0; |
|||
} |
|||
|
|||
int pthread_attr_destroy(pthread_attr_t *connect_att) |
|||
{ |
|||
bzero((gptr) connect_att,sizeof(*connect_att)); |
|||
return 0; |
|||
} |
|||
|
|||
/**************************************************************************** |
|||
** Fix localtime_r() to be a bit safer |
|||
****************************************************************************/ |
|||
|
|||
struct tm *localtime_r(const time_t *timep,struct tm *tmp) |
|||
{ |
|||
if (*timep == (time_t) -1) /* This will crash win32 */ |
|||
{ |
|||
bzero(tmp,sizeof(*tmp)); |
|||
} |
|||
else |
|||
{ |
|||
struct tm *res=localtime(timep); |
|||
if (!res) /* Wrong date */ |
|||
{ |
|||
bzero(tmp,sizeof(*tmp)); /* Keep things safe */ |
|||
return 0; |
|||
} |
|||
*tmp= *res; |
|||
} |
|||
return tmp; |
|||
} |
|||
#endif /* __WIN32__ */ |
|||
Write
Preview
Loading…
Cancel
Save
Reference in new issue