Search Options

Results per page
Sort
Preferred Languages
Advance

Results 441 - 450 of 908 for Base (0.03 sec)

  1. internal/dsync/dsync-client_test.go

    	errLockNotFound = errors.New("lock not found")
    )
    
    func toLockError(err error) error {
    	if err == nil {
    		return nil
    	}
    
    	switch err.Error() {
    	case errLockConflict.Error():
    		return errLockConflict
    	case errLockNotFound.Error():
    		return errLockNotFound
    	}
    	return err
    }
    
    // Call makes a REST call to the remote endpoint using the msgp codec
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Jan 20 17:36:09 UTC 2022
    - 4.4K bytes
    - Viewed (0)
  2. cmd/mrf.go

    		}
    		// Read resync meta header
    		switch binary.LittleEndian.Uint16(data[0:2]) {
    		case healMRFMetaFormat:
    		default:
    			return fmt.Errorf("heal mrf: unknown format: %d", binary.LittleEndian.Uint16(data[0:2]))
    		}
    		switch binary.LittleEndian.Uint16(data[2:4]) {
    		case healMRFMetaVersionV1:
    		default:
    			return fmt.Errorf("heal mrf: unknown version: %d", binary.LittleEndian.Uint16(data[2:4]))
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Aug 13 22:26:05 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  3. ci/official/containers/linux_arm64/builder.devtoolset/stringop_trunc.patch

    -       case 9:								      \
    -	 __u->__ui = __c * 0x01010101;					      \
    -	 __u = __extension__ ((void *) __u + 4);			      \
    -       case 5:								      \
    -	 __u->__ui = __c * 0x01010101;					      \
    -	 __u = __extension__ ((void *) __u + 4);			      \
    -       case 1:								      \
    -	 __u->__uc = (unsigned char) __c;				      \
    -	 break;								      \
    -									      \
    -       case 16:								      \
    Registered: Tue Oct 29 12:39:09 UTC 2024
    - Last Modified: Mon Sep 18 14:52:45 UTC 2023
    - 42.9K bytes
    - Viewed (0)
  4. internal/logger/target/http/http.go

    	for {
    		var (
    			ok    bool
    			entry any
    		)
    
    		if count < h.batchSize {
    			tickered := false
    			select {
    			case _ = <-ticker.C:
    				tickered = true
    			case entry, _ = <-globalBuffer:
    			case entry, ok = <-h.logCh:
    				if !ok {
    					return
    				}
    			case <-ctx.Done():
    				return
    			}
    
    			if !tickered {
    				h.totalMessages.Add(1)
    				if !isDirQueue {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Sep 11 22:20:42 UTC 2024
    - 15.6K bytes
    - Viewed (0)
  5. internal/s3select/select.go

    	// fmt.Printf("actual: %v offset: %v (%v) whence: %v\n", rsc.size, offset, rsc.offset, whence)
    	switch whence {
    	case io.SeekStart:
    		rsc.offset = offset
    	case io.SeekCurrent:
    		rsc.offset += offset
    	case io.SeekEnd:
    		rsc.offset = rsc.size + offset
    	}
    	if rsc.offset < 0 {
    		return rsc.offset, errors.New("seek to invalid negative offset")
    	}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sun Sep 22 00:33:43 UTC 2024
    - 21.2K bytes
    - Viewed (0)
  6. schema/utils.go

    			if _, isZero := rel.Field.ValueOf(ctx, value); !isZero {
    				result := reflect.Indirect(rel.Field.ReflectValueOf(ctx, value))
    				switch result.Kind() {
    				case reflect.Struct:
    					reflectResults = reflect.Append(reflectResults, result.Addr())
    				case reflect.Slice, reflect.Array:
    					for i := 0; i < result.Len(); i++ {
    						if elem := result.Index(i); elem.Kind() == reflect.Ptr {
    Registered: Sun Oct 27 09:35:08 UTC 2024
    - Last Modified: Sat Aug 19 13:35:14 UTC 2023
    - 5.5K bytes
    - Viewed (0)
  7. cmd/object-handlers_test.go

    				switch test.fault {
    				case MissingContentLength:
    					req.ContentLength = -1
    					// Setting the content length to a value greater than the max allowed size of a part.
    					// Used in test case  4.
    				case TooBigObject:
    					req.ContentLength = globalMaxObjectSize + 1
    					// Malformed signature.
    					// Used in test case  6.
    				case BadSignature:
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Sep 12 20:10:44 UTC 2024
    - 163.2K bytes
    - Viewed (0)
  8. cmd/peer-rest-client.go

    		select {
    		case listenCh <- *b:
    		default:
    			// Do not block on slow receivers.
    			b.Recycle()
    		}
    		return nil
    	})
    }
    
    // Listen - listen on peers.
    func (client *peerRESTClient) Listen(ctx context.Context, listenCh chan<- []byte, v url.Values) {
    	go func() {
    		for {
    			client.doListen(ctx, listenCh, v)
    			select {
    			case <-ctx.Done():
    				return
    			default:
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 26.1K bytes
    - Viewed (0)
  9. statement.go

    			}
    		case clause.Interface:
    			c := clause.Clause{Name: v.Name()}
    			v.MergeClause(&c)
    			c.Build(stmt)
    		case clause.Expression:
    			v.Build(stmt)
    		case driver.Valuer:
    			stmt.Vars = append(stmt.Vars, v)
    			stmt.DB.Dialector.BindVarTo(writer, stmt, v)
    		case []byte:
    			stmt.Vars = append(stmt.Vars, v)
    			stmt.DB.Dialector.BindVarTo(writer, stmt, v)
    		case []interface{}:
    			if len(v) > 0 {
    Registered: Sun Oct 27 09:35:08 UTC 2024
    - Last Modified: Mon Jun 24 09:42:59 UTC 2024
    - 19.9K bytes
    - Viewed (0)
  10. internal/s3select/sql/timestampfuncs_test.go

    	for i, tc := range cases {
    		tval, err := parseSQLTimestamp(tc.s)
    		if err != nil {
    			t.Errorf("Case %d: Unexpected error: %v", i+1, err)
    			continue
    		}
    		if !tval.Equal(tc.t) {
    			t.Errorf("Case %d: Expected %v got %v", i+1, tc.t, tval)
    			continue
    		}
    
    		tstr := FormatSQLTimestamp(tc.t)
    		if tstr != tc.s {
    			t.Errorf("Case %d: Expected %s got %s", i+1, tc.s, tstr)
    			continue
    		}
    	}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 2.2K bytes
    - Viewed (0)
Back to top