Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 721 - 730 of 799 for arrays (0.04 seconds)

  1. cmd/object-multipart-handlers.go

    		return
    	}
    	opts.Versioned = versioned
    	opts.VersionSuspended = suspended
    
    	// First, we compute the ETag of the multipart object.
    	// The ETag of a multi-part object is always:
    	//   ETag := MD5(ETag_p1, ETag_p2, ...)+"-N"   (N being the number of parts)
    	//
    	// This is independent of encryption. An encrypted multipart
    	// object also has an ETag that is the MD5 of its part ETags.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 07 16:13:09 GMT 2025
    - 39.5K bytes
    - Click Count (1)
  2. cmd/server-main.go

    		globalConsoleSys.SetNodeName(globalLocalNodeName)
    		if err != nil {
    			// We can only log here since we need globalConsoleSys initialized
    			logger.Fatal(err, "invalid --logrorate-dir option")
    		}
    	})
    
    	// Always load ENV variables from files first.
    	loadEnvVarsFromFiles()
    
    	// Handle early server environment vars
    	serverHandleEarlyEnvVars()
    
    	// Handle all server command args and build the disks layout
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue May 27 15:18:36 GMT 2025
    - 35.9K bytes
    - Click Count (4)
  3. tensorflow/c/c_api_function_test.cc

             true);
      EXPECT_EQ(TF_INVALID_ARGUMENT, TF_GetCode(s_));
      EXPECT_EQ(string("Cannot have duplicate output names. Name 'my_out' "
                       "appears more than once in 'output_names' array."),
                string(TF_Message(s_)));
    }
    
    TEST_F(CApiFunctionTest, InvalidInputTensor_HighIndex) {
      /*
       *                  |  |
       *                  v  v
       *                  add
    Created: Tue Dec 30 12:39:10 GMT 2025
    - Last Modified: Mon Nov 17 00:00:38 GMT 2025
    - 63.6K bytes
    - Click Count (1)
  4. cmd/object-handlers_test.go

    			if err != nil {
    				t.Errorf("MinIO %s: Error decoding the recorded response Body", instanceType)
    				return
    			}
    			// push the obtained upload ID from the response into the array.
    			testUploads.Lock()
    			testUploads.uploads = append(testUploads.uploads, multipartResponse.UploadID)
    			testUploads.Unlock()
    		}()
    	}
    	// Wait till all go routines finishes execution.
    	wg.Wait()
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 163.1K bytes
    - Click Count (0)
  5. cmd/endpoint.go

    // GetLocalPeer - returns local peer value, returns globalMinioAddr
    // for FS and Erasure mode. In case of distributed server return
    // the first element from the set of peers which indicate that
    // they are local. There is always one entry that is local
    // even with repeated server endpoints.
    func GetLocalPeer(endpointServerPools EndpointServerPools, host, port string) (localPeer string) {
    	peerSet := set.NewStringSet()
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 34.5K bytes
    - Click Count (0)
  6. internal/config/config.go

    // subsystem (whether they are enabled or not). A target could be configured via
    // environment variables or via the configuration store. The default target is
    // `_` and is always returned. The result is sorted so that the default target
    // is the first one and the remaining entries are sorted in ascending order.
    func (c Config) GetAvailableTargets(subSys string) ([]string, error) {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 37.7K bytes
    - Click Count (0)
  7. cmd/erasure-server-pool-decom.go

    				if version.Deleted {
    					_, err := z.DeleteObject(ctx,
    						bi.Name,
    						version.Name,
    						ObjectOptions{
    							// Since we are preserving a delete marker, we have to make sure this is always true.
    							// regardless of the current configuration of the bucket we must preserve all versions
    							// on the pool being decommissioned.
    							Versioned:          true,
    							VersionID:          versionID,
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 42.2K bytes
    - Click Count (1)
  8. cmd/object-api-utils.go

    	}
    }
    
    // newS2CompressReader will read data from r, compress it and return the compressed data as a Reader.
    // Use Close to ensure resources are released on incomplete streams.
    //
    // input 'on' is always recommended such that this function works
    // properly, because we do not wish to create an object even if
    // client closed the stream prematurely.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Jun 25 15:08:54 GMT 2025
    - 37.3K bytes
    - Click Count (0)
  9. cmd/iam.go

    						iamLogIf(ctx, logErr)
    					}
    				}
    			}
    		}
    
    		// Replacing origKeys[0] with normKey in the policyMap
    
    		// len(origKeys) is always > 0, so here len(origKeys) == 1
    		mappingValue := policyMap[origKeys[0]]
    		delete(policyMap, origKeys[0])
    		policyMap[normKey] = mappingValue
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Oct 15 17:00:45 GMT 2025
    - 76.5K bytes
    - Click Count (0)
  10. cmd/erasure-object.go

    	}
    
    	return fi.ToObjectInfo(srcBucket, srcObject, srcOpts.Versioned || srcOpts.VersionSuspended), nil
    }
    
    // GetObjectNInfo - returns object info and an object
    // Read(Closer). When err != nil, the returned reader is always nil.
    func (er erasureObjects) GetObjectNInfo(ctx context.Context, bucket, object string, rs *HTTPRangeSpec, h http.Header, opts ObjectOptions) (gr *GetObjectReader, err error) {
    	if !opts.NoAuditLog {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Oct 24 04:05:31 GMT 2025
    - 80.4K bytes
    - Click Count (0)
Back to Top