diff options
| author |   Simon Rozman <simon@rozman.si> | 2019-03-22 12:44:14 +0100 |
|---|---|---|
| committer | Simon Rozman <simon@rozman.si> | 2019-03-22 13:52:51 +0100 |
| commit | a80db5e65e4c202bae184a32120017782549fdac (patch) | |
| tree | e454e6cce4de7642e73ec9e1fdaec88cba80dd6c /tun/tun_windows.go | |
| parent | tun: windows: Fix paused adapter test (diff) | |
| download | wireguard-go-a80db5e65e4c202bae184a32120017782549fdac.tar.xz wireguard-go-a80db5e65e4c202bae184a32120017782549fdac.zip | |
tun: windows: Make writing persistent too
Signed-off-by: Simon Rozman <simon@rozman.si>
Diffstat (limited to 'tun/tun_windows.go')
| -rw-r--r-- | tun/tun_windows.go | 32 |
1 files changed, 17 insertions, 15 deletions
diff --git a/tun/tun_windows.go b/tun/tun_windows.go index ce6ec8c..9888e86 100644 --- a/tun/tun_windows.go +++ b/tun/tun_windows.go @@ -284,24 +284,26 @@ func (tun *NativeTun) Flush() error { return nil } - // Get TUN data pipe. - _, file, err := tun.getTUN() - if err != nil { - return err - } + for { + // Get TUN data pipe. + _, file, err := tun.getTUN() + if err != nil { + return err + } - // Flush write buffer. - _, err = file.Write(tun.wrBuff.data[:tun.wrBuff.offset]) - tun.wrBuff.packetNum = 0 - tun.wrBuff.offset = 0 - if err != nil { - if tun.shouldReopenHandle(err) { - tun.closeTUN() - return nil + // Flush write buffer. + _, err = file.Write(tun.wrBuff.data[:tun.wrBuff.offset]) + tun.wrBuff.packetNum = 0 + tun.wrBuff.offset = 0 + if err != nil { + if tun.shouldReopenHandle(err) { + tun.closeTUN() + continue + } + return err } - return err + return nil } - return nil } func (tun *NativeTun) putTunPacket(buff []byte) error { |