1 files changed, 61 insertions, 0 deletions
diff --git a/manager/ipc_driver.go b/manager/ipc_driver.go
new file mode 100644
index 00000000..6cb43c38
--- /dev/null
+++ b/manager/ipc_driver.go
@@ -0,0 +1,61 @@
+/* SPDX-License-Identifier: MIT
+ *
+ * Copyright (C) 2019-2022 WireGuard LLC. All Rights Reserved.
+ */
+
+package manager
+
+import (
+	"sync"
+
+	"golang.zx2c4.com/wireguard/windows/driver"
+)
+
+type lockedDriverAdapter struct {
+	*driver.Adapter
+	sync.Mutex
+}
+
+var (
+	driverAdapters     = make(map[string]*lockedDriverAdapter)
+	driverAdaptersLock sync.RWMutex
+)
+
+func findDriverAdapter(tunnelName string) (*lockedDriverAdapter, error) {
+	driverAdaptersLock.RLock()
+	driverAdapter, ok := driverAdapters[tunnelName]
+	if ok {
+		driverAdapter.Lock()
+		driverAdaptersLock.RUnlock()
+		return driverAdapter, nil
+	}
+	driverAdaptersLock.RUnlock()
+	driverAdaptersLock.Lock()
+	defer driverAdaptersLock.Unlock()
+	driverAdapter, ok = driverAdapters[tunnelName]
+	if ok {
+		driverAdapter.Lock()
+		return driverAdapter, nil
+	}
+	driverAdapter = &lockedDriverAdapter{}
+	var err error
+	driverAdapter.Adapter, err = driver.OpenAdapter(tunnelName)
+	if err != nil {
+		return nil, err
+	}
+	driverAdapters[tunnelName] = driverAdapter
+	driverAdapter.Lock()
+	return driverAdapter, nil
+}
+
+func releaseDriverAdapter(tunnelName string) {
+	driverAdaptersLock.Lock()
+	defer driverAdaptersLock.Unlock()
+	driverAdapter, ok := driverAdapters[tunnelName]
+	if !ok {
+		return
+	}
+	driverAdapter.Lock()
+	delete(driverAdapters, tunnelName)
+	driverAdapter.Unlock()
+}