Kleinere Anpassungen

undisclosed

2023-01-08 933ccd346f0a38218491e95a0c8dc28ff667db78

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
/*
    Calypso - Media Player Remote Control via HTTP for Raspberry Pi
    Copyright (C) 2021-2023  Ulrich Hilger
 
    This program is free software: you can redistribute it and/or modify
    it under the terms of the GNU Affero General Public License as
    published by the Free Software Foundation, either version 3 of the
    License, or (at your option) any later version.
 
    This program is distributed in the hope that it will be useful,
    but WITHOUT ANY WARRANTY; without even the implied warranty of
    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
    GNU Affero General Public License for more details.
 
    You should have received a copy of the GNU Affero General Public License
    along with this program.  If not, see <https://www.gnu.org/licenses/>.
*/
 
package de.uhilger.calypso.neu;
 
import java.util.logging.Logger;
import java.util.logging.Level;
import java.util.List;
import java.util.ArrayList;
import java.util.Iterator;
 
public class MeldeThread extends Thread {
  
  private static final Logger logger = Logger.getLogger(MeldeThread.class.getName());
  
  private Process omxplayer;
  private int exitValue;
  private List<ProzessLauscher> lauscher = new ArrayList<>();
  private String meldeUrlStr;
  
  public void setProcess(Process p) {
    this.omxplayer = p;
  }
  
  public int getExitValue() {
    return exitValue;
  }
  
  public void setMeldeUrl(String meldeUrlStr) {
    this.meldeUrlStr = meldeUrlStr;
  }
  
  /**
   * ausfuehren des Threads
   */
  @Override
  public void run() {
    try {
      exitValue = omxplayer.waitFor();
      prozessBeendetMelden();
      lauscher.clear();
      lauscher = null;
    } catch(InterruptedException ex) {
      logger.log(Level.FINE, ex.getMessage(), ex);
    } finally {
      aufraeumen();
    }
  }
  
  private void aufraeumen() {
    lauscher.clear();
    lauscher = null;
  }
  
  public void lauscherHinzufuegen(ProzessLauscher l) {
    lauscher.add(l);
  }
  
  public void lauscherEntfernen(ProzessLauscher l) {
    lauscher.remove(l);
  }
  
  private void prozessBeendetMelden() {
    logger.log(Level.FINER, 
              "Alle Lauscher werden ueber beendeten Abspielprozess verstaendigt..");
    Iterator<ProzessLauscher> i = lauscher.iterator();
    while(i.hasNext()) {
      ProzessLauscher l = i.next();
      l.prozessBeendet(meldeUrlStr);
    }
  }
  
}