alpha: limit #edges using LimitMutationsNquad config and add logs

Author: mangalaman93

edgraph/server.go

@@ -594,6 +594,12 @@ func (s *Server) doMutate(ctx context.Context, qc *queryContext, resp *api.Respo
 	if err != nil {
 		return err
 	}
+
+	if len(edges) > x.Config.LimitMutationsNquad {
+		return errors.Errorf("NQuad count in the request: %d, is more that threshold: %d",
+			len(edges), int(x.Config.LimitMutationsNquad))
+	}
+
 	ns, err := x.ExtractNamespace(ctx)
 	if err != nil {
 		return errors.Wrapf(err, "While doing mutations:")
@@ -953,7 +959,6 @@ func updateValInMutations(gmu *dql.Mutation, qc *queryContext) error {
 // updateUIDInMutations does following transformations:
 //   - uid(v) -> 0x123     -- If v is defined in query block
 //   - uid(v) -> _:uid(v)  -- Otherwise
-
 func updateUIDInMutations(gmu *dql.Mutation, qc *queryContext) error {
 	// usedMutationVars keeps track of variables that are used in mutations.
 	getNewVals := func(s string) []string {

query/shortest.go

@@ -242,7 +242,7 @@ func (sg *SubGraph) expandOut(ctx context.Context,
 		if numEdges > x.Config.LimitQueryEdge {
 			// If we've seen too many edges, stop the query.
 			rch <- errors.Errorf("Exceeded query edge limit = %v. Found %v edges.",
-				x.Config.LimitMutationsNquad, numEdges)
+				x.Config.LimitQueryEdge, numEdges)
 			return
 		}
 

worker/proposal.go

@@ -23,6 +23,7 @@ import (
 	"sync/atomic"
 	"time"
 
+	"github.com/golang/glog"
 	"github.com/pkg/errors"
 	ostats "go.opencensus.io/stats"
 	tag "go.opencensus.io/tag"
@@ -249,6 +250,7 @@ func (n *node) proposeAndWait(ctx context.Context, proposal *pb.Proposal) (perr
 				// We arrived here by a call to n.Proposals.Done().
 				return err
 			case <-ctx.Done():
+				glog.Warningf("Context expired while processing proposal %v", ctx.Err())
 				return ctx.Err()
 			case <-timer.C:
 				if atomic.LoadUint32(&pctx.Found) > 0 {
@@ -258,6 +260,7 @@ func (n *node) proposeAndWait(ctx context.Context, proposal *pb.Proposal) (perr
 					cancel()
 				}
 			case <-cctx.Done():
+				glog.Warningf("Internal context expired while processing proposal %v", cctx.Err())
 				return errInternalRetry
 			}
 		}