WebSVN – HomeAutomation – Diff – /trunk/PcSoftware/scripts/atomDude.pl/


#!/usr/bin/perl
 
# Written by Mattias Runge 2008-2010
 
use Cwd 'abs_path';
use File::Basename;
use Time::HiRes qw( usleep );
 
$| = 1;
 
$numArgs = $#ARGV + 1;
 
my $hostname = "localhost";
my $port = 1201;
my $filename = "";
my $hwid = "";
my $bios = 0;
my $reset = "false";
 
foreach $argnum (0 .. $#ARGV)
{
    if ($ARGV[$argnum] eq "-h")
    {
        $hostname = $ARGV[$argnum+1];
        next;
 
    }
    elsif ($ARGV[$argnum] eq "-p")
    {
        $port = $ARGV[$argnum+1];
        next;
 
    }
    elsif ($ARGV[$argnum] eq "-i")
    {
        $hwid = $ARGV[$argnum+1];
        next;
 
    }
    elsif ($ARGV[$argnum] eq "-f")
    {
        $filename = abs_path($ARGV[$argnum+1]);
        next;
 
    }
    elsif ($ARGV[$argnum] eq "-b")
    {
        $bios = 1;
    }
    elsif ($ARGV[$argnum] eq "-r")
    {
        $reset = "true";
    }
}
 
if ($hwid eq "")
{
    die "You must specify a hardware id!\n";
    exit 1;
}
 
my $path = dirname(abs_path($0));
 
# Read atom functions from separate file
if (-e $path."/setConfig/AtomLib.pl") {
    require $path."/setConfig/AtomLib.pl";
} else {
    print "Error: No AtomLib.pl was found in ".$path.". \n\n";
    exit 1;
}
 
#0x14f90d1f to 0x1f0df914
@hwidChars = split(//, $hwid);
$hwid = $hwidChars[0]. $hwidChars[1]. uc($hwidChars[8]. $hwidChars[9]. $hwidChars[6]. $hwidChars[7]. $hwidChars[4]. $hwidChars[5]. $hwidChars[2]. $hwidChars[3]);
 
print "atomDude settings:\n";
print "Hardware id: " . $hwid . "\n";
print "Atom address: " . $hostname . ":" . $port . "\n";
print "Hexfile: " . $filename . "\n";
#print "Parameters: " . "\n";
 
############################## RESET ##############################
if ($reset eq "true" && $filename eq "")
{
    if ($port == 1203)
    {
        $socket = atomd_initialize($hostname, $port);
        atomjs_write($socket, "Node_ResetNative('".$hwid."');\n");
        $response = atomjs_read_line($socket);
        if ($response =~ m/Error/)
        {
            die $response;
        }
        print $response;
 
        $success = 0;
        for ($count = 0; $count < 15; $count++)
        {
            atomjs_write($socket, "Node_ResetPollNative();\n");
            if (atomjs_read_line($socket) =~ m/true/)
            {
                print "\033[32m" . $hwid . " started okay.\033[0m\n";
                $success = 1;
                last;
            }
            usleep(200000);
        }
        if ($success == 0)
        {
            print "\033[31mTimed out waiting for reset.\033[0m\n";
        }
    }
    else
    {
        $socket = atomd_initialize($hostname, $port);
 
        usleep(100000);
        atomd_kill_promt($socket);
        atomd_send_command($socket, "Node_Reset $hwid");
        print atomd_read_command_response($socket);
        #my $result = system("atomic -s $hostname -p $port -c \"Node_Reset $hwid\"");
        #exit($result);
    }
}
############################## REPROGRAM ##############################
else
{
    if ($port == 1203)
    {
        open (FP, "+<".$filename) or die "Error: Cannot open file $filename\n";
        @filecontents = <FP>;
        close FP;
        $socket = atomd_initialize($hostname, $port);
        atomjs_write($socket, "Node_ClearHex();\n");
        atomjs_read_line($socket);
        my $linenums = 0;
        foreach $filerow (@filecontents)
        {
            $filerow =~ s/^\s+//;
            $filerow =~ s/\s+$//;
            $linenums += 1;
            $command = "Node_AppendHexNative('".$filerow."');\n";
            atomjs_write($socket, $command);
            $response = atomjs_read_line($socket);
            if ($response =~ m/Error/)
            {
                die $response;
            }
        }
        $command = "Node_ProgramNative('".$hwid."', '".$bios."', '".$linenums."');\n";
        atomjs_write($socket, $command);
        #print $command;
        $response = atomjs_read_line($socket);
        if ($response =~ m/Error/)
        {
            die $response;
        }
        print $response;
#atomd_disconnect($socket);
        $success = 0;
        $alreadyprintfull = 0;
        for ($count = 0; $count < 150; $count++)
        {
            atomjs_write($socket, "Node_ProgramPollNative();\n");
            if (atomjs_read_line($socket) =~ m/true/)
            {
                print progress_bar( 100, 100, 40, '=' );
                print "\n\033[32m" . $hwid . " started okay.\033[0m\n";
                $success = 1;
                last;
            }
            atomjs_write($socket, "Node_GetProgramProgress('".$hwid."');\n");
            $response = atomjs_read_line($socket);
            if ($response =~ m/Error/)
            {
                die $response;
            }
            $response =~ s/^\s+//;
            $response =~ s/\s+$//;
            if ($response > 99)
            {
                $response = 99;
            }
            #print $response."\n";
            print progress_bar( $response, 100, 40, '=' );
           
            usleep(200000);
        }
        if ($success == 0)
        {
            print "\n\033[31mTimed out waiting for program to finish.\033[0m\n";
        }
    }
    else
    {
        open (FP, "+<".$filename) or die "Error: Cannot open file $filename\n";
        @filecontents = <FP>;
        close FP;
        $socket = atomd_initialize($hostname, $port);
        usleep(100000);
        atomd_kill_promt($socket);
   
        #print "Sending Node_ClearHex\n";
        atomd_send_command($socket, "Node_ClearHex");
        atomd_kill_promt($socket);
   
        my $linenums = 0;
        foreach $filerow (@filecontents)
        {
            #print "Sending Node_AppendHex $filerow \n";
            #$filerow =~ s/^\s+//;
            #$filerow =~ s/\s+$//;
            atomd_send_command($socket, "Node_AppendHex $filerow");
            atomd_kill_promt($socket);
            $linenums += 1;
        }
        #print "Sending Node_ProgramHex $hwid $bios $linenums \n";
        atomd_send_command($socket, "Node_ProgramHex $hwid $bios $linenums");
 
        print atomd_read_command_response($socket);
 
#       my $result = system("atomic -s $hostname -p $port -c \"Node_Program $hwid $bios $filename\"");
#       exit($result);
    }
}
 
exit(0);
 
# wget-style. routine by tachyon
# at http://tachyon.perlmonk.org/
sub progress_bar {
    my ( $got, $total, $width, $char ) = @_;
    $width ||= 25; $char ||= '=';
    my $num_width = length $total;
    sprintf "|%-${width}s| (%.2f%%)\r",
        $char x (($width-1)*$got/$total). '>',
        $got, $total, 100*$got/+$total;
}
 
 

Rev 2161	Rev 2164
1	#!/usr/bin/perl	1	#!/usr/bin/perl
2		2
3	# Written by Mattias Runge 2008-2010	3	# Written by Mattias Runge 2008-2010
4		4
5	use Cwd 'abs_path';	5	use Cwd 'abs_path';
6	use File::Basename;	6	use File::Basename;
7	use Time::HiRes qw( usleep );	7	use Time::HiRes qw( usleep );
8		8
9	$\| = 1;	9	$\| = 1;
10		10
11	$numArgs = $#ARGV + 1;	11	$numArgs = $#ARGV + 1;
12		12
13	my $hostname = "localhost";	13	my $hostname = "localhost";
14	my $port = 1201;	14	my $port = 1201;
15	my $filename = "";	15	my $filename = "";
16	my $hwid = "";	16	my $hwid = "";
17	my $bios = 0;	17	my $bios = 0;
18	my $reset = "false";	18	my $reset = "false";
19		19
20	foreach $argnum (0 .. $#ARGV)	20	foreach $argnum (0 .. $#ARGV)
21	{	21	{
22	if ($ARGV[$argnum] eq "-h")	22	if ($ARGV[$argnum] eq "-h")
23	{	23	{
24	$hostname = $ARGV[$argnum+1];	24	$hostname = $ARGV[$argnum+1];
25	next;	25	next;
26		26
27	}	27	}
28	elsif ($ARGV[$argnum] eq "-p")	28	elsif ($ARGV[$argnum] eq "-p")
29	{	29	{
30	$port = $ARGV[$argnum+1];	30	$port = $ARGV[$argnum+1];
31	next;	31	next;
32		32
33	}	33	}
34	elsif ($ARGV[$argnum] eq "-i")	34	elsif ($ARGV[$argnum] eq "-i")
35	{	35	{
36	$hwid = $ARGV[$argnum+1];	36	$hwid = $ARGV[$argnum+1];
37	next;	37	next;
38		38
39	}	39	}
40	elsif ($ARGV[$argnum] eq "-f")	40	elsif ($ARGV[$argnum] eq "-f")
41	{	41	{
42	$filename = abs_path($ARGV[$argnum+1]);	42	$filename = abs_path($ARGV[$argnum+1]);
43	next;	43	next;
44		44
45	}	45	}
46	elsif ($ARGV[$argnum] eq "-b")	46	elsif ($ARGV[$argnum] eq "-b")
47	{	47	{
48	$bios = 1;	48	$bios = 1;
49	}	49	}
50	elsif ($ARGV[$argnum] eq "-r")	50	elsif ($ARGV[$argnum] eq "-r")
51	{	51	{
52	$reset = "true";	52	$reset = "true";
53	}	53	}
54	}	54	}
55		55
56	if ($hwid eq "")	56	if ($hwid eq "")
57	{	57	{
58	die "You must specify a hardware id!\n";	58	die "You must specify a hardware id!\n";
59	exit 1;	59	exit 1;
60	}	60	}
61		61
62	my $path = dirname(abs_path($0));	62	my $path = dirname(abs_path($0));
63		63
64	# Read atom functions from separate file	64	# Read atom functions from separate file
65	if (-e $path."/setConfig/AtomLib.pl") {	65	if (-e $path."/setConfig/AtomLib.pl") {
66	require $path."/setConfig/AtomLib.pl";	66	require $path."/setConfig/AtomLib.pl";
67	} else {	67	} else {
68	print "Error: No AtomLib.pl was found in ".$path.". \n\n";	68	print "Error: No AtomLib.pl was found in ".$path.". \n\n";
69	exit 1;	69	exit 1;
70	}	70	}
71		71
72	#0x14f90d1f to 0x1f0df914	72	#0x14f90d1f to 0x1f0df914
73	@hwidChars = split(//, $hwid);	73	@hwidChars = split(//, $hwid);
74	$hwid = $hwidChars[0]. $hwidChars[1]. uc($hwidChars[8]. $hwidChars[9]. $hwidChars[6]. $hwidChars[7]. $hwidChars[4]. $hwidChars[5]. $hwidChars[2]. $hwidChars[3]);	74	$hwid = $hwidChars[0]. $hwidChars[1]. uc($hwidChars[8]. $hwidChars[9]. $hwidChars[6]. $hwidChars[7]. $hwidChars[4]. $hwidChars[5]. $hwidChars[2]. $hwidChars[3]);
75		75
76	print "atomDude settings:\n";	76	print "atomDude settings:\n";
77	print "Hardware id: " . $hwid . "\n";	77	print "Hardware id: " . $hwid . "\n";
78	print "Atom address: " . $hostname . ":" . $port . "\n";	78	print "Atom address: " . $hostname . ":" . $port . "\n";
79	print "Hexfile: " . $filename . "\n";	79	print "Hexfile: " . $filename . "\n";
80	#print "Parameters: " . "\n";	80	#print "Parameters: " . "\n";
81		81
82	############################## RESET ##############################	82	############################## RESET ##############################
83	if ($reset eq "true" && $filename eq "")	83	if ($reset eq "true" && $filename eq "")
84	{	84	{
85	if ($port == 1203)	85	if ($port == 1203)
86	{	86	{
87	$socket = atomd_initialize($hostname, $port);	87	$socket = atomd_initialize($hostname, $port);
88	atomjs_write($socket, "Node_ResetNative('".$hwid."');\n");	88	atomjs_write($socket, "Node_ResetNative('".$hwid."');\n");
89	$response = atomjs_read_line($socket);	89	$response = atomjs_read_line($socket);
90	if ($response =~ m/Error/)	90	if ($response =~ m/Error/)
91	{	91	{
92	die $response;	92	die $response;
93	}	93	}
94	print $response;	94	print $response;
95		95
96	$success = 0;	96	$success = 0;
97	for ($count = 0; $count < 15; $count++)	97	for ($count = 0; $count < 15; $count++)
98	{	98	{
99	atomjs_write($socket, "Node_ResetPollNative();\n");	99	atomjs_write($socket, "Node_ResetPollNative();\n");
100	if (atomjs_read_line($socket) =~ m/true/)	100	if (atomjs_read_line($socket) =~ m/true/)
101	{	101	{
102	print "\033[32m" . $hwid . " started okay.\033[0m\n";	102	print "\033[32m" . $hwid . " started okay.\033[0m\n";
103	$success = 1;	103	$success = 1;
104	last;	104	last;
105	}	105	}
106	usleep(200000);	106	usleep(200000);
107	}	107	}
108	if ($success == 0)	108	if ($success == 0)
109	{	109	{
110	print "\033[31mTimed out waiting for reset.\033[0m\n";	110	print "\033[31mTimed out waiting for reset.\033[0m\n";
111	}	111	}
112	}	112	}
113	else	113	else
114	{	114	{
115	$socket = atomd_initialize($hostname, $port);	115	$socket = atomd_initialize($hostname, $port);
116		116
117	usleep(100000);	117	usleep(100000);
118	atomd_kill_promt($socket);	118	atomd_kill_promt($socket);
119	atomd_send_command($socket, "Node_Reset $hwid");	119	atomd_send_command($socket, "Node_Reset $hwid");
120	print atomd_read_command_response($socket);	120	print atomd_read_command_response($socket);
121	#my $result = system("atomic -s $hostname -p $port -c \"Node_Reset $hwid\"");	121	#my $result = system("atomic -s $hostname -p $port -c \"Node_Reset $hwid\"");
122	#exit($result);	122	#exit($result);
123	}	123	}
124	}	124	}
125	############################## REPROGRAM ##############################	125	############################## REPROGRAM ##############################
126	else	126	else
127	{	127	{
128	if ($port == 1203)	128	if ($port == 1203)
129	{	129	{
130	open (FP, "+<".$filename) or die "Error: Cannot open file $filename\n";	130	open (FP, "+<".$filename) or die "Error: Cannot open file $filename\n";
131	@filecontents = <FP>;	131	@filecontents = <FP>;
132	close FP;	132	close FP;
133	$socket = atomd_initialize($hostname, $port);	133	$socket = atomd_initialize($hostname, $port);
134	atomjs_write($socket, "Node_ClearHex();\n");	134	atomjs_write($socket, "Node_ClearHex();\n");
135	atomjs_read_line($socket);	135	atomjs_read_line($socket);
136	my $linenums = 0;	136	my $linenums = 0;
137	foreach $filerow (@filecontents)	137	foreach $filerow (@filecontents)
138	{	138	{
139	$filerow =~ s/^\s+//;	139	$filerow =~ s/^\s+//;
140	$filerow =~ s/\s+$//;	140	$filerow =~ s/\s+$//;
141	$linenums += 1;	141	$linenums += 1;
142	$command = "Node_AppendHexNative('".$filerow."');\n";	142	$command = "Node_AppendHexNative('".$filerow."');\n";
143	atomjs_write($socket, $command);	143	atomjs_write($socket, $command);
144	$response = atomjs_read_line($socket);	144	$response = atomjs_read_line($socket);
145	if ($response =~ m/Error/)	145	if ($response =~ m/Error/)
146	{	146	{
147	die $response;	147	die $response;
148	}	148	}
149	}	149	}
150	$command = "Node_ProgramNative('".$hwid."', '".$bios."', '".$linenums."');\n";	150	$command = "Node_ProgramNative('".$hwid."', '".$bios."', '".$linenums."');\n";
151	atomjs_write($socket, $command);	151	atomjs_write($socket, $command);
152	#print $command;	152	#print $command;
153	$response = atomjs_read_line($socket);	153	$response = atomjs_read_line($socket);
154	if ($response =~ m/Error/)	154	if ($response =~ m/Error/)
155	{	155	{
156	die $response;	156	die $response;
157	}	157	}
158	print $response;	158	print $response;
159	#atomd_disconnect($socket);	159	#atomd_disconnect($socket);
160	$success = 0;	160	$success = 0;
-		161	$alreadyprintfull = 0;
161	for ($count = 0; $count < 150; $count++)	162	for ($count = 0; $count < 150; $count++)
162	{	163	{
163	atomjs_write($socket, "Node_ProgramPollNative();\n");	164	atomjs_write($socket, "Node_ProgramPollNative();\n");
164	if (atomjs_read_line($socket) =~ m/true/)	165	if (atomjs_read_line($socket) =~ m/true/)
165	{	166	{
-		167	print progress_bar( 100, 100, 40, '=' );
166	print "\033[32m" . $hwid . " started okay.\033[0m\n";	168	print "\n\033[32m" . $hwid . " started okay.\033[0m\n";
167	$success = 1;	169	$success = 1;
168	last;	170	last;
169	}	171	}
-		172	atomjs_write($socket, "Node_GetProgramProgress('".$hwid."');\n");
-		173	$response = atomjs_read_line($socket);
-		174	if ($response =~ m/Error/)
-		175	{
-		176	die $response;
-		177	}
-		178	$response =~ s/^\s+//;
-		179	$response =~ s/\s+$//;
-		180	if ($response > 99)
-		181	{
-		182	$response = 99;
-		183	}
-		184	#print $response."\n";
-		185	print progress_bar( $response, 100, 40, '=' );
-		186
170	usleep(200000);	187	usleep(200000);
171	}	188	}
172	if ($success == 0)	189	if ($success == 0)
173	{	190	{
174	print "\033[31mTimed out waiting for program to finish.\033[0m\n";	191	print "\n\033[31mTimed out waiting for program to finish.\033[0m\n";
175	}	192	}
176	}	193	}
177	else	194	else
178	{	195	{
179	open (FP, "+<".$filename) or die "Error: Cannot open file $filename\n";	196	open (FP, "+<".$filename) or die "Error: Cannot open file $filename\n";
180	@filecontents = <FP>;	197	@filecontents = <FP>;
181	close FP;	198	close FP;
182	$socket = atomd_initialize($hostname, $port);	199	$socket = atomd_initialize($hostname, $port);
183	usleep(100000);	200	usleep(100000);
184	atomd_kill_promt($socket);	201	atomd_kill_promt($socket);
185		202
186	#print "Sending Node_ClearHex\n";	203	#print "Sending Node_ClearHex\n";
187	atomd_send_command($socket, "Node_ClearHex");	204	atomd_send_command($socket, "Node_ClearHex");
188	atomd_kill_promt($socket);	205	atomd_kill_promt($socket);
189		206
190	my $linenums = 0;	207	my $linenums = 0;
191	foreach $filerow (@filecontents)	208	foreach $filerow (@filecontents)
192	{	209	{
193	#print "Sending Node_AppendHex $filerow \n";	210	#print "Sending Node_AppendHex $filerow \n";
194	#$filerow =~ s/^\s+//;	211	#$filerow =~ s/^\s+//;
195	#$filerow =~ s/\s+$//;	212	#$filerow =~ s/\s+$//;
196	atomd_send_command($socket, "Node_AppendHex $filerow");	213	atomd_send_command($socket, "Node_AppendHex $filerow");
197	atomd_kill_promt($socket);	214	atomd_kill_promt($socket);
198	$linenums += 1;	215	$linenums += 1;
199	}	216	}
200	#print "Sending Node_ProgramHex $hwid $bios $linenums \n";	217	#print "Sending Node_ProgramHex $hwid $bios $linenums \n";
201	atomd_send_command($socket, "Node_ProgramHex $hwid $bios $linenums");	218	atomd_send_command($socket, "Node_ProgramHex $hwid $bios $linenums");
202		219
203	print atomd_read_command_response($socket);	220	print atomd_read_command_response($socket);
204		221
205	# my $result = system("atomic -s $hostname -p $port -c \"Node_Program $hwid $bios $filename\"");	222	# my $result = system("atomic -s $hostname -p $port -c \"Node_Program $hwid $bios $filename\"");
206	# exit($result);	223	# exit($result);
207	}	224	}
208	}	225	}
209		226
210	exit(0);	227	exit(0);
-		228
-		229	# wget-style. routine by tachyon
-		230	# at http://tachyon.perlmonk.org/
-		231	sub progress_bar {
-		232	my ( $got, $total, $width, $char ) = @_;
-		233	$width \|\|= 25; $char \|\|= '=';
-		234	my $num_width = length $total;
-		235	sprintf "\|%-${width}s\| (%.2f%%)\r",
-		236	$char x (($width-1)*$got/$total). '>',
-		237	$got, $total, 100*$got/+$total;
-		238	}
-		239
211		240

Subversion Repositories HomeAutomation

(root)/trunk/PcSoftware/scripts/atomDude.pl/ – Rev 2161 → 2164