- Sort Score
- Num 10 results
- Language All
Results 371 - 380 of 1,339 for exist (0.05 seconds)
-
internal/event/target/redis.go
} eventData, eErr := target.store.Get(key) if eErr != nil { // The last event key in a successful batch will be sent in the channel atmost once by the replayEvents() // Such events will not exist and would've been already been sent successfully. if os.IsNotExist(eErr) { return nil } return eErr } if err := target.send(eventData); err != nil { if xnet.IsConnRefusedErr(err) {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Mar 30 00:56:02 GMT 2025 - 9.1K bytes - Click Count (0) -
cmd/data-usage-cache.go
p := d.Cache[parent.Key()] p.addChild(hash) d.Cache[parent.Key()] = p } } // copyWithChildren will copy entry with hash from src if it exists along with any children. // If a parent is specified it will be added to that if not already there. // If the parent does not exist, it will be added. func (d *dataUsageCache) copyWithChildren(src *dataUsageCache, hash dataUsageHash, parent *dataUsageHash) { if d.Cache == nil {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 34.7K bytes - Click Count (0) -
build-logic/binary-compatibility/src/test/kotlin/gradlebuild/binarycompatibility/AbstractBinaryCompatibilityTest.kt
} println(buildResult.output) val richReportFile = inputBuildDir.resolve("binary-compatibility/build/japi/japi.html").apply { assertTrue("Rich report file doesn't exist", isFile) } return CheckResult(failure, scrapeRichReport(richReportFile), buildResult).apply { println(richReport.toText()) block() } } /**Created: Wed Apr 01 11:36:16 GMT 2026 - Last Modified: Mon Jan 19 11:30:48 GMT 2026 - 18.3K bytes - Click Count (0) -
src/cmd/asm/internal/asm/testdata/ppc64_p10.s
// Use of this source code is governed by a BSD-style // license that can be found in the LICENSE file. // This contains the valid opcode combinations available // in cmd/internal/obj/ppc64/asm9.go which exist for // POWER10/ISA 3.1. #include "../../../../../runtime/textflag.h" TEXT asmtest(SB), DUPOK|NOSPLIT, $0 BRD R1, R2 // 7c220176 BRH R1, R2 // 7c2201b6
Created: Tue Apr 07 11:13:11 GMT 2026 - Last Modified: Thu Mar 23 20:52:57 GMT 2023 - 14.3K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/suggest/settings/ArraySettings.java
* <li>{@link #deleteFromArray(String, String, String)}: Deletes a specific entry from the array index based on the ID.</li> * <li>{@link #createMappingIfEmpty(String, String, Client)}: Creates the index mapping if it does not exist.</li> * <li>{@link #loadIndexSettings()}: Loads the index settings from a JSON file.</li> * </ul> * * <p>Fields: * <ul> * <li>{@link #logger}: Logger instance for logging debug information.</li>
Created: Fri Apr 17 09:08:13 GMT 2026 - Last Modified: Mon Nov 24 03:40:05 GMT 2025 - 15.8K bytes - Click Count (0) -
fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlQueueService.java
* @param url The URL to check. * @return true if the URL exists in the queue, false otherwise. */ @Override protected boolean exists(final String sessionId, final String url) { final boolean ret = super.exists(sessionId, url); if (!ret) { final QueueHolder queueHolder = getQueueHolder(sessionId); final Queue<OpenSearchUrlQueue> waitingQueue = queueHolder.waitingQueue;Created: Sun Apr 12 03:50:13 GMT 2026 - Last Modified: Thu Nov 20 08:40:57 GMT 2025 - 16.9K bytes - Click Count (1) -
cmd/server_test.go
response, err = s.client.Get(getGetObjectURL(s.endPoint, bucketName, objectName+".1")) c.Assert(err, nil) // assert the http response status code. verifyError(c, response, "AccessDenied", "Access Denied.", http.StatusForbidden) // initiate anonymous HTTP request to fetch the object which does exist. We need to return AccessDenied.
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 118.1K bytes - Click Count (0) -
internal/event/target/amqp.go
} defer ch.Close() eventData, eErr := target.store.Get(key) if eErr != nil { // The last event key in a successful batch will be sent in the channel atmost once by the replayEvents() // Such events will not exist and wouldve been already been sent successfully. if os.IsNotExist(eErr) { return nil } return eErr } if err := target.send(eventData, ch, confirms); err != nil { return err }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Thu Aug 21 04:25:07 GMT 2025 - 10K bytes - Click Count (0) -
internal/event/target/kafka.go
var event event.Event event, err = target.store.Get(key) if err != nil { // The last event key in a successful batch will be sent in the channel atmost once by the replayEvents() // Such events will not exist and wouldve been already been sent successfully. if os.IsNotExist(err) { return nil } return err } err = target.send(event) case key.ItemCount > 1: var events []event.Event
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Sep 06 23:06:30 GMT 2024 - 13.6K bytes - Click Count (0) -
helm-releases/minio-4.0.1.tgz
POLICY=$2 PURGE=$3 VERSIONING=$4 # Purge the bucket, if set & exists # Since PURGE is user input, check explicitly for `true` if [ $PURGE = true ]; then if checkBucketExists $BUCKET ; then echo "Purging bucket '$BUCKET'." set +e ; # don't exit if this fails ${MC} rm -r --force myminio/$BUCKET set -e ; # reset `e` as active else echo "Bucket '$BUCKET' does not exist, skipping purge." fi fi # Create the bucket if it does not exist if ! checkBucketExists $BUCKET ; then echo "Creating bucket '$BUCKET'" ${MC}...
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Mon May 02 06:10:34 GMT 2022 - 18K bytes - Click Count (0)