Search Options

Results per page
Sort
Preferred Languages
Advance

Results 331 - 340 of 507 for await (0.01 sec)

  1. src/main/java/jcifs/SmbResourceException.java

                return "Free up disk space or use a different location";
            case QUOTA:
                return "Contact administrator to increase quota limits";
            case LOCK:
                return "Release existing locks or wait for them to be released";
            case BUFFER:
                return "Reduce buffer usage or increase buffer pool size";
            case THREAD_POOL:
                return "Reduce concurrent operations or increase thread pool size";
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 5.6K bytes
    - Viewed (0)
  2. docs/metrics/prometheus/alerts.md

    2. Start Prometheus server and AlertManager
    3. Bring down couple of MinIO instances to bring down the Erasure Set tolerance to -1 and verify the same with `mc admin prometheus metrics ALIAS | grep minio_cluster_health_erasure_set_status`
    4. Wait for 5 mins (as alert is configured to be firing after 5 mins), and verify that you see an entry in webhook for the alert as well as in Prometheus console as shown below
    
    ```json
    {
      "receiver": "web\\.hook",
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed Apr 23 15:13:23 UTC 2025
    - 4.4K bytes
    - Viewed (0)
  3. src/main/java/jcifs/SmbException.java

         */
        public long getRetryDelay() {
            switch (severity) {
            case RECOVERABLE:
                return 100; // Immediate retry with small delay
            case TRANSIENT:
                return 5000; // Wait 5 seconds
            default:
                return 0; // No retry
            }
        }
    
        @Override
        public String toString() {
            StringBuilder sb = new StringBuilder();
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 6.4K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/core/timer/TimeoutManager.java

                }
            }
        }
    
        /**
         * Interrupts the thread and waits for it to terminate.
         *
         * @param timeoutMillis
         *            The time to wait (in milliseconds)
         * @return <code>true</code> if the thread has terminated
         * @throws InterruptedException
         *             If interrupted while waiting
         */
    Registered: Fri Sep 05 20:58:11 UTC 2025
    - Last Modified: Sat May 10 01:32:17 UTC 2025
    - 7.8K bytes
    - Viewed (0)
  5. src/test/java/jcifs/util/ResourceManagerTest.java

            TestResource resource = new TestResource("old");
            resourceManager.registerResource(resource);
    
            assertFalse(resource.isClosed());
    
            // Wait for automatic cleanup to kick in
            Thread.sleep(300);
    
            // Perform cleanup
            resourceManager.performCleanup();
    
            // Old resource should be auto-closed
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 8.9K bytes
    - Viewed (0)
  6. .teamcity/mvnw.cmd

    @REM
    @REM Optional ENV vars
    @REM M2_HOME - location of maven2's installed home dir
    @REM MAVEN_BATCH_ECHO - set to 'on' to enable the echoing of the batch commands
    @REM MAVEN_BATCH_PAUSE - set to 'on' to wait for a keystroke before ending
    @REM MAVEN_OPTS - parameters passed to the Java VM when running Maven
    @REM     e.g. to debug Maven itself, use
    @REM set MAVEN_OPTS=-Xdebug -Xrunjdwp:transport=dt_socket,server=y,suspend=y,address=8000
    Registered: Wed Sep 10 11:36:15 UTC 2025
    - Last Modified: Wed Feb 26 01:48:39 UTC 2020
    - 6.5K bytes
    - Viewed (0)
  7. cmd/endpoint.go

    					endpoints[i].IsLocal = isLocal
    					epsResolved++
    					if !foundLocal {
    						foundLocal = isLocal
    					}
    				}
    			}
    
    			// Wait for the tick, if the there exist a local endpoint in discovery.
    			// Non docker/kubernetes environment we do not need to wait.
    			if !foundLocal && orchestrated {
    				<-keepAliveTicker.C
    			}
    		}
    	}
    
    	// On Kubernetes/Docker setups DNS resolves inappropriately sometimes
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 34.4K bytes
    - Viewed (0)
  8. cmd/metacache-stream.go

    			}
    		}
    	}()
    
    	return objs, nil
    }
    
    // Close and release resources.
    func (w *metacacheWriter) Close() error {
    	if w == nil || w.closer == nil {
    		return nil
    	}
    	w.streamWg.Wait()
    	err := w.closer()
    	w.closer = nil
    	return err
    }
    
    // Reset and start writing to new writer.
    // Close must have been called before this.
    func (w *metacacheWriter) Reset(out io.Writer) {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed May 07 15:37:12 UTC 2025
    - 19.5K bytes
    - Viewed (0)
  9. src/test/java/jcifs/tests/persistent/PersistentHandleManagerTest.java

        }
    
        @Test
        public void testGetHandleForReconnectExpired() {
            manager.requestDurableHandle("/test/file.txt", HandleType.DURABLE_V2, 100, // 100ms timeout
                    null);
    
            // Wait for expiration
            try {
                Thread.sleep(150);
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
            }
    
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 21 04:51:33 UTC 2025
    - 6.6K bytes
    - Viewed (0)
  10. cmd/dynamic-timeouts_test.go

    					timeout.LogSuccess(time.Duration(float64(time.Second) * rng.Float64()))
    				}
    				to := timeout.Timeout()
    				if to < time.Millisecond || to > time.Second {
    					panic(to)
    				}
    			}
    		}()
    	}
    	wg.Wait()
    }
    
    func TestDynamicTimeoutHitMinimum(t *testing.T) {
    	const minimum = 30 * time.Second
    	timeout := newDynamicTimeout(time.Minute, minimum)
    
    	initial := timeout.Timeout()
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 5.2K bytes
    - Viewed (0)
Back to top