Search Options

Results per page
Sort
Preferred Languages
Advance

Results 81 - 90 of 225 for curinga (0.09 sec)

  1. internal/config/config.go

    )
    
    // DefaultKVS - default kvs for all sub-systems
    var DefaultKVS = map[string]KVS{}
    
    // RegisterDefaultKVS - this function saves input kvsMap
    // globally, this should be called only once preferably
    // during `init()`.
    func RegisterDefaultKVS(kvsMap map[string]KVS) {
    	for subSys, kvs := range kvsMap {
    		DefaultKVS[subSys] = kvs
    	}
    }
    
    // HelpSubSysMap - help for all individual KVS for each sub-systems
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Sep 03 18:23:41 UTC 2024
    - 37.7K bytes
    - Viewed (0)
  2. cmd/perf-tests.go

    		Downloads:     totalBytesRead,
    		UploadTimes:   uploadTimes,
    		DownloadTimes: downloadTimes,
    		DownloadTTFB:  downloadTTFB,
    		Error:         retError,
    	}, nil
    }
    
    // To collect RX stats during "mc support perf net"
    // RXSample holds the RX bytes for the duration between
    // the last peer to connect and the first peer to disconnect.
    // This is to improve the RX throughput accuracy.
    type netPerfRX struct {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  3. cmd/iam-object-store.go

    		userName := path.Dir(item)
    		// loadUser() will delete expired user during the load.
    		iamLogIf(ctx, iamOS.loadUser(ctx, userName, stsUser, stsAccountsFromStore))
    		// No need to return errors for failed expiration of STS users
    	}
    
    	// Loading the STS policy mappings from disk ensures that stale entries
    	// (removed during loadUser() in the loop above) are removed from memory.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Oct 10 23:40:37 UTC 2024
    - 26.6K bytes
    - Viewed (0)
  4. docs/distributed/DESIGN.md

    > http://host2/export8
    ```
    
    *A noticeable trait of this expansion is that it chooses unique hosts such the setup provides maximum protection and availability.*
    
    - Choosing an erasure set for the object is decided during `PutObject()`, object names are used to find the right erasure set using the following pseudo code.
    
    ```go
    // hashes the key returning an integer.
    func sipHashMod(key string, cardinality int, id [16]byte) int {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Aug 15 23:04:20 UTC 2023
    - 8K bytes
    - Viewed (0)
  5. internal/ringbuffer/ring_buffer.go

    	}
    	return nil
    }
    
    // Read reads up to len(p) bytes into p. It returns the number of bytes read (0 <= n <= len(p)) and any error encountered.
    // Even if Read returns n < len(p), it may use all of p as scratch space during the call.
    // If some data is available but not len(p) bytes, Read conventionally returns what is available instead of waiting for more.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed May 15 00:11:04 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  6. internal/hash/reader.go

    				ExpectedMD5:   v.Expected.String(),
    				CalculatedMD5: v.Computed.String(),
    			}
    		}
    	}
    	return n, err
    }
    
    // Size returns the absolute number of bytes the Reader
    // will return during reading. It returns -1 for unlimited
    // data.
    func (r *Reader) Size() int64 { return r.size }
    
    // ActualSize returns the pre-modified size of the object.
    // DecompressedSize - For compressed objects.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Sep 19 12:59:07 UTC 2024
    - 10.9K bytes
    - Viewed (0)
  7. cmd/metacache-stream.go

    			current.EOS = true
    			finishBlock()
    		}
    	}()
    	return &w
    }
    
    // Close the stream.
    // The incoming channel must be closed before calling this.
    // Returns the first error the occurred during the writing if any.
    func (w *metacacheBlockWriter) Close() error {
    	w.wg.Wait()
    	return w.streamErr
    }
    
    type metacacheBlock struct {
    	data  []byte
    	n     int
    	First string `json:"f"`
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Apr 04 12:04:40 UTC 2024
    - 19.5K bytes
    - Viewed (0)
  8. docs/en/docs/deployment/concepts.md

    And it will work and will be useful **during development**.
    
    But if your connection to the server is lost, the **running process** will probably die.
    
    Registered: Sun Oct 27 07:19:11 UTC 2024
    - Last Modified: Wed Sep 18 16:09:57 UTC 2024
    - 17.8K bytes
    - Viewed (0)
  9. internal/bucket/lifecycle/lifecycle_test.go

    			if err != tc.expectedParsingErr {
    				t.Fatalf("%d: Expected %v during parsing but got %v", i+1, tc.expectedParsingErr, err)
    			}
    			if tc.expectedParsingErr != nil {
    				// We already expect a parsing error,
    				// no need to continue this test.
    				return
    			}
    			err = lc.Validate(tc.lr)
    			if err != tc.expectedValidationErr {
    				t.Fatalf("%d: Expected %v during validation but got %v", i+1, tc.expectedValidationErr, err)
    			}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu May 23 01:12:48 UTC 2024
    - 55.1K bytes
    - Viewed (0)
  10. .bazelrc

    #     avx_win:                Build with avx instruction set on windows
    #
    # Other build options:
    #     short_logs:       Only log errors during build, skip warnings.
    #     verbose_logs:     Show all compiler warnings during build.
    #     monolithic:       Build all TF C++ code into a single shared object.
    #     dynamic_kernels:  Try to link all kernels dynamically (experimental).
    Registered: Tue Oct 29 12:39:09 UTC 2024
    - Last Modified: Mon Oct 28 22:02:31 UTC 2024
    - 51.3K bytes
    - Viewed (0)
Back to top