blob: dbeded22250a7962b020029886868d8927354eb9 (
plain)
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
|
package netsvcs.Time;
/*************************************************
*
* = PACKAGE
* netsvcs.Time
*
* = FILENAME
* TSRequestHandler.java
*
*@author Prashant Jain, Everett Anderson
*
*************************************************/
import java.io.*;
import java.util.*;
import JACE.OS.*;
import JACE.Connection.*;
import JACE.Reactor.*;
/**
* <hr>
* <p><h2>SYNOPSIS</h2>
*
* <blockquote>Handles giving the client the average difference between
* the local time and the server times.</blockquote>
*
* <p><h2>DESCRIPTION</h2>
*
* <blockquote>Whenever the RequestHandler receives input to the port, it
* sends the current delta (average difference time) in return as a string.
* Instances of this class are created by TSRequestAcceptor.</blockquote>
*/
public class TSRequestHandler extends SvcHandler
{
/**
* Constructor. Takes in a reference to the Clerk Processor
* so it can call TSClerkProcessor getDelta().
*/
public TSRequestHandler (TSClerkProcessor processor)
{
this.processor_ = processor;
}
/**
*
* Run this in a separate thread.
*/
public int open (Object obj)
{
new Thread (this).start ();
return 0;
}
/**
*
* Called when the thread starts. This is the main code -- whenever
* input comes to the socket, it sends out the current delta time
* as a string.
*/
public void run ()
{
int msgLen;
try
{
while (true)
{
StringBuffer msg = new StringBuffer ();
msgLen = this.peer ().recv (msg);
if (msgLen < 0)
break;
else {
// No matter what was sent in, send the average difference back
String msgOut = new String("" + this.processor_.getDelta() + '\n');
this.peer ().send (msgOut);
}
}
}
catch (NullPointerException e)
{
ACE.ERROR ("Connection reset by peer");
}
catch (IOException e)
{
ACE.ERROR (e);
}
finally
{
try
{
this.peer ().close ();
}
catch (IOException e)
{
ACE.ERROR (e);
}
}
}
// Reference to the Clerk Processor to call getDelta()
TSClerkProcessor processor_;
}
|
