CC-tea/org-hyperion-cules
1
0
Fork 0
mirror of https://github.com/SDL-Hercules-390/hyperion.git synced 2026-04-19 10:15:56 +02:00
Code Issues Packages Projects Releases Wiki Activity

01 Sep 2006 ptt to=<timeout-in-seconds> operand - Greg Smith

Browse Source 
git-svn-id: file:///home/jj/hercules.svn/trunk@3955 956126f8-22a0-4046-8f4a-272fa8102e63
This commit is contained in:
Greg Smith
2006-09-01 22:42:45 +00:00
parent 5a04e31c96
commit 0958e2e904
2 changed files with 67 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

68
pttrace.c
View File

@@ -24,6 +24,10 @@ int pttnothreads; /* 1=no threads events */
int pttnolock; /* 1=no PTT locking */
int pttnotod; /* 1=don't call gettimeofday */
int pttnowrap; /* 1=don't wrap */
int pttto; /* timeout in seconds */
TID ptttotid; /* timeout thread id */
LOCK ptttolock; /* timeout thread lock */
COND ptttocond; /* timeout thread condition */
DLL_EXPORT void ptt_trace_init (int n, int init)
{
@@ -52,13 +56,26 @@ DLL_EXPORT void ptt_trace_init (int n, int init)
pttnolock = 0;
pttnotod = 0;
pttnowrap = 0;
pttto = 0;
ptttotid = 0;
#if defined(OPTION_FTHREADS)
fthread_mutex_init (&ptttolock, NULL);
#if defined(FISH_HANG)
fthread_cond_init (__FILE__, __LINE__, &ptttocond);
#else
fthread_cond_init (&ptttocond);
#endif
#else
pthread_mutex_init (&ptttolock, NULL);
pthread_cond_init (&ptttocond, NULL);
#endif
}
}
DLL_EXPORT int ptt_cmd(int argc, char *argv[], char* cmdline)
{
int rc = 0;
int n;
int n, to = -1;
char c;
UNREFERENCED(cmdline);
@@ -132,6 +149,12 @@ DLL_EXPORT int ptt_cmd(int argc, char *argv[], char* cmdline)
pttnowrap = 0;
continue;
}
else if (strncasecmp("to=", argv[0], 3) == 0 && strlen(argv[0]) > 3
&& (sscanf(&argv[0][3], "%d%c", &to, &c) == 1 && to >= 0))
{
pttto = to;
continue;
}
else if (argc == 1 && sscanf(argv[0], "%d%c", &n, &c) == 1 && n >= 0)
{
OBTAIN_PTTLOCK;
@@ -164,17 +187,58 @@ DLL_EXPORT int ptt_cmd(int argc, char *argv[], char* cmdline)
}
} /* for each ptt argument */
logmsg( _("HHCPT003I ptt %s %s %s %s %s %s %d\n"),
logmsg( _("HHCPT003I ptt %s %s %s %s %s %s to=%d %d\n"),
pttimer ? "timer" : "notimer",
pttnothreads ? "nothreads" : "threads",
pttnolock ? "nolock" : "lock",
pttnotod ? "notod" : "tod",
pttnowrap ? "nowrap" : "wrap",
pttlogger ? "logger" : "nologger",
pttto,
pttracen);
/* wakeup timeout thread if to= specified */
if (to >= 0 && ptttotid)
{
obtain_lock (&ptttolock);
ptttotid = 0;
signal_condition (&ptttocond);
release_lock (&ptttolock);
}
/* start timeout thread if positive to= specified */
if (to > 0)
{
obtain_lock (&ptttolock);
ptttotid = 0;
create_thread (&ptttotid, NULL, ptt_timeout, NULL, "ptt_timeout");
release_lock (&ptttolock);
}
return rc;
}
/* thread to print trace after timeout */
void *ptt_timeout()
{
struct timeval now;
struct timespec tm;
obtain_lock (&ptttolock);
gettimeofday (&now, NULL);
tm.tv_sec = now.tv_sec + pttto;
tm.tv_nsec = now.tv_usec * 1000;
timed_wait_condition (&ptttocond, &ptttolock, &tm);
if (thread_id() == ptttotid)
{
ptt_pthread_print();
pttto = 0;
ptttotid = 0;
}
release_lock (&ptttolock);
return NULL;
}
#ifndef OPTION_FTHREADS
DLL_EXPORT int ptt_pthread_mutex_init(LOCK *mutex, pthread_mutexattr_t *attr, char *file, int line)
{

1
pttrace.h
View File

@@ -64,6 +64,7 @@ PTT_DLL_IMPORT void ptt_trace_init (int n, int init);
PTT_DLL_IMPORT int ptt_cmd(int argc, char *argv[], char*cmdline);
PTT_DLL_IMPORT void ptt_pthread_trace (char *, void *, void *, char *, int, int);
PTT_DLL_IMPORT int ptt_pthread_print ();
void *ptt_timeout();
typedef struct _PTT_TRACE {
TID tid; /* Thead id */