jimzah/openafs
1
0
Fork 0
mirror of https://git.openafs.org/openafs.git synced 2025-01-31 13:38:01 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Windows: convert buf_IncrSyncer to pthreads

Browse Source 
buf_IncrSyncer() calls rx therefore it should be a pthread
thread so as not to count against the 63 native thread count
limit.

Change-Id: If00eeb7d26bfbf7d0f35addb05290f3704d11a89
Reviewed-on: http://gerrit.openafs.org/6171
Tested-by: BuildBot <buildbot@rampaginggeek.com>
Reviewed-by: Jeffrey Altman <jaltman@secure-endpoints.com>
Tested-by: Jeffrey Altman <jaltman@secure-endpoints.com>
This commit is contained in:
Jeffrey Altman 2011-12-02 11:11:59 -05:00 committed by Jeffrey Altman
parent 2aeb041bb0
commit b26161284f
1 changed files with 14 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
src/WINNT/afsd/cm_buf.c
View File

@ -337,7 +337,8 @@ buf_Sync(int quitOnShutdown)
}
/* incremental sync daemon. Writes all dirty buffers every 5000 ms */
void buf_IncrSyncer(long parm)
static void *
buf_IncrSyncer(void * parm)
{
long wasDirty = 0;
long i;
@ -353,6 +354,9 @@ void buf_IncrSyncer(long parm)
wasDirty = buf_Sync(1);
} /* whole daemon's while loop */
pthread_exit(NULL);
return NULL;
}
long
@ -461,9 +465,10 @@ long buf_Init(int newFile, cm_buf_ops_t *opsp, afs_uint64 nbuffers)
{
static osi_once_t once;
cm_buf_t *bp;
thread_t phandle;
pthread_t phandle;
pthread_attr_t tattr;
int pstatus;
long i;
unsigned long pid;
char *data;
if ( newFile ) {
@ -602,12 +607,13 @@ long buf_Init(int newFile, cm_buf_ops_t *opsp, afs_uint64 nbuffers)
osi_EndOnce(&once);
/* and create the incr-syncer */
phandle = thrd_Create(0, 0,
(ThreadFunc) buf_IncrSyncer, 0, 0, &pid,
"buf_IncrSyncer");
pthread_attr_init(&tattr);
pthread_attr_setdetachstate(&tattr, PTHREAD_CREATE_DETACHED);
osi_assertx(phandle != NULL, "buf: can't create incremental sync proc");
CloseHandle(phandle);
pstatus = pthread_create(&phandle, &tattr, buf_IncrSyncer, 0);
osi_assertx(pstatus == 0, "buf: can't create incremental sync proc");
pthread_attr_destroy(&tattr);
}
#ifdef TESTING