- Sort Score
- Result 10 results
- Languages All
Results 141 - 150 of 2,543 for context (0.12 sec)
-
cmd/healthcheck-handler.go
apiErr := toAPIError(r.Context(), err) writeResponse(w, apiErr.HTTPStatusCode, nil, mimeNone) case http.MethodGet: writeErrorResponse(r.Context(), w, toAPIError(r.Context(), err), r.URL) } return } } if globalEtcdClient != nil { // Borrowed from // https://github.com/etcd-io/etcd/blob/main/etcdctl/ctlv3/command/ep_command.go#L118 ctx, cancel := context.WithTimeout(r.Context(), defaultContextTimeout)
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Wed Jun 26 07:44:34 UTC 2024 - 6.9K bytes - Viewed (0) -
cmd/storage-interface.go
DeleteVersions(ctx context.Context, volume string, versions []FileInfoVersions, opts DeleteOptions) []error DeleteBulk(ctx context.Context, volume string, paths ...string) error WriteMetadata(ctx context.Context, origvolume, volume, path string, fi FileInfo) error UpdateMetadata(ctx context.Context, volume, path string, fi FileInfo, opts UpdateMetadataOpts) error
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Apr 25 05:41:04 UTC 2025 - 5.3K bytes - Viewed (0) -
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 Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 15.6K bytes - Viewed (0) -
impl/maven-core/src/test/java/org/apache/maven/project/harness/PomTestWrapper.java
} public void setValueOnModel(String expression, Object value) { context.setValue(expression, value); } public Iterator<?> getIteratorForXPathExpression(String expression) { return context.iterate(expression); } public boolean containsXPathExpression(String expression) { return context.getValue(expression) != null; } public Object getValue(String expression) {Registered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Sun Mar 30 23:08:36 UTC 2025 - 2.8K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/persistent/DurableHandleReconnect.java
@Override public int size() { // Context header (16) + name length (4) + padding to 8-byte alignment + data (16) return 16 + 4 + 4 + STRUCTURE_SIZE; } @Override public int encode(byte[] dst, int dstIndex) { int start = dstIndex; // Write context header SMBUtil.writeInt4(0, dst, dstIndex); // Next (offset to next context, 0 for last) dstIndex += 4;Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Thu Aug 21 04:51:33 UTC 2025 - 3K bytes - Viewed (0) -
internal/grid/muxserver.go
clientPingInterval time.Duration } func newMuxStateless(ctx context.Context, msg message, c *Connection, handler StatelessHandler) *muxServer { var cancel context.CancelFunc ctx = setCaller(ctx, c.remote) if msg.DeadlineMS > 0 { ctx, cancel = context.WithTimeout(ctx, time.Duration(msg.DeadlineMS)*time.Millisecond) } else { ctx, cancel = context.WithCancel(ctx) } m := muxServer{ ID: msg.MuxID,
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Tue May 27 15:19:03 UTC 2025 - 9.7K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb2/nego/Smb2NegotiateRequestTest.java
// Then NegotiateContextRequest[] contexts = request.getNegotiateContexts(); assertNotNull(contexts); assertEquals(2, contexts.length); // Verify preauth context assertTrue(contexts[0] instanceof PreauthIntegrityNegotiateContext); assertEquals(PreauthIntegrityNegotiateContext.NEGO_CTX_PREAUTH_TYPE, contexts[0].getContextType()); // Verify encryption contextRegistered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 20.7K 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: Sat Dec 20 13:44:44 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 Dec 28 19:28:13 UTC 2025 - Last Modified: Wed Apr 09 14:28:39 UTC 2025 - 11.4K bytes - Viewed (0) -
impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/mvn/MavenInvoker.java
protected void lookup(MavenContext context) throws Exception { if (context.maven == null) { super.lookup(context); context.maven = context.lookup.lookup(Maven.class); } } @Override protected void postCommands(MavenContext context) throws Exception { super.postCommands(context); Logger logger = context.logger;
Registered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Thu Sep 11 17:20:46 UTC 2025 - 28.2K bytes - Viewed (0)