Commit f44666a1 authored by Thomas Jahns's avatar Thomas Jahns 🤸
Browse files

Rename queuePush to queueAdd.

* The "queue" data structure actually implements a set anyway and will
  be renamed subsequently.
parent c1aa9a53
......@@ -67,7 +67,7 @@ size_t dbuffer_free ( struct dBuffer * );
/* pio_queue.c */
queue_t *queueInit(valDestroyFunction, eqPredicate);
void queueDestroy ( queue_t * );
int queuePush(queue_t *, void *);
int queueAdd(queue_t *, void *);
int queueDelNode(queue_t *, int (*predicate)(void *, void *),
void *data);
void *queueGet(queue_t *q, int (*predicate)(void *, void *), void *data);
......
......@@ -346,7 +346,7 @@ int fowMPINONB ( const char *filename )
queueCheck ( bibAFiledataM, filename );
of = initAFiledataMPINONB ( filename, buffersize );
if ((id = queuePush(bibAFiledataM, of)) < 0 )
if ((id = queueAdd(bibAFiledataM, of)) < 0 )
{
sprintf ( errorString, "filename %s not unique", of->name );
xabort ( errorString );
......
......@@ -327,7 +327,7 @@ void pioWriterAIO(void)
{
queueCheckPA ( bibBFiledataPA, filename );
bfd = initBFiledataPA(filename, buffersize, nProcsCollNode);
if ((id = queuePush(bibBFiledataPA, bfd)) < 0)
if ((id = queueAdd(bibBFiledataPA, bfd)) < 0)
xabort("fileID=%d not unique", rtag->id);
}
else
......
......@@ -239,7 +239,7 @@ void fpgPOSIXFPGUARDSENDRECV ( void )
bfd = ( bFiledataPF * ) initBFiledataPF ( rtag->id,
nProcsCollNode );
if ((iret = queuePush(bibBFiledataPF, bfd)) < 0)
if ((iret = queueAdd(bibBFiledataPF, bfd)) < 0)
{
sprintf ( errorString, "fileID=%d not unique", rtag->id );
xabort ( errorString);
......@@ -577,7 +577,7 @@ int fowPOSIXFPGUARDSENDRECV ( const char *filename )
afd = initAFiledataPF ( filename, buffersize );
if ((id = queuePush(bibAFiledataPF, afd)) < 0)
if ((id = queueAdd(bibAFiledataPF, afd)) < 0)
{
sprintf ( errorString, "filename %s not unique", afd->name );
xabort ( errorString );
......
......@@ -231,7 +231,7 @@ pioWriterStdIO(void)
bfd = initBFiledataP(filename, buffersize, nProcsCollNode,
rtag->id);
if ((id = queuePush(bibBFiledataP, bfd)) < 0)
if ((id = queueAdd(bibBFiledataP, bfd)) < 0)
xabort("fileID=%d not unique", rtag->id);
}
else
......
......@@ -52,7 +52,7 @@ void queueDestroy ( queue_t *q )
}
int
queuePush(queue_t *q, void *v)
queueAdd(queue_t *q, void *v)
{
listElem_t *newListElem_T, *curr;
......@@ -63,7 +63,7 @@ queuePush(queue_t *q, void *v)
if (( newListElem_T = ( listElem_t * ) malloc (sizeof ( listElem_t ))) == NULL )
{
perror ( "pio_queue: queuePush (): Not enough memory" );
perror ( "pio_queue: queueAdd (): Not enough memory" );
/* FIXME: why not abort? */
return 1;
}
......
......@@ -265,7 +265,7 @@ pioSendOpen(const char *filename)
/* init and enqueue remoteFileBuf */
afd = initRemoteFileBuf(filename, buffersize);
if ((id = queuePush(bibRemoteFileBuf, afd)) < 0)
if ((id = queueAdd(bibRemoteFileBuf, afd)) < 0)
xabort("filename %s is not unique", afd->name);
xdebug("filename=%s, init and enqueued remoteFileBuf, return id = %d",
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment