Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 71 - 80 of 266 for poodlE (0.04 seconds)

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

  1. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/AddressPolicy.kt

     * limitations under the License.
     */
    package okhttp3.internal.connection
    
    /**
     * A policy for how the pool should treat a specific address.
     */
    class AddressPolicy(
      /**
       * How many concurrent calls should be possible to make at any time.
       * The pool will routinely try to pre-emptively open connections to satisfy this minimum.
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Tue Jun 03 17:10:08 GMT 2025
    - 1.3K bytes
    - Click Count (0)
  2. okhttp-testing-support/src/main/kotlin/okhttp3/TestValueFactory.kt

      var uriPort: Int = 1
    
      fun newConnection(
        pool: RealConnectionPool,
        route: Route,
        idleAtNanos: Long = Long.MAX_VALUE,
        taskRunner: TaskRunner = this.taskRunner,
      ): RealConnection {
        val result =
          RealConnection.newTestConnection(
            taskRunner = taskRunner,
            connectionPool = pool,
            route = route,
            socket = Socket(),
            idleAtNs = idleAtNanos,
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Oct 08 03:50:05 GMT 2025
    - 6.7K bytes
    - Click Count (0)
  3. guava-tests/test/com/google/common/collect/ConcurrentHashMultisetBasherTest.java

        int tasksPerThread = 10;
        int nTasks = nThreads * tasksPerThread;
        ExecutorService pool = newFixedThreadPool(nThreads);
        ImmutableList<String> keys = ImmutableList.of("a", "b", "c");
        try {
          List<Future<int[]>> futures = newArrayListWithExpectedSize(nTasks);
          for (int i = 0; i < nTasks; i++) {
            futures.add(pool.submit(new MutateTask(multiset, keys)));
          }
    
          int[] deltas = new int[3];
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Dec 08 22:42:14 GMT 2025
    - 5.7K bytes
    - Click Count (0)
  4. guava-tests/test/com/google/common/util/concurrent/ThreadFactoryBuilderTest.java

        // pool ID but a thread ID of 2.
        Thread thread2 = threadFactory.newThread(monitoredRunnable);
        checkThreadPoolName(thread2, 2);
        assertEquals(
            thread.getName().substring(0, thread.getName().lastIndexOf('-')),
            thread2.getName().substring(0, thread.getName().lastIndexOf('-')));
    
        // Building again should give us a different pool ID.
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Dec 11 20:07:52 GMT 2025
    - 7.6K bytes
    - Click Count (0)
  5. src/test/java/jcifs/SmbTransportPoolTest.java

                verify(transportPool).removeTransport(transport2);
            }
        }
    
        @Nested
        @DisplayName("Pool Lifecycle")
        class PoolLifecycleTests {
    
            @Test
            @DisplayName("Should close pool successfully with no active transports")
            void testClosePoolNoActiveTransports() throws CIFSException {
                // Given
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 22.6K bytes
    - Click Count (0)
  6. prepare_stmt.go

    //
    // Returns:
    // - A pointer to a PreparedStmtDB instance, which manages prepared statements using the provided connection pool and configuration.
    func NewPreparedStmtDB(connPool ConnPool, maxSize int, ttl time.Duration) *PreparedStmtDB {
    	return &PreparedStmtDB{
    		ConnPool: connPool,                     // Assigns the provided connection pool to manage database connections.
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Fri Apr 25 08:22:26 GMT 2025
    - 5.7K bytes
    - Click Count (0)
  7. docs/metrics/prometheus/grafana/minio-dashboard.json

              "expr": "minio_cluster_health_status{job=~\"$scrape_jobs\"}",
              "fullMetaSearch": false,
              "includeNullMetadata": true,
              "interval": "",
              "legendFormat": "Pool: {{pool}} Set: {{set}}",
              "range": true,
              "refId": "A",
              "useBackend": false
            }
          ],
          "title": "Cluster Health Status",
          "type": "stat"
        },
        {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Mon Aug 04 01:46:49 GMT 2025
    - 93.1K bytes
    - Click Count (0)
  8. internal/s3select/csv/reader.go

    	queue        chan *queueItem        // output from workers in order
    	err          error                  // global error state, only touched by Reader.Read
    	bufferPool   bpool.Pool[[]byte]     // pool of []byte objects for input
    	csvDstPool   bpool.Pool[[][]string] // pool of [][]string used for output
    	close        chan struct{}          // used for shutting down the splitter before end of stream
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue May 27 15:19:03 GMT 2025
    - 8.8K bytes
    - Click Count (0)
  9. src/main/java/jcifs/CIFSContext.java

         * Get the buffer cache for efficient memory management
         *
         * @return the buffer cache
         */
        BufferCache getBufferCache();
    
        /**
         * Get the transport pool for managing SMB connections
         *
         * @return the transport pool
         */
        SmbTransportPool getTransportPool();
    
        /**
         * Get the DFS resolver for handling distributed file system paths
         *
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 4.9K bytes
    - Click Count (0)
  10. impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/mvn/resident/ResidentMavenInvoker.java

                    exceptions.add(e);
                }
            }
            if (!exceptions.isEmpty()) {
                InvokerException exception = new InvokerException("Could not cleanly shut down context pool");
                exceptions.forEach(exception::addSuppressed);
                throw exception;
            }
        }
    
        @Override
        protected MavenContext createContext(InvokerRequest invokerRequest) {
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Thu Sep 11 17:20:46 GMT 2025
    - 4.1K bytes
    - Click Count (0)
Back to Top