| /dports/biology/ncbi-cxx-toolkit/ncbi_cxx--25_2_0/src/app/netcache/ |
| H A D | srv_inlines.hpp | 79 CSrvTime::CSrvTime(void) in CSrvTime() function in CSrvTime
85 CSrvTime::CSrvTime(Uint8 sec) in CSrvTime() function in CSrvTime
122 CSrvTime::Compare(const CSrvTime& t) const in Compare()
136 CSrvTime::operator+= (const CSrvTime& t) in operator +=()
148 CSrvTime::operator-= (const CSrvTime& t) in operator -=()
177 CSrvTime::CSrvTime(void) in CSrvTime() function in CSrvTime
180 CSrvTime::CSrvTime(Uint8) in CSrvTime() function in CSrvTime
216 CSrvTime::Compare(const CSrvTime& t) const in Compare()
222 CSrvTime::operator+= (const CSrvTime& t) in operator +=()
228 CSrvTime::operator-= (const CSrvTime& t) in operator -=()
[all …]
|
| H A D | srv_time.hpp | 57 class CSrvTime : public timespec class
59 class CSrvTime
69 static CSrvTime Current(void);
76 CSrvTime(void);
77 CSrvTime(Uint8 sec);
89 int Compare(const CSrvTime& t) const;
93 CSrvTime& operator+= (const CSrvTime& t);
96 CSrvTime& operator-= (const CSrvTime& t);
98 bool operator> (const CSrvTime& t) const;
99 bool operator>= (const CSrvTime& t) const;
[all …]
|
| H A D | time_man.cpp | 51 CSrvTime s_SrvStartTime;
52 CSrvTime s_LastJiffyTime;
54 CSrvTime s_JiffyTime;
63 CSrvTime srv_t = CSrvTime::Current(); in s_InitTZAdjustment()
80 s_LastJiffyTime = s_SrvStartTime = CSrvTime::Current(); in InitTime()
112 s_LastJiffyTime = CSrvTime::Current(); in IncCurJiffies()
155 CSrvTime::Print(char* buf, EFormatType fmt) const in Print()
222 CSrvTime::TZAdjustment(void) in TZAdjustment()
|
| H A D | srv_sync.cpp | 60 CFutex::WaitValueChange(int old_value, const CSrvTime& timeout) in WaitValueChange()
63 CSrvTime start_time = CSrvTime::Current(); in WaitValueChange()
64 CSrvTime left_time = timeout; in WaitValueChange()
83 CSrvTime spent_time = CSrvTime::Current(); in WaitValueChange()
|
| H A D | scheduler.cpp | 94 CSrvTime jfy_start_time;
95 CSrvTime last_exec_time;
113 extern CSrvTime s_JiffyTime;
392 CSrvTime cur_time = CSrvTime::Current(); in SchedStartJiffy()
393 CSrvTime jiffy_time = cur_time; in SchedStartJiffy()
420 CSrvTime idle_time = cur_time; in SchedStartJiffy()
439 CSrvTime cur_time = CSrvTime::Current(); in SchedIsAllIdle()
532 CSrvTime start_time = CSrvTime::Current(); in SchedExecuteTask()
534 CSrvTime end_time = CSrvTime::Current(); in SchedExecuteTask()
551 CSrvTime start_time = CSrvTime::Current(); in SchedExecuteTask()
[all …]
|
| H A D | threads_man.cpp | 75 extern CSrvTime s_JiffyTime;
158 if (thr->seen_secs == CSrvTime::CurSecs()) in s_PerJiffyTasks_Main()
160 thr->seen_secs = CSrvTime::CurSecs(); in s_PerJiffyTasks_Main()
178 if (thr->seen_secs == CSrvTime::CurSecs()) in s_PerJiffyTasks_Service()
180 thr->seen_secs = CSrvTime::CurSecs(); in s_PerJiffyTasks_Service()
209 if (thr->seen_secs == CSrvTime::CurSecs()) in s_PerJiffyTasks_Worker()
211 thr->seen_secs = CSrvTime::CurSecs(); in s_PerJiffyTasks_Worker()
321 CSrvTime next_jfy_time = CSrvTime::Current(); in s_ServiceThreadMain()
334 CSrvTime cur_time = CSrvTime::Current(); in s_ServiceThreadMain()
336 CSrvTime wait_time = next_jfy_time; in s_ServiceThreadMain()
|
| H A D | nc_stat.cpp | 66 typedef map<Uint8, CSrvTime> TSyncTimes;
83 time_t cur_secs = CSrvTime::CurSecs(); in s_InitPeriodsCollected()
103 time_t cur_secs = CSrvTime::CurSecs() + CSrvTime::TZAdjustment(); in s_CheckTZChange()
114 time_t cur_secs = CSrvTime::CurSecs() + CSrvTime::TZAdjustment(); in s_SetCurMonthSize()
703 CSrvTime t; in PrintToLogs()
779 t.Print(buf, CSrvTime::eFmtLogging); in PrintToLogs()
784 t.Print(buf, CSrvTime::eFmtLogging); in PrintToLogs()
874 CSrvTime t; in PrintToSocket()
883 CSrvTime( CNCBlobStorage::GetLatestBlobExpire()).Print( buf, CSrvTime::eFmtHumanSeconds); in PrintToSocket()
1184 time_t cur_secs = CSrvTime::CurSecs(); in CalcNextRun()
[all …]
|
| H A D | periodic_sync.cpp | 285 last_active_time(CSrvTime::Current().Sec()), in SSyncSlotSrv()
640 m_LoopStart = CSrvTime::Current().AsUSec(); in x_StartScanSlots()
739 Uint8 now = CSrvTime::Current().AsUSec(); in x_FinishScanSlots()
784 m_StartTime = CSrvTime::Current().AsUSec(); in x_DoPeriodicSync()
1516 CSrvTime((*c)->m_StartTime / kUSecsPerSecond).Print(buf, CSrvTime::eFmtJson); in PrintState()
1518 CSrvTime((*c)->m_LoopStart / kUSecsPerSecond).Print(buf, CSrvTime::eFmtJson); in PrintState()
1533 CSrvTime((*c)->m_LastActive).Print(buf, CSrvTime::eFmtJson); in PrintState()
1546 CSrvTime((*h)->m_LastActive).Print(buf, CSrvTime::eFmtJson); in PrintState()
1614 CSrvTime((*srv)->next_sync_time / kUSecsPerSecond).Print(buf, CSrvTime::eFmtJson); in PrintState()
1616 CSrvTime((*srv)->last_active_time).Print(buf, CSrvTime::eFmtJson); in PrintState()
[all …]
|
| H A D | nc_utils.cpp | 111 m_LastDetectedTimestamp(CSrvTime::Current()), in NCAlertData()
116 m_LastDetectedTimestamp = CSrvTime::Current(); in Update()
123 m_AcknowledgedTimestamp = CSrvTime::Current(); in Acknowledge()
132 CSrvTime m_LastDetectedTimestamp;
133 CSrvTime m_AcknowledgedTimestamp;
153 m_LastDetectedTimestamp.Print(time_buf, CSrvTime::eFmtHumanSeconds); in Report()
159 if (m_AcknowledgedTimestamp.Compare(CSrvTime()) == 0) { in Report()
163 m_AcknowledgedTimestamp.Print(time_buf, CSrvTime::eFmtHumanSeconds); in Report()
|
| H A D | timers.cpp | 77 int cur_time = CSrvTime::CurSecs(); in s_AddTimerTicket()
151 s_LastFiredTime = CSrvTime::CurSecs(); in InitTimers()
158 int cur_time = CSrvTime::CurSecs(); in FireAllTimers()
180 int cur_time = CSrvTime::CurSecs(); in TimerTick()
221 ticket->timer_time = CSrvTime::CurSecs() + delay_sec; in RunAfter()
|
| H A D | srv_tasks.cpp | 63 m_LastActive(CSrvTime::CurSecs()), in CSrvTask()
102 m_LastActive = CSrvTime::CurSecs(); in InternalRunSlice()
104 m_LastActive = CSrvTime::CurSecs(); in InternalRunSlice()
116 int now = CSrvTime::CurSecs(); in PrintState()
|
| H A D | sockets_man.cpp | 170 extern CSrvTime s_JiffyTime;
574 CSrvTime cmd_start = CSrvTime::Current(); in s_ProcessListenEvent()
580 CSrvTime cmd_len = CSrvTime::Current(); in s_ProcessListenEvent()
583 cmd_start = CSrvTime::Current(); in s_ProcessListenEvent()
626 CSrvTime wait_time = s_JiffyTime; in DoSocketWait()
698 task->m_LastActive = CSrvTime::CurSecs(); in s_SaveSocket()
717 int limit_time = CSrvTime::CurSecs() - s_SocketTimeout; in s_DeleteOldestSockets()
1364 m_LastActive = CSrvTime::CurSecs(); in InternalRunSlice()
1379 m_ProxyDst->m_LastActive = CSrvTime::CurSecs(); in InternalRunSlice()
1421 m_LastActive = CSrvTime::CurSecs(); in InternalRunSlice()
|
| H A D | task_server.hpp | 59 class CSrvTime;
194 static CSrvTime GetStartTime(void);
|
| H A D | nc_storage_blob.hpp | 416 return m_CurData->expire <= CSrvTime::CurSecs(); in IsCurBlobExpired()
422 return m_CurData->ver_expire <= CSrvTime::CurSecs(); in IsCurVerExpired()
427 return m_CurData->dead_time < CSrvTime::CurSecs(); in IsCurBlobDead()
561 m_CurData->update_received = CSrvTime().Current().AsUSec(); in UpdateMetaInfo()
|
| H A D | nc_storage_blob.cpp | 558 Uint8 tdiff = CSrvTime::Current().AsUSec() - create_time; in StartSyncBlob()
811 int cur_time = CSrvTime::CurSecs(); in ExecuteSlice()
890 && m_CurVersion->dead_time <= CSrvTime::CurSecs()) in GetCurVersion()
927 if (ver_data->dead_time > CSrvTime::CurSecs() in FinalizeWriting()
946 m_CurVersion->last_access_time = CSrvTime::CurSecs(); in FinalizeWriting()
1012 ver_data->last_access_time = CSrvTime::CurSecs(); in ExecuteSlice()
1211 last_access_time = CSrvTime::CurSecs(); in SetReleasable()
1223 last_access_time = CSrvTime::CurSecs(); in SetNonReleasable()
1785 Uint8 now = CSrvTime::Current().AsUSec(); in Purge()
2021 int expire = CSrvTime::CurSecs() - 1; in x_RemoveBlob()
[all …]
|
| H A D | netcached.cpp | 1003 CSrvTime cur_time = CSrvTime::Current(); in GetUpTime()
1196 CSrvTime m_CmdStartTime;
1321 CSrvTime to; in IsTaskPaused()
1350 if (s_ftxStop.WaitValueChange(0, CSrvTime()) == CFutex::eTimedOut) { in IsTaskPaused()
1384 cout << "state_time = " << CSrvTime::CurSecs() << endl; in PrintStat()
1399 m_CmdStartTime = CSrvTime::Current(); in x_Start()
1466 CSrvTime cur_srv_time = CSrvTime::Current(); in x_PutEnd()
1501 int expire = CSrvTime::CurSecs() - 1; in x_Remove()
1511 CSrvTime cur_srv_time = CSrvTime::Current(); in x_Remove()
1539 CSrvTime cmd_len = CSrvTime::Current(); in x_Finalize()
|
| H A D | srv_sync.hpp | 41 class CSrvTime;
176 EWaitResult WaitValueChange(int old_value, const CSrvTime& timeout);
|
| H A D | logging.cpp | 48 extern CSrvTime s_JiffyTime;
209 s_LastReopenTime = CSrvTime::CurSecs(); in s_WriteLog()
254 data->last_flush_time = CSrvTime::CurSecs(); in s_RotateLogBuf()
393 CSrvTime cur_time = CSrvTime::Current(); in s_AddLogPrefix()
397 Uint1 len = cur_time.Print(data->cur_ptr, CSrvTime::eFmtLogging); in s_AddLogPrefix()
592 CSrvTime cur_time = CSrvTime::Current(); in FinalizeLogging()
624 int cur_time = CSrvTime::CurSecs(); in CheckLoggingFlush()
1436 if (CSrvTime::CurSecs() - s_LastReopenTime >= s_FileReopenPeriod && s_LogFd != -1) in ExecuteSlice()
|
| H A D | server_core.cpp | 70 static CSrvTime s_ShutdownStartTime;
117 CSrvTime diff_time = CSrvTime::Current(); in TrackShuttingDown()
|
| H A D | message_handler.cpp | 2736 CSrvTime cmd_now = CSrvTime::Current(); in x_LogCmdEvent()
2737 CSrvTime cmd_len = cmd_now; in x_LogCmdEvent()
2739 CSrvTime cmd_time = cmd_now; in x_LogCmdEvent()
2875 CSrvTime cur_srv_time = CSrvTime::Current(); in x_ProlongBlobDeadTime()
2914 CSrvTime cur_srv_time = CSrvTime::Current(); in x_ProlongVersionLife()
3014 CSrvTime cmd_len = CSrvTime::Current(); in x_CleanCmdResources()
3128 CSrvTime cur_srv_time = CSrvTime::Current(); in x_FinishReadingBlob()
3755 CSrvTime cur_srv_time = CSrvTime::Current(); in x_ExecuteOnLatestSrvId()
4438 int expire = CSrvTime::CurSecs() - 1; in x_DoCmd_Remove()
4823 CSrvTime t; in x_DoCmd_GetMeta()
[all …]
|
| H A D | nc_stat.hpp | 48 state_time = CSrvTime::Current(); in SNCStateStat()
50 CSrvTime state_time;
|
| H A D | peer_control.cpp | 226 m_FirstNWErrTime = CSrvTime::Current().AsUSec(); in RegisterConnError()
230 m_ThrottleStart = CSrvTime::Current().AsUSec(); in RegisterConnError()
264 Uint8 cur_time = CSrvTime::Current().AsUSec(); in CreateNewSocket()
317 conn->m_LastActive = CSrvTime::CurSecs(); in x_GetPooledConnImpl()
443 conn->m_LastActive = CSrvTime::CurSecs(); in x_CreateNewConn()
705 Uint8 cur_time = CSrvTime::Current().AsUSec(); in x_AddMirrorEvent()
1004 Uint8 now = CSrvTime::Current().AsUSec(); in RegisterSyncStop()
|
| H A D | nc_storage.cpp | 1466 CSrvTime( expire).Print( buf, CSrvTime::eFmtJson); in WriteBlobStat()
1560 int now = CSrvTime::CurSecs(); in WriteDbInfo()
1734 CSrvTime(it->second->create_time).Print(buf, CSrvTime::eFmtJson); in WriteDbInfo()
1736 CSrvTime(it->second->next_shrink_time).Print(buf, CSrvTime::eFmtJson); in WriteDbInfo()
2816 int res = CSrvTime::CurSecs(); in GetLatestBlobExpire()
3814 m_StartTime = CSrvTime::CurSecs(); in x_StartSession()
4163 int cur_time = CSrvTime::CurSecs(); in x_PrepareToShrink()
4261 m_StartTime = CSrvTime::CurSecs(); in x_StartMoves()
4290 int cur_time = CSrvTime::CurSecs(); in x_MoveNextRecord()
4610 int cur_time = CSrvTime::CurSecs(); in ExecuteSlice()
[all …]
|
| H A D | message_handler.hpp | 332 CSrvTime m_CmdStartTime;
333 CSrvTime m_CmdPrevTime;
|
| H A D | nc_db_files.cpp | 92 stmt.Bind(3, CSrvTime::CurSecs()); in NewDBFile()
|