174a2c4518
git-svn-id: https://yap.svn.sf.net/svnroot/yap/trunk@1628 b08c6af1-5177-4d33-ba66-4b1c6b8b522a
245 lines
7.1 KiB
C
245 lines
7.1 KiB
C
#include "myddas_structs.h"
|
|
#include "myddas_statistics.h"
|
|
#include "Yap.h"
|
|
#include <stdlib.h>
|
|
#include <sys/time.h>
|
|
|
|
#if defined MYDDAS_ODBC || defined MYDDAS_MYSQL
|
|
|
|
#if defined MYDDAS_STATS || defined MYDDAS_TOP_LEVEL
|
|
static void
|
|
myddas_stats_time_subtract (unsigned long *, unsigned long *, MYDDAS_STATS_TIME, MYDDAS_STATS_TIME);
|
|
static void
|
|
myddas_stats_add_seconds_time(MYDDAS_STATS_TIME,unsigned long, unsigned long);
|
|
static void
|
|
myddas_stats_integrity_of_time(MYDDAS_STATS_TIME);
|
|
#endif
|
|
|
|
|
|
/* Documentation: Time Units
|
|
------------------------------------------------------------------------
|
|
*****| Second(s) | MiliSeconds(ms) | MicroSeconds(us) | NanoSecond(ns) |
|
|
-----|-----------|-----------------|------------------|----------------|
|
|
s | 1 | 0.001 | 0.000001 | 1e-9 |
|
|
ms | 1000 | 1 | 0.001 | 0.000001 |
|
|
us | 10000000 | 1000 | 1 | 0.001 |
|
|
ns |1000000000 | 1000000 | 1000 | 1 |
|
|
------------------------------------------------------------------------
|
|
|
|
------
|
|
|
|
The struct timeval structure represents an elapsed time. It is
|
|
declared in `sys/time.h' and has the following members:
|
|
|
|
long int tv_sec -> This represents the number of whole seconds of
|
|
elapsed time.
|
|
|
|
long int tv_usec -> This is the rest of the elapsed time (a fraction
|
|
of a second), represented as the number of microseconds. It is
|
|
always less than one million.
|
|
|
|
|
|
------
|
|
|
|
The struct timespec structure represents an elapsed time. It is
|
|
declared in `time.h' and has the following members:
|
|
|
|
long int tv_sec -> This represents the number of whole seconds of
|
|
elapsed time.
|
|
|
|
long int tv_nsec -> This is the rest of the elapsed time (a fraction
|
|
of a second), represented as the number of nanoseconds. It is
|
|
always less than one billion.
|
|
|
|
-----
|
|
|
|
The gettimeofday() function shall obtain the current time,
|
|
expressed as seconds and microseconds since the Epoch, and store
|
|
it in the timeval structure pointed to by tp. The resolution of
|
|
the system clock is unspecified.
|
|
|
|
If tzp is not a null pointer, the behavior is unspecified.
|
|
|
|
*/
|
|
|
|
#if defined MYDDAS_STATS || defined MYDDAS_TOP_LEVEL
|
|
|
|
|
|
/* Be shore to delete MYDDAS_STATS_TIME structure */
|
|
MYDDAS_STATS_TIME
|
|
myddas_stats_walltime(void) {
|
|
|
|
MYDDAS_STATS_TIME myddas_time;
|
|
myddas_time = (MYDDAS_STATS_TIME) malloc (sizeof(struct timeval));
|
|
myddas_time->type = time_copy;
|
|
|
|
struct timeval time;
|
|
gettimeofday(&time,NULL);
|
|
|
|
myddas_time->u.time_copy.tv_sec = time.tv_sec;
|
|
myddas_time->u.time_copy.tv_usec = time.tv_usec;
|
|
|
|
return myddas_time;
|
|
}
|
|
|
|
void
|
|
myddas_stats_add_time(MYDDAS_STATS_TIME sum, MYDDAS_STATS_TIME time1,MYDDAS_STATS_TIME time2){
|
|
|
|
if (sum->type == time_final){
|
|
sum->u.time_final.microseconds =
|
|
time1->u.time_final.microseconds +
|
|
time2->u.time_final.microseconds;
|
|
sum->u.time_final.miliseconds =
|
|
time1->u.time_final.miliseconds +
|
|
time2->u.time_final.miliseconds;
|
|
sum->u.time_final.seconds =
|
|
time1->u.time_final.seconds +
|
|
time2->u.time_final.seconds;
|
|
sum->u.time_final.minutes =
|
|
time1->u.time_final.minutes +
|
|
time2->u.time_final.minutes;
|
|
sum->u.time_final.hours =
|
|
time1->u.time_final.hours +
|
|
time2->u.time_final.hours;
|
|
} else {
|
|
sum->u.time_copy.tv_sec =
|
|
time1->u.time_copy.tv_sec +
|
|
time2->u.time_copy.tv_sec;
|
|
sum->u.time_copy.tv_usec =
|
|
time1->u.time_copy.tv_usec +
|
|
time2->u.time_copy.tv_usec;
|
|
}
|
|
|
|
myddas_stats_integrity_of_time(sum);
|
|
}
|
|
|
|
|
|
void
|
|
myddas_stats_subtract_time(MYDDAS_STATS_TIME result, MYDDAS_STATS_TIME t1,MYDDAS_STATS_TIME t2){
|
|
|
|
if (result->type == time_copy){
|
|
|
|
unsigned long sec;
|
|
unsigned long usec;
|
|
myddas_stats_time_subtract(&sec,&usec,t1,t2);
|
|
|
|
result->u.time_copy.tv_sec = sec;
|
|
result->u.time_copy.tv_usec = usec;
|
|
|
|
} else {
|
|
|
|
}
|
|
|
|
}
|
|
|
|
void
|
|
myddas_stats_move_time(MYDDAS_STATS_TIME from,
|
|
MYDDAS_STATS_TIME to)
|
|
{
|
|
if (from->type == time_copy)
|
|
{
|
|
to->type = time_copy;
|
|
to->u.time_copy.tv_sec = from->u.time_copy.tv_sec;
|
|
to->u.time_copy.tv_usec = from->u.time_copy.tv_usec;
|
|
}
|
|
else if (from->type == time_final)
|
|
{
|
|
to->u.time_final.hours = from->u.time_final.hours;
|
|
to->u.time_final.minutes = from->u.time_final.minutes;
|
|
to->u.time_final.seconds = from->u.time_final.seconds;
|
|
to->u.time_final.miliseconds = from->u.time_final.miliseconds;
|
|
to->u.time_final.microseconds = from->u.time_final.microseconds;
|
|
}
|
|
free(from);
|
|
}
|
|
|
|
MYDDAS_STATS_TIME
|
|
myddas_stats_time_copy_to_final(MYDDAS_STATS_TIME t_copy){
|
|
|
|
MYDDAS_STATS_TIME t_final;
|
|
MYDDAS_STATS_INITIALIZE_TIME_STRUCT(t_final,time_final);
|
|
|
|
myddas_stats_add_seconds_time(t_final,
|
|
t_copy->u.time_copy.tv_sec,
|
|
t_copy->u.time_copy.tv_usec);
|
|
free(t_copy);
|
|
return t_final;
|
|
}
|
|
|
|
static void
|
|
myddas_stats_add_seconds_time(MYDDAS_STATS_TIME myddas_time,
|
|
unsigned long sec,
|
|
unsigned long usec){
|
|
|
|
short hours = sec / 3600;
|
|
sec %= 3600;
|
|
short minutes = sec / 60;
|
|
sec %= 60;
|
|
short milisec = usec / 1000;
|
|
usec %= 1000;
|
|
|
|
myddas_time->u.time_final.microseconds += usec ;
|
|
myddas_time->u.time_final.miliseconds += milisec;
|
|
myddas_time->u.time_final.seconds += sec ;
|
|
myddas_time->u.time_final.minutes += minutes ;
|
|
myddas_time->u.time_final.hours += hours;
|
|
|
|
myddas_stats_integrity_of_time(myddas_time);
|
|
}
|
|
|
|
|
|
static void
|
|
myddas_stats_time_subtract(unsigned long *sec,unsigned long *usec,
|
|
MYDDAS_STATS_TIME start, MYDDAS_STATS_TIME end){
|
|
|
|
/* Perform the carry for the later subtraction by updating y. */
|
|
if (start->u.time_copy.tv_usec < end->u.time_copy.tv_usec) {
|
|
int nsec = (end->u.time_copy.tv_usec - start->u.time_copy.tv_usec) / 1000000 + 1;
|
|
end->u.time_copy.tv_usec -= 1000000 * nsec;
|
|
end->u.time_copy.tv_sec += nsec;
|
|
}
|
|
if (start->u.time_copy.tv_usec - end->u.time_copy.tv_usec > 1000000) {
|
|
int nsec = (start->u.time_copy.tv_usec - end->u.time_copy.tv_usec) / 1000000;
|
|
end->u.time_copy.tv_usec += 1000000 * nsec;
|
|
end->u.time_copy.tv_sec -= nsec;
|
|
}
|
|
|
|
/* Compute the time remaining to wait.
|
|
tv_usec is certainly positive. */
|
|
*sec = start->u.time_copy.tv_sec - end->u.time_copy.tv_sec;
|
|
*usec = start->u.time_copy.tv_usec - end->u.time_copy.tv_usec;
|
|
}
|
|
|
|
static void
|
|
myddas_stats_integrity_of_time(MYDDAS_STATS_TIME myddas_time){
|
|
|
|
if (myddas_time->u.time_final.microseconds > 999)
|
|
{
|
|
myddas_time->u.time_final.microseconds -= 1000;
|
|
myddas_time->u.time_final.miliseconds++;
|
|
}
|
|
if (myddas_time->u.time_final.miliseconds > 999)
|
|
{
|
|
myddas_time->u.time_final.miliseconds -= 1000;
|
|
myddas_time->u.time_final.seconds++;
|
|
}
|
|
|
|
if (myddas_time->u.time_final.seconds > 59)
|
|
{
|
|
myddas_time->u.time_final.seconds -= 60;
|
|
myddas_time->u.time_final.minutes++;
|
|
}
|
|
|
|
if (myddas_time->u.time_final.minutes > 59)
|
|
{
|
|
myddas_time->u.time_final.minutes -= 60;
|
|
myddas_time->u.time_final.hours++;
|
|
}
|
|
}
|
|
|
|
|
|
#endif /* MYDDAS_STATS || MYDDAS_TOP_LEVEL */
|
|
|
|
#endif
|
|
|