Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 11 - 20 of 32 for getClock (0.06 seconds)

  1. cmd/erasure-object.go

    	nsUnlocker := func() {}
    	defer func() {
    		if unlockOnDefer {
    			nsUnlocker()
    		}
    	}()
    
    	// Acquire lock
    	if !opts.NoLock {
    		lock := er.NewNSLock(bucket, object)
    		lkctx, err := lock.GetRLock(ctx, globalOperationTimeout)
    		if err != nil {
    			return nil, err
    		}
    		ctx = lkctx.Context()
    
    		// Release lock when the metadata is verified, and reader
    		// is ready to be read.
    		//
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Oct 24 04:05:31 GMT 2025
    - 80.4K bytes
    - Click Count (0)
  2. cmd/erasure-multipart.go

    	plkctx, err := partIDLock.GetLock(ctx, globalOperationTimeout)
    	if err != nil {
    		return PartInfo{}, err
    	}
    
    	ctx = plkctx.Context()
    	defer partIDLock.Unlock(plkctx)
    
    	// Read lock for upload id, only held while reading the upload metadata.
    	uploadIDRLock := er.NewNSLock(bucket, pathJoin(object, uploadID))
    	rlkctx, err := uploadIDRLock.GetRLock(ctx, globalOperationTimeout)
    	if err != nil {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Oct 24 04:05:31 GMT 2025
    - 47.1K bytes
    - Click Count (0)
  3. build-logic/documentation/src/main/groovy/gradlebuild/docs/dsl/docbook/model/ClassDoc.groovy

            }
            return comment[0]
        }
    
        PropertyDoc findProperty(String name) {
            return classProperties.find { it.name == name }
        }
    
        BlockDoc getBlock(String name) {
            def block = classBlocks.find { it.name == name }
            if (block) {
                return block
            }
            for (extensionDoc in classExtensions) {
    Created: Wed Dec 31 11:36:14 GMT 2025
    - Last Modified: Wed Dec 09 08:14:05 GMT 2020
    - 6.2K bytes
    - Click Count (0)
  4. cmd/callhome.go

    }
    
    func runCallhome(ctx context.Context, objAPI ObjectLayer) bool {
    	// Make sure only 1 callhome is running on the cluster.
    	locker := objAPI.NewNSLock(minioMetaBucket, "callhome/runCallhome.lock")
    	lkctx, err := locker.GetLock(ctx, callhomeLeaderLockTimeout)
    	if err != nil {
    		// lock timedout means some other node is the leader,
    		// cycle back return 'true'
    		return true
    	}
    
    	ctx = lkctx.Context()
    	defer locker.Unlock(lkctx)
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 5.3K bytes
    - Click Count (0)
  5. fess-crawler/src/main/java/org/codelibs/fess/crawler/entity/Sitemap.java

     */
    public interface Sitemap extends Serializable {
    
        /**
         * Retrieves the location (URL) of the sitemap.
         *
         * @return the location of the sitemap as a String.
         */
        String getLoc();
    
        /**
         * Retrieves the last modification date of the sitemap.
         *
         * @return A string representing the last modification date.
         */
        String getLastmod();
    
    Created: Sat Dec 20 11:21:39 GMT 2025
    - Last Modified: Sat Mar 15 06:52:00 GMT 2025
    - 1.2K bytes
    - Click Count (0)
  6. fess-crawler/src/main/java/org/codelibs/fess/crawler/entity/SitemapFile.java

         */
        public SitemapFile() {
            // Default constructor
        }
    
        /*
         * (non-Javadoc)
         *
         * @see org.codelibs.fess.crawler.entity.Sitemap#getLoc()
         */
        @Override
        public String getLoc() {
            return loc;
        }
    
        /**
         * Sets the location of the sitemap.
         * @param loc the location URL to set
         */
        public void setLoc(final String loc) {
    Created: Sat Dec 20 11:21:39 GMT 2025
    - Last Modified: Sun Jul 06 02:13:03 GMT 2025
    - 4.4K bytes
    - Click Count (1)
  7. cmd/admin-handlers.go

    		writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrNotImplemented), r.URL)
    		return
    	}
    
    	nsLock := objectAPI.NewNSLock(minioMetaBucket, "site-net-perf")
    	lkctx, err := nsLock.GetLock(ctx, globalOperationTimeout)
    	if err != nil {
    		writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(toAPIErrorCode(ctx, err)), r.URL)
    		return
    	}
    	ctx = lkctx.Context()
    	defer nsLock.Unlock(lkctx)
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 99.7K bytes
    - Click Count (0)
  8. fess-crawler/src/main/java/org/codelibs/fess/crawler/processor/impl/SitemapsResponseProcessor.java

                for (final Sitemap sitemap : sitemapSet.getSitemaps()) {
                    if (sitemap != null) {
                        requestDataSet.add(RequestDataBuilder.newRequestData().get().url(sitemap.getLoc()).build()); // TODO priority
                    }
                }
                throw new ChildUrlsException(requestDataSet, this.getClass().getName() + "#process");
            } catch (final IOException e) {
    Created: Sat Dec 20 11:21:39 GMT 2025
    - Last Modified: Sun Jul 06 02:13:03 GMT 2025
    - 3.4K bytes
    - Click Count (0)
  9. build-logic/documentation/src/main/groovy/gradlebuild/docs/dsl/docbook/AssembleDslDocTask.groovy

        }
    
        def mergeBlock(Element tr, gradlebuild.docs.dsl.docbook.model.ClassDoc project) {
            String blockName = tr.td[0].text().trim()
            gradlebuild.docs.dsl.docbook.model.BlockDoc blockDoc = project.getBlock(blockName)
            tr.children = {
                td { link(linkend: blockDoc.id) { literal("$blockName { }")} }
                td(blockDoc.description)
            }
        }
    
    Created: Wed Dec 31 11:36:14 GMT 2025
    - Last Modified: Wed Dec 09 08:14:05 GMT 2020
    - 9.8K bytes
    - Click Count (0)
  10. fess-crawler/src/main/java/org/codelibs/fess/crawler/entity/SitemapImage.java

         */
        public SitemapImage() {
            // Default constructor
        }
    
        /**
         * Gets the location URL of the image.
         * @return the image URL
         */
        public String getLoc() {
            return loc;
        }
    
        /**
         * Sets the location URL of the image.
         * @param loc the image URL to set
         */
        public void setLoc(final String loc) {
            this.loc = loc;
        }
    Created: Sat Dec 20 11:21:39 GMT 2025
    - Last Modified: Thu Nov 13 13:34:36 GMT 2025
    - 3.8K bytes
    - Click Count (0)
Back to Top