File: ServerConnection.java

package info (click to toggle)
speech-tools 1%3A2.5.0-11
  • links: PTS, VCS
  • area: main
  • in suites: bullseye
  • size: 9,988 kB
  • sloc: cpp: 67,350; ansic: 12,174; sh: 4,055; java: 3,748; makefile: 1,111; lisp: 711; perl: 396; awk: 85; xml: 9
file content (129 lines) | stat: -rw-r--r-- 4,769 bytes parent folder | download | duplicates (12)
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
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129

 //\\//\\//\\//\\//\\//\\//\\//\\//\\//\\//\\//\\//\\//\\//\\//\\//\\//\\//\\
 //                                                                        \\
 //                 Centre for Speech Technology Research                  \\
 //                      University of Edinburgh, UK                       \\
 //                        Copyright (c) 1996,1997                         \\
 //                         All Rights Reserved.                           \\
 //   Permission is hereby granted, free of charge, to use and distribute  \\
 //   this software and its documentation without restriction, including   \\
 //   without limitation the rights to use, copy, modify, merge, publish,  \\
 //   distribute, sublicense, and/or sell copies of this work, and to      \\
 //   permit persons to whom this work is furnished to do so, subject to   \\
 //   the following conditions:                                            \\
 //    1. The code must retain the above copyright notice, this list of    \\
 //       conditions and the following disclaimer.                         \\
 //    2. Any modifications must be clearly marked as such.                \\
 //    3. Original authors' names are not deleted.                         \\
 //    4. The authors' names are not used to endorse or promote products   \\
 //       derived from this software without specific prior written        \\
 //       permission.                                                      \\
 //   THE UNIVERSITY OF EDINBURGH AND THE CONTRIBUTORS TO THIS WORK        \\
 //   DISCLAIM ALL WARRANTIES With REGARD TO THIS SOFTWARE, INCLUDING      \\
 //   ALL IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS, IN NO EVENT   \\
 //   SHALL THE UNIVERSITY OF EDINBURGH NOR THE CONTRIBUTORS BE LIABLE     \\
 //   FOR ANY SPECIAL, INDIRECT OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES    \\
 //   WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN   \\
 //   AN ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION,          \\
 //   ARISING OUT OF OR IN CONNECTION WITH THE USE OR PERFORMANCE OF       \\
 //   THIS SOFTWARE.                                                       \\
 //                                                                        \\
 //\\//\\//\\//\\//\\//\\//\\//\\//\\//\\//\\//\\//\\//\\//\\//\\//\\//\\//\\
 //                                                                        \\
 //                  Author: Richard Caley (rjc@cstr.ed.ac.uk)             \\
 //  --------------------------------------------------------------------  \\
 //  Wrapper around a socket which is connected to Fringe.                 \\
 //                                                                        \\
 //\\//\\//\\//\\//\\//\\//\\//\\//\\//\\//\\//\\//\\//\\//\\//\\//\\//\\//\\

package cstr.est;

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

public class ServerConnection
{
  private static String command_term = "//End//";
  private static String result_term = "//End//";

  private Socket s;
  private BufferedReader reader;
  private BufferedWriter writer;

  public ServerConnection(Socket sk)
    throws IOException
    {
      setSocket(sk);
    }

  public void setSocket(Socket sk)
    throws IOException
    {
      s=sk;

      try {
	if (s == null)
	  throw new IOException("no socket");
	
	  Reader r = new InputStreamReader(s.getInputStream());
	  reader = new BufferedReader(r);

	  Writer w = new OutputStreamWriter(s.getOutputStream());
	  writer =  new BufferedWriter(w);
      } catch (IOException e) {
	reader=null;
	writer=null;
	throw e;
      }
    }

  protected String readResult()
    throws IOException
    {
      while (true)
	{
	  StringBuffer res = new StringBuffer(100);
	  String status = null;
	  while (true)
	    {
	      String line = reader.readLine();
	      if (line.startsWith(result_term))
		{
		  status = line.substring(result_term.length());
		  break;
		}
	      res.append(line);
	    }
	  if (status.equals("OK"))
	    return res.toString();
	  else if (status.equals("ERROR"))
	    return "!"+res.toString();
	  else if (status.equals("VAL"))
	    System.err.println("Warning, intermediate value '"+res.toString()+"'");
	  else
	    throw new IOException("Uknknown value type "+status);
	}
    }

  public String sendCommand(String command)
    throws IOException
    {
      writer.write(command, 0, command.length());
      writer.newLine();
      writer.write(command_term, 0, command_term.length());
      writer.newLine();
      writer.flush();
	
      String result = readResult();
      
      return result;
    }

  public String sendCommand(StringBuffer command)
    throws IOException
    {
      return sendCommand(command.toString());
    }
}