| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/fsdataset/impl/ |
| H A D | ReplicaMap.java | 54 if (bpid == null) { in checkBlockPool()
74 checkBlockPool(bpid); in get()
92 checkBlockPool(bpid); in get()
108 checkBlockPool(bpid); in add()
115 map.put(bpid, m); in add()
137 checkBlockPool(bpid); in remove()
161 checkBlockPool(bpid); in remove()
176 int size(String bpid) { in size() argument
179 m = map.get(bpid); in size()
196 m = map.get(bpid); in replicas()
[all …]
|
| H A D | FsVolumeImpl.java | 274 void decDfsUsed(String bpid, long value) { in decDfsUsed() argument
283 void incDfsUsed(String bpid, long value) { in incDfsUsed() argument
360 BlockPoolSlice bp = bpSlices.get(bpid); in getBlockPoolSlice()
500 private final String bpid; field in FsVolumeImpl.BlockIteratorImpl
511 this.bpid = bpid; in BlockIteratorImpl()
637 storageID, bpid, block); in nextBlock()
682 storageID, bpid); in save()
733 return bpid; in getBlockPoolId()
828 bpSlices.put(bpid, bp); in addBlockPool()
831 void shutdownBlockPool(String bpid) { in shutdownBlockPool() argument
[all …]
|
| H A D | RamDiskReplicaTracker.java | 44 private final String bpid; field in RamDiskReplicaTracker.RamDiskReplica
63 RamDiskReplica(final String bpid, final long blockId, in RamDiskReplica() argument
65 this.bpid = bpid; in RamDiskReplica()
80 return bpid; in getBlockPoolId()
118 return bpid.hashCode() ^ (int) blockId; in hashCode()
132 return (otherState.bpid.equals(bpid) && otherState.blockId == blockId); in equals()
155 int bpidResult = bpid.compareTo(other.bpid); in compareTo()
203 abstract void addReplica(final String bpid, final long blockId, in addReplica() argument
210 abstract void touch(final String bpid, final long blockId); in touch() argument
257 final String bpid, final long blockId, in discardReplica() argument
[all …]
|
| H A D | RamDiskReplicaLruTracker.java | 42 super(bpid, blockId, ramDiskVolume); in RamDiskReplicaLru()
81 Map<Long, RamDiskReplicaLru> map = replicaMaps.get(bpid); in addReplica()
84 replicaMaps.put(bpid, map); in addReplica()
92 synchronized void touch(final String bpid, in touch() argument
94 Map<Long, RamDiskReplicaLru> map = replicaMaps.get(bpid); in touch()
113 Map<Long, RamDiskReplicaLru> map = replicaMaps.get(bpid); in recordStartLazyPersist()
121 Map<Long, RamDiskReplicaLru> map = replicaMaps.get(bpid); in recordEndLazyPersist()
126 bpid + "; blockId=" + blockId); in recordEndLazyPersist()
199 final String bpid, final long blockId, in discardReplica() argument
201 Map<Long, RamDiskReplicaLru> map = replicaMaps.get(bpid); in discardReplica()
[all …]
|
| H A D | FsDatasetImpl.java | 502 String bpid = entry.getKey(); in removeVolumes() local
505 invalidate(bpid, block); in removeVolumes()
1969 cacheBlock(bpid, blockIds[i]); in cache()
2331 map.add(bpid, rur); in initReplicaRecovery()
2455 return finalizeReplica(bpid, rur); in updateReplicaUnderRecovery()
2492 volumeMap.initBlockPool(bpid); in addBlockPool()
2500 volumeMap.cleanUpBlockPool(bpid); in shutdownBlockPool()
2501 volumes.removeBlockPool(bpid); in shutdownBlockPool()
2651 dataStorage.enableTrash(bpid); in enableTrash()
2656 dataStorage.clearTrash(bpid); in clearTrash()
[all …]
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/datanode/fsdataset/impl/ |
| H A D | TestReplicaMap.java | 34 private final String bpid = "BP-TEST"; field in TestReplicaMap
49 map.get(bpid, null); in testGet()
54 assertNotNull(map.get(bpid, block)); in testGet()
59 assertNull(map.get(bpid, b)); in testGet()
64 assertNull(map.get(bpid, b)); in testGet()
70 assertNull(map.get(bpid, 0)); in testGet()
77 map.add(bpid, null); in testAdd()
86 map.remove(bpid, null); in testRemove()
93 assertNull(map.remove(bpid, b)); in testRemove()
98 assertNull(map.remove(bpid, b)); in testRemove()
[all …]
|
| H A D | FsDatasetTestUtil.java | 43 public static File getFile(FsDatasetSpi<?> fsd, String bpid, long bid) { in getFile() argument
44 return ((FsDatasetImpl)fsd).getFile(bpid, bid, false); in getFile()
47 public static File getBlockFile(FsDatasetSpi<?> fsd, String bpid, Block b in getBlockFile() argument
49 return ((FsDatasetImpl)fsd).getBlockFile(bpid, b.getBlockId()); in getBlockFile()
52 public static File getMetaFile(FsDatasetSpi<?> fsd, String bpid, Block b) in getMetaFile() argument
54 return FsDatasetUtil.getMetaFile(getBlockFile(fsd, bpid, b), b in getMetaFile()
65 final String bpid, final long blockId) { in fetchReplicaInfo() argument
66 return ((FsDatasetImpl)fsd).fetchReplicaInfo(bpid, blockId); in fetchReplicaInfo()
74 String bpid) { in getReplicas() argument
75 return ((FsDatasetImpl)fsd).volumeMap.replicas(bpid); in getReplicas()
|
| /dports/devel/godot-tools/godot-3.2.3-stable/servers/physics_2d/ |
| H A D | collision_object_2d_sw.cpp | 41 s.bpid = 0; //needs update in add_shape()
104 shape.bpid = 0; in set_shape_as_disabled()
135 if (shapes[i].bpid == 0) in remove_shape()
139 shapes.write[i].bpid = 0; in remove_shape()
160 if (s.bpid > 0) { in _set_static()
171 if (s.bpid > 0) { in _unregister_shapes()
173 s.bpid = 0; in _unregister_shapes()
190 if (s.bpid == 0) { in _update_shapes()
217 if (s.bpid == 0) { in _update_shapes_with_motion()
242 if (s.bpid) { in _set_space()
[all …]
|
| /dports/devel/godot/godot-3.2.3-stable/servers/physics_2d/ |
| H A D | collision_object_2d_sw.cpp | 41 s.bpid = 0; //needs update in add_shape()
104 shape.bpid = 0; in set_shape_as_disabled()
135 if (shapes[i].bpid == 0) in remove_shape()
139 shapes.write[i].bpid = 0; in remove_shape()
160 if (s.bpid > 0) { in _set_static()
171 if (s.bpid > 0) { in _unregister_shapes()
173 s.bpid = 0; in _unregister_shapes()
190 if (s.bpid == 0) { in _update_shapes()
217 if (s.bpid == 0) { in _update_shapes_with_motion()
242 if (s.bpid) { in _set_space()
[all …]
|
| /dports/devel/godot2/godot-2.1.6-stable/servers/physics/ |
| H A D | collision_object_sw.cpp | 39 s.bpid = 0; //needs update in add_shape()
84 if (shapes[i].bpid == 0) in remove_shape()
88 shapes[i].bpid = 0; in remove_shape()
106 if (s.bpid > 0) { in _set_static()
117 if (s.bpid > 0) { in _unregister_shapes()
118 space->get_broadphase()->remove(s.bpid); in _unregister_shapes()
119 s.bpid = 0; in _unregister_shapes()
132 if (s.bpid == 0) { in _update_shapes()
156 if (s.bpid == 0) { in _update_shapes_with_motion()
181 if (s.bpid) { in _set_space()
[all …]
|
| /dports/devel/godot2-tools/godot-2.1.6-stable/servers/physics/ |
| H A D | collision_object_sw.cpp | 39 s.bpid = 0; //needs update in add_shape()
84 if (shapes[i].bpid == 0) in remove_shape()
88 shapes[i].bpid = 0; in remove_shape()
106 if (s.bpid > 0) { in _set_static()
117 if (s.bpid > 0) { in _unregister_shapes()
118 space->get_broadphase()->remove(s.bpid); in _unregister_shapes()
119 s.bpid = 0; in _unregister_shapes()
132 if (s.bpid == 0) { in _update_shapes()
156 if (s.bpid == 0) { in _update_shapes_with_motion()
181 if (s.bpid) { in _set_space()
[all …]
|
| /dports/devel/godot2-tools/godot-2.1.6-stable/servers/physics_2d/ |
| H A D | collision_object_2d_sw.cpp | 39 s.bpid = 0; //needs update in add_shape()
92 if (shapes[i].bpid == 0) in remove_shape()
96 shapes[i].bpid = 0; in remove_shape()
114 if (s.bpid > 0) { in _set_static()
125 if (s.bpid > 0) { in _unregister_shapes()
126 space->get_broadphase()->remove(s.bpid); in _unregister_shapes()
127 s.bpid = 0; in _unregister_shapes()
140 if (s.bpid == 0) { in _update_shapes()
164 if (s.bpid == 0) { in _update_shapes_with_motion()
189 if (s.bpid) { in _set_space()
[all …]
|
| /dports/devel/godot2/godot-2.1.6-stable/servers/physics_2d/ |
| H A D | collision_object_2d_sw.cpp | 39 s.bpid = 0; //needs update in add_shape()
92 if (shapes[i].bpid == 0) in remove_shape()
96 shapes[i].bpid = 0; in remove_shape()
114 if (s.bpid > 0) { in _set_static()
125 if (s.bpid > 0) { in _unregister_shapes()
126 space->get_broadphase()->remove(s.bpid); in _unregister_shapes()
127 s.bpid = 0; in _unregister_shapes()
140 if (s.bpid == 0) { in _update_shapes()
164 if (s.bpid == 0) { in _update_shapes_with_motion()
189 if (s.bpid) { in _set_space()
[all …]
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/datanode/ |
| H A D | SimulatedFSDataset.java | 218 storage.free(bpid, -extraLen); in finalizeBlock()
389 getBPStorage(bpid).free(amount); in free()
408 map.remove(bpid); in removeBlockPool()
430 map.get(bpid).getUsed()); in getStorageReport()
542 blk.set(bpid, b); in injectBlocks()
550 blockMap.put(bpid, map); in injectBlocks()
602 String bpid) { in getBlockReports() argument
1173 blockMap.put(bpid, map); in addBlockPool()
1174 storage.addBlockPool(bpid); in addBlockPool()
1179 blockMap.remove(bpid); in shutdownBlockPool()
[all …]
|
| H A D | TestSimulatedFSDataset.java | 48 static final String bpid = "BP-TEST"; field in TestSimulatedFSDataset
118 b = new ExtendedBlock(bpid, 1, 0, 0); in testGetMetaData()
171 blockReport = fsdataset.getBlockReport(bpid); in testGetBlockReport()
185 blockReport = fsdataset.getBlockReport(bpid); in testInjectionEmpty()
195 sfsdataset.injectBlocks(bpid, blockReport); in testInjectionEmpty()
228 sfsdataset.getBlockReport(bpid); in testInjectionNonEmpty()
230 sfsdataset.getBlockReport(bpid); in testInjectionNonEmpty()
232 sfsdataset.injectBlocks(bpid, blockReport); in testInjectionNonEmpty()
249 sfsdataset.addBlockPool(bpid, conf); in testInjectionNonEmpty()
301 fsdataset.invalidate(bpid, deleteBlocks); in testInvalidate()
[all …]
|
| H A D | DataNodeTestUtils.java | 47 getDNRegistrationForBP(DataNode dn, String bpid) throws IOException { in getDNRegistrationForBP() argument
48 return dn.getDNRegistrationForBP(bpid); in getDNRegistrationForBP()
81 String bpid = nn.getNamesystem().getBlockPoolId(); in spyOnBposToNN() local
85 if (thisBpos.getBlockPoolId().equals(bpid)) { in spyOnBposToNN()
91 "No such bpid: %s", bpid); in spyOnBposToNN()
130 public static File getFile(DataNode dn, String bpid, long bid) { in getFile() argument
131 return FsDatasetTestUtil.getFile(dn.getFSDataset(), bpid, bid); in getFile()
134 public static File getBlockFile(DataNode dn, String bpid, Block b in getBlockFile() argument
139 public static File getMetaFile(DataNode dn, String bpid, Block b) in getMetaFile() argument
141 return FsDatasetTestUtil.getMetaFile(dn.getFSDataset(), bpid, b); in getMetaFile()
[all …]
|
| /dports/devel/godot/godot-3.2.3-stable/servers/physics/ |
| H A D | collision_object_sw.cpp | 41 s.bpid = 0; //needs update in add_shape()
104 if (shapes[i].bpid == 0) in remove_shape()
108 shapes.write[i].bpid = 0; in remove_shape()
129 if (s.bpid > 0) { in _set_static()
140 if (s.bpid > 0) { in _unregister_shapes()
141 space->get_broadphase()->remove(s.bpid); in _unregister_shapes()
142 s.bpid = 0; in _unregister_shapes()
155 if (s.bpid == 0) { in _update_shapes()
182 if (s.bpid == 0) { in _update_shapes_with_motion()
207 if (s.bpid) { in _set_space()
[all …]
|
| /dports/devel/godot-tools/godot-3.2.3-stable/servers/physics/ |
| H A D | collision_object_sw.cpp | 41 s.bpid = 0; //needs update in add_shape()
104 if (shapes[i].bpid == 0) in remove_shape()
108 shapes.write[i].bpid = 0; in remove_shape()
129 if (s.bpid > 0) { in _set_static()
140 if (s.bpid > 0) { in _unregister_shapes()
141 space->get_broadphase()->remove(s.bpid); in _unregister_shapes()
142 s.bpid = 0; in _unregister_shapes()
155 if (s.bpid == 0) { in _update_shapes()
182 if (s.bpid == 0) { in _update_shapes_with_motion()
207 if (s.bpid) { in _set_space()
[all …]
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/ |
| H A D | TestDFSStartupVersions.java | 76 long cTime, String bpid) { in StorageData() argument
79 blockPoolId = bpid; in StorageData()
106 fsscTimeOld, bpid), // 0 in initializeVersions()
108 fsscTimeCur, bpid), // 1 in initializeVersions()
110 fsscTimeNew, bpid), // 2 in initializeVersions()
112 fsscTimeOld, bpid), // 3 in initializeVersions()
114 fsscTimeCur, bpid), // 4 in initializeVersions()
116 fsscTimeNew, bpid), // 5 in initializeVersions()
118 fsscTimeOld, bpid), // 6 in initializeVersions()
120 fsscTimeCur, bpid), // 7 in initializeVersions()
[all …]
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/fsdataset/ |
| H A D | FsDatasetSpi.java | 127 public StorageReport[] getStorageReports(String bpid) in getStorageReports() argument
179 public Replica getReplica(String bpid, long blockId); in getReplica() argument
184 public String getReplicaString(String bpid, long blockId); in getReplicaString() argument
322 public List<Long> getCacheReport(String bpid); in getCacheReport() argument
375 public void cache(String bpid, long[] blockIds); in cache() argument
382 public void uncache(String bpid, long[] blockIds); in uncache() argument
390 public boolean isCached(String bpid, long blockId); in isCached() argument
452 public void shutdownBlockPool(String bpid) ; in shutdownBlockPool() argument
490 public void enableTrash(String bpid); in enableTrash() argument
495 public void clearTrash(String bpid); in clearTrash() argument
[all …]
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/datanode/extdataset/ |
| H A D | ExternalDatasetImpl.java | 117 public Replica getReplica(String bpid, long blockId) { in getReplica() argument
122 public String getReplicaString(String bpid, long blockId) { in getReplicaString() argument
203 public List<Long> getCacheReport(String bpid) { in getCacheReport() argument
232 public void cache(String bpid, long[] blockIds) { in cache() argument
236 public void uncache(String bpid, long[] blockIds) { in uncache() argument
240 public boolean isCached(String bpid, long blockId) { in isCached() argument
285 public void shutdownBlockPool(String bpid) { in shutdownBlockPool() argument
304 public void enableTrash(String bpid) { in enableTrash() argument
309 public void clearTrash(String bpid) { in clearTrash() argument
314 public boolean trashEnabled(String bpid) { in trashEnabled() argument
[all …]
|
| /dports/multimedia/libv4l/linux-5.13-rc2/include/soc/fsl/ |
| H A D | dpaa2-fd.h | 44 __le16 bpid; member
277 fd->simple.bpid &= cpu_to_le16(~(FD_BPID_MASK)); in dpaa2_fd_set_bpid()
278 fd->simple.bpid |= cpu_to_le16(bpid); in dpaa2_fd_set_bpid()
291 __le16 bpid; member
410 return le16_to_cpu(sg->bpid) & SG_BPID_MASK; in dpaa2_sg_get_bpid()
420 sg->bpid &= cpu_to_le16(~(SG_BPID_MASK)); in dpaa2_sg_set_bpid()
421 sg->bpid |= cpu_to_le16(bpid); in dpaa2_sg_set_bpid()
460 __le16 bpid; member
643 return le16_to_cpu(fle->bpid) & FL_BPID_MASK; in dpaa2_fl_get_bpid()
653 fle->bpid &= cpu_to_le16(~(FL_BPID_MASK)); in dpaa2_fl_set_bpid()
[all …]
|
| /dports/multimedia/v4l_compat/linux-5.13-rc2/include/soc/fsl/ |
| H A D | dpaa2-fd.h | 44 __le16 bpid; member
277 fd->simple.bpid &= cpu_to_le16(~(FD_BPID_MASK)); in dpaa2_fd_set_bpid()
278 fd->simple.bpid |= cpu_to_le16(bpid); in dpaa2_fd_set_bpid()
291 __le16 bpid; member
410 return le16_to_cpu(sg->bpid) & SG_BPID_MASK; in dpaa2_sg_get_bpid()
420 sg->bpid &= cpu_to_le16(~(SG_BPID_MASK)); in dpaa2_sg_set_bpid()
421 sg->bpid |= cpu_to_le16(bpid); in dpaa2_sg_set_bpid()
460 __le16 bpid; member
643 return le16_to_cpu(fle->bpid) & FL_BPID_MASK; in dpaa2_fl_get_bpid()
653 fle->bpid &= cpu_to_le16(~(FL_BPID_MASK)); in dpaa2_fl_set_bpid()
[all …]
|
| /dports/multimedia/v4l-utils/linux-5.13-rc2/include/soc/fsl/ |
| H A D | dpaa2-fd.h | 44 __le16 bpid; member
277 fd->simple.bpid &= cpu_to_le16(~(FD_BPID_MASK)); in dpaa2_fd_set_bpid()
278 fd->simple.bpid |= cpu_to_le16(bpid); in dpaa2_fd_set_bpid()
291 __le16 bpid; member
410 return le16_to_cpu(sg->bpid) & SG_BPID_MASK; in dpaa2_sg_get_bpid()
420 sg->bpid &= cpu_to_le16(~(SG_BPID_MASK)); in dpaa2_sg_set_bpid()
421 sg->bpid |= cpu_to_le16(bpid); in dpaa2_sg_set_bpid()
460 __le16 bpid; member
643 return le16_to_cpu(fle->bpid) & FL_BPID_MASK; in dpaa2_fl_get_bpid()
653 fle->bpid &= cpu_to_le16(~(FL_BPID_MASK)); in dpaa2_fl_set_bpid()
[all …]
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/security/token/block/ |
| H A D | BlockPoolTokenSecretManager.java | 47 public synchronized void addBlockPool(String bpid, in addBlockPool() argument
49 map.put(bpid, secretMgr); in addBlockPool()
52 synchronized BlockTokenSecretManager get(String bpid) { in get() argument
53 BlockTokenSecretManager secretMgr = map.get(bpid); in get()
55 throw new IllegalArgumentException("Block pool " + bpid in get()
61 public synchronized boolean isBlockPoolRegistered(String bpid) { in isBlockPoolRegistered() argument
62 return map.containsKey(bpid); in isBlockPoolRegistered()
103 public void addKeys(String bpid, ExportedBlockKeys exportedKeys) in addKeys() argument
105 get(bpid).addKeys(exportedKeys); in addKeys()
|