|
|
@ -263,7 +263,7 @@ inSyncWork(FName, Work, Timeout) -> |
|
|
|
overflow; |
|
|
|
FTaskLen == FTLfl -> |
|
|
|
%% See factory if need to hire hourly worker |
|
|
|
case eLfq:in(QRef, {'$SyncWork', RetTag, Work}) of |
|
|
|
case eLfq:in(QRef, {'$SyncWork', RetTag, self(), Work}) of |
|
|
|
true -> |
|
|
|
fwFMgr:chAddW(FName), |
|
|
|
receive |
|
|
@ -277,7 +277,7 @@ inSyncWork(FName, Work, Timeout) -> |
|
|
|
end; |
|
|
|
FTaskLen < WFCnt -> |
|
|
|
%% See if need to wake up idle workers |
|
|
|
case eLfq:in(QRef, {'$SyncWork', RetTag, Work}) of |
|
|
|
case eLfq:in(QRef, {'$SyncWork', RetTag, self(), Work}) of |
|
|
|
true -> |
|
|
|
fwFMgr:chAwkW(FName), |
|
|
|
receive |
|
|
@ -290,7 +290,7 @@ inSyncWork(FName, Work, Timeout) -> |
|
|
|
false |
|
|
|
end; |
|
|
|
true -> |
|
|
|
case eLfq:in(QRef, {'$SyncWork', RetTag, Work}) of |
|
|
|
case eLfq:in(QRef, {'$SyncWork', RetTag, self(), Work}) of |
|
|
|
true -> |
|
|
|
receive |
|
|
|
{RetTag, Ret} -> |
|
|
|