Search Options

Results per page
Sort
Preferred Languages
Advance

Results 641 - 650 of 873 for Breaks (0.07 sec)

  1. guava/src/com/google/common/hash/BloomFilterStrategies.java

          boolean changedAnyBits = true;
          do {
            ourLongOld = data.get(i);
            ourLongNew = ourLongOld | longValue;
            if (ourLongOld == ourLongNew) {
              changedAnyBits = false;
              break;
            }
          } while (!data.compareAndSet(i, ourLongOld, ourLongNew));
    
          if (changedAnyBits) {
            int bitsAdded = Long.bitCount(ourLongNew) - Long.bitCount(ourLongOld);
            bitCount.add(bitsAdded);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 10 19:45:10 UTC 2022
    - 10.7K bytes
    - Viewed (0)
  2. impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/BaseParser.java

                    } else {
                        throw new ParserException(
                                "POM file " + arg + " specified with the -f/--file command line argument does not exist");
                    }
                    break;
                } else {
                    // Check if this is the -f/--file option
                    isAltFile = arg.equals("-f") || arg.equals("--file");
                }
            }
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 13.4K bytes
    - Viewed (0)
  3. ci/official/containers/linux_arm64/builder.devtoolset/gcc9-fixups.patch

    index e966c03..22ab790 100644
    --- a/locale/weightwc.h
    +++ b/locale/weightwc.h
    @@ -79,19 +79,19 @@ findidx (const wint_t **cpp, size_t len)
     	    if (cp[cnt] != usrc[cnt])
     	      break;
     
    -	  if (cnt < nhere - 1)
    +	  if (cnt < nhere - 1 || cnt == len)
     	    {
     	      cp += 2 * nhere;
     	      continue;
     	    }
     
    -	  if (cp[nhere - 1] > usrc[nhere -1])
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Mon Sep 18 14:52:45 UTC 2023
    - 8.9K bytes
    - Viewed (0)
  4. internal/s3select/csv/reader.go

    type queueItem struct {
    	input []byte          // raw input sent to the worker
    	dst   chan [][]string // result of block decode
    	err   error           // any error encountered will be set here
    }
    
    // Read - reads single record.
    // Once Read is called the previous record should no longer be referenced.
    func (r *Reader) Read(dst sql.Record) (sql.Record, error) {
    	// If we have have any records left, return these before any error.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Feb 22 06:26:06 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  5. internal/event/target/amqp.go

    		return err
    	}
    	ch, confirms, err := target.channel()
    	if err != nil {
    		return err
    	}
    	defer ch.Close()
    
    	return target.send(eventData, ch, confirms)
    }
    
    // SendFromStore - reads an event from store and sends it to AMQP091.
    func (target *AMQPTarget) SendFromStore(key store.Key) error {
    	if err := target.init(); err != nil {
    		return err
    	}
    
    	ch, confirms, err := target.channel()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 10K bytes
    - Viewed (0)
  6. ci/official/README.md

    1.  `envs/*` are lists of variables made with bash syntax. A user must set a
        `TFCI` env param pointing to a list of `env` files.
    2.  `utilities/setup.sh`, initialized by all top-level scripts, reads and sets
        values from those `TFCI` paths.
        -   `set -a` / `set -o allexport` exports the variables from `env` files so
            all scripts can use them.
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Thu Feb 01 03:21:19 UTC 2024
    - 8K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/io/CharStreamsTest.java

        // nothing really to assert?
        assertSame(CharStreams.nullWriter(), CharStreams.nullWriter());
      }
    
      /**
       * Returns a reader wrapping the given reader that only reads half of the maximum number of
       * characters that it could read in read(char[], int, int).
       */
      private static Reader newNonBufferFillingReader(Reader reader) {
        return new FilterReader(reader) {
          @Override
    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. guava-tests/test/com/google/common/io/CharStreamsTest.java

        // nothing really to assert?
        assertSame(CharStreams.nullWriter(), CharStreams.nullWriter());
      }
    
      /**
       * Returns a reader wrapping the given reader that only reads half of the maximum number of
       * characters that it could read in read(char[], int, int).
       */
      private static Reader newNonBufferFillingReader(Reader reader) {
        return new FilterReader(reader) {
          @Override
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 14:28:19 UTC 2024
    - 11.2K bytes
    - Viewed (0)
  9. istioctl/pkg/injector/injector-list.go

    			if err != nil {
    				return err
    			}
    
    			if ctx.Namespace() != "" {
    				for _, namespace := range nsList {
    					if namespace.Name == ctx.Namespace() {
    						nsList = []corev1.Namespace{namespace}
    						break
    					}
    				}
    			}
    
    			hooksList, err := client.Kube().AdmissionregistrationV1().MutatingWebhookConfigurations().List(context.Background(), metav1.ListOptions{
    				LabelSelector: "app=sidecar-injector",
    			})
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Oct 18 11:39:52 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  10. guava/src/com/google/common/util/concurrent/MoreExecutors.java

       * under {@code directExecutor}: Not only might the wait for a lock be long, but if the running
       * thread was holding a lock, the listener may deadlock or break lock isolation.
       *
       * <p>This instance is equivalent to:
       *
       * <pre>{@code
       * final class DirectExecutor implements Executor {
       *   public void execute(Runnable r) {
       *     r.run();
       *   }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 44.1K bytes
    - Viewed (0)
Back to top