kern: http2 response packet decode failed.

pkg/event_processor/http_request.go

@@ -88,6 +88,9 @@ func (this *HTTPRequest) Reset() {
 }
 
 func (this *HTTPRequest) Display() []byte {
+	if this.request.Proto == "HTTP/2.0" {
+		return this.reader.Bytes()
+	}
 	b, e := httputil.DumpRequest(this.request, true)
 	if e != nil {
 		log.Println("DumpRequest error:", e)

pkg/event_processor/iparser.go

@@ -2,6 +2,7 @@ package event_processor
 
 import (
 	"bytes"
+	"encoding/hex"
 	"fmt"
 )
 
@@ -25,7 +26,9 @@ const (
 const (
 	PARSER_TYPE_NULL PARSER_TYPE = iota
 	PARSER_TYPE_HTTP_REQUEST
+	PARSER_TYPE_HTTP2_REQUEST
 	PARSER_TYPE_HTTP_RESPONSE
+	PARSER_TYPE_HTTP2_RESPONSE
 	PARSER_TYPE_WEB_SOCKET
 )
 
@@ -76,6 +79,12 @@ func NewParser(payload []byte) IParser {
 					newParser = new(HTTPRequest)
 				case PARSER_TYPE_HTTP_RESPONSE:
 					newParser = new(HTTPResponse)
+				case PARSER_TYPE_HTTP2_REQUEST:
+					// TODO support HTTP2 request
+					// via golang.org/x/net/http2
+					//hpack.NewEncoder(buf)
+				case PARSER_TYPE_HTTP2_RESPONSE:
+					// TODO  support HTTP2 response
 				}
 				break
 			}
@@ -127,6 +136,13 @@ func (this *DefaultParser) Init() {
 }
 
 func (this *DefaultParser) Display() []byte {
+	b := this.reader.Bytes()
+	if len(b) <= 0 {
+		return []byte{}
+	}
+	if b[0] < 32 || b[0] > 126 {
+		return []byte(hex.Dump(b))
+	}
 	return []byte(CToGoString(this.reader.Bytes()))
 }
 

pkg/event_processor/iworker.go

@@ -119,6 +119,7 @@ func (this *eventWorker) Run() {
 		case _ = <-this.ticker.C:
 			// 输出包
 			if this.tickerCount > MAX_TICKER_COUNT {
+				this.processor.GetLogger().Printf("eventWorker TickerCount > %d, event closed.", MAX_TICKER_COUNT)
 				this.Close()
 				return
 			}

pkg/event_processor/processor.go

@@ -46,7 +46,7 @@ func (this *EventProcessor) Serve() {
 }
 
 func (this *EventProcessor) dispatch(e event.IEventStruct) {
-	//this.logger.Printf("event ID:%s", event.GetUUID())
+	//this.logger.Printf("event ID:%s", e.GetUUID())
 	var uuid string = e.GetUUID()
 	found, eWorker := this.getWorkerByUUID(uuid)
 	if !found {
@@ -58,6 +58,7 @@ func (this *EventProcessor) dispatch(e event.IEventStruct) {
 	err := eWorker.Write(e)
 	if err != nil {
 		//...
+		this.GetLogger().Fatalf("write event failed , error:%v", err)
 	}
 }