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
|
/* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership.
* The ASF licenses this file to You under the Apache License, Version 2.0
* (the "License"); you may not use this file except in compliance with
* the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package java.nio;
import java.nio.channels.FileChannel.MapMode;
import libcore.io.ErrnoException;
import libcore.io.Libcore;
import libcore.io.Memory;
import static libcore.io.OsConstants.*;
/**
* {@code MappedByteBuffer} is a special kind of direct byte buffer which maps a
* region of file to memory.
* <p>
* {@code MappedByteBuffer} can be created by calling
* {@link java.nio.channels.FileChannel#map(java.nio.channels.FileChannel.MapMode, long, long) FileChannel.map}.
* Once created, the mapping between the byte buffer and the file region remains
* valid until the byte buffer is garbage collected.
* <p>
* All or part of a {@code MappedByteBuffer}'s content may change or become
* inaccessible at any time, since the mapped file region can be modified by
* another thread or process at any time. If this happens, the behavior of the
* {@code MappedByteBuffer} is undefined.
*/
public abstract class MappedByteBuffer extends ByteBuffer {
final DirectByteBuffer wrapped;
private final MapMode mapMode;
MappedByteBuffer(ByteBuffer directBuffer) {
super(directBuffer.capacity, directBuffer.block);
if (!directBuffer.isDirect()) {
throw new IllegalArgumentException("directBuffer is not a direct buffer: " + directBuffer);
}
this.wrapped = (DirectByteBuffer) directBuffer;
this.mapMode = null;
}
MappedByteBuffer(MemoryBlock block, int capacity, int offset, MapMode mapMode) {
super(capacity, block);
this.mapMode = mapMode;
if (mapMode == MapMode.READ_ONLY) {
wrapped = new ReadOnlyDirectByteBuffer(block, capacity, offset);
} else {
wrapped = new ReadWriteDirectByteBuffer(block, capacity, offset);
}
}
/**
* Returns true if there is a high probability that every page of this buffer is currently
* loaded in RAM, meaning that accesses will not cause a page fault. It is impossible to give
* a strong guarantee since this is only a snapshot of a dynamic situation.
*/
public final boolean isLoaded() {
long address = block.toInt();
long size = block.getSize();
if (size == 0) {
return true;
}
try {
int pageSize = (int) Libcore.os.sysconf(_SC_PAGE_SIZE);
int pageOffset = (int) (address % pageSize);
address -= pageOffset;
size += pageOffset;
int pageCount = (int) ((size + pageSize - 1) / pageSize);
byte[] vector = new byte[pageCount];
Libcore.os.mincore(address, size, vector);
for (int i = 0; i < vector.length; ++i) {
if ((vector[i] & 1) != 1) {
return false;
}
}
return true;
} catch (ErrnoException errnoException) {
return false;
}
}
/**
* Attempts to load every page of this buffer into RAM. See {@link #isLoaded}.
* @return this buffer.
*/
public final MappedByteBuffer load() {
try {
Libcore.os.mlock(block.toInt(), block.getSize());
Libcore.os.munlock(block.toInt(), block.getSize());
} catch (ErrnoException ignored) {
}
return this;
}
/**
* Writes all changes of the buffer to the mapped file. If the mapped file
* is stored on a local device, it is guaranteed that the changes are
* written to the file. No such guarantee is given if the file is located on
* a remote device.
*
* @return this buffer.
*/
public final MappedByteBuffer force() {
if (mapMode == MapMode.READ_WRITE) {
try {
Libcore.os.msync(block.toInt(), block.getSize(), MS_SYNC);
} catch (ErrnoException errnoException) {
// The RI doesn't throw, presumably on the assumption that you can't get into
// a state where msync(2) could return an error.
throw new AssertionError(errnoException);
}
}
return this;
}
}
|
