Code

Sam/stream msg app#1252

Code

Closed

srh wants to merge 21 commits intomasterhypermodeinc/dgraph:masterfrom sam/streamMsgApphypermodeinc/dgraph:sam/streamMsgAppCopy head branch name to clipboard

+459-106

Commits

Commits on Jul 25, 2017

• Use grpc.DialContext

  

  Sam Hughes

  committed
  4ad62c9

  Copy full SHA for 4ad62c9

• Fix typo

  

  Sam Hughes

  committed
  6c6d94f

  Copy full SHA for 6c6d94f

• Make node::send not Fatalf

  

  Sam Hughes

  committed
  388e397

  Copy full SHA for 388e397

• Make RaftMessageStream RPC, used for MsgApp

  

  Sam Hughes

  committed
  7d2d959

  Copy full SHA for 7d2d959

• RaftMessageStream cleanup logic

  

  Sam Hughes

  committed
  5ee52b1

  Copy full SHA for 5ee52b1

• Make server graceful shutdown work

  

  Sam Hughes

  committed
  9961da0

  Copy full SHA for 9961da0

• Factor out sendMessages

  

  Sam Hughes

  committed
  e08042d

  Copy full SHA for e08042d

• Inline away n.send

  

  Sam Hughes

  committed
  d061609

  Copy full SHA for d061609

• Just some renamings

  

  Sam Hughes

  committed
  b193f5c

  Copy full SHA for b193f5c

• Tolerate stream failure in streamMsgApps

  

  Sam Hughes

  committed
  e9a2583

  Copy full SHA for e9a2583

• Adjust comment

  

  Sam Hughes

  committed
  f513e08

  Copy full SHA for f513e08

• Add and make use of Kick() method in etcd

  

  Sam Hughes

  committed
  a402fb9

  Copy full SHA for a402fb9

• Make kickCh not block

  

  Sam Hughes

  committed
  d183b28

  Copy full SHA for d183b28

• Kick harder

  

  Sam Hughes

  committed
  1f17412

  Copy full SHA for 1f17412

• kickc tweak

  

  Sam Hughes

  committed
  cbee87b

  Copy full SHA for cbee87b

• Make streamMsgApps WaitGroup be held per-peerPool

  

  Sam Hughes

  committed
  1502dc9

  Copy full SHA for 1502dc9

• Remove fixed TODO

  

  Sam Hughes

  committed
  0698d6e

  Copy full SHA for 0698d6e

• Remove spurious error return

  

  Sam Hughes

  committed
  5554f8b

  Copy full SHA for 5554f8b

• kickValue placeholder

  

  Sam Hughes

  committed
  91a8e21

  Copy full SHA for 91a8e21

• Make etcd use kickValue

  

  Sam Hughes

  committed
  942c7f8

  Copy full SHA for 942c7f8

• Make kick buffering be in Dgraph, not etcd

  

  Sam Hughes

  committed
  240ca4c

  Copy full SHA for 240ca4c