| /* |
| * Licensed to the Apache Software Foundation (ASF) under one or more contributor license |
| * agreements. See the NOTICE file distributed with this work for additional information regarding |
| * copyright ownership. The ASF licenses this file to You under the Apache License, Version 2.0 (the |
| * "License"); you may not use this file except in compliance with the License. You may obtain a |
| * copy of the License at |
| * |
| * http://www.apache.org/licenses/LICENSE-2.0 |
| * |
| * Unless required by applicable law or agreed to in writing, software distributed under the License |
| * is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express |
| * or implied. See the License for the specific language governing permissions and limitations under |
| * the License. |
| */ |
| package org.apache.geode_examples.transaction; |
| |
| import org.apache.geode.cache.Region; |
| import org.apache.geode.cache.client.ClientCache; |
| import org.apache.geode.cache.client.ClientCacheFactory; |
| import org.apache.geode.cache.client.ClientRegionFactory; |
| import org.apache.geode.cache.client.ClientRegionShortcut; |
| |
| import java.io.File; |
| import java.io.IOException; |
| import java.util.HashMap; |
| import java.util.Map; |
| |
| public class Example { |
| public static final int INCREMENTS = 1000; |
| |
| public static final String REGION_NAME = "example-region"; |
| |
| public static final String KEY = "counter"; |
| |
| final Region<String, Integer> region; |
| |
| final Map<Integer, Process> children = new HashMap<>(); |
| |
| static String constructJVMPath() { |
| StringBuilder builder = new StringBuilder(); |
| builder.append(System.getProperty("java.home")); |
| builder.append(File.separator); |
| builder.append("bin"); |
| builder.append(File.separator); |
| builder.append("java"); |
| if (System.getProperty("os.name").toLowerCase().contains("win")) { |
| builder.append("w.exe"); |
| } |
| return builder.toString(); |
| } |
| |
| public static void main(String[] args) { |
| // connect to the locator using default port 10334 |
| ClientCache cache = new ClientCacheFactory().addPoolLocator("127.0.0.1", 10334) |
| .set("log-level", "WARN").create(); |
| |
| // create a local region that matches the server region |
| ClientRegionFactory<String, Integer> clientRegionFactory = |
| cache.createClientRegionFactory(ClientRegionShortcut.PROXY); |
| Region<String, Integer> region = clientRegionFactory.create(REGION_NAME); |
| |
| Example example = new Example(region); |
| example.initializeEntry(); |
| example.executeChildProcesses(5); |
| |
| cache.close(); |
| } |
| |
| Example(Region<String, Integer> region) { |
| this.region = region; |
| } |
| |
| void executeChildProcess(int id) { |
| String[] command = new String[5]; |
| command[0] = constructJVMPath(); |
| command[1] = "-classpath"; |
| command[2] = System.getProperty("java.class.path") + ":build/libs/transaction.jar"; |
| command[3] = "org.apache.geode_examples.transaction.Incrementer"; |
| command[4] = Integer.toString(id); |
| try { |
| children.put(id, Runtime.getRuntime().exec(command)); |
| System.out.println("Executed child " + id); |
| } catch (IOException ioe) { |
| ioe.printStackTrace(); |
| } |
| } |
| |
| void executeChildProcesses(int numberOfIncrementers) { |
| System.out.println("Expected value of counter: " + (numberOfIncrementers * INCREMENTS)); |
| |
| for (int i = 0; i < numberOfIncrementers; ++i) { |
| executeChildProcess(i + 1); |
| } |
| |
| for (Map.Entry<Integer, Process> child : children.entrySet()) { |
| System.out.println("Waiting for " + child.getKey() + "..."); |
| try { |
| child.getValue().waitFor(); |
| System.out.println("Reaped child " + child.getKey()); |
| } catch (InterruptedException ie) { |
| ie.printStackTrace(); |
| } |
| } |
| |
| System.out.println("Actual value of counter: " + region.get(KEY)); |
| } |
| |
| void initializeEntry() { |
| region.put(KEY, 0); |
| } |
| } |