- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 14 for InUse (0.04 sec)
-
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) -
src/main/java/jcifs/context/BaseContext.java
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Sun Nov 27 18:25:00 UTC 2022 - 5.3K bytes - Viewed (0) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)