eTRM uses javascript that opens and focuses a separate window to display reports. Your browser does not appear to support javascript. This should not prevent you from using eTRM but it does mean the window focus feature will not work. Please check the contents of other windows on your desktop if you click on a link that does not appear to do anything.

OWAPUB.DEBUG_CARTX dependencies on DBMS_PIPE

Line 43: sys.dbms_pipe.purge(pipeName);

39: This function should be called as a last call to the pipes.
40: Never send a message or ack and call this immediately.
41: If we do this, we may remove the pipe prematurely.
42: */
43: sys.dbms_pipe.purge(pipeName);
44: sys.dbms_pipe.purge(pipeName || 'Res');
45:
46: status := sys.dbms_pipe.remove_pipe(pipeName);
47: status := sys.dbms_pipe.remove_pipe(pipeName || 'Res');

Line 44: sys.dbms_pipe.purge(pipeName || 'Res');

40: Never send a message or ack and call this immediately.
41: If we do this, we may remove the pipe prematurely.
42: */
43: sys.dbms_pipe.purge(pipeName);
44: sys.dbms_pipe.purge(pipeName || 'Res');
45:
46: status := sys.dbms_pipe.remove_pipe(pipeName);
47: status := sys.dbms_pipe.remove_pipe(pipeName || 'Res');
48: end;

Line 46: status := sys.dbms_pipe.remove_pipe(pipeName);

42: */
43: sys.dbms_pipe.purge(pipeName);
44: sys.dbms_pipe.purge(pipeName || 'Res');
45:
46: status := sys.dbms_pipe.remove_pipe(pipeName);
47: status := sys.dbms_pipe.remove_pipe(pipeName || 'Res');
48: end;
49:
50: PROCEDURE sendAck(PipeName varchar2, msg integer, status OUT integer) IS

Line 47: status := sys.dbms_pipe.remove_pipe(pipeName || 'Res');

43: sys.dbms_pipe.purge(pipeName);
44: sys.dbms_pipe.purge(pipeName || 'Res');
45:
46: status := sys.dbms_pipe.remove_pipe(pipeName);
47: status := sys.dbms_pipe.remove_pipe(pipeName || 'Res');
48: end;
49:
50: PROCEDURE sendAck(PipeName varchar2, msg integer, status OUT integer) IS
51: errNo integer;

Line 53: status := sys.dbms_pipe.create_pipe(PipeName, 8192, FALSE);

49:
50: PROCEDURE sendAck(PipeName varchar2, msg integer, status OUT integer) IS
51: errNo integer;
52: BEGIN
53: status := sys.dbms_pipe.create_pipe(PipeName, 8192, FALSE);
54:
55: if (status = 0) then
56: sys.dbms_pipe.Pack_Message(msg);
57: status := sys.dbms_pipe.Send_Message(PipeName, 3600);

Line 56: sys.dbms_pipe.Pack_Message(msg);

52: BEGIN
53: status := sys.dbms_pipe.create_pipe(PipeName, 8192, FALSE);
54:
55: if (status = 0) then
56: sys.dbms_pipe.Pack_Message(msg);
57: status := sys.dbms_pipe.Send_Message(PipeName, 3600);
58: end if;
59: end;
60:

Line 57: status := sys.dbms_pipe.Send_Message(PipeName, 3600);

53: status := sys.dbms_pipe.create_pipe(PipeName, 8192, FALSE);
54:
55: if (status = 0) then
56: sys.dbms_pipe.Pack_Message(msg);
57: status := sys.dbms_pipe.Send_Message(PipeName, 3600);
58: end if;
59: end;
60:
61: PROCEDURE sendAck(PipeName varchar2, msg varchar2, status OUT integer) IS

Line 64: status := sys.dbms_pipe.create_pipe(PipeName, 8192, FALSE);

60:
61: PROCEDURE sendAck(PipeName varchar2, msg varchar2, status OUT integer) IS
62: errNo integer;
63: BEGIN
64: status := sys.dbms_pipe.create_pipe(PipeName, 8192, FALSE);
65:
66: if (status = 0) then
67: sys.dbms_pipe.Pack_Message(msg);
68: status := sys.dbms_pipe.Send_Message(PipeName, 3600);

Line 67: sys.dbms_pipe.Pack_Message(msg);

63: BEGIN
64: status := sys.dbms_pipe.create_pipe(PipeName, 8192, FALSE);
65:
66: if (status = 0) then
67: sys.dbms_pipe.Pack_Message(msg);
68: status := sys.dbms_pipe.Send_Message(PipeName, 3600);
69: end if;
70: end;
71:

Line 68: status := sys.dbms_pipe.Send_Message(PipeName, 3600);

64: status := sys.dbms_pipe.create_pipe(PipeName, 8192, FALSE);
65:
66: if (status = 0) then
67: sys.dbms_pipe.Pack_Message(msg);
68: status := sys.dbms_pipe.Send_Message(PipeName, 3600);
69: end if;
70: end;
71:
72: PROCEDURE sendAck(PipeName varchar2, numMsg integer,

Line 76: status := sys.dbms_pipe.create_pipe(PipeName, 8192, FALSE);

72: PROCEDURE sendAck(PipeName varchar2, numMsg integer,
73: msg varchar2, status OUT integer) IS
74: errNo integer;
75: BEGIN
76: status := sys.dbms_pipe.create_pipe(PipeName, 8192, FALSE);
77:
78: if (status = 0) then
79: sys.dbms_pipe.Pack_Message(NumMsg);
80: sys.dbms_pipe.Pack_Message(msg);

Line 79: sys.dbms_pipe.Pack_Message(NumMsg);

75: BEGIN
76: status := sys.dbms_pipe.create_pipe(PipeName, 8192, FALSE);
77:
78: if (status = 0) then
79: sys.dbms_pipe.Pack_Message(NumMsg);
80: sys.dbms_pipe.Pack_Message(msg);
81: status := sys.dbms_pipe.Send_Message(PipeName, 3600);
82: end if;
83: end;

Line 80: sys.dbms_pipe.Pack_Message(msg);

76: status := sys.dbms_pipe.create_pipe(PipeName, 8192, FALSE);
77:
78: if (status = 0) then
79: sys.dbms_pipe.Pack_Message(NumMsg);
80: sys.dbms_pipe.Pack_Message(msg);
81: status := sys.dbms_pipe.Send_Message(PipeName, 3600);
82: end if;
83: end;
84:

Line 81: status := sys.dbms_pipe.Send_Message(PipeName, 3600);

77:
78: if (status = 0) then
79: sys.dbms_pipe.Pack_Message(NumMsg);
80: sys.dbms_pipe.Pack_Message(msg);
81: status := sys.dbms_pipe.Send_Message(PipeName, 3600);
82: end if;
83: end;
84:
85: FUNCTION waitForAck(pipename varchar2, res out varchar2) RETURN INTEGER is

Line 95: status := sys.dbms_pipe.Receive_Message(PipeName);

91: msg := '';
92: res := '';
93: numMsg := 0;
94:
95: status := sys.dbms_pipe.Receive_Message(PipeName);
96: if (status = 0) then
97: msgType := sys.dbms_pipe.Next_Item_Type;
98: if (msgType = 9) then
99: sys.dbms_pipe.unpack_message(res);

Line 97: msgType := sys.dbms_pipe.Next_Item_Type;

93: numMsg := 0;
94:
95: status := sys.dbms_pipe.Receive_Message(PipeName);
96: if (status = 0) then
97: msgType := sys.dbms_pipe.Next_Item_Type;
98: if (msgType = 9) then
99: sys.dbms_pipe.unpack_message(res);
100: elsif (msgType = 6) then
101: sys.dbms_pipe.unpack_message(numMsg);

Line 99: sys.dbms_pipe.unpack_message(res);

95: status := sys.dbms_pipe.Receive_Message(PipeName);
96: if (status = 0) then
97: msgType := sys.dbms_pipe.Next_Item_Type;
98: if (msgType = 9) then
99: sys.dbms_pipe.unpack_message(res);
100: elsif (msgType = 6) then
101: sys.dbms_pipe.unpack_message(numMsg);
102: res := to_char(numMsg);
103: else

Line 101: sys.dbms_pipe.unpack_message(numMsg);

97: msgType := sys.dbms_pipe.Next_Item_Type;
98: if (msgType = 9) then
99: sys.dbms_pipe.unpack_message(res);
100: elsif (msgType = 6) then
101: sys.dbms_pipe.unpack_message(numMsg);
102: res := to_char(numMsg);
103: else
104: res := to_char(msgType);
105: end if;

Line 176: SessionId := sys.dbms_pipe.unique_session_name;

172:
173:
174: PROCEDURE getInternalDebugSession(SessionId out varchar2) IS
175: BEGIN
176: SessionId := sys.dbms_pipe.unique_session_name;
177: end;
178:
179: PROCEDURE fmtSessionId (SessionId in out varchar2) IS
180: BEGIN

Line 333: sys.dbms_pipe.purge(SessID);

329: sendAck(SessId, DEBUG_CARTX_QUIT, status);
330: sendAck(SessId || 'Res', DEBUG_CARTX_QUIT, status);
331:
332: --Now clean the pipes.
333: sys.dbms_pipe.purge(SessID);
334: sys.dbms_pipe.purge(SessID || 'Res');
335: status := sys.dbms_pipe.remove_pipe(SessID);
336: status := sys.dbms_pipe.remove_pipe(SessID || 'Res');
337:

Line 334: sys.dbms_pipe.purge(SessID || 'Res');

330: sendAck(SessId || 'Res', DEBUG_CARTX_QUIT, status);
331:
332: --Now clean the pipes.
333: sys.dbms_pipe.purge(SessID);
334: sys.dbms_pipe.purge(SessID || 'Res');
335: status := sys.dbms_pipe.remove_pipe(SessID);
336: status := sys.dbms_pipe.remove_pipe(SessID || 'Res');
337:
338: --Now that we have successfully removed the pipes send a message.

Line 335: status := sys.dbms_pipe.remove_pipe(SessID);

331:
332: --Now clean the pipes.
333: sys.dbms_pipe.purge(SessID);
334: sys.dbms_pipe.purge(SessID || 'Res');
335: status := sys.dbms_pipe.remove_pipe(SessID);
336: status := sys.dbms_pipe.remove_pipe(SessID || 'Res');
337:
338: --Now that we have successfully removed the pipes send a message.
339: htp.print('SessionID ' || SessionId || ' has been successfully reset.');

Line 336: status := sys.dbms_pipe.remove_pipe(SessID || 'Res');

332: --Now clean the pipes.
333: sys.dbms_pipe.purge(SessID);
334: sys.dbms_pipe.purge(SessID || 'Res');
335: status := sys.dbms_pipe.remove_pipe(SessID);
336: status := sys.dbms_pipe.remove_pipe(SessID || 'Res');
337:
338: --Now that we have successfully removed the pipes send a message.
339: htp.print('SessionID ' || SessionId || ' has been successfully reset.');
340: htp.bodyclose;

Line 368: sys.dbms_pipe.purge(SessionID);

364: --Send a 'bye' message to all waiting processes
365: sendAck(SessionId, DEBUG_CARTX_QUIT, status);
366: sendAck(SessionId || 'Res', DEBUG_CARTX_QUIT, status);
367: --Now clean the pipes.
368: sys.dbms_pipe.purge(SessionID);
369: sys.dbms_pipe.purge(SessionID || 'Res');
370: status := sys.dbms_pipe.remove_pipe(SessionID);
371: status := sys.dbms_pipe.remove_pipe(SessionID || 'Res');
372:

Line 369: sys.dbms_pipe.purge(SessionID || 'Res');

365: sendAck(SessionId, DEBUG_CARTX_QUIT, status);
366: sendAck(SessionId || 'Res', DEBUG_CARTX_QUIT, status);
367: --Now clean the pipes.
368: sys.dbms_pipe.purge(SessionID);
369: sys.dbms_pipe.purge(SessionID || 'Res');
370: status := sys.dbms_pipe.remove_pipe(SessionID);
371: status := sys.dbms_pipe.remove_pipe(SessionID || 'Res');
372:
373: --Now that we have successfully removed the pipes send a message.

Line 370: status := sys.dbms_pipe.remove_pipe(SessionID);

366: sendAck(SessionId || 'Res', DEBUG_CARTX_QUIT, status);
367: --Now clean the pipes.
368: sys.dbms_pipe.purge(SessionID);
369: sys.dbms_pipe.purge(SessionID || 'Res');
370: status := sys.dbms_pipe.remove_pipe(SessionID);
371: status := sys.dbms_pipe.remove_pipe(SessionID || 'Res');
372:
373: --Now that we have successfully removed the pipes send a message.
374: htp.print('SessionID: ' || substr(SessionId, 10) ||

Line 371: status := sys.dbms_pipe.remove_pipe(SessionID || 'Res');

367: --Now clean the pipes.
368: sys.dbms_pipe.purge(SessionID);
369: sys.dbms_pipe.purge(SessionID || 'Res');
370: status := sys.dbms_pipe.remove_pipe(SessionID);
371: status := sys.dbms_pipe.remove_pipe(SessionID || 'Res');
372:
373: --Now that we have successfully removed the pipes send a message.
374: htp.print('SessionID: ' || substr(SessionId, 10) ||
375: ' is successfully reset.');

Line 410: status := sys.dbms_pipe.create_pipe(PipeName, 8192, FALSE);

406:
407:
408: resPipeName := pipeName || 'Res';
409:
410: status := sys.dbms_pipe.create_pipe(PipeName, 8192, FALSE);
411: if (status = 0) then
412: sys.dbms_pipe.Pack_Message(num_params);
413:
414: FOR counter IN 1 .. num_params LOOP

Line 412: sys.dbms_pipe.Pack_Message(num_params);

408: resPipeName := pipeName || 'Res';
409:
410: status := sys.dbms_pipe.create_pipe(PipeName, 8192, FALSE);
411: if (status = 0) then
412: sys.dbms_pipe.Pack_Message(num_params);
413:
414: FOR counter IN 1 .. num_params LOOP
415: msg := param_name(counter);
416: sys.dbms_pipe.Pack_Message(msg);

Line 416: sys.dbms_pipe.Pack_Message(msg);

412: sys.dbms_pipe.Pack_Message(num_params);
413:
414: FOR counter IN 1 .. num_params LOOP
415: msg := param_name(counter);
416: sys.dbms_pipe.Pack_Message(msg);
417: END LOOP;
418:
419: counter := 1;
420: FOR counter IN 1 .. num_params LOOP

Line 422: sys.dbms_pipe.Pack_Message(msg);

418:
419: counter := 1;
420: FOR counter IN 1 .. num_params LOOP
421: msg := param_val(counter);
422: sys.dbms_pipe.Pack_Message(msg);
423: END LOOP;
424: status := sys.dbms_pipe.Send_Message(PipeName, 3600);
425: ack := waitForAck(resPipeName, res);
426:

Line 424: status := sys.dbms_pipe.Send_Message(PipeName, 3600);

420: FOR counter IN 1 .. num_params LOOP
421: msg := param_val(counter);
422: sys.dbms_pipe.Pack_Message(msg);
423: END LOOP;
424: status := sys.dbms_pipe.Send_Message(PipeName, 3600);
425: ack := waitForAck(resPipeName, res);
426:
427: if (ack < DEBUG_CARTX_SUCCESS) then
428: getDebugSessionId(SessId);

Line 457: status := sys.dbms_pipe.create_pipe(pipeName, 8192, FALSE);

453: begin
454: getInternalDebugSession(pipeName);
455: resPipeName := pipeName || 'Res';
456:
457: status := sys.dbms_pipe.create_pipe(pipeName, 8192, FALSE);
458: if (status = 0) then
459: sys.dbms_pipe.Pack_Message(procname);
460: status := sys.dbms_pipe.Send_Message(pipeName, 3600);
461: ack := waitForAck(resPipeName, res);

Line 459: sys.dbms_pipe.Pack_Message(procname);

455: resPipeName := pipeName || 'Res';
456:
457: status := sys.dbms_pipe.create_pipe(pipeName, 8192, FALSE);
458: if (status = 0) then
459: sys.dbms_pipe.Pack_Message(procname);
460: status := sys.dbms_pipe.Send_Message(pipeName, 3600);
461: ack := waitForAck(resPipeName, res);
462:
463: if (ack < DEBUG_CARTX_SUCCESS) then

Line 460: status := sys.dbms_pipe.Send_Message(pipeName, 3600);

456:
457: status := sys.dbms_pipe.create_pipe(pipeName, 8192, FALSE);
458: if (status = 0) then
459: sys.dbms_pipe.Pack_Message(procname);
460: status := sys.dbms_pipe.Send_Message(pipeName, 3600);
461: ack := waitForAck(resPipeName, res);
462:
463: if (ack < DEBUG_CARTX_SUCCESS) then
464: getDebugSessionId(SessId);

Line 480: status := sys.dbms_pipe.create_pipe(PipeName, 8192, FALSE);

476: status integer;
477: SessId varchar2(30);
478: begin
479: getInternalDebugSession(PipeName);
480: status := sys.dbms_pipe.create_pipe(PipeName, 8192, FALSE);
481: if (status = 0) then
482: sys.dbms_pipe.Pack_Message(source);
483: status := sys.dbms_pipe.Send_Message(PipeName, 3600);
484: ack := waitForAck(PipeName || 'Res', res);

Line 482: sys.dbms_pipe.Pack_Message(source);

478: begin
479: getInternalDebugSession(PipeName);
480: status := sys.dbms_pipe.create_pipe(PipeName, 8192, FALSE);
481: if (status = 0) then
482: sys.dbms_pipe.Pack_Message(source);
483: status := sys.dbms_pipe.Send_Message(PipeName, 3600);
484: ack := waitForAck(PipeName || 'Res', res);
485:
486: if (ack < DEBUG_CARTX_SUCCESS) then

Line 483: status := sys.dbms_pipe.Send_Message(PipeName, 3600);

479: getInternalDebugSession(PipeName);
480: status := sys.dbms_pipe.create_pipe(PipeName, 8192, FALSE);
481: if (status = 0) then
482: sys.dbms_pipe.Pack_Message(source);
483: status := sys.dbms_pipe.Send_Message(PipeName, 3600);
484: ack := waitForAck(PipeName || 'Res', res);
485:
486: if (ack < DEBUG_CARTX_SUCCESS) then
487: getDebugSessionId(SessId);

Line 513: status := sys.dbms_pipe.Receive_Message(resPipename);

509: resPipeName := pipeName || 'Res';
510:
511: insertmessage ('Waiting in fetch results.');
512: --First receive the downloadfilelist and its properties.
513: status := sys.dbms_pipe.Receive_Message(resPipename);
514: if (status = 0) then
515: msgType := sys.dbms_pipe.Next_Item_Type;
516: if (msgType = 9) then
517: sys.dbms_pipe.unpack_message(sDownloadFileList);

Line 515: msgType := sys.dbms_pipe.Next_Item_Type;

511: insertmessage ('Waiting in fetch results.');
512: --First receive the downloadfilelist and its properties.
513: status := sys.dbms_pipe.Receive_Message(resPipename);
514: if (status = 0) then
515: msgType := sys.dbms_pipe.Next_Item_Type;
516: if (msgType = 9) then
517: sys.dbms_pipe.unpack_message(sDownloadFileList);
518: elsif (msgType = 6) then
519: sys.dbms_pipe.unpack_message(ack);

Line 517: sys.dbms_pipe.unpack_message(sDownloadFileList);

513: status := sys.dbms_pipe.Receive_Message(resPipename);
514: if (status = 0) then
515: msgType := sys.dbms_pipe.Next_Item_Type;
516: if (msgType = 9) then
517: sys.dbms_pipe.unpack_message(sDownloadFileList);
518: elsif (msgType = 6) then
519: sys.dbms_pipe.unpack_message(ack);
520: insertmessage (to_char(ack));
521: getDebugSessionId(SessId);

Line 519: sys.dbms_pipe.unpack_message(ack);

515: msgType := sys.dbms_pipe.Next_Item_Type;
516: if (msgType = 9) then
517: sys.dbms_pipe.unpack_message(sDownloadFileList);
518: elsif (msgType = 6) then
519: sys.dbms_pipe.unpack_message(ack);
520: insertmessage (to_char(ack));
521: getDebugSessionId(SessId);
522: handleAborts(ack, Sessid);
523: cleanup_pipes(pipeName);

Line 531: msgType := sys.dbms_pipe.Next_Item_Type;

527: -- raise PDE_QUIT_DEBUG_CARTX;
528: end if;
529:
530:
531: msgType := sys.dbms_pipe.Next_Item_Type;
532: if (msgType = 6) then
533: sys.dbms_pipe.unpack_message(nCompress);
534: end if;
535:

Line 533: sys.dbms_pipe.unpack_message(nCompress);

529:
530:
531: msgType := sys.dbms_pipe.Next_Item_Type;
532: if (msgType = 6) then
533: sys.dbms_pipe.unpack_message(nCompress);
534: end if;
535:
536: sendAck(pipename, DEBUG_CARTX_SUCCESS, status);
537: else

Line 562: status := sys.dbms_pipe.Receive_Message(resPipename);

558:
559: msg := '';
560: --Now receive the htp page data.
561: loop
562: status := sys.dbms_pipe.Receive_Message(resPipename);
563: if (status = 0) then
564: msgType := sys.dbms_pipe.Next_Item_Type;
565:
566: if (msgType = 9) then

Line 564: msgType := sys.dbms_pipe.Next_Item_Type;

560: --Now receive the htp page data.
561: loop
562: status := sys.dbms_pipe.Receive_Message(resPipename);
563: if (status = 0) then
564: msgType := sys.dbms_pipe.Next_Item_Type;
565:
566: if (msgType = 9) then
567: sys.dbms_pipe.unpack_message(msg);
568: numLines := to_number(msg);

Line 567: sys.dbms_pipe.unpack_message(msg);

563: if (status = 0) then
564: msgType := sys.dbms_pipe.Next_Item_Type;
565:
566: if (msgType = 9) then
567: sys.dbms_pipe.unpack_message(msg);
568: numLines := to_number(msg);
569: elsif(msgType = 6) then
570: sys.dbms_pipe.unpack_message(numLines);
571: else

Line 570: sys.dbms_pipe.unpack_message(numLines);

566: if (msgType = 9) then
567: sys.dbms_pipe.unpack_message(msg);
568: numLines := to_number(msg);
569: elsif(msgType = 6) then
570: sys.dbms_pipe.unpack_message(numLines);
571: else
572: --Weird type. Something is wrong... Get out...
573: numLines := DEBUG_CARTX_RES_OVER;
574: end if;

Line 583: msgType := sys.dbms_pipe.Next_Item_Type;

579: end if;
580:
581: if (numLines > 0) then
582: FOR counter IN 1 .. numLines LOOP
583: msgType := sys.dbms_pipe.Next_Item_Type;
584: if (msgType = 9) then
585: sys.dbms_pipe.unpack_message(msg);
586: htp.prn(msg);
587: elsif(msgType = 6) then

Line 585: sys.dbms_pipe.unpack_message(msg);

581: if (numLines > 0) then
582: FOR counter IN 1 .. numLines LOOP
583: msgType := sys.dbms_pipe.Next_Item_Type;
584: if (msgType = 9) then
585: sys.dbms_pipe.unpack_message(msg);
586: htp.prn(msg);
587: elsif(msgType = 6) then
588: sys.dbms_pipe.unpack_message(numMsg);
589: htp.prn(numMsg);

Line 588: sys.dbms_pipe.unpack_message(numMsg);

584: if (msgType = 9) then
585: sys.dbms_pipe.unpack_message(msg);
586: htp.prn(msg);
587: elsif(msgType = 6) then
588: sys.dbms_pipe.unpack_message(numMsg);
589: htp.prn(numMsg);
590: else
591: --We are into some weird msgType. Just get out.
592: exit;

Line 622: status := sys.dbms_pipe.receive_message(SessionID);

618:
619: SessionID := SessID;
620: fmtSessionId (SessionID);
621:
622: status := sys.dbms_pipe.receive_message(SessionID);
623: if (status = 0) then
624: msgType := sys.dbms_pipe.next_item_type;
625: if (msgType != 0) then
626: if (msgType = 9) then

Line 624: msgType := sys.dbms_pipe.next_item_type;

620: fmtSessionId (SessionID);
621:
622: status := sys.dbms_pipe.receive_message(SessionID);
623: if (status = 0) then
624: msgType := sys.dbms_pipe.next_item_type;
625: if (msgType != 0) then
626: if (msgType = 9) then
627: sys.dbms_pipe.unpack_message(msg);
628: if (msg = DEBUG_CARTX_BYE) then

Line 627: sys.dbms_pipe.unpack_message(msg);

623: if (status = 0) then
624: msgType := sys.dbms_pipe.next_item_type;
625: if (msgType != 0) then
626: if (msgType = 9) then
627: sys.dbms_pipe.unpack_message(msg);
628: if (msg = DEBUG_CARTX_BYE) then
629: status := -1;
630: else
631: num_params := to_number(msg);

Line 634: sys.dbms_pipe.unpack_message(num_params);

630: else
631: num_params := to_number(msg);
632: end if;
633: else
634: sys.dbms_pipe.unpack_message(num_params);
635: end if;
636: end if;
637: end if;
638:

Line 641: if (sys.dbms_pipe.next_item_type != 0) then

637: end if;
638:
639: if (status = 0) then
640: FOR counter IN 1 .. num_params LOOP
641: if (sys.dbms_pipe.next_item_type != 0) then
642: sys.dbms_pipe.unpack_message(param_name(counter));
643: --else
644: -- raise PDE_OUT_OF_SYNC;
645: end if;

Line 642: sys.dbms_pipe.unpack_message(param_name(counter));

638:
639: if (status = 0) then
640: FOR counter IN 1 .. num_params LOOP
641: if (sys.dbms_pipe.next_item_type != 0) then
642: sys.dbms_pipe.unpack_message(param_name(counter));
643: --else
644: -- raise PDE_OUT_OF_SYNC;
645: end if;
646: END LOOP;

Line 649: if (sys.dbms_pipe.Next_Item_Type != 0) then

645: end if;
646: END LOOP;
647:
648: FOR counter IN 1..num_params LOOP
649: if (sys.dbms_pipe.Next_Item_Type != 0) then
650: sys.dbms_pipe.unpack_message(param_val(counter));
651: --else
652: --raise PDE_OUT_OF_SYNC;
653: end if;

Line 650: sys.dbms_pipe.unpack_message(param_val(counter));

646: END LOOP;
647:
648: FOR counter IN 1..num_params LOOP
649: if (sys.dbms_pipe.Next_Item_Type != 0) then
650: sys.dbms_pipe.unpack_message(param_val(counter));
651: --else
652: --raise PDE_OUT_OF_SYNC;
653: end if;
654: END LOOP;

Line 687: locstatus := sys.dbms_pipe.create_pipe(resPipeName, 8192, FALSE);

683: fmtSessionId (SessionID);
684:
685: locstatus := 0;
686: resPipeName := SessionID || 'Res';
687: locstatus := sys.dbms_pipe.create_pipe(resPipeName, 8192, FALSE);
688:
689: if (locstatus = 0) then
690:
691: --if there is an error, poppulate the HTML array with error info

Line 721: sys.dbms_pipe.Pack_Message(sDownloadFile);

717: end if;
718:
719: -- insertmessage('Sending file :' || sDownloadFile
720: -- || ':And its compress code is ' || to_char(nCompress));
721: sys.dbms_pipe.Pack_Message(sDownloadFile);
722: sys.dbms_pipe.Pack_Message(nCompress);
723:
724: locstatus := sys.dbms_pipe.Send_Message(resPipeName, 3600);
725: ack := waitForAck(SessionID, res);

Line 722: sys.dbms_pipe.Pack_Message(nCompress);

718:
719: -- insertmessage('Sending file :' || sDownloadFile
720: -- || ':And its compress code is ' || to_char(nCompress));
721: sys.dbms_pipe.Pack_Message(sDownloadFile);
722: sys.dbms_pipe.Pack_Message(nCompress);
723:
724: locstatus := sys.dbms_pipe.Send_Message(resPipeName, 3600);
725: ack := waitForAck(SessionID, res);
726:

Line 724: locstatus := sys.dbms_pipe.Send_Message(resPipeName, 3600);

720: -- || ':And its compress code is ' || to_char(nCompress));
721: sys.dbms_pipe.Pack_Message(sDownloadFile);
722: sys.dbms_pipe.Pack_Message(nCompress);
723:
724: locstatus := sys.dbms_pipe.Send_Message(resPipeName, 3600);
725: ack := waitForAck(SessionID, res);
726:
727: if (ack < DEBUG_CARTX_SUCCESS) then
728: handleAborts(ack, SessID);

Line 744: sys.dbms_pipe.Pack_Message(numLines);

740: end if;
741:
742: if (numLines > 0) then
743: /* Only if we have message to send, send! */
744: sys.dbms_pipe.Pack_Message(numLines);
745:
746: for counter in 1 .. numLines loop
747: sys.dbms_pipe.Pack_Message(Lines(counter));
748: -- insertmessage('sending msg ' || Lines(counter));

Line 747: sys.dbms_pipe.Pack_Message(Lines(counter));

743: /* Only if we have message to send, send! */
744: sys.dbms_pipe.Pack_Message(numLines);
745:
746: for counter in 1 .. numLines loop
747: sys.dbms_pipe.Pack_Message(Lines(counter));
748: -- insertmessage('sending msg ' || Lines(counter));
749: end loop;
750:
751: locstatus := sys.dbms_pipe.Send_Message(resPipeName, 3600);

Line 751: locstatus := sys.dbms_pipe.Send_Message(resPipeName, 3600);

747: sys.dbms_pipe.Pack_Message(Lines(counter));
748: -- insertmessage('sending msg ' || Lines(counter));
749: end loop;
750:
751: locstatus := sys.dbms_pipe.Send_Message(resPipeName, 3600);
752: ack := waitForAck(SessionID, res);
753:
754: if (ack < DEBUG_CARTX_SUCCESS) then
755: handleAborts(ack, SessID);

Line 763: sys.dbms_pipe.Pack_Message(numLines);

759: end if;
760:
761: if (numLines < 10) then
762: numLines := DEBUG_CARTX_RES_OVER;
763: sys.dbms_pipe.Pack_Message(numLines);
764: locstatus := sys.dbms_pipe.Send_Message(resPipeName, 3600);
765: ack := waitForAck(SessionID, res);
766:
767: if (ack < DEBUG_CARTX_SUCCESS) then

Line 764: locstatus := sys.dbms_pipe.Send_Message(resPipeName, 3600);

760:
761: if (numLines < 10) then
762: numLines := DEBUG_CARTX_RES_OVER;
763: sys.dbms_pipe.Pack_Message(numLines);
764: locstatus := sys.dbms_pipe.Send_Message(resPipeName, 3600);
765: ack := waitForAck(SessionID, res);
766:
767: if (ack < DEBUG_CARTX_SUCCESS) then
768: handleAborts(ack, SessID);

Line 791: status := sys.dbms_pipe.Receive_Message(SessionID);

787: begin
788:
789: SessionID := SessID;
790: fmtSessionId (SessionID);
791: status := sys.dbms_pipe.Receive_Message(SessionID);
792:
793: if (status = 0) then
794: msgType := sys.dbms_pipe.Next_Item_Type;
795: if ( msgType = 9) then

Line 794: msgType := sys.dbms_pipe.Next_Item_Type;

790: fmtSessionId (SessionID);
791: status := sys.dbms_pipe.Receive_Message(SessionID);
792:
793: if (status = 0) then
794: msgType := sys.dbms_pipe.Next_Item_Type;
795: if ( msgType = 9) then
796: sys.dbms_pipe.unpack_message(procname);
797: else
798: DBMS_OUTPUT.PUT_LINE('Weird Message Type ' || to_char(msgType));

Line 796: sys.dbms_pipe.unpack_message(procname);

792:
793: if (status = 0) then
794: msgType := sys.dbms_pipe.Next_Item_Type;
795: if ( msgType = 9) then
796: sys.dbms_pipe.unpack_message(procname);
797: else
798: DBMS_OUTPUT.PUT_LINE('Weird Message Type ' || to_char(msgType));
799: end if;
800: msg := DEBUG_CARTX_SUCCESS;

Line 813: status := sys.dbms_pipe.Receive_Message(SessionID);

809: procedure receiveAStringMessage(SessionID varchar2, status Out integer,
810: msg out varchar2) is
811: msgType integer;
812: begin
813: status := sys.dbms_pipe.Receive_Message(SessionID);
814: if (status = 0) then
815:
816: msgType := sys.dbms_pipe.Next_Item_Type;
817: if ( msgType = 9) then

Line 816: msgType := sys.dbms_pipe.Next_Item_Type;

812: begin
813: status := sys.dbms_pipe.Receive_Message(SessionID);
814: if (status = 0) then
815:
816: msgType := sys.dbms_pipe.Next_Item_Type;
817: if ( msgType = 9) then
818: sys.dbms_pipe.unpack_message(msg);
819: --else
820: --Wrong Message Type.

Line 818: sys.dbms_pipe.unpack_message(msg);

814: if (status = 0) then
815:
816: msgType := sys.dbms_pipe.Next_Item_Type;
817: if ( msgType = 9) then
818: sys.dbms_pipe.unpack_message(msg);
819: --else
820: --Wrong Message Type.
821: end if;
822: --else