close bool
rdBuff *exchgBufRead
wrBuff *exchgBufWrite
+ rdEvent windows.Handle
+ wrEvent windows.Handle
events chan TUNEvent
errors chan error
forcedMtu int
return nil, err
}
+ rde, err := windows.CreateEvent(nil, 1 /*TRUE*/, 0 /*FALSE*/, nil)
+ if err != nil {
+ wt.DeleteInterface(0)
+ return nil, err
+ }
+ wre, err := windows.CreateEvent(nil, 1 /*TRUE*/, 0 /*FALSE*/, nil)
+ if err != nil {
+ windows.CloseHandle(rde)
+ wt.DeleteInterface(0)
+ return nil, err
+ }
+
return &NativeTun{
wt: wt,
tunName: tunNameUTF16,
tunFile: windows.InvalidHandle,
rdBuff: &exchgBufRead{},
wrBuff: &exchgBufWrite{},
+ rdEvent: rde,
+ wrEvent: wre,
events: make(chan TUNEvent, 10),
errors: make(chan error, 1),
forcedMtu: 1500,
err1 = err2
}
+ windows.CloseHandle(tun.rdEvent)
+ windows.CloseHandle(tun.wrEvent)
+
return err1
}
// Fill queue.
var n uint32
- overlapped := &windows.Overlapped{}
+ overlapped := &windows.Overlapped{HEvent: tun.rdEvent}
err = windows.ReadFile(file, tun.rdBuff.data[:], &n, overlapped)
if err != nil {
if en, ok := err.(syscall.Errno); ok && en == windows.ERROR_IO_PENDING {
// Flush write buffer.
var n uint32
- overlapped := &windows.Overlapped{}
+ overlapped := &windows.Overlapped{HEvent: tun.wrEvent}
err = windows.WriteFile(file, tun.wrBuff.data[:tun.wrBuff.offset], &n, overlapped)
tun.wrBuff.packetNum = 0
tun.wrBuff.offset = 0