/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/ |
H A D | TestDFSFinalize.java | 68 String bpid) throws Exception { in checkResult() argument 89 if (bpid == null) { in checkResult() 95 File bpRoot = BlockPoolSliceStorage.getBpRoot(bpid, dnCurDirs[i]); in checkResult() 157 String bpid = UpgradeUtilities.getCurrentBlockPoolID(cluster); in testFinalize() local 161 UpgradeUtilities.createBlockPoolStorageDirs(dataNodeDirs, "current", bpid); in testFinalize() 162 UpgradeUtilities.createBlockPoolStorageDirs(dataNodeDirs, "previous", bpid); in testFinalize() 173 checkResult(nameNodeDirs, dataNodeDirs, bpid); in testFinalize() 180 checkResult(nameNodeDirs, dataNodeDirs, bpid); in testFinalize()
|
H A D | TestDatanodeReport.java | 60 final String bpid = cluster.getNamesystem().getBlockPoolId(); in testDatanodeReport() local 64 assertReports(NUM_OF_DATANODES, DatanodeReportType.ALL, client, datanodes, bpid); in testDatanodeReport() 65 assertReports(NUM_OF_DATANODES, DatanodeReportType.LIVE, client, datanodes, bpid); in testDatanodeReport() 66 assertReports(0, DatanodeReportType.DEAD, client, datanodes, bpid); in testDatanodeReport() 102 DFSClient client, List<DataNode> datanodes, String bpid) throws IOException { in assertReports() argument 112 if (bpid != null) { in assertReports() 116 final StorageReport[] expected = d.getFSDataset().getStorageReports(bpid); in assertReports()
|
H A D | TestDFSStorageStateRecovery.java | 196 String[] createBlockPoolStorageState(String bpid, boolean[] state) throws Exception { in createBlockPoolStorageState() argument 203 String[] bpDirs = UpgradeUtilities.createEmptyBPDirs(baseDirs, bpid); in createBlockPoolStorageState() 205 UpgradeUtilities.createBlockPoolStorageDirs(baseDirs, "current", bpid); in createBlockPoolStorageState() 207 UpgradeUtilities.createBlockPoolStorageDirs(baseDirs, "previous", bpid); in createBlockPoolStorageState() 210 bpid); in createBlockPoolStorageState() 213 .createBlockPoolStorageDirs(baseDirs, "removed.tmp", bpid); in createBlockPoolStorageState() 413 String bpid = UpgradeUtilities.getCurrentBlockPoolID(null); in testBlockPoolStorageStates() local 428 baseDirs = createBlockPoolStorageState(bpid, testCase); in testBlockPoolStorageStates() 438 assertFalse(cluster.getDataNodes().get(0).isBPServiceAlive(bpid)); in testBlockPoolStorageStates()
|
/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 | FsDatasetCache.java | 259 synchronized List<Long> getCachedBlocks(String bpid) { in getCachedBlocks() argument 264 if (entry.getKey().getBlockPoolId().equals(bpid)) { in getCachedBlocks() 276 synchronized void cacheBlock(long blockId, String bpid, in cacheBlock() argument 279 ExtendedBlockId key = new ExtendedBlockId(blockId, bpid); in cacheBlock() 292 bpid); in cacheBlock() 295 synchronized void uncacheBlock(String bpid, long blockId) { in uncacheBlock() argument 296 ExtendedBlockId key = new ExtendedBlockId(blockId, bpid); in uncacheBlock() 307 bpid); in uncacheBlock() 314 bpid); in uncacheBlock() 545 public synchronized boolean isCached(String bpid, long blockId) { in isCached() argument [all …]
|
H A D | FsVolumeList.java | 141 long getBlockPoolUsed(String bpid) throws IOException { in getBlockPoolUsed() argument 145 dfsUsed += v.getBlockPoolUsed(bpid); in getBlockPoolUsed() 177 void getAllVolumesMap(final String bpid, in getAllVolumesMap() argument 190 bpid + " on volume " + v + "..."); in getAllVolumesMap() 192 v.getVolumeMap(bpid, volumeMap, ramDiskReplicaMap); in getAllVolumesMap() 195 + " " + bpid + " on volume " + v + ": " + timeTaken + "ms"); in getAllVolumesMap() 402 FsDatasetImpl.LOG.info("Scanning block pool " + bpid + in addBlockPool() 405 v.addBlockPool(bpid, conf); in addBlockPool() 434 bpid + ": " + totalTimeTaken + "ms"); in addBlockPool() 437 void removeBlockPool(String bpid) { in removeBlockPool() argument [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 | FsVolumeSpi.java | 54 public String getPath(String bpid) throws IOException; in getPath() argument 57 public File getFinalizedDir(String bpid) throws IOException; in getFinalizedDir() argument 163 public BlockIterator newBlockIterator(String bpid, String name); in newBlockIterator() argument 175 public BlockIterator loadBlockIterator(String bpid, String name) in loadBlockIterator() argument
|
/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 | ExternalVolumeImpl.java | 48 public String getPath(String bpid) throws IOException { in getPath() argument 53 public File getFinalizedDir(String bpid) throws IOException { in getFinalizedDir() argument 86 public BlockIterator newBlockIterator(String bpid, String name) { in newBlockIterator() argument 91 public BlockIterator loadBlockIterator(String bpid, String name) in loadBlockIterator() argument
|
/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 | TestInterDatanodeProtocol.java | 237 String bpid = "BP-TEST"; in testInitReplicaRecovery() local 241 map.add(bpid, createReplicaInfo(blocks[i])); in testInitReplicaRecovery() 247 final ReplicaInfo originalInfo = map.get(bpid, b); in testInitReplicaRecovery() 251 .initReplicaRecovery(bpid, map, blocks[0], recoveryid, in testInitReplicaRecovery() 262 .initReplicaRecovery(bpid, map, blocks[0], recoveryid2, in testInitReplicaRecovery() 272 FsDatasetImpl.initReplicaRecovery(bpid, map, b, recoveryid, in testInitReplicaRecovery() 284 ReplicaRecoveryInfo r = FsDatasetImpl.initReplicaRecovery(bpid, map, b, in testInitReplicaRecovery() 294 FsDatasetImpl.initReplicaRecovery(bpid, map, b, recoveryid, in testInitReplicaRecovery() 308 FsDatasetImpl.initReplicaRecovery(bpid, map, b, recoveryid, in testInitReplicaRecovery() 330 String bpid = cluster.getNamesystem().getBlockPoolId(); in testUpdateReplicaUnderRecovery() local [all …]
|
H A D | TestFsDatasetImpl.java | 149 for (String bpid : BLOCK_POOL_IDS) { in setUp() 150 dataset.addBlockPool(bpid, conf); in setUp() 164 for (String bpid : BLOCK_POOL_IDS) { in testAddVolumes() 165 nsInfos.add(new NamespaceInfo(0, CLUSTER_ID, bpid, 1)); in testAddVolumes() 200 ExtendedBlock eb = new ExtendedBlock(bpid, i); in testRemoveVolumes() 231 for (String bpid : dataset.volumeMap.getBlockPoolList()) { in testRemoveVolumes() 232 totalNumReplicas += dataset.volumeMap.size(bpid); in testRemoveVolumes() 243 for (String bpid : BLOCK_POOL_IDS) { in testRemoveNewlyAddedVolume() 244 nsInfos.add(new NamespaceInfo(0, CLUSTER_ID, bpid, 1)); in testRemoveNewlyAddedVolume() 347 for (String bpid : BLOCK_POOL_IDS) { in testAddVolumeFailureReleasesInUseLock() [all …]
|
H A D | TestDatanodeRestart.java | 120 String bpid = cluster.getNamesystem().getBlockPoolId(); in testRbwReplicas() local 122 Assert.assertEquals(1, replicas.size(bpid)); in testRbwReplicas() 123 ReplicaInfo replica = replicas.replicas(bpid).iterator().next(); in testRbwReplicas() 130 dataset(dn).invalidate(bpid, new Block[]{replica}); in testRbwReplicas() 154 String bpid = cluster.getNamesystem().getBlockPoolId(); in testRecoverReplicas() local 157 dataset(dn).volumeMap.replicas(bpid).iterator(); in testRecoverReplicas() 173 Collection<ReplicaInfo> replicas = dataset(dn).volumeMap.replicas(bpid); in testRecoverReplicas()
|
/dports/java/bouncycastle15/crypto-169/util/src/test/java/org/bouncycastle/asn1/cmc/test/ |
H A D | BodyPartReferenceTest.java | 40 BodyPartID[] bpid = new BodyPartID[Math.abs(rand.nextInt()) % 20]; in performTest() local 41 for (int t = 0; t < bpid.length; t++) in performTest() 43 bpid[t] = new BodyPartID(Math.abs(rand.nextLong() % 4294967295L)); in performTest() 46 ch1 = new BodyPartReference(new BodyPartPath(bpid)); in performTest()
|
/dports/www/moodle311/moodle/badges/ |
H A D | upgradelib.php | 45 $bpid = $bp->id; 47 $bpid = $DB->insert_record('badge_external_backpack', $record); 51 $DB->set_field('badge_backpack', 'externalbackpackid', $bpid);
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/ |
H A D | VolumeScanner.java | 687 public synchronized void enableBlockPoolId(String bpid) { in enableBlockPoolId() argument 689 if (iter.getBlockPoolId().equals(bpid)) { in enableBlockPoolId() 690 LOG.warn("{}: already enabled scanning on block pool {}", this, bpid); in enableBlockPoolId() 697 iter = volume.loadBlockIterator(bpid, BLOCK_ITERATOR_NAME); in enableBlockPoolId() 698 LOG.trace("{}: loaded block iterator for {}.", this, bpid); in enableBlockPoolId() 705 iter = volume.newBlockIterator(bpid, BLOCK_ITERATOR_NAME); in enableBlockPoolId() 706 LOG.trace("{}: created new block iterator for {}.", this, bpid); in enableBlockPoolId() 718 public synchronized void disableBlockPoolId(String bpid) { in disableBlockPoolId() argument 722 if (iter.getBlockPoolId().equals(bpid)) { in disableBlockPoolId() 723 LOG.trace("{}: disabling scanning on block pool {}", this, bpid); in disableBlockPoolId() [all …]
|
H A D | BlockScanner.java | 271 synchronized void enableBlockPoolId(String bpid) { in enableBlockPoolId() argument 272 Preconditions.checkNotNull(bpid); in enableBlockPoolId() 274 scanner.enableBlockPoolId(bpid); in enableBlockPoolId() 283 synchronized void disableBlockPoolId(String bpid) { in disableBlockPoolId() argument 284 Preconditions.checkNotNull(bpid); in disableBlockPoolId() 286 scanner.disableBlockPoolId(bpid); in disableBlockPoolId()
|
/dports/sysutils/u-boot-utilite/u-boot-2015.07/drivers/net/ldpaa_eth/ |
H A D | ldpaa_eth.c | 67 qbman_release_desc_set_bpid(&releasedesc, dflt_dpbp->dpbp_attr.bpid); in ldpaa_eth_rx() 157 qbman_release_desc_set_bpid(&releasedesc, dflt_dpbp->dpbp_attr.bpid); in ldpaa_eth_tx_conf() 233 dflt_dpbp->dpbp_attr.bpid, in ldpaa_eth_tx() 251 ldpaa_fd_set_bpid(&fd, dflt_dpbp->dpbp_attr.bpid); in ldpaa_eth_tx() 406 dflt_dpbp->dpbp_attr.bpid, in ldpaa_dpbp_drain_cnt() 427 static int ldpaa_bp_add_7(uint16_t bpid) in ldpaa_bp_add_7() argument 457 qbman_release_desc_set_bpid(&rd, bpid); in ldpaa_bp_add_7() 469 static int ldpaa_dpbp_seed(uint16_t bpid) in ldpaa_dpbp_seed() argument 475 count = ldpaa_bp_add_7(bpid); in ldpaa_dpbp_seed() 507 err = ldpaa_dpbp_seed(dflt_dpbp->dpbp_attr.bpid); in ldpaa_dpbp_setup() [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 | TestDiskError.java | 94 String bpid = cluster.getNamesystem().getBlockPoolId(); in testShutdown() local 96 File dir1 = MiniDFSCluster.getRbwDir(storageDir, bpid); in testShutdown() 98 File dir2 = MiniDFSCluster.getRbwDir(storageDir, bpid); in testShutdown() 162 String bpid = cluster.getNamesystem().getBlockPoolId(); in testReplicationError() local 164 File dir1 = MiniDFSCluster.getRbwDir(storageDir, bpid); in testReplicationError() 166 File dir2 = MiniDFSCluster.getRbwDir(storageDir, bpid); in testReplicationError()
|
H A D | TestBlockHasMultipleReplicasOnSameDN.java | 61 private String bpid; field in TestBlockHasMultipleReplicasOnSameDN 71 bpid = cluster.getNamesystem().getBlockPoolId(); in startUpCluster() 107 DatanodeRegistration dnReg = dn.getDNRegistrationForBP(bpid); in testBlockHasMultipleReplicasOnSameDN() 126 cluster.getNameNodeRpc().blockReport(dnReg, bpid, reports, in testBlockHasMultipleReplicasOnSameDN()
|
/dports/multimedia/libv4l/linux-5.13-rc2/include/soc/fsl/ |
H A D | dpaa2-io.h | 118 int dpaa2_io_service_release(struct dpaa2_io *d, u16 bpid, 120 int dpaa2_io_service_acquire(struct dpaa2_io *d, u16 bpid, 130 int dpaa2_io_query_bp_count(struct dpaa2_io *d, u16 bpid,
|
/dports/multimedia/v4l_compat/linux-5.13-rc2/include/soc/fsl/ |
H A D | dpaa2-io.h | 118 int dpaa2_io_service_release(struct dpaa2_io *d, u16 bpid, 120 int dpaa2_io_service_acquire(struct dpaa2_io *d, u16 bpid, 130 int dpaa2_io_query_bp_count(struct dpaa2_io *d, u16 bpid,
|
/dports/multimedia/v4l-utils/linux-5.13-rc2/include/soc/fsl/ |
H A D | dpaa2-io.h | 118 int dpaa2_io_service_release(struct dpaa2_io *d, u16 bpid, 120 int dpaa2_io_service_acquire(struct dpaa2_io *d, u16 bpid, 130 int dpaa2_io_query_bp_count(struct dpaa2_io *d, u16 bpid,
|
/dports/multimedia/v4l_compat/linux-5.13-rc2/drivers/soc/fsl/dpio/ |
H A D | qbman-portal.c | 1419 d->bpid = cpu_to_le16(bpid); in qbman_release_desc_set_bpid() 1470 p->bpid = d->bpid; in qbman_swp_release_direct() 1512 p->bpid = d->bpid; in qbman_swp_release_mem_back() 1525 __le16 bpid; member 1566 p->bpid = cpu_to_le16(bpid); in qbman_swp_acquire() 1573 bpid); in qbman_swp_acquire() 1583 bpid, r->rslt); in qbman_swp_acquire() 1760 __le16 bpid; member 1774 p->bpid = cpu_to_le16(bpid); in qbman_bp_query() 1778 bpid); in qbman_bp_query() [all …]
|
/dports/multimedia/libv4l/linux-5.13-rc2/drivers/soc/fsl/dpio/ |
H A D | qbman-portal.c | 1419 d->bpid = cpu_to_le16(bpid); in qbman_release_desc_set_bpid() 1470 p->bpid = d->bpid; in qbman_swp_release_direct() 1512 p->bpid = d->bpid; in qbman_swp_release_mem_back() 1525 __le16 bpid; member 1566 p->bpid = cpu_to_le16(bpid); in qbman_swp_acquire() 1573 bpid); in qbman_swp_acquire() 1583 bpid, r->rslt); in qbman_swp_acquire() 1760 __le16 bpid; member 1774 p->bpid = cpu_to_le16(bpid); in qbman_bp_query() 1778 bpid); in qbman_bp_query() [all …]
|
/dports/multimedia/v4l-utils/linux-5.13-rc2/drivers/soc/fsl/dpio/ |
H A D | qbman-portal.c | 1419 d->bpid = cpu_to_le16(bpid); in qbman_release_desc_set_bpid() 1470 p->bpid = d->bpid; in qbman_swp_release_direct() 1512 p->bpid = d->bpid; in qbman_swp_release_mem_back() 1525 __le16 bpid; member 1566 p->bpid = cpu_to_le16(bpid); in qbman_swp_acquire() 1573 bpid); in qbman_swp_acquire() 1583 bpid, r->rslt); in qbman_swp_acquire() 1760 __le16 bpid; member 1774 p->bpid = cpu_to_le16(bpid); in qbman_bp_query() 1778 bpid); in qbman_bp_query() [all …]
|
/dports/comms/mgetty+sendfax/mgetty-1.1.37/ |
H A D | locks.c | 329 int bpid; /* must be 4 bytes wide! */ variable 330 bpid = getpid(); 331 if ( write(fd, &bpid, sizeof(bpid) ) != sizeof(bpid) )
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/protocol/ |
H A D | FinalizeCommand.java | 34 public FinalizeCommand(String bpid) { in FinalizeCommand() argument 36 blockPoolId = bpid; in FinalizeCommand()
|