Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 371 - 380 of 1,339 for exist (0.02 seconds)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to Top