[svn:p5ee] r3705 - p5ee/trunk/App-Context/lib/App

Author: spadkins
Date: Tue Mar 21 09:45:08 2006
New Revision: 3705

Modified:
   p5ee/trunk/App-Context/lib/App/Context.pm

Log:
add response(), renew_process_resources(), fork()

Modified: p5ee/trunk/App-Context/lib/App/Context.pm
==============================================================================
--- p5ee/trunk/App-Context/lib/App/Context.pm	(original)
+++ p5ee/trunk/App-Context/lib/App/Context.pm	Tue Mar 21 09:45:08 2006
@@ -2014,6 +2014,91 @@
     &App::sub_exit() if ($App::trace);
 }
 
+=head2 fork()
+
+    * Signature: $pid = $self->fork()
+    * Param:     void
+    * Return:    $pid     integer
+    * Throws:    App::Exception
+    * Since:     0.01
+
+    Sample Usage: 
+
+    $self->fork();
+
+The fork() method is called in a child process just after
+it has been fork()ed.
+This causes connections to databases, etc. to be closed gracefully and new
+connections to be created if necessary.
+
+Call this after a fork() in the child process.
+It will renew the resources which cannot be shared between a parent and 
+a child process. 
+
+Currently, this is primarily for database connections.
+For most databases, the child needs its own connection.
+
+=cut
+
+sub fork {
+    &App::sub_entry if ($App::trace);
+    my ($self) = @_;
+    my $pid = fork();
+    if (!$pid) {  # in the child process
+        $self->renew_process_resources();
+    }
+    &App::sub_exit($pid) if ($App::trace);
+    return($pid);
+}
+
+#############################################################################
+# renew_process_resources()
+#############################################################################
+
+=head2 renew_process_resources()
+
+    * Signature: $self->renew_process_resources()
+    * Param:     void
+    * Return:    void
+    * Throws:    App::Exception
+    * Since:     0.01
+
+    Sample Usage: 
+
+    $self->renew_process_resources();
+
+The renew_process_resources() method is called in a child process just after
+it has been fork()ed.
+This causes connections to databases, etc. to be closed gracefully and new
+connections to be created if necessary.
+
+Call this after a fork() in the child process.
+It will renew the resources which cannot be shared between a parent and 
+a child process. 
+
+Currently, this is primarily for database connections.
+For most databases, the child needs its own connection.
+
+=cut
+
+sub renew_process_resources {
+    my $self = shift;
+    my ($conf, $repdef, $repname, $instance);
+    my ($class, $method, $args, $argidx, $repcache);
+
+    $self->dbgprint("Context->renew_process_resources()")
+        if ($App::DEBUG && $self->dbg(1));
+
+    $repcache = $self->{session}{cache}{Repository};
+    if (defined $repcache && ref($repcache) eq "HASH") {
+        foreach $repname (keys %$repcache) {
+            $instance = $repcache->{$repname};
+            $instance->_renew_process_resources();
+            delete $repcache->{$repname};
+        }
+    }
+}
+
 #############################################################################
 # shutdown()
 #############################################################################
@@ -2057,5 +2142,49 @@
     }
 }
 
+#############################################################################
+# response()
+#############################################################################
+
+=head2 response()
+
+    * Signature: $context->response()
+    * Param:     void
+    * Return:    void
+    * Throws:    App::Exception
+    * Since:     0.01
+
+    Sample Usage: 
+
+    $context->response();
+
+The response() method gets the current Response being handled in the Context.
+
+=cut
+
+sub response {
+    &App::sub_entry if ($App::trace);
+    my $self = shift;
+
+    my $response = $self->{response};
+    if (!defined $response) {
+
+        #################################################################
+        # RESPONSE
+        #################################################################
+
+        my $response_class = $self->get_option("response_class", "App::Response");
+
+        eval {
+            $response = App->new($response_class, "new", $self, $self->{options});
+        };
+        $self->{response} = $response;
+        $self->add_message("Context::response(): $@") if ($@);
+    }
+
+    &App::sub_exit($response) if ($App::trace);
+    return($response);
+}
+
 1;