001    /*
002     * Copyright (c) 2009 The openGion Project.
003     *
004     * Licensed under the Apache License, Version 2.0 (the "License");
005     * you may not use this file except in compliance with the License.
006     * You may obtain a copy of the License at
007     *
008     *     http://www.apache.org/licenses/LICENSE-2.0
009     *
010     * Unless required by applicable law or agreed to in writing, software
011     * distributed under the License is distributed on an "AS IS" BASIS,
012     * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND,
013     * either express or implied. See the License for the specific language
014     * governing permissions and limitations under the License.
015     */
016    package org.opengion.plugin.daemon;
017    
018    import org.opengion.hayabusa.common.HybsSystem;
019    import org.opengion.fukurou.util.Shell;
020    import org.opengion.fukurou.util.StringUtil;
021    import org.opengion.fukurou.util.HybsTimerTask;
022    import java.io.File;
023    import java.util.Date;
024    
025    /**
026     * 縲心hell螳溯｡後?
027     * 謖?ｮ壹＠縺溘ヱ繝ｩ繝｡繝ｼ繧ｿ縺ｧShell繧貞ｮ溯｡後＠縺ｾ縺吶?
028     * 縺薙?繧ｯ繝ｩ繧ｹ縺ｯ縲？ybsTimerTask 繧堤ｶ呎価縺励◆ 繧ｿ繧､繝槭?繧ｿ繧ｹ繧ｯ繧ｯ繝ｩ繧ｹ縺ｧ縺吶?
029     * startDaemon() 縺後ち繧､繝槭?繧ｿ繧ｹ繧ｯ縺ｫ繧医▲縺ｦ縲∝他縺ｳ蜃ｺ縺輔ｌ縺ｾ縺吶?
030     *
031     * 謗･邯壹?縺溘ａ縺ｮ繝代Λ繝｡繝ｼ繧ｿ縺ｯ莉･荳九〒縺?
032     * fukurou縺ｮShell繧偵く繝?け縺吶ｋ繝代Λ繝｡繝ｼ繧ｿ縺ｨ蜷後§縺ｧ縺吶?
033     * program       : 蜍穂ｽ懊?繧ｪ繧ｰ繝ｩ繝?
034     * workDir       : 螳溯｡後ョ繧｣繝ｬ繧ｯ繝医Μ
035     * useBatch      : BATCH繝励Ο繧ｻ繧ｹ繧貞ｮ溯｡後☆繧九?縺九←縺?°(蛻晄悄蛟､:false)
036     * stdout        : 讓呎ｺ門?繧貞?蜉帙☆繧九°縺ｩ縺?°(蛻晄悄蛟､:false)
037     * stderr        : 繧ｨ繝ｩ繝ｼ蜃ｺ蜉帙ｒ蜃ｺ蜉帙☆繧九°縺ｩ縺?°(蛻晄悄蛟､:false)
038     * wait          : 繝励Ο繧ｻ繧ｹ縺ｮ邨ゆｺ?ｒ蠕?▽(true)/蠕?◆縺ｪ縺?false) (蛻晄悄蛟､:true)
039     *      
040     *
041     *
042     * @og.rev 5.6.9.1 (2013/10/11) 譁ｰ隕丈ｽ懈?
043     * @og.group 繝??繝｢繝ｳ
044     *
045     * @version  4.0
046     * @author   Takahashi Masakazu
047     * @since    JDK5.0,
048     */
049    public class Daemon_RunShell extends HybsTimerTask {
050    
051            private static final int LOOP_COUNTER = 24; // 繧ｫ繧ｦ繝ｳ繧ｿ繧?4蝗槭↓險ｭ螳?
052    
053            private int loopCnt = 0;
054    
055            private boolean   debug = false;
056            private String    program  = null;
057            private boolean   useBatch = false;     // BATCH繝励Ο繧ｻ繧ｹ繧貞ｮ溯｡後☆繧九?縺九←縺?°(蛻晄悄蛟､:false)
058            private boolean   stdout   = false;     // 讓呎ｺ門?繧貞?蜉帙☆繧九°縺ｩ縺?°(蛻晄悄蛟､:false)
059            private boolean   stderr   = false;     // 繧ｨ繝ｩ繝ｼ蜃ｺ蜉帙ｒ蜃ｺ蜉帙☆繧九°縺ｩ縺?°(蛻晄悄蛟､:false)
060            private boolean   wait     = true;      // 繝励Ο繧ｻ繧ｹ縺ｮ邨ゆｺ?ｒ蠕?▽(true)/蠕?◆縺ｪ縺?false) (蛻晄悄蛟､:true)
061            private File      workDir  = null;
062            // 3.6.1.0 (2005/01/05) 繧ｿ繧､繝?い繧ｦ繝域凾髢薙ｒ險ｭ螳?
063            private int timeout                     = HybsSystem.sysInt( "SHELL_TIMEOUT" );
064            
065            private Shell shell;
066    
067            /**
068             * 縺薙?繧ｿ繧､繝槭?繧ｿ繧ｹ繧ｯ縺ｫ繧医▲縺ｦ蛻晄悄蛹悶＆繧後ｋ繧｢繧ｯ繧ｷ繝ｧ繝ｳ縺ｧ縺吶?
069             * 繝代Λ繝｡繝ｼ繧ｿ繧剃ｽｿ逕ｨ縺励◆蛻晄悄蛹悶ｒ陦後＞縺ｾ縺吶?
070             *
071             */
072            @Override
073            public void initDaemon() {
074                    debug = StringUtil.nval( getValue( "DEBUG" ),debug ) ;
075                    program         = StringUtil.nval( getValue( "program" ), program );
076                    useBatch        = StringUtil.nval( getValue( "useBatch" ), useBatch );
077                    stdout          = StringUtil.nval( getValue( "stdout" ), stdout );
078                    stderr          = StringUtil.nval( getValue( "stderr" ), stderr );
079                    wait            = StringUtil.nval( getValue( "wait" ), wait   );
080                    if( getValue( "workDir" ) != null ){ workDir = new File(getValue( "workDir" ));  }
081                    shell = new Shell();
082                    shell.setCommand( program,useBatch );
083                    shell.setWait( wait );
084                    shell.setTimeout( timeout );            // 3.6.1.0 (2005/01/05)
085                    shell.setWorkDir( workDir );
086                    if(debug){System.out.println(program+"/"+useBatch+"/"+wait+"/"+timeout+"/"+workDir.toString());}
087            }
088    
089            /**
090             * 繧ｿ繧､繝槭?繧ｿ繧ｹ繧ｯ縺ｮ繝??繝｢繝ｳ蜃ｦ逅??髢句ｧ九?繧､繝ｳ繝医〒縺吶?
091             *
092             */
093            @Override
094            protected void startDaemon() {
095                    if( loopCnt % LOOP_COUNTER == 0 ) {
096                            loopCnt = 1;
097                            System.out.println( toString() + " " + new Date()  + " " );
098                    }
099                    else {
100                            loopCnt++ ;
101                    }
102                    // 螳溯｡?
103                    int rtnCode = shell.exec();             // 0 縺ｯ豁｣蟶ｸ邨ゆｺ?ｒ遉ｺ縺?
104                    if( rtnCode < 0 ){System.out.println( "Shell Run Error:" + program );}
105            }
106    
107            /**
108             * 縺薙?繧ｿ繧､繝槭?繧ｿ繧ｹ繧ｯ縺ｮcancel() 繝｡繧ｽ繝?ラ繧偵が繝ｼ繝舌?繝ｩ繧､繝峨＠縺ｾ縺吶?
109             * HybsTimerTaskManager#cancelTask( int ) 繧貞ｮ溯｡後＠縺ｾ縺吶?
110             *
111             * @og.rev 4.3.1.1 (2008/08/23) super.cancel() 縺ｮ縺ｿ螳溯｡後↑繧峨?繧ｪ繝ｼ繝舌?繝ｩ繧､繝峨?蠢?ｦ√?縺ｪ縺?
112             *
113             * @see java.util.TimerTask#cancel()
114             */
115    //      public boolean cancel() {
116    //              return super.cancel();
117    //      }
118    
119    }
120