WebSVN – HomeAutomation – Diff – /trunk/PcSoftware/scripts/setConfig/AtomLib.pl


use IO::Select;
use IO::Socket;
 
 
sub atomd_connect
{
    ($host, $port) = @_;
    $socket = IO::Socket::INET->new(
            Proto    => "tcp",
            PeerAddr => $host,
            PeerPort => $port,
            Blocking => 1,
        )
        or die "Error: Cannot connect to port $port at $host\n";
 
    return $socket;
}
 
sub atomd_read_packet
{
    ($socket) = @_;
    $command="";
    read($socket, $command, 4);
 
    $payload_length="";
    read($socket, $payload_length, 4);
 
    $payload_length = int($payload_length);
    $payload="";
    if ($payload_length > 0)
    {
        read($socket, $payload, $payload_length);
    }
   
    #Pad payload length with 0s
    $payload_length = sprintf("%04d", $payload_length);
   
    #print "areadpacket ".$command . $payload_length . $payload."\n";
    return $command . $payload_length . $payload;
}
 
sub atomd_write_packet
{
    ($socket, $command, $payload) = @_;
   
    #Pad payload length with 0s
    $payload_length = sprintf("%04d", length($payload)+1);
    $packet = $command.$payload_length.$payload.chr(0);
 
    #print "awritepacket ".$packet."\n";
    print $socket $packet;
}
 
 
sub atomd_data_available
{
    ($socket) = @_;
 
    $s = IO::Select->new();
    $s->add($socket);
    @handles = $s->can_read(0.001);
 
    $has_data = 0;
    if (@handles)
    {
        $has_data = 1;
    }
   
    return $has_data;
}
 
sub atomd_kill_promt
{
    ($socket) = @_;
 
    while (atomd_data_available($socket))
    {
        $packet = atomd_read_packet($socket); # Read prompt
    }
}
 
sub atomd_initialize
{
    ($host, $port) = @_;
    $socket = atomd_connect($host, $port);
   
    atomd_kill_promt($socket);
 
 
 
   
    return $socket;
}
 
 
sub atomd_send_command
{
    ($socket, $command) = @_;
    atomd_write_packet($socket, "RESP", $command);
}
 
 
sub atomd_read_command_response
{
    ($socket) = @_;
 
    $response = "";
 
    while (1)
    {
        $packet = atomd_read_packet($socket);
 
        if (substr($packet, 0, 4) ne "TEXT")
        {
            last;
        }
 
        $packet =~ s/\n//g;
        $response .= substr($packet, 8);
        $response .= "\n";
    }
 
    return $response;
}
 
# "return" 1 to not generate an error when loading file
1;
 
 

Rev 1885	Rev 1890
1	use IO::Select;	1	use IO::Select;
2	use IO::Socket;	2	use IO::Socket;
3		3
4		4
5	sub atomd_connect	5	sub atomd_connect
6	{	6	{
7	($host, $port) = @_;	7	($host, $port) = @_;
8	$socket = IO::Socket::INET->new(	8	$socket = IO::Socket::INET->new(
9	Proto => "tcp",	9	Proto => "tcp",
10	PeerAddr => $host,	10	PeerAddr => $host,
11	PeerPort => $port,	11	PeerPort => $port,
12	Blocking => 1,	12	Blocking => 1,
13	)	13	)
14	or die "Error: Cannot connect to port $port at $host\n";	14	or die "Error: Cannot connect to port $port at $host\n";
15		15
16	return $socket;	16	return $socket;
17	}	17	}
18		18
19	sub atomd_read_packet	19	sub atomd_read_packet
20	{	20	{
21	($socket) = @_;	21	($socket) = @_;
22	$command="";	22	$command="";
23	read($socket, $command, 4);	23	read($socket, $command, 4);
24		24
25	$payload_length="";	25	$payload_length="";
26	read($socket, $payload_length, 4);	26	read($socket, $payload_length, 4);
27		27
28	$payload_length = int($payload_length);	28	$payload_length = int($payload_length);
29	$payload="";	29	$payload="";
30	if ($payload_length > 0)	30	if ($payload_length > 0)
31	{	31	{
32	read($socket, $payload, $payload_length);	32	read($socket, $payload, $payload_length);
33	}	33	}
34		34
35	#Pad payload length with 0s	35	#Pad payload length with 0s
36	$payload_length = sprintf("%04d", $payload_length);	36	$payload_length = sprintf("%04d", $payload_length);
37		37
38	#print "areadpacket ".$command . $payload_length . $payload."\n";	38	#print "areadpacket ".$command . $payload_length . $payload."\n";
39	return $command . $payload_length . $payload;	39	return $command . $payload_length . $payload;
40	}	40	}
41		41
42	sub atomd_write_packet	42	sub atomd_write_packet
43	{	43	{
44	($socket, $command, $payload) = @_;	44	($socket, $command, $payload) = @_;
45		45
46	#Pad payload length with 0s	46	#Pad payload length with 0s
47	$payload_length = sprintf("%04d", length($payload)+1);	47	$payload_length = sprintf("%04d", length($payload)+1);
48	$packet = $command.$payload_length.$payload.chr(0);	48	$packet = $command.$payload_length.$payload.chr(0);
49		49
50	#print "awritepacket ".$packet."\n";	50	#print "awritepacket ".$packet."\n";
51	print $socket $packet;	51	print $socket $packet;
52	}	52	}
53		53
54		54
55	sub atomd_data_available	55	sub atomd_data_available
56	{	56	{
57	($socket) = @_;	57	($socket) = @_;
58		58
59	$s = IO::Select->new();	59	$s = IO::Select->new();
60	$s->add($socket);	60	$s->add($socket);
61	@handles = $s->can_read(0.01);	61	@handles = $s->can_read(0.001);
62		62
63	$has_data = 0;	63	$has_data = 0;
64	if (@handles)	64	if (@handles)
65	{	65	{
66	$has_data = 1;	66	$has_data = 1;
67	}	67	}
68		68
69	return $has_data;	69	return $has_data;
70	}	70	}
71		71
-		72	sub atomd_kill_promt
-		73	{
-		74	($socket) = @_;
-		75
-		76	while (atomd_data_available($socket))
-		77	{
-		78	$packet = atomd_read_packet($socket); # Read prompt
-		79	}
-		80	}
72		81
73	sub atomd_initialize	82	sub atomd_initialize
74	{	83	{
75	($host, $port) = @_;	84	($host, $port) = @_;
76	$socket = atomd_connect($host, $port);	85	$socket = atomd_connect($host, $port);
77		86
78	~~while (atomd_data_available~~($socket))	87	atomd_kill_promt($socket);
79	{	-
80	$packet = atomd_read_packet($socket); # Read initial prompt	-
81	}	-
82		88
83	return $socket;	89	return $socket;
84	}	90	}
85		91
86		92
87	sub atomd_send_command	93	sub atomd_send_command
88	{	94	{
89	($socket, $command) = @_;	95	($socket, $command) = @_;
90	atomd_write_packet($socket, "RESP", $command);	96	atomd_write_packet($socket, "RESP", $command);
91	}	97	}
92		98
93		99
94	sub atomd_read_command_response	100	sub atomd_read_command_response
95	{	101	{
96	($socket) = @_;	102	($socket) = @_;
97		103
98	$response = "";	104	$response = "";
99		105
100	while (1)	106	while (1)
101	{	107	{
102	$packet = atomd_read_packet($socket);	108	$packet = atomd_read_packet($socket);
103		109
104	if (substr($packet, 0, 4) ne "TEXT")	110	if (substr($packet, 0, 4) ne "TEXT")
105	{	111	{
106	last;	112	last;
107	}	113	}
108		114
109	$packet =~ s/\n//g;	115	$packet =~ s/\n//g;
110	$response .= substr($packet, 8);	116	$response .= substr($packet, 8);
111	$response .= "\n";	117	$response .= "\n";
112	}	118	}
113		119
114	return $response;	120	return $response;
115	}	121	}
116		122
117	# "return" 1 to not generate an error when loading file	123	# "return" 1 to not generate an error when loading file
118	1;	124	1;
119		125
120		126

Subversion Repositories HomeAutomation

(root)/trunk/PcSoftware/scripts/setConfig/AtomLib.pl – Rev 1885 → 1890