Merge release-7.1 into master
This commit is contained in:
commit
3dd7349c99
|
@ -117,7 +117,7 @@
|
||||||
<version>1.0.1</version>
|
<version>1.0.1</version>
|
||||||
</artifactItem>
|
</artifactItem>
|
||||||
<artifactItem>
|
<artifactItem>
|
||||||
<groupId>woodstox</groupId>
|
<groupId>org.codehaus.woodstox</groupId>
|
||||||
<artifactId>wstx-asl</artifactId>
|
<artifactId>wstx-asl</artifactId>
|
||||||
<version>3.2.7</version>
|
<version>3.2.7</version>
|
||||||
</artifactItem>
|
</artifactItem>
|
||||||
|
|
|
@ -191,19 +191,23 @@ public class AtmosphereServerPush implements ServerPush {
|
||||||
log.error(e.getMessage(), e);
|
log.error(e.getMessage(), e);
|
||||||
}
|
}
|
||||||
if (!ok) {
|
if (!ok) {
|
||||||
try {
|
for(int i = 0; i < 3 && !ok; i++) {
|
||||||
Thread.sleep(500);
|
|
||||||
} catch (InterruptedException e1) {}
|
|
||||||
if (schedules.size() > 0) {
|
|
||||||
try {
|
try {
|
||||||
ok = commitResponse();
|
Thread.sleep(500);
|
||||||
} catch (IOException e) {
|
} catch (InterruptedException e1) {}
|
||||||
log.error(e.getMessage(), e);
|
if (schedules.size() > 0) {
|
||||||
}
|
try {
|
||||||
if (!ok) {
|
ok = commitResponse();
|
||||||
log.warn("Failed to resume long polling resource");
|
} catch (IOException e) {
|
||||||
}
|
log.error(e.getMessage(), e);
|
||||||
}
|
}
|
||||||
|
} else {
|
||||||
|
ok = true;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if (!ok) {
|
||||||
|
log.warn("Failed to resume long polling resource");
|
||||||
|
}
|
||||||
}
|
}
|
||||||
} else {
|
} else {
|
||||||
//in event listener thread, can schedule immediately
|
//in event listener thread, can schedule immediately
|
||||||
|
@ -252,12 +256,6 @@ public class AtmosphereServerPush implements ServerPush {
|
||||||
log.trace(resource.transport().name());
|
log.trace(resource.transport().name());
|
||||||
}
|
}
|
||||||
|
|
||||||
try {
|
|
||||||
commitResponse();
|
|
||||||
} catch (IOException e) {
|
|
||||||
log.error(e.getLocalizedMessage(), e);
|
|
||||||
}
|
|
||||||
|
|
||||||
DesktopCtrl desktopCtrl = (DesktopCtrl) this.desktop.get();
|
DesktopCtrl desktopCtrl = (DesktopCtrl) this.desktop.get();
|
||||||
if (desktopCtrl == null) {
|
if (desktopCtrl == null) {
|
||||||
log.error("No desktop available");
|
log.error("No desktop available");
|
||||||
|
|
Loading…
Reference in New Issue