trunk/com/so/news/NNTPDaemon.java
author chris <chris@marvin>
Tue, 20 Jan 2009 10:21:03 +0100
changeset 0 f907866f0e4b
permissions -rw-r--r--
Initial import.
chris@0
     1
/*
chris@0
     2
 *   StarOffice News Server
chris@0
     3
 *   see AUTHORS for the list of contributors
chris@0
     4
 *
chris@0
     5
 *   This program is free software: you can redistribute it and/or modify
chris@0
     6
 *   it under the terms of the GNU General Public License as published by
chris@0
     7
 *   the Free Software Foundation, either version 3 of the License, or
chris@0
     8
 *   (at your option) any later version.
chris@0
     9
 *
chris@0
    10
 *   This program is distributed in the hope that it will be useful,
chris@0
    11
 *   but WITHOUT ANY WARRANTY; without even the implied warranty of
chris@0
    12
 *   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
chris@0
    13
 *   GNU General Public License for more details.
chris@0
    14
 *
chris@0
    15
 *   You should have received a copy of the GNU General Public License
chris@0
    16
 *   along with this program.  If not, see <http://www.gnu.org/licenses/>.
chris@0
    17
 */
chris@0
    18
chris@0
    19
package com.so.news;
chris@0
    20
chris@0
    21
import java.io.IOException;
chris@0
    22
import java.net.ServerSocket;
chris@0
    23
chris@0
    24
/**
chris@0
    25
 * Server component of the n3tpd.
chris@0
    26
 * @author Christian Lins
chris@0
    27
 * @author Dennis Schwerdel
chris@0
    28
 */
chris@0
    29
public class NNTPDaemon extends Thread
chris@0
    30
{
chris@0
    31
  private ServerSocket socket;
chris@0
    32
chris@0
    33
  public NNTPDaemon(boolean aux) throws IOException
chris@0
    34
  {
chris@0
    35
    int port; 
chris@0
    36
    if(!aux)
chris@0
    37
      port = Config.getInstance().get("n3tpd.port", 119);
chris@0
    38
    else
chris@0
    39
      port = Config.getInstance().get("n3tpd.auxport", 8080);
chris@0
    40
    
chris@0
    41
    int backlog = Config.getInstance().get("n3tpd.server.backlog", 10);
chris@0
    42
    
chris@0
    43
    // Create and bind the socket
chris@0
    44
    socket = new ServerSocket(port, backlog);
chris@0
    45
  }
chris@0
    46
chris@0
    47
  @Override
chris@0
    48
  public void run()
chris@0
    49
  {
chris@0
    50
    System.out.println("Daemon listening on port " + socket.getLocalPort() + " ...");
chris@0
    51
    
chris@0
    52
    while(isAlive() && !isInterrupted())
chris@0
    53
    {
chris@0
    54
      try
chris@0
    55
      {
chris@0
    56
        new NNTPConnection(socket.accept()).start();
chris@0
    57
      }
chris@0
    58
      catch (Exception e)
chris@0
    59
      {
chris@0
    60
        e.printStackTrace();
chris@0
    61
      }
chris@0
    62
    }
chris@0
    63
  }
chris@0
    64
}