db flush extra labor now returns void
This commit is contained in:
@@ -1927,14 +1927,7 @@ LOCAL int clear_channel_reply ( caHdrLargeArray *mp,
|
||||
freeListFree(rsrvEventFreeList, pevext);
|
||||
}
|
||||
|
||||
status = db_flush_extra_labor_event(client->evuser);
|
||||
if (status) {
|
||||
SEND_LOCK(client);
|
||||
send_err(mp, ECA_INTERNAL, client,
|
||||
"extra labor event didnt flush");
|
||||
SEND_UNLOCK(client);
|
||||
return RSRV_ERROR;
|
||||
}
|
||||
db_flush_extra_labor_event ( client->evuser );
|
||||
|
||||
/*
|
||||
* send delete confirmed message
|
||||
|
||||
+5
-12
@@ -643,22 +643,15 @@ void destroy_tcp_client ( struct client *client )
|
||||
|
||||
if ( client->evuser ) {
|
||||
/*
|
||||
* turn off extra labor callbacks from the event thread
|
||||
*/
|
||||
* turn off extra labor callbacks from the event thread
|
||||
*/
|
||||
status = db_add_extra_labor_event ( client->evuser, NULL, NULL );
|
||||
assert ( ! status );
|
||||
|
||||
/*
|
||||
* wait for extra labor in progress to comple
|
||||
*/
|
||||
status = db_flush_extra_labor_event ( client->evuser );
|
||||
assert ( ! status );
|
||||
|
||||
/*
|
||||
* wait for any put notify in progress to comple
|
||||
*/
|
||||
status = db_flush_extra_labor_event(client->evuser);
|
||||
assert ( ! status );
|
||||
* wait for extra labor in progress to comple
|
||||
*/
|
||||
db_flush_extra_labor_event ( client->evuser );
|
||||
}
|
||||
|
||||
destroyAllChannels ( client, & client->chanList );
|
||||
|
||||
Reference in New Issue
Block a user