1 126 168 green 0.00 2.0 0.0 44 36 6.26 1268 115.02 2 Bronx 011502 2011502 E BX27 Hunts Point 3710 2085 43 2 Bronx 004300 2004300 E BX39 Mott Haven-Port Morris 3710 3389260 2 2014-03-18 10:44:11 2014-03-18 10:50:41 N 1 -73.889472961425781 40.819126129150391 -73.93768310546875 40.838615417480469 1 1.26 6.5 0 0.5 0 0 7 2 1 126 244 green 0.00 0.0 0.0 43 28 6.93 1268 115.02 2 Bronx 011502 2011502 E BX27 Hunts Point 3710 45 249 1 Manhattan 024900 1024900 E MN36 Washington Heights South 3801 3389261 1 2014-03-11...

	for i, testCase := range testCases {
		// initialize HTTP NewRecorder, this records any mutations to response writer inside the handler.
		rec := httptest.NewRecorder()
		// construct HTTP request for Get Object end point.
		req, err := newTestSignedRequestV4(http.MethodHead, getHeadObjectURL("", testCase.bucketName, testCase.objectName),
			0, nil, testCase.accessKey, testCase.secretKey, nil)
		if err != nil {

    public void addDocumentMappingRewriteRule(final UnaryOperator<String> rule) {
        docMappingRewriteRuleList.add(rule);
    }

    /**
     * Updates index aliases to point to a new index.
     *
     * @param newIndex the new index to point aliases to
     * @return true if the alias update was successful, false otherwise
     */
    public boolean updateAlias(final String newIndex) {

// on remote clusters, and creating replication rules on local and peer
// clusters.
func (c *SiteReplicationSys) MakeBucketHook(ctx context.Context, bucket string, opts MakeBucketOptions) error {
	// At this point, the local bucket is created.

	c.RLock()
	defer c.RUnlock()
	if !c.enabled {
		return nil
	}

	optsMap := make(map[string]string)
	if opts.LockEnabled {
		optsMap["lockEnabled"] = "true"

            if (valueReference.isLoading()) {
              return waitForLoadingValue(e, key, valueReference);
            }
          }
        }

        // at this point e is either null or expired;
        return lockedGetOrLoad(key, hash, loader);
      } catch (ExecutionException ee) {
        Throwable cause = ee.getCause();
        if (cause instanceof Error) {

    // number 0. Since the client may have attempted to reuse the broken connection just before
    // creating a fresh connection, the server may have recorded 2 requests at this point. The order
    // of recording is non-deterministic.
    val requestAfter = server.takeRequest()
    assertThat(
      requestAfter.exchangeIndex == 0 ||
        server.requestCount == 3 &&

                    final UniAddress addr = UniAddress.getByName(dr.server);
                    final SmbTransport trans = SmbTransport.getSmbTransport(addr, url.getPort());
                    /* This is a key point. This is where we set the "tree" of this file which
                     * is like changing the rug out from underneath our feet.
                     */

        }
      }
    callA.enqueue(callback)
    callB.enqueue(callback)
    assertThat(server.takeRequest().url.encodedPath).isEqualTo("/a")
    callback.await(requestA.url).assertBody("A")
    // At this point we know the callback is ready, and that it will receive a cancel failure.
    callback
      .await(requestB.url)
      .assertFailure("canceled", "Canceled", "Socket closed", "Socket is closed")
  }

  @Test

		srcInfo.metadataOnly = true
		srcInfo.keyRotation = true
	} else {
		if isSourceEncrypted || isTargetEncrypted {
			// We are not only copying just metadata instead
			// we are creating a new object at this point, even
			// if source and destination are same objects.
			if !srcInfo.keyRotation {
				srcInfo.metadataOnly = false
			}
		}

		// Calculate the size of the target object
		var targetSize int64

                If the servers `list` is not provided, or is an empty `list`, the
                `servers` property in the generated OpenAPI will be:

                * a `dict` with a `url` value of the application's mounting point
                (`root_path`) if it's different from `/`.
                * otherwise, the `servers` property will be omitted from the OpenAPI
                schema.