Search Options

Results per page
Sort
Preferred Languages
Advance

Results 941 - 950 of 6,596 for _return (0.08 sec)

  1. cmd/metacache-set.go

    			bugLogIf(context.Background(), err)
    			return -1, err
    		}
    		if tmp.First == "" && tmp.Last == "" && tmp.EOS {
    			return 0, errFileNotFound
    		}
    		if tmp.First >= search {
    			o.debugln("First >= search", v)
    			return i, nil
    		}
    		if tmp.Last >= search {
    			o.debugln("Last >= search", v)
    			return i, nil
    		}
    		if tmp.EOS {
    			o.debugln("no match, at EOS", v)
    			return -3, io.EOF
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 16:23:16 UTC 2024
    - 30.7K bytes
    - Viewed (0)
  2. docs/debugging/hash-set/main.go

    	if cardinality <= 0 {
    		return -1
    	}
    	// use the faster version as per siphash docs
    	// https://github.com/dchest/siphash#usage
    	k0, k1 := binary.LittleEndian.Uint64(id[0:8]), binary.LittleEndian.Uint64(id[8:16])
    	sum64 := siphash.Hash(k0, k1, []byte(key))
    	return int(sum64 % uint64(cardinality))
    }
    
    // hashOrder - hashes input key to return consistent
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 19 18:05:16 UTC 2022
    - 3.7K bytes
    - Viewed (0)
  3. cmd/metacache-server-pool.go

    	cancelList()
    	wg.Wait()
    
    	// we should return 'errs' from per disk
    	if isAllNotFound(errs) {
    		if isAllVolumeNotFound(errs) {
    			return errVolumeNotFound
    		}
    		return nil
    	}
    
    	if err != nil {
    		return err
    	}
    
    	if contextCanceled(ctx) {
    		return ctx.Err()
    	}
    
    	for _, err := range errs {
    		if errors.Is(err, io.EOF) {
    			continue
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 16:23:16 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  4. internal/store/queuestore.go

    	files, err := os.ReadDir(store.directory)
    	if err != nil {
    		return nil, err
    	}
    
    	// Sort the entries.
    	sort.Slice(files, func(i, j int) bool {
    		ii, err := files[i].Info()
    		if err != nil {
    			return false
    		}
    		ji, err := files[j].Info()
    		if err != nil {
    			return true
    		}
    		return ii.ModTime().Before(ji.ModTime())
    	})
    
    	return files, nil
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.6K bytes
    - Viewed (0)
  5. guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java

          return perms;
        }
    
        @Override
        public PermissionCollection getPermissions(ProtectionDomain pd) {
          return perms;
        }
    
        @Override
        public boolean implies(ProtectionDomain pd, Permission p) {
          return perms.implies(p);
        }
    
        @Override
        public void refresh() {}
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 37.9K bytes
    - Viewed (0)
  6. guava/src/com/google/common/util/concurrent/AggregateFutureState.java

           */
          seenExceptionsLocal = requireNonNull(seenExceptions);
        }
        return seenExceptionsLocal;
      }
    
      /** Populates {@code seen} with the exception that was passed to {@code setException}. */
      abstract void addInitialException(Set<Throwable> seen);
    
      final int decrementRemainingAndGet() {
        return ATOMIC_HELPER.decrementAndGetRemainingCount(this);
      }
    
      final void clearSeenExceptions() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue May 28 20:40:51 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  7. cmd/api-utils.go

    			j += 3
    		default:
    			t[j] = s[i]
    			j++
    		}
    	}
    	return string(t)
    }
    
    // s3EncodeName encodes string in response when encodingType is specified in AWS S3 requests.
    func s3EncodeName(name, encodingType string) string {
    	if strings.ToLower(encodingType) == "url" {
    		return s3URLEncode(name)
    	}
    	return name
    }
    
    // getHandlerName returns the name of the handler function. It takes the type
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Mar 04 18:05:56 UTC 2024
    - 2.8K bytes
    - Viewed (0)
  8. okhttp-logging-interceptor/src/main/kotlin/okhttp3/logging/HttpLoggingInterceptor.kt

                  append(" body)")
                },
              )
            }
          }
    
          return response
        }
    
        internal fun redactUrl(url: HttpUrl): String {
          if (queryParamsNameToRedact.isEmpty() || url.querySize == 0) {
            return url.toString()
          }
          return url.newBuilder().query(null).apply {
            for (i in 0 until url.querySize) {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 06 09:14:38 UTC 2024
    - 11.2K bytes
    - Viewed (0)
  9. okhttp/src/main/kotlin/okhttp3/internal/url/-Url.kt

          out.writePercentDecoded(this, pos = i, limit = limit, plusIsSpace = plusIsSpace)
          return out.readUtf8()
        }
      }
    
      // Fast path: no characters in [pos..limit) required decoding.
      return substring(pos, limit)
    }
    
    internal fun String.isPercentEncoded(
      pos: Int,
      limit: Int,
    ): Boolean {
      return pos + 2 < limit &&
        this[pos] == '%' &&
        this[pos + 1].parseHexDigit() != -1 &&
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Tue Jan 09 12:33:05 UTC 2024
    - 7.3K bytes
    - Viewed (0)
  10. android/guava-tests/test/com/google/common/reflect/InvokableTest.java

            signature.append(sep).append(typeName(param));
            sep = ", ";
          }
          methods.add(signature.append(")").toString());
        }
        return methods.build();
      }
    
      private static String typeName(Class<?> type) {
        return type.isArray() ? typeName(type.getComponentType()) + "[]" : type.getName();
      }
    
      public void testConstructor() throws Exception {
        Invokable<A, A> invokable = A.constructor();
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 13:00:28 UTC 2024
    - 30.7K bytes
    - Viewed (0)
Back to top