Code

working multitasking
authorrettenbe <rettenbe@594d385d-05f5-0310-b6e9-bd551577e9d8>
Tue, 11 Mar 2008 18:26:01 +0000 (18:26 +0000)
committerrettenbe <rettenbe@594d385d-05f5-0310-b6e9-bd551577e9d8>
Tue, 11 Mar 2008 18:26:01 +0000 (18:26 +0000)
git-svn-id: https://oss.gonicus.de/repositories/gosa/trunk@9691 594d385d-05f5-0310-b6e9-bd551577e9d8

gosa-si/gosa-si-server

index 9019a1e5f674a18dbdd1370b743c8c66e6763b42..e18545c310a075f5bfeb780d14909407e02c2540 100755 (executable)
@@ -953,15 +953,15 @@ sub next_task {
                 StdoutEvent  => "task_result",
                 StderrEvent  => "task_debug",
                 CloseEvent   => "task_done",
-                );
+               );
 
         $heap->{task}->{ $task->ID } = $task;
     }
 }
 
 sub handle_task_result {
-    my ($kernel, $heap, $client_answer, $heap_id) = @_[KERNEL, HEAP, ARG0, ARG1];
-       daemon_log(Dumper($heap_id),1);
+    my ($kernel, $heap, $result) = @_[KERNEL, HEAP, ARG0];
+    my $client_answer = $result->{'answer'};
     if( $client_answer =~ s/session_id=(\d+)$// ) {
         my $session_id = $1;
         if( defined $session_id ) {
@@ -1164,8 +1164,19 @@ sub process_task {
         }
     }
 
-    print $client_answer;
-       return;
+    my $filter = POE::Filter::Reference->new();
+    my %result = ( 
+            status => "seems ok to me",
+            answer => $client_answer,
+            );
+
+    my $output = $filter->put( [ \%result ] );
+    print @$output;
+
+
+#    print STDERR $client_answer."\n";
+#    print $client_answer;
+#      return;
 }