- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 3,379 for FClose (0.24 sec)
-
src/net/http/httptest/server_test.go
t.Log(err) return } resp.Body.Close() }() wg.Add(1) conn := <-hijacked go func(conn net.Conn) { defer wg.Done() // Close the connection and then inform the Server that // we closed it. conn.Close() ts.Config.ConnState(conn, http.StateClosed) }(conn) wg.Add(1) go func() { defer wg.Done() ts.Close() }() wg.Wait() }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 18 16:57:12 UTC 2024 - 7.4K bytes - Viewed (0) -
src/net/tcpsock_test.go
if err == nil { <-ctx.Done() c.Close() } }() } c, err := ln.Accept() if err == nil { c.Close() } else { t.Error(err) } time.Sleep(10 * time.Millisecond) cancel() wg.Wait() ln.Close() c, err = ln.Accept() if !errors.Is(err, ErrClosed) { if err == nil { c.Close() } t.Errorf("after l.Close(), l.Accept() = _, %v\nwant %v", err, ErrClosed)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Feb 20 06:04:31 UTC 2024 - 17.7K bytes - Viewed (0) -
src/os/pipe_test.go
r, w, err := os.Pipe() if err != nil { t.Fatal(err) } defer r.Close() defer w.Close() // Close the read end of the pipe in a goroutine while we are // writing to the write end, or vice-versa. go func() { // Give the main goroutine a chance to enter the Read or // Write call. This is sloppy but the test will pass even // if we close before the read/write. time.Sleep(20 * time.Millisecond)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Sep 05 23:35:29 UTC 2023 - 12.4K bytes - Viewed (0) -
.github/workflows/stale-issues.yml
# limitations under the License. # ============================================================================ name: Close inactive issues on: schedule: - cron: "30 1 * * *" permissions: contents: read jobs: close-issues: # Don't do this in forks if: github.repository == 'tensorflow/tensorflow' runs-on: ubuntu-latest permissions: issues: write
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Nov 23 20:04:38 UTC 2023 - 4.1K bytes - Viewed (0) -
internal/s3select/json/reader.go
dstRec, ok := dst.(*Record) if !ok { dstRec = &Record{} } dstRec.KVS = kvs dstRec.SelectFormat = sql.SelectFmtJSON return dstRec, nil } // Close - closes underlying reader. func (r *Reader) Close() error { // Close the input. err := r.readCloser.Close() for range r.valueCh { // Drain values so we don't leak a goroutine. // Since we have closed the input, it should fail rather quickly. } return err }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Mar 24 03:58:53 UTC 2022 - 3K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/cache2/RelayTest.kt
val relay = edit(file, upstream, metadata, 1024) val source1 = relay.newSource() val source2 = relay.newSource() source1!!.close() source1.close() // Unnecessary. Shouldn't decrement the reference count. assertThat(relay.isClosed).isFalse() source2!!.close() assertThat(relay.isClosed).isTrue() assertFile(Relay.PREFIX_DIRTY, -1L, -1, null, null) } @Test fun racingReaders() {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Thu Apr 11 22:09:35 UTC 2024 - 8.1K bytes - Viewed (0) -
src/net/rpc/client_test.go
return errors.New("shutdownCodec ReadResponseHeader") } func (c *shutdownCodec) Close() error { c.closed = true return nil } func TestCloseCodec(t *testing.T) { codec := &shutdownCodec{responded: make(chan int)} client := NewClientWithCodec(codec) <-codec.responded client.Close() if !codec.closed { t.Error("client.Close did not close codec") } } // Test that errors in gob shut down the connection. Issue 7689.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Dec 13 18:45:54 UTC 2021 - 1.7K bytes - Viewed (0) -
src/net/http/response_test.go
{ "HTTP/1.0 200 OK\r\n" + "Connection: close\r\n" + "\r\n" + "Body here\n", Response{ Status: "200 OK", StatusCode: 200, Proto: "HTTP/1.0", ProtoMajor: 1, ProtoMinor: 0, Request: dummyReq("GET"), Header: Header{ "Connection": {"close"}, // TODO(rsc): Delete? }, Close: true, ContentLength: -1, }, "Body here\n",
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Mar 08 19:01:29 UTC 2024 - 23.6K bytes - Viewed (0) -
platforms/software/testing-base/src/test/groovy/org/gradle/api/internal/tasks/testing/junit/result/TestOutputStoreSpec.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Sep 18 20:52:40 UTC 2023 - 6.1K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/test/groovy/org/gradle/cache/internal/DefaultPersistentDirectoryStoreTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 14 16:40:49 UTC 2024 - 5.9K bytes - Viewed (0)