Bug 615334

Summary: Ch 16 low-latency
Product: Red Hat Enterprise MRG Reporter: Robert Rati <rrati>
Component: Grid_User_GuideAssignee: Lana Brindley <lbrindle>
Status: CLOSED CURRENTRELEASE QA Contact: Lubos Trilety <ltrilety>
Severity: medium Docs Contact:
Priority: medium    
Version: DevelopmentCC: ltoscano, ltrilety, mhideo
Target Milestone: 1.3   
Target Release: ---   
Hardware: All   
OS: Linux   
Whiteboard:
Fixed In Version: Doc Type: Bug Fix
Doc Text:
Story Points: ---
Clone Of: Environment:
Last Closed: 2010-10-14 20:11:37 UTC Type: ---
Regression: --- Mount Type: ---
Documentation: --- CRM:
Verified Versions: Category: ---
oVirt Team: --- RHEL 7.3 requirements from Atomic Host:
Cloudforms Team: --- Target Upstream Version:
Embargoed:

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