Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 488 for Reset (0.1 sec)

  1. internal/grid/msg_gen_test.go

    	if buf.Len() > m {
    		t.Log("WARNING: TestEncodeDecodeconnectReq Msgsize() is inaccurate")
    	}
    
    	vn := connectReq{}
    	err := msgp.Decode(&buf, &vn)
    	if err != nil {
    		t.Error(err)
    	}
    
    	buf.Reset()
    	msgp.Encode(&buf, &v)
    	err = msgp.NewReader(&buf).Skip()
    	if err != nil {
    		t.Error(err)
    	}
    }
    
    func BenchmarkEncodeconnectReq(b *testing.B) {
    	v := connectReq{}
    	var buf bytes.Buffer
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jul 25 21:07:21 UTC 2024
    - 12.9K bytes
    - Viewed (0)
  2. cmd/batch-replicate_gen_test.go

    		t.Log("WARNING: TestEncodeDecodeBatchJobReplicateCredentials Msgsize() is inaccurate")
    	}
    
    	vn := BatchJobReplicateCredentials{}
    	err := msgp.Decode(&buf, &vn)
    	if err != nil {
    		t.Error(err)
    	}
    
    	buf.Reset()
    	msgp.Encode(&buf, &v)
    	err = msgp.NewReader(&buf).Skip()
    	if err != nil {
    		t.Error(err)
    	}
    }
    
    func BenchmarkEncodeBatchJobReplicateCredentials(b *testing.B) {
    	v := BatchJobReplicateCredentials{}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 29 18:27:23 UTC 2023
    - 14.2K bytes
    - Viewed (0)
  3. tensorflow/c/eager/gradients_test.cc

        ASSERT_EQ(errors::OK, s.code()) << s.message();
        ctx.reset(ctx_raw);
      }
    
      AbstractTensorHandlePtr t;
      {
        AbstractTensorHandle* x_raw = nullptr;
        absl::Status s =
            TestScalarTensorHandle<float, TF_FLOAT>(ctx.get(), 1.0f, &x_raw);
        ASSERT_EQ(errors::OK, s.code()) << s.message();
        t.reset(x_raw);
      }
    
      AbstractOperationPtr check_numerics_op(ctx->CreateOperation());
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Sat Oct 12 05:11:17 UTC 2024
    - 7K bytes
    - Viewed (0)
  4. src/test/java/org/codelibs/opensearch/extension/analysis/ReloadableKuromojiTokenizerFactory.java

            @Override
            public int read(final char[] cbuf, final int off, final int len) {
                throw new IllegalStateException("TokenStream contract violation: reset()/close() call missing, "
                        + "reset() called multiple times, or subclass does not call super.reset(). "
                        + "Please see Javadocs of TokenStream class for more information about the correct consuming workflow.");
            }
    
            @Override
    Registered: Fri Nov 08 09:08:12 UTC 2024
    - Last Modified: Thu Feb 22 01:36:54 UTC 2024
    - 9.5K bytes
    - Viewed (0)
  5. cmd/url_test.go

    	if err != nil {
    		b.Fatal(err)
    	}
    
    	// benchmark utility which helps obtain number of allocations and bytes allocated per ops.
    	b.ReportAllocs()
    	// the actual benchmark for PutObject starts here. Reset the benchmark timer.
    	b.ResetTimer()
    
    	if err := req.ParseForm(); err != nil {
    		b.Fatal(err)
    	}
    
    	b.RunParallel(func(pb *testing.PB) {
    		for pb.Next() {
    			req.Form.Get("uploadId")
    		}
    	})
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Nov 16 17:28:29 UTC 2021
    - 2K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/cache/LongAdder.java

       * method is intrinsically racy, it should only be used when it is known that no threads are
       * concurrently updating.
       */
      public void reset() {
        internalReset(0L);
      }
    
      /**
       * Equivalent in effect to {@link #sum} followed by {@link #reset}. This method may apply for
       * example during quiescent points between multithreaded computations. If there are updates
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jun 15 18:00:07 UTC 2021
    - 5.5K bytes
    - Viewed (0)
  7. istioctl/pkg/ztunnelconfig/ztunnelconfig.go

    		levelToString[InfoLevel],
    		levelToString[WarningLevel],
    		levelToString[ErrorLevel],
    		levelToString[CriticalLevel],
    		levelToString[OffLevel])
    	common.attach(cmd)
    	cmd.PersistentFlags().BoolVarP(&reset, "reset", "r", reset, "Reset levels to default value (warning).")
    	cmd.PersistentFlags().StringVar(&loggerLevelString, "level", loggerLevelString,
    		fmt.Sprintf("Comma-separated minimum per-logger level of messages to output, in the form of"+
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 19:17:45 UTC 2024
    - 22.2K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/io/FileBackedOutputStreamTest.java

          }
        }
        out.close();
    
        // Check that source returns the right data
        assertTrue(Arrays.equals(data, source.read()));
    
        // Make sure that reset deleted the file
        out.reset();
        if (file != null) {
          assertFalse(file.exists());
        }
      }
    
    
      public void testThreshold_resetOnFinalize() throws Exception {
        testThreshold(0, 100, true, true);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  9. cmd/metacache-stream.go

    	if w == nil || w.closer == nil {
    		return nil
    	}
    	w.streamWg.Wait()
    	err := w.closer()
    	w.closer = nil
    	return err
    }
    
    // Reset and start writing to new writer.
    // Close must have been called before this.
    func (w *metacacheWriter) Reset(out io.Writer) {
    	w.streamErr = nil
    	w.creator = func() error {
    		s2w := s2.NewWriter(out, s2.WriterBlockSize(w.blockSize), s2.WriterConcurrency(2))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Apr 04 12:04:40 UTC 2024
    - 19.5K bytes
    - Viewed (0)
  10. internal/s3select/simdj/record.go

    		b, err := iter.MarshalJSON()
    		return sql.FromBytes(b), err
    	}
    	return nil, fmt.Errorf("iterToValue: unknown JSON type: %s", iter.Type().String())
    }
    
    // Reset the record.
    func (r *Record) Reset() {
    	r.object = simdjson.Object{}
    }
    
    // Clone the record and if possible use the destination provided.
    func (r *Record) Clone(dst sql.Record) sql.Record {
    	other, ok := dst.(*Record)
    	if !ok {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 5.4K bytes
    - Viewed (0)
Back to top