ahead - Code Search

cmd/server_test.go

	c.Assert(err, nil)
	// Since the "If-Modified-Since" header was ahead in time compared to the actual
	// modified time of the object expecting the response status to be http.StatusNotModified.
	c.Assert(response.StatusCode, http.StatusOK)
}

// TestHeadOnBucket - Validates response for HEAD on the bucket.
// HEAD request on the bucket validates the existence of the bucket.

Registered: Sun Jun 16 00:44:34 UTC 2024

- Last Modified: Fri May 24 23:05:23 UTC 2024

- 115.3K bytes

- Viewed (0)

github.com/golang/go

src/net/http/server.go

	// "keep-alive" connections alive.
	// Exceptions: 304/204/1xx responses never get Content-Length, and if
	// it was a HEAD request, we don't know the difference between
	// 0 actual bytes and 0 bytes because the handler noticed it
	// was a HEAD request and chose not to write anything. So for
	// HEAD, the handler should either write the Content-Length or
	// write non-zero bytes. If it's actually 0 bytes and the

Registered: Wed Jun 12 16:32:35 UTC 2024

- Last Modified: Fri Jun 07 17:57:01 UTC 2024

- 123.4K bytes

- Viewed (0)

github.com/google/guava

android/guava/src/com/google/common/cache/LocalCache.java

    public void clear() {
      ReferenceEntry<K, V> e = head.getNextInWriteQueue();
      while (e != head) {
        ReferenceEntry<K, V> next = e.getNextInWriteQueue();
        nullifyWriteOrder(e);
        e = next;
      }

      head.setNextInWriteQueue(head);
      head.setPreviousInWriteQueue(head);
    }

    @Override
    public Iterator<ReferenceEntry<K, V>> iterator() {

Registered: Wed Jun 12 16:38:11 UTC 2024

- Last Modified: Sat May 18 03:24:34 UTC 2024

- 143.6K bytes

- Viewed (0)

github.com/google/guava

guava/src/com/google/common/cache/LocalCache.java

    public void clear() {
      ReferenceEntry<K, V> e = head.getNextInWriteQueue();
      while (e != head) {
        ReferenceEntry<K, V> next = e.getNextInWriteQueue();
        nullifyWriteOrder(e);
        e = next;
      }

      head.setNextInWriteQueue(head);
      head.setPreviousInWriteQueue(head);
    }

    @Override
    public Iterator<ReferenceEntry<K, V>> iterator() {

Registered: Wed Jun 12 16:38:11 UTC 2024

- Last Modified: Sat May 18 03:24:34 UTC 2024

- 149.2K bytes

- Viewed (0)

github.com/golang/go

src/runtime/proc.go

	if !q.empty() {
		q.tail.ptr().schedlink = l.head
		l.head = q.head
	}
}

// pop removes and returns the head of l. If l is empty, it returns nil.
func (l *gList) pop() *g {
	gp := l.head.ptr()
	if gp != nil {
		l.head = gp.schedlink
	}
	return gp
}

//go:linkname setMaxThreads runtime/debug.setMaxThreads
func setMaxThreads(in int) (out int) {
	lock(&sched.lock)

Registered: Wed Jun 12 16:32:35 UTC 2024

- Last Modified: Wed May 29 17:58:53 UTC 2024

- 207.5K bytes

- Viewed (0)

github.com/golang/go

src/net/http/transport_test.go

		if n != 0 || err == nil {
			t.Errorf("expected Read error after Close; got %d, %v", n, err)
		}
	}

	// And a HEAD request too, because they're always weird.
	res, err := c.Head(ts.URL)
	if err != nil {
		t.Fatalf("Head: %v", err)
	}
	if res.StatusCode != 200 {
		t.Errorf("Head status=%d; want=200", res.StatusCode)
	}
}

// A transport100Continue test exercises Transport behaviors when sending a

Registered: Wed Jun 12 16:32:35 UTC 2024

- Last Modified: Thu Jun 06 21:59:21 UTC 2024

- 192.6K bytes

- Viewed (0)

github.com/square/okhttp

okhttp/src/test/java/okhttp3/CacheTest.kt

    server.enqueue(
      MockResponse.Builder()
        .addHeader("Allow: GET, HEAD")
        .addHeader("Last-Modified: " + formatDate(-1, TimeUnit.HOURS))
        .addHeader("Cache-Control: max-age=0")
        .body("A")
        .build(),
    )
    server.enqueue(
      MockResponse.Builder()
        .addHeader("Allow: GET, HEAD, PUT")
        .code(HttpURLConnection.HTTP_NOT_MODIFIED)
        .build(),

Registered: Sun Jun 16 04:42:17 UTC 2024

- Last Modified: Wed Apr 10 19:46:48 UTC 2024

- 108.6K bytes

- Viewed (0)

github.com/kubernetes/kubernetes

pkg/scheduler/internal/queue/scheduling_queue_test.go

}

// TestRecentlyTriedPodsGoBack tests that pods which are recently tried and are
// unschedulable go behind other pods with the same priority. This behavior
// ensures that an unschedulable pod does not block head of the queue when there
// are frequent events that move pods to the active queue.
func TestRecentlyTriedPodsGoBack(t *testing.T) {
	c := testingclock.NewFakeClock(time.Now())
	logger, ctx := ktesting.NewTestContext(t)

Registered: Sat Jun 15 01:39:40 UTC 2024

- Last Modified: Wed Jun 12 13:26:09 UTC 2024

- 146.9K bytes

- Viewed (0)

github.com/square/okhttp

okhttp/src/test/java/okhttp3/CallTest.kt

    }
  }

  @Test
  fun head() {
    server.enqueue(
      MockResponse(
        headers = headersOf("Content-Type", "text/plain"),
      ),
    )
    val request =
      Request.Builder()
        .url(server.url("/"))
        .head()
        .header("User-Agent", "SyncApiTest")
        .build()
    executeSynchronously(request)

Registered: Sun Jun 16 04:42:17 UTC 2024

- Last Modified: Wed Apr 10 19:46:48 UTC 2024

- 142.5K bytes

- Viewed (0)

github.com/golang/go

src/net/http/serve_test.go

				}
				return nil
			},
		},
		{
			name: "sniff-on-first-write content-type",
			handler: func(rw ResponseWriter, r *Request) {
				rw.Write([]byte("<html><head></head><body>some html</body></html>"))
				rw.Header().Set("Content-Type", "x/wrong")
			},
			check: func(got, logs string) error {
				if !strings.Contains(got, "Content-Type: text/html") {

Registered: Wed Jun 12 16:32:35 UTC 2024

- Last Modified: Fri Jun 07 17:57:01 UTC 2024

- 202K bytes

- Viewed (0)

Search Options