Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 190 for IsFull (0.05 sec)

  1. 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)
  2. internal/ringbuffer/ring_buffer_test.go

    	}
    	// check empty or full
    	if rb.IsEmpty() {
    		t.Fatalf("expect IsEmpty is false but got true")
    	}
    	if rb.IsFull() {
    		t.Fatalf("expect IsFull is false but got true")
    	}
    
    	// write to, isFull
    	err = rb.WriteByte('b')
    	if err != nil {
    		t.Fatalf("WriteByte failed: %v", err)
    	}
    	if rb.Length() != 2 {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 26.7K bytes
    - Viewed (0)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top