From c346b62190c59a4dbb5d0390c3eb7f9c04b6f6da Mon Sep 17 00:00:00 2001
From: Asmir Selimovic <asmir@bicomsystems.com>
Date: Tue, 10 Dec 2019 15:37:02 +0100
Subject: [PATCH]  - Option to resume interrupted send

---
 sendrecv.go | 34 ++++++++++++++++++++++++++++++++++
 1 file changed, 34 insertions(+)

diff --git a/sendrecv.go b/sendrecv.go
index e4bcc34..13d0000 100644
--- a/sendrecv.go
+++ b/sendrecv.go
@@ -160,6 +160,40 @@ func (d *Dataset) SendResume(outf *os.File, flags *SendFlags, receiveResumeToken
 	return
 }
 
+func (d *Dataset) SendResume(outf *os.File, flags *SendFlags, receiveResumeToken string) (err error) {
+	if d.Type != DatasetTypeSnapshot {
+		err = fmt.Errorf("Unsupported method on filesystem or bookmark. Use func SendOne() for that purpose.")
+		return
+	}
+
+	var dpath string
+	var pd Dataset
+
+	cflags := to_sendflags_t(flags)
+	defer C.free(unsafe.Pointer(cflags))
+	if dpath, err = d.Path(); err != nil {
+		return
+	}
+	sendparams := strings.Split(dpath, "@")
+	parent := sendparams[0]
+
+	if pd, err = DatasetOpen(parent); err != nil {
+		return
+	}
+	defer pd.Close()
+
+	cReceiveResumeToken := C.CString(receiveResumeToken)
+	defer C.free(unsafe.Pointer(cReceiveResumeToken))
+
+	clerr := C.zfs_send_resume(C.libzfsHandle, cflags, C.int(outf.Fd()), cReceiveResumeToken)
+	if clerr != 0 {
+		err = LastError()
+		fmt.Println(err.Error())
+	}
+
+	return
+}
+
 func (d *Dataset) Send(outf *os.File, flags SendFlags) (err error) {
 	if flags.Replicate {
 		flags.DoAll = true