Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 36 for increment (0.05 seconds)

  1. cmd/namespace-lock_test.go

    		}()
    		runtime.Gosched()
    
    		// unlock the manual lock
    		nsLk.lockMapMutex.Unlock()
    
    		// To trigger the race:
    		// 1) lk3 or lk4 need to advance and increment the ref on the existing resource,
    		//    successfully acquiring the lock.
    		// 2) lk2 then needs to advance and remove the resource from lockMap.
    		// 3) lk3 or lk4 (whichever didn't execute in step 1) then executes and creates
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 3K bytes
    - Click Count (0)
  2. internal/store/queuestore.go

    	} else {
    		err = os.WriteFile(path, buf.Bytes(), os.FileMode(0o770))
    	}
    
    	buf.Reset()
    	if err != nil {
    		return err
    	}
    
    	// Increment the item count.
    	store.entries[key.String()] = time.Now().UnixNano()
    
    	return err
    }
    
    // write - writes an item to the directory.
    func (store *QueueStore[I]) write(key Key, item I) error {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 7.8K bytes
    - Click Count (0)
  3. tests/multi_primary_keys_test.go

    }
    
    func TestManyToManyWithMultiPrimaryKeys(t *testing.T) {
    	if name := DB.Dialector.Name(); name == "sqlite" || name == "sqlserver" {
    		t.Skip("skip sqlite, sqlserver due to it doesn't support multiple primary keys with auto increment")
    	}
    
    	if name := DB.Dialector.Name(); name == "postgres" || name == "mysql" || name == "gaussdb" {
    		stmt := gorm.Statement{DB: DB}
    		stmt.Parse(&Blog{})
    		stmt.Schema.LookUpField("ID").Unique = true
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Mon Jul 21 02:46:58 GMT 2025
    - 13.1K bytes
    - Click Count (0)
  4. src/cmd/asm/internal/asm/testdata/arm64error.s

    	VST1.P	[V4.S4,V5.S4], 48(R1)                            // ERROR "invalid post-increment offset"
    	VST1.P	[V4.S4], 8(R1)                                   // ERROR "invalid post-increment offset"
    	VLD1.P	32(R1), [V8.S4, V9.S4, V10.S4]                   // ERROR "invalid post-increment offset"
    	VLD1.P	48(R1), [V7.S4, V8.S4, V9.S4, V10.S4]            // ERROR "invalid post-increment offset"
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Tue Oct 14 19:00:00 GMT 2025
    - 38.4K bytes
    - Click Count (0)
  5. callbacks/create.go

    		if !insertOk {
    			if !supportReturning {
    				db.AddError(err)
    			}
    			return
    		}
    
    		// append @id column with value for auto-increment primary key
    		// the @id value is correct, when: 1. without setting auto-increment primary key, 2. database AutoIncrementIncrement = 1
    		switch values := db.Statement.Dest.(type) {
    		case map[string]interface{}:
    			values[pkFieldName] = insertID
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Tue Jul 29 11:06:13 GMT 2025
    - 13K bytes
    - Click Count (0)
  6. cmd/os-instrumented.go

    	startTime := time.Now()
    	return func() {
    		duration := time.Since(startTime)
    
    		atomic.AddUint64(&o.operations[s], 1)
    		o.latency[s].add(duration)
    	}
    }
    
    // incTime will increment time on metric s with a specific duration.
    func (o *osMetrics) incTime(s osMetric, d time.Duration) {
    	atomic.AddUint64(&o.operations[s], 1)
    	o.latency[s].add(d)
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 6.2K bytes
    - Click Count (0)
  7. tests/gaussdb_test.go

        log_id bigint NOT NULL
    );
    
    ALTER TABLE public.log_usage ALTER COLUMN log_id ADD GENERATED BY DEFAULT AS IDENTITY (
        SEQUENCE NAME public.log_usage_log_id_seq
        START WITH 1
        INCREMENT BY 1
        NO MINVALUE
        NO MAXVALUE
        CACHE 1
    );
    	`).Error; err != nil {
    		t.Fatalf("failed to create table, got error %v", err)
    	}
    
    	columns, err := DB.Migrator().ColumnTypes("log_usage")
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Mon Jul 21 02:46:58 GMT 2025
    - 6.6K bytes
    - Click Count (0)
  8. cmd/data-scanner-metric.go

    		duration := time.Since(startTime)
    
    		atomic.AddUint64(&p.operations[s], 1)
    		if s < scannerMetricLastRealtime {
    			p.latency[s].addSize(duration, int64(sz))
    		}
    	}
    }
    
    // incTime will increment time on metric s with a specific duration.
    // Use for s < scannerMetricLastRealtime
    func (p *scannerMetrics) incTime(s scannerMetric, d time.Duration) {
    	atomic.AddUint64(&p.operations[s], 1)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Oct 01 06:06:01 GMT 2025
    - 9.4K bytes
    - Click Count (0)
  9. api/maven-api-core/src/main/java/org/apache/maven/api/services/ProblemCollector.java

                    // drop without counting towards preserved problems
                    return false;
                }
                int currentCount = totalCount.incrementAndGet();
                getCounter(problem.getSeverity()).increment();
                if (currentCount <= maxCountLimit || dropProblemWithLowerSeverity(problem.getSeverity())) {
                    getProblems(problem.getSeverity()).add(problem);
                    return true;
                }
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Fri Jul 18 17:30:19 GMT 2025
    - 11.4K bytes
    - Click Count (0)
  10. cmd/site-replication-utils.go

    			st.Status = s.Status
    			return nil
    		}
    		sm.resyncStatus[s.ResyncID] = st
    		return saveSiteResyncMetadata(GlobalContext, st, newObjectLayerFn())
    	}
    	return nil
    }
    
    // increment SyncedBuckets count
    func (sm *siteResyncMetrics) incBucket(o resyncOpts, bktStatus ResyncStatusType) {
    	if !globalSiteReplicationSys.isEnabled() {
    		return
    	}
    	sm.Lock()
    	defer sm.Unlock()
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 8.8K bytes
    - Click Count (0)
Back to Top