Search Options

Results per page
Sort
Preferred Languages
Advance

Results 341 - 350 of 390 for callback2 (0.06 sec)

  1. impl/maven-core/src/main/java/org/apache/maven/ReactorReader.java

                return packagedArtifactFile;
            }
    
            if (!hasBeenPackagedDuringThisSession(project)) {
                // fallback to loose class files only if artifacts haven't been packaged yet
                // and only for plain old jars. Not war files, not ear files, not anything else.
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 22.3K bytes
    - Viewed (0)
  2. okhttp/src/test/java/okhttp3/internal/http2/Http2Test.kt

        frame.writeByte(99) // type 99
        frame.writeByte(FLAG_NONE)
        frame.writeInt(expectedStreamId)
        frame.writeInt(111111111) // custom data
        reader.nextFrame(requireSettings = false, BaseTestHandler()) // Should not callback.
      }
    
      @Test fun onlyOneLiteralHeadersFrame() {
        val sentHeaders = headerEntries("name", "value")
        val headerBytes = literalHeaders(sentHeaders)
        writeMedium(frame, headerBytes.size.toInt())
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 28.1K bytes
    - Viewed (0)
  3. internal/dsync/drwmutex.go

    				noQuorum, err := refreshLock(ctx, dm.clnt, id, source, quorum)
    				if err == nil && noQuorum {
    					// Clean the lock locally and in remote nodes
    					forceUnlock(ctx, dm.clnt, id)
    					// Execute the caller lock loss callback
    					if lockLossCallback != nil {
    						lockLossCallback()
    					}
    					return
    				}
    
    				refreshTimer.Reset(dm.refreshInterval)
    			}
    		}
    	}()
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 15:49:49 UTC 2024
    - 20.4K bytes
    - Viewed (0)
  4. okhttp/src/test/java/okhttp3/internal/connection/FastFallbackExchangeFinderTest.kt

        )
    
        taskFaker.assertNoMoreTasks()
      }
    
      /**
       * This test puts several connections in flight that all fail at approximately the same time. It
       * confirms the fast fallback implements these invariants:
       *
       *  * if there's no TCP connect in flight, start one.
       *  * don't start a new TCP connect within 250 ms of the previous TCP connect.
       */
      @Test
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Apr 24 04:40:49 UTC 2024
    - 20.9K bytes
    - Viewed (0)
  5. guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

           * Atomically reschedules this task and assigns the new future to {@link
           * #cancellationDelegate}.
           */
          @CanIgnoreReturnValue
          public Cancellable reschedule() {
            // invoke the callback outside the lock, prevents some shenanigans.
            Schedule schedule;
            try {
              schedule = CustomScheduler.this.getNextSchedule();
            } catch (Throwable t) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 16:22:21 UTC 2024
    - 27.8K bytes
    - Viewed (0)
  6. guava/src/com/google/common/util/concurrent/MoreExecutors.java

       *   <li>If an exception propagates out of a {@code Runnable}, it is not necessarily seen by any
       *       {@code UncaughtExceptionHandler} for the thread. For example, if the callback passed to
       *       {@link Futures#addCallback} throws an exception, that exception will be typically be
       *       logged by the {@link ListenableFuture} implementation, even if the thread is configured
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 44.1K bytes
    - Viewed (0)
  7. istioctl/pkg/ztunnelconfig/ztunnelconfig.go

    }
    
    // getComponentPodName returns the pod name and namespace of the Istio component
    func getComponentPodName(ctx cli.Context, podflag string) (string, string, error) {
    	// If user passed --namespace, respect it. Else fallback to --istio-namespace (which is typically defaulted, to istio-system).
    	return getPodNameWithNamespace(ctx, podflag, model.GetOrDefault(ctx.Namespace(), ctx.IstioNamespace()))
    }
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 19:17:45 UTC 2024
    - 22.2K bytes
    - Viewed (0)
  8. cmd/erasure-multipart.go

    				if split := strings.Split(string(b64), "x"); len(split) == 2 {
    					t, err := strconv.ParseInt(split[1], 10, 64)
    					if err == nil {
    						modTime = time.Unix(0, t)
    					}
    				}
    			}
    			// Fallback for older uploads without time in the ID.
    			if modTime.IsZero() {
    				wait := deleteMultipartCleanupSleeper.Timer(ctx)
    				fi, err := disk.ReadVersion(ctx, "", minioMetaMultipartBucket, uploadIDPath, "", ReadOptions{})
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 44.7K bytes
    - Viewed (0)
  9. doc/godebug.md

    Go 1.20 introduced automatic seeding of the
    [`math/rand`](/pkg/math/rand) global random number generator,
    controlled by the [`randautoseed` setting](/pkg/math/rand/#Seed).
    
    Go 1.20 introduced the concept of fallback roots for use during certificate verification,
    controlled by the [`x509usefallbackroots` setting](/pkg/crypto/x509/#SetFallbackRoots).
    
    Go 1.20 removed the preinstalled `.a` files for the standard library
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Oct 28 14:46:33 UTC 2024
    - 17.2K bytes
    - Viewed (0)
  10. src/bytes/bytes.go

    			return i - last
    		next:
    			fails++
    			i++
    			if (haveFastIndex && fails > bytealg.Cutover(i)) && i < len(s) ||
    				(!haveFastIndex && fails >= 4+i>>4 && i < len(s)) {
    				goto fallback
    			}
    		}
    		return -1
    
    	fallback:
    		// Switch to bytealg.Index, if available, or a brute force search when
    		// IndexByte returns too many false positives.
    		if haveFastIndex {
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Tue Sep 03 20:55:15 UTC 2024
    - 35.6K bytes
    - Viewed (0)
Back to top