tiny fixes

moxian · Oct 21, 2013 · 00f964f · 00f964f
1 parent abda757
commit 00f964f
Show file tree

Hide file tree

Showing 4 changed files with 12 additions and 6 deletions.
diff --git a/context.go b/context.go
@@ -38,6 +38,7 @@ type Canceler interface {
 type CxState uint32
 
 const (
+	CxOK       = CxState(0)
 	CxCanceled = CxState(1)
 	CxTimeout  = CxState(2)
 )

diff --git a/epoch.go b/epoch.go
@@ -55,3 +55,7 @@ func (e Epoch) String() string {
 func (e Epoch) Remains() time.Duration {
 	return time.Duration(e - NowEpoch())
 }
+
+func (e Epoch) Elapsed() time.Duration {
+	return time.Duration(NowEpoch() - e)
+}
diff --git a/request.go b/request.go
@@ -211,6 +211,7 @@ func (cm *ReqContext) Done() {
 	if req := cm.Request; req != nil {
 		req.RespondFail(RcInternalError)
 	}
+	cm.Context.Done()
 }
 
 func (r *Request) Context() (cx *ReqContext) {

diff --git a/response.go b/response.go
@@ -18,14 +18,14 @@ const (
 )
 
 const (
-	RcShutdown      = 0xff03
-	RcProtocolError = 0x0302
-	RcInternalError = 0xfc02
+	RcShutdown      = RetCode(0xff03)
+	RcProtocolError = RetCode(0x0302)
+	RcInternalError = RetCode(0xfc02)
 )
 const (
-	RcCanceled = 0xff03
-	RcIOError  = 0xfe03
-	RcTimeout  = 0xfd03
+	RcCanceled = RetCode(0xff03)
+	RcIOError  = RetCode(0xfe03)
+	RcTimeout  = RetCode(0xfd03)
 )
 
 type Response struct {