v = rq.dequeue();
- assert v.size() == 2;
-
- assert v.get(0).equals("hello");
- assert v.get(1).equals("world");
- assert rq.empty();
-
- v.remove();
-
- rq.enqueue(v);
- assert !rq.empty();
-
- v = rq.dequeue();
- assert v.size() == 1;
- assert v.get(0).equals("world");
- }
-}
diff --git a/java/common/src/com/google/airbag/common/ReportStorage.java b/java/common/src/com/google/airbag/common/ReportStorage.java
deleted file mode 100644
index 0c01281c..00000000
--- a/java/common/src/com/google/airbag/common/ReportStorage.java
+++ /dev/null
@@ -1,134 +0,0 @@
-/* Copyright (C) 2006 Google Inc.
-
-Licensed 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 com.google.airbag.common;
-
-import java.io.InputStream;
-import java.io.IOException;
-import java.io.FileNotFoundException;
-
-import java.util.SortedMap;
-
-/**
- * ReportStorage.java
- *
- *
- * Provide an abstract layer for storing crash reports and associated meta
- * data.
- *
- *
- *
- * The interface is intended to be used by a client in the following way:
- *
- *
- * ReportStorage rs = new ReportStorageImpl(...);
- * // Write an uploading file to a storage
- * try {
- * String rid = rs.getUniqueId(attributes); // params from URL
- * rs.saveAttributes(id, attributes);
- * if (!rs.reportExists(rid) || allowOverwrite)
- * rs.writeStreamToReport(rid, input, 0);
- * else
- * rs.appendStreamToReport(rid, input, 0);
- * } catch (...)
- *
- * // Read a file from the storage
- * try {
- * OutputStream os = fs.openReportForRead(fid);
- * os.read(...);
- * os.close();
- * } catch (...)
- *
- */
-
-public interface ReportStorage {
- /**
- * Given a sorted map of attributes (name and value), returns a unique id
- * of the crash report.
- *
- * @param params a sorted map from name to value
- * @return a string as the file id
- */
- public String getUniqueId(SortedMap params);
-
- /**
- * Given a report id, checks if the report data AND attributes identified
- * by this id exists on the storage.
- *
- * @param id a report id
- * @return true if the id represents an existing file
- */
- public boolean reportExists(String id);
-
- /**
- * Given a report id and a sorted map of attributes, saves attributes on
- * the storage.
- *
- * @param id a report id
- * @param attrs attributes associated with this id
- * @return true if attributes are saved successfully
- */
- public boolean saveAttributes(String id, SortedMap attrs);
-
- /**
- * Given a report id, returns attributes associated with this report.
- *
- * @param id a report id
- * @return a sorted map from name to value
- * @throws FileNotFoundException if fileExists(id) returns false
- */
- public SortedMap getAttributes(String id)
- throws FileNotFoundException;
-
- /**
- * Writes max bytes from an input stream to a report identified by
- * an id.
- *
- * @param id a report id
- * @param input an input stream
- * @param max
- * maximum bytes to be written, if max is less or equal than 0, it will
- * write all bytes from input stream to the file
- * @return the number of bytes written
- * @throws FileNotFoundException
- * if reportExists(id) returns false
- * @throws IOException
- */
- public int writeStreamToReport(String id, InputStream input, int max)
- throws FileNotFoundException, IOException;
-
- /**
- * Opens a report for read.
- *
- * @param id a report id
- * @return an output stream for read
- * @throws FileNotFoundException
- */
- public InputStream openReportForRead(String id) throws FileNotFoundException;
-
- /**
- * @param id a report id
- * @return the checksum of a report.
- * @throws FileNotFoundException
- */
- public String getChecksum(String id) throws FileNotFoundException;
-
- /**
- * Removes a report.
- *
- * @param id a report id
- * @return true if the report is removed successfully
- */
- public boolean removeReport(String id) throws FileNotFoundException;
-}
diff --git a/java/common/src/com/google/airbag/common/ReportStorageLocalFileImpl.java b/java/common/src/com/google/airbag/common/ReportStorageLocalFileImpl.java
deleted file mode 100644
index 9a6cf91f..00000000
--- a/java/common/src/com/google/airbag/common/ReportStorageLocalFileImpl.java
+++ /dev/null
@@ -1,197 +0,0 @@
-/* Copyright (C) 2006 Google Inc.
-
-Licensed 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 com.google.airbag.common;
-
-import java.util.SortedMap;
-import java.util.logging.Logger;
-
-import java.io.File;
-import java.io.InputStream;
-import java.io.FileInputStream;
-import java.io.FileOutputStream;
-import java.io.IOException;
-import java.io.FileNotFoundException;
-
-/**
- * Implement FileStorage using a local file system.
- *
- * Given a sorted map of attributes, create a checksum as unique file
- * id.
- *
- * Each file id is associated with two files in the storage:
- *
- * - an attribute file named as .attr;
- * - a data file named as .data;
- *
- *
- */
-
-public class ReportStorageLocalFileImpl implements ReportStorage {
-
- // Name extension of attribute file
- private static final String ATTR_FILE_EXT = ".attr";
-
- // Name extension of data file
- private static final String DATA_FILE_EXT = ".data";
-
- // Set the maximum file length at 1M
- private static final long MAX_ATTR_FILE_LENGTH = 1 << 10;
-
- // Logging
- private static final Logger logger =
- Logger.getLogger(ReportStorageLocalFileImpl.class.getName());
-
- // Directory name for storing files.
- private String directoryName;
-
- /**
- * Creates an instance of ReportStorageLocalFileImpl by providing a
- * directory name.
- *
- * @param dirname a directory for storing files
- * @throws IOException
- * @throws NullPointerException if dirname is null
- */
- public ReportStorageLocalFileImpl(String dirname) throws IOException {
- this.directoryName = dirname;
- // new File can throw NullPointerException if dirname is null
- File dir = new File(dirname);
- if (!dir.exists() && !dir.mkdirs())
- throw new IOException("Cannot make dirs for "+dirname);
-
- if (!dir.canWrite())
- throw new IOException("Cannot write to "+dirname
- +", check your permissions.");
- }
-
- /**
- * Returns a hashed string of attributes. Attributes are saved
- * in the file storage if not exists.
- */
- public String getUniqueId(SortedMap attributes)
- {
- String attr = CrashUtils.attributesToString(attributes);
- return CrashUtils.dataSignature(attr.getBytes());
- }
-
- /**
- * Saves attributes associated with a given id. if attributes does not
- * match the id (comparing results of getUniqueId(attributes)
- * with id), it returns false. Otherwise, attributes are saved.
- */
- public boolean saveAttributes(String id, SortedMap attributes)
- {
- String attr = CrashUtils.attributesToString(attributes);
- String digest = CrashUtils.dataSignature(attr.getBytes());
-
- if (!digest.equals(id))
- return false;
-
- try {
- File attrFile = new File(this.directoryName, digest+ATTR_FILE_EXT);
-
- // check if attr file exists
- if (!attrFile.exists()) {
- FileOutputStream fos = new FileOutputStream(attrFile);
- fos.write(attr.getBytes());
- fos.close();
- }
-
- return true;
- } catch (IOException e) {
- e.printStackTrace();
- logger.warning(e.toString());
- return false;
- }
- }
-
- /** Checks if a report id exists. */
- public boolean reportExists(String id) {
- File datafile = new File(this.directoryName, id+DATA_FILE_EXT);
- File attrfile = new File(this.directoryName, id+ATTR_FILE_EXT);
- return datafile.isFile() && attrfile.isFile();
- }
-
- /** Returns attributes in a map associated with an id. */
- public SortedMap getAttributes(String id)
- throws FileNotFoundException
- {
- if (!this.reportExists(id))
- throw new FileNotFoundException("no file is identified by "+id);
-
- File attrfile = new File(this.directoryName, id+ATTR_FILE_EXT);
- if (!attrfile.isFile())
- throw new FileNotFoundException("no file is identified by "+id);
-
- int length = (int) attrfile.length();
- if (length >= MAX_ATTR_FILE_LENGTH)
- throw new FileNotFoundException("no file is identified by "+id);
-
- byte[] content = new byte[length];
-
- try {
- FileInputStream fis = new FileInputStream(attrfile);
- fis.read(content);
- fis.close();
-
- // verify checksum
- String sig = CrashUtils.dataSignature(content);
- if (!sig.equals(id)) {
- logger.warning("illegal access to "+attrfile);
- return null;
- }
-
- // parse contents
- return CrashUtils.stringToAttributes(new String(content));
-
- } catch (IOException e) {
- logger.warning(e.toString());
- return null;
- }
- }
-
- public int writeStreamToReport(String id, InputStream input, int max)
- throws FileNotFoundException, IOException {
- File datafile = new File(this.directoryName, id + DATA_FILE_EXT);
- FileOutputStream fos = new FileOutputStream(datafile);
-
- int bytesCopied = CrashUtils.copyStream(input, fos, max);
-
- fos.close();
-
- return bytesCopied;
- }
-
- public InputStream openReportForRead(String id) throws FileNotFoundException {
- File datafile = new File(this.directoryName, id + DATA_FILE_EXT);
- return new FileInputStream(datafile);
- }
-
- public String getChecksum(String id) throws FileNotFoundException {
- File datafile = new File(this.directoryName, id + DATA_FILE_EXT);
- return CrashUtils.fileSignature(datafile);
- }
-
-
- public boolean removeReport(String id) {
- File datafile = new File(this.directoryName, id + DATA_FILE_EXT);
- File attrfile = new File(this.directoryName, id + ATTR_FILE_EXT);
-
- datafile.delete();
- attrfile.delete();
-
- return true;
- }
-}
diff --git a/java/common/src/com/google/airbag/common/ReportStorageTest.java b/java/common/src/com/google/airbag/common/ReportStorageTest.java
deleted file mode 100644
index dc17f56a..00000000
--- a/java/common/src/com/google/airbag/common/ReportStorageTest.java
+++ /dev/null
@@ -1,89 +0,0 @@
-/* Copyright (C) 2006 Google Inc.
-
-Licensed 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 com.google.airbag.common;
-
-import java.io.ByteArrayInputStream;
-import java.io.FileNotFoundException;
-import java.io.IOException;
-import java.io.InputStream;
-import java.util.TreeMap;
-
-/** A simple regression test of ReportStorage.java and implementations.
- */
-
-public class ReportStorageTest {
- public static void main(String[] args) {
- // use /tmp/test as testing directory
- ReportStorage rs = null;
- try {
- rs = new ReportStorageLocalFileImpl("/tmp/test");
- } catch (IOException e) {
- e.printStackTrace();
- System.exit(1);
- }
-
- runTest(rs);
-
- // test passed
- System.out.println("OK.");
- }
-
- private static void runTest(ReportStorage rs) {
- // test CrashUtil.bytesToHexString
- byte[] ba = new byte[4];
- ba[0] = (byte)0xFF;
- ba[1] = (byte)0x00;
- ba[2] = (byte)0x0F;
- ba[3] = (byte)0xF0;
- String s = CrashUtils.bytesToHexString(ba);
- assert s.equals("FF000FF0");
-
- // construct a simple map of attributes
- TreeMap params =
- new TreeMap();
- params.put("Hello", "World");
- String rid = rs.getUniqueId(params);
- assert rid != null;
-
- boolean b = rs.saveAttributes(rid, params);
- assert b;
- ba = "hellow, world!".getBytes();
- InputStream in = new ByteArrayInputStream(ba);
-
- assert rs.reportExists(rid);
-
- // save contents to storage
- try {
- rs.writeStreamToReport(rid, in, 0);
- } catch (FileNotFoundException e) {
- e.printStackTrace();
- System.exit(1);
- } catch (IOException e) {
- e.printStackTrace();
- System.exit(1);
- }
-
- // read contents out
- try {
- InputStream in1 = rs.openReportForRead(rid);
- assert in1.available() == ba.length;
- in1.read(ba);
- assert(new String(ba).equals("hellow, world!"));
- } catch (IOException e) {
- e.printStackTrace();
- System.exit(1);
- }
- }
-}
diff --git a/java/common/src/com/google/airbag/common/SymbolStorage.java b/java/common/src/com/google/airbag/common/SymbolStorage.java
deleted file mode 100644
index 5f0a3508..00000000
--- a/java/common/src/com/google/airbag/common/SymbolStorage.java
+++ /dev/null
@@ -1,86 +0,0 @@
-/* Copyright (C) 2006 Google Inc.
-
-Licensed 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 com.google.airbag.common;
-
-import java.io.IOException;
-import java.io.InputStream;
-import java.util.SortedMap;
-
-/**
- * SymbolStorage provides a simple interface for storing and retrieving
- * symbol files. Symbol files are indexed by a set of attributes:
- *
- * - product name
- * - version (build id)
- * - platform
- * - application/module name
- *
- *
- *
- *
- * The interface is designed for a symbol server supports upload, getid,
- * download operations.
- *
- */
-
-public interface SymbolStorage {
- /**
- * Saves a symbol file indexed by a set of attributes. Attributes include
- * product, version, platform, application/module, plus a checksum of
- * the symbol file.
- *
- * If a symbol file whose checksum matches the attribute, the input stream
- * can be NULL. No contents will be written. This can save some workloads
- * of uploading symbols.
- *
- * @param attrs a map of attributes, it must have 'prod', 'ver', 'plat',
- * 'app', and 'sum', values of the first four attributes are used
- * as index, and the value of the last attribute is the MD5 checksum
- * of the symbol file for verification.
- * @param contents symbol file contents.
- * @return true if checksum matches
- * @throws IOException
- */
- public boolean saveSymbolFile(SortedMap attrs,
- InputStream contents) throws IOException;
-
- /**
- * Gets the checksum of a symbol file indexed by a set of attributes.
- * @param attrs a map of attributes, must include 'prod', 'ver', 'plat',
- * and 'app'.
- * @return MD5 checksum as a string
- * @throws IOException
- */
- public String getFileChecksum(SortedMap attrs)
- throws IOException;
-
- /**
- * Checks if a file exists already (identified by its checksum).
- * @param checksum the file checksum
- * @return true if a file with the same checksum exists
- */
- public boolean fileExists(String checksum);
-
- /**
- * Gets an input stream of a symbol server indexed by a set of attributes.
- * @param attrs a map of attributes, must include 'prod', 'ver', 'plat',
- * and 'app'.
- * @return an input stream of the symbol file
- * @throws IOException
- */
- public InputStream openFileForRead(SortedMap attrs)
- throws IOException;
-}
diff --git a/java/common/src/com/google/airbag/common/SymbolStorageLocalFileImpl.java b/java/common/src/com/google/airbag/common/SymbolStorageLocalFileImpl.java
deleted file mode 100644
index ed4e0e63..00000000
--- a/java/common/src/com/google/airbag/common/SymbolStorageLocalFileImpl.java
+++ /dev/null
@@ -1,203 +0,0 @@
-/* Copyright (C) 2006 Google Inc.
-
-Licensed 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 com.google.airbag.common;
-
-import java.io.File;
-import java.io.FileInputStream;
-import java.io.FileNotFoundException;
-import java.io.FileOutputStream;
-import java.io.IOException;
-import java.io.InputStream;
-import java.util.SortedMap;
-import java.util.TreeMap;
-
-/**
- * Implementation of SymbolStorage interface using a local file system.
- *
- * Given a set of parameters, prod, ver, app, plat, computes its MD5 digest.
- * Digest + .attr contains attributes and checksum of the symbol file.
- * Symbol file content is stored in a file named by its checksum + .data.
- *
- * To upload a symbol file, a client can send a query:
- *
- * /symexists?sum=, the server checks if a symbol file identified by checksum exists;
- * /upload?prod=&ver=&plat=&app=&sum= use POST
- * method with or without uploading a file.
- *
- * A client can always call /upload to upload a symbol file.
- * However, a more efficient way is to check whether a file is on the server by calling /symexists.
- * If so, the client can just POST the request without actually upload the file content,
- * checksum is sufficient.
- *
- * /getchecksum?prod=&ver=&plat=&app=, returns the checksum
- * of the symbol file on the server.
- * /download?prod=&ver=&plat=&app=, downloads the symbol file
- * on the server.
- *
- * A client can always use /download to download a symbol file.
- * However, if the client maintins its own cache of symbol files, it can call /getchecksum,
- * and look up the cache using the checksum. If the cache does not have the file, then it
- * calls /download.
- *
- */
-
-public class SymbolStorageLocalFileImpl implements SymbolStorage {
-
- // Name extension of attribute file
- private static final String ATTR_FILE_EXT = ".attr";
-
- // Name extension of data file
- private static final String DATA_FILE_EXT = ".data";
-
- private static final int MAX_ATTR_FILE_LENGTH = 1 << 10;
-
- // Directory name for storing files.
- private String directoryName;
-
- /**
- * Creates an instance of ReportStorageLocalFileImpl by providing a
- * directory name.
- *
- * @param dirname
- * @throws IOException
- */
- public SymbolStorageLocalFileImpl(String dirname) throws IOException {
- this.directoryName = dirname;
- // new File can throw NullPointerException if dirname is null
- File dir = new File(dirname);
- if (!dir.exists() && !dir.mkdirs())
- throw new IOException("Cannot make dirs for "+dirname);
-
- if (!dir.canWrite())
- throw new IOException("Cannot write to "+dirname
- +", check your permissions.");
- }
-
- /**
- * Save a symbol file.
- */
- public boolean saveSymbolFile(SortedMap attrs, InputStream contents)
- throws IOException {
- String digest = getAttributesSignature(attrs);
-
- // get 'sum' value
- String checksum = attrs.get(NameConstants.CHECKSUM_PNAME);
- if (checksum == null)
- return false;
-
- // attribute file name and data file name
- File attrFile = new File(this.directoryName, digest+ATTR_FILE_EXT);
-
- // use passed in checksum as file name
- File dataFile = new File(this.directoryName, checksum+DATA_FILE_EXT);
-
- // write data to file
- FileOutputStream outs = new FileOutputStream(dataFile);
- CrashUtils.copyStream(contents, outs, 0);
- outs.close();
-
- // get signature of input stream
- String filesig = CrashUtils.fileSignature(dataFile);
-
- if (!checksum.equals(filesig)) {
- dataFile.delete();
- return false;
- }
-
- // save all attributes with checksum
- String fullAttrs = CrashUtils.attributesToString(attrs);
-
- FileOutputStream fos = new FileOutputStream(attrFile);
- fos.write(fullAttrs.getBytes());
- fos.close();
-
- return true;
- }
-
-
- public String getFileChecksum(SortedMap attrs) throws IOException {
- String digest = getAttributesSignature(attrs);
- File attrFile = new File(this.directoryName, digest+ATTR_FILE_EXT);
-
- if (!attrFile.isFile())
- throw new FileNotFoundException();
-
- int length = (int) attrFile.length();
- if (length >= MAX_ATTR_FILE_LENGTH)
- throw new FileNotFoundException();
-
- byte[] content = new byte[length];
-
- FileInputStream fis = new FileInputStream(attrFile);
- fis.read(content);
- fis.close();
-
- // parse contents
- SortedMap savedAttrs =
- CrashUtils.stringToAttributes(new String(content));
-
- return savedAttrs.get(NameConstants.CHECKSUM_PNAME);
- }
-
- public boolean fileExists(String checksum) {
- File dataFile = new File(this.directoryName, checksum+DATA_FILE_EXT);
- return dataFile.isFile();
- }
-
- public InputStream openFileForRead(SortedMap attrs)
- throws IOException {
- String checksum = getFileChecksum(attrs);
- if (checksum == null)
- throw new FileNotFoundException();
-
- File dataFile = new File(this.directoryName, checksum + DATA_FILE_EXT);
- if (!dataFile.isFile())
- throw new FileNotFoundException();
-
- return new FileInputStream(dataFile);
- }
-
- private static final String[] requiredParameters = {
- NameConstants.PRODUCT_PNAME,
- NameConstants.APPLICATION_PNAME,
- NameConstants.PLATFORM_PNAME,
- NameConstants.VERSION_PNAME
- };
-
- private String getAttributesSignature(SortedMap attrs) {
- // canonize parameters
- SortedMap params = canonizeAttributes(attrs);
- String attrString = CrashUtils.attributesToString(params);
- return CrashUtils.dataSignature(attrString.getBytes());
- }
- /* Canonize attributes, get 'prod', 'ver', 'plat', and 'app' values,
- * and put them in a new sorted map. If one of value is missing,
- * returns null.
- */
- private SortedMap
- canonizeAttributes(SortedMap attrs) {
- SortedMap params = new TreeMap();
- for (String s : requiredParameters) {
- String v = attrs.get(s);
- if (v == null)
- return null;
- else
- params.put(s, v);
- }
- return params;
- }
-
-}
diff --git a/java/common/src/com/google/airbag/common/TestReportStorageConsumer.java b/java/common/src/com/google/airbag/common/TestReportStorageConsumer.java
deleted file mode 100644
index 6b40dee2..00000000
--- a/java/common/src/com/google/airbag/common/TestReportStorageConsumer.java
+++ /dev/null
@@ -1,87 +0,0 @@
-/* Copyright (C) 2006 Google Inc.
-
-Licensed 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 com.google.airbag.common;
-
-import java.io.FileNotFoundException;
-import java.io.IOException;
-import java.io.InputStream;
-import java.util.TreeMap;
-
-/**
- * Test ReportStorage and its implementation by simulating two pocesses
- * as producer and consuer.
- *
- * To use this test with TestReportStorageProducer:
- * > java TestReportStorageProducer /tmp/testdir
- *
- * In another console,
- * > java TestReportStorageConsumer /tmp/testdir
- *
- * Then watch output on both console.
- */
-public class TestReportStorageConsumer {
-
- /**
- * @param args
- */
- public static void main(String[] args) {
- String testdir = args[0];
- ReportStorage rs = null;
- try {
- rs = new ReportStorageLocalFileImpl(testdir);
- } catch (IOException e) {
- e.printStackTrace();
- System.exit(1);
- }
-
- consume(rs);
- }
-
- private static void consume(ReportStorage rs) {
- int i = 0;
- TreeMap params =
- new TreeMap();
- String v = "hello";
- byte[] buf = new byte[1024];
- while (true) {
- params.put(Integer.toString(i), v);
- String id = rs.getUniqueId(params);
- rs.saveAttributes(id, params);
- if (rs.reportExists(id)) {
- InputStream is = null;
- try {
- is = rs.openReportForRead(id);
- while (is.read(buf) != -1) {
- System.out.print(new String(buf));
- }
- } catch (FileNotFoundException e) {
- e.printStackTrace();
- break;
- } catch (IOException e) {
- e.printStackTrace();
- break;
- }
- }
- i++;
- try {
- Thread.sleep(1000);
- } catch (InterruptedException e) {
- e.printStackTrace();
- break;
- }
- }
- }
-}
diff --git a/java/common/src/com/google/airbag/common/TestReportStorageProducer.java b/java/common/src/com/google/airbag/common/TestReportStorageProducer.java
deleted file mode 100644
index b52296b6..00000000
--- a/java/common/src/com/google/airbag/common/TestReportStorageProducer.java
+++ /dev/null
@@ -1,86 +0,0 @@
-/* Copyright (C) 2006 Google Inc.
-
-Licensed 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 com.google.airbag.common;
-
-import java.io.ByteArrayInputStream;
-import java.io.FileNotFoundException;
-import java.io.IOException;
-import java.util.TreeMap;
-
-/**
- * Test ReportStorage and its implementation by simulating two pocesses
- * as producer and consuer.
- *
- * To use this test with TestReportStorageConsumer:
- * > java TestReportStorageProducer /tmp/testdir
- *
- * In another console,
- * > java TestReportStorageConsumer /tmp/testdir
- *
- * Then watch output on both console.
- */
-
-public class TestReportStorageProducer {
-
- /**
- * @param args
- */
- public static void main(String[] args) {
- String testdir = args[0];
- ReportStorage rs = null;
- try {
- rs = new ReportStorageLocalFileImpl(testdir);
- } catch (IOException e) {
- e.printStackTrace();
- System.exit(1);
- }
-
- produce(rs);
- }
-
- private static void produce(ReportStorage rs) {
- int i = 0;
- TreeMap params =
- new TreeMap();
- String v = "hello";
- ByteArrayInputStream ba = new ByteArrayInputStream("hello world!".getBytes());
- while (true) {
- ba.reset();
- params.put(Integer.toString(i), v);
- String id = rs.getUniqueId(params);
- rs.saveAttributes(id, params);
- if (id == null) {
- System.exit(1);
- }
- try {
- rs.writeStreamToReport(id, ba, 0);
- } catch (FileNotFoundException e) {
- e.printStackTrace();
- break;
- } catch (IOException e) {
- e.printStackTrace();
- break;
- }
- i++;
- try {
- Thread.sleep(1000);
- } catch (InterruptedException e) {
- e.printStackTrace();
- break;
- }
- }
- }
-}