124: end_time := sysdate + (timeout / (24 * 60 * 60));
125:
126: loop
127:
128: fnd_cp_opp_ipc.get_message(cpid, flag, msgtype, msggroup, message, params, sender, timeout, reqid);
129:
130: -- if flag = N then a timeout or exception occurred
131: if flag <> 'Y' then
132:
244: subscriber varchar2(30);
245:
246: begin
247: -- Check to see if a service is running on the local node
248: if (fnd_cp_opp_ipc.check_group_subscribers(localnode) >= 1) then
249: return localnode;
250: end if;
251:
252: -- if not, select a random service
249: return localnode;
250: end if;
251:
252: -- if not, select a random service
253: subscriber := fnd_cp_opp_ipc.select_random_subscriber;
254: if subscriber is null then
255: return null;
256: end if;
257:
414:
415:
416:
417:
418: fnd_cp_opp_ipc.send_request(groupid, cpid, reqid, '');
419:
420: fnd_profile.get('CONC_PP_RESPONSE_TIMEOUT', prof_buffer);
421: if prof_buffer is null then
422: timeout := TIMEOUT1;