Search Options

Results per page
Sort
Preferred Languages
Advance

Results 251 - 260 of 329 for recorded (0.08 sec)

  1. apache-maven/src/main/appended-resources/licenses/EPL-1.0.txt

    law, it shall not affect the validity or enforceability of the remainder of
    the terms of this Agreement, and without further action by the parties hereto,
    such provision shall be reformed to the minimum extent necessary to make such
    provision valid and enforceable.
    
    If Recipient institutes patent litigation against any entity (including a
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Mon Sep 17 05:50:12 UTC 2018
    - 11.1K bytes
    - Viewed (0)
  2. cmd/bucket-replication-metrics.go

    func newRateMeasurement(initTime time.Time) *rateMeasurement {
    	return &rateMeasurement{
    		startTime: initTime,
    	}
    }
    
    // incrementBytes add bytes reported for a bucket/target.
    func (m *rateMeasurement) incrementBytes(bytes uint64) {
    	atomic.AddUint64(&m.bytesSinceLastWindow, bytes)
    }
    
    // updateExponentialMovingAverage processes the measurements captured so far.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 14.2K bytes
    - Viewed (0)
  3. cmd/bucket-lifecycle.go

    		}
    	}
    }
    
    type expiryTask struct {
    	objInfo ObjectInfo
    	event   lifecycle.Event
    	src     lcEventSrc
    }
    
    // expiryStats records metrics related to ILM expiry activities
    type expiryStats struct {
    	missedExpiryTasks      atomic.Int64
    	missedFreeVersTasks    atomic.Int64
    	missedTierJournalTasks atomic.Int64
    	workers                atomic.Int32
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 23 15:35:37 UTC 2024
    - 33.7K bytes
    - Viewed (0)
  4. cmd/metacache-stream.go

    		if w.reuseBlocks || o.reusable {
    			metaDataPoolPut(o.metadata)
    		}
    	}
    
    	return nil
    }
    
    // stream entries to the output.
    // The returned channel should be closed when done.
    // Any error is reported when closing the metacacheWriter.
    func (w *metacacheWriter) stream() (chan<- metaCacheEntry, error) {
    	if w.creator != nil {
    		err := w.creator()
    		w.creator = nil
    		if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Apr 04 12:04:40 UTC 2024
    - 19.5K bytes
    - Viewed (0)
  5. internal/event/target/amqp.go

    	if err != nil {
    		return err
    	}
    	key := eventData.S3.Bucket.Name + "/" + objectName
    
    	data, err := json.Marshal(event.Log{EventName: eventData.EventName, Key: key, Records: []event.Event{eventData}})
    	if err != nil {
    		return err
    	}
    
    	headers := make(amqp091.Table)
    	// Add more information here as required, but be aware to not overload headers
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 10K bytes
    - Viewed (0)
  6. okhttp/src/main/kotlin/okhttp3/HttpUrl.kt

     *
     * [idna]: http://www.unicode.org/reports/tr46/#ToASCII
     */
    class HttpUrl private constructor(
      /** Either "http" or "https". */
      @get:JvmName("scheme") val scheme: String,
      /**
       * The decoded username, or an empty string if none is present.
       *
       * | URL                              | `username()` |
       * | :------------------------------- | :----------- |
       * | `http://host/`                   | `""`         |
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Tue Jan 09 12:33:05 UTC 2024
    - 63.5K bytes
    - Viewed (0)
  7. src/main/java/jcifs/internal/smb2/ServerMessageBlock2.java

            return decode(buffer, bufferIndex, false);
        }
    
    
        /**
         * @param buffer
         * @param bufferIndex
         * @param compound
         * @return decoded length
         * @throws SMBProtocolDecodingException
         */
        public int decode ( byte[] buffer, int bufferIndex, boolean compound ) throws SMBProtocolDecodingException {
            int start = this.headerStart = bufferIndex;
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Sep 30 10:47:31 UTC 2018
    - 19.9K bytes
    - Viewed (0)
  8. cmd/tier.go

    	config.Lock()
    	defer config.Unlock()
    
    	switch err {
    	case nil:
    		break
    	case errConfigNotFound: // nothing to reload
    		// To maintain the invariance that lastRefreshedAt records the
    		// timestamp of last successful refresh
    		config.lastRefreshedAt = UTCNow()
    		return nil
    	default:
    		return err
    	}
    
    	// Reset drivercache built using current config
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 20:44:05 UTC 2024
    - 15.7K bytes
    - Viewed (0)
  9. LICENSE

    Copyright (c) 2014, the respective contributors
    All rights reserved.
    
    Caffe uses a shared copyright model: each contributor holds copyright over
    their contributions to Caffe. The project versioning records all such
    contribution and copyright details. If a contributor wants to further mark
    their specific copyright on a particular contribution, they should indicate
    their copyright solely in the commit message of the change when it is
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Mon Nov 29 17:31:56 UTC 2021
    - 13.3K bytes
    - Viewed (0)
  10. android/guava-tests/test/com/google/common/graph/AbstractNetworkTest.java

         * including in MapRetrievalCache, so I'm not sure why this one is different. I did at least
         * confirm that my change to MapIteratorCache fixes the TSAN error in the (larger) test it was
         * originally reported in.
         */
        for (Future<?> future : futures.build()) {
          future.get();
        }
        executor.shutdown();
      }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Jan 22 17:29:38 UTC 2024
    - 32.7K bytes
    - Viewed (0)
Back to top