Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 6 of 6 for newMeta (0.05 seconds)

  1. cmd/utils.go

    func cleanMinioInternalMetadataKeys(metadata map[string]string) map[string]string {
    	newMeta := make(map[string]string, len(metadata))
    	for k, v := range metadata {
    		if strings.HasPrefix(k, "X-Amz-Meta-X-Minio-Internal-") {
    			newMeta[strings.TrimPrefix(k, "X-Amz-Meta-")] = v
    		} else {
    			newMeta[k] = v
    		}
    	}
    	return newMeta
    }
    
    // pathClean is like path.Clean but does not return "." for
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 33K bytes
    - Click Count (0)
  2. cmd/erasure-server-pool-decom.go

    				currentPool.ID = idx
    				newMeta.Pools = append(newMeta.Pools, currentPool)
    				skip = true
    				break
    			}
    		}
    		if skip {
    			continue
    		}
    		newMeta.Pools = append(newMeta.Pools, PoolStatus{
    			CmdLine:    pool.endpoints.CmdLine,
    			ID:         idx,
    			LastUpdate: UTCNow(),
    		})
    	}
    	return newMeta
    }
    
    func (z *erasureServerPools) IsDecommissionRunning() bool {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 42.2K bytes
    - Click Count (1)
  3. cmd/object-api-utils.go

    func cleanMetadataKeys(metadata map[string]string, keyNames ...string) map[string]string {
    	newMeta := make(map[string]string, len(metadata))
    	for k, v := range metadata {
    		if slices.Contains(keyNames, k) {
    			continue
    		}
    		newMeta[k] = v
    	}
    	return newMeta
    }
    
    // Extracts etag value from the metadata.
    func extractETag(metadata map[string]string) string {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Wed Jun 25 15:08:54 GMT 2025
    - 37.3K bytes
    - Click Count (0)
  4. android/guava/src/com/google/common/eventbus/SubscriberRegistry.java

          if (eventSubscribers == null) {
            CopyOnWriteArraySet<Subscriber> newSet = new CopyOnWriteArraySet<>();
            eventSubscribers =
                MoreObjects.firstNonNull(subscribers.putIfAbsent(eventType, newSet), newSet);
          }
    
          eventSubscribers.addAll(eventMethodsInListener);
        }
      }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Jul 08 18:32:10 GMT 2025
    - 10.8K bytes
    - Click Count (0)
  5. src/test/java/jcifs/internal/smb2/Smb2SigningDigestTest.java

                digest.secureWipeKey();
    
                // Verify digest fails after wiping
                byte[] newData = new byte[128];
                Arrays.fill(newData, (byte) 0x66);
    
                assertThrows(IllegalStateException.class, () -> {
                    digest.sign(newData, 0, newData.length, request, response);
                }, "Should throw exception after key is wiped");
            }
    
            @Test
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 30 05:58:03 GMT 2025
    - 43.7K bytes
    - Click Count (0)
  6. tests/association_generics_test.go

    		t.Fatalf("failed to create user: %v", err)
    	}
    
    	// Create a pet object
    	newPet := Pet{Name: "created-pet"}
    
    	// Test Set + Update with Association OpCreate
    	assocOp := clause.Association{
    		Association: "Pets",
    		Type:        clause.OpCreate,
    		Values:      []interface{}{&newPet},
    	}
    
    	rows, err := gorm.G[User](DB).Where("id = ?", user.ID).Set(assocOp).Update(ctx)
    	if err != nil {
    Created: Sun Apr 05 09:35:12 GMT 2026
    - Last Modified: Fri Sep 12 05:42:26 GMT 2025
    - 37.9K bytes
    - Click Count (0)
Back to Top