- Sort Score
- Result 10 results
- Languages All
Results 1071 - 1080 of 1,182 for happened (0.07 sec)
-
internal/event/config_test.go
} for i, testCase := range testCases { testCase.config.SetRegion(testCase.region) result := []ARN{} for _, queue := range testCase.config.QueueList { result = append(result, queue.ARN) } if !reflect.DeepEqual(result, testCase.expectedResult) { t.Fatalf("test %v: data: expected: %v, got: %v", i+1, testCase.expectedResult, result) } } }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Dec 05 10:16:33 UTC 2023 - 29K bytes - Viewed (0) -
internal/logger/target/http/http.go
fmt.Errorf("unable to encode webhook log entry, err '%w' entry: %v\n", err, entry), h.Name(), ) h.failedMessages.Add(1) continue } } else { entries = append(entries, entry) } count++ } if len(h.logCh) > 0 || len(globalBuffer) > 0 || count == 0 { // there is something in the log queue // process it first, even if we tickered
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Sep 11 22:20:42 UTC 2024 - 15.6K bytes - Viewed (0) -
internal/ringbuffer/ring_buffer.go
// Callers should always process the n > 0 bytes returned before considering the error err. // Doing so correctly handles I/O errors that happen after reading some bytes and also both of the allowed EOF behaviors. func (r *RingBuffer) Read(p []byte) (n int, err error) { if len(p) == 0 { return 0, r.readErr(false) } r.mu.Lock() defer r.mu.Unlock()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed May 15 00:11:04 UTC 2024 - 13.3K bytes - Viewed (0) -
internal/ringbuffer/ring_buffer_test.go
} if n != 16 { t.Fatalf("expect write 16 bytes but got %d", n) } if rb.Free() != 0 { t.Fatalf("expect free 0 bytes but got %d. r.w=%d, r.r=%d", rb.Free(), rb.w, rb.r) } if !bytes.Equal(append(buf, rb.Bytes(nil)...), []byte(strings.Repeat("abcd", 16)+strings.Repeat("1234", 4))) { t.Fatalf("expect 16 abcd and 4 1234 but got %s. r.w=%d, r.r=%d", rb.Bytes(nil), rb.w, rb.r) } }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed May 15 00:11:04 UTC 2024 - 26.8K bytes - Viewed (0) -
cmd/data-usage-cache.go
add = func(path dataUsageHash) { e, ok := d.Cache[path.Key()] if !ok { return } if len(e.Children) == 0 { return } sz := d.sizeRecursive(path.Key()) leaves = append(leaves, struct { objects uint64 path dataUsageHash }{objects: sz.Objects, path: path}) for ch := range e.Children { add(dataUsageHash(ch)) } } // Add path recursively.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Oct 22 15:30:50 UTC 2024 - 34.7K bytes - Viewed (0) -
guava/src/com/google/common/collect/CompactHashSet.java
return delegate.add(object); } int[] entries = requireEntries(); @Nullable Object[] elements = requireElements(); int newEntryIndex = this.size; // current size, and pointer to the entry to be appended int newSize = newEntryIndex + 1; int hash = smearedHash(object); int mask = hashTableMask(); int tableIndex = hash & mask; int next = CompactHashing.tableGet(requireTable(), tableIndex);
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 20:24:49 UTC 2024 - 24.9K bytes - Viewed (0) -
docs/en/docs/advanced/security/oauth2-scopes.md
And if you select the scope `me` but not the scope `items`, you will be able to access `/users/me/` but not `/users/me/items/`. That's what would happen to a third party application that tried to access one of these *path operations* with a token provided by a user, depending on how many permissions the user gave the application. ## About third party integrations
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Tue Oct 29 11:02:16 UTC 2024 - 13.1K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/cache/LocalCacheTest.java
boolean done = doneSignal.await(1, SECONDS); if (!done) { StringBuilder builder = new StringBuilder(); for (StackTraceElement trace : thread.getStackTrace()) { builder.append("\tat ").append(trace).append('\n'); } fail(builder.toString()); } } /** * Returns an iterable containing all combinations of maximumSize, expireAfterAccess/Write,
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 19:07:49 UTC 2024 - 110.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/cache/LocalCacheTest.java
boolean done = doneSignal.await(1, SECONDS); if (!done) { StringBuilder builder = new StringBuilder(); for (StackTraceElement trace : thread.getStackTrace()) { builder.append("\tat ").append(trace).append('\n'); } fail(builder.toString()); } } /** * Returns an iterable containing all combinations of maximumSize, expireAfterAccess/Write,
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 19:07:49 UTC 2024 - 112.3K bytes - Viewed (0) -
cmd/xl-storage_test.go
} testCases := []struct { fileName string expectedErr error }{ {"myobject", nil}, {"path/to/my/object", nil}, // TestXLStorage to append to previously created file. {"myobject", nil}, // TestXLStorage to use same path of previously created file. {"path/to/my/testobject", nil}, // TestXLStorage to use object is a directory now.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Aug 14 17:11:51 UTC 2024 - 66.7K bytes - Viewed (0)