diff --git a/src/pipewire/remote.c b/src/pipewire/remote.c
index 6267d90bc..5fb32e19b 100644
--- a/src/pipewire/remote.c
+++ b/src/pipewire/remote.c
@@ -544,8 +544,8 @@ on_rtsocket_condition(void *user_data, int fd, enum spa_io mask)
 	if (mask & SPA_IO_IN) {
 		uint64_t cmd;
 
-		if (read(fd, &cmd, sizeof(uint64_t)) != sizeof(uint64_t))
-			pw_log_warn("proxy %p: read failed %m", proxy);
+		if (read(fd, &cmd, sizeof(uint64_t)) != sizeof(uint64_t) || cmd != 1)
+			pw_log_warn("proxy %p: read %"PRIu64" failed %m", proxy, cmd);
 
 		pw_log_trace("remote %p: process", data->remote);
 		spa_graph_run(node->graph->parent->graph);
diff --git a/src/pipewire/stream.c b/src/pipewire/stream.c
index ca7b7aced..c78cd5266 100644
--- a/src/pipewire/stream.c
+++ b/src/pipewire/stream.c
@@ -627,7 +627,7 @@ static int impl_port_use_buffers(struct spa_node *node, enum spa_direction direc
 static int impl_port_reuse_buffer(struct spa_node *node, uint32_t port_id, uint32_t buffer_id)
 {
 	struct stream *d = SPA_CONTAINER_OF(node, struct stream, impl_node);
-	pw_log_trace("export-source %p: recycle buffer %d", d, buffer_id);
+	pw_log_trace("stream %p: recycle buffer %d", d, buffer_id);
 	if (buffer_id < d->n_buffers)
 		push_queue(d, &d->queued, &d->buffers[buffer_id]);
 	return 0;
@@ -750,7 +750,7 @@ static int handle_connect(struct pw_stream *stream)
 	struct stream *impl = SPA_CONTAINER_OF(stream, struct stream, this);
 
 	pw_log_debug("stream %p: creating node", stream);
-	impl->node = pw_node_new(impl->core, "export-source",
+	impl->node = pw_node_new(impl->core, "PipeWire-stream",
 			pw_properties_copy(stream->properties), 0);
 	impl->impl_node = impl_node;