@@ -54,6 +54,7 @@ typedef struct DtmTransStatus
5454typedef struct
5555{
5656cid_t cid ;
57+ long time_shift ;
5758volatile slock_t lock ;
5859DtmTransStatus * trans_list_head ;
5960DtmTransStatus * * trans_list_tail ;
@@ -105,7 +106,7 @@ static timestamp_t dtm_get_current_time()
105106{
106107struct timeval tv ;
107108gettimeofday (& tv ,NULL );
108- return (timestamp_t )tv .tv_sec * USEC + tv .tv_usec ;
109+ return (timestamp_t )tv .tv_sec * USEC + tv .tv_usec + local -> time_shift ;
109110}
110111
111112static void dtm_sleep (timestamp_t interval )
@@ -136,6 +137,11 @@ static cid_t dtm_get_cid()
136137static cid_t dtm_sync (cid_t global_cid )
137138{
138139cid_t local_cid ;
140+ #if 1
141+ while ((local_cid = dtm_get_cid ())< global_cid ) {
142+ local -> time_shift += global_cid - local_cid ;
143+ }
144+ #else
139145while ((local_cid = dtm_get_cid ())< global_cid ) {
140146SpinLockRelease (& local -> lock );
141147#if TRACE_SLEEP_TIME
@@ -160,6 +166,7 @@ static cid_t dtm_sync(cid_t global_cid)
160166#endif
161167SpinLockAcquire (& local -> lock );
162168 }
169+ #endif
163170return global_cid ;
164171}
165172
@@ -525,6 +532,7 @@ void DtmInitialize()
525532local = (DtmNodeState * )ShmemInitStruct ("dtm" ,sizeof (DtmNodeState ),& found );
526533if (!found )
527534{
535+ local -> time_shift = 0 ;
528536local -> cid = dtm_get_current_time ();
529537local -> trans_list_head = NULL ;
530538local -> trans_list_tail = & local -> trans_list_head ;