fix bug to allow pool shutdown and restart in running app

gwhalin · gwhalin · commit 68da1e6f7b49 · 2008-01-12T17:47:51.000Z
diff --git a/src/com/danga/MemCached/SockIOPool.java b/src/com/danga/MemCached/SockIOPool.java
@@ -1210,7 +1210,6 @@ public void shutDown() {
 				while ( maintThread.isRunning() ) {
 					log.debug( "++++ waiting for main thread to finish run +++" );
 					try { Thread.sleep( 500 ); } catch ( Exception ex ) { }
-
 				}
 			}
 
@@ -1223,6 +1222,7 @@ public void shutDown() {
 			consistentBuckets = null;
 			hostDeadDur       = null;
 			hostDead          = null;
+			maintThread       = null;
 			initialized       = false;
 			log.debug( "++++ SockIOPool finished shutting down." );
 		}

Original file line number	Diff line number	Diff line change
`@@ -1210,7 +1210,6 @@ public void shutDown() {`
`1210`	`1210`	`while ( maintThread.isRunning() ) {`
`1211`	`1211`	`log.debug( "++++ waiting for main thread to finish run +++" );`
`1212`	`1212`	`try { Thread.sleep( 500 ); } catch ( Exception ex ) { }`
`1213`		`-`
`1214`	`1213`	`}`
`1215`	`1214`	`}`
`1216`	`1215`
`@@ -1223,6 +1222,7 @@ public void shutDown() {`
`1223`	`1222`	`consistentBuckets = null;`
`1224`	`1223`	`hostDeadDur = null;`
`1225`	`1224`	`hostDead = null;`
	`1225`	`+ maintThread = null;`
`1226`	`1226`	`initialized = false;`
`1227`	`1227`	`log.debug( "++++ SockIOPool finished shutting down." );`
`1228`	`1228`	`}`