Code

server side concurrency#49

Code

Merged

cdevienne merged 21 commits intomasternats-rpc/nrpc:masterfrom 48-server-side-concurrencynats-rpc/nrpc:48-server-side-concurrencyCopy head branch name to clipboardSep 21, 2018

Commits

Commits on Sep 17, 2018

• Add a Request type

  Show description for 8f9f8d3
  cdevienne

  committed
  8f9f8d3

  Copy full SHA for 8f9f8d3

• Store the service and package parameters on the request

  cdevienne

  committed
  5d5487e

  Copy full SHA for 5d5487e

• Context is now passed to the handler by Request

  cdevienne

  committed
  0311b15

  Copy full SHA for 0311b15

• Call request.Run() in a unique place in the service handler,

  Show description for 85ec181
  cdevienne

  committed
  85ec181

  Copy full SHA for 85ec181

Commits on Sep 18, 2018

• Add Request.SendReply and use it instead of nrpc.Publish

  cdevienne

  committed
  32d288d

  Copy full SHA for 32d288d

• De-specialize unmarshalling requests of streamed replies methods

  Show description for c59a3ad
  cdevienne

  committed
  c59a3ad

  Copy full SHA for c59a3ad

• Streamed replies are now handled by Request

  cdevienne

  committed
  9f435ef

  Copy full SHA for 9f435ef

• Add Request.RunAndReply

  Show description for c36e2be
  cdevienne

  committed
  c36e2be

  Copy full SHA for c36e2be

• Implement server-side concurrency

  Show description for fcce55e
  cdevienne

  committed
  fcce55e

  Copy full SHA for fcce55e

• Cancel requests that are pending for too long

  Show description for 3f3a380
  cdevienne

  committed
  3f3a380

  Copy full SHA for 3f3a380

Commits on Sep 19, 2018

• Fix tests

  Show description for a8fcf90
  cdevienne

  committed
  a8fcf90

  Copy full SHA for a8fcf90

• protect maxPendingDuration with the mutex

  cdevienne

  committed
  fbe01c7

  Copy full SHA for fbe01c7

• Protect SetSize with the mutex

  cdevienne

  committed
  729aa24

  Copy full SHA for 729aa24

• WorkerPool.QueueRequest now sends the TOOBUSY error itself

  Show description for a4ce384
  cdevienne

  committed
  a4ce384

  Copy full SHA for a4ce384

• WorkerPool: close the schedule chan after scheduler() returns

  Show description for 2285329
  cdevienne

  committed
  2285329

  Copy full SHA for 2285329

• WorkerPool: fix: cancel extra requests if current queue has more pending tasks that the new queue size

  cdevienne

  committed
  36f3637

  Copy full SHA for 36f3637

• WorkerPool.Close: Send an error to the pending requests callers

  cdevienne

  committed
  552a89f

  Copy full SHA for 552a89f

• Stream replies are now initialized at queueing or by the request itself on RunAndReply

  cdevienne

  committed
  453f2a5

  Copy full SHA for 453f2a5

• Fix: Use log.Printf instead of log.Println

  cdevienne

  committed
  978e4fb

  Copy full SHA for 978e4fb

• Request: Use pointer receiver for all functions

  cdevienne

  committed
  58accd6

  Copy full SHA for 58accd6

• Remove debug logs

  cdevienne

  committed
  914de1b

  Copy full SHA for 914de1b