update

Author: chenjie199234

cgrpc/client.go

@@ -13,6 +13,7 @@ import (
 
 	cerror "github.com/chenjie199234/Corelib/error"
 	"github.com/chenjie199234/Corelib/log"
+	"github.com/chenjie199234/Corelib/monitor"
 	"github.com/chenjie199234/Corelib/trace"
 	"github.com/chenjie199234/Corelib/util/common"
 	"github.com/chenjie199234/Corelib/util/name"
@@ -210,6 +211,7 @@ func (c *CGrpcClient) Call(ctx context.Context, path string, req interface{}, re
 		} else {
 			//req send,recv error
 			trace.Trace(ctx, trace.CLIENT, c.serverappname, p.Addr.String(), "GRPC", path, &start, &end, e)
+			monitor.GrpcClientMonitor(c.serverappname, "GRPC", path, e, uint64(end.UnixNano()-start.UnixNano()))
 		}
 		if cerror.Equal(e, cerror.ErrClosing) {
 			continue

cgrpc/server.go

@@ -16,6 +16,7 @@ import (
 
 	cerror "github.com/chenjie199234/Corelib/error"
 	"github.com/chenjie199234/Corelib/log"
+	"github.com/chenjie199234/Corelib/monitor"
 	"github.com/chenjie199234/Corelib/trace"
 	"github.com/chenjie199234/Corelib/util/common"
 	"github.com/chenjie199234/Corelib/util/host"
@@ -273,6 +274,7 @@ func (s *CGrpcServer) insidehandler(sname, mname string, handlers ...OutsideHand
 			}
 			end := time.Now()
 			trace.Trace(trace.InitTrace(nil, traceid, sourceapp, sourceip, sourcemethod, sourcepath, selfdeep-1), trace.SERVER, s.selfappname, host.Hostip, "GRPC", path, &start, &end, workctx.e)
+			monitor.GrpcServerMonitor(sourceapp, "GRPC", path, workctx.e, uint64(end.UnixNano()-start.UnixNano()))
 			resp = workctx.resp
 			if workctx.e != nil {
 				e = workctx.e

crpc/client.go

@@ -14,6 +14,7 @@ import (
 
 	cerror "github.com/chenjie199234/Corelib/error"
 	"github.com/chenjie199234/Corelib/log"
+	"github.com/chenjie199234/Corelib/monitor"
 	"github.com/chenjie199234/Corelib/stream"
 	"github.com/chenjie199234/Corelib/trace"
 	"github.com/chenjie199234/Corelib/util/common"
@@ -287,6 +288,7 @@ func (c *CrpcClient) Call(ctx context.Context, path string, in []byte, metadata
 			atomic.AddInt32(&server.Pickinfo.Activecalls, -1)
 			end := time.Now()
 			trace.Trace(ctx, trace.CLIENT, c.serverappname, server.addr, "CRPC", path, &start, &end, r.err)
+			monitor.CrpcClientMonitor(c.serverappname, "CRPC", path, r.err, uint64(end.UnixNano()-start.UnixNano()))
 			if r.err != nil {
 				//req error,update last fail time
 				server.Pickinfo.LastFailTime = time.Now().UnixNano()
@@ -327,6 +329,7 @@ func (c *CrpcClient) Call(ctx context.Context, path string, in []byte, metadata
 			}
 			end := time.Now()
 			trace.Trace(ctx, trace.CLIENT, c.serverappname, server.addr, "CRPC", path, &start, &end, e)
+			monitor.CrpcClientMonitor(c.serverappname, "CRPC", path, e, uint64(end.UnixNano()-start.UnixNano()))
 			return nil, e
 		}
 	}

crpc/server.go

@@ -15,6 +15,7 @@ import (
 
 	cerror "github.com/chenjie199234/Corelib/error"
 	"github.com/chenjie199234/Corelib/log"
+	"github.com/chenjie199234/Corelib/monitor"
 	"github.com/chenjie199234/Corelib/stream"
 	"github.com/chenjie199234/Corelib/trace"
 	"github.com/chenjie199234/Corelib/util/common"
@@ -288,6 +289,7 @@ func (s *CrpcServer) insidehandler(path string, handlers ...OutsideHandler) func
 			}
 			end := time.Now()
 			trace.Trace(trace.InitTrace(nil, traceid, sourceapp, sourceip, sourcemethod, sourcepath, selfdeep-1), trace.SERVER, s.instance.GetSelfAppName(), host.Hostip, "CRPC", path, &start, &end, msg.Error)
+			monitor.CrpcServerMonitor(sourceapp, "CRPC", path, msg.Error, uint64(end.UnixNano()-start.UnixNano()))
 			s.putContext(workctx)
 		}()
 		workctx.run()