- Sort Score
- Result 10 results
- Languages All
Results 271 - 280 of 302 for Ordering (0.08 sec)
-
src/archive/tar/writer.go
// Write PAX records to the output. isGlobal := hdr.Typeflag == TypeXGlobalHeader if len(paxHdrs) > 0 || isGlobal { // Write each record to a buffer. var buf strings.Builder // Sort keys for deterministic ordering. for _, k := range slices.Sorted(maps.Keys(paxHdrs)) { rec, err := formatPAXRecord(k, paxHdrs[k]) if err != nil { return err } buf.WriteString(rec) }
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Wed Oct 02 14:22:59 UTC 2024 - 19.6K bytes - Viewed (0) -
guava/src/com/google/common/collect/ImmutableBiMap.java
} sort( (Entry<K, V>[]) entries, // Entries up to size are not null 0, size, Ordering.from(valueComparator).onResultOf(Maps.valueFunction())); } entriesUsed = true; return RegularImmutableBiMap.fromEntryArray(size, entries); } } /**
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Oct 30 16:15:19 UTC 2024 - 22.6K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbTransportImpl.java
CommonServerMessageBlock smb = (CommonServerMessageBlock) request; byte[] buffer = this.getContext().getBufferCache().getBuffer(); try { // synchronize around encode and write so that the ordering for SMB1 signing can be maintained synchronized ( this.outLock ) { int n = smb.encode(buffer, 4); Encdec.enc_uint32be(n & 0xFFFF, buffer, 0); /* 4 byte session message header */
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Wed Jan 18 23:47:00 UTC 2023 - 67K bytes - Viewed (0) -
internal/bucket/lifecycle/lifecycle_test.go
} if !tc.hasRules && len(rules) > 0 { t.Fatalf("%d: Expected no rules to match but got matches %v", i+1, rules) } }) } } // TestDeleteAllVersions tests ordering among events, especially ones which // expire all versions like ExpiredObjectDeleteAllVersions and // DelMarkerExpiration func TestDeleteAllVersions(t *testing.T) { // ExpiredObjectDeleteAllVersions
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu May 23 01:12:48 UTC 2024 - 55.1K bytes - Viewed (0) -
common-protos/k8s.io/apimachinery/pkg/apis/meta/v1/generated.proto
// component responsible for a finalizer later in the list, resulting in a deadlock. // Without enforced ordering finalizers are free to order amongst themselves and // are not vulnerable to ordering changes in the list. // +optional // +patchStrategy=merge repeated string finalizers = 14; // ManagedFields maps workflow-id and version to the set of fields
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Mon Mar 11 18:43:24 UTC 2024 - 53.3K bytes - Viewed (0) -
doc/go_mem.html
</p> <p> If the effects of a goroutine must be observed by another goroutine, use a synchronization mechanism such as a lock or channel communication to establish a relative ordering. </p> <h3 id="chan">Channel communication</h3> <p> Channel communication is the main method of synchronization between goroutines. Each send on a particular channel
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Mon Mar 04 15:54:42 UTC 2024 - 26.6K bytes - Viewed (0) -
cmd/erasure-sets.go
return } if currentDisk := s.erasureDisks[setIndex][diskIndex]; currentDisk != nil { if !reflect.DeepEqual(currentDisk.Endpoint(), disk.Endpoint()) { err = fmt.Errorf("Detected unexpected drive ordering refusing to use the drive: expecting %s, found %s, refusing to use the drive", currentDisk.Endpoint(), disk.Endpoint()) printEndpointError(endpoint, err, false) disk.Close() s.erasureDisksMu.Unlock()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 27 10:41:37 UTC 2024 - 37K bytes - Viewed (1) -
cmd/xl-storage.go
if err != nil { return s, err } diskID := format.Erasure.This if m != ep.SetIdx || n != ep.DiskIdx { storageLogOnceIf(context.Background(), fmt.Errorf("unexpected drive ordering on pool: %s: found drive at (set=%s, drive=%s), expected at (set=%s, drive=%s): %s(%s): %w", humanize.Ordinal(ep.PoolIdx+1), humanize.Ordinal(m+1), humanize.Ordinal(n+1), humanize.Ordinal(ep.SetIdx+1), humanize.Ordinal(ep.DiskIdx+1),
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Oct 26 09:58:27 UTC 2024 - 91.3K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Futures.java
* computation is {@linkplain java.util.concurrent.Future#isDone() complete} or, if the * computation is already complete, immediately. * * <p>The callback is run on {@code executor}. There is no guaranteed ordering of execution of * callbacks, but any callback added through this method is guaranteed to be called once the * computation is complete. *
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 25 13:13:32 UTC 2024 - 64.7K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/ImmutableMap.java
V value = (V) requireNonNull(alternatingKeysAndValues[2 * i + 1]); entries[i] = new AbstractMap.SimpleImmutableEntry<Object, V>(key, value); } Arrays.sort( entries, 0, size, Ordering.from(valueComparator).onResultOf(Maps.<V>valueFunction())); for (int i = 0; i < size; i++) { alternatingKeysAndValues[2 * i] = entries[i].getKey();
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Oct 30 16:15:19 UTC 2024 - 41.5K bytes - Viewed (0)