Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 14 for InUse (0.04 sec)

  1. src/main/java/jcifs/smb/SmbTransportPoolImpl.java

                try {
                    inUse |= conn.disconnect(false, false);
                }
                catch ( IOException e ) {
                    log.warn("Failed to close connection", e);
                }
            }
            synchronized ( this.connections ) {
                cleanup();
            }
            return inUse;
        }
    
    
        @Override
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Dec 20 14:09:34 UTC 2020
    - 12.5K bytes
    - Viewed (0)
  2. src/main/java/jcifs/context/BaseContext.java

        /**
         * {@inheritDoc}
         *
         * @see jcifs.CIFSContext#close()
         */
        @Override
        public boolean close () throws CIFSException {
            boolean inUse = super.close();
            inUse |= this.transportPool.close();
            return inUse;
        }
    
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Nov 27 18:25:00 UTC 2022
    - 5.3K bytes
    - Viewed (0)
  3. src/main/java/jcifs/smb/SmbTransportInternal.java

         * @return whether the transport has been disconnected
         */
        boolean isDisconnected ();
    
    
        /**
         * @param hard
         * @param inuse
         * @return whether the connection was in use
         * @throws IOException
         */
        boolean disconnect ( boolean hard, boolean inuse ) throws IOException;
    
    
        /**
         * @return whether the transport was connected
         * @throws SmbException
         * @throws IOException
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 3K bytes
    - Viewed (0)
  4. cmd/tier.go

    	d, err := newWarmBackend(ctx, tier, true)
    	if err != nil {
    		return err
    	}
    
    	if !ignoreInUse {
    		// Check if warmbackend is in use by other MinIO tenants
    		inUse, err := d.InUse(ctx)
    		if err != nil {
    			return err
    		}
    		if inUse {
    			return errTierBackendInUse
    		}
    	}
    
    	config.Tiers[tierName] = tier
    	config.drivercache[tierName] = d
    
    	return nil
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 20:44:05 UTC 2024
    - 15.7K bytes
    - Viewed (0)
  5. src/main/java/jcifs/util/transport/Transport.java

    
        /**
         * Disconnect the transport
         * 
         * @param hard
         * @param inUse
         *            whether the caller is holding a usage reference on the transport
         * @return whether conenction was in use
         * @throws IOException
         */
        public synchronized boolean disconnect ( boolean hard, boolean inUse ) throws IOException {
            IOException ioe = null;
    
            switch ( this.state ) {
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Nov 01 18:12:21 UTC 2020
    - 24.1K bytes
    - Viewed (0)
  6. src/main/java/jcifs/smb/SmbTreeImpl.java

                    if ( st == 2 ) {
                        long l = this.usageCount.get();
                        if ( ( inUse && l != 1 ) || ( !inUse && l > 0 ) ) {
                            log.warn("Disconnected tree while still in use " + this);
                            dumpResource();
                            wasInUse = true;
                            if ( sess.getConfig().isTraceResourceUsage() ) {
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Thu Jan 05 13:06:39 UTC 2023
    - 29.6K bytes
    - Viewed (0)
  7. cmd/warm-backend.go

    	Get(ctx context.Context, object string, rv remoteVersionID, opts WarmBackendGetOpts) (io.ReadCloser, error)
    	Remove(ctx context.Context, object string, rv remoteVersionID) error
    	InUse(ctx context.Context) (bool, error)
    }
    
    const probeObject = "probeobject"
    
    // checkWarmBackend checks if tier config credentials have sufficient privileges
    // to perform all operations defined in the WarmBackend interface.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 4K bytes
    - Viewed (0)
  8. cmd/warm-backend-s3.go

    	if rv != "" {
    		ropts.VersionID = string(rv)
    	}
    	err := s3.client.RemoveObject(ctx, s3.Bucket, s3.getDest(object), ropts)
    	return s3.ToObjectError(err, object)
    }
    
    func (s3 *warmBackendS3) InUse(ctx context.Context) (bool, error) {
    	result, err := s3.core.ListObjectsV2(s3.Bucket, s3.Prefix, "", "", slashSeparator, 1)
    	if err != nil {
    		return false, s3.ToObjectError(err)
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 5.7K bytes
    - Viewed (0)
  9. cmd/warm-backend-azure.go

    	_, err := az.clnt.DeleteBlob(ctx, az.Bucket, az.getDest(object), &azblob.DeleteBlobOptions{})
    	return azureToObjectError(err, az.Bucket, az.getDest(object))
    }
    
    func (az *warmBackendAzure) InUse(ctx context.Context) (bool, error) {
    	maxResults := int32(1)
    	pager := az.clnt.NewListBlobsFlatPager(az.Bucket, &azblob.ListBlobsFlatOptions{
    		Prefix:     &az.Prefix,
    		MaxResults: &maxResults,
    	})
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 7K bytes
    - Viewed (0)
  10. cmd/warm-backend-gcs.go

    	err := gcs.client.Bucket(gcs.Bucket).Object(gcs.getDest(key)).Delete(ctx)
    	return gcsToObjectError(err, gcs.Bucket, key)
    }
    
    func (gcs *warmBackendGCS) InUse(ctx context.Context) (bool, error) {
    	it := gcs.client.Bucket(gcs.Bucket).Objects(ctx, &storage.Query{
    		Delimiter: "/",
    		Prefix:    gcs.Prefix,
    		Versions:  false,
    	})
    	pager := iterator.NewPager(it, 1, "")
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 6.1K bytes
    - Viewed (0)
Back to top