systemtap stapvirt tool

I am having a quandary with libvirt and am wondering if someone can shed some light. Systemtap converts a probing and instrumentation language into a kernel module. The module can optionally be run remotely via ssh or libvirt. The libvirt mechanism is not working (not yet sure of timing of regression) The systemtap stap command pipes to a stapvirt command that is the libvirt interface. The remote is running a stapsh tool that receives the requests. The initial commands are sent and received okay (strace output on remote) but never receives the stap kernel module: # local sent option data request [pid 11959] read(3, "option data\n", 4096) = 12 # remote says OK [pid 11959] write(3, "OK\n", 3) = 3 [pid 11959] poll([{fd=3, events=POLLIN}, {fd=0, events=0}, {fd=0, events=0}], 3, -1) = 1 ([{fd=3, revents=POLLIN}]) [pid 11959] --- SIGIO {si_signo=SIGIO, si_code=SI_KERNEL} --- [pid 11959] poll([{fd=3, events=POLLHUP}], 1, 0) = 0 (Timeout) [pid 11959] rt_sigreturn({mask=[]}) = 1 # local sent file ... request to download the module [pid 11959] read(3, "file 926928 stap_1f18b4b54e74602"..., 4096) = 58 # remote opens the module [pid 11959] openat(AT_FDCWD, "stap_1f18b4b54e74602a0a1f0685f2f7333e_1006.ko", O_WRONLY|O_CREAT|O_TRUNC, 0666) = 4 # but never receives it [pid 11959] read(3, "", 4096) = 0 The local sets up callbacks for stdin, stdout, stream: ctxt.stdin_w = virEventAddHandle(STDIN_FILENO, VIR_EVENT_HANDLE_READABLE, stdin_event, &ctxt, NULL); ... ctxt.stdout_w = virEventAddHandle(STDOUT_FILENO, 0, stdout_event, &ctxt, NULL); ... virStreamEventAddCallback(ctxt.st, VIR_STREAM_EVENT_READABLE | VIR_EVENT_HANDLE_WRITABLE, stream_event, &ctxt, NULL) < 0) Then starts an even loop while (!disconnect) { if (virEventRunDefaultImpl() != 0) break; } stream_event is notified for the command requests, but is not notified for the kernel module chunks: stdin_event excerpt: bytes_read = read(fd, ctxt->termbuf + ctxt->termbuf_off, sizeof(ctxt->termbuf) - ctxt->termbuf_off); ... ctxt->termbuf_off += bytes_read; ... if (ctxt->termbuf_off) { // we have stuff to write to the stream virStreamEventUpdateCallback(ctxt->st, VIR_STREAM_EVENT_READABLE | VIR_STREAM_EVENT_WRITABLE); } stream_event excerpt: if ((events & VIR_STREAM_EVENT_READABLE) && (ctxt->stbuf_off < sizeof(ctxt->stbuf))) { int bytes_recv = virStreamRecv(st, ctxt->stbuf + ctxt->stbuf_off, sizeof(ctxt->stbuf) - ctxt->stbuf_off); I notice https://libvirt.org/html/libvirt-libvirt-stream.html has an example using virStreamSend. Is that the preferred way to do the above?