- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 201 for back (0.01 sec)
-
src/archive/zip/writer_test.go
// write a zip file buf := new(bytes.Buffer) w := NewWriter(buf) for _, wt := range writeTests { testCreate(t, w, &wt) } if err := w.Close(); err != nil { t.Fatal(err) } // read it back r, err := NewReader(bytes.NewReader(buf.Bytes()), int64(buf.Len())) if err != nil { t.Fatal(err) } for i, wt := range writeTests { testReadFile(t, r.File[i], &wt) } }
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Mon Sep 23 14:32:33 UTC 2024 - 14.4K bytes - Viewed (0) -
internal/s3select/jstream/scanner.go
} } s.pos++ return s.buf[s.ipos] } // back undoes a previous call to next(), moving backward one byte in the internal buffer. // as we only guarantee a lookback buffer size of one, any subsequent calls to back() // before calling next() may panic func (s *scanner) back() { if s.ipos <= 0 { panic("back buffer exhausted") } s.ipos-- s.pos--
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 23 19:35:41 UTC 2024 - 2.5K bytes - Viewed (0) -
internal/bpool/bpool.go
if cap(b) != bp.wcap { // someone tried to put back buffer which is not part of this buffer pool // we simply don't put this back into pool, a modified buffer provided // by this package is no more usable, callers make sure to not modify // the capacity of the buffer. return } select { case bp.c <- b[:bp.w]: // buffer went back into pool default: // buffer didn't go back into pool, just discard } }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 29 01:40:52 UTC 2024 - 3K bytes - Viewed (0) -
compat/maven-compat/src/test/java/org/apache/maven/project/artifact/MavenMetadataSourceTest.java
assertEquals( Artifact.SCOPE_COMPILE, artifact.getScope(), "dependency artifact has wrong scope." ); //check for back-propagation of default scope. assertEquals( Artifact.SCOPE_COMPILE, dep.getScope(), "default scope NOT back-propagated to dependency." ); */ } @Test @Disabled void testShouldUseInjectedTestScopeFromDependencyManagement() throws Exception {
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 5.7K bytes - Viewed (0) -
guava/src/com/google/common/hash/LittleEndianByteArray.java
| ((source[offset + 3] & 0xFF) << 24); } /** * Indicates that the loading of Unsafe was successful and the load and store operations will be * very efficient. May be useful for calling code to fall back on an alternative implementation * that is slower than Unsafe.get/store but faster than the pure-Java mask-and-shift. */ static boolean usingUnsafe() { return (byteArray instanceof UnsafeByteArray); }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Oct 19 00:26:48 UTC 2024 - 9.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java
RateLimiter limiter = RateLimiter.create(2.0, 4000, MILLISECONDS, 3.0, stopwatch); for (int i = 0; i < 8; i++) { limiter.acquire(); // // #1 } stopwatch.sleepMillis(4500); // #2: back to cold state (warmup period + repay last acquire) for (int i = 0; i < 3; i++) { // only three steps, we're somewhere in the warmup period limiter.acquire(); // #3 }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Oct 21 14:28:19 UTC 2024 - 21.8K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java
RateLimiter limiter = RateLimiter.create(2.0, 4000, MILLISECONDS, 3.0, stopwatch); for (int i = 0; i < 8; i++) { limiter.acquire(); // // #1 } stopwatch.sleepMillis(4500); // #2: back to cold state (warmup period + repay last acquire) for (int i = 0; i < 3; i++) { // only three steps, we're somewhere in the warmup period limiter.acquire(); // #3 }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Oct 21 14:28:19 UTC 2024 - 21.8K bytes - Viewed (0) -
tests/prepared_stmt_test.go
) func TestPreparedStmt(t *testing.T) { tx := DB.Session(&gorm.Session{PrepareStmt: true}) if _, ok := tx.ConnPool.(*gorm.PreparedStmtDB); !ok { t.Fatalf("should assign PreparedStatement Manager back to database when using PrepareStmt mode") } ctx, cancel := context.WithTimeout(context.Background(), 500*time.Millisecond) defer cancel() txCtx := tx.WithContext(ctx) user := *GetUser("prepared_stmt", Config{})
Registered: Sun Nov 03 09:35:10 UTC 2024 - Last Modified: Thu Aug 22 11:02:05 UTC 2024 - 8.5K bytes - Viewed (0) -
istioctl/pkg/tag/util.go
// used rather than just deleting the webhook since we want to keep it around after changing the default so user can later // switch back to it. This is a hack but it is meant to cover a corner case where a user wants to migrate from a non-revisioned // old version and then later decides to switch back to the old revision again. func DeactivateIstioInjectionWebhook(ctx context.Context, client kubernetes.Interface) error {
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Wed Oct 09 16:05:45 UTC 2024 - 5.5K bytes - Viewed (0) -
compat/maven-model-builder/src/main/java/org/apache/maven/model/building/ModelProblem.java
* information that is available at the point the problem occurs and as such merely serves as best effort * to provide information to the user to track the problem back to its origin. * * @return The hint about the source of the problem or an empty string if unknown, never {@code null}. */ String getSource(); /**
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 4K bytes - Viewed (0)