blob: 404c17fcab438eb4552dd1017e32bc6a66c4a1b1 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
|
/*
* Copyright (C) 2017, Markus Duft <markus.duft@ssi-schaefer.com> and others
*
* This program and the accompanying materials are made available under the
* terms of the Eclipse Distribution License v. 1.0 which is available at
* https://www.eclipse.org/org/documents/edl-v10.php.
*
* SPDX-License-Identifier: BSD-3-Clause
*/
package org.eclipse.jgit.lfs;
import java.io.IOException;
import java.nio.file.Files;
import java.nio.file.Path;
import java.nio.file.attribute.BasicFileAttributes;
import org.eclipse.jgit.errors.LargeObjectException;
import org.eclipse.jgit.errors.MissingObjectException;
import org.eclipse.jgit.lib.Constants;
import org.eclipse.jgit.lib.ObjectLoader;
import org.eclipse.jgit.lib.ObjectStream;
import org.eclipse.jgit.storage.pack.PackConfig;
import org.eclipse.jgit.util.IO;
/**
* An {@link ObjectLoader} implementation that reads a media file from the LFS
* storage.
*
* @since 4.11
*/
public class LfsBlobLoader extends ObjectLoader {
private Path mediaFile;
private BasicFileAttributes attributes;
private byte[] cached;
/**
* Create a loader for the LFS media file at the given path.
*
* @param mediaFile
* path to the file
* @throws IOException
* in case of an error reading attributes
*/
public LfsBlobLoader(Path mediaFile) throws IOException {
this.mediaFile = mediaFile;
this.attributes = Files.readAttributes(mediaFile,
BasicFileAttributes.class);
}
@Override
public int getType() {
return Constants.OBJ_BLOB;
}
@Override
public long getSize() {
return attributes.size();
}
@Override
public byte[] getCachedBytes() throws LargeObjectException {
if (getSize() > PackConfig.DEFAULT_BIG_FILE_THRESHOLD) {
throw new LargeObjectException();
}
if (cached == null) {
try {
cached = IO.readFully(mediaFile.toFile());
} catch (IOException ioe) {
throw new LargeObjectException(ioe);
}
}
return cached;
}
@Override
public ObjectStream openStream()
throws MissingObjectException, IOException {
return new ObjectStream.Filter(getType(), getSize(),
Files.newInputStream(mediaFile));
}
}
|
