diff options
| author |  John Kohl <jtkohl@mit.edu> | 1987-07-15 12:42:27 +0000 |
|---|---|---|
| committer | John Kohl <jtkohl@mit.edu> | 1987-07-15 12:42:27 +0000 |
| commit | 75f8f31640f298c9b65035c488fed8036f8852bb (patch) | |
| tree | 9438fb8f1916bd1e051de74f95babf5c47534dd0 /server/subscr.c | |
| parent | 74b936c55d63dbab8ff7db35bc21a94237adabb2 (diff) | |
add some paranoia
Diffstat (limited to 'server/subscr.c')
| -rw-r--r-- | server/subscr.c | 41 |
1 files changed, 30 insertions, 11 deletions
diff --git a/server/subscr.c b/server/subscr.c index 4385a0e..4f96a8f 100644 --- a/server/subscr.c +++ b/server/subscr.c @@ -471,6 +471,7 @@ ZClient_t *client; register ZSubscr_t *sub; char buf[512], buf2[512], *lyst[7 * NUM_FIELDS]; int num = 1; + Code_t retval; zdbug((LOG_DEBUG, "send_subs")); (void) sprintf(buf2, "%d",ntohs(client->zct_sin.sin_port)); @@ -481,10 +482,15 @@ ZClient_t *client; sizeof(C_Block)) != ZERR_NONE) lyst[++num] = buf; - bdump_send_list_tcp(SERVACK, bdump_sin.sin_port, ZEPHYR_ADMIN_CLASS, - num > 1 ? "CBLOCK" : "", ADMIN_NEWCLT, myname, "", - lyst, num); - + if ((retval = bdump_send_list_tcp(SERVACK, bdump_sin.sin_port, + ZEPHYR_ADMIN_CLASS, + num > 1 ? "CBLOCK" : "", + ADMIN_NEWCLT, myname, "", + lyst, num)) != ZERR_NONE ) { + syslog(LOG_ERR, "subscr_send_subs newclt: %s", + error_message(retval)); + return; + } if (!client->zct_subs) return; @@ -499,17 +505,30 @@ ZClient_t *client; if (i > 7) { /* we only put 7 in each packet, so we don't run out of room */ - bdump_send_list_tcp(ACKED, bdump_sin.sin_port, - ZEPHYR_CTL_CLASS, "", - CLIENT_SUBSCRIBE, "", "", lyst, - i * NUM_FIELDS); + if ((retval = bdump_send_list_tcp(ACKED, + bdump_sin.sin_port, + ZEPHYR_CTL_CLASS, "", + CLIENT_SUBSCRIBE, "", + "", lyst, + i * NUM_FIELDS)) + != ZERR_NONE) { + syslog(LOG_ERR, "subscr_send_subs subs: %s", + error_message(retval)); + return; + } i = 0; } } if (i) { - bdump_send_list_tcp(ACKED, bdump_sin.sin_port, ZEPHYR_CTL_CLASS, "", - CLIENT_SUBSCRIBE, "", "", lyst, - i * NUM_FIELDS); + if ((retval = bdump_send_list_tcp(ACKED, bdump_sin.sin_port, + ZEPHYR_CTL_CLASS, "", + CLIENT_SUBSCRIBE, "", "", + lyst, i * NUM_FIELDS)) + != ZERR_NONE) { + syslog(LOG_ERR, "subscr_send_subs subs: %s", + error_message(retval)); + return; + } } return; } |