APPS.MSC_SRP_PIPE dependencies on DBMS_PIPE

Line 109: ---dbms_pipe.purge(p_outPipe); --

105: p_pcnt :=-1; --- no change from previous percentage
106:
107:
108:
109: ---dbms_pipe.purge(p_outPipe); --
110: dbms_pipe.pack_message(4); ---
111: if (dbms_pipe.send_message(p_outPipe,0,8192)) =3 then ---
112: p_error_code:=-1 ;-- pipe error
113: return;

Line 110: dbms_pipe.pack_message(4); ---

106:
107:
108:
109: ---dbms_pipe.purge(p_outPipe); --
110: dbms_pipe.pack_message(4); ---
111: if (dbms_pipe.send_message(p_outPipe,0,8192)) =3 then ---
112: p_error_code:=-1 ;-- pipe error
113: return;
114: end if;

Line 111: if (dbms_pipe.send_message(p_outPipe,0,8192)) =3 then ---

107:
108:
109: ---dbms_pipe.purge(p_outPipe); --
110: dbms_pipe.pack_message(4); ---
111: if (dbms_pipe.send_message(p_outPipe,0,8192)) =3 then ---
112: p_error_code:=-1 ;-- pipe error
113: return;
114: end if;
115:

Line 116: if (DBMS_PIPE.RECEIVE_MESSAGE(p_inPipe,0) in (2,3) )then

112: p_error_code:=-1 ;-- pipe error
113: return;
114: end if;
115:
116: if (DBMS_PIPE.RECEIVE_MESSAGE(p_inPipe,0) in (2,3) )then
117: p_error_code :=-1;
118: return;
119: else
120:

Line 121: dbms_pipe.unpack_message(l_engine_ping_return_code);

117: p_error_code :=-1;
118: return;
119: else
120:
121: dbms_pipe.unpack_message(l_engine_ping_return_code);
122: if (l_engine_ping_return_code is null) then
123:
124: -- this could be that engine is not running or
125: -- does not reponse ping

Line 146: dbms_pipe.unpack_message(l_engine_stage_code);

142: elsif (l_engine_ping_return_code =9) then
143: p_stage_code :=PLANNER_ERROR;
144: elsif (l_engine_ping_return_code=7) then
145:
146: dbms_pipe.unpack_message(l_engine_stage_code);
147: dbms_pipe.unpack_message(l_engine_percentage);
148:
149: p_pcnt :=l_engine_percentage;
150: if (l_engine_stage_code =1) then

Line 147: dbms_pipe.unpack_message(l_engine_percentage);

143: p_stage_code :=PLANNER_ERROR;
144: elsif (l_engine_ping_return_code=7) then
145:
146: dbms_pipe.unpack_message(l_engine_stage_code);
147: dbms_pipe.unpack_message(l_engine_percentage);
148:
149: p_pcnt :=l_engine_percentage;
150: if (l_engine_stage_code =1) then
151: p_stage_code :=LOAD_FILE;

Line 219: DBMS_PIPE.PACK_MESSAGE(p_msg);

215: p_msg in varchar2) return number is
216:
217: l_reStatus number;
218: begin
219: DBMS_PIPE.PACK_MESSAGE(p_msg);
220:
221: l_reStatus := DBMS_PIPE.SEND_MESSAGE(p_pipeName,
222: 1000,
223: 8192);

Line 221: l_reStatus := DBMS_PIPE.SEND_MESSAGE(p_pipeName,

217: l_reStatus number;
218: begin
219: DBMS_PIPE.PACK_MESSAGE(p_msg);
220:
221: l_reStatus := DBMS_PIPE.SEND_MESSAGE(p_pipeName,
222: 1000,
223: 8192);
224:
225:

Line 246: l_reStatus := DBMS_PIPE.RECEIVE_MESSAGE(p_pipeName,0);

242: Function read_pipe(p_pipeName in varchar2) return varchar2 is
243: l_msg varchar2(512) := NULL;
244: l_reStatus number;
245: begin
246: l_reStatus := DBMS_PIPE.RECEIVE_MESSAGE(p_pipeName,0);
247: --- possible return of dbms_pipe.receive_message are
248: --- 0 --> successfully
249: --- 1 --> time out
250: --- 2 --> message is too large. internal error

Line 247: --- possible return of dbms_pipe.receive_message are

243: l_msg varchar2(512) := NULL;
244: l_reStatus number;
245: begin
246: l_reStatus := DBMS_PIPE.RECEIVE_MESSAGE(p_pipeName,0);
247: --- possible return of dbms_pipe.receive_message are
248: --- 0 --> successfully
249: --- 1 --> time out
250: --- 2 --> message is too large. internal error
251: --- 3 --> internal error

Line 254: DBMS_PIPE.UNPACK_MESSAGE(l_msg);

250: --- 2 --> message is too large. internal error
251: --- 3 --> internal error
252:
253: IF l_reStatus = 0 THEN
254: DBMS_PIPE.UNPACK_MESSAGE(l_msg);
255: elsif (l_reStatus =2 ) OR (l_reStatus =3) then
256: l_msg := 'PIPE_ERROR';
257: END IF;
258: return l_msg;