parallel_service: recover

moxian · Oct 21, 2013 · 5138305 · 5138305
1 parent ec4be5d
commit 5138305
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/parallel_service.go b/parallel_service.go
@@ -2,6 +2,7 @@ package iproto
 
 import (
 	"log"
+	"runtime"
 	"sync"
 	"time"
 )
@@ -101,6 +102,12 @@ Loop:
 }
 
 func (serv *ParallelService) inc(ctx *ReqContext) {
+	if err := recover(); err != nil {
+		log.Print(err)
+		btrace := &[2048]byte{}
+		n := runtime.Stack(btrace[:], false)
+		log.Printf("%s", btrace[:n])
+	}
 	ctx.Done()
 	ctx.gen.Release()
 	serv.sema <- struct{}{}