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
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
|
/*
* Copyright (C) 2012, Robin Rosenberg
* Copyright (C) 2010, 2013 Marc Strapetz <marc.strapetz@syntevo.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.util.io;
import java.io.IOException;
import java.io.InputStream;
import org.eclipse.jgit.diff.RawText;
/**
* An InputStream that expands LF to CRLF.
*
* Existing CRLF are not expanded to CRCRLF, but retained as is.
*
* Optionally, a binary check on the first 8000 bytes is performed and in case
* of binary files, canonicalization is turned off (for the complete file).
*/
public class AutoCRLFInputStream extends InputStream {
static final int BUFFER_SIZE = 8096;
private final byte[] single = new byte[1];
private final byte[] buf = new byte[BUFFER_SIZE];
private final InputStream in;
private int cnt;
private int ptr;
private boolean isBinary;
private boolean detectBinary;
private byte last;
/**
* Creates a new InputStream, wrapping the specified stream
*
* @param in
* raw input stream
* @param detectBinary
* whether binaries should be detected
* @since 2.0
*/
public AutoCRLFInputStream(InputStream in, boolean detectBinary) {
this.in = in;
this.detectBinary = detectBinary;
}
/** {@inheritDoc} */
@Override
public int read() throws IOException {
final int read = read(single, 0, 1);
return read == 1 ? single[0] & 0xff : -1;
}
/** {@inheritDoc} */
@Override
public int read(byte[] bs, int off, int len) throws IOException {
if (len == 0)
return 0;
if (cnt == -1)
return -1;
int i = off;
final int end = off + len;
while (i < end) {
if (ptr == cnt && !fillBuffer())
break;
byte b = buf[ptr++];
if (isBinary || b != '\n') {
// Logic for binary files ends here
bs[i++] = last = b;
continue;
}
if (b == '\n') {
if (last == '\r') {
bs[i++] = last = b;
continue;
}
bs[i++] = last = '\r';
ptr--;
} else
bs[i++] = last = b;
}
int n = i == off ? -1 : i - off;
if (n > 0)
last = bs[i - 1];
return n;
}
/** {@inheritDoc} */
@Override
public void close() throws IOException {
in.close();
}
private boolean fillBuffer() throws IOException {
cnt = 0;
while (cnt < buf.length) {
int n = in.read(buf, cnt, buf.length - cnt);
if (n < 0) {
break;
}
cnt += n;
}
if (cnt < 1) {
cnt = -1;
return false;
}
if (detectBinary) {
isBinary = RawText.isBinary(buf, cnt);
detectBinary = false;
}
ptr = 0;
return true;
}
}
|
