Search Options

Results per page
Sort
Preferred Languages
Advance

Results 621 - 630 of 873 for Breaks (0.1 sec)

  1. internal/event/target/redis.go

    		if err != nil {
    			return err
    		}
    		if _, err := conn.Do("RPUSH", target.args.Key, data); err != nil {
    			return err
    		}
    	}
    
    	return nil
    }
    
    // SendFromStore - reads an event from store and sends it to redis.
    func (target *RedisTarget) SendFromStore(key store.Key) error {
    	if err := target.init(); err != nil {
    		return err
    	}
    
    	conn := target.pool.Get()
    	defer conn.Close()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 9.1K bytes
    - Viewed (0)
  2. cmd/erasure-coding.go

    // It returns an error if the decoding failed.
    func (e *Erasure) DecodeDataBlocks(data [][]byte) error {
    	isZero := 0
    	for _, b := range data {
    		if len(b) == 0 {
    			isZero++
    			break
    		}
    	}
    	if isZero == 0 || isZero == len(data) {
    		// If all are zero, payload is 0 bytes.
    		return nil
    	}
    	return e.encoder().ReconstructData(data)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jan 31 02:11:45 UTC 2024
    - 8.6K bytes
    - Viewed (0)
  3. docs/debugging/s3-verify/main.go

    	tgtSha256 := sha256.New()
    
    	for {
    		srcSha256.Reset()
    		tgtSha256.Reset()
    
    		srcEOF = !srcOk
    		tgtEOF = !tgtOk
    
    		// No objects from source AND target: Finish
    		if srcEOF && tgtEOF {
    			break
    		}
    
    		if !srcEOF && srcCtnt.Err != nil {
    			log.Fatal(srcCtnt.Err)
    		}
    
    		if !tgtEOF && tgtCtnt.Err != nil {
    			log.Fatal(tgtCtnt.Err)
    		}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jun 22 15:12:47 UTC 2022
    - 8.4K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/collect/Streams.java

            while (true) {
              Spliterator<T> prefix = spliterator.trySplit();
              if (prefix == null || prefix.getExactSizeIfKnown() == 0) {
                break;
              } else if (spliterator.getExactSizeIfKnown() == 0) {
                spliterator = prefix;
                break;
              }
            }
    
            // spliterator is known to be nonempty now
            spliterator.forEachRemaining(state::set);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 31 14:20:11 UTC 2024
    - 37.4K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/collect/Collections2.java

              continue;
            }
            if (q == j + 1) {
              if (j == 0) {
                break;
              }
              s++;
              switchDirection();
              continue;
            }
    
            Collections.swap(list, j - c[j] + s, j - q + s);
            c[j] = q;
            break;
          }
        }
    
        void switchDirection() {
          o[j] = -o[j];
          j--;
        }
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 20:24:49 UTC 2024
    - 22.8K bytes
    - Viewed (0)
  6. cmd/site-replication.go

    		if err != nil {
    			peerAddErr = errSRPeerResp(fmt.Errorf("unable to create admin client for %s: %w", v.Name, err))
    			break
    		}
    		joinReq.SvcAcctParent = v.AccessKey
    		err = admClient.SRPeerJoin(ctx, joinReq)
    		if err != nil {
    			peerAddErr = errSRPeerResp(fmt.Errorf("unable to link with peer %s: %w", v.Name, err))
    			break
    		}
    		addedCount++
    	}
    
    	if peerAddErr != nil {
    		if addedCount == 0 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 185.1K bytes
    - Viewed (0)
  7. architecture/environments/operator.md

    See the
    [design doc](https://docs.google.com/document/d/11j9ZtYWNWnxQYnZy8ayZav1FMwTH6F6z6fkDYZ7V298/edit#heading=h.qex63c29z2to)
    for a more complete design description. The operator code is divided roughly into five areas:
    
    1. [IstioOperatorSpec API](#istiooperatorspec-api) and related infrastructure, which is expressed as a
    [proto](https://github.com/istio/api/blob/master/operator/v1alpha1/operator.proto) and
    compiled to [Go
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Jul 29 21:11:35 UTC 2024
    - 13.2K bytes
    - Viewed (0)
  8. cni/pkg/install/install.go

    				if err != nil {
    					return fmt.Errorf("%s: %w", in.cniConfigFilepath, err)
    				}
    				if plugin["type"] == "istio-cni" {
    					cniConfigMap["plugins"] = append(plugins[:i], plugins[i+1:]...)
    					break
    				}
    			}
    
    			cniConfig, err := util.MarshalCNIConfig(cniConfigMap)
    			if err != nil {
    				return fmt.Errorf("failed to marshal CNI config map in file %s: %w", in.cniConfigFilepath, err)
    			}
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Aug 09 21:33:51 UTC 2024
    - 13.5K bytes
    - Viewed (0)
  9. guava/src/com/google/common/collect/Ordering.java

        return explicit(Lists.asList(leastValue, remainingValuesInOrder));
      }
    
      // Ordering<Object> singletons
    
      /**
       * Returns an ordering which treats all values as equal, indicating "no ordering." Passing this
       * ordering to any <i>stable</i> sort algorithm results in no change to the order of elements.
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 39.4K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/primitives/Booleans.java

       * compares, using {@link #compare(boolean, boolean)}), the first pair of values that follow any
       * common prefix, or when one array is a prefix of the other, treats the shorter array as the
       * lesser. For example, {@code [] < [false] < [false, true] < [true]}.
       *
       * <p>The returned comparator is inconsistent with {@link Object#equals(Object)} (since arrays
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 20.4K bytes
    - Viewed (0)
Back to top