- Sort Score
- Num 10 results
- Language All
Results 121 - 130 of 1,340 for readN (0.02 seconds)
-
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) -
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) -
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) -
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) -
docs/en/docs/how-to/general.md
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) -
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) -
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) -
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) -
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 theCreated: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Sat Dec 27 12:54:56 GMT 2025 - 174.6K bytes - Click Count (0) -
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)