lib/zclient: Consolidate error reporting for zclient_read_header
All functions that call zclient_read_header immediately turn around
and check to ensure that the version and marker fields are correct
Move this code into zclient_read_header
Signed-off-by: Donald Sharp <sharpd@cumulusnetworks.com>
diff --git a/bgpd/bgp_nexthop.c b/bgpd/bgp_nexthop.c
index c74beba..20302e3 100644
--- a/bgpd/bgp_nexthop.c
+++ b/bgpd/bgp_nexthop.c
@@ -809,13 +809,7 @@
zlog_err("%s: zserv_read_header() failed", __func__);
return NULL;
}
- if (version != ZSERV_VERSION || marker != ZEBRA_HEADER_MARKER)
- {
- zlog_err("%s: socket %d version mismatch, marker %d, version %d",
- __func__, zlookup->sock, marker, version);
- return NULL;
- }
-
+
/* XXX: not doing anything with raddr */
raddr.s_addr = stream_get_ipv4 (s);
metric = stream_getl (s);
@@ -918,13 +912,7 @@
zlog_err("%s: zserv_read_header() failed", __func__);
return NULL;
}
- if (version != ZSERV_VERSION || marker != ZEBRA_HEADER_MARKER)
- {
- zlog_err("%s: socket %d version mismatch, marker %d, version %d",
- __func__, zlookup->sock, marker, version);
- return NULL;
- }
-
+
/* XXX: not actually doing anything with raddr */
stream_get (&raddr, s, 16);
@@ -1065,13 +1053,7 @@
zlog_err("%s: zserv_read_header() failed", __func__);
return 0;
}
- if (version != ZSERV_VERSION || marker != ZEBRA_HEADER_MARKER)
- {
- zlog_err("%s: socket %d version mismatch, marker %d, version %d",
- __func__, zlookup->sock, marker, version);
- return 0;
- }
-
+
/* XXX: not using addr */
addr.s_addr = stream_get_ipv4 (s);
metric = stream_getl (s);