"Fossies" - the Fresh Open Source Software Archive  

Source code changes of the file "dso-l2/src/main/java/com/tc/objectserver/entity/ManagedEntityImpl.java" between
terracotta-core-5.7.0.tar.gz and terracotta-core-5.7.1.tar.gz

About: Terracotta - Clustering technology for Java ("Network Attached Memory", "Distributed Cache"). Source code of the server (5.x) core components.

ManagedEntityImpl.java  (terracotta-core-5.7.0):ManagedEntityImpl.java  (terracotta-core-5.7.1)
skipping to change at line 739 skipping to change at line 739
} }
} }
} }
private void reconfigureEntity(ResultCapture reconfigureEntityRequest, byte[] constructorInfo) throws ConfigurationException { private void reconfigureEntity(ResultCapture reconfigureEntityRequest, byte[] constructorInfo) throws ConfigurationException {
byte[] oldconfig = this.constructorInfo; byte[] oldconfig = this.constructorInfo;
if (this.isDestroyed || (this.activeServerEntity == null && this.passiveServ erEntity == null)) { if (this.isDestroyed || (this.activeServerEntity == null && this.passiveServ erEntity == null)) {
reconfigureEntityRequest.failure(ServerException.createNotFoundException(i d)); reconfigureEntityRequest.failure(ServerException.createNotFoundException(i d));
return; return;
} }
this.constructorInfo = constructorInfo;
// Create the appropriate kind of entity, based on our active/passive state. // Create the appropriate kind of entity, based on our active/passive state.
notifyEntityDestroyed(); notifyEntityDestroyed();
if (this.isInActiveState) { if (this.isInActiveState) {
if (null == this.activeServerEntity) { if (null == this.activeServerEntity) {
throw new IllegalStateException("Active entity " + id + " does not exist s."); throw new IllegalStateException("Active entity " + id + " does not exist s.");
} else { } else {
this.activeServerEntity = this.factory.reconfigureEntity(this.registry, this.activeServerEntity, constructorInfo); this.activeServerEntity = this.factory.reconfigureEntity(this.registry, this.activeServerEntity, constructorInfo);
this.concurrencyStrategy = this.factory.getConcurrencyStrategy(construct orInfo); this.concurrencyStrategy = this.factory.getConcurrencyStrategy(construct orInfo);
this.executionStrategy = this.factory.getExecutionStrategy(constructorIn fo); this.executionStrategy = this.factory.getExecutionStrategy(constructorIn fo);
} }
} else { } else {
if (null == this.passiveServerEntity) { if (null == this.passiveServerEntity) {
throw new IllegalStateException("Passive entity " + id + " does not exis ts."); throw new IllegalStateException("Passive entity " + id + " does not exis ts.");
} else { } else {
this.passiveServerEntity = this.factory.reconfigureEntity(this.registry, this.passiveServerEntity, this.constructorInfo); this.passiveServerEntity = this.factory.reconfigureEntity(this.registry, this.passiveServerEntity, constructorInfo);
Assert.assertNull(this.concurrencyStrategy); Assert.assertNull(this.concurrencyStrategy);
Assert.assertNull(this.executionStrategy); Assert.assertNull(this.executionStrategy);
// TODO: Store the configuration in case we promote. // TODO: Store the configuration in case we promote.
} }
} }
this.constructorInfo = constructorInfo;
notifyEntityCreated(); notifyEntityCreated();
reconfigureEntityRequest.complete(oldconfig); reconfigureEntityRequest.complete(oldconfig);
// Fire the event that the entity was created. // Fire the event that the entity was created.
this.eventCollector.entityWasReloaded(this.getID(), this.consumerID, this.is InActiveState); this.eventCollector.entityWasReloaded(this.getID(), this.consumerID, this.is InActiveState);
} }
private void createEntity(ResultCapture response, byte[] constructorInfo) thro ws ConfigurationException { private void createEntity(ResultCapture response, byte[] constructorInfo) thro ws ConfigurationException {
Trace.activeTrace().log("ManagedEntityImpl.createEntity"); Trace.activeTrace().log("ManagedEntityImpl.createEntity");
 End of changes. 3 change blocks. 
2 lines changed or deleted 2 lines changed or added

Home  |  About  |  Features  |  All  |  Newest  |  Dox  |  Diffs  |  RSS Feeds  |  Screenshots  |  Comments  |  Imprint  |  Privacy  |  HTTP(S)