- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 1,843 for context (0.13 sec)
-
cmd/tier.go
if t, ok := config.Tiers[tierName]; ok { return t.Type, true } return madmin.Unsupported, false } // Add adds tier to config if it passes all validations. func (config *TierConfigMgr) Add(ctx context.Context, tier madmin.TierConfig, ignoreInUse bool) error { config.Lock() defer config.Unlock() // check if tier name is in all caps tierName := tier.Name if tierName != strings.ToUpper(tierName) {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 15.6K bytes - Viewed (0) -
cmd/bucket-metadata-sys.go
} sys.Set(meta.Name, meta) globalNotificationSys.LoadBucketMetadata(bgContext(ctx), meta.Name) // Do not use caller context here return nil } // Delete delete the bucket metadata for the specified bucket. // must be used by all callers instead of using Update() with nil configData. func (sys *BucketMetadataSys) Delete(ctx context.Context, bucket string, configFile string) (updatedAt time.Time, err error) {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 20.4K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbOperationException.java
} /** * Add context information * * @param key the context key * @param value the context value * @return this exception for chaining */ public SmbOperationException withContext(String key, Object value) { this.context.put(key, value); return this; } /** * Add multiple context values *Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 16.5K bytes - Viewed (0) -
cmd/signature-v2_test.go
break } } } // Tests presigned v2 signature. func TestDoesPresignedV2SignatureMatch(t *testing.T) { ctx, cancel := context.WithCancel(t.Context()) defer cancel() obj, fsDir, err := prepareFS(ctx) if err != nil { t.Fatal(err) } defer os.RemoveAll(fsDir) if err = newTestConfig(globalMinioDefaultRegion, obj); err != nil {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 8K bytes - Viewed (0) -
src/main/java/jcifs/smb1/util/MD4.java
@Override public void engineReset() { // initial values of MD4 i.e. A, B, C, D // as per rfc-1320; they are low-order byte first context[0] = 0x67452301; context[1] = 0xEFCDAB89; context[2] = 0x98BADCFE; context[3] = 0x10325476; count = 0L; for (int i = 0; i < BLOCK_LENGTH; i++) { buffer[i] = 0; } } /**Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 9.6K bytes - Viewed (0) -
cmd/storage-rest_test.go
continue } err := storage.AppendFile(t.Context(), testCase.volumeName, testCase.objectName, testCase.data) expectErr := (err != nil) if expectErr != testCase.expectErr { t.Fatalf("case %v: error: expected: %v, got: %v", i+1, testCase.expectErr, expectErr) } if !testCase.expectErr { data, err := storage.ReadAll(t.Context(), testCase.volumeName, testCase.objectName) if err != nil {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Wed Apr 09 14:28:39 UTC 2025 - 11.4K bytes - Viewed (0) -
cmd/generic-handlers.go
} } sr, err := globalDNSConfig.Get(bucket) if err != nil { defer logger.AuditLog(r.Context(), w, r, mustGetClaimsFromToken(r)) if err == dns.ErrNoEntriesFound { writeErrorResponse(r.Context(), w, errorCodes.ToAPIErr(ErrNoSuchBucket), r.URL) } else { writeErrorResponse(r.Context(), w, toAPIError(r.Context(), err), r.URL) } return }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 20.7K bytes - Viewed (1) -
src/main/java/org/codelibs/fess/query/TermRangeQueryCommand.java
final String origQuery = queryBuf.toString(); context.addFieldLog(Constants.DEFAULT_FIELD, origQuery); context.addHighlightedQuery(origQuery); return buildDefaultQueryBuilder(fessConfig, context, (f, b) -> QueryBuilders.matchPhraseQuery(f, origQuery).boost(b)); } context.addFieldLog(field, termRangeQuery.toString(field));
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 4.9K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/nego/Smb2RdmaTransformCapabilitiesContext.java
/** * SMB2 RDMA Transform Capabilities negotiate context. * * This context is used during SMB2 negotiation to indicate RDMA transform * capabilities when SMB Direct is supported by the client and server. */ public class Smb2RdmaTransformCapabilitiesContext implements NegotiateContextRequest, NegotiateContextResponse { // Context type /** Context ID for RDMA transform capabilities */Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sun Aug 24 00:12:28 UTC 2025 - 4.4K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb2/lease/DirectoryLeasingIntegrationTest.java
DirectoryLeaseContext context = new DirectoryLeaseContext(key, DirectoryLeaseState.DIRECTORY_FULL, DirectoryCacheScope.RECURSIVE_TREE); context.setMaxCacheAge(60000L); context.setNotificationEnabled(true); context.setNotificationFilter(0x1F); // Test encoding and decoding roundtrip byte[] buffer = new byte[context.size()];Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 23 01:47:47 UTC 2025 - 14.2K bytes - Viewed (0)