fc518cbb6a
add primitive get_range_slice. inefficient, but better than get_key_range + get_slices.
...
patch by gdusbabek; reviewed by jbellis for CASSANDRA-344
git-svn-id: https://svn.apache.org/repos/asf/incubator/cassandra/trunk@881998 13f79535-47bb-0310-9956-ffa450edef68
2009-11-18 23:27:14 +00:00
e972ec8dfe
add license headers. patch by jbellis
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/cassandra/trunk@881384 13f79535-47bb-0310-9956-ffa450edef68
2009-11-17 17:19:40 +00:00
6c37fb8b73
rename
...
patch by jbellis; reviewed by Jaakko Laine for CASSANDRA-558
git-svn-id: https://svn.apache.org/repos/asf/incubator/cassandra/trunk@881282 13f79535-47bb-0310-9956-ffa450edef68
2009-11-17 13:34:13 +00:00
a5bd08f421
add WriteResponseHandler combining the important parts of QuorumResponseHandler and WriteResponseResolver.
...
In particular, not thate we (correctly) never send a write response of false, letting the timeout take care
of that should-never-happen case. optimize local writes in insertBlocking, and fix HH.
patch by jbellis; reviewed by Jaakko Laine for CASSANDRA-558
git-svn-id: https://svn.apache.org/repos/asf/incubator/cassandra/trunk@881281 13f79535-47bb-0310-9956-ffa450edef68
2009-11-17 13:34:06 +00:00
f57ac0d959
make local insert() skip MessagingService and fix HH write
...
patch by jbellis; reviewed by Jaakko Laine for CASSANDRA-558
git-svn-id: https://svn.apache.org/repos/asf/incubator/cassandra/trunk@881280 13f79535-47bb-0310-9956-ffa450edef68
2009-11-17 13:33:53 +00:00
d5cdd6d043
r/m redundant interface IMessagingService. patch by jbellis
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/cassandra/trunk@880926 13f79535-47bb-0310-9956-ffa450edef68
2009-11-16 19:37:12 +00:00
b7a1c44333
r/m underscores. patch by jbellis
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/cassandra/trunk@880924 13f79535-47bb-0310-9956-ffa450edef68
2009-11-16 19:37:07 +00:00
43bf9e237c
add nodeprobe cancelpending
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/cassandra/trunk@880918 13f79535-47bb-0310-9956-ffa450edef68
2009-11-16 19:25:20 +00:00
6691b2c295
multithread recovery
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/cassandra/trunk@880889 13f79535-47bb-0310-9956-ffa450edef68
2009-11-16 18:22:14 +00:00
f1279e9618
add getSortedApplicationStates to preserve state ordering when re-gossiping to other nodes. patch by Jaakko Laine; reviewed by jbellis for CASSANDRA-548
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/cassandra/trunk@880772 13f79535-47bb-0310-9956-ffa450edef68
2009-11-16 14:31:47 +00:00
64c6a9cf1e
remove duplicated configuration directive
...
Patch by eevans for CASSANDRA-557
git-svn-id: https://svn.apache.org/repos/asf/incubator/cassandra/trunk@836381 13f79535-47bb-0310-9956-ffa450edef68
2009-11-15 17:44:17 +00:00
58f585f605
minor cleanup. patch by jbellis
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/cassandra/trunk@836337 13f79535-47bb-0310-9956-ffa450edef68
2009-11-15 08:06:32 +00:00
0801f420e5
nodeprobe loadbalance
...
patch by jbellis; reviewed by goffinet for CASSANDRA-192
git-svn-id: https://svn.apache.org/repos/asf/incubator/cassandra/trunk@836295 13f79535-47bb-0310-9956-ffa450edef68
2009-11-14 23:49:55 +00:00
050752c703
Fixed multi-get to put localCommands onto the StorageService.readStage when a node gets commands to process, instead of running them serially.
...
patch by goffinet, minor cleanup and review by jbellis for CASSANDRA-555
git-svn-id: https://svn.apache.org/repos/asf/incubator/cassandra/trunk@836264 13f79535-47bb-0310-9956-ffa450edef68
2009-11-14 21:05:56 +00:00
ceea0afc83
update CHANGES
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/cassandra/trunk@836010 13f79535-47bb-0310-9956-ffa450edef68
2009-11-13 21:49:41 +00:00
f31e5779de
make iterator closeable, again
...
patch by jbellis; tested by "elsif" for CASSANDRA-552
git-svn-id: https://svn.apache.org/repos/asf/incubator/cassandra/trunk@835999 13f79535-47bb-0310-9956-ffa450edef68
2009-11-13 21:26:53 +00:00
483bb4f367
add user config to search path (like daemon start script)
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/cassandra/trunk@835991 13f79535-47bb-0310-9956-ffa450edef68
2009-11-13 21:13:38 +00:00
b2b4260c68
gracefully handle missing keyspace argument (cli)
...
Patch by Hafsteinn Baldvinsson; reviewed by eevans for CASSANDRA-551
git-svn-id: https://svn.apache.org/repos/asf/incubator/cassandra/trunk@835990 13f79535-47bb-0310-9956-ffa450edef68
2009-11-13 21:13:31 +00:00
b5f3263839
specifically look for TOKEN and GENERATION columns
...
patch by jbellis; tested by Ray Slakinski for CASSANDRA-550
git-svn-id: https://svn.apache.org/repos/asf/incubator/cassandra/trunk@835987 13f79535-47bb-0310-9956-ffa450edef68
2009-11-13 21:00:44 +00:00
266e94f320
clean up temporary for-streaming files when done
...
patch by jbellis; tested by Ray Slakinski for CASSANDRA-550
git-svn-id: https://svn.apache.org/repos/asf/incubator/cassandra/trunk@835986 13f79535-47bb-0310-9956-ffa450edef68
2009-11-13 21:00:39 +00:00
185d436fdb
windows start script for cassandra cli
...
Patch by Dirk Weber; reviewed by eevans for CASSANDRA-549
git-svn-id: https://svn.apache.org/repos/asf/incubator/cassandra/trunk@835939 13f79535-47bb-0310-9956-ffa450edef68
2009-11-13 17:50:26 +00:00
f21052e916
workaround for "Resource temporarily unavailable"
...
patch by jbellis; reviewed by Jaakko Laine for CASSANDRA-541
git-svn-id: https://svn.apache.org/repos/asf/incubator/cassandra/trunk@835892 13f79535-47bb-0310-9956-ffa450edef68
2009-11-13 15:57:38 +00:00
e734d837a0
fix for when bootstrap source has no data in the range requested
...
patch by jbellis; reviewed by Jaakko Laine for CASSANDRA-541
git-svn-id: https://svn.apache.org/repos/asf/incubator/cassandra/trunk@835891 13f79535-47bb-0310-9956-ffa450edef68
2009-11-13 15:57:34 +00:00
f3cdaa96b7
add Move command
...
patch by jbellis; reviewed by Jaakko Laine for CASSANDRA-541
git-svn-id: https://svn.apache.org/repos/asf/incubator/cassandra/trunk@835890 13f79535-47bb-0310-9956-ffa450edef68
2009-11-13 15:57:31 +00:00
6ede8c5d91
fix misleading comment. patch by jbellis for CASSANDRA-545
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/cassandra/trunk@835873 13f79535-47bb-0310-9956-ffa450edef68
2009-11-13 15:18:31 +00:00
01a2b07711
force bind to correct address
...
patch by jbellis; reviewed by Ray Slakinski for CASSANDRA-546
git-svn-id: https://svn.apache.org/repos/asf/incubator/cassandra/trunk@835711 13f79535-47bb-0310-9956-ffa450edef68
2009-11-13 02:34:31 +00:00
183f51dc21
r/m unused bootstrap directory and ensure streaming files live to be streamed
...
patch by jbellis; reviewed by Jun Rao for CASSANDRA-538
git-svn-id: https://svn.apache.org/repos/asf/incubator/cassandra/trunk@835446 13f79535-47bb-0310-9956-ffa450edef68
2009-11-12 17:03:52 +00:00
0485f532a4
tokenMetadata should be updated before removing obsolete pending ranges, and unset bootstrapped flag when decommission is complete. patch by Jaakko Laine and jbellis for CASSANDRA-435
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/cassandra/trunk@835413 13f79535-47bb-0310-9956-ffa450edef68
2009-11-12 15:26:17 +00:00
2b8c1cec9a
avoid making local node part of the token ring until bootstrap completes; fix other buglets
...
patch by jbellis; reviewed by Jaakko Laine for CASSANDRA-536
git-svn-id: https://svn.apache.org/repos/asf/incubator/cassandra/trunk@835213 13f79535-47bb-0310-9956-ffa450edef68
2009-11-12 03:37:15 +00:00
1bf797b943
various improvements to stress.py (see issue comments). patch by Scott White; reviewed by Brandon Williams for CASSANDRA-542
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/cassandra/trunk@835196 13f79535-47bb-0310-9956-ffa450edef68
2009-11-12 02:20:41 +00:00
4c877f9124
parallelize post-recovery flushes.
...
patch by jbellis; reviewed by Brandon Williams for CASSANDRA-539
git-svn-id: https://svn.apache.org/repos/asf/incubator/cassandra/trunk@834995 13f79535-47bb-0310-9956-ffa450edef68
2009-11-11 18:10:55 +00:00
50b67f50af
simplify getChangedRangesForLeaving. patch by Jaakko Laine; reviewed by jbellis for CASSANDRA-435
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/cassandra/trunk@834945 13f79535-47bb-0310-9956-ffa450edef68
2009-11-11 16:23:41 +00:00
542accc65b
add leaving mode
...
patch by jbellis; reviewed by Jaakko Laine for CASSANDRA-435
git-svn-id: https://svn.apache.org/repos/asf/incubator/cassandra/trunk@834940 13f79535-47bb-0310-9956-ffa450edef68
2009-11-11 16:12:15 +00:00
d0db57ad10
move more generic streaming code into Streaming.java
...
patch by jbellis; reviewed by Jaakko Laine for CASSANDRA-435
git-svn-id: https://svn.apache.org/repos/asf/incubator/cassandra/trunk@834939 13f79535-47bb-0310-9956-ffa450edef68
2009-11-11 16:11:44 +00:00
321848d09c
clean up transfer code from BMVH; move to Streaming.java
...
patch by jbellis; reviewed by Jaakko Laine for CASSANDRA-435
git-svn-id: https://svn.apache.org/repos/asf/incubator/cassandra/trunk@834937 13f79535-47bb-0310-9956-ffa450edef68
2009-11-11 16:11:36 +00:00
93c5afa5c9
r/m unused storageport from ReplicationStrategies. patch by jbellis
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/cassandra/trunk@834920 13f79535-47bb-0310-9956-ffa450edef68
2009-11-11 15:48:45 +00:00
a905e9b3bc
generify AbstractReplicationStrategy construction. patch by jbellis
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/cassandra/trunk@834912 13f79535-47bb-0310-9956-ffa450edef68
2009-11-11 15:34:40 +00:00
a0f620e124
really delete BasicUtilities.java (CASSANDRA-516)
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/cassandra/trunk@834494 13f79535-47bb-0310-9956-ffa450edef68
2009-11-10 15:15:51 +00:00
4d44ddfc99
merge with cassandra-0.4 branch
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/cassandra/trunk@834351 13f79535-47bb-0310-9956-ffa450edef68
2009-11-10 05:18:54 +00:00
d97be8f5e4
merge with cassandra-0.4 branch
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/cassandra/trunk@834241 13f79535-47bb-0310-9956-ffa450edef68
2009-11-09 21:18:57 +00:00
07ad40f249
fix broken functional test (expect Super3 in list of CFs)
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/cassandra/trunk@834186 13f79535-47bb-0310-9956-ffa450edef68
2009-11-09 19:32:14 +00:00
b294cd555a
consolodate BasicUtilities and FBUtilities
...
Patch by Gary Dusbabek; reviewed by eevans for CASSANDRA-516
git-svn-id: https://svn.apache.org/repos/asf/incubator/cassandra/trunk@834185 13f79535-47bb-0310-9956-ffa450edef68
2009-11-09 19:32:09 +00:00
c9a6b7de39
check for live-ness and throw UnavailableException if quorum is unsatisfyable.
...
patch by jbellis; reviewed by Ray Slakinski for CASSANDRA-441
git-svn-id: https://svn.apache.org/repos/asf/incubator/cassandra/trunk@834164 13f79535-47bb-0310-9956-ffa450edef68
2009-11-09 18:15:46 +00:00
8f85a51e64
Use getHostAddress instead of toString(), Read Repair was throwing an Exception. Patch by sammyyu, reviewed by jbellis for CASSANDRA-529
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/cassandra/trunk@834152 13f79535-47bb-0310-9956-ffa450edef68
2009-11-09 17:26:30 +00:00
580ac7d708
clean out unused code from TcpConnectionManager; split connections to a node into "command" and "ack", which will allow us to use backpressure on the command socket. patch by gdusbabek; reviewed by jbellis for CASSANDRA-488
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/cassandra/trunk@834143 13f79535-47bb-0310-9956-ffa450edef68
2009-11-09 16:57:08 +00:00
3d6d023e68
merge from 0.4
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/cassandra/trunk@833785 13f79535-47bb-0310-9956-ffa450edef68
2009-11-08 00:44:20 +00:00
5d447035ba
containing isBootstrapping and BootstrapTokenAddress information in TokenMetadata is the wrong level of abstraction. Switch to pendingRanges instead.
...
patch by jbellis and Jaakko Laine for CASSANDRA-525
git-svn-id: https://svn.apache.org/repos/asf/incubator/cassandra/trunk@833579 13f79535-47bb-0310-9956-ffa450edef68
2009-11-06 22:17:26 +00:00
d6977789cd
split out onJoin from onChange, so we can pass a single ApplicationState object to onChange to emphasize that it gets called once per AS; rename ApplicationState.getState -> getValue
...
patch by jbellis; reviewed by Jaakko Laine for CASSANDRA-525
git-svn-id: https://svn.apache.org/repos/asf/incubator/cassandra/trunk@833578 13f79535-47bb-0310-9956-ffa450edef68
2009-11-06 22:17:18 +00:00
1e7b673cbe
make sortedtokens passably efficient
...
patch by jbellis; reviewed by Jaakko Laine for CASSANDRA-525
git-svn-id: https://svn.apache.org/repos/asf/incubator/cassandra/trunk@833577 13f79535-47bb-0310-9956-ffa450edef68
2009-11-06 22:17:14 +00:00
b3b58932f3
fix TODO in tokenmetadata (bootstrap tokens aren't part of the official ring now). r/m redundant getNextEndPoint method in favor of getSuccessor
...
patch by jbellis; reviewed by Jaakko Laine for CASSANDRA-525
git-svn-id: https://svn.apache.org/repos/asf/incubator/cassandra/trunk@833576 13f79535-47bb-0310-9956-ffa450edef68
2009-11-06 22:17:09 +00:00
Jonathan Ellis