Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 321 - 330 of 472 for vive (0.02 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. cmd/streaming-signature-v4.go

    	if err != nil {
    		return err
    	}
    	if buf[0] != '\r' || buf[1] != '\n' {
    		return errMalformedEncoding
    	}
    	return nil
    }
    
    // Read a line of bytes (up to \n) from b.
    // Give up if the line exceeds maxLineLength.
    // The returned bytes are owned by the bufio.Reader
    // so they are only valid until the next bufio read.
    func readChunkLine(b *bufio.Reader) ([]byte, []byte, error) {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 18.2K bytes
    - Click Count (0)
  2. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Connection.kt

                }
    
                else -> {
                  // Ignore an unexpected pong.
                }
              }
            }
          } else {
            // Send a reply to a client ping if this is a server and vice versa.
            writerQueue.execute("$connectionName ping") {
              writePing(true, payload1, payload2)
            }
          }
        }
    
        override fun goAway(
          lastGoodStreamId: Int,
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 31.9K bytes
    - Click Count (0)
  3. android/guava/src/com/google/common/collect/MapMakerInternalMap.java

        void setValue(S segment, E entry, V value);
      }
    
      /**
       * An entry in a hash table of a {@link Segment}.
       *
       * <p>Entries in the map can be in the following states:
       *
       * <p>Valid: - Live: valid key/value are set
       *
       * <p>Invalid: - Collected: key/value was partially collected, but not yet cleaned up
       */
      interface InternalEntry<K, V, E extends InternalEntry<K, V, E>> {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Apr 01 17:27:13 GMT 2026
    - 89.9K bytes
    - Click Count (0)
  4. MIGRATION.md

    - [ ] Security testing (authentication, authorization)
    - [ ] Integration testing with client applications
    - [ ] User acceptance testing
    - [ ] Load testing for production capacity
    
    ### Go-Live
    
    - [ ] Schedule maintenance window
    - [ ] Final incremental data sync
    - [ ] Switch DNS or endpoints to Fess
    - [ ] Monitor logs for errors
    - [ ] Monitor search performance metrics
    - [ ] Have rollback plan ready
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Nov 06 12:40:11 GMT 2025
    - 23.2K bytes
    - Click Count (0)
  5. src/cmd/asm/internal/arch/arch.go

    	instructions["B"] = obj.AJMP
    	instructions["BL"] = obj.ACALL
    	// MCR differs from MRC by the way fields of the word are encoded.
    	// (Details in arm.go). Here we add the instruction so parse will find
    	// it, but give it an opcode number known only to us.
    	instructions["MCR"] = aMCR
    
    	return &Arch{
    		LinkArch:       &arm.Linkarm,
    		Instructions:   instructions,
    		Register:       register,
    		RegisterPrefix: registerPrefix,
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Fri Mar 20 17:02:17 GMT 2026
    - 22K bytes
    - Click Count (0)
  6. android/guava/src/com/google/common/collect/Range.java

        } else {
          Cut<C> newLower = (lowerCmp >= 0) ? lowerBound : connectedRange.lowerBound;
          Cut<C> newUpper = (upperCmp <= 0) ? upperBound : connectedRange.upperBound;
    
          // create() would catch this, but give a confusing error message
          checkArgument(
              newLower.compareTo(newUpper) <= 0,
              "intersection is undefined for disconnected ranges %s and %s",
              this,
              connectedRange);
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Sep 22 18:35:44 GMT 2025
    - 28K bytes
    - Click Count (0)
  7. android/guava/src/com/google/common/util/concurrent/ServiceManager.java

     *           System.exit(1);
     *         }
     *       },
     *       MoreExecutors.directExecutor());
     *
     *     Runtime.getRuntime().addShutdownHook(new Thread() {
     *       public void run() {
     *         // Give the services 5 seconds to stop to ensure that we are responsive to shutdown
     *         // requests.
     *         try {
     *           manager.stopAsync().awaitStopped(5, TimeUnit.SECONDS);
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Feb 23 19:19:10 GMT 2026
    - 33.2K bytes
    - Click Count (1)
  8. guava-tests/test/com/google/common/collect/MinMaxPriorityQueueTest.java

          assertIntact(queue);
          assertThat(queue).containsExactlyElementsIn(elements);
        }
      }
    
      private enum Element {
        ONE,
        TWO,
        THREE,
        FOUR,
        FIVE;
      }
    
      public void testRandomAddsAndRemoves_duplicateElements() {
        Random random = new Random(0);
        Multiset<Element> elements = HashMultiset.create();
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 13:11:08 GMT 2026
    - 36.2K bytes
    - Click Count (0)
  9. src/main/resources/fess_config.properties

    coordinator.poll.interval=60
    # Time-to-live (ms) for instance heartbeat documents.
    coordinator.heartbeat.ttl=180000
    # Time-to-live (ms) for operation lock documents.
    coordinator.operation.ttl=7200000
    # Maximum number of retries for acquiring an operation lock.
    coordinator.operation.retry=3
    # Time-to-live (ms) for event notification documents.
    coordinator.event.ttl=600000
    
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Mar 28 06:59:19 GMT 2026
    - 59.3K bytes
    - Click Count (0)
  10. okhttp/src/jvmTest/kotlin/okhttp3/URLConnectionTest.kt

          .source()
          .timeout()
          .timeout(100, TimeUnit.MILLISECONDS)
        assertContent("This connection won't pool properly", response1)
        assertThat(server.takeRequest().exchangeIndex).isEqualTo(0)
    
        // Give the server time to enact the socket policy if it's one that could happen after the
        // client has received the response.
        Thread.sleep(500)
        val response2 = getResponse(newRequest("/b"))
        response1.body
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 133.3K bytes
    - Click Count (0)
Back to Top