- Sort Score
- Num 10 results
- Language All
Results 461 - 470 of 551 for state (0.02 seconds)
-
internal/s3select/progress.go
pr.closedMu.Lock() defer pr.closedMu.Unlock() if pr.closed { return nil } pr.closed = true if pr.closer != nil { pr.closer.Close() } return pr.rc.Close() } func (pr *progressReader) Stats() (bytesScanned, bytesProcessed int64) { if pr == nil { return 0, 0 } return pr.scannedReader.BytesRead(), pr.processedReader.BytesRead() }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 22 00:33:43 GMT 2024 - 4.3K bytes - Click Count (0) -
cmd/http-tracer.go
func httpTracerMiddleware(h http.Handler) http.Handler { return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) { // Setup a http request response recorder - this is needed for // http stats requests and audit if enabled. respRecorder := xhttp.NewResponseRecorder(w) // Setup a http request body recorder reqRecorder := &xhttp.RequestRecorder{Reader: r.Body} r.Body = reqRecorder
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Sep 24 17:13:00 GMT 2024 - 6K bytes - Click Count (0) -
internal/lock/lock_solaris.go
return nil, err } if err = syscall.FcntlFlock(f.Fd(), rlockType, &lock); err != nil { f.Close() if err == syscall.EAGAIN { err = ErrAlreadyLocked } return nil, err } st, err := os.Stat(path) if err != nil { f.Close() return nil, err } if st.IsDir() { f.Close() return nil, &os.PathError{ Op: "open", Path: path, Err: syscall.EISDIR, } }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Jan 02 17:15:06 GMT 2022 - 2.8K bytes - Click Count (0) -
cmd/os_unix.go
} // Fallback for filesystems (like old XFS) that don't // support Dirent.Type and have DT_UNKNOWN (0) there // instead. if typ == unexpectedFileMode || typ&os.ModeSymlink == os.ModeSymlink { fi, err := Stat(pathJoin(dirPath, string(name))) if err != nil { // It got deleted in the meantime, not found // or returns too many symlinks ignore this // file/directory.
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 9.3K bytes - Click Count (0) -
internal/logger/target/testlogger/testlogger.go
tb := t.current.Load() if tb != nil { tbb := *tb return tbb.Name() } return "" } func (t *testLogger) Endpoint() string { return "" } func (t *testLogger) Stats() types.TargetStats { return types.TargetStats{} } func (t *testLogger) Init(ctx context.Context) error { return nil } func (t *testLogger) IsOnline(ctx context.Context) bool {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 4K bytes - Click Count (0) -
docs/features/calls.md
## Retrying Requests Sometimes connections fail: either a pooled connection was stale and disconnected, or the webserver itself couldn’t be reached. OkHttp will retry the request with a different route if one is available. ## [Calls](https://square.github.io/okhttp/4.x/okhttp/okhttp3/-call/)
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Sun Feb 06 02:19:09 GMT 2022 - 3.9K bytes - Click Count (0) -
docs/debugging/healing-bin/main.go
ht := make(map[string]map[string]any) file := c.Args().Get(0) if strings.HasSuffix(file, ".zip") { var sz int64 f, err := os.Open(file) if err != nil { return err } if st, err := f.Stat(); err == nil { sz = st.Size() } defer f.Close() zr, err := zip.NewReader(f, sz) if err != nil { return err } for _, file := range zr.File {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 3.1K bytes - Click Count (0) -
docs/features/connections.md
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Mon Feb 21 03:33:59 GMT 2022 - 5.4K bytes - Click Count (0) -
docs/tr/docs/project-generation.md
* **Vuex**. * **Vue-router**. * **Vuetify** güzel material design kompanentleri için. * **TypeScript**. * **Nginx** tabanlı Docker sunucusu (Vue-router için yapılandırılmış). * Docker ile multi-stage yapı, böylece kodu derlemeniz, kaydetmeniz veya işlemeniz gerekmez. * Derleme zamanında Frontend testi (devre dışı bırakılabilir).Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Mon Jul 29 23:35:07 GMT 2024 - 6K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/CacheTest.kt
.header("Cache-Control", "max-stale=180") .build() val response = client.newCall(request).execute() assertThat(response.body.string()).isEqualTo("A") assertThat(response.header("Warning")).isEqualTo( "110 HttpURLConnection \"Response is stale\"", ) } @Test fun requestMaxStaleDirectiveWithNoValue() { // Add a stale response to the cache. server.enqueue(
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Fri Oct 03 17:41:45 GMT 2025 - 116.8K bytes - Click Count (0)