Mirroristas/etcd
2
0
Fork 0
mirror of https://github.com/etcd-io/etcd.git synced 2024-09-27 06:25:44 +00:00
Code Issues Packages Projects Releases Wiki Activity
11,536 Commits 15 Branches 491 Tags 148 MiB
Commit Graph

97 Commits

Author SHA1 Message Date
Anthony Romano
be8f102efb grpcproxy: forward PrevKv flag in Put 2017-08-04 07:32:17 -07:00
Anthony Romano
19fe4b0cac grpcproxy: return nil on receiving snapshot EOF 
Gets "code = OutOfRange desc = EOF" errors otherwise.
 2017-07-19 08:33:44 -07:00
Anthony Romano
33c375dc44 *: fill out blank package godocs 
Mostly one-liner short descriptions, but also includes some typo fixes
and some examples.
 2017-05-18 09:41:13 -07:00
Anthony Romano
713e006bc6 adpater: adapters for lock and election services 2017-05-10 12:51:05 -07:00
Anthony Romano
fd01db9e60 grpcproxy, etcdmain: add lock and election services to proxy 2017-05-10 12:19:09 -07:00
Anthony Romano
6dd8fb6f24 Revert "Merge pull request #7732 from heyitsanthony/lease-err-ka" 
This reverts commit fbbc4a4979b256125d2238f6325ad86e7f1b58bd, reversing
changes made to f254e383859a2939d5929346f6595549f424f7c5.

Fixes #7851
 2017-05-02 09:36:16 -07:00
Anthony Romano
b5384ac1c0 grpcproxy: use new lease interface 2017-04-24 23:49:44 -07:00
Gyu-Ho Lee
7adf4d7c94 grpcproxy/adapter: add Cluster API support 
Signed-off-by: Gyu-Ho Lee <gyuhox@gmail.com>
 2017-04-04 08:13:30 -07:00
Gyu-Ho Lee
5c642ae314 grpcproxy/adapter: add maintenance API support 
Signed-off-by: Gyu-Ho Lee <gyuhox@gmail.com>
 2017-03-28 09:09:06 -07:00
Gyu-Ho Lee
caa73c176f proxy/grpcproxy: add chanStream helper 
Prelimiary work for maintenance API in adapter

Signed-off-by: Gyu-Ho Lee <gyuhox@gmail.com>
 2017-03-27 11:24:02 -07:00
Anthony Romano
b2a465e354 grpcproxy/cache: only check compaction revision for historical revisions 
Since the current revision is 0, it'll always be less than the compaction
revision. If the proxy sees a compaction, it would always reject the
current revision requests since it's less than the compaction revision.
Instead, check if the revision is historical before trying to reject on
compaction revision.

Fixes #7599
 2017-03-24 13:20:46 -07:00
Anthony Romano
b025cdd097 adapter, integration: split out grpc adapters from grpcproxy package 
Break cyclic dependency:
clientv3/naming <-> integration <-> v3client <-> grpcproxy <-> clientv3/naming
 2017-03-13 15:23:26 -07:00
Gyu-Ho Lee
f862b47e92 grpcproxy: configure register to Cluster API 
Signed-off-by: Gyu-Ho Lee <gyuhox@gmail.com>
 2017-03-09 02:40:13 -08:00
Anthony Romano
28e9ba365a grpcproxy: return closing error when stream is canceled from conn close 
Fixes #6630
 2017-03-01 16:46:13 -08:00
Gyu-Ho Lee
72a531e8b2 grpcproxy: add 'register' address 
For https://github.com/coreos/etcd/issues/6902.
 2017-02-22 16:47:48 -08:00
Anthony Romano
29a6fd65ad grpcproxy: only return ctx error in chan stream if recvc is empty 
Since select{} won't prioritize, ctx.Done() can sometimes override
a pending message on recvc. Loop if recvc has messages instead.

Fixes #7340
 2017-02-21 10:53:58 -08:00
fanmin shi
ba52bd07ba grpcproxy: add lease coalescing support 2017-02-16 11:50:50 -08:00
fanmin shi
05b82f2022 grpcproxy: refactor chan stream out of watch_client_adapter 2017-02-16 11:41:21 -08:00
Anthony Romano
80de75431e grpcproxy: support forcing leader as available 
Leadership timeout can sometimes take too long, such as in test cases.
However, it is possible to infer a leader is available based on RPCs
that must go through consensus. Therefore, have a way to update the
leadership status off the watch path.
 2017-02-15 16:49:41 -08:00
Anthony Romano
36f5b713bf grpcproxy: don't wait for ctx.Done() to close kv donec 
Causes a goroutine leak in ActiveConnection.Close() tests. Channel is
vestigial since removing ccache; revisit if kv ever needs goroutines.
 2017-02-15 00:16:25 -08:00
Anthony Romano
49a0a63fc3 grpcproxy: split out leadership detection code 
Move out of watch code since will be shared with lease code. Also assumes
leader does not exist unless watch can be successfully created.
 2017-02-15 00:16:25 -08:00
Anthony Romano
853f68071b grpcproxy: respect CompactRevision in watcher 
CompactRevision wasn't sent over watch stream, causing TestKVCompact to hang.
 2017-02-13 15:43:41 -08:00
Anthony Romano
c22ba766d5 grpcproxy: support CountOnly 
TestKVRange from client integration tests was failing.
 2017-02-10 16:06:24 -08:00
Anthony Romano
1fe2a9b124 Revert "Merge pull request #7139 from heyitsanthony/proxy-rlock" 
This reverts commit 304606ab0bb009169b442dec6f9af76e4cd1e887, reversing
changes made to 7dfe503f1c86de755ca379e95922e43afacee923.
 2017-02-10 14:37:48 -08:00
Anthony Romano
e42fa18ccf grpcproxy: don't use WithRequireLeader for watch event stream 
Ohterwise leader loss will reject all stream creation.
 2017-02-02 09:32:25 -08:00
sharat
2fce80e4c0 grpcproxy: handle 'IgnoreLease' field in PutRequest 2017-01-25 03:14:31 +05:30
Anthony Romano
8c0282ab24 grpcproxy, etcdmain, integration: add close channel to kv proxy 
ccache launches goroutines that need to be explicitly stopped.

Fixes #7158
 2017-01-18 11:51:16 -08:00
Gyu-Ho Lee
0f8060bede grpcproxy: handle 'IgnoreValue' field in PutRequest 2017-01-13 15:13:18 -08:00
Anthony Romano
9fa6c95054 grpcproxy: use ccache for key cache 
groupcache needs a write lock and has no way to expire keys; ccache can
do this, though.

Also removes the key count metric, since there's no way to efficiently
calculate it using ccache.
 2017-01-13 10:00:57 -08:00
Anthony Romano
e179225f28 grpcproxy: tear down watch when client context is done 
If client closes but all watch streams are not canceled, the outstanding
watch will wait until it is canceled, causing watch server to potentially
wait forever to close.

Fixes #7102
 2017-01-04 16:23:27 -08:00
Anthony Romano
9b5eb1ae5a grpcproxy, etcdmain, integration: return done channel with WatchServer 
Makes it possible to synchronously close the watch server.

Fixes #7078
 2016-12-30 12:09:48 -08:00
Gyu-Ho Lee
7e74b3f846 grpcproxy: remove unused field 'wbs *watchBroadcasts' 2016-12-12 10:07:14 -08:00
Gyu-Ho Lee
a98de7efa7
grpcproxy: fix minor typo 2016-12-07 17:08:46 -08:00
Anthony Romano
91ff6f30b5 grpcproxy: fix deadlock in watchbroadcast 
Calling empty() in watchbroadcast methods was trying to
lock the rwmutex when it was already held.

Fixes #6937
 2016-12-05 15:06:44 -08:00
Anthony Romano
62398954e4 grpcproxy: lock store when getting size 
Fixes data race in proxy integration tests.
 2016-12-05 13:29:57 -08:00
Xiang Li
0cb680800e grpcproxy: add cache related metrics 2016-12-02 15:29:42 -08:00
Xiang Li
1f954dc9f4 Merge pull request #6926 from xiang90/metrics 
grpcproxy: add richer metrics for watch
 2016-12-02 14:13:43 -08:00
Xiang Li
a686c994cd grpcproxy: add richer metrics for watch 2016-12-02 11:13:30 -08:00
Anthony Romano
60908c64a6 grpcproxy: fix race between coalesce and bcast on nextrev 
coalesce was locking the target coalesce broadcast object but not the source
broadcast object resulting in a data race on the source's nextrev.
 2016-11-30 16:50:29 -08:00
Anthony Romano
d680b8b5fb grpcproxy: fix race between watch ranges delete() and broadcasts empty() 
Checking empty() wasn't grabbing the broadcasts lock so the race detector
flags it as a data race with coalesce(). Instead, just return the number
of remaining watches following delete() and get rid of empty().
 2016-11-28 15:53:41 -08:00
Anthony Romano
7618fdd1d6 grpcproxy: fix deadlock on watch broadcasts stop 
Holding the WatchBroadcasts lock and waiting on donec was
causing a deadlock with the coalesce loop. Was causing
TestV3WatchSyncCancel to hang.
 2016-11-18 16:55:26 -08:00
Anthony Romano
1358a9d460 grpcproxy: copy range request before storing in cache 
Reused Range requests would have Serialized overwritten with 'true'.

Was failing on TestV3LeaseSwitch.
 2016-11-15 14:35:00 -08:00
Anthony Romano
98a7c642d4 grpcproxy: watch next revision should be start revision when not 0 
The create header revision is the current etcd revision. For watches with
rev=0, the next revision is hdr.rev+1. For watches with rev=n, the next
revision should be n.

Fixes TestDoubleBarrier timeouts.
 2016-11-14 16:46:02 -08:00
Anthony Romano
90ea3fbadc grpcproxy: do not resend create event after leader loss 
Only set CreateNotify if no watch responses have been received.
 2016-11-14 10:43:06 -08:00
Anthony Romano
e40da39143 grpcproxy: only coalesce watchers that have received create response 
Current watchers may have nextrev=0; check response count instead.
 2016-11-14 09:19:02 -08:00
Anthony Romano
6604306398 grpcproxy: support prevKV watcher 
Makes all server watchers PrevKV, discards if client watcher is not PrevKV.
 2016-11-11 14:22:06 -08:00
Anthony Romano
395cf7de51 grpcproxy: reject invalid watch ranges 2016-11-11 10:14:35 -08:00
Anthony Romano
ec459c2185 grpcproxy: rework watcher organization 
The single watcher / group watcher distinction limited and
complicated watcher coalescing more than necessary. Reworked:

Each server watcher is represented by a WatchBroadcast, each
client "Watcher" attaches to some WatchBroadcast. WatchBroadcasts
hold all WatchBroadcast instances for a range. WatchRanges holds
all WatchBroadcasts for the proxy.

WatchProxyStreams represent a grpc watch stream between the proxy and
a client. When a client requests a new watcher through its grpc stream,
the ProxyStream will allocate a Watcher and WatchRanges assigns it to
some WatchBroadcast based on its range.

Coalescing is done by WatchBroadcasts when it receives an update
notification from a WatchBroadcast.

Supports leader failure detection so watches on a bad member
can migrate to other members. Coincidentally, Fixes #6303.
 2016-11-11 10:14:35 -08:00
Anthony Romano
a4dcceb8aa grpcproxy: update cache based on txn response 
Fixes more hangs in TestSTMConflict.
 2016-11-09 12:11:38 -08:00
Anthony Romano
bf08a6142c grpcproxy: invalidate comparison keys after txn 
If the txn comparison block makes claims about a key's current
state, then it may say a key has been updated. Future range/txn
operations may expect this update to eventually be propagated through
the cluster and show up in serialized requests. To avoid spinning
forever on txn/serialized range loops, invalidate the comparison keys.
 2016-11-04 09:46:43 -07:00