MultiplexPatchWriter

Overview

Package

Class

Tree

Deprecated

Index

Help

PREV CLASS NEXT CLASS

FRAMES NO FRAMES

SUMMARY: NESTED | FIELD | CONSTR | METHOD

DETAIL: FIELD | CONSTR | METHOD

uka.patch
Class MultiplexPatchWriter

java.lang.Object
  uka.patch.AbstractPatchWriter
      uka.patch.MultiplexPatchWriter

All Implemented Interfaces:: Constants

public class MultiplexPatchWriter
extends AbstractPatchWriter

Multiplexes a patch created with calls to the interface of AbstractPatchWriter to several MarshalStreams. With an installed distributor, the generated patches can be customized for the recipient. If not all objects in the source object graph are locally available at all target graphs (the graphs the generated patches will be applied to), these objects can be excluded from the patch.

Field Summary
`(package private) int`	`activeCnt` Number of initialized fields in `activeGroup`.
`(package private) PatchWriter[]`	`activeGroup` Subset of `PatchWriter`s in `group`.
`(package private) ReferenceFilter`	`filter`
`(package private) PatchWriter[]`	`group` Group of `PatchWriter`s for transmitting patches to other ranks.
`(package private) boolean[]`	`hasStream` Remembers the initialization status of `PatchWriter`s in `group`.
`(package private) int`	`myRank`
`(package private) PartitionedObjectSpace`	`objects`
`(package private) int`	`size`

Fields inherited from class uka.patch.AbstractPatchWriter

currentID, modified, unmodifiedCnt

Fields inherited from interface uka.patch.Constants

CODE_BOOLEAN, CODE_DOUBLE, CODE_END_OF_PATCH, CODE_FLOAT, CODE_INT16, CODE_INT32, CODE_INT64, CODE_INT8, CODE_NOT_MODIFIED, CODE_NULL, CODE_PATCH_HEADER, CODE_REFERENCE, MAX_DISTRIBUTION_RECORDS

Constructor Summary
`MultiplexPatchWriter(PartitionedObjectSpace objects, ReferenceFilter filter, int myRank)`

Method Summary
`void`	`beginPatch()`
`void`	`beginPatchRecord(int id)`
`void`	`clear()`
`protected void`	`encode(boolean value)`
`protected void`	`encode(byte value)`
`protected void`	`encode(char value)`
`protected void`	`encode(double value)`
`protected void`	`encode(float value)`
`protected void`	`encode(int value)`
`protected void`	`encode(long value)`
`protected void`	`encode(short value)`
`protected void`	`encodeBeginPatch()`
`protected void`	`encodeEndPatch()`
`protected void`	`encodeNull()`
`protected void`	`encodePatchHeader(int id)`
`protected java.lang.Object`	`encodeReference(java.lang.Object ref)`
`protected void`	`encodeUnmodifiedCnt(int cnt)`
`void`	`endPatch()`
`void`	`flush()`
`PatchWriter[]`	`getGroup()`
`MarshalStream`	`getOutput(int rank)` Experimental low-level API: Patch creation for the expert.
`void`	`init(java.lang.Object root)`
`void`	`rawWriteInt(int value)`
`void`	`registerStreams(MarshalStream[] streams)`
`void`	`unregisterStreams()`

Methods inherited from class uka.patch.AbstractPatchWriter

endPatchRecord, flushUnmodified, write, write, write, write, write, write, write, write, writeNotModified, writeNull, writeReference

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

size

int size

myRank

int myRank

objects

PartitionedObjectSpace objects

filter

ReferenceFilter filter

group

PatchWriter[] group

Group of PatchWriters for transmitting patches to other ranks. This array is initialized with PatchWriters upon construction, but the writer connections are plugged in dynamically in calls to registerStreams(uka.transport.MarshalStream[]).

hasStream

boolean[] hasStream

Remembers the initialization status of PatchWriters in group. If hasStream[n] is true, the corresponding PatchWriter {#link #group}[n] is initialized with a stream for transmission.

activeCnt

int activeCnt

Number of initialized fields in activeGroup.

activeGroup

PatchWriter[] activeGroup

Subset of PatchWriters in group. The active group is configured for each patch record to ensure it is only sent to those ranks having a copy of the corresponding object.

See Also:: beginPatchRecord(int)

Constructor Detail