Mercurial > jhg
diff src/org/tmatesoft/hg/internal/DirstateBuilder.java @ 525:0be5be8d57e9
Repository checkout support, first iteration
author | Artem Tikhomirov <tikhomirov.artem@gmail.com> |
---|---|
date | Fri, 11 Jan 2013 18:12:39 +0100 |
parents | |
children | 2f9ed6bcefa2 |
line wrap: on
line diff
--- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/src/org/tmatesoft/hg/internal/DirstateBuilder.java Fri Jan 11 18:12:39 2013 +0100 @@ -0,0 +1,105 @@ +/* + * Copyright (c) 2012-2013 TMate Software Ltd + * + * This program is free software; you can redistribute it and/or modify + * it under the terms of the GNU General Public License as published by + * the Free Software Foundation; version 2 of the License. + * + * This program is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU General Public License for more details. + * + * For information on how to redistribute this software under + * the terms of a license other than GNU General Public License + * contact TMate Software at support@hg4j.com + */ +package org.tmatesoft.hg.internal; + +import java.io.IOException; +import java.nio.ByteBuffer; +import java.nio.channels.WritableByteChannel; +import java.util.ArrayList; +import java.util.List; + +import org.tmatesoft.hg.core.Nodeid; +import org.tmatesoft.hg.repo.HgDirstate; +import org.tmatesoft.hg.repo.HgManifest.Flags; +import org.tmatesoft.hg.util.Path; + +/** + * Facility to build a dirstate file as described in {@linkplain http://mercurial.selenic.com/wiki/DirState} + * + * @see http://mercurial.selenic.com/wiki/DirState + * @see HgDirstate + * @author Artem Tikhomirov + * @author TMate Software Ltd. + */ +public class DirstateBuilder { + private List<HgDirstate.Record> normal = new ArrayList<HgDirstate.Record>(); + private Nodeid parent1, parent2; + private final EncodingHelper encodingHelper; + + public DirstateBuilder(EncodingHelper encHelper) { + encodingHelper = encHelper; + } + + public void parents(Nodeid p1, Nodeid p2) { + parent1 = p1 == null ? Nodeid.NULL : p1; + parent2 = p2 == null ? Nodeid.NULL : p2; + } + + public void recordNormal(Path fname, Flags flags, int bytesWritten) { + // Mercurial seems to write "n 0 -1 unset fname" on `hg --clean co -rev <earlier rev>` + // and the reason for 'force lookup' I suspect is a slight chance of simultaneous modification + // of the file by user that doesn't alter its size the very second dirstate is being written + // (or the file is being updated and the update brought in changes that didn't alter the file size - + // with size and timestamp set, later `hg status` won't notice these changes) + + // However, as long as we use this class to write clean copies of the files, we can put all the fields + // right away. + int fmode = flags == Flags.RegularFile ? 0666 : 0777; // FIXME actual unix flags + int mtime = (int) (System.currentTimeMillis() / 1000); + normal.add(new HgDirstate.Record(fmode, bytesWritten, mtime,fname, null)); + + } + + public void serialize(WritableByteChannel dest) throws IOException { + assert parent1 != null : "Parent(s) of the working directory shall be set first"; + ByteBuffer bb = ByteBuffer.allocate(256); + bb.put(parent1.toByteArray()); + bb.put(parent2.toByteArray()); + bb.flip(); + // header + int written = dest.write(bb); + if (written != bb.limit()) { + throw new IOException("Incomplete write"); + } + bb.clear(); + // entries + for (HgDirstate.Record r : normal) { + // normal entry is 1+4+4+4+4+fname.length bytes + byte[] fname = encodingHelper.toDirstate(r.name().toString()); + bb = ensureCapacity(bb, 17 + fname.length); + bb.put((byte) 'n'); + bb.putInt(r.mode()); + bb.putInt(r.size()); + bb.putInt(r.modificationTime()); + bb.putInt(fname.length); + bb.put(fname); + bb.flip(); + written = dest.write(bb); + if (written != bb.limit()) { + throw new IOException("Incomplete write"); + } + bb.clear(); + } + } + + private static ByteBuffer ensureCapacity(ByteBuffer buf, int cap) { + if (buf.capacity() >= cap) { + return buf; + } + return ByteBuffer.allocate(cap); + } +}