@@ -91,7 +91,7 @@ typedef struct {
9191 int16 count ;
9292 int16 limit ;
9393 int size ;
94- } pipe_desc ;
94+ } orafce_pipe ;
9595
9696typedef struct {
9797 int32 size ;
@@ -130,7 +130,7 @@ typedef struct
130130
131131#endif
132132
133- pipe_desc * pipes ;
133+ orafce_pipe * pipes ;
134134 alert_event * events ;
135135 alert_lock * locks ;
136136 size_t size ;
@@ -143,7 +143,7 @@ typedef struct
143143message_buffer * output_buffer = NULL ;
144144message_buffer * input_buffer = NULL ;
145145
146- pipe_desc * pipes = NULL ;
146+ orafce_pipe * pipes = NULL ;
147147
148148#define NOT_INITIALIZED NULL
149149
@@ -274,7 +274,7 @@ ora_lock_shmem(size_t size, int max_pipes, int max_events, int max_locks, bool r
274274
275275 sh_mem -> size = size - sh_memory_size ;
276276 ora_sinit (sh_mem -> data , size , true);
277- pipes = sh_mem -> pipes = ora_salloc (max_pipes * sizeof (pipe_desc ));
277+ pipes = sh_mem -> pipes = ora_salloc (max_pipes * sizeof (orafce_pipe ));
278278 sid = sh_mem -> sid = 1 ;
279279 for (i = 0 ; i < max_pipes ; i ++ )
280280 pipes [i ].is_valid = false;
@@ -347,11 +347,11 @@ ora_lock_shmem(size_t size, int max_pipes, int max_events, int max_locks, bool r
347347 * can be enhanced access/hash.h
348348 */
349349
350- static pipe_desc *
350+ static orafce_pipe *
351351find_pipe (text * pipe_name , bool * created , bool only_check )
352352{
353353 int i ;
354- pipe_desc * result = NULL ;
354+ orafce_pipe * result = NULL ;
355355
356356 * created = false;
357357 for (i = 0 ; i < MAX_PIPES ; i ++ )
@@ -401,7 +401,7 @@ find_pipe(text* pipe_name, bool* created, bool only_check)
401401
402402
403403static bool
404- new_last (pipe_desc * p , void * ptr )
404+ new_last (orafce_pipe * p , void * ptr )
405405{
406406 queue_item * q , * aux_q ;
407407
@@ -436,7 +436,7 @@ new_last(pipe_desc *p, void *ptr)
436436
437437
438438static void *
439- remove_first (pipe_desc * p , bool * found )
439+ remove_first (orafce_pipe * p , bool * found )
440440{
441441 struct _queue_item * q ;
442442 void * ptr = NULL ;
@@ -468,7 +468,7 @@ remove_first(pipe_desc *p, bool *found)
468468static message_buffer *
469469get_from_pipe (text * pipe_name , bool * found )
470470{
471- pipe_desc * p ;
471+ orafce_pipe * p ;
472472 bool created ;
473473 message_buffer * shm_msg ;
474474 message_buffer * result = NULL ;
@@ -504,7 +504,7 @@ get_from_pipe(text *pipe_name, bool *found)
504504static bool
505505add_to_pipe (text * pipe_name , message_buffer * ptr , int limit , bool limit_is_valid )
506506{
507- pipe_desc * p ;
507+ orafce_pipe * p ;
508508 bool created ;
509509 bool result = false;
510510 message_buffer * sh_ptr ;
@@ -556,7 +556,7 @@ add_to_pipe(text *pipe_name, message_buffer *ptr, int limit, bool limit_is_valid
556556static void
557557remove_pipe (text * pipe_name , bool purge )
558558{
559- pipe_desc * p ;
559+ orafce_pipe * p ;
560560 bool created ;
561561
562562 if (NULL != (p = find_pipe (pipe_name , & created , true)))
@@ -1162,7 +1162,7 @@ dbms_pipe_create_pipe (PG_FUNCTION_ARGS)
11621162 WATCH_PRE (timeout , endtime , cycle );
11631163 if (ora_lock_shmem (SHMEMMSGSZ , MAX_PIPES ,MAX_EVENTS ,MAX_LOCKS ,false))
11641164 {
1165- pipe_desc * p ;
1165+ orafce_pipe * p ;
11661166 if (NULL != (p = find_pipe (pipe_name , & created , false)))
11671167 {
11681168 if (!created )
0 commit comments