Bug 615334 - Ch 16 low-latency
Summary: Ch 16 low-latency
Status: CLOSED CURRENTRELEASE
Alias: None
Product: Red Hat Enterprise MRG
Classification: Red Hat
Component: Grid_User_Guide
Version: Development
Hardware: All
OS: Linux
medium
medium
Target Milestone: 1.3
: ---
Assignee: Lana Brindley
QA Contact: Lubos Trilety
URL:
Whiteboard:
Keywords:
Depends On:
Blocks:
TreeView+ depends on / blocked
 
Reported: 2010-07-16 14:23 UTC by Robert Rati
Modified: 2013-10-23 23:17 UTC (History)
3 users (show)

(edit)
Clone Of:
(edit)
Last Closed: 2010-10-14 20:11:37 UTC


Attachments (Terms of Use)

Description Robert Rati 2010-07-16 14:23:07 UTC
Description of problem:
Remove "Further examples can be found at usr/share/doc/condor-low-latency-1.0/ll_condor_config"

Change
FetchWorkDelay = 10 * (Activity == "Idle")

To:
FetchWorkDelay = ifThenElse(State == "Claimed" && Activity == "Idle", 0, 10)


Suggest re-organizing table 16.1 such that all *LL_* items are together and all *JOB_HOOKS_* items are together.

"replyTo reply-t queue" => replyTo reply-to queue

In example 16.1, need to show definition of replyTo, so add:
replyTo = str(uuid4())

Also, add quotes around amq.direct, so 'amq.direct'

Version-Release number of selected component (if applicable):


How reproducible:


Steps to Reproduce:
1.
2.
3.
  
Actual results:


Expected results:


Additional info:

Comment 1 Lana Brindley 2010-07-19 02:51:31 UTC
(In reply to comment #0)
> Description of problem:
> Remove "Further examples can be found at
> usr/share/doc/condor-low-latency-1.0/ll_condor_config"

Removed.

> 
> Change
> FetchWorkDelay = 10 * (Activity == "Idle")
> 
> To:
> FetchWorkDelay = ifThenElse(State == "Claimed" && Activity == "Idle", 0, 10)
> 

<programlisting>
FetchWorkDelay = ifThenElse(State == "Claimed" &amp;&amp; Activity == "Idle", 0, 10)
STARTER_UPDATE_INTERVAL = 30
</programlisting>

> 
> Suggest re-organizing table 16.1 such that all *LL_* items are together and all
> *JOB_HOOKS_* items are together.

Good idea. Done.

> 
> "replyTo reply-t queue" => replyTo reply-to queue
> 
> In example 16.1, need to show definition of replyTo, so add:
> replyTo = str(uuid4())
> 
> Also, add quotes around amq.direct, so 'amq.direct'

<programlisting>
work_headers = {}
work_headers[&#39;Cmd&#39;] = &#39;&#34;/bin/sleep&#34;&#39;
work_headers[&#39;Arguments&#39;] = &#39;&#34;5&#34;&#39;
work_headers[&#39;Iwd&#39;] = &#39;&#34;/tmp&#34;&#39;
work_headers[&#39;Owner&#39;] = &#39;&#34;nobody&#34;&#39;
work_headers[&#39;JobUniverse&#39;] = 5
message_props = session.message_properties(application_headers=work_headers)
message_props.reply_to = session.reply_to('amq.direct', replyTo)
message_props.message_id = uuid4()
replyTo = str(uuid4())
</programlisting>

LKB

Comment 2 Luigi Toscano 2010-08-13 12:29:43 UTC
In the following code snippet, 

[...]
message_props = session.message_properties(application_headers=work_headers)
message_props.reply_to = session.reply_to('amq.direct', replyTo)
message_props.message_id = uuid4()
replyTo = str(uuid4())


replyTo should be defined before the line which uses it, so:

[...]
message_props = session.message_properties(application_headers=work_headers)
replyTo = str(uuid4())
message_props.reply_to = session.reply_to('amq.direct', replyTo)
message_props.message_id = uuid4()

Comment 3 Lana Brindley 2010-08-25 02:39:55 UTC
(In reply to comment #2)
> In the following code snippet, 
> 
> [...]
> message_props = session.message_properties(application_headers=work_headers)
> message_props.reply_to = session.reply_to('amq.direct', replyTo)
> message_props.message_id = uuid4()
> replyTo = str(uuid4())
> 
> 
> replyTo should be defined before the line which uses it, so:
> 
> [...]
> message_props = session.message_properties(application_headers=work_headers)
> replyTo = str(uuid4())
> message_props.reply_to = session.reply_to('amq.direct', replyTo)
> message_props.message_id = uuid4()

<programlisting>
work_headers = {}
work_headers[&#39;Cmd&#39;] = &#39;&#34;/bin/sleep&#34;&#39;
work_headers[&#39;Arguments&#39;] = &#39;&#34;5&#34;&#39;
work_headers[&#39;Iwd&#39;] = &#39;&#34;/tmp&#34;&#39;
work_headers[&#39;Owner&#39;] = &#39;&#34;nobody&#34;&#39;
work_headers[&#39;JobUniverse&#39;] = 5
message_props = session.message_properties(application_headers=work_headers)
replyTo = str(uuid4())
message_props.reply_to = session.reply_to(&#39;amq.direct&#39;, replyTo)
message_props.message_id = uuid4()
</programlisting>

LKB

Comment 4 Lubos Trilety 2010-09-01 12:17:40 UTC
All notes checked

>>> VERIFIED


Note You need to log in before you can comment on or make changes to this bug.