diff options
Diffstat (limited to 'java/demo/book/simple_filesystem/Server.java')
-rw-r--r-- | java/demo/book/simple_filesystem/Server.java | 33 |
1 files changed, 25 insertions, 8 deletions
diff --git a/java/demo/book/simple_filesystem/Server.java b/java/demo/book/simple_filesystem/Server.java index aefca791431..4889a6e47ab 100644 --- a/java/demo/book/simple_filesystem/Server.java +++ b/java/demo/book/simple_filesystem/Server.java @@ -9,41 +9,51 @@ import Filesystem.*; -public class Server extends Ice.Application { +public class Server extends Ice.Application +{ public int run(String[] args) { + // // Terminate cleanly on receipt of a signal // shutdownOnInterrupt(); + // // Create an object adapter. // - Ice.ObjectAdapter adapter = communicator().createObjectAdapterWithEndpoints( - "SimpleFilesystem", "default -h 127.0.0.1 -p 10000"); + Ice.ObjectAdapter adapter = + communicator().createObjectAdapterWithEndpoints("SimpleFilesystem", "default -h 127.0.0.1 -p 10000"); + // // Create the root directory (with name "/" and no parent) // DirectoryI root = new DirectoryI(communicator(), "/", null); root.activate(adapter); + // // Create a file called "README" in the root directory // FileI file = new FileI(communicator(), "README", root); String[] text; text = new String[]{ "This file system contains a collection of poetry." }; - try { + try + { file.write(text, null); - } catch (GenericError e) { + } + catch(GenericError e) + { System.err.println(e.reason); } file.activate(adapter); + // // Create a directory called "Coleridge" in the root directory // DirectoryI coleridge = new DirectoryI(communicator(), "Coleridge", root); coleridge.activate(adapter); + // // Create a file called "Kubla_Khan" in the Coleridge directory // file = new FileI(communicator(), "Kubla_Khan", coleridge); @@ -52,23 +62,30 @@ public class Server extends Ice.Application { "Where Alph, the sacred river, ran", "Through caverns measureless to man", "Down to a sunless sea." }; - try { + try + { file.write(text, null); - } catch (GenericError e) { + } + catch(GenericError e) + { System.err.println(e.reason); } file.activate(adapter); + // // All objects are created, allow client requests now // adapter.activate(); + // // Wait until we are done // communicator().waitForShutdown(); - if (interrupted()) + if(interrupted()) + { System.err.println(appName() + ": terminating"); + } return 0; } |