Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 461 - 470 of 551 for state (0.02 seconds)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. docs/features/connections.md

    If there's a problem with the connection, OkHttp will select another route and try again. This allows OkHttp to recover when a subset of a server's addresses are unreachable. It's also useful when a pooled connection is stale or if the attempted TLS version is unsupported.
    
    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)
  9. 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)
  10. 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)
Back to Top