X-Git-Url: https://git.lttng.org/?p=lttng-tools.git;a=blobdiff_plain;f=src%2Fcommon%2Fconsumer.c;h=e66edee2b79609cdcb76c77bca74b04d97b50da9;hp=ca6aeba3ffd7a8748256bd9cae356eeff3e977b6;hb=b63149382964b82d32eb35b179d0b043b657fa26;hpb=9617607b21389440ecd1e02faf46f7ccf38dbd2b

diff --git a/src/common/consumer.c b/src/common/consumer.c
index ca6aeba3f..e66edee2b 100644
--- a/src/common/consumer.c
+++ b/src/common/consumer.c
@@ -1559,7 +1559,7 @@ ssize_t lttng_consumer_on_read_subbuffer_splice(
 				written = ret_splice;
 			}
 			/* Socket operation failed. We consider the relayd dead */
-			if (errno == EBADF) {
+			if (errno == EBADF || errno == EPIPE) {
 				WARN("Remote relayd disconnected. Stopping");
 				relayd_hang_up = 1;
 				goto write_error;
@@ -2754,7 +2754,7 @@ int consumer_data_pending(uint64_t id)
 	ht = consumer_data.stream_list_ht;
 
 	cds_lfht_for_each_entry_duplicate(ht->ht,
-			ht->hash_fct((void *)((unsigned long) id), 0x42UL),
+			ht->hash_fct((void *)((unsigned long) id), lttng_ht_seed),
 			ht->match_fct, (void *)((unsigned long) id),
 			&iter.iter, stream, node_session_id.node) {
 		/* If this call fails, the stream is being used hence data pending. */