Search Options

Results per page
Sort
Preferred Languages
Advance

Results 101 - 110 of 488 for Reset (0.03 sec)

  1. internal/s3select/csv/record.go

    func (r *Record) Set(name string, value *sql.Value) (sql.Record, error) {
    	r.columnNames = append(r.columnNames, name)
    	r.csvRecord = append(r.csvRecord, value.CSVString())
    	return r, nil
    }
    
    // Reset data in record.
    func (r *Record) Reset() {
    	if len(r.columnNames) > 0 {
    		r.columnNames = r.columnNames[:0]
    	}
    	if len(r.csvRecord) > 0 {
    		r.csvRecord = r.csvRecord[:0]
    	}
    	for k := range r.nameIndexMap {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/util/concurrent/InterruptibleTask.java

         * the interrupting thread doesn't interrupt the _next_ thing to run on this thread.
         *
         * Note: We don't reset the interrupted bit, just wait for it to be set. If this is a thread
         * pool thread, the thread pool will reset it for us. Otherwise, the interrupted bit may have
         * been intended for something else, so don't clear it.
         */
        boolean restoreInterruptedBit = false;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 10.1K bytes
    - Viewed (0)
  3. src/bytes/buffer_test.go

    	buf := NewBuffer(make([]byte, n))
    	for i := 0; i < b.N; i++ {
    		buf.Reset()
    		for i := 0; i < n; i++ {
    			buf.WriteByte('x')
    		}
    	}
    }
    
    func BenchmarkWriteRune(b *testing.B) {
    	const n = 4 << 10
    	const r = '☺'
    	b.SetBytes(int64(n * utf8.RuneLen(r)))
    	buf := NewBuffer(make([]byte, n*utf8.UTFMax))
    	for i := 0; i < b.N; i++ {
    		buf.Reset()
    		for i := 0; i < n; i++ {
    			buf.WriteRune(r)
    		}
    	}
    }
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Tue Sep 03 20:55:15 UTC 2024
    - 18.6K bytes
    - Viewed (0)
  4. src/main/java/jcifs/util/transport/Response.java

    
        /**
         * 
         * @param exp
         *            message timeout
         */
        void setExpiration ( Long exp );
    
    
        /**
         * 
         */
        public void reset ();
    
    
        /**
         * 
         * @return an exception linked to an error
         */
        public Exception getException ();
    
    
        /**
         * @param e
         */
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 2.3K bytes
    - Viewed (0)
  5. okhttp/src/main/kotlin/okhttp3/internal/http2/StreamResetException.kt

    import java.io.IOException
    
    /** Thrown when an HTTP/2 stream is canceled without damage to the socket that carries it. */
    class StreamResetException(
      @JvmField val errorCode: ErrorCode,
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 869 bytes
    - Viewed (0)
  6. 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 true but got false")
    	}
    
    	// reset this ringbuffer and set a long slice
    	rb.Reset()
    	n, err = rb.Write([]byte(strings.Repeat("abcd", 20)))
    	if err == nil {
    		t.Fatalf("expect ErrTooManyDataToWrite but got nil")
    	}
    	if n != 64 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 15 00:11:04 UTC 2024
    - 26.8K bytes
    - Viewed (0)
  7. tests/prepared_stmt_test.go

    	}
    
    	pdb.Mux.Lock()
    	if len(pdb.Stmts) == 0 {
    		pdb.Mux.Unlock()
    		t.Fatalf("prepared stmt can not be empty")
    	}
    	pdb.Mux.Unlock()
    
    	pdb.Reset()
    	pdb.Mux.Lock()
    	defer pdb.Mux.Unlock()
    	if len(pdb.Stmts) != 0 {
    		t.Fatalf("prepared stmt should be empty")
    	}
    }
    
    func isUsingClosedConnError(err error) bool {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Thu Aug 22 11:02:05 UTC 2024
    - 8.5K bytes
    - Viewed (0)
  8. cmd/lock-rest-server.go

    		select {
    		case <-ctx.Done():
    			return
    		case <-lkTimer.C:
    			globalLockServer.expireOldLocks(lockValidityDuration)
    
    			// Reset the timer for next cycle.
    			lkTimer.Reset(lockMaintenanceInterval)
    		}
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  9. compat/maven-embedder/src/main/java/org/fusesource/jansi/Ansi.java

         * <a href="https://en.wikipedia.org/wiki/ANSI_escape_code#SGR_(Select_Graphic_Rendition)_parameters">SGR
         * (Select Graphic Rendition) parameters</a>.
         */
        public enum Attribute {
            RESET(0, "RESET"),
            INTENSITY_BOLD(1, "INTENSITY_BOLD"),
            INTENSITY_FAINT(2, "INTENSITY_FAINT"),
            ITALIC(3, "ITALIC_ON"),
            UNDERLINE(4, "UNDERLINE_ON"),
            BLINK_SLOW(5, "BLINK_SLOW"),
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 23.1K bytes
    - Viewed (0)
  10. cmd/metacache_gen_test.go

    	m := v.Msgsize()
    	if buf.Len() > m {
    		t.Log("WARNING: TestEncodeDecodemetacache Msgsize() is inaccurate")
    	}
    
    	vn := metacache{}
    	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 BenchmarkEncodemetacache(b *testing.B) {
    	v := metacache{}
    	var buf bytes.Buffer
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Apr 23 18:58:53 UTC 2021
    - 2.3K bytes
    - Viewed (0)
Back to top