GeezerVison

The World Wide Web, restored to 800 pixels of glory.

GeezerVison is showing github.com — CLOUDSTACK-8656: debug messages on interupted exceptions · javascriptextjs/cloudstack@e2b6237

File tree

Expand file treeCollapse file tree

Open diff view settings

Filter options

agent/src/com/cloud/agent
- AgentShell.java
engine
- schema/src/com/cloud/network/security/dao
  - VmRulesetLogDaoImpl.java
- storage/cache/src/org/apache/cloudstack/storage/cache/manager
  - StorageCacheManagerImpl.java
framework
- cluster/src/com/cloud/cluster
  - ClusterServiceServletContainer.java
- db
  - src/com/cloud/utils/db
    - Merovingian2.java
  - test/com/cloud/utils/db
    - GlobalLockTest.java
- ipc
  - src/org/apache/cloudstack/framework/messagebus
    - MessageBusBase.java
    - MessageDetector.java
  - test/org/apache/cloudstack
    - framework/sampleserver
      - SampleManagementServer.java
    - messagebus
      - TestMessageBus.java
- jobs/test/org/apache/cloudstack/framework/jobs
  - AsyncJobManagerTest.java
  - AsyncJobTestDispatcher.java
plugins
- database/mysql-ha/src/com/cloud/utils/db
  - StaticStrategy.java
- hypervisors
  - baremetal/src/com/cloud/baremetal/networkservice
    - BareMetalResourceBase.java
  - hyperv/src/com/cloud/hypervisor/hyperv/resource
    - HypervDirectConnectResource.java
  - kvm/src/com/cloud/hypervisor/kvm
    - resource
      - KVMHAMonitor.java
    - storage
      - KVMStoragePoolManager.java
  - vmware/src/com/cloud/hypervisor/vmware
    - manager
      - VmwareManagerImpl.java
    - resource
      - VmwareResource.java
- network-elements/netscaler/src/com/cloud/network/resource
  - NetscalerResource.java
server/src/com/cloud
- storage/snapshot
  - SnapshotManagerImpl.java
- vm
  - SystemVmLoadScanner.java
services/console-proxy/server/src/com/cloud/consoleproxy
- ConsoleProxyClientBase.java
- ConsoleProxyGCThread.java
test/src/com/cloud/test
- regression
  - ApiCommand.java
- stress
  - StressTestDirectAttach.java
  - TestClientWithAPI.java
- utils
  - ConsoleProxy.java
vmware-base/src/com/cloud/hypervisor/vmware
- mo
  - HypervisorHostHelper.java
  - VirtualMachineMO.java
- util
  - VmwareContext.java

Expand file treeCollapse file tree

Open diff view settings

Collapse file

`‎agent/src/com/cloud/agent/AgentShell.java‎`

Copy file name to clipboardExpand all lines: agent/src/com/cloud/agent/AgentShell.java

+1Lines changed: 1 addition & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -464,6 +464,7 @@ public void start() {`
`464`	`464`	`while (!_exit)`
`465`	`465`	`Thread.sleep(1000);`
`466`	`466`	`} catch (InterruptedException e) {`
	`467`	`+ s_logger.debug("[ignored] AgentShell was interupted.");`
`467`	`468`	`}`
`468`	`469`
`469`	`470`	`} catch (final ConfigurationException e) {`

Collapse file

`‎engine/schema/src/com/cloud/network/security/dao/VmRulesetLogDaoImpl.java‎`

Copy file name to clipboardExpand all lines: engine/schema/src/com/cloud/network/security/dao/VmRulesetLogDaoImpl.java

+1-1Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -104,7 +104,7 @@ private int executeWithRetryOnDeadlock(TransactionLegacy txn, String pstmt, List`
`104`	`104`	`try {`
`105`	`105`	`Thread.sleep(delayMs);`
`106`	`106`	`} catch (InterruptedException ie) {`
`107`		`-`
	`107`	`+ s_logger.debug("[ignored] interupted while inserting security group rule log.");`
`108`	`108`	`}`
`109`	`109`	`} else`
`110`	`110`	`s_logger.warn("Caught another deadlock exception while retrying inserting security group rule log, giving up");`

Collapse file

`‎engine/storage/cache/src/org/apache/cloudstack/storage/cache/manager/StorageCacheManagerImpl.java‎`

Copy file name to clipboardExpand all lines: engine/storage/cache/src/org/apache/cloudstack/storage/cache/manager/StorageCacheManagerImpl.java

+3-1Lines changed: 3 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -274,7 +274,9 @@ public DataObject createCacheObject(DataObject data, DataStore store) {`
`274`	`274`	`s_logger.debug("waiting cache copy completion type: " + typeName + ", id: " + obj.getObjectId() + ", lock: " + lock.hashCode());`
`275`	`275`	`try {`
`276`	`276`	`lock.wait(miliSeconds);`
`277`		`- } catch (InterruptedException e) {}`
	`277`	`+ } catch (InterruptedException e) {`
	`278`	`+ s_logger.debug("[ignored] interupted while waiting for cache copy completion.");`
	`279`	`+ }`
`278`	`280`	`s_logger.debug("waken up");`
`279`	`281`
`280`	`282`	`now = new Date();`

Collapse file

`‎framework/cluster/src/com/cloud/cluster/ClusterServiceServletContainer.java‎`

Copy file name to clipboardExpand all lines: framework/cluster/src/com/cloud/cluster/ClusterServiceServletContainer.java

+1Lines changed: 1 addition & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -170,6 +170,7 @@ protected void runInContext() {`
`170`	`170`	`try {`
`171`	`171`	`Thread.sleep(1000);`
`172`	`172`	`} catch (InterruptedException e1) {`
	`173`	`+ s_logger.debug("[ignored] interupted while waiting to retry running the servlet container.");`
`173`	`174`	`}`
`174`	`175`	`}`
`175`	`176`	`}`

Collapse file

`‎framework/db/src/com/cloud/utils/db/Merovingian2.java‎`

Copy file name to clipboardExpand all lines: framework/db/src/com/cloud/utils/db/Merovingian2.java

+1Lines changed: 1 addition & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -144,6 +144,7 @@ public boolean acquire(String key, int timeInSeconds) {`
`144`	`144`	`}`
`145`	`145`	`Thread.sleep(5000);`
`146`	`146`	`} catch (InterruptedException e) {`
	`147`	`+ s_logger.debug("[ignored] interupted while aquiring " + key);`
`147`	`148`	`}`
`148`	`149`	`}`
`149`	`150`	`String msg = "Timed out on acquiring lock " + key + " . Waited for " + ((InaccurateClock.getTime() - startTime)/1000) + "seconds";`

Collapse file

`‎framework/db/test/com/cloud/utils/db/GlobalLockTest.java‎`

Copy file name to clipboardExpand all lines: framework/db/test/com/cloud/utils/db/GlobalLockTest.java

+1Lines changed: 1 addition & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -54,6 +54,7 @@ public void run() {`
`54`	`54`	`Thread.sleep(jobDuration * 1000);`
`55`	`55`	`}`
`56`	`56`	`} catch (InterruptedException e) {`
	`57`	`+ s_logger.debug("[ignored] interupted while testing global lock.");`
`57`	`58`	`} finally {`
`58`	`59`	`if (locked) {`
`59`	`60`	`boolean unlocked = WorkLock.unlock();`

Collapse file

`‎framework/ipc/src/org/apache/cloudstack/framework/messagebus/MessageBusBase.java‎`

Copy file name to clipboardExpand all lines: framework/ipc/src/org/apache/cloudstack/framework/messagebus/MessageBusBase.java

+1Lines changed: 1 addition & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -326,6 +326,7 @@ public boolean enter(boolean wait) {`
`326`	`326`	`try {`
`327`	`327`	`wait();`
`328`	`328`	`} catch (InterruptedException e) {`
	`329`	`+ s_logger.debug("[ignored] interupted while guarding re-entrance on message bus.");`
`329`	`330`	`}`
`330`	`331`	`} else {`
`331`	`332`	`break;`

Collapse file

`‎framework/ipc/src/org/apache/cloudstack/framework/messagebus/MessageDetector.java‎`

Copy file name to clipboardExpand all lines: framework/ipc/src/org/apache/cloudstack/framework/messagebus/MessageDetector.java

+1Lines changed: 1 addition & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -41,6 +41,7 @@ public void waitAny(long timeoutInMiliseconds) {`
`41`	`41`	`try {`
`42`	`42`	`wait(timeoutInMiliseconds);`
`43`	`43`	`} catch (InterruptedException e) {`
	`44`	`+ s_logger.debug("[ignored] interupted while waiting on any message.");`
`44`	`45`	`}`
`45`	`46`	`}`
`46`	`47`	`}`

Collapse file

`‎framework/ipc/test/org/apache/cloudstack/framework/sampleserver/SampleManagementServer.java‎`

Copy file name to clipboardExpand all lines: framework/ipc/test/org/apache/cloudstack/framework/sampleserver/SampleManagementServer.java

+4Lines changed: 4 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -18,13 +18,17 @@`
`18`	`18`	`*/`
`19`	`19`	`package org.apache.cloudstack.framework.sampleserver;`
`20`	`20`
	`21`	`+import org.apache.log4j.Logger;`
	`22`	`+`
`21`	`23`	`public class SampleManagementServer {`
	`24`	`+ private static final Logger s_logger = Logger.getLogger(SampleManagementServer.class);`
`22`	`25`
`23`	`26`	`public void mainLoop() {`
`24`	`27`	`while (true) {`
`25`	`28`	`try {`
`26`	`29`	`Thread.sleep(1000);`
`27`	`30`	`} catch (InterruptedException e) {`
	`31`	`+ s_logger.debug("[ignored] .");`
`28`	`32`	`}`
`29`	`33`	`}`
`30`	`34`	`}`

Collapse file

`‎framework/ipc/test/org/apache/cloudstack/messagebus/TestMessageBus.java‎`

Copy file name to clipboardExpand all lines: framework/ipc/test/org/apache/cloudstack/messagebus/TestMessageBus.java

+8-5Lines changed: 8 additions & 5 deletions

Original file line number	Diff line number	Diff line change
`@@ -22,21 +22,22 @@`
`22`	`22`
`23`	`23`	`import junit.framework.TestCase;`
`24`	`24`
	`25`	`+import org.apache.cloudstack.framework.messagebus.MessageBus;`
	`26`	`+import org.apache.cloudstack.framework.messagebus.MessageDetector;`
	`27`	`+import org.apache.cloudstack.framework.messagebus.MessageSubscriber;`
	`28`	`+import org.apache.cloudstack.framework.messagebus.PublishScope;`
	`29`	`+import org.apache.log4j.Logger;`
`25`	`30`	`import org.junit.Assert;`
`26`	`31`	`import org.junit.Test;`
`27`	`32`	`import org.junit.runner.RunWith;`
`28`	`33`	`import org.mockito.Mockito;`
`29`	`34`	`import org.springframework.test.context.ContextConfiguration;`
`30`	`35`	`import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;`
`31`	`36`
`32`		`-import org.apache.cloudstack.framework.messagebus.MessageBus;`
`33`		`-import org.apache.cloudstack.framework.messagebus.MessageDetector;`
`34`		`-import org.apache.cloudstack.framework.messagebus.MessageSubscriber;`
`35`		`-import org.apache.cloudstack.framework.messagebus.PublishScope;`
`36`		`-`
`37`	`37`	`@RunWith(SpringJUnit4ClassRunner.class)`
`38`	`38`	`@ContextConfiguration(locations = "classpath:/MessageBusTestContext.xml")`
`39`	`39`	`public class TestMessageBus extends TestCase {`
	`40`	`+ private static final Logger s_logger = Logger.getLogger(TestMessageBus.class);`
`40`	`41`
`41`	`42`	`@Inject`
`42`	`43`	`MessageBus _messageBus;`
`@@ -128,6 +129,7 @@ public void run() {`
`128`	`129`	`try {`
`129`	`130`	`Thread.sleep(3000);`
`130`	`131`	`} catch (InterruptedException e) {`
	`132`	`+ s_logger.debug("[ignored] .");`
`131`	`133`	`}`
`132`	`134`	`_messageBus.publish(null, "Host", PublishScope.GLOBAL, null);`
`133`	`135`	`}`
`@@ -148,6 +150,7 @@ public void run() {`
`148`	`150`	`try {`
`149`	`151`	`thread.join();`
`150`	`152`	`} catch (InterruptedException e) {`
	`153`	`+ s_logger.debug("[ignored] .");`
`151`	`154`	`}`
`152`	`155`	`}`
`153`	`156`	`}`

0 commit comments

Comments

0 (0)

You are visitor 01402520 — GeezerVison does not store the pages you look up.
Best viewed with Netscape Navigator 4.7 or Internet Explorer 6 at 800×600. No cookies required.