DBA Data[Home] [Help]

SYS.JVMRJBCINV dependencies on DBMS_PIPE

Line 25: s integer := dbms_pipe.send_message(pipename);

21:
22:
23: -- private subroutines
24: procedure rjbc_send(pipename VARCHAR2) as
25: s integer := dbms_pipe.send_message(pipename);
26: begin
27: if s <> 0 then
28: raise_application_error(-20000,
29: 'rjbc_send pipe error:' || to_char(s));

Line 34: s integer := dbms_pipe.receive_message(pipename);

30: end if;
31: end;
32:
33: procedure rjbc_receive(pipename VARCHAR2) as
34: s integer := dbms_pipe.receive_message(pipename);
35: begin
36: if s <> 0 then
37: raise_application_error(-20000,
38: 'rjbc_receive pipe error:' || to_char(s));

Line 47: dbms_pipe.reset_buffer;

43: procedure rjbc_ack as
44: begin
45: if not rjbc_client_started then
46: rjbc_receive(rjbc_fromclient);
47: dbms_pipe.reset_buffer;
48: rjbc_client_started := true;
49: end if;
50: end;
51:

Line 71: trash := dbms_pipe.remove_pipe(rjbc_toclient);

67: loop
68: m_sessid := sys.jvmrjbc.init;
69: rjbc_set_pipe_names;
70: begin
71: trash := dbms_pipe.remove_pipe(rjbc_toclient);
72: trash := dbms_pipe.remove_pipe(rjbc_fromclient);
73: trash := dbms_pipe.create_pipe(rjbc_toclient, private => true);
74: trash := dbms_pipe.create_pipe(rjbc_fromclient, private => true);
75: exit;

Line 72: trash := dbms_pipe.remove_pipe(rjbc_fromclient);

68: m_sessid := sys.jvmrjbc.init;
69: rjbc_set_pipe_names;
70: begin
71: trash := dbms_pipe.remove_pipe(rjbc_toclient);
72: trash := dbms_pipe.remove_pipe(rjbc_fromclient);
73: trash := dbms_pipe.create_pipe(rjbc_toclient, private => true);
74: trash := dbms_pipe.create_pipe(rjbc_fromclient, private => true);
75: exit;
76: exception when others then

Line 73: trash := dbms_pipe.create_pipe(rjbc_toclient, private => true);

69: rjbc_set_pipe_names;
70: begin
71: trash := dbms_pipe.remove_pipe(rjbc_toclient);
72: trash := dbms_pipe.remove_pipe(rjbc_fromclient);
73: trash := dbms_pipe.create_pipe(rjbc_toclient, private => true);
74: trash := dbms_pipe.create_pipe(rjbc_fromclient, private => true);
75: exit;
76: exception when others then
77: if sqlcode not in (-23322) then raise; end if;

Line 74: trash := dbms_pipe.create_pipe(rjbc_fromclient, private => true);

70: begin
71: trash := dbms_pipe.remove_pipe(rjbc_toclient);
72: trash := dbms_pipe.remove_pipe(rjbc_fromclient);
73: trash := dbms_pipe.create_pipe(rjbc_toclient, private => true);
74: trash := dbms_pipe.create_pipe(rjbc_fromclient, private => true);
75: exit;
76: exception when others then
77: if sqlcode not in (-23322) then raise; end if;
78: begin

Line 79: trash := dbms_pipe.remove_pipe(rjbc_toclient);

75: exit;
76: exception when others then
77: if sqlcode not in (-23322) then raise; end if;
78: begin
79: trash := dbms_pipe.remove_pipe(rjbc_toclient);
80: exception when others then
81: null;
82: end;
83: begin

Line 84: trash := dbms_pipe.remove_pipe(rjbc_fromclient);

80: exception when others then
81: null;
82: end;
83: begin
84: trash := dbms_pipe.remove_pipe(rjbc_fromclient);
85: exception when others then
86: null;
87: end;
88: sys.jvmrjbc.done(m_sessid);

Line 94: dbms_pipe.purge(rjbc_toclient);

90: end loop;
91: m_flags := flags;
92: rjbc_client_started := false;
93:
94: dbms_pipe.purge(rjbc_toclient);
95: dbms_pipe.purge(rjbc_fromclient);
96: trash :=
97: dbms_java.remove_output_to_sql('___rjbc');
98: trash :=

Line 95: dbms_pipe.purge(rjbc_fromclient);

91: m_flags := flags;
92: rjbc_client_started := false;
93:
94: dbms_pipe.purge(rjbc_toclient);
95: dbms_pipe.purge(rjbc_fromclient);
96: trash :=
97: dbms_java.remove_output_to_sql('___rjbc');
98: trash :=
99: dbms_java.set_output_to_sql('___rjbc',

Line 117: dbms_pipe.pack_message(rtype);

113: status NUMBER;
114: begin
115: rjbc_ack;
116: sys.jvmrjbc.putpath(m_sessid, pathname);
117: dbms_pipe.pack_message(rtype);
118: rjbc_send(rjbc_toclient);
119: rjbc_receive(rjbc_fromclient);
120: dbms_pipe.unpack_message(status);
121: if status = 0 and rtype = 0 then

Line 120: dbms_pipe.unpack_message(status);

116: sys.jvmrjbc.putpath(m_sessid, pathname);
117: dbms_pipe.pack_message(rtype);
118: rjbc_send(rjbc_toclient);
119: rjbc_receive(rjbc_fromclient);
120: dbms_pipe.unpack_message(status);
121: if status = 0 and rtype = 0 then
122: lob := sys.jvmrjbc.getlob(m_sessid);
123: end if;
124: return status;

Line 142: dbms_pipe.pack_message(rtype);

138: status NUMBER;
139: begin
140: rjbc_ack;
141: sys.jvmrjbc.putpath(m_sessid, pathname);
142: dbms_pipe.pack_message(rtype);
143: rjbc_send(rjbc_toclient);
144: rjbc_receive(rjbc_fromclient);
145: dbms_pipe.unpack_message(status);
146: normalized_pathname := sys.jvmrjbc.getpath(m_sessid);

Line 145: dbms_pipe.unpack_message(status);

141: sys.jvmrjbc.putpath(m_sessid, pathname);
142: dbms_pipe.pack_message(rtype);
143: rjbc_send(rjbc_toclient);
144: rjbc_receive(rjbc_fromclient);
145: dbms_pipe.unpack_message(status);
146: normalized_pathname := sys.jvmrjbc.getpath(m_sessid);
147: return status;
148: end;
149:

Line 159: dbms_pipe.pack_message(3);

155: begin
156: rjbc_ack;
157: sys.jvmrjbc.putpath(m_sessid, text);
158: if nl = 0 then
159: dbms_pipe.pack_message(3);
160: else
161: dbms_pipe.pack_message(2);
162: end if;
163: rjbc_send(rjbc_toclient);

Line 161: dbms_pipe.pack_message(2);

157: sys.jvmrjbc.putpath(m_sessid, text);
158: if nl = 0 then
159: dbms_pipe.pack_message(3);
160: else
161: dbms_pipe.pack_message(2);
162: end if;
163: rjbc_send(rjbc_toclient);
164: rjbc_receive(rjbc_fromclient);
165: dbms_pipe.unpack_message(trash);

Line 165: dbms_pipe.unpack_message(trash);

161: dbms_pipe.pack_message(2);
162: end if;
163: rjbc_send(rjbc_toclient);
164: rjbc_receive(rjbc_fromclient);
165: dbms_pipe.unpack_message(trash);
166: end;
167:
168: -- rjbc_done: called from client to shutdown back channel
169: procedure rjbc_done(id VARCHAR2 := null) as

Line 178: dbms_pipe.pack_message(-1);

174: rjbc_set_pipe_names;
175: rjbc_client_started := true;
176: end if;
177: rjbc_ack;
178: dbms_pipe.pack_message(-1);
179: rjbc_send(rjbc_toclient);
180: trash := dbms_pipe.remove_pipe(rjbc_toclient);
181: trash := dbms_pipe.remove_pipe(rjbc_fromclient);
182: sys.jvmrjbc.done(m_sessid);

Line 180: trash := dbms_pipe.remove_pipe(rjbc_toclient);

176: end if;
177: rjbc_ack;
178: dbms_pipe.pack_message(-1);
179: rjbc_send(rjbc_toclient);
180: trash := dbms_pipe.remove_pipe(rjbc_toclient);
181: trash := dbms_pipe.remove_pipe(rjbc_fromclient);
182: sys.jvmrjbc.done(m_sessid);
183: trash :=
184: dbms_java.remove_output_to_sql('___rjbc');

Line 181: trash := dbms_pipe.remove_pipe(rjbc_fromclient);

177: rjbc_ack;
178: dbms_pipe.pack_message(-1);
179: rjbc_send(rjbc_toclient);
180: trash := dbms_pipe.remove_pipe(rjbc_toclient);
181: trash := dbms_pipe.remove_pipe(rjbc_fromclient);
182: sys.jvmrjbc.done(m_sessid);
183: trash :=
184: dbms_java.remove_output_to_sql('___rjbc');
185: m_sessid := null;

Line 220: dbms_pipe.pack_message(status);

216: end if;
217: if rjbc_action = 1 then
218: sys.jvmrjbc.putpath(m_sessid, p);
219: end if;
220: dbms_pipe.pack_message(status);
221: rjbc_send(rjbc_fromclient);
222: rjbc_receive(rjbc_toclient);
223: dbms_pipe.unpack_message(rjbc_action);
224: if rjbc_action <> -1 then

Line 223: dbms_pipe.unpack_message(rjbc_action);

219: end if;
220: dbms_pipe.pack_message(status);
221: rjbc_send(rjbc_fromclient);
222: rjbc_receive(rjbc_toclient);
223: dbms_pipe.unpack_message(rjbc_action);
224: if rjbc_action <> -1 then
225: p := sys.jvmrjbc.getpath(m_sessid);
226: end if;
227: return rjbc_action;