- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 20 for updateStats (0.07 seconds)
-
cmd/http-tracer_test.go
} } } // TestHTTPStatsRaceCondition tests the race condition fix for HTTPStats. // This test specifically addresses the race between: // - Write operations via updateStats. // - Read operations via toServerHTTPStats(false). func TestRaulStatsRaceCondition(t *testing.T) { httpStats := newHTTPStats() // Simulate the concurrent scenario from the original race condition:
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 5.3K bytes - Click Count (0) -
cmd/http-stats.go
serverStats.TotalS3Canceled = ServerHTTPAPIStats{ APIStats: st.totalS3Canceled.Load(toLowerKeys), } return serverStats } // Update statistics from http request and response data func (st *HTTPStats) updateStats(api string, w *xhttp.ResponseRecorder) { st.totalS3Requests.Inc(api) // Increment the prometheus http request response histogram with appropriate labelCreated: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Sep 24 17:13:00 GMT 2024 - 11.4K bytes - Click Count (0) -
cmd/handler-utils.go
f.ServeHTTP(w, r) globalHTTPStats.currentS3Requests.Dec(api) tc, _ := r.Context().Value(mcontext.ContextTraceKey).(*mcontext.TraceCtxt) if tc != nil { globalHTTPStats.updateStats(api, tc.ResponseRecorder) globalConnStats.incS3InputBytes(int64(tc.RequestRecorder.Size())) globalConnStats.incS3OutputBytes(int64(tc.ResponseRecorder.Size())) if countBktStat {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 16.4K bytes - Click Count (1) -
src/test/java/org/codelibs/fess/job/PurgeLogJobTest.java
public void deleteBefore(int days) { deleteJobLogCalled[0] = true; jobLogDeletedDays[0] = days; } @Override public void updateStatus() { updateJobLogStatusCalled[0] = true; } }; UserInfoService userInfoService = new UserInfoService() { @Override
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Wed Jan 14 14:29:07 GMT 2026 - 32.7K bytes - Click Count (0) -
cmd/admin-handlers.go
if lrTime.Sub(currentReleaseTime) <= 0 { updateStatus.Results = append(updateStatus.Results, madmin.ServerPeerUpdateStatus{ Host: local, Err: fmt.Sprintf("server is running the latest version: %s", Version), CurrentVersion: Version, }) for _, client := range globalNotificationSys.peerClients { updateStatus.Results = append(updateStatus.Results, madmin.ServerPeerUpdateStatus{
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 99.7K bytes - Click Count (0) -
src/main/java/jcifs/internal/smb2/lease/LeaseManager.java
entry.updateState(Smb2LeaseState.SMB2_LEASE_NONE); } releaseLease(key); } catch (Exception e) { log.error("Error handling lease break for key: " + key, e); // On error, ensure we're in safe state LeaseEntry entry = leases.get(key); if (entry != null) { entry.updateState(Smb2LeaseState.SMB2_LEASE_NONE);Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sun Aug 31 08:00:57 GMT 2025 - 18.8K bytes - Click Count (0) -
build-tools-internal/src/main/java/org/elasticsearch/gradle/internal/release/GitWrapper.java
} /** * Updates the git repository's tags from the specified remote * @param remote the remote to use to update */ public void updateTags(String remote) { runCommand("git", "fetch", "--tags", Objects.requireNonNull(remote)); } /** * Fetch all tags matching the specified pattern, returning them as {@link QualifiedVersion} instances.Created: Wed Apr 08 16:19:15 GMT 2026 - Last Modified: Wed Sep 01 06:25:29 GMT 2021 - 3K bytes - Click Count (0) -
docs/smb3-features/01-smb3-lease-design.md
this.lastAccessTime = createTime; this.epoch = 1; this.breaking = false; } public synchronized void updateState(int newState) { this.leaseState = newState; this.lastAccessTime = System.currentTimeMillis(); } public synchronized void incrementEpoch() {Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 16 02:53:50 GMT 2025 - 22K bytes - Click Count (0) -
internal/grid/connection.go
} err = conn.SetWriteDeadline(time.Now().Add(connWriteTimeout)) if err != nil { return err } return wsutil.WriteMessage(conn, c.side, ws.OpBinary, dst) } func (c *Connection) connect() { c.updateState(StateConnecting) rng := rand.New(rand.NewSource(time.Now().UnixNano())) // Runs until the server is shut down. for { if c.State() == StateShutdown { return } dialStarted := time.Now()
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 46.9K bytes - Click Count (0) -
src/main/webapp/WEB-INF/view/admin/storage/admin_storage_tag_edit.jsp
<la:message key="labels.crud_button_back" /> </la:link> <c:if test="${editable}"> <button type="submit" class="btn btn-success" name="updateTags" value="<la:message key="labels.crud_button_update" />" > <i class="fa fa-pencil-alt" aria-hidden="true"></i> <la:message key="labels.crud_button_update" /> </button>
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Mon Feb 23 08:03:44 GMT 2026 - 4.4K bytes - Click Count (0)