Merge branch 'master' of homeproj.cesnet.cz:warden

src/warden-client/etc/warden-client.conf

@@ -22,3 +22,9 @@ $SSL_CERT_FILE = "/opt/warden-client/etc/warden-dev.cesnet.cz.pem";
 #-------------------------------------------------------------------------------
 $SSL_CA_FILE = "/etc/ssl/certs/tcs-ca-bundle.pem";
 
+#-------------------------------------------------------------------------------
+# MAX_RCV_EVENTS_LIMIT - maximum number of events the client is allowd to get
+#                        from the Warden server in one batch
+#-------------------------------------------------------------------------------
+$MAX_RCV_EVENTS_LIMIT = 10000;
+

src/warden-client/lib/WardenClientConf.pm

@@ -24,6 +24,7 @@ sub loadConf
   our $SSL_KEY_FILE = undef;
   our $SSL_CERT_FILE = undef;
   our $SSL_CA_FILE = undef;
+  our $MAX_RCV_EVENTS_LIMIT = undef;
 
   # read config file
   if ( ! open( TMP, $conf_file) ) {
@@ -36,7 +37,7 @@ sub loadConf
     die("Errors in config file '$conf_file': $@");
   }
 
-  return ($URI, $SSL_KEY_FILE, $SSL_CERT_FILE, $SSL_CA_FILE);
+  return ($URI, $SSL_KEY_FILE, $SSL_CERT_FILE, $SSL_CA_FILE, $MAX_RCV_EVENTS_LIMIT);
 
 } # End of loadConf
 1;

src/warden-client/lib/WardenClientReceive.pm

@@ -91,7 +91,7 @@ sub getNewEvents
   # read the config file
   require $libdir .  "WardenClientConf.pm";
   my $conf_file = $etcdir . "warden-client.conf";
-  my ($uri, $ssl_key_file, $ssl_cert_file, $ssl_ca_file) = WardenClientConf::loadConf($conf_file);
+  my ($uri, $ssl_key_file, $ssl_cert_file, $ssl_ca_file, $max_rcv_events_limit) = WardenClientConf::loadConf($conf_file);
 
   # set name of ID file for each client aplication 
   my $caller_name = $FindBin::Script;
@@ -122,7 +122,8 @@ sub getNewEvents
   my $request_data = SOAP::Data->name(
     request => \SOAP::Data->value(
       SOAP::Data->name(REQUESTED_TYPE 		=> $requested_type),
-      SOAP::Data->name(LAST_ID        => $last_id)
+      SOAP::Data->name(LAST_ID        		=> $last_id),
+      SOAP::Data->name(MAX_RCV_EVENTS_LIMIT 	=> $max_rcv_events_limit)
     )
   );