Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 901 - 910 of 1,204 for loggers (0.05 seconds)

  1. src/test/java/jcifs/smb/SmbFileHandleImplTest.java

            h.markClosed();
    
            SmbException ex1 = assertThrows(SmbException.class, h::getFid);
            assertEquals("Descriptor is no longer valid", ex1.getMessage());
            SmbException ex2 = assertThrows(SmbException.class, h::getFileId);
            assertEquals("Descriptor is no longer valid", ex2.getMessage());
        }
    
        @Test
        @DisplayName("close(long) sends SMB2 close request and releases tree when SMB2")
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 12.3K bytes
    - Click Count (0)
  2. src/main/java/jcifs/smb/SmbResourceLocatorImpl.java

     */
    package jcifs.smb;
    
    import java.net.MalformedURLException;
    import java.net.URL;
    import java.net.UnknownHostException;
    import java.util.Objects;
    
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    
    import jcifs.Address;
    import jcifs.CIFSContext;
    import jcifs.CIFSException;
    import jcifs.DfsReferralData;
    import jcifs.NetbiosAddress;
    import jcifs.RuntimeCIFSException;
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Thu Aug 14 07:14:38 GMT 2025
    - 23.6K bytes
    - Click Count (0)
  3. src/main/java/jcifs/smb1/dcerpc/DcerpcPipeHandle.java

        protected void doSendFragment(final byte[] buf, final int off, final int length, final boolean isDirect) throws IOException {
            if (out != null && !out.isOpen()) {
                throw new IOException("DCERPC pipe is no longer open");
            }
    
            if (in == null) {
                in = (SmbFileInputStream) pipe.getNamedPipeInputStream();
            }
            if (out == null) {
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 4.5K bytes
    - Click Count (0)
  4. cmd/erasure-server-pool-rebalance.go

    	})
    	return err
    }
    
    // rebalanceBucket rebalances objects under bucket in poolIdx pool
    func (z *erasureServerPools) rebalanceBucket(ctx context.Context, bucket string, poolIdx int) (err error) {
    	ctx = logger.SetReqInfo(ctx, &logger.ReqInfo{})
    
    	var vc *versioning.Versioning
    	var lc *lifecycle.Lifecycle
    	var lr objectlock.Retention
    	var rcfg *replication.Config
    	if bucket != minioMetaBucket {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 28.7K bytes
    - Click Count (0)
  5. cmd/namespace-lock_test.go

    		// Unlock the 1st lock; ref=1 after this line
    		nsLk.unlock("volume", "path", false)
    
    		// Taking another lockMapMutex here allows queuing up additional lockers. This should
    		// not be required but makes reproduction much easier.
    		nsLk.lockMapMutex.Lock()
    
    		// lk3 blocks.
    		lk3ch := make(chan bool)
    		go func() {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 3K bytes
    - Click Count (0)
  6. internal/grid/stream.go

    	// Requests sent to the server.
    	// If the handler is defined with 0 incoming capacity this will be nil.
    	// Channel *must* be closed to signal the end of the stream.
    	// If the request context is canceled, the stream will no longer process requests.
    	// Requests sent cannot be used any further by the called.
    	Requests chan<- []byte
    
    	muxID uint64
    	ctx   context.Context
    }
    
    // Send a payload to the remote server.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Jun 07 15:51:52 GMT 2024
    - 3.1K bytes
    - Click Count (0)
  7. CHANGELOG/CHANGELOG-1.35.md

    - Feature gate dependencies are now explicit, and validated at startup. A feature can no longer be enabled if it depends on a disabled feature. In particular, this means that `AllAlpha=true` will no longer work without enabling disabled-by-default beta features that are depended on (either with `AllBeta=true` or explicitly enumerating the disabled dependencies). ([#133697](https://github.com/ku...
    Created: Fri Dec 26 09:05:12 GMT 2025
    - Last Modified: Wed Dec 17 13:01:55 GMT 2025
    - 228.5K bytes
    - Click Count (0)
  8. cmd/metrics-v3.go

    	clusterConfigCollectorPath       collectorPath = "/cluster/config"
    
    	ilmCollectorPath           collectorPath = "/ilm"
    	auditCollectorPath         collectorPath = "/audit"
    	loggerWebhookCollectorPath collectorPath = "/logger/webhook"
    	replicationCollectorPath   collectorPath = "/replication"
    	notificationCollectorPath  collectorPath = "/notification"
    	scannerCollectorPath       collectorPath = "/scanner"
    )
    
    const (
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 02 00:55:27 GMT 2024
    - 13.6K bytes
    - Click Count (0)
  9. CHANGELOG/CHANGELOG-1.22.md

    - github.com/Azure/go-autorest/autorest: [v0.11.12 → v0.11.18](https://github.com/Azure/go-autorest/autorest/compare/v0.11.12...v0.11.18)
    - github.com/Azure/go-autorest/logger: [v0.2.0 → v0.2.1](https://github.com/Azure/go-autorest/logger/compare/v0.2.0...v0.2.1)
    - github.com/alecthomas/units: [c3de453 → f65c72e](https://github.com/alecthomas/units/compare/c3de453...f65c72e)
    Created: Fri Dec 26 09:05:12 GMT 2025
    - Last Modified: Tue Dec 13 12:43:45 GMT 2022
    - 454.1K bytes
    - Click Count (0)
  10. cmd/metrics-v2.go

    }
    
    func getWebhookMetrics() *MetricsGroupV2 {
    	mg := &MetricsGroupV2{
    		cacheInterval: 10 * time.Second,
    	}
    	mg.RegisterRead(func(ctx context.Context) []MetricV2 {
    		tgts := append(logger.SystemTargets(), logger.AuditTargets()...)
    		metrics := make([]MetricV2, 0, len(tgts)*4)
    		for _, t := range tgts {
    			isOnline := 0
    			if t.IsOnline(ctx) {
    				isOnline = 1
    			}
    			labels := map[string]string{
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 133.6K bytes
    - Click Count (0)
Back to Top