Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 111 for isFull (0.07 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 15 00:11:04 UTC 2024
    - 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 15 00:11:04 UTC 2024
    - 26.8K 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 Nov 03 19:28:11 UTC 2024
    - 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);
        }
    
        @CheckForNull
        abstract V getValue(int keyIndex);
    
        @Override
        ImmutableSet<K> createKeySet() {
          return isFull() ? keyToIndex().keySet() : super.createKeySet();
        }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:05:46 UTC 2024
    - 10.1K bytes
    - Viewed (0)
  5. 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);
        }
    
        @CheckForNull
        abstract V getValue(int keyIndex);
    
        @Override
        ImmutableSet<K> createKeySet() {
          return isFull() ? keyToIndex().keySet() : super.createKeySet();
        }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:05:46 UTC 2024
    - 10.1K bytes
    - Viewed (0)
  6. okhttp/src/test/java/okhttp3/RequestTest.kt

            .build()
        assertThat(request.tag()).isNull()
        assertThat(request.tag(Any::class.java)).isNull()
        assertThat(request.tag(UUID::class.java)).isNull()
        assertThat(request.tag(String::class.java)).isNull()
    
        // Alternate access APIs also work.
        assertThat(request.tag<String>()).isNull()
        assertThat(request.tag(String::class)).isNull()
      }
    
      @Test
      fun defaultTag() {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 16.4K bytes
    - Viewed (0)
  7. okhttp/src/test/java/okhttp3/MultipartReaderTest.kt

            boundary = "simple boundary",
            source = Buffer().writeUtf8(multipart),
          )
    
        assertThat(parts.nextPart()).isNotNull()
        assertThat(parts.nextPart()).isNull()
        assertThat(parts.nextPart()).isNull()
      }
    
      @Test fun `empty source`() {
        val parts =
          MultipartReader(
            boundary = "simple boundary",
            source = Buffer(),
          )
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 13.8K bytes
    - Viewed (0)
  8. okhttp/src/test/java/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 Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 24.3K bytes
    - Viewed (0)
  9. internal/bucket/lifecycle/noncurrentversion.go

    		NoncurrentDays:          val.NoncurrentDays,
    		NewerNoncurrentVersions: val.NewerNoncurrentVersions,
    	}
    	n.set = true
    	return nil
    }
    
    // IsNull returns if both NoncurrentDays and NoncurrentVersions are empty
    func (n NoncurrentVersionExpiration) IsNull() bool {
    	return n.IsDaysNull() && n.NewerNoncurrentVersions == 0
    }
    
    // IsDaysNull returns true if days field is null
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Dec 14 17:41:44 UTC 2021
    - 5.3K bytes
    - Viewed (0)
  10. okhttp/src/test/java/okhttp3/RequestCommonTest.kt

            .url("https://square.com")
            .build()
        assertThat(request.tag<Any>()).isNull()
        assertThat(request.tag(Any::class)).isNull()
        assertThat(request.tag(String::class)).isNull()
    
        // Alternate access APIs also work.
        assertThat(request.tag<String>()).isNull()
        assertThat(request.tag(String::class)).isNull()
      }
    
      @Test
      fun defaultTag() {
        val tag = "1234"
        val request =
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 10.7K bytes
    - Viewed (0)
Back to top