f727e7c1325f863157c57d88ba0a1c3cf65b1478 galt Sat Jan 11 16:19:08 2025 -0800 fix for overflowing packet issue when paraHub restarts but most jobs are run on just one node. diff --git src/parasol/lib/paraMessage.c src/parasol/lib/paraMessage.c index 598fe20..1b368ef 100644 --- src/parasol/lib/paraMessage.c +++ src/parasol/lib/paraMessage.c @@ -51,51 +51,51 @@ freez(pPm); } void pmClear(struct paraMessage *pm) /* Clear out data buffer. */ { pm->size = 0; } void pmSet(struct paraMessage *pm, char *message) /* Set message in data buffer. */ { int len = strlen(message); if (len >= sizeof(pm->data) - 1) { - warn("Message too long in pmSet, ignoring: %.20s...", message); - pmClear(pm); + errAbort("Message too long in pmSet, ignoring: %.20s...", message); + //pmClear(pm); } else { strcpy(pm->data, message); pm->size = len; } } void pmVaPrintf(struct paraMessage *pm, char *format, va_list args) /* Print message into end of data buffer. Warn if it goes * past limit. */ { int sizeLeft = sizeof(pm->data) - pm->size; int sz = vsnprintf(pm->data + pm->size, sizeLeft, format, args); /* note that some version return -1 if too small */ if ((sz < 0) || (sz >= sizeLeft)) { - warn("pmVaPrintf buffer overflow size %d, format %s", sz, format); - pmClear(pm); + errAbort("pmVaPrintf buffer overflow size %d, format %s", sz, format); + //pmClear(pm); } else pm->size += sz; } void pmPrintf(struct paraMessage *pm, char *format, ...) /* Print message into end of data buffer. Warn if it goes * past limit. */ { va_list args; va_start(args, format); pmVaPrintf(pm, format, args); va_end(args); }