+ end_critical_section(S_SUPPMSGMAIN);
+
+ /*
+ * If we can't open the queue, perform the operation synchronously.
+ */
+ if (arcfp == NULL) {
+ for (i = 0; i < nmsg; i++)
+ TDAP_AdjRefCount(msgnum[i], incr);
+ return;
+ }
+
+ the_size = sizeof(struct arcq) * nmsg;
+ new_arcq = malloc(the_size);
+ for (i = 0; i < nmsg; i++) {
+ new_arcq[i].arcq_msgnum = msgnum[i];
+ new_arcq[i].arcq_delta = incr;
+ }
+ rv = 0;
+ offset = 0;
+ while ((rv >= 0) && (offset < the_size))
+ {
+ rv = fwrite(new_arcq + offset, 1, the_size - offset, arcfp);
+ if (rv == -1) {
+ MSG_syslog(LOG_EMERG, "Couldn't write Refcount Queue File %s: %s\n",
+ file_arcq,
+ strerror(errno));
+ }
+ else {
+ offset += rv;
+ }
+ }
+ free(new_arcq);