mds:fix updatechunkserverstat bug & add some logs

Signed-off-by: Hanqing Wu <wuhanqing@corp.netease.com>

Author: xu-chaojie

src/chunkserver/chunkserver.cpp

@@ -294,6 +294,7 @@ int ChunkServer::Run(int argc, char** argv) {
     heartbeatOptions.chunkFilePool = chunkfilePool;
     heartbeatOptions.chunkserverId = metadata.id();
     heartbeatOptions.chunkserverToken = metadata.token();
+    heartbeatOptions.useChunkFilePoolAsWalPool = useChunkFilePoolAsWalPool;
     LOG_IF(FATAL, heartbeat_.Init(heartbeatOptions) != 0)
         << "Failed to init Heartbeat manager.";
 

src/chunkserver/datastore/file_pool.cpp

@@ -524,7 +524,6 @@ bool FilePool::ScanInternal() {
         }
     }
 
-    currentState_.capacity = tmpvec.size();
     currentState_.preallocatedChunksLeft = tmpvec.size();
 
     std::unique_lock<std::mutex> lk(mtx_);
@@ -539,10 +538,6 @@ size_t FilePool::Size() {
     return tmpChunkvec_.size();
 }
 
-size_t FilePool::Capacity() {
-    return currentState_.capacity;
-}
-
 FilePoolState FilePool::GetState() const {
     return currentState_;
 }

src/chunkserver/datastore/file_pool.h

@@ -73,8 +73,6 @@ struct FilePoolState {
     uint32_t    metaPageSize = 0;
     // io alignment
     uint32_t    blockSize = 0;
-    // filepool Capacity
-    uint64_t   capacity = 0;
 };
 
 struct FilePoolMeta {
@@ -173,8 +171,6 @@ class CURVE_CACHELINE_ALIGNMENT FilePool {
      */
     virtual size_t Size();
 
-    virtual size_t Capacity();
-
     /**
      * Get the allocation status of FilePool
      */

src/chunkserver/heartbeat.cpp

@@ -250,11 +250,17 @@ int Heartbeat::BuildRequest(HeartbeatRequest* req) {
     // leftWalSegmentSize will be 0 when CHUNK and WAL share file pool
     uint64_t leftWalSegmentSize = metric->GetWalSegmentLeftCount()
                                 * walSegmentFileSize;
-    uint64_t chunkPoolSize = options_.chunkFilePool->Capacity() *
-                options_.chunkFilePool->GetFilePoolOpt().fileSize;
-    stats->set_chunkfilepoolsize(chunkPoolSize);
-    stats->set_chunksizeusedbytes(usedChunkSize+usedWalSegmentSize);
-    stats->set_chunksizeleftbytes(leftChunkSize+leftWalSegmentSize);
+    // CHUNK and WAL share file pool
+    uint64_t totalSize = 0;
+    if (options_.useChunkFilePoolAsWalPool) {
+        totalSize = usedChunkSize + usedWalSegmentSize +
+            leftChunkSize + leftWalSegmentSize;
+    } else {
+        totalSize = usedChunkSize + leftChunkSize;
+    }
+    stats->set_chunkfilepoolsize(totalSize);
+    stats->set_chunksizeusedbytes(usedChunkSize + usedWalSegmentSize);
+    stats->set_chunksizeleftbytes(leftChunkSize + leftWalSegmentSize);
     stats->set_chunksizetrashedbytes(trashedChunkSize);
     req->set_allocated_stats(stats);
 

src/chunkserver/heartbeat.h

@@ -70,6 +70,7 @@ struct HeartbeatOptions {
     uint32_t                port;
     uint32_t                intervalSec;
     uint32_t                timeout;
+    bool                    useChunkFilePoolAsWalPool;
     CopysetNodeManager*     copysetNodeManager;
 
     std::shared_ptr<LocalFileSystem> fs;

src/fs/ext4_filesystem_impl.cpp

@@ -346,7 +346,11 @@ int Ext4FileSystemImpl::Write(int fd,
                 continue;
             }
             LOG(ERROR) << "IOBuf::pcut_into_file_descriptor failed: "
-                       << strerror(errno);
+                       << strerror(errno)
+                       << ", fd: " << fd
+                       << ", offset: " << offset
+                       << ", remainLength: " << remainLength
+                       << ", length: " << length;
             return -errno;
         }
 

src/mds/topology/topology_service_manager.cpp

@@ -82,13 +82,9 @@ void TopologyServiceManager::RegistChunkServer(
 
     std::string hostIp = request->hostip();
     uint32_t port = request->port();
-    ChunkServerStat stat;
     bool useChunkFilePoolAsWalPool = false;
     uint32_t useChunkFilePoolAsWalPoolReserve;
     bool useChunkFilepool = false;
-    if (request->has_chunkfilepoolsize()) {
-        stat.chunkFilepoolSize = request->chunkfilepoolsize();
-    }
     if (request->has_usechunkfilepoolaswalpool()) {
         useChunkFilepool = true;
         useChunkFilePoolAsWalPool = request->usechunkfilepoolaswalpool();
@@ -135,7 +131,7 @@ void TopologyServiceManager::RegistChunkServer(
             response->set_statuscode(kTopoErrCodeSuccess);
             response->set_chunkserverid(cs.GetId());
             response->set_token(cs.GetToken());
-            topoStat_->UpdateChunkServerStat(cs.GetId(), stat);
+
             topologyChunkAllocator_->UpdateChunkFilePoolAllocConfig(
                 useChunkFilepool, useChunkFilePoolAsWalPool,
                 useChunkFilePoolAsWalPoolReserve);
@@ -172,8 +168,6 @@ void TopologyServiceManager::RegistChunkServer(
         response->set_statuscode(kTopoErrCodeSuccess);
         response->set_chunkserverid(cs.GetId());
         response->set_token(cs.GetToken());
-        topoStat_->UpdateChunkServerStat(cs.GetId(),
-                    stat);
         topologyChunkAllocator_->UpdateChunkFilePoolAllocConfig(
             useChunkFilepool, useChunkFilePoolAsWalPool,
             useChunkFilePoolAsWalPoolReserve);
@@ -253,6 +247,9 @@ void TopologyServiceManager::RegistChunkServer(
         response->set_token(chunkserver.GetToken());
         ChunkServerStat stat;
         stat.chunkFilepoolSize = request->chunkfilepoolsize();
+        stat.chunkSizeUsedBytes = 0;
+        stat.chunkSizeLeftBytes = stat.chunkFilepoolSize;
+        stat.chunkSizeTrashedBytes = 0;
         topoStat_->UpdateChunkServerStat(chunkserver.GetId(), stat);
         topologyChunkAllocator_->UpdateChunkFilePoolAllocConfig(
                 useChunkFilepool, useChunkFilePoolAsWalPool,