- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 268 for Println (0.16 sec)
-
internal/dsync/drwmutex_test.go
drwm1.RUnlock(context.Background()) // fmt.Println("1st read lock released, waiting...") }() go func() { time.Sleep(3 * testDrwMutexAcquireTimeout) drwm2.RUnlock(context.Background()) // fmt.Println("2nd read lock released, waiting...") }() drwm3 := NewDRWMutex(ds, "simplelock") // fmt.Println("Trying to acquire write lock, waiting...") ctx3, cancel3 := context.WithCancel(context.Background())
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Dec 24 03:49:07 GMT 2022 - 9.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/WebPlatformUrlTest.kt
if (!testData.scheme.isEmpty() && !HTTP_URL_SCHEMES.contains(testData.scheme)) { System.err.println("Ignoring unsupported scheme ${testData.scheme}") return } if (!testData.base!!.startsWith("https:") && !testData.base!!.startsWith("http:") && testData.base != "about:blank" ) { System.err.println("Ignoring unsupported base ${testData.base}") return } try {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 4.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/RouteFailureTest.kt
val proxyServer1 = InetAddress.getByAddress("proxyServer1", byteArrayOf(127, 0, 0, 2)) val proxyServer2 = InetAddress.getByAddress("proxyServer2", byteArrayOf(127, 0, 0, 3)) println("Proxy Server 1 is ${server1.inetSocketAddress}") println("Proxy Server 2 is ${server2.inetSocketAddress}") // Since myproxy:8008 won't resolve, redirect with DNS to proxyServer1 // Then redirect socket connection to server1
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 11.9K bytes - Viewed (0) -
internal/lsync/lrwmutex_test.go
panic("Failed to acquire read lock") } // fmt.Println("1st read lock acquired, waiting...") if !lrwm.GetRLock(ctx, "", "object1", time.Second) { panic("Failed to acquire read lock") } // fmt.Println("2nd read lock acquired, waiting...") go func() { time.Sleep(2 * time.Second) lrwm.RUnlock() // fmt.Println("1st read lock released, waiting...") }() go func() {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Mar 05 04:57:35 GMT 2023 - 7.9K bytes - Viewed (0) -
buildscripts/heal-manual.go
if err != nil { log.Fatalln(err) } fmt.Println("Healstart sequence ===") enc := json.NewEncoder(os.Stdout) if err = enc.Encode(&start); err != nil { log.Fatalln(err) } fmt.Println() for { _, status, err := madmClnt.Heal(context.Background(), "healing-rewrite-bucket", "", opts, start.ClientToken, false, false) if status.Summary == "finished" { fmt.Println("Healstatus on items ===")
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 27 09:47:58 GMT 2024 - 2.3K bytes - Viewed (0) -
internal/grid/README.md
Sample handler: ```go handler := func(ctx context.Context, payload []byte, in <-chan []byte, out chan<- []byte) *RemoteErr { fmt.Println("Got request with initial payload", p, "from", GetCaller(ctx context.Context)) fmt.Println("Subroute:", GetSubroute(ctx)) for { select { case <-ctx.Done(): return nil case req, ok := <-in:
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 9.4K bytes - Viewed (0) -
okcurl/src/main/kotlin/okhttp3/curl/internal/-MainCommon.kt
val request = createRequest() try { val response = client!!.newCall(request).execute() if (showHeaders) { println(StatusLine.get(response)) val headers = response.headers for ((name, value) in headers) { println("$name: $value") } println() } // Stream the response to the System.out as it is returned from the server. val out = System.out.sink()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2.7K bytes - Viewed (0) -
internal/s3select/sql/parser_test.go
t.Fatalf("%d: %v", i, err) } // repr.Println(id, repr.Indent(" "), repr.OmitEmpty(true)) } invalidCases := []string{ "+a", "-a", "1a", `"ab`, `abc"`, `aa""a`, `"a"a"`, } for i, tc := range invalidCases { err := p.ParseString(tc, &id) if err == nil { t.Fatalf("%d: %v", i, err) } // fmt.Println(tc, err) } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 9.2K bytes - Viewed (0) -
src/test/java/org/codelibs/core/io/ResourceTraversalTest.java
ResourceTraversalUtil.forEach(con.getJarFile(), (ResourceHandler) (path, is) -> { try { if (count < 10) { System.out.println(path); } System.out.println(path); assertThat(path, is(notNullValue())); assertThat(path, path.startsWith("junit") || path.startsWith("org/junit") || path.startsWith("org/hamcrest")
Java - Registered: Fri May 03 20:58:11 GMT 2024 - Last Modified: Thu Mar 07 01:59:08 GMT 2024 - 6K bytes - Viewed (0) -
analysis/analysis-api-fir/analysis-api-fir-generator/src/org/jetbrains/kotlin/analysis/api/fir/generator/rendererrs/KtDiagnosticClassImplementationRenderer.kt
for (diagnostic in diagnosticList.diagnostics) { printDiagnosticImplementation(diagnostic, diagnosticList) println() } } private fun SmartPrinter.printDiagnosticImplementation(diagnostic: HLDiagnostic, diagnosticList: HLDiagnosticList) { println("internal class ${diagnostic.implClassName}(") withIndent { printParameters(diagnostic, diagnosticList) }
Plain Text - Registered: Fri Apr 26 08:18:10 GMT 2024 - Last Modified: Tue Jul 18 11:49:20 GMT 2023 - 2.8K bytes - Viewed (0)