X-Git-Url: http://git.rot13.org/?p=perl-cwmp.git;a=blobdiff_plain;f=lib%2FCWMP%2FSession.pm;h=bdde16c6a743d4fa662679ca4d920667a4547f45;hp=ce43cb3a8e33fb22cf8736e36a21d335ca099db8;hb=441fa54478368fedae46f6b83a8d46852751769a;hpb=7b228b78e7b84172c1180c463c38f187d1ce496e

diff --git a/lib/CWMP/Session.pm b/lib/CWMP/Session.pm
index ce43cb3..bdde16c 100644
--- a/lib/CWMP/Session.pm
+++ b/lib/CWMP/Session.pm
@@ -137,9 +137,42 @@ sub process_request {
 		$xml = $self->dispatch( $job->dispatch );
 		$job->finish;
 	} else {
-		warn ">>> empty response $to_uid";
-		$state->{NoMoreRequests} = 1;
-		$xml = '';
+		my $stored = $self->store->get_state( $uid );
+		if ( ! defined $stored->{ParameterInfo} ) {
+			$xml = $self->dispatch( 'GetParameterNames', [ 'InternetGatewayDevice.', 1 ] );
+		} else {
+			my @params = grep { m/\.$/ } keys %{ $stored->{ParameterInfo} };
+			if ( @params ) {
+				warn "# GetParameterNames ", dump( @params );
+				my $first = shift @params;
+				delete $stored->{ParameterInfo}->{$first};
+				$xml = $self->dispatch( 'GetParameterNames', [ $first, 1 ] );
+				foreach ( @params ) {
+					$queue->enqueue( 'GetParameterNames', [ $_, 1 ] );
+					delete $stored->{ParameterInfo}->{ $_ };
+				}
+				$self->store->set_state( $uid, $stored );
+			} else {
+
+				my @params = sort grep { ! exists $stored->{Parameter}->{$_} } grep { ! m/\.$/ } keys %{ $stored->{ParameterInfo} };
+				if ( @params ) {
+					warn "# GetParameterValues ", dump( @params );
+					my $first = shift @params;
+					$xml = $self->dispatch( 'GetParameterValues', [ $first ] );
+					while ( @params ) {
+						my @chunk = splice @params, 0, 16; # FIXME 16 seems to be max
+						$queue->enqueue( 'GetParameterValues', [ @chunk ] );
+					}
+
+				} else {
+
+					warn ">>> empty response $to_uid";
+					$state->{NoMoreRequests} = 1;
+					$xml = '';
+
+				}
+			}
+		}
 	}
 
 	my $status = length($xml) ? 200 : 204;