- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 190 for IsFull (0.05 sec)
-
internal/ringbuffer/ring_buffer.go
copy(buf[c1:], r.buf[0:c2]) } return buf } // IsFull returns this ringbuffer is full. func (r *RingBuffer) IsFull() bool { r.mu.Lock() defer r.mu.Unlock() return r.isFull } // IsEmpty returns this ringbuffer is empty. func (r *RingBuffer) IsEmpty() bool { r.mu.Lock() defer r.mu.Unlock() return !r.isFull && r.w == r.r }
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 13.3K bytes - Viewed (0) -
internal/ringbuffer/ring_buffer_test.go
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 26.7K bytes - Viewed (0) -
internal/store/batch.go
Store Store[I] CommitTimeout time.Duration Log logger } // Add adds the item to the batch func (b *Batch[I]) Add(item I) error { b.Lock() defer b.Unlock() if b.isFull() { if b.store == nil { return ErrBatchFull } // commit batch to store if err := b.commit(); err != nil { return err } } b.items = append(b.items, item) return nil }
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 2.9K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/DenseImmutableTable.java
// True if getValue never returns null. private boolean isFull() { return size == keyToIndex().size(); } K getKey(int index) { return keyToIndex().keySet().asList().get(index); } abstract @Nullable V getValue(int keyIndex); @Override ImmutableSet<K> createKeySet() { return isFull() ? keyToIndex().keySet() : super.createKeySet(); }Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Mon Sep 22 21:07:18 UTC 2025 - 9.6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/cache/CacheBuilderSpecTest.java
assertThat(spec.initialCapacity).isNull(); assertThat(spec.maximumSize).isNull(); assertThat(spec.maximumWeight).isNull(); assertThat(spec.concurrencyLevel).isNull(); assertThat(spec.keyStrength).isNull(); assertThat(spec.valueStrength).isNull(); assertThat(spec.writeExpirationTimeUnit).isNull(); assertThat(spec.accessExpirationTimeUnit).isNull();
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Sep 30 22:03:28 UTC 2025 - 20.8K bytes - Viewed (0) -
okcurl/src/test/kotlin/okhttp3/curl/MainTest.kt
assertThat(request.body).isNull() } @Test fun userAgent() { val request = fromArgs("-A", "foo", "http://example.com").createRequest() assertThat(request.method).isEqualTo("GET") assertThat(request.url.toString()).isEqualTo("http://example.com/") assertThat(request.header("User-Agent")).isEqualTo("foo") assertThat(request.body).isNull() } @Test
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 4.3K bytes - Viewed (0) -
okhttp/src/commonTest/kotlin/okhttp3/CompressionInterceptorTest.kt
* See the License for the specific language governing permissions and * limitations under the License. */ package okhttp3 import assertk.assertThat import assertk.assertions.isEqualTo import assertk.assertions.isNull import okhttp3.HttpUrl.Companion.toHttpUrl import okhttp3.ResponseBody.Companion.asResponseBody import okhttp3.ResponseBody.Companion.toResponseBody import okio.Buffer import okio.ByteString.Companion.encodeUtf8
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Fri Aug 01 06:04:22 UTC 2025 - 3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/collect/AbstractTableTest.java
} } public void testPut() { assertThat(table.put("foo", 1, cellValue('a'))).isNull(); assertThat(table.put("bar", 1, cellValue('b'))).isNull(); assertThat(table.put("foo", 3, cellValue('c'))).isNull(); assertEquals((Character) 'a', table.put("foo", 1, cellValue('d'))); assertEquals((Character) 'd', table.get("foo", 1));
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Oct 28 16:03:47 UTC 2025 - 6K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/platform/Jdk8WithJettyBootPlatformTest.kt
* limitations under the License. */ package okhttp3.internal.platform import assertk.assertThat import assertk.assertions.isNotNull import assertk.assertions.isNull import okhttp3.internal.platform.Jdk8WithJettyBootPlatform.Companion.buildIfSupported import okhttp3.testing.PlatformRule import org.junit.jupiter.api.Assumptions.assumeFalse import org.junit.jupiter.api.Assumptions.assumeTrue
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Fri Dec 27 13:39:56 UTC 2024 - 1.5K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/CookieTest.kt
assertThat(parse(url, "a\u0000b=cd")).isNull() assertThat(parse(url, "ab=c\u0000d")).isNull() assertThat(parse(url, "a\u0001b=cd")).isNull() assertThat(parse(url, "ab=c\u0001d")).isNull() assertThat(parse(url, "a\u0009b=cd")).isNull() assertThat(parse(url, "ab=c\u0009d")).isNull() assertThat(parse(url, "a\u001fb=cd")).isNull() assertThat(parse(url, "ab=c\u001fd")).isNull()
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Sat Nov 01 12:18:11 UTC 2025 - 24.4K bytes - Viewed (0)