| Overview |  |
Perform "chain repair", i.e., resynchronization of Machi file contents and metadata as servers are (re-)added to the chain.
The implementation here is a very basic one, and is probably a bit slower than the original "demo day" implementation at https://github.com/basho/machi/blob/master/prototype/demo-day-hack/file0_repair_server.escript
It's so easy to bikeshed this into a 1 year programming exercise.
General TODO note: There are a lot of areas for exploiting parallelism here. I've set the bikeshed aside for now, but "make repair faster" has a lot of room for exploiting concurrency, overlapping reads & writes, etc etc. There are also lots of different trade-offs to make with regard to RAM use vs. disk use.
There's no reason why repair can't be done:
Use bigger chunks than the client originally used to write the file ... Optimization ... but it would be the easiest to implement, e.g. use constant-sized 4MB chunks. Unfortuntely, it would also destroy the ability to verify here that the chunk checksums are correct *and* also propagate the correct checksum metadata to the destination FLU.
As an additional optimization, add a bit of #2 to start the next read while the current write is still in progress.Most/all of this could be executed in parallel on each FLU relative to its own files. Then, in another TODO option, perhaps build a Merkle tree or other summary of the local files and send that data structure to the repair coordinator.
Also, as another TODO note, repair_both_present() in the prototype/demo-day code uses an optimization of calculating the MD5 checksum of the chunk checksum data as it arrives, and if the two MD5s match, then we consider the two files in sync. If there isn't a match, then we sort the lines and try another MD5, and if they match, then we're in sync. In theory, that's lower overhead than the procedure used here.
NOTE that one reason I chose the "directives list" method is to have an option, later, of choosing to repair a subset of repairee FLUs if there is a big discrepency between out of sync files: e.g., if FLU x has N bytes out of sync but FLU y has 50N bytes out of sync, then it's likely better to repair x only so that x can return to the UPI list quickly. Also, in the event that all repairees are roughly comparably out of sync, then the repair network traffic can be minimized by reading each chunk only once.| repair/7 |
repair(ConsistencyMode, Src, Repairing, UPI, MembersDict, ETS, Opts) -> any()
Generated by EDoc, May 20 2015, 12:50:53.