Package com.newstep.solid.replication.protocol
Note text:
ReplicationRequest
Links:
Note Link [Note Link: [Note1] -> [null]]
Note Link [Note Link: [Note1] -> [null]]
[Note Link: [Note1] -> [null]]
[Note Link: [Note1] -> [null]]
Note text:
ReplicationResponse
Links:
Note Link [Note Link: [Note2] -> [null]]
Note Link [Note Link: [Note2] -> [null]]
[Note Link: [Note2] -> [null]]
[Note Link: [Note2] -> [null]]
Note text:
ReplicationStart
Links:
Note Link [Note Link: [Note3] -> [null]]
Note Link [Note Link: [Note3] -> [null]]
[Note Link: [Note3] -> [null]]
[Note Link: [Note3] -> [null]]
Note text:
peerId of the replicatorB
Links:
Note Link [Note Link: [Note4] -> [null]]
[Note Link: [Note4] -> [null]]
Note text:
peerId of the replicatorA
Links:
Note Link [Note Link: [Note4] -> [null]]
[Note Link: [Note4] -> [null]]
Note text:
Listen for connection from replicatorB (peerA)
Links:
Note Link [Note Link: [Note5] -> [null]]
[Note Link: [Note5] -> [null]]
Note text:
Connect to replicatorA (peerB)
Links:
Note Link [Note Link: [Note6] -> [null]]
[Note Link: [Note6] -> [null]]
Note text:
ReplicationStartResponse
Links:
Note Link [Note Link: [Note7] -> [null]]
Note Link [Note Link: [Note7] -> [null]]
[Note Link: [Note7] -> [null]]
[Note Link: [Note7] -> [null]]
Note text:
And now they are happily replicatin'. Method replicate is not realy invoked by peerB on peerA, it is invoked by a replicant belonging to the replicatorA on peerB, which passes it through the comm channel to peerA, which passes it to the corresponding replicant on replicatorB
Links:
Note Link [Note Link: [Note8] -> [null]]
[Note Link: [Note8] -> [null]]
Note text:
peerB is the ChannelAccessPointListener
Links:
Note Link [Note Link: [Note9] -> [null]]
Note Link [Note Link: [Note9] -> [peerB]]
[Note Link: [Note9] -> [null]]
[Note Link: [Note9] -> [peerB]]