Return-Path: X-Original-To: apmail-cassandra-commits-archive@www.apache.org Delivered-To: apmail-cassandra-commits-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id C7A5DF9EA for ; Sat, 5 Oct 2013 02:53:28 +0000 (UTC) Received: (qmail 61301 invoked by uid 500); 5 Oct 2013 02:53:20 -0000 Delivered-To: apmail-cassandra-commits-archive@cassandra.apache.org Received: (qmail 61246 invoked by uid 500); 5 Oct 2013 02:53:19 -0000 Mailing-List: contact commits-help@cassandra.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@cassandra.apache.org Delivered-To: mailing list commits@cassandra.apache.org Received: (qmail 61201 invoked by uid 99); 5 Oct 2013 02:53:16 -0000 Received: from tyr.zones.apache.org (HELO tyr.zones.apache.org) (140.211.11.114) by apache.org (qpsmtpd/0.29) with ESMTP; Sat, 05 Oct 2013 02:53:16 +0000 Received: by tyr.zones.apache.org (Postfix, from userid 65534) id 7AD8991055E; Sat, 5 Oct 2013 02:53:16 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: jbellis@apache.org To: commits@cassandra.apache.org Date: Sat, 05 Oct 2013 02:53:20 -0000 Message-Id: <951ce328b76746729d44be39d4af1c85@git.apache.org> In-Reply-To: <67ee1d77564c4e7d91625a2f8db95446@git.apache.org> References: <67ee1d77564c4e7d91625a2f8db95446@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [5/6] git commit: merge from 1.2 merge from 1.2 Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/27967f95 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/27967f95 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/27967f95 Branch: refs/heads/cassandra-2.0 Commit: 27967f95b85b659aedb535946dabb04979bce600 Parents: 6529d73 5b7dd5e Author: Jonathan Ellis Authored: Fri Oct 4 21:53:02 2013 -0500 Committer: Jonathan Ellis Committed: Fri Oct 4 21:53:02 2013 -0500 ---------------------------------------------------------------------- CHANGES.txt | 1 + .../apache/cassandra/metrics/ClientMetrics.java | 35 ++++++++++++++++++ .../cassandra/thrift/CassandraServer.java | 18 ++++++++-- .../cassandra/thrift/ThriftSessionManager.java | 5 +++ .../org/apache/cassandra/transport/Server.java | 37 ++++++++++++++------ 5 files changed, 84 insertions(+), 12 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cassandra/blob/27967f95/CHANGES.txt ---------------------------------------------------------------------- diff --cc CHANGES.txt index 6a7c3fe,5af4e2e..1590dd0 --- a/CHANGES.txt +++ b/CHANGES.txt @@@ -34,43 -12,10 +34,44 @@@ Merged from 1.2 * Fix fat client schema pull NPE (CASSANDRA-6089) * Fix memtable flushing for indexed tables (CASSANDRA-6112) * Fix skipping columns with multiple slices (CASSANDRA-6119) + * Expose connected thrift + native client counts (CASSANDRA-5084) -1.2.10 +2.0.1 + * Fix bug that could allow reading deleted data temporarily (CASSANDRA-6025) + * Improve memory use defaults (CASSANDRA-5069) + * Make ThriftServer more easlly extensible (CASSANDRA-6058) + * Remove Hadoop dependency from ITransportFactory (CASSANDRA-6062) + * add file_cache_size_in_mb setting (CASSANDRA-5661) + * Improve error message when yaml contains invalid properties (CASSANDRA-5958) + * Improve leveled compaction's ability to find non-overlapping L0 compactions + to work on concurrently (CASSANDRA-5921) + * Notify indexer of columns shadowed by range tombstones (CASSANDRA-5614) + * Log Merkle tree stats (CASSANDRA-2698) + * Switch from crc32 to adler32 for compressed sstable checksums (CASSANDRA-5862) + * Improve offheap memcpy performance (CASSANDRA-5884) + * Use a range aware scanner for cleanup (CASSANDRA-2524) + * Cleanup doesn't need to inspect sstables that contain only local data + (CASSANDRA-5722) + * Add ability for CQL3 to list partition keys (CASSANDRA-4536) + * Improve native protocol serialization (CASSANDRA-5664) + * Upgrade Thrift to 0.9.1 (CASSANDRA-5923) + * Require superuser status for adding triggers (CASSANDRA-5963) + * Make standalone scrubber handle old and new style leveled manifest + (CASSANDRA-6005) + * Fix paxos bugs (CASSANDRA-6012, 6013, 6023) + * Fix paged ranges with multiple replicas (CASSANDRA-6004) + * Fix potential AssertionError during tracing (CASSANDRA-6041) + * Fix NPE in sstablesplit (CASSANDRA-6027) + * Migrate pre-2.0 key/value/column aliases to system.schema_columns + (CASSANDRA-6009) + * Paging filter empty rows too agressively (CASSANDRA-6040) + * Support variadic parameters for IN clauses (CASSANDRA-4210) + * cqlsh: return the result of CAS writes (CASSANDRA-5796) + * Fix validation of IN clauses with 2ndary indexes (CASSANDRA-6050) + * Support named bind variables in CQL (CASSANDRA-6033) +Merged from 1.2: + * Allow cache-keys-to-save to be set at runtime (CASSANDRA-5980) * Avoid second-guessing out-of-space state (CASSANDRA-5605) * Tuning knobs for dealing with large blobs and many CFs (CASSANDRA-5982) * (Hadoop) Fix CQLRW for thrift tables (CASSANDRA-6002) http://git-wip-us.apache.org/repos/asf/cassandra/blob/27967f95/src/java/org/apache/cassandra/thrift/CassandraServer.java ---------------------------------------------------------------------- diff --cc src/java/org/apache/cassandra/thrift/CassandraServer.java index 3d77743,65ae177..12176b7 --- a/src/java/org/apache/cassandra/thrift/CassandraServer.java +++ b/src/java/org/apache/cassandra/thrift/CassandraServer.java @@@ -47,16 -44,18 +48,17 @@@ import org.apache.cassandra.cql3.QueryO import org.apache.cassandra.db.*; import org.apache.cassandra.db.context.CounterContext; import org.apache.cassandra.db.filter.IDiskAtomFilter; -import org.apache.cassandra.db.filter.QueryPath; -import org.apache.cassandra.db.marshal.MarshalException; +import org.apache.cassandra.db.filter.NamesQueryFilter; +import org.apache.cassandra.db.filter.SliceQueryFilter; +import org.apache.cassandra.db.marshal.CompositeType; - import org.apache.cassandra.serializers.MarshalException; import org.apache.cassandra.db.marshal.TimeUUIDType; import org.apache.cassandra.dht.*; -import org.apache.cassandra.exceptions.ReadTimeoutException; -import org.apache.cassandra.exceptions.RequestExecutionException; -import org.apache.cassandra.exceptions.RequestValidationException; -import org.apache.cassandra.exceptions.UnauthorizedException; +import org.apache.cassandra.exceptions.*; import org.apache.cassandra.io.util.DataOutputBuffer; import org.apache.cassandra.locator.DynamicEndpointSnitch; + import org.apache.cassandra.metrics.ClientMetrics; import org.apache.cassandra.scheduler.IRequestScheduler; ++import org.apache.cassandra.serializers.MarshalException; import org.apache.cassandra.service.ClientState; import org.apache.cassandra.service.MigrationManager; import org.apache.cassandra.service.StorageProxy; @@@ -1958,7 -1734,7 +1961,7 @@@ public class CassandraServer implement try { ThriftClientState cState = state(); -- String queryString = uncompress(query,compression); ++ String queryString = uncompress(query, compression); return QueryProcessor.prepare(queryString, cState); } catch (RequestValidationException e) http://git-wip-us.apache.org/repos/asf/cassandra/blob/27967f95/src/java/org/apache/cassandra/thrift/ThriftSessionManager.java ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cassandra/blob/27967f95/src/java/org/apache/cassandra/transport/Server.java ---------------------------------------------------------------------- diff --cc src/java/org/apache/cassandra/transport/Server.java index 5ac4a70,0ffb92b..bd403fe --- a/src/java/org/apache/cassandra/transport/Server.java +++ b/src/java/org/apache/cassandra/transport/Server.java @@@ -30,23 -31,14 +31,16 @@@ import javax.net.ssl.SSLEngine import org.slf4j.Logger; import org.slf4j.LoggerFactory; +import org.apache.cassandra.auth.IAuthenticator; +import org.apache.cassandra.auth.ISaslAwareAuthenticator; import org.apache.cassandra.config.DatabaseDescriptor; import org.apache.cassandra.config.EncryptionOptions; + import org.apache.cassandra.metrics.ClientMetrics; import org.apache.cassandra.security.SSLFactory; - import org.apache.cassandra.service.CassandraDaemon; - import org.apache.cassandra.service.IEndpointLifecycleSubscriber; - import org.apache.cassandra.service.IMigrationListener; - import org.apache.cassandra.service.MigrationManager; - import org.apache.cassandra.service.StorageService; + import org.apache.cassandra.service.*; import org.apache.cassandra.transport.messages.EventMessage; import org.jboss.netty.bootstrap.ServerBootstrap; - import org.jboss.netty.channel.Channel; - import org.jboss.netty.channel.ChannelFactory; - import org.jboss.netty.channel.ChannelPipeline; - import org.jboss.netty.channel.ChannelPipelineFactory; - import org.jboss.netty.channel.Channels; + import org.jboss.netty.channel.*; import org.jboss.netty.channel.group.ChannelGroup; import org.jboss.netty.channel.group.DefaultChannelGroup; import org.jboss.netty.channel.socket.nio.NioServerSocketChannelFactory;