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
|
package Pdapilot;
import java.io.*;
/**
* A representation of a pilot-link socket. All pilot-link socket functions
* can be performed on these objects. When a DLP (Sync) connection is
* established via accept(), a Dlp object is returned.
*
* @see Dlp
* @author Kenneth Albanowski
*/
public class Socket {
int socket;
/**
* Construct a Socket from a domain/type/protocol three-tuple. Use
* values from constants for the arguments.
* @param domain the domain the socket needs to operate in. Please use constants.PI_AF_SLP, constants.PI_AF_INETSLP, or constants.AF_INET.
* @param type the type of socket to construct. Please use constants.PI_SOCK_STREAM or constants.PI_SOCK_RAW.
* @param protocol the protocol speaken by the socket. May be left zero, or use constants.PI_PF_SLP for a raw connection, or constants.PI_PF_PADP for a stream connection.
* @see constants
*/
public Socket(int domain, int type, int protocol) throws IOException
{ this.socket = calls.pi_socket(domain, type, protocol); }
public Socket(int sock) { this.socket = sock; }
public Socket(String port) throws IOException
{ this.socket = calls.pi_socket(0x51, 0x10, 0x51);
this.bind(port);
this.listen(1);
}
synchronized public int bind(String device) throws IOException
{ return calls.pi_bind(socket, device); }
synchronized public int listen(int backlog) throws IOException
{ return calls.pi_listen(socket, backlog); }
synchronized public Dlp accept() throws IOException
{ return new Dlp(calls.pi_accept(socket)); }
synchronized public int version() throws IOException
{ return calls.pi_version(socket); }
synchronized public int tickle() throws IOException
{ return calls.pi_tickle(socket); }
synchronized public int watchdog(int interval) throws IOException
{ return calls.pi_watchdog(socket, interval); }
synchronized public int read(byte[] data, int len) throws IOException
{ return calls.pi_read(socket, data, len); }
synchronized public int write(byte[] data, int len) throws IOException
{ return calls.pi_write(socket, data, len); }
synchronized public void close() throws IOException, DlpException {
/* this method must be idempotent */
if (this.socket != 0)
calls.pi_close(socket);
this.socket = 0;
}
protected void finalize() throws IOException, DlpException {
this.close();
}
}
|
