package ch07.section08;

import java.io.*;
import java.net.*;
import java.util.*;

class SonServerThreadTest
    extends ServerThread {
  private long FIVE_SECONDS = 5000;

  public SonServerThreadTest() throws IOException {
    super("SonServerThreadTest");
  }

  public void run() {
    while (moreQuotes) {
      try {
        byte[] buf = new byte[256];

        // construct quote
        String dString = null;
        if (in == null) {
          dString = new Date().toString();
        }
        else {
          dString = getNextQuote();
        }
        buf = dString.getBytes();

        // send it
        InetAddress group = InetAddress.getByName("10.189.0.88");
        DatagramPacket packet = new DatagramPacket(buf, buf.length, group,
            4446);
        socket.send(packet);

        // sleep for a while
        try {
          sleep( (long) (Math.random() * FIVE_SECONDS));
        }
        catch (InterruptedException e) {}
      }
      catch (IOException e) {
        e.printStackTrace();
        moreQuotes = false;
      }
    }
    socket.close();
  }
}