Search Options

Results per page
Sort
Preferred Languages
Advance

Results 361 - 370 of 596 for stette (0.08 sec)

  1. guava/src/com/google/common/util/concurrent/AbstractTransformFuture.java

         * StackOverflowError: We can't reliably call setException(error).
         *
         * - Any kind of Error from a listener. Even if we could distinguish that case (by exposing some
         * extra state from AbstractFuture), our options are limited: A call to setException() would be
         * a no-op. We could log, but if that's what we really want, we should modify
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 13:13:32 UTC 2024
    - 11K bytes
    - Viewed (0)
  2. guava/src/com/google/common/util/concurrent/AtomicDoubleArray.java

          b.append(longBitsToDouble(longs.get(i)));
          if (i == iMax) {
            return b.append(']').toString();
          }
          b.append(',').append(' ');
        }
      }
    
      /**
       * Saves the state to a stream (that is, serializes it).
       *
       * @serialData The length of the array is emitted (int), followed by all of its elements (each a
       *     {@code double}) in the proper order.
       */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Jun 14 17:55:55 UTC 2024
    - 10.3K bytes
    - Viewed (0)
  3. docs/de/docs/advanced/events.md

    Aber `open()` verwendet nicht `async` und `await`.
    
    Daher deklarieren wir die Eventhandler-Funktion mit Standard-`def` statt mit `async def`.
    
    ///
    
    ### `startup` und `shutdown` zusammen
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 9.1K bytes
    - Viewed (0)
  4. src/bytes/reader_test.go

    			t.Errorf("%d. got error = %v; want %v", i, err, tt.wanterr)
    		}
    	}
    }
    
    func TestReaderAtConcurrent(t *testing.T) {
    	// Test for the race detector, to verify ReadAt doesn't mutate
    	// any state.
    	r := NewReader([]byte("0123456789"))
    	var wg sync.WaitGroup
    	for i := 0; i < 5; i++ {
    		wg.Add(1)
    		go func(i int) {
    			defer wg.Done()
    			var buf [1]byte
    			r.ReadAt(buf[:], int64(i))
    		}(i)
    	}
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Dec 13 18:45:54 UTC 2021
    - 8K bytes
    - Viewed (0)
  5. cni/pkg/nodeagent/net.go

    	return s.ztunnelServer.PodAdded(ctx, pod, netns)
    }
    
    // ConstructInitialSnapshot takes a "snapshot" of current ambient pods and
    //
    // 1. Constructs a ztunnel state message to initialize ztunnel
    // 2. Syncs the host ipset
    func (s *NetServer) ConstructInitialSnapshot(ambientPods []*corev1.Pod) error {
    	var consErr []error
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Oct 21 16:48:55 UTC 2024
    - 9.1K bytes
    - Viewed (0)
  6. common-protos/k8s.io/api/policy/v1/generated.proto

      // +optional
      optional string unhealthyPodEvictionPolicy = 4;
    }
    
    // PodDisruptionBudgetStatus represents information about the status of a
    // PodDisruptionBudget. Status may trail the actual state of a system.
    message PodDisruptionBudgetStatus {
      // Most recent generation observed when updating this PDB status. DisruptionsAllowed and other
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Mar 11 18:43:24 UTC 2024
    - 8K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/es/user/bsbhv/BsUserBhv.java

                result.setRoles(toStringArray(source.get("roles")));
                result.setRoomNumber(DfTypeUtil.toString(source.get("roomNumber")));
                result.setState(DfTypeUtil.toString(source.get("state")));
                result.setStreet(DfTypeUtil.toString(source.get("street")));
                result.setSurname(DfTypeUtil.toString(source.get("surname")));
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 12K bytes
    - Viewed (0)
  8. cmd/site-replication-utils.go

    						}()
    					}
    				}
    				wg.Wait()
    				sm.Unlock()
    			}
    			sTimer.Reset(siteResyncSaveInterval)
    		case <-ctx.Done():
    			return
    		}
    	}
    }
    
    // update overall site resync state
    func (sm *siteResyncMetrics) updateState(s SiteResyncStatus) error {
    	if !globalSiteReplicationSys.isEnabled() {
    		return nil
    	}
    	sm.Lock()
    	defer sm.Unlock()
    	switch s.Status {
    	case ResyncStarted:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  9. docs/de/docs/tutorial/security/simple-oauth2.md

    ///
    
    ### Die Formulardaten verwenden
    
    /// tip | "Tipp"
    
    Die Instanz der Klassenabhängigkeit `OAuth2PasswordRequestForm` verfügt, statt eines Attributs `scope` mit dem durch Leerzeichen getrennten langen String, über das Attribut `scopes` mit einer tatsächlichen Liste von Strings, einem für jeden gesendeten Scope.
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 14.1K bytes
    - Viewed (0)
  10. okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt

      internal val plansToCancel = CopyOnWriteArrayList<RoutePlanner.Plan>()
    
      override fun timeout(): Timeout = timeout
    
      @SuppressWarnings("CloneDoesntCallSuperClone") // We are a final type & this saves clearing state.
      override fun clone(): Call = RealCall(client, originalRequest, forWebSocket)
    
      override fun request(): Request = originalRequest
    
      /**
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 17.9K bytes
    - Viewed (0)
Back to top