public ClusterImpl clusterImpl;
public ClusterChange(ClusterStream clusterStream, ClusterImpl clusterImpl) {
+
this.clusterImpl = clusterImpl;
+
+ if (!clusterImpl.isLoaded())
+ new IllegalStateException("Change to proxy cluster " + clusterImpl.getClusterUID()).printStackTrace();
+
clusterUID = clusterImpl.getClusterUID();
long[] longs = new long[ClusterUID.getLongLength()];
clusterUID.toLong(longs, 0);
Bytes.writeLE(header, offset, longs[i]);
//initBuffer();
this.clusterStream = clusterStream;
- this.clusterChange2 = new ClusterChange2(clusterUID, clusterImpl);
+ this.clusterChange2 = new ClusterChange2(clusterUID);
clusterStream.changes.add(this);
}
+
+ public void adopt(ClusterImpl impl) {
+ this.clusterImpl = impl;
+ }
private void setHeaderVectorSize(int size) {
if (size < 0)
}
@Override
public String toString() {
- return super.toString() + " cluster=" + clusterImpl.getClusterUID() + " id=" + clusterImpl.getClusterId() + " off=" + byteIndex;
+ return super.toString() + " cluster=" + clusterUID + " id=" + clusterImpl.getClusterId() + " off=" + byteIndex;
}
private final void initBuffer() {
flushed = false;