Skip to content

Commit

Permalink
Simple logging and comment cleanup.
Browse files Browse the repository at this point in the history
  • Loading branch information
jkreps committed Feb 27, 2009
1 parent ed3bcb0 commit 2af7a88
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 5 deletions.
5 changes: 2 additions & 3 deletions src/java/voldemort/server/socket/SocketServer.java
Expand Up @@ -77,8 +77,7 @@ public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) {
logger.error("Too many open connections, " + executor.getActiveCount() + " of "
+ executor.getLargestPoolSize()
+ " threads in use, denying connection from "
+ session.getSocket().getRemoteSocketAddress() + ":"
+ session.getSocket().getPort());
+ session.getSocket().getRemoteSocketAddress());
try {
session.getSocket().close();
} catch(IOException e) {
Expand All @@ -92,7 +91,7 @@ public SocketServer(ConcurrentMap<String, ? extends Store<byte[], byte[]>> store
int defaultThreads,
int maxThreads) {
this.port = port;
this.threadGroup = new ThreadGroup("VoldemortRawSocketHandler");
this.threadGroup = new ThreadGroup("voldemort-socket-server");
this.storeMap = storeMap;
this.threadPool = new ThreadPoolExecutor(defaultThreads,
maxThreads,
Expand Down
4 changes: 2 additions & 2 deletions src/java/voldemort/server/storage/StorageService.java
Expand Up @@ -137,7 +137,7 @@ protected void startInner() {
Time time = new SystemTime();
for(StoreDefinition def: storeDefs) {
if(!def.getName().equals(MetadataStore.METADATA_STORE_NAME)) {
logger.info("Opening " + def.getName() + ".");
logger.info("Opening store '" + def.getName() + "'.");
StorageEngine<byte[], byte[]> engine = getStore(def.getName(), def.getType());
rawEngines.put(engine.getName(), engine);

Expand Down Expand Up @@ -221,7 +221,7 @@ protected void stopInner() {
logger.info("Closing stores:");
for(Store<byte[], byte[]> s: this.localStoreMap.values()) {
try {
logger.info("Closing " + s.getName() + ".");
logger.info("Closing store '" + s.getName() + "'.");
s.close();
} catch(VoldemortException e) {
// in the event of a failure still attempt to close other stores
Expand Down

0 comments on commit 2af7a88

Please sign in to comment.