import org.apache.hadoop.fs.swift.http.SwiftProtocolConstants; //导入依赖的package包/类
/**
 * Tell the Swift server to expect a multi-part upload by submitting
 * a 0-byte file with the X-Object-Manifest header
 *
 * @param path path of final final
 * @throws IOException
 */
public void createManifestForPartUpload(Path path) throws IOException {
  String pathString = toObjectPath(path).toString();
  if (!pathString.endsWith("/")) {
    pathString = pathString.concat("/");
  }
  if (pathString.startsWith("/")) {
    pathString = pathString.substring(1);
  }

  swiftRestClient.upload(toObjectPath(path),
          new ByteArrayInputStream(new byte[0]),
          0,
          new Header(SwiftProtocolConstants.X_OBJECT_MANIFEST, pathString));
}
 

import org.apache.hadoop.fs.swift.http.SwiftProtocolConstants; //导入依赖的package包/类
/**
 * Get a configuration which a small blocksize reported to callers
 * @return a configuration for this test
 */
@Override
public Configuration getConf() {
  Configuration conf = super.getConf();
  /*
   * set to 4KB
   */
  conf.setInt(SwiftProtocolConstants.SWIFT_BLOCKSIZE, SWIFT_READ_BLOCKSIZE);
  return conf;
}
 

import org.apache.hadoop.fs.swift.http.SwiftProtocolConstants; //导入依赖的package包/类
/**
 * Create a config with a 1KB request size
 * @return a config
 */
@Override
protected Configuration createConfiguration() {
  Configuration conf = super.createConfiguration();
  conf.set(SwiftProtocolConstants.SWIFT_REQUEST_SIZE, "1");
  return conf;
}
 

import org.apache.hadoop.fs.swift.http.SwiftProtocolConstants; //导入依赖的package包/类
@Override
protected Configuration createConfiguration() {
  Configuration conf = super.createConfiguration();
  //set the partition size to 1 KB
  conf.setInt(SwiftProtocolConstants.SWIFT_PARTITION_SIZE, PART_SIZE);
  return conf;
}
 

import org.apache.hadoop.fs.swift.http.SwiftProtocolConstants; //导入依赖的package包/类
@Override
@Before
public void setUp() throws Exception {
  Configuration conf = new Configuration();
  //small blocksize for faster remote tests
  conf.setInt(SwiftProtocolConstants.SWIFT_BLOCKSIZE, 2);
  URI serviceURI = SwiftTestUtils.getServiceURI(conf);
  fSys = FileSystem.get(serviceURI, conf);
  super.setUp();
}
 

import org.apache.hadoop.fs.swift.http.SwiftProtocolConstants; //导入依赖的package包/类
private void assertLocationValid(BlockLocation location) throws
                                                         IOException {
  LOG.info(location);
  String[] hosts = location.getHosts();
  String[] names = location.getNames();
  assertNotEqual("No hosts supplied for " + location, 0, hosts.length);
  //for every host, there's a name.
  assertEquals("Unequal names and hosts in " + location,
               hosts.length, names.length);
  assertEquals(SwiftProtocolConstants.BLOCK_LOCATION,
               location.getNames()[0]);
  assertEquals(SwiftProtocolConstants.TOPOLOGY_PATH,
               location.getTopologyPaths()[0]);
}