Search Options

Results per page
Sort
Preferred Languages
Advance

Results 751 - 760 of 1,387 for Take (0.02 sec)

  1. guava/src/com/google/common/primitives/UnsignedInteger.java

      public static final UnsignedInteger MAX_VALUE = fromIntBits(-1);
    
      private final int value;
    
      private UnsignedInteger(int value) {
        // GWT doesn't consistently overflow values to make them 32-bit, so we need to force it.
        this.value = value & 0xffffffff;
      }
    
      /**
       * Returns an {@code UnsignedInteger} corresponding to a given bit representation. The argument is
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 8.3K bytes
    - Viewed (0)
  2. okhttp/src/jvmTest/kotlin/okhttp3/ServerTruncatesRequestTest.kt

            ) {
              socket = connection.socket() as SSLSocket
            }
    
            override fun requestHeadersStart(call: Call) {
              if (closed) {
                throw IOException("fake socket failure")
              }
            }
          }
        val localClient = client.newBuilder().eventListener(eventListener).build()
    
        val call1 = localClient.newCall(Request(server.url("/")))
    
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Tue Nov 04 19:13:52 UTC 2025
    - 10.4K bytes
    - Viewed (0)
  3. impl/maven-core/src/test/java/org/apache/maven/lifecycle/internal/LifecycleExecutionPlanCalculatorTest.java

                    session1, ProjectDependencyGraphStub.A, taskSegment2.getTasks());
            assertEquals(3, executionPlan2.size());
        }
    
        // Maybe also make one with LifeCycleTasks
    
        public static LifecycleExecutionPlanCalculator createExecutionPlaceCalculator(
                MojoDescriptorCreator mojoDescriptorCreator) throws ComponentLookupException {
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  4. cmd/globals.go

    	globalIsTLS bool
    
    	globalTLSCerts *certs.Manager
    
    	globalHTTPServer        *xhttp.Server
    	globalTCPOptions        xhttp.TCPOptions
    	globalHTTPServerErrorCh = make(chan error)
    	globalOSSignalCh        = make(chan os.Signal, 1)
    
    	// global Trace system to send HTTP request/response
    	// and Storage/OS calls info to registered listeners.
    	globalTrace = pubsub.New[madmin.TraceInfo, madmin.TraceType](8)
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Sep 03 18:23:41 UTC 2024
    - 16.2K bytes
    - Viewed (1)
  5. android-test/src/test/kotlin/okhttp/android/test/DisabledInitialiserTest.kt

            )
            hasClass<IOException>()
          }
        }
      }
    
      companion object {
        @AfterClass
        @JvmStatic
        fun resetContext() {
          // Ensure we don't make other tests fail
          Platform.resetForTests()
        }
      }
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Sat Aug 30 16:25:39 UTC 2025
    - 2.1K bytes
    - Viewed (0)
  6. samples/guide/src/main/java/okhttp3/guide/PostExample.java

            + "]}";
      }
    
      public static void main(String[] args) throws IOException {
        PostExample example = new PostExample();
        String json = example.bowlingJson("Jesse", "Jake");
        String response = example.post("http://www.roundsapp.com/post", json);
        System.out.println(response);
      }
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Fri Apr 05 03:30:42 UTC 2024
    - 2K bytes
    - Viewed (0)
  7. impl/maven-core/src/main/java/org/apache/maven/project/DuplicateArtifactAttachmentException.java

    package org.apache.maven.project;
    
    import org.apache.maven.artifact.Artifact;
    
    /**
     * This exception is thrown if an application attempts to attach
     * two of the same artifacts to a single project.
     *
     * TODO Make this a checked exception, and modify the API of MavenProjectHelper.
     * Currently, this modification would create compatibility problems for existing plugins.
     */
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 1.9K bytes
    - Viewed (0)
  8. cmd/bootstrap-messages.go

    	bs.mu.Lock()
    	defer bs.mu.Unlock()
    
    	if len(bs.info) > bootstrapTraceLimit {
    		return
    	}
    	bs.info = append(bs.info, info)
    }
    
    func (bs *bootstrapTracer) Events() []madmin.TraceInfo {
    	traceInfo := make([]madmin.TraceInfo, 0, bootstrapTraceLimit)
    
    	bs.mu.RLock()
    	traceInfo = append(traceInfo, bs.info...)
    	bs.mu.RUnlock()
    
    	return traceInfo
    }
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 1.7K bytes
    - Viewed (0)
  9. cmd/os-instrumented.go

    	var m madmin.OSMetrics
    	m.CollectedAt = time.Now()
    	m.LifeTimeOps = make(map[string]uint64, osMetricLast)
    	for i := range osMetricLast {
    		if n := atomic.LoadUint64(&o.operations[i]); n > 0 {
    			m.LifeTimeOps[i.String()] = n
    		}
    	}
    	if len(m.LifeTimeOps) == 0 {
    		m.LifeTimeOps = nil
    	}
    
    	m.LastMinute.Operations = make(map[string]madmin.TimedAction, osMetricLast)
    	for i := range osMetricLast {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 6.2K bytes
    - Viewed (0)
  10. internal/kms/context.go

    	// heuristic value that seems like a good starting size.
    	b := bytes.NewBuffer(make([]byte, 0, 128))
    	if len(c) == 1 {
    		for k, v := range c {
    			b.WriteString(`{"`)
    			escapeStringJSON(b, k)
    			b.WriteString(`":"`)
    			escapeStringJSON(b, v)
    			b.WriteString(`"}`)
    		}
    		return b.Bytes(), nil
    	}
    
    	sortedKeys := make([]string, 0, len(c))
    	for k := range c {
    		sortedKeys = append(sortedKeys, k)
    	}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Jan 02 17:15:06 UTC 2022
    - 6K bytes
    - Viewed (0)
Back to top