| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/ |
| H A D | BlockStorageLocationUtil.java | 90 DatanodeInfo datanode = entry.getKey(); in createVolumeBlockLocationCallables() local
161 DatanodeInfo datanode = callable.getDatanodeInfo(); in queryDatanodesForHdfsBlocksMetadata() local
237 DatanodeInfo datanode = entry.getKey(); in associateVolumeIdsWithBlocks() local
321 private final DatanodeInfo datanode; field in BlockStorageLocationUtil.VolumeBlockLocationCallable
329 DatanodeInfo datanode, String poolId, long []blockIds, in VolumeBlockLocationCallable()
|
| /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 | TestTransferRbw.java | 56 private static ReplicaBeingWritten getRbw(final DataNode datanode, in getRbw()
60 private static ReplicaInPipeline getReplica(final DataNode datanode, in getReplica()
|
| H A D | TestDataNodeMetrics.java | 72 DataNode datanode = datanodes.get(0); in testDataNodeMetrics() local
97 DataNode datanode = datanodes.get(0); in testSendDataPacketMetrics() local
130 DataNode datanode = datanodes.get(0); in testReceivePacketMetrics() local
267 DataNode datanode = datanodes.get(0); in testDataNodeTimeSpend() local
|
| H A D | TestTriggerBlockReport.java | 92 DataNode datanode = cluster.getDataNodes().get(0); in testTriggerBlockReport() local
|
| /dports/science/netcdf/netcdf-c-4.7.4/oc2/ |
| H A D | oc.c | 1084 oc_data_root(OCobject link, OCobject datanode, OCobject* rootp) in oc_data_root()
1247 oc_data_ddsnode(OCobject link, OCobject datanode, OCobject* nodep) in oc_data_ddsnode()
1275 oc_data_octype(OCobject link, OCobject datanode, OCtype* typep) in oc_data_octype()
1302 oc_data_indexable(OCobject link, OCobject datanode) in oc_data_indexable()
1326 oc_data_indexed(OCobject link, OCobject datanode) in oc_data_indexed()
1370 oc_data_read(OCobject link, OCobject datanode, in oc_data_read()
1420 oc_data_readscalar(OCobject link, OCobject datanode, in oc_data_readscalar()
1454 oc_data_readn(OCobject link, OCobject datanode, in oc_data_readn()
1896 oc_data_ddpath(OCobject link, OCobject datanode, char** resultp) in oc_data_ddpath()
1933 oc_data_mode(OCobject link, OCobject datanode, OCDT* modep) in oc_data_mode()
[all …]
|
| /dports/math/libmesh/libmesh-1.6.2/contrib/netcdf/netcdf-c-4.6.2/oc2/ |
| H A D | oc.c | 1084 oc_data_root(OCobject link, OCobject datanode, OCobject* rootp) in oc_data_root()
1247 oc_data_ddsnode(OCobject link, OCobject datanode, OCobject* nodep) in oc_data_ddsnode()
1275 oc_data_octype(OCobject link, OCobject datanode, OCtype* typep) in oc_data_octype()
1302 oc_data_indexable(OCobject link, OCobject datanode) in oc_data_indexable()
1326 oc_data_indexed(OCobject link, OCobject datanode) in oc_data_indexed()
1370 oc_data_read(OCobject link, OCobject datanode, in oc_data_read()
1420 oc_data_readscalar(OCobject link, OCobject datanode, in oc_data_readscalar()
1454 oc_data_readn(OCobject link, OCobject datanode, in oc_data_readn()
1896 oc_data_ddpath(OCobject link, OCobject datanode, char** resultp) in oc_data_ddpath()
1933 oc_data_mode(OCobject link, OCobject datanode, OCDT* modep) in oc_data_mode()
[all …]
|
| /dports/devel/hadoop/hadoop-1.2.1/src/hdfs/org/apache/hadoop/hdfs/server/datanode/ |
| H A D | DataXceiverServer.java | 48 DataNode datanode; field in DataXceiverServer
112 DataNode datanode) { in DataXceiverServer()
|
| /dports/devel/hadoop/hadoop-1.2.1/src/hdfs/org/apache/hadoop/hdfs/server/balancer/ |
| H A D | Balancer.java | 444 BalancerDatanode datanode) { in isLocatedOnDatanode()
474 private BalancerDatanode datanode; //target node field in Balancer.NodeTask
478 private NodeTask(BalancerDatanode datanode, long size) { in NodeTask()
495 static private double getUtilization(DatanodeInfo datanode) { in getUtilization()
502 protected DatanodeInfo datanode; field in Balancer.BalancerDatanode
662 BalancerDatanode datanode = datanodes.get(location); in getBlockList() local
1167 final D datanode = i.next(); in chooseDatanodes() local
1457 private boolean isOverUtilized(BalancerDatanode datanode) { in isOverUtilized()
1463 private boolean isAboveAvgUtilized(BalancerDatanode datanode) { in isAboveAvgUtilized()
1469 private boolean isUnderUtilized(BalancerDatanode datanode) { in isUnderUtilized()
[all …]
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/namenode/ |
| H A D | TestFavoredNodesEndToEnd.java | 90 InetSocketAddress datanode[] = getDatanodes(rand); in testFavoredNodesEndToEnd() local
171 InetSocketAddress datanode[] = getDatanodes(rand); in testFavoredNodesEndToEndForAppend() local
199 private String[] getStringForInetSocketAddrs(InetSocketAddress[] datanode) { in getStringForInetSocketAddrs()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/ |
| H A D | CacheReplicationMonitor.java | 507 DatanodeDescriptor datanode = iter.next(); in rescanCachedBlockMap() local
531 DatanodeDescriptor datanode = iter.next(); in rescanCachedBlockMap() local
546 DatanodeDescriptor datanode = iter.next(); in rescanCachedBlockMap() local
608 DatanodeDescriptor datanode = in addNewPendingUncached() local
652 DatanodeDescriptor datanode = blockInfo.getDatanode(i); in addNewPendingCached() local
|
| H A D | CorruptReplicasMap.java | 108 boolean removeFromCorruptReplicasMap(Block blk, DatanodeDescriptor datanode) { in removeFromCorruptReplicasMap()
112 boolean removeFromCorruptReplicasMap(Block blk, DatanodeDescriptor datanode, in removeFromCorruptReplicasMap()
|
| H A D | DecommissionManager.java | 496 private void pruneSufficientlyReplicated(final DatanodeDescriptor datanode, in pruneSufficientlyReplicated()
512 final DatanodeDescriptor datanode) { in handleInsufficientlyReplicated()
536 final DatanodeDescriptor datanode, in processBlocksForDecomInternal()
|
| /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 | BlockPoolSliceStorage.java | 146 private StorageDirectory loadStorageDirectory(DataNode datanode, in loadStorageDirectory()
206 DataNode datanode, NamespaceInfo nsInfo, in loadBpStorageDirectories()
241 void recoverTransitionRead(DataNode datanode, NamespaceInfo nsInfo, in recoverTransitionRead()
349 private void doTransition(DataNode datanode, StorageDirectory sd, in doTransition()
421 void doUpgrade(DataNode datanode, StorageDirectory bpSd, NamespaceInfo nsInfo) in doUpgrade()
643 private void linkAllBlocks(DataNode datanode, File fromDir, File toDir) in linkAllBlocks()
|
| H A D | BlockScanner.java | 56 private final DataNode datanode; field in BlockScanner
168 public BlockScanner(DataNode datanode, Configuration conf) { in BlockScanner()
346 DataNode datanode = (DataNode) in doGet() local
|
| H A D | DataStorage.java | 259 private StorageDirectory loadStorageDirectory(DataNode datanode, in loadStorageDirectory()
314 public VolumeBuilder prepareVolume(DataNode datanode, File volume, in prepareVolume()
362 synchronized List<StorageLocation> addStorageLocations(DataNode datanode, in addStorageLocations()
467 void recoverTransitionRead(DataNode datanode, NamespaceInfo nsInfo, in recoverTransitionRead()
658 private void doTransition( DataNode datanode, in doTransition()
743 void doUpgrade(DataNode datanode, StorageDirectory sd, NamespaceInfo nsInfo) in doUpgrade()
969 private void linkAllBlocks(DataNode datanode, File fromDir, File fromBbwDir, in linkAllBlocks()
1010 static void linkBlocks(DataNode datanode, File from, File to, int oldLV, in linkBlocks()
|
| H A D | DataXceiverServer.java | 46 private final DataNode datanode; field in DataXceiverServer
110 DataNode datanode) { in DataXceiverServer()
|
| H A D | DirectoryScanner.java | 66 private final DataNode datanode; field in DirectoryScanner
312 DirectoryScanner(DataNode datanode, FsDatasetSpi<?> dataset, Configuration conf) { in DirectoryScanner()
594 private final DataNode datanode; field in DirectoryScanner.ReportCompiler
596 public ReportCompiler(DataNode datanode, FsVolumeSpi volume) { in ReportCompiler()
|
| /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 | FsDatasetFactory.java | 32 public FsDatasetImpl newInstance(DataNode datanode, in newInstance()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/ |
| H A D | FileChecksumServlets.java | 92 final DatanodeID datanode = NamenodeJspHelper.getRandomDatanode(namenode); in doGet() local
117 final DataNode datanode = (DataNode) context.getAttribute("datanode"); in doGet() local
|
| /dports/devel/hadoop/hadoop-1.2.1/src/test/org/apache/hadoop/hdfs/server/datanode/ |
| H A D | TestDataNodeMetrics.java | 43 DataNode datanode = datanodes.get(0); in testDataNodeMetrics() local
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/shortcircuit/ |
| H A D | DfsClientShmManager.java | 75 private final DatanodeInfo datanode; field in DfsClientShmManager.EndpointShmManager
109 EndpointShmManager (DatanodeInfo datanode) { in EndpointShmManager()
420 public Slot allocSlot(DatanodeInfo datanode, DomainPeer peer, in allocSlot()
|
| /dports/devel/hadoop/hadoop-1.2.1/src/hdfs/org/apache/hadoop/hdfs/server/protocol/ |
| H A D | NamenodeProtocol.java | 51 public BlocksWithLocations getBlocks(DatanodeInfo datanode, long size) in getBlocks()
|
| /dports/math/SCIP/scip-7.0.3/src/scip/ |
| H A D | reader_osil.c | 76 const XML_NODE* datanode, /**< XML root node for instance data */ in readVariables()
290 const XML_NODE* datanode, /**< XML root node for instance data */ in readObjective()
436 const XML_NODE* datanode, /**< XML root node for instance data */ in readConstraints()
672 const XML_NODE* datanode, /**< XML root node for instance data */ in readLinearCoefs()
1012 const XML_NODE* datanode, /**< XML root node for instance data */ in readQuadraticCoefs()
1946 const XML_NODE* datanode, /**< XML root node for instance data */ in readNonlinearExprs()
2277 const XML_NODE* datanode, /**< XML root node for instance data */ in readSOScons()
|
| /dports/math/libmesh/libmesh-1.6.2/contrib/netcdf/netcdf-c-4.6.2/ncdump/ |
| H A D | ocprint.c | 70 OCdatanode datanode; member
517 printdata(OClink link, OCdatanode datanode) in printdata()
539 printdata_container(OClink link, OCdatanode datanode, NCbytes* buffer, int istoplevel) in printdata_container()
573 printdata_indices(OClink link, OCdatanode datanode, NCbytes* buffer, int istoplevel) in printdata_indices()
640 printdata_leaf(OClink link, OCdatanode datanode, NCbytes* buffer, int istoplevel) in printdata_leaf()
999 dumpdatanode(OClink link, OCdatanode datanode, size_t count, void* memory, NCbytes* buffer) in dumpdatanode()
1155 pushstack(OCdatanode datanode) in pushstack()
1180 OCdatanode datanode = entry->datanode; in printstack() local
|
| /dports/science/netcdf/netcdf-c-4.7.4/ncdump/ |
| H A D | ocprint.c | 66 OCdatanode datanode; member
513 printdata(OClink link, OCdatanode datanode) in printdata()
535 printdata_container(OClink link, OCdatanode datanode, NCbytes* buffer, int istoplevel) in printdata_container()
569 printdata_indices(OClink link, OCdatanode datanode, NCbytes* buffer, int istoplevel) in printdata_indices()
636 printdata_leaf(OClink link, OCdatanode datanode, NCbytes* buffer, int istoplevel) in printdata_leaf()
995 dumpdatanode(OClink link, OCdatanode datanode, size_t count, void* memory, NCbytes* buffer) in dumpdatanode()
1151 pushstack(OCdatanode datanode) in pushstack()
1176 OCdatanode datanode = entry->datanode; in printstack() local
|