Home
last modified time | relevance | path

Searched refs:bpid (Results 51 – 75 of 1250) sorted by relevance

12345678910>>...50

/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/
H A DTestDFSFinalize.java68 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 DTestDatanodeReport.java60 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 DTestDFSStorageStateRecovery.java196 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 DFsDatasetCache.java259 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 DFsVolumeList.java141 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 DFsVolumeSpi.java54 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 DExternalVolumeImpl.java48 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 DTestInterDatanodeProtocol.java237 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 DTestFsDatasetImpl.java149 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 DTestDatanodeRestart.java120 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 DBodyPartReferenceTest.java40 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 Dupgradelib.php45 $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 DVolumeScanner.java687 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 DBlockScanner.java271 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 Dldpaa_eth.c67 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 DTestDiskError.java94 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 DTestBlockHasMultipleReplicasOnSameDN.java61 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 Ddpaa2-io.h118 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 Ddpaa2-io.h118 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 Ddpaa2-io.h118 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 Dqbman-portal.c1419 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 Dqbman-portal.c1419 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 Dqbman-portal.c1419 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 Dlocks.c329 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 DFinalizeCommand.java34 public FinalizeCommand(String bpid) { in FinalizeCommand() argument
36 blockPoolId = bpid; in FinalizeCommand()

12345678910>>...50