Browse Source

Fixing issue with Push stopping working in some circumstances (#11791) (#11795)

* Fixing issue with Push stopping working in some circumstances

If new request is attempted when resynchronization is ongoing, the Push will stop working. This patch fixes the issue by aborting handleJson if resynch is already ongoing.

Fixes #11702, #7719
tags/8.9.3
Anna Koskinen 4 years ago
parent
commit
f12a6e7c4c
No account linked to committer's email address

+ 16
- 2
client/src/main/java/com/vaadin/client/communication/MessageHandler.java View File

private int lastSeenServerSyncId = UNDEFINED_SYNC_ID; private int lastSeenServerSyncId = UNDEFINED_SYNC_ID;


private ApplicationConnection connection; private ApplicationConnection connection;
private boolean resyncInProgress;


/** /**
* Data structure holding information about pending UIDL messages. * Data structure holding information about pending UIDL messages.
protected void handleJSON(final ValueMap json) { protected void handleJSON(final ValueMap json) {
final int serverId = getServerId(json); final int serverId = getServerId(json);


if (isResynchronize(json) && !isNextExpectedMessage(serverId)) {
boolean hasResynchronize = isResynchronize(json);

if (!hasResynchronize && resyncInProgress) {
Logger.getLogger(MessageHandler.class.getName())
.warning("Dropping the response of a request before a resync request.");
return;
}

resyncInProgress = false;

if (hasResynchronize && !isNextExpectedMessage(serverId)) {
// Resynchronize request. We must remove any old pending // Resynchronize request. We must remove any old pending
// messages and ensure this is handled next. Otherwise we // messages and ensure this is handled next. Otherwise we
// would keep waiting for an older message forever (if this // would keep waiting for an older message forever (if this
int serverNextExpected = json int serverNextExpected = json
.getInt(ApplicationConstants.CLIENT_TO_SERVER_ID); .getInt(ApplicationConstants.CLIENT_TO_SERVER_ID);
getMessageSender().setClientToServerMessageId(serverNextExpected, getMessageSender().setClientToServerMessageId(serverNextExpected,
isResynchronize(json));
hasResynchronize);
} }


if (serverId != -1) { if (serverId != -1) {
} }
}-*/; }-*/;


public void onResynchronize() {
resyncInProgress = true;
}
} }

+ 1
- 0
client/src/main/java/com/vaadin/client/communication/MessageSender.java View File

* state from the server * state from the server
*/ */
public void resynchronize() { public void resynchronize() {
getMessageHandler().onResynchronize();
getLogger().info("Resynchronizing from server"); getLogger().info("Resynchronizing from server");
JsonObject resyncParam = Json.createObject(); JsonObject resyncParam = Json.createObject();
resyncParam.put(ApplicationConstants.RESYNCHRONIZE_ID, true); resyncParam.put(ApplicationConstants.RESYNCHRONIZE_ID, true);

Loading…
Cancel
Save