Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 15 for AddUint64 (0.07 sec)

  1. cmd/bucket-replication-metrics.go

    	atomic.AddUint64(&p.GetTotal, p2.GetTotal)
    	atomic.AddUint64(&p.HeadTotal, p2.HeadTotal)
    	atomic.AddUint64(&p.GetTagTotal, p2.GetTagTotal)
    	atomic.AddUint64(&p.PutTagTotal, p2.PutTagTotal)
    	atomic.AddUint64(&p.RmvTagTotal, p2.RmvTagTotal)
    	atomic.AddUint64(&p.GetFailedTotal, p2.GetFailedTotal)
    	atomic.AddUint64(&p.HeadFailedTotal, p2.HeadFailedTotal)
    	atomic.AddUint64(&p.GetTagFailedTotal, p2.GetTagFailedTotal)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 14.2K bytes
    - Viewed (0)
  2. cmd/http-stats.go

    	s3OutputBytes        uint64
    }
    
    // Increase internode total input bytes
    func (s *connStats) incInternodeInputBytes(n int64) {
    	atomic.AddUint64(&s.internodeInputBytes, uint64(n))
    }
    
    // Increase internode total output bytes
    func (s *connStats) incInternodeOutputBytes(n int64) {
    	atomic.AddUint64(&s.internodeOutputBytes, uint64(n))
    }
    
    // Return internode total input bytes
    func (s *connStats) getInternodeInputBytes() uint64 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 17:13:00 UTC 2024
    - 11.4K bytes
    - Viewed (0)
  3. cmd/generic-handlers.go

    				tc.ResponseRecorder.LogErrBody = true
    			}
    
    			defer logger.AuditLog(r.Context(), w, r, mustGetClaimsFromToken(r))
    			writeErrorResponse(r.Context(), w, errorCodes.ToAPIErr(ErrMetadataTooLarge), r.URL)
    			atomic.AddUint64(&globalHTTPStats.rejectedRequestsHeader, 1)
    			return
    		}
    		// Restricting read data to a given maximum length
    		r.Body = http.MaxBytesReader(w, r.Body, requestMaxBodySize)
    		h.ServeHTTP(w, r)
    	})
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 20.5K bytes
    - Viewed (0)
  4. cmd/perf-tests.go

    						errOnce.Do(func() {
    							retError = err.Error()
    						})
    					}
    					uploadsCancel()
    					return
    				}
    				response := time.Since(t)
    				atomic.AddUint64(&totalBytesWritten, uint64(info.Size))
    				objCountPerThread[i]++
    				mu.Lock()
    				uploadTimes = append(uploadTimes, response)
    				mu.Unlock()
    			}
    		}(i)
    	}
    	wg.Wait()
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  5. internal/rest/client.go

    	r.errorStatus(err)
    	return
    }
    
    func (r *respBodyMonitor) errorStatus(err error) {
    	if xnet.IsNetworkOrHostDown(err, r.expectTimeouts) {
    		r.errorStatusOnce.Do(func() {
    			atomic.AddUint64(&globalStats.errs, 1)
    		})
    	}
    }
    
    // dumpHTTP - dump HTTP request and response.
    func (c *Client) dumpHTTP(req *http.Request, resp *http.Response) {
    	// Starts http dump.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 26 12:55:01 UTC 2024
    - 14.7K bytes
    - Viewed (0)
  6. cmd/auth-handler.go

    				// present we will reject such clients.
    				defer logger.AuditLog(r.Context(), w, r, mustGetClaimsFromToken(r))
    				writeErrorResponse(r.Context(), w, errorCodes.ToAPIErr(errCode), r.URL)
    				atomic.AddUint64(&globalHTTPStats.rejectedRequestsTime, 1)
    				return
    			}
    			// Verify if the request date header is shifted by less than globalMaxSkewTime parameter in the past
    			// or in the future, reject request otherwise.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 17 16:45:46 UTC 2024
    - 26.1K bytes
    - Viewed (0)
  7. cmd/admin-handlers-site-replication.go

    	ctx := r.Context()
    
    	globalSiteNetPerfRX.Connect()
    	defer globalSiteNetPerfRX.Disconnect()
    
    	connectTime := time.Now()
    	for {
    		n, err := io.CopyN(xioutil.Discard, r.Body, 128*humanize.KiByte)
    		atomic.AddUint64(&globalSiteNetPerfRX.RX, uint64(n))
    		if err != nil && err != io.EOF && err != io.ErrUnexpectedEOF {
    			// If there is a disconnection before globalNetPerfMinDuration (we give a margin of error of 1 sec)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 19.4K bytes
    - Viewed (0)
  8. internal/grid/connection.go

    		trace:      c.trace.subroute(route),
    	}
    }
    
    // newMuxClient returns a mux client for manual use.
    func (c *Connection) newMuxClient(ctx context.Context) (*muxClient, error) {
    	client := newMuxClient(ctx, atomic.AddUint64(&c.NextID, 1), c)
    	if dl, ok := ctx.Deadline(); ok {
    		client.deadline = getDeadline(time.Until(dl))
    		if client.deadline == 0 {
    			client.cancelFn(context.DeadlineExceeded)
    			return nil, context.DeadlineExceeded
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 46.7K bytes
    - Viewed (0)
  9. cmd/xl-storage-disk-id-check.go

    			acc = newAcc
    		} else {
    			// We may be able to grab the new accumulator by yielding.
    			runtime.Gosched()
    			acc = e.cached.Load()
    		}
    	}
    	atomic.AddInt64(&acc.N, 1)
    	atomic.AddInt64(&acc.Total, int64(value))
    	atomic.AddInt64(&acc.Size, sz)
    }
    
    // total returns the total call count and latency for the last minute.
    func (e *lockedLastMinuteLatency) total() AccElem {
    	e.mu.Lock()
    	defer e.mu.Unlock()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:56:26 UTC 2024
    - 34.5K bytes
    - Viewed (0)
  10. cmd/bucket-replication-stats.go

    	defer r.qCache.Unlock()
    	v, ok := r.qCache.bucketStats[bucket]
    	if !ok {
    		v = newInQueueStats(r.registry, bucket)
    	}
    	atomic.AddInt64(&v.nowBytes, sz)
    	atomic.AddInt64(&v.nowCount, 1)
    	r.qCache.bucketStats[bucket] = v
    	atomic.AddInt64(&r.qCache.srQueueStats.nowBytes, sz)
    	atomic.AddInt64(&r.qCache.srQueueStats.nowCount, 1)
    }
    
    func (r *ReplicationStats) decQ(bucket string, sz int64, isDelMarker bool, opType replication.Type) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 13.6K bytes
    - Viewed (0)
Back to top