- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 3,990 for cgoUse (0.11 sec)
-
platforms/core-execution/persistent-cache/src/test/groovy/org/gradle/cache/internal/FixedSharedModeCrossProcessCacheAccessTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 16 15:49:51 UTC 2024 - 5.5K bytes - Viewed (0) -
pilot/pkg/leaderelection/leaderelection_test.go
_, stop4 := createElection(t, "pod4", "green", watcher, false, client) close(stop2) close(stop3) close(stop4) // Now that revision "green" has stopped acting as leader, revision "red" should be able to claim lock. _, stop5 := createElection(t, "pod2", "red", watcher, true, client) close(stop5) close(stop) // Revision "green" can reclaim once "red" releases.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Apr 28 04:22:19 UTC 2024 - 11.4K bytes - Viewed (0) -
.github/DISCUSSION_TEMPLATE/questions.yml
And there's a high chance that you will find the solution along the way and you won't even have to submit it and wait for an answer. 😎 As there are too many questions, I'll have to discard and close the incomplete ones. That will allow me (and others) to focus on helping people like you that follow the whole process and help us help you. 🤓 - type: checkboxes id: checks attributes: label: First Check
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Thu Aug 03 15:59:41 UTC 2023 - 5.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/ws/RealWebSocket.kt
synchronized(this) { queueSize -= message.data.size.toLong() } } else if (messageOrClose is Close) { val close = messageOrClose as Close writer!!.writeClose(close.code, close.reason) // We closed the writer: now both reader and writer are closed. if (streamsToClose != null) {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Apr 01 14:21:25 UTC 2024 - 22.1K bytes - Viewed (0) -
src/net/net_fake_test.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Sep 18 17:20:52 UTC 2023 - 2.8K bytes - Viewed (0) -
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) -
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) -
.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)