kill implementation fixed
authorTamas Jung <tamasjung@gmail.com>
Fri, 7 Jan 2011 16:12:21 +0000 (17:12 +0100)
committerTamas Jung <tamasjung@gmail.com>
Fri, 7 Jan 2011 16:12:21 +0000 (17:12 +0100)
ext/arc_stat.cpp
lib/arc_client_r.rb
test/test_kill.rb

index 84cbb0a..488b42c 100644 (file)
@@ -14,7 +14,7 @@
 #ifdef HAVE_CONFIG_H
 #include <config.h>
 #endif
-
+#include "logger.h"
 #include <iostream>
 #include <list>
 #include <string>
@@ -71,7 +71,8 @@ stat_result_t*  arc_stat(int argc, char **argv) {
                
        Arc::UserConfig usercfg(conffile, joblist);
        if (!usercfg) {
-               result  -> message = new_str("Failed configuration initialization");
+               //result  -> message = new_str("Failed configuration initialization");
+               logger.msg(Arc::ERROR, "Failed configuration initialization");
                return result;
        }
                
@@ -90,18 +91,21 @@ stat_result_t*  arc_stat(int argc, char **argv) {
        
        Arc::JobSupervisor jobmaster(usercfg, jobs);
        if (!jobmaster.JobsFound()) {
-               result -> message = new_str("No jobs");
+               //result -> message = new_str("No jobs");
+    logger.msg(Arc::INFO, "No jobs");
                return result;
        }
        std::list<Arc::JobController*> jobcont = jobmaster.GetJobControllers();
        
        if (jobcont.empty()) {
-               result -> message = new_str("No job controller plugins loaded");
+               //result -> message = new_str("No job controller plugins loaded");
+    logger.msg(Arc::INFO, "No job controller plugins loaded");
                return result;
        }
        
        if (jobcont.size() != 1){
-               result -> message = new_str("Too many jobs found");
+               //result -> message = new_str("Too many jobs found");
+    logger.msg(Arc::ERROR, "Too many jobs found");
                return result;
        } 
        Arc::JobController* it = jobcont.front();
@@ -111,7 +115,8 @@ stat_result_t*  arc_stat(int argc, char **argv) {
        std::list<Arc::Job> jobs_list = it->GetJobs();
        
        if (jobs_list.size() != 1) {
-               result -> message = new_str("Ambiguous job");
+               //result -> message = new_str("Ambiguous job");
+    logger.msg(Arc::ERROR, "Ambiguous job");
                return result;
        }
        
index 133b262..fa1901b 100644 (file)
@@ -44,7 +44,7 @@ class ArcClientR
   end
   
   def kill(the_args)
-    args = the_args.unshift##optparser cuts the first arg TODO
+    args = the_args.unshift ""##optparser cuts the first arg TODO
     args_pointer = ArcClientCWrapper::string_array_as_pointer(args)
     @wrapper.arc_kill(args.size, args_pointer)
   end
index 1497117..1429db5 100644 (file)
@@ -6,16 +6,19 @@ class TestGet < ::Test::Unit::TestCase
   
   
   def test_base
+    joblistfile = "test_jobkill_list.xml"
     arc_client = ArcClientR.new
-    #message, job_id = arc_client.submit(["-e", SLEEP_JSDL, "-j", "test_jobkill_list.xml"])
-    #p "job submitted: #{job_id}, message: #{message}"
+    message, job_id = arc_client.submit(["-e", SLEEP_JSDL, "-j", joblistfile])
+    p "job submitted: #{job_id}, message: #{message}"
     
-    # delay = 45
-    # p "sleeping for #{delay} seconds"
-    # sleep delay
-    job_id = 'https://testce.grid.niif.hu:60000/arex/202691294184794230106886'
+    delay = 45
+    p "sleeping for #{delay} seconds"
+    sleep delay
+    #job_id = 'https://testce.grid.niif.hu:60000/arex/2026912942666321386090377'
     p 'waking and killing'
-    result = arc_client.kill(["-j", "test_jobkill_list.xml", job_id])
+    result = arc_client.kill(["-j", joblistfile, job_id])
     p "result #{result}"
+    p arc_client.stat(["-j", "test_jobkill_list.xml", job_id])
+    File.delete(joblistfile)
   end
 end
\ No newline at end of file