- Sort Score
- Num 10 results
- Language All
Results 171 - 180 of 271 for unlink (0.06 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
cmd/xl-storage.go
ModTime: st.ModTime(), }) } return stat, nil } // CleanAbandonedData will read metadata of the object on disk // and delete any data directories and inline data that isn't referenced in metadata. // Metadata itself is not modified, only inline data. func (s *xlStorage) CleanAbandonedData(ctx context.Context, volume string, path string) error { if volume == "" || path == "" { return nil // Ignore }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 91.7K bytes - Click Count (0) -
docs/distributed/README.md
A stand-alone MinIO server would go down if the server hosting the drives goes offline. In contrast, a distributed MinIO setup with _m_ servers and _n_ drives will have your data safe as long as _m/2_ servers or _m*n_/2 or more drives are online. For example, an 16-server distributed setup with 200 drives per node would continue serving files, up to 4 servers can be offline in default configuration i.e around 800 drives down MinIO would continue to read and write objects.
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Aug 12 18:20:36 GMT 2025 - 8.9K bytes - Click Count (0) -
build-logic/binary-compatibility/src/test/kotlin/gradlebuild/binarycompatibility/AbstractBinaryCompatibilityTest.kt
assertThat("Has errors", richReport.errors, inAnyOrder(errorWithDetail.map { ReportMessage(it.first, it.second) })) } private inline fun <reified T> inAnyOrder(items: List<T>): Matcher<Iterable<T>> = inAnyOrder(items.toTypedArray()) /** * Matcher checking each item is present exactly once in a given iterable, but an any position,
Created: Wed Dec 31 11:36:14 GMT 2025 - Last Modified: Tue Dec 30 10:14:25 GMT 2025 - 18K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/ResponseBody.kt
* possibility for your response. */ @Throws(IOException::class) fun byteString() = consumeSource(BufferedSource::readByteString) { it.size } private inline fun <T : Any> ResponseBody.consumeSource( consumer: (BufferedSource) -> T, sizeMapper: (T) -> Int, ): T { val contentLength = contentLength() if (contentLength > Int.MAX_VALUE) {
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Tue May 27 14:51:25 GMT 2025 - 11.6K bytes - Click Count (0) -
internal/logger/target/kafka/kafka.go
if len(h.client.Brokers()) > 0 { // Refer https://github.com/IBM/sarama/issues/1341 atomic.StoreInt32(&h.status, statusOnline) } return nil } // IsOnline returns true if the target is online. func (h *Target) IsOnline(_ context.Context) bool { return atomic.LoadInt32(&h.status) == statusOnline } // Send log message 'e' to kafka target. func (h *Target) Send(ctx context.Context, entry any) error {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 10.2K bytes - Click Count (0) -
build-logic/documentation/src/main/groovy/gradlebuild/docs/dsl/docbook/JavadocConverter.java
} String href = attributes.get("href"); if (href.startsWith("#")) { return false; } Element element = document.createElement("ulink"); element.setAttribute("url", href); nodes.push(element); return true; } @Override public void onEndElement(String element) {Created: Wed Dec 31 11:36:14 GMT 2025 - Last Modified: Wed May 21 06:20:45 GMT 2025 - 29.3K bytes - Click Count (0) -
docs/en/docs/tutorial/dependencies/index.md
/// The dependencies will keep working as expected, and the **best part** is that the **type information will be preserved**, which means that your editor will be able to keep providing you with **autocompletion**, **inline errors**, etc. The same for other tools like `mypy`. This will be especially useful when you use it in a **large code base** where you use **the same dependencies** over and over again in **many *path operations***.
Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Sun Aug 31 09:15:41 GMT 2025 - 9.6K bytes - Click Count (0) -
compat/maven-embedder/src/main/java/org/apache/maven/cli/event/ExecutionEventLogger.java
} } @Override public void mojoSkipped(ExecutionEvent event) { if (logger.isWarnEnabled()) { init(); logger.warn( "Goal '{}' requires online mode for execution but Maven is currently offline, skipping", event.getMojoExecution().getGoal()); } } /**Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Fri Nov 08 08:49:11 GMT 2024 - 17.2K bytes - Click Count (0) -
docs/smb3-features/06-witness-protocol-design.md
private void scheduleServiceRetry() { scheduler.schedule(() -> { try { // Test if service is back online if (testWitnessService()) { serviceAvailable = true; log.info("Witness service is back online"); // Re-register for notifications reregisterNotifications();
Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Sat Aug 16 02:53:50 GMT 2025 - 42K bytes - Click Count (0) -
tests/query_test.go
if len(results) != 1 { t.Fatalf("Search all records with inline map") } CheckUser(t, results[0], users[2]) var results2 []User DB.Find(&results2, map[string]interface{}{"name": users[3].Name, "company_id": nil}) if len(results2) != 0 { t.Errorf("Search all records with inline map containing null value finding 0 records") }
Created: Sun Dec 28 09:35:17 GMT 2025 - Last Modified: Tue Jul 22 06:21:04 GMT 2025 - 51K bytes - Click Count (0)