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
|
###########################################################################
##
#W process.gi The SCSCP package Alexander Konovalov
#W Steve Linton
##
###########################################################################
DeclareRepresentation( "IsSCSCPconnectionRep",
IsPositionalObjectRep,
[ 1, 2 ] );
SCSCPconnectionsFamily := NewFamily( "SCSCPconnectionsFamily(...)",
IsSCSCPconnection );
SCSCPconnectionDefaultType := NewType( SCSCPconnectionsFamily,
IsSCSCPconnectionRep and IsSCSCPconnection);
###########################################################################
##
#M ViewObj( <SCSCPconnection> )
##
InstallMethod( ViewObj, "for SCSCP connection",
[ IsSCSCPconnectionRep and IsSCSCPconnection ],
function( connection )
local stream, pid;
stream := connection![1];
pid := connection![2];
Print("< ");
if IsClosedStream(stream) then
Print("closed ");
fi;
Print("connection to ",stream![2],":",stream![3][1], " session_id=", pid, " >");
end);
###########################################################################
##
#M PrintObj( <process> )
##
InstallMethod( PrintObj, "for SCSCP connection",
[ IsSCSCPconnectionRep and IsSCSCPconnection ],
function( connection )
local stream, pid;
stream := connection![1];
pid := connection![2];
Print("< ");
if IsClosedStream(stream) then
Print("closed ");
fi;
Print("connection to ",stream![2],":",stream![3][1], " session_id=", pid, " >");
end);
###########################################################################
##
## NewSCSCPconnection
##
InstallGlobalFunction( NewSCSCPconnection, function( hostname, port )
local tcpstream, session_id, pos1, pid;
tcpstream:=InputOutputTCPStream( hostname, port );
session_id := StartSCSCPsession( tcpstream );
return Objectify( SCSCPconnectionDefaultType, [ tcpstream, session_id ] );
end);
###########################################################################
##
## CloseSCSCPconnection
##
InstallGlobalFunction( CloseSCSCPconnection, function( connection )
CloseStream( connection![1]);
end);
###########################################################################
##
#E
##
|
