qadevOOo/runner/helper/OfficeWatcher.java

   1 /*
   2  * This file is part of the LibreOffice project.
   3  *
   4  * This Source Code Form is subject to the terms of the Mozilla Public
   5  * License, v. 2.0. If a copy of the MPL was not distributed with this
   6  * file, You can obtain one at http://mozilla.org/MPL/2.0/.
   7  *
   8  * This file incorporates work covered by the following license notice:
   9  *
  10  *   Licensed to the Apache Software Foundation (ASF) under one or more
  11  *   contributor license agreements. See the NOTICE file distributed
  12  *   with this work for additional information regarding copyright
  13  *   ownership. The ASF licenses this file to you under the Apache
  14  *   License, Version 2.0 (the "License"); you may not use this file
  15  *   except in compliance with the License. You may obtain a copy of
  16  *   the License at http://www.apache.org/licenses/LICENSE-2.0 .
  17  */
  18 package helper;
  19
  20 import lib.TestParameters;
  21 import java.util.StringTokenizer;
  22 import util.utils;
  23
  24 public class OfficeWatcher extends Thread implements share.Watcher {
  25
  26     public boolean finish;
  27     private TestParameters params;
  28     private int StoredPing = 0;
  29     private boolean debug = false;
  30
  31     /** Creates new OfficeWatcher
  32      * @param param
  33      */
  34     public OfficeWatcher(TestParameters param) {
  35         finish = false;
  36         this.params = param;
  37         debug = params.getBool(util.PropertyName.DEBUG_IS_ACTIVE);
  38     }
  39
  40     /**
  41      * pings the office watcher to check for changes
  42      */
  43     public void ping() {
  44         try {
  45             StoredPing++;
  46         } catch (Exception e) {
  47             StoredPing = 0;
  48         }
  49     }
  50
  51     /**
  52      * returns the amount of pings
  53      * @return returns the amount of pings
  54      */
  55     public int getPing() {
  56         return StoredPing;
  57     }
  58
  59     public void run() {
  60         dbg("started");
  61         boolean isDone = false;
  62         final ProcessHandler ph = (ProcessHandler) params.get("AppProvider");
  63         int timeOut = params.getInt("TimeOut");
  64         if (ph == null) {
  65             isDone = true;
  66         }
  67         while (!isDone) {
  68             timeOut = params.getInt("TimeOut");
  69             final int previous = StoredPing;
  70             shortWait(timeOut == 0 ? 30000 : timeOut);
  71             // a timeout with value 0 lets watcher not react.
  72             if ((StoredPing == previous) && timeOut != 0) {
  73                 isDone = true;
  74             }
  75             // execute in case the watcher is not needed anymore
  76             if (finish) {
  77                 return;
  78             }
  79         }
  80         if (ph != null) {
  81             dbg("the Office is idle for " + timeOut / 1000 +
  82                 " seconds, it probably hangs and is killed NOW.");
  83             final String AppKillCommand = (String) params.get(util.PropertyName.APP_KILL_COMMAND);
  84             if (AppKillCommand != null) {
  85                 final StringTokenizer aKillCommandToken = new StringTokenizer(AppKillCommand, ";");
  86                 while (aKillCommandToken.hasMoreTokens()) {
  87                     final String sKillCommand = aKillCommandToken.nextToken();
  88
  89                     dbg("User defined an application to destroy the started process.");
  90                     dbg("Trying to execute: " + sKillCommand);
  91
  92                     final ProcessHandler pHdl = new ProcessHandler(sKillCommand);
  93                     pHdl.executeSynchronously();
  94 //                    dbg("---> Output of killoffice:");
  95 //                    dbg(pHdl.getOutputText());
  96 //                    dbg("<--- Output of killoffice");
  97 //                    dbg("---> Error output of killoffice:");
  98 //                    dbg(pHdl.getErrorText());
  99 //                    dbg("<--- Error output of killoffice");
 100
 101                 }
 102             }
 103             ph.kill();
 104         } else {
 105             dbg("reaeched timeout but ProcessHandler is NULL");
 106         }
 107         shortWait(timeOut == 0 ? 30000 : timeOut);
 108         dbg("finished");
 109     }
 110
 111     protected void shortWait(int timeOut) {
 112         try {
 113             OfficeWatcher.sleep(timeOut);
 114         } catch (java.lang.InterruptedException ie) {
 115         }
 116     }
 117
 118     protected void dbg(String message) {
 119         if (debug) {
 120             System.out.println(utils.getDateTime() + "OfficeWatcher: " + message);
 121         }
 122     }
 123 }