Author: gdusbabek
Date: Fri May 21 19:36:05 2010
New Revision: 947137
URL: http://svn.apache.org/viewvc?rev=947137&view=rev
Log:
remove echo from nodetool.bat
Modified:
cassandra/branches/cassandra-0.6/bin/nodetool.bat
cassandra/branches/cassandra-0.6/conf/storage-conf.xml
cassandra/branches/cassandra-0.6/src/java/org/apache/cassandra/streaming/StreamOutManager.java
cassandra/branches/cassandra-0.6/src/java/org/apache/cassandra/streaming/StreamingService.java
Modified: cassandra/branches/cassandra-0.6/bin/nodetool.bat
URL:
http://svn.apache.org/viewvc/cassandra/branches/cassandra-0.6/bin/nodetool.bat?rev=947137&r1=947136&r2=947137&view=diff
==============================================================================
--- cassandra/branches/cassandra-0.6/bin/nodetool.bat (original)
+++ cassandra/branches/cassandra-0.6/bin/nodetool.bat Fri May 21 19:36:05 2010
@@ -39,7 +39,6 @@ goto runNodeTool
:runNodeTool
echo Starting NodeTool
-echo cp %CASSANDRA_CLASSPATH%
"%JAVA_HOME%\bin\java" -cp "%CASSANDRA_CLASSPATH%"
-Dstorage-config=%CASSANDRA_HOME%\conf\
-Dlog4j.configuration=log4j-tools.properties org.apache.cassandra.tools.NodeCmd
%*
goto finally
Modified: cassandra/branches/cassandra-0.6/conf/storage-conf.xml
URL:
http://svn.apache.org/viewvc/cassandra/branches/cassandra-0.6/conf/storage-conf.xml?rev=947137&r1=947136&r2=947137&view=diff
==============================================================================
--- cassandra/branches/cassandra-0.6/conf/storage-conf.xml (original)
+++ cassandra/branches/cassandra-0.6/conf/storage-conf.xml Fri May 21 19:36:05
2010
@@ -131,7 +131,7 @@
~ a different datacenter, and the others on different racks in the same
~ one.)
-->
-
<ReplicaPlacementStrategy>org.apache.cassandra.locator.RackUnawareStrategy</ReplicaPlacementStrategy>
+ <!--
<ReplicaPlacementStrategy>org.apache.cassandra.locator.RackUnawareStrategy</ReplicaPlacementStrategy>
-->
<!-- Number of replicas of the data -->
<ReplicationFactor>1</ReplicationFactor>
Modified:
cassandra/branches/cassandra-0.6/src/java/org/apache/cassandra/streaming/StreamOutManager.java
URL:
http://svn.apache.org/viewvc/cassandra/branches/cassandra-0.6/src/java/org/apache/cassandra/streaming/StreamOutManager.java?rev=947137&r1=947136&r2=947137&view=diff
==============================================================================
---
cassandra/branches/cassandra-0.6/src/java/org/apache/cassandra/streaming/StreamOutManager.java
(original)
+++
cassandra/branches/cassandra-0.6/src/java/org/apache/cassandra/streaming/StreamOutManager.java
Fri May 21 19:36:05 2010
@@ -78,6 +78,11 @@ public class StreamOutManager
return hosts;
}
+ public static Set<InetAddress> getDestinationsWaiting()
+ {
+ return new HashSet<InetAddress>(pendingDestinations);
+ }
+
/**
* this method exists so that we don't have to call StreamOutManager.get()
which has a nasty side-effect of
* indicating that we are streaming to a particular host.
Modified:
cassandra/branches/cassandra-0.6/src/java/org/apache/cassandra/streaming/StreamingService.java
URL:
http://svn.apache.org/viewvc/cassandra/branches/cassandra-0.6/src/java/org/apache/cassandra/streaming/StreamingService.java?rev=947137&r1=947136&r2=947137&view=diff
==============================================================================
---
cassandra/branches/cassandra-0.6/src/java/org/apache/cassandra/streaming/StreamingService.java
(original)
+++
cassandra/branches/cassandra-0.6/src/java/org/apache/cassandra/streaming/StreamingService.java
Fri May 21 19:36:05 2010
@@ -51,24 +51,43 @@ public class StreamingService implements
public String getStatus()
{
StringBuilder sb = new StringBuilder();
- sb.append("Receiving from:\n");
- for (InetAddress source : StreamInManager.getSources())
+
+ Set<InetAddress> sources = StreamInManager.getSources();
+ if (sources.size() > 0)
{
- sb.append(String.format(" %s:\n", source.getHostAddress()));
- for (PendingFile pf : StreamInManager.getIncomingFiles(source))
+ sb.append("Receiving from:\n");
+ for (InetAddress source : sources)
{
- sb.append(String.format(" %s %d/%d\n", pf.getTargetFile(),
pf.getPtr(), pf.getExpectedBytes()));
+ sb.append(String.format(" %s:\n", source.getHostAddress()));
+ for (PendingFile pf : StreamInManager.getIncomingFiles(source))
+ {
+ sb.append(String.format(" %s %d/%d\n",
pf.getTargetFile(), pf.getPtr(), pf.getExpectedBytes()));
+ }
}
}
- sb.append("Sending to:\n");
- for (InetAddress dest : StreamOutManager.getDestinations())
+
+ Set<InetAddress> destinations = StreamOutManager.getDestinations();
+ if (destinations.size() > 0)
{
- sb.append(String.format(" %s:\n", dest.getHostAddress()));
- for (PendingFile pf : StreamOutManager.getPendingFiles(dest))
+ sb.append("Sending to:\n");
+ for (InetAddress dest : destinations)
{
- sb.append(String.format(" %s %d/%d\n", pf.getTargetFile(),
pf.getPtr(), pf.getExpectedBytes()));
+ sb.append(String.format(" %s:\n", dest.getHostAddress()));
+ for (PendingFile pf : StreamOutManager.getPendingFiles(dest))
+ {
+ sb.append(String.format(" %s %d/%d\n",
pf.getTargetFile(), pf.getPtr(), pf.getExpectedBytes()));
+ }
}
}
+
+ Set<InetAddress> waiting = StreamOutManager.getDestinationsWaiting();
+ if (waiting.size() > 0)
+ {
+ sb.append("Destinations waiting for anticompaction:\n");
+ for (InetAddress dest : waiting)
+ sb.append(String.format(" %s\n", dest.getHostAddress()));
+ }
+
return sb.toString();
}
