import Extensions.*;
public class Server {
static int
serverDelay = 0;
static boolean DEBUG = false;
static boolean KILL = false;
public static void main(String[] argv) throws Exception {
Thread t;
if (System.getSecurityManager() == null)
System.setSecurityManager(new RMISecurityManager());
if (argv.length > 0)
serverDelay = Integer.parseInt(argv[0]);
if (System.getProperty("DEBUG") != null)
DEBUG = true;
if (System.getProperty("KILL") != null)
KILL = true;
System.out.println("Server(serverDelay: " + serverDelay +
")");
if (KILL)
new Thread(new Killer(120)).start();
Naming.rebind("Frobber", new ServerImpl());
System.out.println("Server: 'Frobber' now registered with
rmiregistry.");
}
}
//
ServerRMI/Client.java
import Extensions.*;
import java.rmi.*;
import java.rmi.server.*;
public class Client implements Runnable {
static boolean
DEBUG = false;
String
name;
static int
nCalls = 100;
static int
nThreads = 2;
static int
clientDelay = 10;
static SingleBarrier barrier;
static boolean
KILL = false;
public static void main(String[] argv) {
if (System.getSecurityManager() == null)
System.setSecurityManager(new RMISecurityManager());
if (argv.length > 0)
nCalls = Integer.parseInt(argv[0]);
if (argv.length > 1)
nThreads = Integer.parseInt(argv[1]);
Search WWH :
