[TE] fix(tcp): add handshake daemon initialization (kvcache-ai#846)

- Implement startHandshakeDaemon method in TcpTransport class
- Call handshake daemon during transport installation process

Signed-off-by: staryxchen <staryxchen@tencent.com>

Author: staryxchen

mooncake-transfer-engine/include/transport/tcp_transport/tcp_transport.h

@@ -60,6 +60,8 @@ class TcpTransport : public Transport {
                 std::shared_ptr<TransferMetadata> meta,
                 std::shared_ptr<Topology> topo);
 
+    int startHandshakeDaemon();
+
     int allocateLocalSegmentID(int tcp_data_port);
 
     int registerLocalMemory(void *addr, size_t length,

mooncake-transfer-engine/src/transport/tcp_transport/tcp_transport.cpp

@@ -269,6 +269,12 @@ TcpTransport::~TcpTransport() {
     metadata_->removeSegmentDesc(local_server_name_);
 }
 
+int TcpTransport::startHandshakeDaemon() {
+    return metadata_->startHandshakeDaemon(nullptr,
+                                           metadata_->localRpcMeta().rpc_port,
+                                           metadata_->localRpcMeta().sockfd);
+}
+
 int TcpTransport::install(std::string &local_server_name,
                           std::shared_ptr<TransferMetadata> meta,
                           std::shared_ptr<Topology> topo) {
@@ -288,6 +294,12 @@ int TcpTransport::install(std::string &local_server_name,
         return -1;
     }
 
+    ret = startHandshakeDaemon();
+    if (ret) {
+        LOG(ERROR) << "TcpTransport: cannot start handshake daemon";
+        return -1;
+    }
+
     ret = metadata_->updateLocalSegmentDesc();
     if (ret) {
         LOG(ERROR) << "TcpTransport: cannot publish segments, "