Search Options

Results per page
Sort
Preferred Languages
Advance

Results 381 - 390 of 854 for breaks (0.06 sec)

  1. internal/s3select/simdj/record.go

    			}
    			columnValue = val
    		case simdjson.TypeObject, simdjson.TypeArray:
    			b, err := tmp.MarshalJSON()
    			if err != nil {
    				return err
    			}
    			columnValue = string(b)
    		case simdjson.TypeNone:
    			break allElems
    		default:
    			return fmt.Errorf("cannot marshal unhandled type: %s", typ.String())
    		}
    		csvRecord = append(csvRecord, columnValue)
    	}
    	w := csv.NewWriter(writer)
    	w.Comma = opts.FieldDelimiter
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 5.4K bytes
    - Viewed (0)
  2. internal/logger/targets.go

    		for ii := range tgts {
    			if currentTgt.Name() == tgts[ii].Name() {
    				newTgt = tgts[ii]
    				currentTgt.AssignMigrateTarget(newTgt)
    				http.CreateOrAdjustGlobalBuffer(currentTgt, newTgt)
    				break
    			}
    		}
    	}
    
    	for _, t := range tgts {
    		err := t.Init(ctx)
    		if err != nil {
    			errs = append(errs, err)
    		}
    	}
    
    	targetsList.set(newWebhooks)
    
    	cancelTargets(oldTargets)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 03 15:44:50 UTC 2024
    - 6K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/util/concurrent/Uninterruptibles.java

        boolean interrupted = false;
        try {
          long remainingNanos = unit.toNanos(timeout);
          long end = System.nanoTime() + remainingNanos;
    
          while (true) {
            try {
              // CountDownLatch treats negative timeouts just like zero.
              return latch.await(remainingNanos, NANOSECONDS);
            } catch (InterruptedException e) {
              interrupted = true;
              remainingNanos = end - System.nanoTime();
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 20.1K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/es/user/allcommon/EsAbstractBehavior.java

                    final SearchHit[] hits = searchHits.getHits();
                    if (hits.length == 0) {
                        break;
                    }
    
                    if (!handler.apply(searchHits)) {
                        break;
                    }
    
                    response = client.prepareSearchScroll(scrollId).setScroll(scrollForDelete).execute().actionGet(scrollSearchTimeout);
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 26.4K bytes
    - Viewed (0)
  5. guava/src/com/google/common/collect/Queues.java

                try {
                  e = q.poll(deadline - System.nanoTime(), NANOSECONDS);
                  break;
                } catch (InterruptedException ex) {
                  interrupted = true; // note interruption and retry
                }
              }
              if (e == null) {
                break; // we already waited enough, and there are no more elements in sight
              }
              buffer.add(e);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 26 14:11:14 UTC 2024
    - 18.2K bytes
    - Viewed (0)
  6. internal/ringbuffer/ring_buffer.go

    	wrote := 0
    	for len(p) > 0 {
    		n, err = r.write(p)
    		wrote += n
    		if !r.block || err == nil {
    			break
    		}
    		err = r.setErr(err, true)
    		if r.block && (err == ErrIsFull || err == ErrTooMuchDataToWrite) {
    			r.writeCond.Broadcast()
    			r.readCond.Wait()
    			p = p[n:]
    			err = nil
    			continue
    		}
    		break
    	}
    	if r.block && wrote > 0 {
    		r.writeCond.Broadcast()
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 15 00:11:04 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  7. build-logic/build-update-utils/src/main/kotlin/gradlebuild/buildutils/tasks/UpdateKotlinVersions.kt

                                if (versionsOfPatch.any { !it.contains("-") }) {
                                    add(versionsOfPatch.first { !it.contains("-") })
                                    break
                                }
                                if (versionsOfPatch.any { it.contains("-RC") }) {
                                    add(versionsOfPatch.firstOrNull { it.contains("-RC") })
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Tue Jul 23 18:27:26 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  8. src/test/java/org/codelibs/core/beans/factory/BeanDescFactoryTest.java

     * governing permissions and limitations under the License.
     */
    package org.codelibs.core.beans.factory;
    
    import static org.hamcrest.CoreMatchers.is;
    import static org.hamcrest.CoreMatchers.not;
    import static org.hamcrest.CoreMatchers.sameInstance;
    import static org.junit.Assert.assertThat;
    
    import org.codelibs.core.beans.BeanDesc;
    import org.junit.Test;
    
    /**
     * @author higa
     */
    public class BeanDescFactoryTest {
    Registered: Fri Nov 01 20:58:10 UTC 2024
    - Last Modified: Thu Mar 07 01:59:08 UTC 2024
    - 2.3K bytes
    - Viewed (0)
  9. src/main/webapp/js/admin/plugins/form-validator/jquery.form-validator.min.js

    0!==c.get(0).files?c.get(0).files.length:b.length,j=a.formUtils.numericRangeCheck(i,f);switch(j[0]){case"out":this.errorMessage=e.lengthBadStart+f+e.lengthBadEnd,h=!1;break;case"min":this.errorMessage=e.lengthTooShortStart+j[1]+e.lengthBadEnd,h=!1;break;case"max":this.errorMessage=e.lengthTooLongStart+j[1]+e.lengthBadEnd,h=!1;break;default:h=!0}return h},errorMessage:"",errorMessageKey:""}),a.formUtils.addValidator({name:"url",validatorFunction:function(b){var c=/^(https?|ftp):\/\/((((\w|-|\.|~|...
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Mon Jan 01 05:12:47 UTC 2018
    - 32.8K bytes
    - Viewed (0)
  10. src/cmd/addr2line/main.go

    // license that can be found in the LICENSE file.
    
    // Addr2line is a minimal simulation of the GNU addr2line tool,
    // just enough to support pprof.
    //
    // Usage:
    //
    //	go tool addr2line binary
    //
    // Addr2line reads hexadecimal addresses, one per line and with optional 0x prefix,
    // from standard input. For each input address, addr2line prints two output lines,
    // first the name of the function containing the address and second the file:line
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Jun 21 19:58:04 UTC 2024
    - 2.4K bytes
    - Viewed (0)
Back to top