From 6f8012bd27f6a84ff1eb47abbbe1fb7443072e24 Mon Sep 17 00:00:00 2001
From: Simon Rettberg
Date: Mon, 13 Aug 2018 13:56:27 +0200
Subject: [SERVER] Use atomic vars for uplink byte counters

---
 src/server/globals.h | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

(limited to 'src/server/globals.h')

diff --git a/src/server/globals.h b/src/server/globals.h
index 84588c3..097df83 100644
--- a/src/server/globals.h
+++ b/src/server/globals.h
@@ -70,8 +70,7 @@ struct _dnbd3_connection
 	int nextReplicationIndex;   // Which index in the cache map we should start looking for incomplete blocks at
 	                            // If BGR == BGR_HASHBLOCK, -1 means "currently no incomplete block"
 	uint64_t replicationHandle; // Handle of pending replication request
-	uint64_t bytesReceived;     // Number of bytes received by the connection.
-	uint64_t lastBytesReceived; // Number of bytes received last time we updated the global counter.
+	atomic_uint_fast64_t bytesReceived; // Number of bytes received by the uplink since startup.
 	int queueLen;               // length of queue
 	int idleCount;              // How many iterations of keepalive check connection was idle
 	dnbd3_queued_request_t queue[SERVER_MAX_UPLINK_QUEUE];
-- 
cgit v1.2.3-55-g7522