jimzah/openafs
1
0
Fork 0
mirror of https://git.openafs.org/openafs.git synced 2025-02-01 05:57:43 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

STABLE14-windows-ip-change-20051018

Browse Source 
add a monitor to watch for IP Address changes.  When a change is detected,
wait 2.5 seconds for things to settle down and then check to see if down
servers are reachable.


(cherry picked from commit a923af27265c8d0aa359d57c8c47b50eb0dbeee3)
This commit is contained in:
Jeffrey Altman 2005-10-18 21:51:01 +00:00
parent d2b95196a4
commit 8b2b6569d6
1 changed files with 36 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

39
src/WINNT/afsd/cm_daemon.c
View File

@ -13,6 +13,7 @@
#ifndef DJGPP
#include <windows.h>
#include <winsock2.h>
#include <iphlpapi.h>
#else
#include <netdb.h>
#endif /* !DJGPP */
@ -40,6 +41,22 @@ cm_bkgRequest_t *cm_bkgListEndp; /* last elt in the list of requests */
static int daemon_ShutdownFlag = 0;
#ifndef DJGPP
void cm_IpAddrDaemon(long parm)
{
rx_StartClientThread();
while (daemon_ShutdownFlag == 0) {
DWORD Result = NotifyAddrChange(NULL,NULL);
if (Result == NO_ERROR && daemon_ShutdownFlag == 0) {
osi_Log0(afsd_logp, "cm_IpAddrDaemon CheckDownServers");
Sleep(2500);
cm_CheckServers(CM_FLAG_CHECKDOWNSERVERS, NULL);
}
}
}
#endif
void cm_BkgDaemon(long parm)
{
cm_bkgRequest_t *rp;
@ -226,33 +243,41 @@ void cm_Daemon(long parm)
/* check down servers */
if (now > lastDownServerCheck + cm_daemonCheckInterval) {
lastDownServerCheck = now;
osi_Log0(afsd_logp, "cm_Daemon CheckDownServers");
cm_CheckServers(CM_FLAG_CHECKDOWNSERVERS, NULL);
now = osi_Time();
}
/* check up servers */
if (now > lastUpServerCheck + 3600) {
lastUpServerCheck = now;
osi_Log0(afsd_logp, "cm_Daemon CheckUpServers");
cm_CheckServers(CM_FLAG_CHECKUPSERVERS, NULL);
now = osi_Time();
}
if (now > lastVolCheck + 3600) {
lastVolCheck = now;
cm_CheckVolumes();
now = osi_Time();
}
if (now > lastCBExpirationCheck + 60) {
lastCBExpirationCheck = now;
cm_CheckCBExpiration();
now = osi_Time();
}
if (now > lastLockCheck + 60) {
lastLockCheck = now;
cm_CheckLocks();
now = osi_Time();
}
if (now > lastTokenCacheCheck + cm_daemonTokenCheckInterval) {
lastTokenCacheCheck = now;
cm_CheckTokenCache(now);
now = osi_Time();
}
/* allow an exit to be called prior to stopping the service */
@ -291,14 +316,22 @@ void cm_InitDaemon(int nDaemons)
if (osi_Once(&once)) {
lock_InitializeRWLock(&cm_daemonLock, "cm_daemonLock");
osi_EndOnce(&once);
#ifndef DJGPP
/* creating IP Address Change monitor daemon */
phandle = thrd_Create((SecurityAttrib) 0, 0,
(ThreadFunc) cm_IpAddrDaemon, 0, 0, &pid, "cm_IpAddrDaemon");
osi_assert(phandle != NULL);
thrd_CloseHandle(phandle);
#endif /* DJGPP */
/* creating pinging daemon */
phandle = thrd_Create((SecurityAttrib) 0, 0,
(ThreadFunc) cm_Daemon, 0, 0, &pid, "cm_Daemon");
osi_assert(phandle != NULL);
thrd_CloseHandle(phandle);
for(i=0; i < nDaemons; i++) {
for(i=0; i < nDaemons; i++) {
phandle = thrd_Create((SecurityAttrib) 0, 0,
(ThreadFunc) cm_BkgDaemon, 0, 0, &pid,
"cm_BkgDaemon");