Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 121 - 130 of 1,340 for readN (0.02 seconds)

  1. internal/deadlineconn/deadlineconn_test.go

    		defer deadlineconn.Close()
    
    		// Read a line
    		b := make([]byte, 12)
    		_, terr = deadlineconn.Read(b)
    		if terr != nil {
    			t.Errorf("failed to read from client. %v", terr)
    			return
    		}
    		received := string(b)
    		if received != "message one\n" {
    			t.Errorf(`server: expected: "message one\n", got: %v`, received)
    			return
    		}
    
    		// Wait for more than read timeout to simulate processing.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Mon Nov 11 17:15:17 GMT 2024
    - 4.8K bytes
    - Click Count (0)
  2. docs/en/docs/virtual-environments.md

    ```console
    $ deactivate
    ```
    
    </div>
    
    This way, when you run `python` it won't try to run it from that virtual environment with the packages installed there.
    
    ## Ready to Work { #ready-to-work }
    
    Now you're ready to start working on your project.
    
    
    
    /// tip
    
    Do you want to understand what's all that above?
    
    Continue reading. 👇🤓
    
    ///
    
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Tue Dec 02 05:09:25 GMT 2025
    - 22.8K bytes
    - Click Count (0)
  3. docs/en/docs/management-tasks.md

    This way, we can notice when there are new translations ready, because they have the `approved-1` label.
    
    ## Merge Translation PRs
    
    For Spanish, as I'm a native speaker and it's a language close to me, I will give it a final review myself and in most cases tweak the PR a bit before merging it.
    
    For the other languages, confirm that:
    
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Wed Dec 17 20:41:43 GMT 2025
    - 14.2K bytes
    - Click Count (0)
  4. cmd/erasure-multipart-conditional_test.go

    	if err != nil {
    		t.Fatal(err)
    	}
    	existingETag := objInfo.ETag
    
    	// Simulate read quorum failure by taking enough disks offline
    	// With 16 disks (EC 8+8), read quorum is 9. Taking 8 disks offline leaves only 8,
    	// which is below read quorum.
    	erasureDisks := xl.getDisks()
    	z.serverPools[0].erasureDisksMu.Lock()
    	xl.getDisks = func() []StorageAPI {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Oct 24 04:05:31 GMT 2025
    - 6.9K bytes
    - Click Count (0)
  5. docs/en/docs/how-to/general.md

    To ensure that you don't return more data than you should, read the docs for [Tutorial - Response Model - Return Type](../tutorial/response-model.md){.internal-link target=_blank}.
    
    ## Documentation Tags - OpenAPI { #documentation-tags-openapi }
    
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Sun Aug 31 09:15:41 GMT 2025
    - 2.6K bytes
    - Click Count (0)
  6. internal/ringbuffer/ring_buffer_test.go

    		t.Errorf("Read error: got %T, want testError1", err)
    	}
    	if _, err := rb.TryRead([]byte{0}); err != (testError1{}) {
    		t.Errorf("Read error: got %T, want testError1", err)
    	}
    	rb.CloseWithError(testError2{})
    	if _, err := rb.Read(nil); err != (testError1{}) {
    		t.Errorf("Read error: got %T, want testError1", err)
    	}
    	if _, err := rb.Read([]byte{0}); err != (testError1{}) {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 26.7K bytes
    - Click Count (0)
  7. internal/logger/target/http/http.go

    	maxWorkers int64
    
    	// workerStartMu sync.Mutex
    	lastStarted time.Time
    
    	wg sync.WaitGroup
    
    	// Channel of log entries.
    	// Reading logCh must hold read lock on logChMu (to avoid read race)
    	// Sending a value on logCh must hold read lock on logChMu (to avoid closing)
    	logCh   chan any
    	logChMu sync.RWMutex
    
    	// If this webhook is being re-configured we will
    	// assign the new webhook target to this field.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 15.6K bytes
    - Click Count (0)
  8. compat/maven-model-builder/src/main/java/org/apache/maven/model/io/DefaultModelReader.java

        @Override
        public Model read(File input, Map<String, ?> options) throws IOException {
            Objects.requireNonNull(input, "input cannot be null");
    
            Model model = read(new FileInputStream(input), options);
    
            model.setPomFile(input);
    
            return model;
        }
    
        @Override
        public Model read(Reader input, Map<String, ?> options) throws IOException {
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Fri Jan 10 07:09:12 GMT 2025
    - 3.4K bytes
    - Click Count (0)
  9. fastapi/routing.py

                    WebSocket.
    
                    Read more about it in the
                    [FastAPI docs for WebSockets](https://fastapi.tiangolo.com/advanced/websockets/).
                    """
                ),
            ] = None,
        ) -> Callable[[DecoratedCallable], DecoratedCallable]:
            """
            Decorate a WebSocket function.
    
            Read more about it in the
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Sat Dec 27 12:54:56 GMT 2025
    - 174.6K bytes
    - Click Count (0)
  10. buildscripts/verify-build.sh

    	"${MINIO[@]}" server "${WORK_DIR}/fs-disk" >"$WORK_DIR/fs-minio.log" 2>&1 &
    
    	"${WORK_DIR}/mc" ready verify
    }
    
    function start_minio_erasure() {
    	"${MINIO[@]}" server "${WORK_DIR}/erasure-disk1" "${WORK_DIR}/erasure-disk2" "${WORK_DIR}/erasure-disk3" "${WORK_DIR}/erasure-disk4" >"$WORK_DIR/erasure-minio.log" 2>&1 &
    
    	"${WORK_DIR}/mc" ready verify
    }
    
    function start_minio_erasure_sets() {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri May 24 19:28:51 GMT 2024
    - 6.7K bytes
    - Click Count (0)
Back to Top