You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@chemistry.apache.org by je...@apache.org on 2010/04/16 16:21:47 UTC
svn commit: r934907 [2/2] - in
/incubator/chemistry/opencmis/trunk/chemistry-opencmis-test:
chemistry-opencmis-test-tools/src/main/java/org/apache/chemistry/opencmis/commander/
chemistry-opencmis-test-util/src/main/java/org/apache/chemistry/opencmis/ut...
Modified: incubator/chemistry/opencmis/trunk/chemistry-opencmis-test/chemistry-opencmis-test-util/src/main/java/org/apache/chemistry/opencmis/util/repository/ObjectGenerator.java
URL: http://svn.apache.org/viewvc/incubator/chemistry/opencmis/trunk/chemistry-opencmis-test/chemistry-opencmis-test-util/src/main/java/org/apache/chemistry/opencmis/util/repository/ObjectGenerator.java?rev=934907&r1=934906&r2=934907&view=diff
==============================================================================
--- incubator/chemistry/opencmis/trunk/chemistry-opencmis-test/chemistry-opencmis-test-util/src/main/java/org/apache/chemistry/opencmis/util/repository/ObjectGenerator.java (original)
+++ incubator/chemistry/opencmis/trunk/chemistry-opencmis-test/chemistry-opencmis-test-util/src/main/java/org/apache/chemistry/opencmis/util/repository/ObjectGenerator.java Fri Apr 16 14:21:47 2010
@@ -50,557 +50,567 @@ import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
/**
- * A simple helper class for the tests that generates a sample folder hierarchy and
- * optionally documents in it.
+ * A simple helper class for the tests that generates a sample folder hierarchy
+ * and optionally documents in it.
*
* @author Jens
- *
+ *
*/
public class ObjectGenerator {
-
- private static Log log = LogFactory.getLog(ObjectGenerator.class);
- private BindingsObjectFactory fFactory;
- NavigationService fNavSvc;
- ObjectService fObjSvc;
- private String fRepositoryId;
- private TimeLogger fTimeLoggerCreateDoc;
- private TimeLogger fTimeLoggerCreateFolder;
- private TimeLogger fTimeLoggerDelete;
- private boolean fCleanup;
- List<String> fTopLevelDocsCreated; // list of ids created on first level
- List<String> fTopLevelFoldersCreated; // list of ids created on first level
-
- /**
- * Indicates if / how many documents are created in each folder
- */
- private int fNoDocumentsToCreate;
-
- /**
- * The type id of the document id that is created.
- */
- private String fDocTypeId = BaseTypeId.CMIS_DOCUMENT.value();
-
- /**
- * The type id of the folder that is created.
- */
- private String fFolderTypeId = BaseTypeId.CMIS_FOLDER.value();
-
- /**
- * A list of property ids. For each element in this list a String property value
- * is created for each creation of a document. All ids must be valid string
- * property id of the type fDocTypeId
- */
- private List<String> fStringPropertyIdsToSetForDocument;
-
- /**
- * A list of property ids. For each element in this list a String property value
- * is created for each creation of a folder. All ids must be valid string
- * property id of the type fFolderTypeId
- */
- private List<String> fStringPropertyIdsToSetForFolder;
-
- /**
- * number of documents created in total
- */
- private int fDocumentsInTotalCount = 0;
-
- /**
- * number of folders created in total
- */
- private int fFoldersInTotalCount = 0;
-
- /**
- * size of content in KB, if 0 create documents without content
- */
- private int fContentSizeInK = 0;
-
- private static final String NAMEPROPVALPREFIXDOC = "My_Document-";
- private static final String NAMEPROPVALPREFIXFOLDER = "My_Folder-";
- private static final String STRINGPROPVALPREFIXDOC = "My Doc StringProperty ";
- private static final String STRINGPROPVALPREFIXFOLDER = "My Folder StringProperty ";
- private static int PROPVALCOUNTER_DOC_STRING_PROP = 0;
- private static int PROPVALCOUNTER_FOLDER_STRING_PROP = 0;
- /**
- * use UUIDs to generate folder and document names
- */
- private boolean fUseUuids ;
-
- public ObjectGenerator(BindingsObjectFactory factory, NavigationService navSvc,
- ObjectService objSvc, String repositoryId) {
- super();
- fFactory = factory;
- fNavSvc = navSvc;
- fObjSvc = objSvc;
- fRepositoryId = repositoryId;
- // create an empty list of properties to generate by default for folder and document
- fStringPropertyIdsToSetForDocument = new ArrayList<String>();
- fStringPropertyIdsToSetForFolder = new ArrayList<String>();
- fNoDocumentsToCreate = 0;
- fUseUuids = false;
- fTimeLoggerCreateDoc = new TimeLogger("createDocument()");
- fTimeLoggerCreateFolder = new TimeLogger("createFolder()");
- fTimeLoggerDelete = new TimeLogger("Delete");
- fCleanup = false;
- fTopLevelDocsCreated = new ArrayList<String>();
- fTopLevelFoldersCreated = new ArrayList<String>();
- }
-
- public void setNumberOfDocumentsToCreatePerFolder(int noDocumentsToCreate) {
- fNoDocumentsToCreate = noDocumentsToCreate;
- }
-
- public void setFolderTypeId(String folderTypeId) {
- fFolderTypeId = folderTypeId;
- }
-
- public void setDocumentTypeId(String docTypeId) {
- fDocTypeId = docTypeId;
- }
-
- public void setDocumentPropertiesToGenerate(List<String> propertyIds) {
- fStringPropertyIdsToSetForDocument = propertyIds;
- }
-
- public void setFolderPropertiesToGenerate(List<String> propertyIds) {
- fStringPropertyIdsToSetForFolder = propertyIds;
- }
-
- public void setContentSizeInKB(int sizeInK) {
- fContentSizeInK = sizeInK;
- }
-
- public void setCleanUpAfterCreate(boolean doCleanup) {
- fCleanup = doCleanup;
- }
-
- public TimeLogger getCreateDocumentTimeLogger() {
- return fTimeLoggerCreateDoc;
- }
-
- public TimeLogger getCreateFolderTimeLogger() {
- return fTimeLoggerCreateFolder;
- }
-
- public TimeLogger getDeleteTimeLogger() {
- return fTimeLoggerDelete;
- }
-
- public void createFolderHierachy(int levels, int childrenPerLevel, String rootFolderId) {
- resetCounters();
- fTimeLoggerCreateDoc.reset();
- fTimeLoggerCreateFolder.reset();
- fTopLevelFoldersCreated.clear();
- fTopLevelDocsCreated.clear();
- createFolderHierachy(rootFolderId, 0, levels, childrenPerLevel);
- if (fCleanup)
- deleteTree();
- }
-
- public void setUseUuidsForNames(boolean useUuids) {
- /**
- * use UUIDs to generate folder and document names
- */
- fUseUuids = useUuids;
- }
-
- /**
- * retrieve the index-th folder from given level of the hierarchy
- * starting at rootId
- * @param rootId
- * @param level
- * @param index
- * @return
- */
- public String getFolderId(String rootId, int level, int index) {
- String objectId = rootId;
- final String requiredProperties = PropertyIds.OBJECT_ID + "," + PropertyIds.OBJECT_TYPE_ID +
- "," + PropertyIds.BASE_TYPE_ID;
- // Note: This works because first folders are created then documents
- for (int i=0; i<level; i++) {
- ObjectInFolderList result = fNavSvc.getChildren(fRepositoryId, objectId, requiredProperties, PropertyIds.OBJECT_TYPE_ID, false,
- IncludeRelationships.NONE, null, true, BigInteger.valueOf(-1), BigInteger.valueOf(-1), null);
- List<ObjectInFolderData> children = result.getObjects();
- ObjectData child = children.get(index).getObject();
- objectId = (String) child.getProperties().getProperties().get(PropertyIds.OBJECT_ID).getFirstValue();
- }
- return objectId;
- }
-
- /**
- * retrieve the index-th document from given folder
- * @param folderId
- * folder to retrieve document from
- * @param index
- * index of document to retrieve from this folder
- * @return
- */
- public String getDocumentId(String folderId, int index) {
- String docId = null;
- final String requiredProperties = PropertyIds.OBJECT_ID + "," + PropertyIds.OBJECT_TYPE_ID +
- "," + PropertyIds.BASE_TYPE_ID;
- ObjectInFolderList result = fNavSvc.getChildren(fRepositoryId, folderId, requiredProperties,
- PropertyIds.OBJECT_TYPE_ID, false, IncludeRelationships.NONE, null, true, BigInteger
- .valueOf(-1), BigInteger.valueOf(-1), null);
- List<ObjectInFolderData> children = result.getObjects();
- int numDocsFound = 0;
- for (int i=0; i<children.size(); i++) {
- ObjectData child = children.get(i).getObject();
- docId = (String) child.getProperties().getProperties().get(PropertyIds.OBJECT_ID).getFirstValue();
- if (child.getBaseTypeId().equals(BaseTypeId.CMIS_DOCUMENT)) {
- if (numDocsFound == index)
- return docId;
- else
- numDocsFound++;
- }
- }
- return docId;
- }
-
- /**
- * return the total number of documents created
- * @return
- */
- public int getDocumentsInTotal() {
- return fDocumentsInTotalCount;
- }
-
- /**
- * return the total number of folders created
- * @return
- */
- public int getFoldersInTotal() {
- return fFoldersInTotalCount;
- }
-
- /**
- * return the total number of objects created
- * @return
- */
- public int getObjectsInTotal() {
- return fDocumentsInTotalCount + fFoldersInTotalCount;
- }
-
- public String createSingleDocument(String folderId) {
- fTimeLoggerCreateDoc.reset();
- String objectId = createDocument(folderId, 0, 0);
- if (fCleanup)
- deleteObject(objectId);
- return objectId;
- }
-
- public String[] createDocuments(String folderId, int count) {
-
- String result[];
-
- fTimeLoggerCreateDoc.reset();
- for (int i=0; i<count; i++) {
- String id = createDocument(folderId, 0, 0);
- fTopLevelDocsCreated.add(id);
- }
- if (fCleanup) {
- deleteTree();
- result = null;
- } else {
- result = new String[count];
- for (int i=0; i<fTopLevelDocsCreated.size(); i++)
- result[i] = fTopLevelDocsCreated.get(i);
- }
- return result;
- }
-
- public String[] createFolders(String folderId, int count) {
-
- String result[];
-
- fTimeLoggerCreateFolder.reset();
- for (int i=0; i<count; i++) {
- createFolder(folderId);
- }
- if (fCleanup) {
- deleteTree();
- result = null;
- } else {
- result = new String[count];
- for (int i=0; i<fTopLevelFoldersCreated.size(); i++)
- result[i] = fTopLevelFoldersCreated.get(i);
- }
- return result;
- }
-
- public void resetCounters() {
- fDocumentsInTotalCount = fFoldersInTotalCount = 0;
- }
-
- public void printTimings() {
- fTimeLoggerCreateDoc.printTimes();
- fTimeLoggerCreateFolder.printTimes();
- if (fCleanup)
- fTimeLoggerDelete.printTimes();
- }
-
- public void logTimings() {
- fTimeLoggerCreateDoc.logTimes();
- fTimeLoggerCreateFolder.logTimes();
- if (fCleanup)
- fTimeLoggerDelete.logTimes();
- }
-
- private void createFolderHierachy(String parentId, int level, int levels, int childrenPerLevel) {
- String id = null;
-
- if (level>=levels)
- return;
-
- log.debug(" create folder for parent id: " + parentId + ", in level " + level
- + ", max levels " + levels);
-
- for (int i = 0; i < childrenPerLevel; i++) {
- Properties props = createFolderProperties(i, level);
- try {
- fTimeLoggerCreateFolder.start();
- id = fObjSvc.createFolder(fRepositoryId, props, parentId, null, null, null, null);
- if (level==0)
- fTopLevelFoldersCreated.add(id);
- } finally {
- fTimeLoggerCreateFolder.stop();
- }
-
- if (id != null) {
- ++fFoldersInTotalCount;
- createFolderHierachy(id, level+1, levels, childrenPerLevel);
- }
- }
- for (int j=0; j<fNoDocumentsToCreate; j++) {
- id = createDocument(parentId, j, level);
- if (level==0)
- fTopLevelDocsCreated.add(id);
- }
- }
-
- private String createFolder(String parentId) {
- Properties props = createFolderProperties(0, 0);
- String id = null;
- try {
- fTimeLoggerCreateFolder.start();
- id = fObjSvc.createFolder(fRepositoryId, props, parentId, null, null, null, null);
- fTopLevelFoldersCreated.add(id);
- } finally {
- fTimeLoggerCreateFolder.stop();
- }
- return id;
- }
-
- private String createDocument(String folderId, int no, int level) {
- ContentStream contentStream = null;
- VersioningState versioningState = VersioningState.NONE;
- List<String> policies = null;
- Acl addACEs = null;
- Acl removeACEs = null;
- ExtensionsData extension = null;
-
- // log.info("create document in folder " + folderId);
- Properties props = createDocumentProperties(no, level);
- String id = null;
- if (fContentSizeInK > 0)
- contentStream = createContent();
- try {
- fTimeLoggerCreateDoc.start();
- id = fObjSvc.createDocument(fRepositoryId, props, folderId, contentStream, versioningState,
- policies, addACEs, removeACEs, extension);
- } finally {
- fTimeLoggerCreateDoc.stop();
- }
-
- if (null == id)
- throw new RuntimeException("createDocument failed.");
- ++fDocumentsInTotalCount;
- return id;
- }
-
- private void deleteTree() {
-
- // delete all documents from first level
- for (String id : fTopLevelDocsCreated) {
- deleteObject(id);
- }
-
- // delete recursively all folders from first level
- for (String id : fTopLevelFoldersCreated) {
- try {
- fTimeLoggerDelete.start();
- fObjSvc.deleteTree(fRepositoryId, id, true, UnfileObject.DELETE, true, null);
- } finally {
- fTimeLoggerDelete.stop();
- }
- }
- }
-
- private void deleteObject(String objectId) {
- try {
- fTimeLoggerDelete.start();
- fObjSvc.deleteObject(fRepositoryId, objectId, true, null);
- } finally {
- fTimeLoggerDelete.stop();
- }
- }
-
- private ContentStream createContent() {
- ContentStreamImpl content = new ContentStreamImpl();
- content.setFileName("data.txt");
- content.setMimeType("text/plain");
- int len = fContentSizeInK * 1024; // size of document in K
- byte[] b = {0x61, 0x62, 0x63, 0x64, 0x65, 0x66, 0x67, 0x68,
- 0x69, 0x6a, 0x6b, 0x6c, 0x6d, 0x6e, 0x0c, 0x0a,
- 0x61, 0x62, 0x63, 0x64, 0x65, 0x66, 0x67, 0x68,
- 0x69, 0x6a, 0x6b, 0x6c, 0x6d, 0x6e, 0x0c, 0x0a
- }; // 32 Bytes
- ByteArrayOutputStream ba = new ByteArrayOutputStream(len);
- try {
- for (int j=0; j<fContentSizeInK; j++) {
- // write 1K of data
- for (int i=0; i<32; i++)
- ba.write(b);
- }
- } catch (IOException e) {
- throw new RuntimeException("Failed to fill content stream with data", e) ;
- }
- content.setStream(new ByteArrayInputStream(ba.toByteArray()));
- return content;
- }
-
- private Properties createFolderProperties(int no, int level) {
- List<PropertyData<?>> properties = new ArrayList<PropertyData<?>>();
- properties.add(fFactory.createPropertyStringData(PropertyIds.NAME, generateFolderNameValue(no, level)));
- properties.add(fFactory.createPropertyIdData(PropertyIds.OBJECT_TYPE_ID, fFolderTypeId));
- // Generate some property values for custom attributes
- for (String stringPropId : fStringPropertyIdsToSetForFolder) {
- properties.add(fFactory.createPropertyStringData(stringPropId, generateStringPropValueFolder()));
- }
- Properties props = fFactory.createPropertiesData(properties);
- return props;
- }
-
- private Properties createDocumentProperties(int no, int level) {
- List<PropertyData<?>> properties = new ArrayList<PropertyData<?>>();
- properties.add(fFactory.createPropertyStringData(PropertyIds.NAME, generateDocNameValue(no, level)));
- properties.add(fFactory.createPropertyIdData(PropertyIds.OBJECT_TYPE_ID, fDocTypeId));
- // Generate some property values for custom attributes
- for (String stringPropId : fStringPropertyIdsToSetForDocument) {
- properties.add(fFactory.createPropertyStringData(stringPropId, generateStringPropValueDoc()));
- }
- Properties props = fFactory.createPropertiesData(properties);
- return props;
- }
-
- private static synchronized int incrementPropCounterDocStringProp() {
- return PROPVALCOUNTER_DOC_STRING_PROP++;
- }
-
- private static synchronized int incrementPropCounterFolderStringProp() {
- return PROPVALCOUNTER_FOLDER_STRING_PROP++;
- }
-
- private String generateDocNameValue(int no, int level) {
- if (fUseUuids)
- return UUID.randomUUID().toString();
- else
- return NAMEPROPVALPREFIXDOC + level + "-" + no;
- }
-
- private String generateFolderNameValue(int no, int level) {
- if (fUseUuids)
- return UUID.randomUUID().toString();
- else
- return NAMEPROPVALPREFIXFOLDER + level + "-" + no;
- }
-
- private static String generateStringPropValueDoc() {
- return STRINGPROPVALPREFIXDOC + incrementPropCounterDocStringProp();
- }
-
- private static String generateStringPropValueFolder() {
- return STRINGPROPVALPREFIXFOLDER + incrementPropCounterFolderStringProp();
- }
-
- public void dumpFolder(String folderId, String propertyFilter) {
- log.info("starting dumpFolder() id " + folderId + " ...");
- boolean allRequiredPropertiesArePresent = propertyFilter!= null && propertyFilter.equals("*"); // can be optimized
- final String requiredProperties = allRequiredPropertiesArePresent ? propertyFilter :
- PropertyIds.OBJECT_ID+","+PropertyIds.NAME + ","+PropertyIds.OBJECT_TYPE_ID +
- ","+PropertyIds.BASE_TYPE_ID;
- // if all required properties are contained in the filter use we use the filter otherwise
- // we use our own set and get those from the filter later in an extra call
- String propertyFilterIntern = allRequiredPropertiesArePresent ? propertyFilter : requiredProperties;
- dumpFolder(folderId, propertyFilterIntern, 0);
- }
-
- private void dumpFolder(String folderId, String propertyFilter, int depth) {
- boolean allRequiredPropertiesArePresent = propertyFilter.equals("*"); // can be optimized
- StringBuilder prefix = new StringBuilder();
- for (int i=0; i<depth; i++)
- prefix.append(" ");
-
- ObjectInFolderList result = fNavSvc.getChildren(fRepositoryId, folderId, propertyFilter, null, false,
- IncludeRelationships.NONE, null, true, BigInteger.valueOf(-1), BigInteger.valueOf(-1), null);
- List<ObjectInFolderData> folders = result.getObjects();
- if (null != folders) {
- log.info(prefix + "found " + folders.size() + " children in folder " + folderId);
- int no=0;
- for (ObjectInFolderData folder : folders) {
- log.info(prefix.toString() + ++no + ": found object with id: " + folder.getObject().getId() + " and path segment: "
- + folder.getPathSegment());
- dumpObjectProperties(folder.getObject(), depth, propertyFilter, !allRequiredPropertiesArePresent);
- String objectTypeBaseId = folder.getObject().getBaseTypeId().value();
- if (objectTypeBaseId.equals(BaseTypeId.CMIS_FOLDER.value())) {
- dumpFolder(folder.getObject().getId(), propertyFilter, depth+1);
- }
- else if (objectTypeBaseId.equals(BaseTypeId.CMIS_DOCUMENT.value())) {
- dumpObjectProperties(folder.getObject(), depth+1, propertyFilter, !allRequiredPropertiesArePresent);
- }
- }
- }
- log.info(""); // add empty line
- }
-
- private void dumpObjectProperties(ObjectData object, int depth, String propertyFilter, boolean mustFetchProperties) {
- final SimpleDateFormat df=new SimpleDateFormat("yyyy-MM-dd'T'HH:mm:ssZ");
- StringBuilder prefix = new StringBuilder();
- for (int i=0; i<depth; i++)
- prefix.append(" ");
-
- log.info(prefix + "found object id " + object.getId());
- Map<String, PropertyData<?>> propMap;
- if (mustFetchProperties) {
- String objId = (String) object.getProperties().getProperties().get(PropertyIds.OBJECT_ID).getFirstValue();
- Properties props = fObjSvc.getProperties(fRepositoryId, objId, propertyFilter, null);
- propMap = props.getProperties();
- } else {
- propMap = object.getProperties().getProperties();
- }
- StringBuilder valueStr = new StringBuilder("[");
- for (Map.Entry <String, PropertyData<?>> entry : propMap.entrySet()) {
- if (entry.getValue().getValues().size() > 1) {
- if (entry.getValue().getFirstValue() instanceof GregorianCalendar) {
- for ( Object obj : entry.getValue().getValues()) {
- GregorianCalendar cal = (GregorianCalendar) obj;
- valueStr.append(df.format(cal.getTime()) + ", ");
- }
- valueStr.append("]");
- } else {
- valueStr = new StringBuilder(entry.getValue().getValues().toString());
- }
- } else {
- Object value = entry.getValue().getFirstValue();
- if (null != value) {
- valueStr = new StringBuilder(value.toString());
- if (value instanceof GregorianCalendar) {
- valueStr = new StringBuilder(df.format(((GregorianCalendar) entry.getValue().getFirstValue()).getTime()));
- }
- }
- }
- log.info(prefix + entry.getKey() + ": " + valueStr);
- }
- log.info(""); // add empty line
- }
+
+ private static Log log = LogFactory.getLog(ObjectGenerator.class);
+ private BindingsObjectFactory fFactory;
+ NavigationService fNavSvc;
+ ObjectService fObjSvc;
+ private String fRepositoryId;
+ private TimeLogger fTimeLoggerCreateDoc;
+ private TimeLogger fTimeLoggerCreateFolder;
+ private TimeLogger fTimeLoggerDelete;
+ private boolean fCleanup;
+ List<String> fTopLevelDocsCreated; // list of ids created on first level
+ List<String> fTopLevelFoldersCreated; // list of ids created on first level
+
+ /**
+ * Indicates if / how many documents are created in each folder
+ */
+ private int fNoDocumentsToCreate;
+
+ /**
+ * The type id of the document id that is created.
+ */
+ private String fDocTypeId = BaseTypeId.CMIS_DOCUMENT.value();
+
+ /**
+ * The type id of the folder that is created.
+ */
+ private String fFolderTypeId = BaseTypeId.CMIS_FOLDER.value();
+
+ /**
+ * A list of property ids. For each element in this list a String property
+ * value is created for each creation of a document. All ids must be valid
+ * string property id of the type fDocTypeId
+ */
+ private List<String> fStringPropertyIdsToSetForDocument;
+
+ /**
+ * A list of property ids. For each element in this list a String property
+ * value is created for each creation of a folder. All ids must be valid
+ * string property id of the type fFolderTypeId
+ */
+ private List<String> fStringPropertyIdsToSetForFolder;
+
+ /**
+ * number of documents created in total
+ */
+ private int fDocumentsInTotalCount = 0;
+
+ /**
+ * number of folders created in total
+ */
+ private int fFoldersInTotalCount = 0;
+
+ /**
+ * size of content in KB, if 0 create documents without content
+ */
+ private int fContentSizeInK = 0;
+
+ private static final String NAMEPROPVALPREFIXDOC = "My_Document-";
+ private static final String NAMEPROPVALPREFIXFOLDER = "My_Folder-";
+ private static final String STRINGPROPVALPREFIXDOC = "My Doc StringProperty ";
+ private static final String STRINGPROPVALPREFIXFOLDER = "My Folder StringProperty ";
+ private static int PROPVALCOUNTER_DOC_STRING_PROP = 0;
+ private static int PROPVALCOUNTER_FOLDER_STRING_PROP = 0;
+ /**
+ * use UUIDs to generate folder and document names
+ */
+ private boolean fUseUuids;
+
+ public ObjectGenerator(BindingsObjectFactory factory, NavigationService navSvc, ObjectService objSvc,
+ String repositoryId) {
+ super();
+ fFactory = factory;
+ fNavSvc = navSvc;
+ fObjSvc = objSvc;
+ fRepositoryId = repositoryId;
+ // create an empty list of properties to generate by default for folder
+ // and document
+ fStringPropertyIdsToSetForDocument = new ArrayList<String>();
+ fStringPropertyIdsToSetForFolder = new ArrayList<String>();
+ fNoDocumentsToCreate = 0;
+ fUseUuids = false;
+ fTimeLoggerCreateDoc = new TimeLogger("createDocument()");
+ fTimeLoggerCreateFolder = new TimeLogger("createFolder()");
+ fTimeLoggerDelete = new TimeLogger("Delete");
+ fCleanup = false;
+ fTopLevelDocsCreated = new ArrayList<String>();
+ fTopLevelFoldersCreated = new ArrayList<String>();
+ }
+
+ public void setNumberOfDocumentsToCreatePerFolder(int noDocumentsToCreate) {
+ fNoDocumentsToCreate = noDocumentsToCreate;
+ }
+
+ public void setFolderTypeId(String folderTypeId) {
+ fFolderTypeId = folderTypeId;
+ }
+
+ public void setDocumentTypeId(String docTypeId) {
+ fDocTypeId = docTypeId;
+ }
+
+ public void setDocumentPropertiesToGenerate(List<String> propertyIds) {
+ fStringPropertyIdsToSetForDocument = propertyIds;
+ }
+
+ public void setFolderPropertiesToGenerate(List<String> propertyIds) {
+ fStringPropertyIdsToSetForFolder = propertyIds;
+ }
+
+ public void setContentSizeInKB(int sizeInK) {
+ fContentSizeInK = sizeInK;
+ }
+
+ public void setCleanUpAfterCreate(boolean doCleanup) {
+ fCleanup = doCleanup;
+ }
+
+ public TimeLogger getCreateDocumentTimeLogger() {
+ return fTimeLoggerCreateDoc;
+ }
+
+ public TimeLogger getCreateFolderTimeLogger() {
+ return fTimeLoggerCreateFolder;
+ }
+
+ public TimeLogger getDeleteTimeLogger() {
+ return fTimeLoggerDelete;
+ }
+
+ public void createFolderHierachy(int levels, int childrenPerLevel, String rootFolderId) {
+ resetCounters();
+ fTimeLoggerCreateDoc.reset();
+ fTimeLoggerCreateFolder.reset();
+ fTopLevelFoldersCreated.clear();
+ fTopLevelDocsCreated.clear();
+ createFolderHierachy(rootFolderId, 0, levels, childrenPerLevel);
+ if (fCleanup)
+ deleteTree();
+ }
+
+ public void setUseUuidsForNames(boolean useUuids) {
+ /**
+ * use UUIDs to generate folder and document names
+ */
+ fUseUuids = useUuids;
+ }
+
+ /**
+ * retrieve the index-th folder from given level of the hierarchy starting
+ * at rootId
+ *
+ * @param rootId
+ * @param level
+ * @param index
+ * @return
+ */
+ public String getFolderId(String rootId, int level, int index) {
+ String objectId = rootId;
+ final String requiredProperties = PropertyIds.OBJECT_ID + "," + PropertyIds.OBJECT_TYPE_ID + ","
+ + PropertyIds.BASE_TYPE_ID;
+ // Note: This works because first folders are created then documents
+ for (int i = 0; i < level; i++) {
+ ObjectInFolderList result = fNavSvc.getChildren(fRepositoryId, objectId, requiredProperties,
+ PropertyIds.OBJECT_TYPE_ID, false, IncludeRelationships.NONE, null, true, BigInteger.valueOf(-1),
+ BigInteger.valueOf(-1), null);
+ List<ObjectInFolderData> children = result.getObjects();
+ ObjectData child = children.get(index).getObject();
+ objectId = (String) child.getProperties().getProperties().get(PropertyIds.OBJECT_ID).getFirstValue();
+ }
+ return objectId;
+ }
+
+ /**
+ * retrieve the index-th document from given folder
+ *
+ * @param folderId
+ * folder to retrieve document from
+ * @param index
+ * index of document to retrieve from this folder
+ * @return
+ */
+ public String getDocumentId(String folderId, int index) {
+ String docId = null;
+ final String requiredProperties = PropertyIds.OBJECT_ID + "," + PropertyIds.OBJECT_TYPE_ID + ","
+ + PropertyIds.BASE_TYPE_ID;
+ ObjectInFolderList result = fNavSvc.getChildren(fRepositoryId, folderId, requiredProperties,
+ PropertyIds.OBJECT_TYPE_ID, false, IncludeRelationships.NONE, null, true, BigInteger.valueOf(-1),
+ BigInteger.valueOf(-1), null);
+ List<ObjectInFolderData> children = result.getObjects();
+ int numDocsFound = 0;
+ for (int i = 0; i < children.size(); i++) {
+ ObjectData child = children.get(i).getObject();
+ docId = (String) child.getProperties().getProperties().get(PropertyIds.OBJECT_ID).getFirstValue();
+ if (child.getBaseTypeId().equals(BaseTypeId.CMIS_DOCUMENT)) {
+ if (numDocsFound == index)
+ return docId;
+ else
+ numDocsFound++;
+ }
+ }
+ return docId;
+ }
+
+ /**
+ * return the total number of documents created
+ *
+ * @return
+ */
+ public int getDocumentsInTotal() {
+ return fDocumentsInTotalCount;
+ }
+
+ /**
+ * return the total number of folders created
+ *
+ * @return
+ */
+ public int getFoldersInTotal() {
+ return fFoldersInTotalCount;
+ }
+
+ /**
+ * return the total number of objects created
+ *
+ * @return
+ */
+ public int getObjectsInTotal() {
+ return fDocumentsInTotalCount + fFoldersInTotalCount;
+ }
+
+ public String createSingleDocument(String folderId) {
+ fTimeLoggerCreateDoc.reset();
+ String objectId = createDocument(folderId, 0, 0);
+ if (fCleanup)
+ deleteObject(objectId);
+ return objectId;
+ }
+
+ public String[] createDocuments(String folderId, int count) {
+
+ String result[];
+
+ fTimeLoggerCreateDoc.reset();
+ for (int i = 0; i < count; i++) {
+ String id = createDocument(folderId, 0, 0);
+ fTopLevelDocsCreated.add(id);
+ }
+ if (fCleanup) {
+ deleteTree();
+ result = null;
+ } else {
+ result = new String[count];
+ for (int i = 0; i < fTopLevelDocsCreated.size(); i++)
+ result[i] = fTopLevelDocsCreated.get(i);
+ }
+ return result;
+ }
+
+ public String[] createFolders(String folderId, int count) {
+
+ String result[];
+
+ fTimeLoggerCreateFolder.reset();
+ for (int i = 0; i < count; i++) {
+ createFolder(folderId);
+ }
+ if (fCleanup) {
+ deleteTree();
+ result = null;
+ } else {
+ result = new String[count];
+ for (int i = 0; i < fTopLevelFoldersCreated.size(); i++)
+ result[i] = fTopLevelFoldersCreated.get(i);
+ }
+ return result;
+ }
+
+ public void resetCounters() {
+ fDocumentsInTotalCount = fFoldersInTotalCount = 0;
+ }
+
+ public void printTimings() {
+ fTimeLoggerCreateDoc.printTimes();
+ fTimeLoggerCreateFolder.printTimes();
+ if (fCleanup)
+ fTimeLoggerDelete.printTimes();
+ }
+
+ public void logTimings() {
+ fTimeLoggerCreateDoc.logTimes();
+ fTimeLoggerCreateFolder.logTimes();
+ if (fCleanup)
+ fTimeLoggerDelete.logTimes();
+ }
+
+ private void createFolderHierachy(String parentId, int level, int levels, int childrenPerLevel) {
+ String id = null;
+
+ if (level >= levels)
+ return;
+
+ log.debug(" create folder for parent id: " + parentId + ", in level " + level + ", max levels " + levels);
+
+ for (int i = 0; i < childrenPerLevel; i++) {
+ Properties props = createFolderProperties(i, level);
+ try {
+ fTimeLoggerCreateFolder.start();
+ id = fObjSvc.createFolder(fRepositoryId, props, parentId, null, null, null, null);
+ if (level == 0)
+ fTopLevelFoldersCreated.add(id);
+ } finally {
+ fTimeLoggerCreateFolder.stop();
+ }
+
+ if (id != null) {
+ ++fFoldersInTotalCount;
+ createFolderHierachy(id, level + 1, levels, childrenPerLevel);
+ }
+ }
+ for (int j = 0; j < fNoDocumentsToCreate; j++) {
+ id = createDocument(parentId, j, level);
+ if (level == 0)
+ fTopLevelDocsCreated.add(id);
+ }
+ }
+
+ private String createFolder(String parentId) {
+ Properties props = createFolderProperties(0, 0);
+ String id = null;
+ try {
+ fTimeLoggerCreateFolder.start();
+ id = fObjSvc.createFolder(fRepositoryId, props, parentId, null, null, null, null);
+ fTopLevelFoldersCreated.add(id);
+ } finally {
+ fTimeLoggerCreateFolder.stop();
+ }
+ return id;
+ }
+
+ private String createDocument(String folderId, int no, int level) {
+ ContentStream contentStream = null;
+ VersioningState versioningState = VersioningState.NONE;
+ List<String> policies = null;
+ Acl addACEs = null;
+ Acl removeACEs = null;
+ ExtensionsData extension = null;
+
+ // log.info("create document in folder " + folderId);
+ Properties props = createDocumentProperties(no, level);
+ String id = null;
+ if (fContentSizeInK > 0)
+ contentStream = createContent();
+ try {
+ fTimeLoggerCreateDoc.start();
+ id = fObjSvc.createDocument(fRepositoryId, props, folderId, contentStream, versioningState, policies,
+ addACEs, removeACEs, extension);
+ } finally {
+ fTimeLoggerCreateDoc.stop();
+ }
+
+ if (null == id)
+ throw new RuntimeException("createDocument failed.");
+ ++fDocumentsInTotalCount;
+ return id;
+ }
+
+ private void deleteTree() {
+
+ // delete all documents from first level
+ for (String id : fTopLevelDocsCreated) {
+ deleteObject(id);
+ }
+
+ // delete recursively all folders from first level
+ for (String id : fTopLevelFoldersCreated) {
+ try {
+ fTimeLoggerDelete.start();
+ fObjSvc.deleteTree(fRepositoryId, id, true, UnfileObject.DELETE, true, null);
+ } finally {
+ fTimeLoggerDelete.stop();
+ }
+ }
+ }
+
+ private void deleteObject(String objectId) {
+ try {
+ fTimeLoggerDelete.start();
+ fObjSvc.deleteObject(fRepositoryId, objectId, true, null);
+ } finally {
+ fTimeLoggerDelete.stop();
+ }
+ }
+
+ private ContentStream createContent() {
+ ContentStreamImpl content = new ContentStreamImpl();
+ content.setFileName("data.txt");
+ content.setMimeType("text/plain");
+ int len = fContentSizeInK * 1024; // size of document in K
+ byte[] b = { 0x61, 0x62, 0x63, 0x64, 0x65, 0x66, 0x67, 0x68, 0x69, 0x6a, 0x6b, 0x6c, 0x6d, 0x6e, 0x0c, 0x0a,
+ 0x61, 0x62, 0x63, 0x64, 0x65, 0x66, 0x67, 0x68, 0x69, 0x6a, 0x6b, 0x6c, 0x6d, 0x6e, 0x0c, 0x0a }; // 32
+ // Bytes
+ ByteArrayOutputStream ba = new ByteArrayOutputStream(len);
+ try {
+ for (int j = 0; j < fContentSizeInK; j++) {
+ // write 1K of data
+ for (int i = 0; i < 32; i++)
+ ba.write(b);
+ }
+ } catch (IOException e) {
+ throw new RuntimeException("Failed to fill content stream with data", e);
+ }
+ content.setStream(new ByteArrayInputStream(ba.toByteArray()));
+ return content;
+ }
+
+ private Properties createFolderProperties(int no, int level) {
+ List<PropertyData<?>> properties = new ArrayList<PropertyData<?>>();
+ properties.add(fFactory.createPropertyStringData(PropertyIds.NAME, generateFolderNameValue(no, level)));
+ properties.add(fFactory.createPropertyIdData(PropertyIds.OBJECT_TYPE_ID, fFolderTypeId));
+ // Generate some property values for custom attributes
+ for (String stringPropId : fStringPropertyIdsToSetForFolder) {
+ properties.add(fFactory.createPropertyStringData(stringPropId, generateStringPropValueFolder()));
+ }
+ Properties props = fFactory.createPropertiesData(properties);
+ return props;
+ }
+
+ private Properties createDocumentProperties(int no, int level) {
+ List<PropertyData<?>> properties = new ArrayList<PropertyData<?>>();
+ properties.add(fFactory.createPropertyStringData(PropertyIds.NAME, generateDocNameValue(no, level)));
+ properties.add(fFactory.createPropertyIdData(PropertyIds.OBJECT_TYPE_ID, fDocTypeId));
+ // Generate some property values for custom attributes
+ for (String stringPropId : fStringPropertyIdsToSetForDocument) {
+ properties.add(fFactory.createPropertyStringData(stringPropId, generateStringPropValueDoc()));
+ }
+ Properties props = fFactory.createPropertiesData(properties);
+ return props;
+ }
+
+ private static synchronized int incrementPropCounterDocStringProp() {
+ return PROPVALCOUNTER_DOC_STRING_PROP++;
+ }
+
+ private static synchronized int incrementPropCounterFolderStringProp() {
+ return PROPVALCOUNTER_FOLDER_STRING_PROP++;
+ }
+
+ private String generateDocNameValue(int no, int level) {
+ if (fUseUuids)
+ return UUID.randomUUID().toString();
+ else
+ return NAMEPROPVALPREFIXDOC + level + "-" + no;
+ }
+
+ private String generateFolderNameValue(int no, int level) {
+ if (fUseUuids)
+ return UUID.randomUUID().toString();
+ else
+ return NAMEPROPVALPREFIXFOLDER + level + "-" + no;
+ }
+
+ private static String generateStringPropValueDoc() {
+ return STRINGPROPVALPREFIXDOC + incrementPropCounterDocStringProp();
+ }
+
+ private static String generateStringPropValueFolder() {
+ return STRINGPROPVALPREFIXFOLDER + incrementPropCounterFolderStringProp();
+ }
+
+ public void dumpFolder(String folderId, String propertyFilter) {
+ log.info("starting dumpFolder() id " + folderId + " ...");
+ boolean allRequiredPropertiesArePresent = propertyFilter != null && propertyFilter.equals("*"); // can
+ // be
+ // optimized
+ final String requiredProperties = allRequiredPropertiesArePresent ? propertyFilter : PropertyIds.OBJECT_ID
+ + "," + PropertyIds.NAME + "," + PropertyIds.OBJECT_TYPE_ID + "," + PropertyIds.BASE_TYPE_ID;
+ // if all required properties are contained in the filter use we use the
+ // filter otherwise
+ // we use our own set and get those from the filter later in an extra
+ // call
+ String propertyFilterIntern = allRequiredPropertiesArePresent ? propertyFilter : requiredProperties;
+ dumpFolder(folderId, propertyFilterIntern, 0);
+ }
+
+ private void dumpFolder(String folderId, String propertyFilter, int depth) {
+ boolean allRequiredPropertiesArePresent = propertyFilter.equals("*"); // can
+ // be
+ // optimized
+ StringBuilder prefix = new StringBuilder();
+ for (int i = 0; i < depth; i++)
+ prefix.append(" ");
+
+ ObjectInFolderList result = fNavSvc.getChildren(fRepositoryId, folderId, propertyFilter, null, false,
+ IncludeRelationships.NONE, null, true, BigInteger.valueOf(-1), BigInteger.valueOf(-1), null);
+ List<ObjectInFolderData> folders = result.getObjects();
+ if (null != folders) {
+ log.info(prefix + "found " + folders.size() + " children in folder " + folderId);
+ int no = 0;
+ for (ObjectInFolderData folder : folders) {
+ log.info(prefix.toString() + ++no + ": found object with id: " + folder.getObject().getId()
+ + " and path segment: " + folder.getPathSegment());
+ dumpObjectProperties(folder.getObject(), depth, propertyFilter, !allRequiredPropertiesArePresent);
+ String objectTypeBaseId = folder.getObject().getBaseTypeId().value();
+ if (objectTypeBaseId.equals(BaseTypeId.CMIS_FOLDER.value())) {
+ dumpFolder(folder.getObject().getId(), propertyFilter, depth + 1);
+ } else if (objectTypeBaseId.equals(BaseTypeId.CMIS_DOCUMENT.value())) {
+ dumpObjectProperties(folder.getObject(), depth + 1, propertyFilter,
+ !allRequiredPropertiesArePresent);
+ }
+ }
+ }
+ log.info(""); // add empty line
+ }
+
+ private void dumpObjectProperties(ObjectData object, int depth, String propertyFilter, boolean mustFetchProperties) {
+ final SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd'T'HH:mm:ssZ");
+ StringBuilder prefix = new StringBuilder();
+ for (int i = 0; i < depth; i++)
+ prefix.append(" ");
+
+ log.info(prefix + "found object id " + object.getId());
+ Map<String, PropertyData<?>> propMap;
+ if (mustFetchProperties) {
+ String objId = (String) object.getProperties().getProperties().get(PropertyIds.OBJECT_ID).getFirstValue();
+ Properties props = fObjSvc.getProperties(fRepositoryId, objId, propertyFilter, null);
+ propMap = props.getProperties();
+ } else {
+ propMap = object.getProperties().getProperties();
+ }
+ StringBuilder valueStr = new StringBuilder("[");
+ for (Map.Entry<String, PropertyData<?>> entry : propMap.entrySet()) {
+ if (entry.getValue().getValues().size() > 1) {
+ if (entry.getValue().getFirstValue() instanceof GregorianCalendar) {
+ for (Object obj : entry.getValue().getValues()) {
+ GregorianCalendar cal = (GregorianCalendar) obj;
+ valueStr.append(df.format(cal.getTime()) + ", ");
+ }
+ valueStr.append("]");
+ } else {
+ valueStr = new StringBuilder(entry.getValue().getValues().toString());
+ }
+ } else {
+ Object value = entry.getValue().getFirstValue();
+ if (null != value) {
+ valueStr = new StringBuilder(value.toString());
+ if (value instanceof GregorianCalendar) {
+ valueStr = new StringBuilder(df.format(((GregorianCalendar) entry.getValue().getFirstValue())
+ .getTime()));
+ }
+ }
+ }
+ log.info(prefix + entry.getKey() + ": " + valueStr);
+ }
+ log.info(""); // add empty line
+ }
}
Modified: incubator/chemistry/opencmis/trunk/chemistry-opencmis-test/chemistry-opencmis-test-util/src/main/java/org/apache/chemistry/opencmis/util/repository/TimeLogger.java
URL: http://svn.apache.org/viewvc/incubator/chemistry/opencmis/trunk/chemistry-opencmis-test/chemistry-opencmis-test-util/src/main/java/org/apache/chemistry/opencmis/util/repository/TimeLogger.java?rev=934907&r1=934906&r2=934907&view=diff
==============================================================================
--- incubator/chemistry/opencmis/trunk/chemistry-opencmis-test/chemistry-opencmis-test-util/src/main/java/org/apache/chemistry/opencmis/util/repository/TimeLogger.java (original)
+++ incubator/chemistry/opencmis/trunk/chemistry-opencmis-test/chemistry-opencmis-test-util/src/main/java/org/apache/chemistry/opencmis/util/repository/TimeLogger.java Fri Apr 16 14:21:47 2010
@@ -24,234 +24,234 @@ import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
/**
- * Simple utility class for time logging
- * Note: NOT thread safe!
+ * Simple utility class for time logging Note: NOT thread safe!
*
* @author Jens
- *
+ *
*/
public class TimeLogger {
- private static Log LOG = LogFactory.getLog(TimeLogger.class);
+ private static Log LOG = LogFactory.getLog(TimeLogger.class);
+
+ private static class TimeRecord {
+ public long fStart;
+ public long fStop;
+ };
+
+ private String fAction;
+ private LinkedList<TimeRecord> fTimeRecs = new LinkedList<TimeRecord>();
+ private final int maxSize = 2500;
+ TimeRecord fCurrentRec;
+
+ public TimeLogger() {
+ fAction = "";
+ fTimeRecs = new LinkedList<TimeRecord>();
+ }
+
+ public TimeLogger(String action) {
+ fAction = action;
+ }
+
+ public void start() {
+ createAndAddNewRecord();
+ fCurrentRec.fStart = System.currentTimeMillis();
+ }
+
+ public void stop() {
+ fCurrentRec.fStop = System.currentTimeMillis();
+ }
+
+ public void reset() {
+ fTimeRecs.clear();
+ }
+
+ public void logTimes() {
+ long size = fTimeRecs.size();
+ if (size == 0)
+ LOG.info("No samples for " + fAction + " available. ");
+ else if (size == 1)
+ LOG.info("Time elapsed for " + fAction + ": " + getLastTime());
+ else {
+ LOG.info("Timings for " + size + " samples for action " + fAction + ": ");
+ LOG.info(" Average: " + getAverageTime() + "ms");
+ LOG.info(" Min : " + getMinTime() + "ms");
+ LOG.info(" Max : " + getMaxTime() + "ms");
+ LOG.info(" Total : " + getTotalTime() + "ms");
+ }
+ }
+
+ public void printTimes() {
+ long size = fTimeRecs.size();
+ if (size == 0)
+ System.out.println("No samples for " + fAction + " available. ");
+ else if (size == 1)
+ System.out.println("Time elapsed for " + fAction + ": " + getLastTime());
+ else {
+ System.out.println("Timings for " + size + " samples for action " + fAction + ": ");
+ System.out.println(" Average: " + getAverageTime() + "ms");
+ System.out.println(" Min : " + getMinTime() + "ms");
+ System.out.println(" Max : " + getMaxTime() + "ms");
+ System.out.println(" Total : " + getTotalTime() + "ms");
+ }
+ }
+
+ public long getLastTime() {
+ TimeRecord lastRec = fTimeRecs.getLast();
+ if (null != lastRec)
+ return lastRec.fStop - lastRec.fStart;
+ else
+ return 0;
+ }
+
+ private void createAndAddNewRecord() {
+ if (fTimeRecs.size() < maxSize) {
+ fCurrentRec = new TimeRecord();
+ fTimeRecs.add(fCurrentRec);
+ }
+ }
+
+ private long getAverageTime() {
+ long sum = 0;
+ long size = fTimeRecs.size();
+
+ if (0 == fTimeRecs.size())
+ return 0;
+
+ for (TimeRecord tm : fTimeRecs) {
+ sum += tm.fStop - tm.fStart;
+ }
+ return (sum + size / 2) / size;
+ }
+
+ private long getMinTime() {
+ long min = Long.MAX_VALUE;
+
+ if (0 == fTimeRecs.size())
+ return 0;
+
+ for (TimeRecord tm : fTimeRecs) {
+ long val = tm.fStop - tm.fStart;
+ if (val < min)
+ min = val;
+ }
+ return min;
+
+ }
+
+ private long getMaxTime() {
+ long max = Long.MIN_VALUE;
+
+ if (0 == fTimeRecs.size())
+ return 0;
+
+ for (TimeRecord tm : fTimeRecs) {
+ long val = tm.fStop - tm.fStart;
+ if (val > max)
+ max = val;
+ }
+ return max;
+ }
+
+ private long getTotalTime() {
+ long sum = 0;
+
+ for (TimeRecord tm : fTimeRecs) {
+ sum += tm.fStop - tm.fStart;
+ }
+ return sum;
+ }
+
+ ////////////////////////////////////////////////////////////////////////////
+ // ////////
+ //
+ // Same methods used for multithreaded logging
+
+ public static void logTimes(TimeLogger[] loggers) {
+ long size = 0;
+ if (null == loggers)
+ return;
+
+ for (int i = 0; i < loggers.length; i++)
+ size += loggers[i].fTimeRecs.size();
+
+ LOG.info("Timings for " + size + " samples for action " + loggers[0].fAction + ": ");
+ LOG.info(" Average: " + getAverageTime(loggers) + "ms");
+ LOG.info(" Min : " + getMinTime(loggers) + "ms");
+ LOG.info(" Max : " + getMaxTime(loggers) + "ms");
+ LOG.info(" Total : " + getTotalTime(loggers) + "ms");
+ }
+
+ public static void printTimes(TimeLogger[] loggers) {
+ long size = 0;
+ if (null == loggers)
+ return;
+
+ for (int i = 0; i < loggers.length; i++)
+ size += loggers[i].fTimeRecs.size();
+
+ System.out.println("Timings for " + size + " samples for action " + loggers[0].fAction + ": ");
+ System.out.println(" Average: " + getAverageTime(loggers) + "ms");
+ System.out.println(" Min : " + getMinTime(loggers) + "ms");
+ System.out.println(" Max : " + getMaxTime(loggers) + "ms");
+ System.out.println(" Total : " + getTotalTime(loggers) + "ms");
+
+ }
+
+ static private long getAverageTime(TimeLogger[] loggers) {
+ long sum = 0;
+ long size = 0;
+
+ for (int i = 0; i < loggers.length; i++)
+ size += loggers[i].fTimeRecs.size();
+
+ if (size == 0)
+ return 0;
+
+ for (int i = 0; i < loggers.length; i++) {
+ if (0 == loggers[i].fTimeRecs.size())
+ continue;
+
+ for (TimeRecord tm : loggers[i].fTimeRecs) {
+ sum += tm.fStop - tm.fStart;
+ }
+ }
+
+ return (sum + size / 2) / size;
+ }
+
+ static private long getMaxTime(TimeLogger[] loggers) {
+ long max = Long.MIN_VALUE;
+
+ for (int i = 0; i < loggers.length; i++) {
+ long val = loggers[i].getMaxTime();
+ if (val > max)
+ max = val;
+ }
+
+ return max;
+ }
+
+ static private long getMinTime(TimeLogger[] loggers) {
+ long min = Long.MAX_VALUE;
+
+ for (int i = 0; i < loggers.length; i++) {
+ long val = loggers[i].getMinTime();
+ if (val < min)
+ min = val;
+ }
+
+ return min;
+ }
+
+ static private long getTotalTime(TimeLogger[] loggers) {
+ long totalTime = Long.MIN_VALUE;
+
+ for (int i = 0; i < loggers.length; i++) {
+ long val = loggers[i].getTotalTime();
+ if (val > totalTime)
+ totalTime = val;
+ }
+
+ return totalTime;
+ }
- private static class TimeRecord {
- public long fStart;
- public long fStop;
- };
-
- private String fAction;
- private LinkedList<TimeRecord> fTimeRecs = new LinkedList<TimeRecord>();
- private final int maxSize = 2500;
- TimeRecord fCurrentRec;
-
- public TimeLogger() {
- fAction = "";
- fTimeRecs = new LinkedList<TimeRecord>();
- }
-
- public TimeLogger(String action) {
- fAction = action;
- }
-
- public void start() {
- createAndAddNewRecord();
- fCurrentRec.fStart = System.currentTimeMillis();
- }
-
- public void stop() {
- fCurrentRec.fStop = System.currentTimeMillis();
- }
-
- public void reset() {
- fTimeRecs.clear();
- }
-
- public void logTimes() {
- long size = fTimeRecs.size();
- if (size==0)
- LOG.info("No samples for " + fAction + " available. ");
- else if (size==1)
- LOG.info("Time elapsed for " + fAction + ": " + getLastTime());
- else {
- LOG.info("Timings for " + size + " samples for action " + fAction + ": ");
- LOG.info(" Average: " + getAverageTime() + "ms");
- LOG.info(" Min : " + getMinTime() + "ms");
- LOG.info(" Max : " + getMaxTime() + "ms");
- LOG.info(" Total : " + getTotalTime() + "ms");
- }
- }
-
- public void printTimes() {
- long size = fTimeRecs.size();
- if (size==0)
- System.out.println("No samples for " + fAction + " available. ");
- else if (size==1)
- System.out.println("Time elapsed for " + fAction + ": " + getLastTime());
- else {
- System.out.println("Timings for " + size + " samples for action " + fAction + ": ");
- System.out.println(" Average: " + getAverageTime() + "ms");
- System.out.println(" Min : " + getMinTime() + "ms");
- System.out.println(" Max : " + getMaxTime() + "ms");
- System.out.println(" Total : " + getTotalTime() + "ms");
- }
- }
-
- public long getLastTime() {
- TimeRecord lastRec = fTimeRecs.getLast();
- if (null != lastRec)
- return lastRec.fStop-lastRec.fStart;
- else
- return 0;
- }
-
- private void createAndAddNewRecord() {
- if (fTimeRecs.size() < maxSize) {
- fCurrentRec = new TimeRecord();
- fTimeRecs.add(fCurrentRec);
- }
- }
-
- private long getAverageTime() {
- long sum = 0;
- long size = fTimeRecs.size();
-
- if (0 == fTimeRecs.size())
- return 0;
-
- for (TimeRecord tm : fTimeRecs) {
- sum += tm.fStop - tm.fStart;
- }
- return (sum + size/2) / size;
- }
-
- private long getMinTime() {
- long min = Long.MAX_VALUE;
-
- if (0 == fTimeRecs.size())
- return 0;
-
- for (TimeRecord tm : fTimeRecs) {
- long val = tm.fStop - tm.fStart;
- if (val < min)
- min = val;
- }
- return min;
-
- }
-
- private long getMaxTime() {
- long max = Long.MIN_VALUE;
-
- if (0 == fTimeRecs.size())
- return 0;
-
- for (TimeRecord tm : fTimeRecs) {
- long val = tm.fStop - tm.fStart;
- if (val > max)
- max = val;
- }
- return max;
- }
-
- private long getTotalTime() {
- long sum = 0;
-
- for (TimeRecord tm : fTimeRecs) {
- sum += tm.fStop - tm.fStart;
- }
- return sum;
- }
-
- ////////////////////////////////////////////////////////////////////////////////////
- //
- // Same methods used for multithreaded logging
-
- public static void logTimes(TimeLogger[] loggers) {
- long size=0;
- if (null == loggers)
- return;
-
- for (int i=0; i<loggers.length; i++)
- size += loggers[i].fTimeRecs.size();
-
- LOG.info("Timings for " + size + " samples for action " + loggers[0].fAction + ": ");
- LOG.info(" Average: " + getAverageTime(loggers) + "ms");
- LOG.info(" Min : " + getMinTime(loggers) + "ms");
- LOG.info(" Max : " + getMaxTime(loggers) + "ms");
- LOG.info(" Total : " + getTotalTime(loggers) + "ms");
- }
-
- public static void printTimes(TimeLogger[] loggers) {
- long size=0;
- if (null == loggers)
- return;
-
- for (int i=0; i<loggers.length; i++)
- size += loggers[i].fTimeRecs.size();
-
- System.out.println("Timings for " + size + " samples for action " + loggers[0].fAction + ": ");
- System.out.println(" Average: " + getAverageTime(loggers) + "ms");
- System.out.println(" Min : " + getMinTime(loggers) + "ms");
- System.out.println(" Max : " + getMaxTime(loggers) + "ms");
- System.out.println(" Total : " + getTotalTime(loggers) + "ms");
-
- }
-
- static private long getAverageTime(TimeLogger[] loggers) {
- long sum = 0;
- long size=0;
-
- for (int i=0; i<loggers.length; i++)
- size += loggers[i].fTimeRecs.size();
-
- if (size==0)
- return 0;
-
- for (int i=0; i<loggers.length; i++) {
- if (0 == loggers[i].fTimeRecs.size())
- continue;
-
- for (TimeRecord tm : loggers[i].fTimeRecs) {
- sum += tm.fStop - tm.fStart;
- }
- }
-
- return (sum + size/2) / size;
- }
-
- static private long getMaxTime(TimeLogger[] loggers) {
- long max = Long.MIN_VALUE;
-
- for (int i=0; i<loggers.length; i++) {
- long val = loggers[i].getMaxTime();
- if (val > max)
- max = val;
- }
-
- return max;
- }
-
- static private long getMinTime(TimeLogger[] loggers) {
- long min = Long.MAX_VALUE;
-
- for (int i=0; i<loggers.length; i++) {
- long val = loggers[i].getMinTime();
- if (val < min)
- min = val;
- }
-
- return min;
- }
-
- static private long getTotalTime(TimeLogger[] loggers) {
- long totalTime = Long.MIN_VALUE;
-
- for (int i=0; i<loggers.length; i++) {
- long val = loggers[i].getTotalTime();
- if (val > totalTime)
- totalTime = val;
- }
-
- return totalTime;
- }
-
}