Search Options

Results per page
Sort
Preferred Languages
Advance

Results 451 - 460 of 899 for been (0.03 sec)

  1. okhttp/src/test/java/okhttp3/internal/ws/RealWebSocketTest.kt

        client.processNextFrame() // Pong.
    
        // After 1000ms the client will attempt a ping 2, but we don't process it. That'll cause the
        // client to fail at 1500ms when it's time to send ping 3 because pong 2 hasn't been received.
        taskFaker.advanceUntil(ns(1000L))
        taskFaker.advanceUntil(ns(1500L))
        client.listener.assertFailure(
          SocketTimeoutException::class.java,
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Apr 11 01:59:58 UTC 2024
    - 18.5K bytes
    - Viewed (0)
  2. android/guava-tests/benchmark/com/google/common/util/concurrent/ExecutionListBenchmark.java

          RunnableExecutorPair oldHead;
          do {
            oldHead = head;
            if (oldHead == null) {
              // If runnables == null then execute() has been called so we should just execute our
              // listener immediately.
              newHead.execute();
              return;
            }
            // Try to make newHead the new head of the stack at runnables.
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 20.5K bytes
    - Viewed (0)
  3. compat/maven-compat/src/main/java/org/apache/maven/artifact/resolver/DefaultArtifactResolver.java

                    artifacts, rootArtifact, managedVersions, collectionRequest, source, collectionFilter, listeners, null);
    
            // We have metadata retrieval problems, or there are cycles that have been detected
            // so we give this back to the calling code and let them deal with this information
            // appropriately.
    
            if (result.hasMetadataResolutionExceptions()
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 24.8K bytes
    - Viewed (0)
  4. licenses/sigs.k8s.io/json/LICENSE

          designated in writing by the copyright owner as "Not a Contribution."
    
          "Contributor" shall mean Licensor and any individual or Legal Entity
          on behalf of whom a Contribution has been received by Licensor and
          subsequently incorporated within the Work.
    
       2. Grant of Copyright License. Subject to the terms and conditions of
          this License, each Contributor hereby grants to You a perpetual,
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Jan 05 01:31:25 UTC 2022
    - 12.6K bytes
    - Viewed (0)
  5. compat/maven-plugin-api/src/main/java/org/apache/maven/plugin/descriptor/MojoDescriptor.java

        public void addParameter(Parameter parameter) throws DuplicateParameterException {
            if (parameters.contains(parameter)) {
                throw new DuplicateParameterException(parameter.getName()
                        + " has been declared multiple times in mojo with goal: " + getGoal() + " (implementation: "
                        + getImplementation() + ")");
            }
    
            parameters.add(parameter);
        }
    
        /**
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 21.7K bytes
    - Viewed (0)
  6. cmd/xl-storage-disk-id-check.go

    					p.health.logSuccess()
    				}
    			}
    			si(sz, errp)
    		})
    	}, nil
    }
    
    var toWrite = []byte{2048: 42}
    
    // monitorDiskStatus should be called once when a drive has been marked offline.
    // Once the disk has been deemed ok, it will return to online status.
    func (p *xlStorageDiskIDCheck) monitorDiskStatus(spent time.Duration, fn string) {
    	t := time.NewTicker(5 * time.Second)
    	defer t.Stop()
    
    	for range t.C {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:56:26 UTC 2024
    - 34.5K bytes
    - Viewed (0)
  7. api/maven-api-core/src/main/java/org/apache/maven/api/services/DependencyResolver.java

            }
            return resolve(request);
        }
    
        /**
         * Flattens a list of nodes.
         * Note that the {@code PathScope} argument should usually be null as the dependency tree has been
         * filtered during collection for the appropriate scope.
         *
         * @param session the {@link Session}, must not be {@code null}
         * @param node the {@link Node} to flatten, must not be {@code null}
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Wed Oct 16 14:15:37 UTC 2024
    - 9.4K bytes
    - Viewed (0)
  8. internal/grid/grid.go

    	"io"
    	"net"
    	"net/http"
    	"strconv"
    	"strings"
    	"sync"
    	"time"
    
    	"github.com/gobwas/ws"
    	"github.com/gobwas/ws/wsutil"
    )
    
    // ErrDisconnected is returned when the connection to the remote has been lost during the call.
    var ErrDisconnected = RemoteErr("remote disconnected")
    
    const (
    	// minBufferSize is the minimum buffer size.
    	// Buffers below this is not reused.
    	minBufferSize = 1 << 10
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  9. istioctl/pkg/writer/compare/sds/util.go

    	auth "github.com/envoyproxy/go-control-plane/envoy/extensions/transport_sockets/tls/v3"
    
    	"istio.io/istio/istioctl/pkg/util/configdump"
    	"istio.io/istio/pkg/log"
    )
    
    // SecretItemDiff represents a secret that has been diffed between nodeagent and proxy
    type SecretItemDiff struct {
    	Agent string `json:"agent"`
    	Proxy string `json:"proxy"`
    	SecretItem
    }
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Oct 28 19:52:53 UTC 2024
    - 8.5K bytes
    - Viewed (0)
  10. guava-tests/test/com/google/common/hash/AbstractStreamingHasherTest.java

          for (int insertion = 0; insertion < totalInsertions; insertion++) {
            RandomHasherAction.pickAtRandom(random).performAction(random, sinksAndControl);
          }
          // We need to ensure that at least 4 bytes have been put into the hasher or else
          // Hasher#hash will throw an ISE.
          int intToPut = random.nextInt();
          for (Hasher hasher : sinksAndControl) {
            hasher.putInt(intToPut);
          }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jul 23 14:22:54 UTC 2024
    - 8.5K bytes
    - Viewed (0)
Back to top