Search Options

Results per page
Sort
Preferred Languages
Advance

Results 671 - 680 of 952 for Piller (0.04 sec)

  1. cmd/local-locker.go

    				// No more resources for UID, but we did update at least one.
    				return true, nil
    			}
    		}
    	}
    }
    
    // Similar to removeEntry but only removes an entry only if the lock entry exists in map.
    // Caller must hold 'l.mutex' lock.
    func (l *localLocker) expireOldLocks(interval time.Duration) {
    	l.mutex.Lock()
    	defer l.mutex.Unlock()
    
    	for k, lris := range l.lockMap {
    		modified := false
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 24 10:24:01 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  2. scripts/docs.py

    index_sponsors_template = """
    {% if sponsors %}
    {% for sponsor in sponsors.gold -%}
    <a href="{{ sponsor.url }}" target="_blank" title="{{ sponsor.title }}"><img src="{{ sponsor.img }}"></a>
    {% endfor -%}
    {%- for sponsor in sponsors.silver -%}
    <a href="{{ sponsor.url }}" target="_blank" title="{{ sponsor.title }}"><img src="{{ sponsor.img }}"></a>
    {% endfor %}
    {% endif %}
    """
    
    
    def generate_readme_content() -> str:
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Tue Oct 08 11:01:17 UTC 2024
    - 13.5K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/es/config/cbean/cq/bs/BsRelatedQueryCQ.java

            bool((must, should, mustNot, filter) -> {
                filteredLambda.callback(must, filter);
            }, opLambda);
        }
    
        public void not(OperatorCall<RelatedQueryCQ> notLambda) {
            not(notLambda, null);
        }
    
        public void not(final OperatorCall<RelatedQueryCQ> notLambda, final ConditionOptionCall<BoolQueryBuilder> opLambda) {
            bool((must, should, mustNot, filter) -> notLambda.callback(mustNot), opLambda);
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 57.5K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/es/config/cbean/cq/bs/BsRequestHeaderCQ.java

            bool((must, should, mustNot, filter) -> {
                filteredLambda.callback(must, filter);
            }, opLambda);
        }
    
        public void not(OperatorCall<RequestHeaderCQ> notLambda) {
            not(notLambda, null);
        }
    
        public void not(final OperatorCall<RequestHeaderCQ> notLambda, final ConditionOptionCall<BoolQueryBuilder> opLambda) {
            bool((must, should, mustNot, filter) -> notLambda.callback(mustNot), opLambda);
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 57.2K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/es/config/cbean/cq/bs/BsRoleTypeCQ.java

            bool((must, should, mustNot, filter) -> {
                filteredLambda.callback(must, filter);
            }, opLambda);
        }
    
        public void not(OperatorCall<RoleTypeCQ> notLambda) {
            not(notLambda, null);
        }
    
        public void not(final OperatorCall<RoleTypeCQ> notLambda, final ConditionOptionCall<BoolQueryBuilder> opLambda) {
            bool((must, should, mustNot, filter) -> notLambda.callback(mustNot), opLambda);
        }
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 55.2K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/io/CharStreamsTest.java

        String string = Strings.repeat("0123456789", 100);
        StringBuilder b = new StringBuilder();
        // the main assertion of this test is here... the copy will fail if the buffer size goes down
        // each time it is not filled completely
        long copied = CharStreams.copy(newNonBufferFillingReader(new StringReader(string)), b);
        assertEquals(string, b.toString());
        assertEquals(string.length(), copied);
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 14:28:19 UTC 2024
    - 11.2K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/io/CharStreamsTest.java

        String string = Strings.repeat("0123456789", 100);
        StringBuilder b = new StringBuilder();
        // the main assertion of this test is here... the copy will fail if the buffer size goes down
        // each time it is not filled completely
        long copied = CharStreams.copy(newNonBufferFillingReader(new StringReader(string)), b);
        assertEquals(string, b.toString());
        assertEquals(string.length(), copied);
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 14:28:19 UTC 2024
    - 11.2K bytes
    - Viewed (0)
  8. cmd/os_unix.go

    			if typ&os.ModeSymlink == os.ModeSymlink && fi.IsDir() {
    				continue
    			}
    
    			typ = fi.Mode() & os.ModeType
    		}
    		if err = fn(string(name), typ); err == errDoneForNow {
    			// fn() requested to return by caller.
    			return nil
    		}
    	}
    
    	return err
    }
    
    // Return count entries at the directory dirPath and all entries
    // if count is set to -1
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 9.3K bytes
    - Viewed (0)
  9. cmd/namespace-lock.go

    	}
    	const readLock = true
    	for _, path := range li.paths {
    		li.ns.unlock(li.volume, path, readLock)
    	}
    }
    
    func getSource(n int) string {
    	var funcName string
    	pc, filename, lineNum, ok := runtime.Caller(n)
    	if ok {
    		filename = pathutil.Base(filename)
    		funcName = strings.TrimPrefix(runtime.FuncForPC(pc).Name(),
    			"github.com/minio/minio/cmd.")
    	} else {
    		filename = "<unknown>"
    		lineNum = 0
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  10. internal/http/listener_test.go

    		var ip net.IP
    		switch v := addr.(type) {
    		case *net.IPNet:
    			ip = v.IP
    		case *net.IPAddr:
    			ip = v.IP
    		}
    
    		if ip.To4() != nil {
    			localIP4.Add(ip.String())
    		}
    	}
    
    	// Filter ipList by IPs those do not start with '127.'.
    	nonLoopBackIPs := localIP4.FuncMatch(func(ip string, matchString string) bool {
    		return !strings.HasPrefix(ip, "127.")
    	}, "")
    	if len(nonLoopBackIPs) == 0 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 17:41:02 UTC 2024
    - 11.8K bytes
    - Viewed (0)
Back to top