MCPcopy Create free account
hub / github.com/chainreactors/EvilProxy / Complete

Method Complete

internal/bridge/taskmanager.go:202–216  ·  view source on GitHub ↗

Complete marks a task as completed and closes its result channel.

(sessionID string, taskID uint32)

Source from the content-addressed store, hash-verified

200
201// Complete marks a task as completed and closes its result channel.
202func (tm *TaskManager) Complete(sessionID string, taskID uint32) {
203 task := tm.Get(sessionID, taskID)
204 if task == nil {
205 return
206 }
207 task.mu.Lock()
208 defer task.mu.Unlock()
209
210 if task.State == TaskCompleted || task.State == TaskFailed {
211 return // already terminal
212 }
213 task.State = TaskCompleted
214 task.UpdatedAt = time.Now()
215 close(task.resultCh)
216}
217
218// Fail marks a task as failed with a reason and closes its result channel.
219func (tm *TaskManager) Fail(sessionID string, taskID uint32, reason string) {

Callers 15

TestTask_LifecycleFunction · 0.95
TestTask_ActiveBySessionFunction · 0.95
handleDirectUploadMethod · 0.45
executeChunksMethod · 0.45
handleDirectDownloadMethod · 0.45
waitForReadResultMethod · 0.45
executeSingleShellMethod · 0.45
executeChunksMethod · 0.45

Calls 1

GetMethod · 0.95