aboutsummaryrefslogtreecommitdiff
path: root/weed/admin/dash/worker_grpc_server.go
diff options
context:
space:
mode:
authorChris Lu <chrislusf@users.noreply.github.com>2025-10-17 22:11:50 -0700
committerGitHub <noreply@github.com>2025-10-17 22:11:50 -0700
commit97f30287821e1c49b816f2e4c05be46728b06a0b (patch)
tree1169d6e45c06698fc4081b8cfc27f2d4d2e98684 /weed/admin/dash/worker_grpc_server.go
parent8d63a9cf5f011baa4b86372b4f28b7179b9dc9cb (diff)
downloadseaweedfs-97f30287821e1c49b816f2e4c05be46728b06a0b.tar.xz
seaweedfs-97f30287821e1c49b816f2e4c05be46728b06a0b.zip
Clean up logs and deprecated functions (#7339)
* less logs * fix deprecated grpc.Dial
Diffstat (limited to 'weed/admin/dash/worker_grpc_server.go')
-rw-r--r--weed/admin/dash/worker_grpc_server.go6
1 files changed, 0 insertions, 6 deletions
diff --git a/weed/admin/dash/worker_grpc_server.go b/weed/admin/dash/worker_grpc_server.go
index 78ba6d7de..74410aab6 100644
--- a/weed/admin/dash/worker_grpc_server.go
+++ b/weed/admin/dash/worker_grpc_server.go
@@ -335,19 +335,15 @@ func (s *WorkerGrpcServer) handleHeartbeat(conn *WorkerConnection, heartbeat *wo
// handleTaskRequest processes task requests from workers
func (s *WorkerGrpcServer) handleTaskRequest(conn *WorkerConnection, request *worker_pb.TaskRequest) {
- // glog.Infof("DEBUG handleTaskRequest: Worker %s requesting tasks with capabilities %v", conn.workerID, conn.capabilities)
if s.adminServer.maintenanceManager == nil {
- glog.Infof("DEBUG handleTaskRequest: maintenance manager is nil")
return
}
// Get next task from maintenance manager
task := s.adminServer.maintenanceManager.GetNextTask(conn.workerID, conn.capabilities)
- // glog.Infof("DEBUG handleTaskRequest: GetNextTask returned task: %v", task != nil)
if task != nil {
- glog.Infof("DEBUG handleTaskRequest: Assigning task %s (type: %s) to worker %s", task.ID, task.Type, conn.workerID)
// Use typed params directly - master client should already be configured in the params
var taskParams *worker_pb.TaskParams
@@ -383,12 +379,10 @@ func (s *WorkerGrpcServer) handleTaskRequest(conn *WorkerConnection, request *wo
select {
case conn.outgoing <- assignment:
- glog.Infof("DEBUG handleTaskRequest: Successfully assigned task %s to worker %s", task.ID, conn.workerID)
case <-time.After(time.Second):
glog.Warningf("Failed to send task assignment to worker %s", conn.workerID)
}
} else {
- // glog.Infof("DEBUG handleTaskRequest: No tasks available for worker %s", conn.workerID)
}
}