Hi.

I think that retry_interval can be set also with LB.
Is it correct?

> +<directive name="retry_interval" workers="AJP,SUB" default="100"  
> required="false">

regards.

On Sun, Oct 5, 2008 at 4:05 PM,  <[EMAIL PROTECTED]> wrote:
> Author: mturk
> Date: Sun Oct  5 00:05:51 2008
> New Revision: 701754
>
> URL: http://svn.apache.org/viewvc?rev=701754&view=rev
> Log:
> Rename retry_wait to retry_interval. It means exactly that; 'the interval 
> between retries'
>
> Modified:
>    tomcat/connectors/trunk/jk/native/common/jk_ajp_common.c
>    tomcat/connectors/trunk/jk/native/common/jk_ajp_common.h
>    tomcat/connectors/trunk/jk/native/common/jk_lb_worker.c
>    tomcat/connectors/trunk/jk/native/common/jk_lb_worker.h
>    tomcat/connectors/trunk/jk/native/common/jk_util.c
>    tomcat/connectors/trunk/jk/native/common/jk_util.h
>    tomcat/connectors/trunk/jk/xdocs/miscellaneous/changelog.xml
>    tomcat/connectors/trunk/jk/xdocs/reference/workers.xml
>
> Modified: tomcat/connectors/trunk/jk/native/common/jk_ajp_common.c
> URL: 
> http://svn.apache.org/viewvc/tomcat/connectors/trunk/jk/native/common/jk_ajp_common.c?rev=701754&r1=701753&r2=701754&view=diff
> ==============================================================================
> --- tomcat/connectors/trunk/jk/native/common/jk_ajp_common.c (original)
> +++ tomcat/connectors/trunk/jk/native/common/jk_ajp_common.c Sun Oct  5 
> 00:05:51 2008
> @@ -2095,7 +2095,7 @@
>     int log_error;
>     int rc = JK_UNSET;
>     char *msg = "";
> -    int retry_wait;
> +    int retry_interval;
>
>     JK_TRACE_ENTER(l);
>
> @@ -2198,7 +2198,7 @@
>         aw->s->state = JK_AJP_STATE_PROBE;
>     if (aw->s->busy > aw->s->max_busy)
>         aw->s->max_busy = aw->s->busy;
> -    retry_wait = p->worker->retry_wait;
> +    retry_interval = p->worker->retry_interval;
>     for (i = 0; i < aw->retries; i++) {
>         /*
>          * ajp_send_request() already locally handles
> @@ -2206,12 +2206,12 @@
>          * So if we already failed in it, wait a bit before
>          * retrying the same backend.
>          */
> -        if (i > 0 && retry_wait >= 0) {
> +        if (i > 0 && retry_interval >= 0) {
>             if (JK_IS_DEBUG_LEVEL(l))
>                 jk_log(l, JK_LOG_DEBUG,
>                        "retry %d, sleeping for %d ms before retrying",
> -                       i, retry_wait);
> -            jk_sleep(retry_wait);
> +                       i, retry_interval);
> +            jk_sleep(retry_interval);
>         }
>         /*
>          * We're using op->request which hold initial request
> @@ -2554,8 +2554,8 @@
>         p->socket_buf =
>             jk_get_worker_socket_buffer(props, p->name, p->max_packet_size);
>
> -        p->retry_wait =
> -            jk_get_worker_retry_wait(props, p->name,
> +        p->retry_interval =
> +            jk_get_worker_retry_interval(props, p->name,
>                                      JK_SLEEP_DEF);
>
>         p->http_status_fail_num = jk_get_worker_fail_on_status(props, p->name,
> @@ -2625,8 +2625,8 @@
>                     p->max_packet_size);
>
>             jk_log(l, JK_LOG_DEBUG,
> -                   "retry wait time:  %d",
> -                    p->retry_wait);
> +                   "retry interval:   %d",
> +                    p->retry_interval);
>         }
>         /*
>          *  Need to initialize secret here since we could return from inside
>
> Modified: tomcat/connectors/trunk/jk/native/common/jk_ajp_common.h
> URL: 
> http://svn.apache.org/viewvc/tomcat/connectors/trunk/jk/native/common/jk_ajp_common.h?rev=701754&r1=701753&r2=701754&view=diff
> ==============================================================================
> --- tomcat/connectors/trunk/jk/native/common/jk_ajp_common.h (original)
> +++ tomcat/connectors/trunk/jk/native/common/jk_ajp_common.h Sun Oct  5 
> 00:05:51 2008
> @@ -337,7 +337,7 @@
>
>     unsigned int max_packet_size;  /*  Maximum AJP Packet size */
>
> -    int retry_wait;                /*  Number of milliseconds to sleep 
> before doing a retry */
> +    int retry_interval;            /*  Number of milliseconds to sleep 
> before doing a retry */
>
>     /*
>      * HTTP status that will cause failover (0 means disabled)
>
> Modified: tomcat/connectors/trunk/jk/native/common/jk_lb_worker.c
> URL: 
> http://svn.apache.org/viewvc/tomcat/connectors/trunk/jk/native/common/jk_lb_worker.c?rev=701754&r1=701753&r2=701754&view=diff
> ==============================================================================
> --- tomcat/connectors/trunk/jk/native/common/jk_lb_worker.c (original)
> +++ tomcat/connectors/trunk/jk/native/common/jk_lb_worker.c Sun Oct  5 
> 00:05:51 2008
> @@ -1095,7 +1095,7 @@
>             ajp_worker_t *aw = (ajp_worker_t *)rec->worker->worker_private;
>             jk_endpoint_t *end = NULL;
>             int retry = 0;
> -            int retry_wait = JK_LB_MIN_RETRY_WAIT;
> +            int retry_interval = JK_LB_MIN_RETRY_INTERVAL;
>
>             if (!s->route)
>                 s->route = rec->route;
> @@ -1117,12 +1117,12 @@
>
>             while ((!(r=rec->worker->get_endpoint(rec->worker, &end, l)) || 
> !end) && (retry < p->worker->retries)) {
>                 retry++;
> -                retry_wait *=2;
> +                retry_interval *=2;
>
>                 if (p->worker->lblock == JK_LB_LOCK_PESSIMISTIC)
>                     jk_shm_lock();
> -                if (retry_wait > JK_LB_MAX_RETRY_WAIT)
> -                    retry_wait = JK_LB_MAX_RETRY_WAIT;
> +                if (retry_interval > JK_LB_MAX_RETRY_INTERVAL)
> +                    retry_interval = JK_LB_MAX_RETRY_INTERVAL;
>                 if (p->worker->lblock == JK_LB_LOCK_PESSIMISTIC)
>                     jk_shm_unlock();
>
> @@ -1130,8 +1130,8 @@
>                     jk_log(l, JK_LOG_DEBUG,
>                            "could not get free endpoint for worker"
>                            " (retry %d, sleeping for %d ms)",
> -                           retry, retry_wait);
> -                jk_sleep(retry_wait);
> +                           retry, retry_interval);
> +                jk_sleep(retry_interval);
>             }
>             if (!r || !end) {
>                 /* If we can not get the endpoint
>
> Modified: tomcat/connectors/trunk/jk/native/common/jk_lb_worker.h
> URL: 
> http://svn.apache.org/viewvc/tomcat/connectors/trunk/jk/native/common/jk_lb_worker.h?rev=701754&r1=701753&r2=701754&view=diff
> ==============================================================================
> --- tomcat/connectors/trunk/jk/native/common/jk_lb_worker.h (original)
> +++ tomcat/connectors/trunk/jk/native/common/jk_lb_worker.h Sun Oct  5 
> 00:05:51 2008
> @@ -122,9 +122,9 @@
>  #define JK_NOTE_LB_LAST_STATE        ("JK_LB_LAST_STATE")
>
>  /* Minimal time in ms to wait between get_endpoint retries for balanced 
> workers */
> -#define JK_LB_MIN_RETRY_WAIT  (25)
> +#define JK_LB_MIN_RETRY_INTERVAL     (25)
>  /* Maximal time in ms to wait between get_endpoint retries for balanced 
> workers */
> -#define JK_LB_MAX_RETRY_WAIT  (100)
> +#define JK_LB_MAX_RETRY_INTERVAL     (100)
>  /* Time to wait before retry. */
>  #define WAIT_BEFORE_RECOVER   (60)
>  /* We accept doing global maintenance if we are */
>
> Modified: tomcat/connectors/trunk/jk/native/common/jk_util.c
> URL: 
> http://svn.apache.org/viewvc/tomcat/connectors/trunk/jk/native/common/jk_util.c?rev=701754&r1=701753&r2=701754&view=diff
> ==============================================================================
> --- tomcat/connectors/trunk/jk/native/common/jk_util.c (original)
> +++ tomcat/connectors/trunk/jk/native/common/jk_util.c Sun Oct  5 00:05:51 
> 2008
> @@ -86,7 +86,7 @@
>  #define ACTIVATION_OF_WORKER        ("activation")
>  #define WORKER_RECOVER_TIME         ("recover_time")
>  #define MAX_REPLY_TIMEOUTS_OF_WORKER ("max_reply_timeouts")
> -#define RETRY_WAIT_OF_WORKER        ("retry_wait")
> +#define RETRY_INTERVAL_OF_WORKER    ("retry_interval")
>  #define WORKER_MAX_PACKET_SIZE      ("max_packet_size")
>  #define STYLE_SHEET_OF_WORKER       ("css")
>  #define NAMESPACE_OF_WORKER         ("ns")
> @@ -202,7 +202,7 @@
>     ACTIVATION_OF_WORKER,
>     WORKER_RECOVER_TIME,
>     MAX_REPLY_TIMEOUTS_OF_WORKER,
> -    RETRY_WAIT_OF_WORKER,
> +    RETRY_INTERVAL_OF_WORKER,
>     WORKER_MAX_PACKET_SIZE,
>     STYLE_SHEET_OF_WORKER,
>     READ_ONLY_OF_WORKER,
> @@ -295,7 +295,7 @@
>     ACTIVATION_OF_WORKER,
>     WORKER_RECOVER_TIME,
>     MAX_REPLY_TIMEOUTS_OF_WORKER,
> -    RETRY_WAIT_OF_WORKER,
> +    RETRY_INTERVAL_OF_WORKER,
>     WORKER_MAX_PACKET_SIZE,
>     STYLE_SHEET_OF_WORKER,
>     NAMESPACE_OF_WORKER,
> @@ -970,7 +970,7 @@
>     return jk_map_get_int(m, buf, def);
>  }
>
> -int jk_get_worker_retry_wait(jk_map_t *m, const char *wname, int def)
> +int jk_get_worker_retry_interval(jk_map_t *m, const char *wname, int def)
>  {
>     char buf[1024];
>
> @@ -978,7 +978,7 @@
>         return -1;
>     }
>
> -    MAKE_WORKER_PARAM(RETRY_WAIT_OF_WORKER);
> +    MAKE_WORKER_PARAM(RETRY_INTERVAL_OF_WORKER);
>
>     return jk_map_get_int(m, buf, def);
>  }
>
> Modified: tomcat/connectors/trunk/jk/native/common/jk_util.h
> URL: 
> http://svn.apache.org/viewvc/tomcat/connectors/trunk/jk/native/common/jk_util.h?rev=701754&r1=701753&r2=701754&view=diff
> ==============================================================================
> --- tomcat/connectors/trunk/jk/native/common/jk_util.h (original)
> +++ tomcat/connectors/trunk/jk/native/common/jk_util.h Sun Oct  5 00:05:51 
> 2008
> @@ -98,7 +98,7 @@
>
>  int jk_get_worker_max_reply_timeouts(jk_map_t *m, const char *wname, int 
> def);
>
> -int jk_get_worker_retry_wait(jk_map_t *m, const char *wname, int def);
> +int jk_get_worker_retry_interval(jk_map_t *m, const char *wname, int def);
>
>  const char *jk_get_worker_route(jk_map_t *m, const char *wname, const char 
> *def);
>
>
> Modified: tomcat/connectors/trunk/jk/xdocs/miscellaneous/changelog.xml
> URL: 
> http://svn.apache.org/viewvc/tomcat/connectors/trunk/jk/xdocs/miscellaneous/changelog.xml?rev=701754&r1=701753&r2=701754&view=diff
> ==============================================================================
> --- tomcat/connectors/trunk/jk/xdocs/miscellaneous/changelog.xml (original)
> +++ tomcat/connectors/trunk/jk/xdocs/miscellaneous/changelog.xml Sun Oct  5 
> 00:05:51 2008
> @@ -47,7 +47,7 @@
>         Status: Add display of seconds since last statistics reset. (rjung)
>       </update>
>       <add>
> -        AJP13: Add a configurable retry wait time. (rjung)
> +        AJP13: Add a configurable retry_interval time. (rjung)
>       </add>
>       <update>
>         Documentation: Enhance description of connection_pool_size. (rjung)
>
> Modified: tomcat/connectors/trunk/jk/xdocs/reference/workers.xml
> URL: 
> http://svn.apache.org/viewvc/tomcat/connectors/trunk/jk/xdocs/reference/workers.xml?rev=701754&r1=701753&r2=701754&view=diff
> ==============================================================================
> --- tomcat/connectors/trunk/jk/xdocs/reference/workers.xml (original)
> +++ tomcat/connectors/trunk/jk/xdocs/reference/workers.xml Sun Oct  5 
> 00:05:51 2008
> @@ -729,14 +729,14 @@
>  sleeping time.
>  <p>
>  See also the attribute <b>recovery_options</b> for a more fine-grained 
> control
> -of retries and <b>retry_wait</b> for the sleep time configuration.
> +of retries and <b>retry_interval</b> for the sleep time configuration.
>  </p>
>  <p>
>  Until version <b>1.2.16</b> the default value was 3.
>  </p>
>  </directive>
>
> -<directive name="retry_wait" workers="AJP,SUB" default="100" 
> required="false">
> +<directive name="retry_interval" workers="AJP,SUB" default="100" 
> required="false">
>  The amount of time in milliseconds the worker sleeps before doing any retry.
>  <p>
>  This features has been added in <b>jk 1.2.27</b>.
>
>
>
> ---------------------------------------------------------------------
> To unsubscribe, e-mail: [EMAIL PROTECTED]
> For additional commands, e-mail: [EMAIL PROTECTED]
>
>

---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]

Reply via email to