133ad161aSMark McLoughlin /* 233ad161aSMark McLoughlin * TAP-Win32 -- A kernel driver to provide virtual tap device functionality 333ad161aSMark McLoughlin * on Windows. Originally derived from the CIPE-Win32 433ad161aSMark McLoughlin * project by Damion K. Wilson, with extensive modifications by 533ad161aSMark McLoughlin * James Yonan. 633ad161aSMark McLoughlin * 733ad161aSMark McLoughlin * All source code which derives from the CIPE-Win32 project is 833ad161aSMark McLoughlin * Copyright (C) Damion K. Wilson, 2003, and is released under the 933ad161aSMark McLoughlin * GPL version 2 (see below). 1033ad161aSMark McLoughlin * 1133ad161aSMark McLoughlin * All other source code is Copyright (C) James Yonan, 2003-2004, 1233ad161aSMark McLoughlin * and is released under the GPL version 2 (see below). 1333ad161aSMark McLoughlin * 1433ad161aSMark McLoughlin * This program is free software; you can redistribute it and/or modify 1533ad161aSMark McLoughlin * it under the terms of the GNU General Public License as published by 1633ad161aSMark McLoughlin * the Free Software Foundation; either version 2 of the License, or 1733ad161aSMark McLoughlin * (at your option) any later version. 1833ad161aSMark McLoughlin * 1933ad161aSMark McLoughlin * This program is distributed in the hope that it will be useful, 2033ad161aSMark McLoughlin * but WITHOUT ANY WARRANTY; without even the implied warranty of 2133ad161aSMark McLoughlin * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the 2233ad161aSMark McLoughlin * GNU General Public License for more details. 2333ad161aSMark McLoughlin * 2433ad161aSMark McLoughlin * You should have received a copy of the GNU General Public License 2533ad161aSMark McLoughlin * along with this program (see the file COPYING included with this 2633ad161aSMark McLoughlin * distribution); if not, see <http://www.gnu.org/licenses/>. 2733ad161aSMark McLoughlin */ 28a8ed73f7SMark McLoughlin 29a8ed73f7SMark McLoughlin #include "net/tap.h" 30a8ed73f7SMark McLoughlin 3133ad161aSMark McLoughlin #include "qemu-common.h" 3233ad161aSMark McLoughlin #include "net.h" 3333ad161aSMark McLoughlin #include "sysemu.h" 3433ad161aSMark McLoughlin #include <stdio.h> 3533ad161aSMark McLoughlin #include <windows.h> 3633ad161aSMark McLoughlin #include <winioctl.h> 3733ad161aSMark McLoughlin 3833ad161aSMark McLoughlin //============= 3933ad161aSMark McLoughlin // TAP IOCTLs 4033ad161aSMark McLoughlin //============= 4133ad161aSMark McLoughlin 4233ad161aSMark McLoughlin #define TAP_CONTROL_CODE(request,method) \ 4333ad161aSMark McLoughlin CTL_CODE (FILE_DEVICE_UNKNOWN, request, method, FILE_ANY_ACCESS) 4433ad161aSMark McLoughlin 4533ad161aSMark McLoughlin #define TAP_IOCTL_GET_MAC TAP_CONTROL_CODE (1, METHOD_BUFFERED) 4633ad161aSMark McLoughlin #define TAP_IOCTL_GET_VERSION TAP_CONTROL_CODE (2, METHOD_BUFFERED) 4733ad161aSMark McLoughlin #define TAP_IOCTL_GET_MTU TAP_CONTROL_CODE (3, METHOD_BUFFERED) 4833ad161aSMark McLoughlin #define TAP_IOCTL_GET_INFO TAP_CONTROL_CODE (4, METHOD_BUFFERED) 4933ad161aSMark McLoughlin #define TAP_IOCTL_CONFIG_POINT_TO_POINT TAP_CONTROL_CODE (5, METHOD_BUFFERED) 5033ad161aSMark McLoughlin #define TAP_IOCTL_SET_MEDIA_STATUS TAP_CONTROL_CODE (6, METHOD_BUFFERED) 5133ad161aSMark McLoughlin #define TAP_IOCTL_CONFIG_DHCP_MASQ TAP_CONTROL_CODE (7, METHOD_BUFFERED) 5233ad161aSMark McLoughlin #define TAP_IOCTL_GET_LOG_LINE TAP_CONTROL_CODE (8, METHOD_BUFFERED) 5333ad161aSMark McLoughlin #define TAP_IOCTL_CONFIG_DHCP_SET_OPT TAP_CONTROL_CODE (9, METHOD_BUFFERED) 5433ad161aSMark McLoughlin 5533ad161aSMark McLoughlin //================= 5633ad161aSMark McLoughlin // Registry keys 5733ad161aSMark McLoughlin //================= 5833ad161aSMark McLoughlin 5933ad161aSMark McLoughlin #define ADAPTER_KEY "SYSTEM\\CurrentControlSet\\Control\\Class\\{4D36E972-E325-11CE-BFC1-08002BE10318}" 6033ad161aSMark McLoughlin 6133ad161aSMark McLoughlin #define NETWORK_CONNECTIONS_KEY "SYSTEM\\CurrentControlSet\\Control\\Network\\{4D36E972-E325-11CE-BFC1-08002BE10318}" 6233ad161aSMark McLoughlin 6333ad161aSMark McLoughlin //====================== 6433ad161aSMark McLoughlin // Filesystem prefixes 6533ad161aSMark McLoughlin //====================== 6633ad161aSMark McLoughlin 6733ad161aSMark McLoughlin #define USERMODEDEVICEDIR "\\\\.\\Global\\" 6833ad161aSMark McLoughlin #define TAPSUFFIX ".tap" 6933ad161aSMark McLoughlin 7033ad161aSMark McLoughlin 7133ad161aSMark McLoughlin //====================== 7233ad161aSMark McLoughlin // Compile time configuration 7333ad161aSMark McLoughlin //====================== 7433ad161aSMark McLoughlin 7533ad161aSMark McLoughlin //#define DEBUG_TAP_WIN32 7633ad161aSMark McLoughlin 7733ad161aSMark McLoughlin #define TUN_ASYNCHRONOUS_WRITES 1 7833ad161aSMark McLoughlin 7933ad161aSMark McLoughlin #define TUN_BUFFER_SIZE 1560 8033ad161aSMark McLoughlin #define TUN_MAX_BUFFER_COUNT 32 8133ad161aSMark McLoughlin 8233ad161aSMark McLoughlin /* 8333ad161aSMark McLoughlin * The data member "buffer" must be the first element in the tun_buffer 8433ad161aSMark McLoughlin * structure. See the function, tap_win32_free_buffer. 8533ad161aSMark McLoughlin */ 8633ad161aSMark McLoughlin typedef struct tun_buffer_s { 8733ad161aSMark McLoughlin unsigned char buffer [TUN_BUFFER_SIZE]; 8833ad161aSMark McLoughlin unsigned long read_size; 8933ad161aSMark McLoughlin struct tun_buffer_s* next; 9033ad161aSMark McLoughlin } tun_buffer_t; 9133ad161aSMark McLoughlin 9233ad161aSMark McLoughlin typedef struct tap_win32_overlapped { 9333ad161aSMark McLoughlin HANDLE handle; 9433ad161aSMark McLoughlin HANDLE read_event; 9533ad161aSMark McLoughlin HANDLE write_event; 9633ad161aSMark McLoughlin HANDLE output_queue_semaphore; 9733ad161aSMark McLoughlin HANDLE free_list_semaphore; 9833ad161aSMark McLoughlin HANDLE tap_semaphore; 9933ad161aSMark McLoughlin CRITICAL_SECTION output_queue_cs; 10033ad161aSMark McLoughlin CRITICAL_SECTION free_list_cs; 10133ad161aSMark McLoughlin OVERLAPPED read_overlapped; 10233ad161aSMark McLoughlin OVERLAPPED write_overlapped; 10333ad161aSMark McLoughlin tun_buffer_t buffers[TUN_MAX_BUFFER_COUNT]; 10433ad161aSMark McLoughlin tun_buffer_t* free_list; 10533ad161aSMark McLoughlin tun_buffer_t* output_queue_front; 10633ad161aSMark McLoughlin tun_buffer_t* output_queue_back; 10733ad161aSMark McLoughlin } tap_win32_overlapped_t; 10833ad161aSMark McLoughlin 10933ad161aSMark McLoughlin static tap_win32_overlapped_t tap_overlapped; 11033ad161aSMark McLoughlin 11133ad161aSMark McLoughlin static tun_buffer_t* get_buffer_from_free_list(tap_win32_overlapped_t* const overlapped) 11233ad161aSMark McLoughlin { 11333ad161aSMark McLoughlin tun_buffer_t* buffer = NULL; 11433ad161aSMark McLoughlin WaitForSingleObject(overlapped->free_list_semaphore, INFINITE); 11533ad161aSMark McLoughlin EnterCriticalSection(&overlapped->free_list_cs); 11633ad161aSMark McLoughlin buffer = overlapped->free_list; 11733ad161aSMark McLoughlin // assert(buffer != NULL); 11833ad161aSMark McLoughlin overlapped->free_list = buffer->next; 11933ad161aSMark McLoughlin LeaveCriticalSection(&overlapped->free_list_cs); 12033ad161aSMark McLoughlin buffer->next = NULL; 12133ad161aSMark McLoughlin return buffer; 12233ad161aSMark McLoughlin } 12333ad161aSMark McLoughlin 12433ad161aSMark McLoughlin static void put_buffer_on_free_list(tap_win32_overlapped_t* const overlapped, tun_buffer_t* const buffer) 12533ad161aSMark McLoughlin { 12633ad161aSMark McLoughlin EnterCriticalSection(&overlapped->free_list_cs); 12733ad161aSMark McLoughlin buffer->next = overlapped->free_list; 12833ad161aSMark McLoughlin overlapped->free_list = buffer; 12933ad161aSMark McLoughlin LeaveCriticalSection(&overlapped->free_list_cs); 13033ad161aSMark McLoughlin ReleaseSemaphore(overlapped->free_list_semaphore, 1, NULL); 13133ad161aSMark McLoughlin } 13233ad161aSMark McLoughlin 13333ad161aSMark McLoughlin static tun_buffer_t* get_buffer_from_output_queue(tap_win32_overlapped_t* const overlapped, const int block) 13433ad161aSMark McLoughlin { 13533ad161aSMark McLoughlin tun_buffer_t* buffer = NULL; 13633ad161aSMark McLoughlin DWORD result, timeout = block ? INFINITE : 0L; 13733ad161aSMark McLoughlin 13833ad161aSMark McLoughlin // Non-blocking call 13933ad161aSMark McLoughlin result = WaitForSingleObject(overlapped->output_queue_semaphore, timeout); 14033ad161aSMark McLoughlin 14133ad161aSMark McLoughlin switch (result) 14233ad161aSMark McLoughlin { 14333ad161aSMark McLoughlin // The semaphore object was signaled. 14433ad161aSMark McLoughlin case WAIT_OBJECT_0: 14533ad161aSMark McLoughlin EnterCriticalSection(&overlapped->output_queue_cs); 14633ad161aSMark McLoughlin 14733ad161aSMark McLoughlin buffer = overlapped->output_queue_front; 14833ad161aSMark McLoughlin overlapped->output_queue_front = buffer->next; 14933ad161aSMark McLoughlin 15033ad161aSMark McLoughlin if(overlapped->output_queue_front == NULL) { 15133ad161aSMark McLoughlin overlapped->output_queue_back = NULL; 15233ad161aSMark McLoughlin } 15333ad161aSMark McLoughlin 15433ad161aSMark McLoughlin LeaveCriticalSection(&overlapped->output_queue_cs); 15533ad161aSMark McLoughlin break; 15633ad161aSMark McLoughlin 15733ad161aSMark McLoughlin // Semaphore was nonsignaled, so a time-out occurred. 15833ad161aSMark McLoughlin case WAIT_TIMEOUT: 15933ad161aSMark McLoughlin // Cannot open another window. 16033ad161aSMark McLoughlin break; 16133ad161aSMark McLoughlin } 16233ad161aSMark McLoughlin 16333ad161aSMark McLoughlin return buffer; 16433ad161aSMark McLoughlin } 16533ad161aSMark McLoughlin 16633ad161aSMark McLoughlin static tun_buffer_t* get_buffer_from_output_queue_immediate (tap_win32_overlapped_t* const overlapped) 16733ad161aSMark McLoughlin { 16833ad161aSMark McLoughlin return get_buffer_from_output_queue(overlapped, 0); 16933ad161aSMark McLoughlin } 17033ad161aSMark McLoughlin 17133ad161aSMark McLoughlin static void put_buffer_on_output_queue(tap_win32_overlapped_t* const overlapped, tun_buffer_t* const buffer) 17233ad161aSMark McLoughlin { 17333ad161aSMark McLoughlin EnterCriticalSection(&overlapped->output_queue_cs); 17433ad161aSMark McLoughlin 17533ad161aSMark McLoughlin if(overlapped->output_queue_front == NULL && overlapped->output_queue_back == NULL) { 17633ad161aSMark McLoughlin overlapped->output_queue_front = overlapped->output_queue_back = buffer; 17733ad161aSMark McLoughlin } else { 17833ad161aSMark McLoughlin buffer->next = NULL; 17933ad161aSMark McLoughlin overlapped->output_queue_back->next = buffer; 18033ad161aSMark McLoughlin overlapped->output_queue_back = buffer; 18133ad161aSMark McLoughlin } 18233ad161aSMark McLoughlin 18333ad161aSMark McLoughlin LeaveCriticalSection(&overlapped->output_queue_cs); 18433ad161aSMark McLoughlin 18533ad161aSMark McLoughlin ReleaseSemaphore(overlapped->output_queue_semaphore, 1, NULL); 18633ad161aSMark McLoughlin } 18733ad161aSMark McLoughlin 18833ad161aSMark McLoughlin 18933ad161aSMark McLoughlin static int is_tap_win32_dev(const char *guid) 19033ad161aSMark McLoughlin { 19133ad161aSMark McLoughlin HKEY netcard_key; 19233ad161aSMark McLoughlin LONG status; 19333ad161aSMark McLoughlin DWORD len; 19433ad161aSMark McLoughlin int i = 0; 19533ad161aSMark McLoughlin 19633ad161aSMark McLoughlin status = RegOpenKeyEx( 19733ad161aSMark McLoughlin HKEY_LOCAL_MACHINE, 19833ad161aSMark McLoughlin ADAPTER_KEY, 19933ad161aSMark McLoughlin 0, 20033ad161aSMark McLoughlin KEY_READ, 20133ad161aSMark McLoughlin &netcard_key); 20233ad161aSMark McLoughlin 20333ad161aSMark McLoughlin if (status != ERROR_SUCCESS) { 20433ad161aSMark McLoughlin return FALSE; 20533ad161aSMark McLoughlin } 20633ad161aSMark McLoughlin 20733ad161aSMark McLoughlin for (;;) { 20833ad161aSMark McLoughlin char enum_name[256]; 20933ad161aSMark McLoughlin char unit_string[256]; 21033ad161aSMark McLoughlin HKEY unit_key; 21133ad161aSMark McLoughlin char component_id_string[] = "ComponentId"; 21233ad161aSMark McLoughlin char component_id[256]; 21333ad161aSMark McLoughlin char net_cfg_instance_id_string[] = "NetCfgInstanceId"; 21433ad161aSMark McLoughlin char net_cfg_instance_id[256]; 21533ad161aSMark McLoughlin DWORD data_type; 21633ad161aSMark McLoughlin 21733ad161aSMark McLoughlin len = sizeof (enum_name); 21833ad161aSMark McLoughlin status = RegEnumKeyEx( 21933ad161aSMark McLoughlin netcard_key, 22033ad161aSMark McLoughlin i, 22133ad161aSMark McLoughlin enum_name, 22233ad161aSMark McLoughlin &len, 22333ad161aSMark McLoughlin NULL, 22433ad161aSMark McLoughlin NULL, 22533ad161aSMark McLoughlin NULL, 22633ad161aSMark McLoughlin NULL); 22733ad161aSMark McLoughlin 22833ad161aSMark McLoughlin if (status == ERROR_NO_MORE_ITEMS) 22933ad161aSMark McLoughlin break; 23033ad161aSMark McLoughlin else if (status != ERROR_SUCCESS) { 23133ad161aSMark McLoughlin return FALSE; 23233ad161aSMark McLoughlin } 23333ad161aSMark McLoughlin 23433ad161aSMark McLoughlin snprintf (unit_string, sizeof(unit_string), "%s\\%s", 23533ad161aSMark McLoughlin ADAPTER_KEY, enum_name); 23633ad161aSMark McLoughlin 23733ad161aSMark McLoughlin status = RegOpenKeyEx( 23833ad161aSMark McLoughlin HKEY_LOCAL_MACHINE, 23933ad161aSMark McLoughlin unit_string, 24033ad161aSMark McLoughlin 0, 24133ad161aSMark McLoughlin KEY_READ, 24233ad161aSMark McLoughlin &unit_key); 24333ad161aSMark McLoughlin 24433ad161aSMark McLoughlin if (status != ERROR_SUCCESS) { 24533ad161aSMark McLoughlin return FALSE; 24633ad161aSMark McLoughlin } else { 24733ad161aSMark McLoughlin len = sizeof (component_id); 24833ad161aSMark McLoughlin status = RegQueryValueEx( 24933ad161aSMark McLoughlin unit_key, 25033ad161aSMark McLoughlin component_id_string, 25133ad161aSMark McLoughlin NULL, 25233ad161aSMark McLoughlin &data_type, 25333ad161aSMark McLoughlin (LPBYTE)component_id, 25433ad161aSMark McLoughlin &len); 25533ad161aSMark McLoughlin 25633ad161aSMark McLoughlin if (!(status != ERROR_SUCCESS || data_type != REG_SZ)) { 25733ad161aSMark McLoughlin len = sizeof (net_cfg_instance_id); 25833ad161aSMark McLoughlin status = RegQueryValueEx( 25933ad161aSMark McLoughlin unit_key, 26033ad161aSMark McLoughlin net_cfg_instance_id_string, 26133ad161aSMark McLoughlin NULL, 26233ad161aSMark McLoughlin &data_type, 26333ad161aSMark McLoughlin (LPBYTE)net_cfg_instance_id, 26433ad161aSMark McLoughlin &len); 26533ad161aSMark McLoughlin 26633ad161aSMark McLoughlin if (status == ERROR_SUCCESS && data_type == REG_SZ) { 26733ad161aSMark McLoughlin if (/* !strcmp (component_id, TAP_COMPONENT_ID) &&*/ 26833ad161aSMark McLoughlin !strcmp (net_cfg_instance_id, guid)) { 26933ad161aSMark McLoughlin RegCloseKey (unit_key); 27033ad161aSMark McLoughlin RegCloseKey (netcard_key); 27133ad161aSMark McLoughlin return TRUE; 27233ad161aSMark McLoughlin } 27333ad161aSMark McLoughlin } 27433ad161aSMark McLoughlin } 27533ad161aSMark McLoughlin RegCloseKey (unit_key); 27633ad161aSMark McLoughlin } 27733ad161aSMark McLoughlin ++i; 27833ad161aSMark McLoughlin } 27933ad161aSMark McLoughlin 28033ad161aSMark McLoughlin RegCloseKey (netcard_key); 28133ad161aSMark McLoughlin return FALSE; 28233ad161aSMark McLoughlin } 28333ad161aSMark McLoughlin 28433ad161aSMark McLoughlin static int get_device_guid( 28533ad161aSMark McLoughlin char *name, 28633ad161aSMark McLoughlin int name_size, 28733ad161aSMark McLoughlin char *actual_name, 28833ad161aSMark McLoughlin int actual_name_size) 28933ad161aSMark McLoughlin { 29033ad161aSMark McLoughlin LONG status; 29133ad161aSMark McLoughlin HKEY control_net_key; 29233ad161aSMark McLoughlin DWORD len; 29333ad161aSMark McLoughlin int i = 0; 29433ad161aSMark McLoughlin int stop = 0; 29533ad161aSMark McLoughlin 29633ad161aSMark McLoughlin status = RegOpenKeyEx( 29733ad161aSMark McLoughlin HKEY_LOCAL_MACHINE, 29833ad161aSMark McLoughlin NETWORK_CONNECTIONS_KEY, 29933ad161aSMark McLoughlin 0, 30033ad161aSMark McLoughlin KEY_READ, 30133ad161aSMark McLoughlin &control_net_key); 30233ad161aSMark McLoughlin 30333ad161aSMark McLoughlin if (status != ERROR_SUCCESS) { 30433ad161aSMark McLoughlin return -1; 30533ad161aSMark McLoughlin } 30633ad161aSMark McLoughlin 30733ad161aSMark McLoughlin while (!stop) 30833ad161aSMark McLoughlin { 30933ad161aSMark McLoughlin char enum_name[256]; 31033ad161aSMark McLoughlin char connection_string[256]; 31133ad161aSMark McLoughlin HKEY connection_key; 31233ad161aSMark McLoughlin char name_data[256]; 31333ad161aSMark McLoughlin DWORD name_type; 31433ad161aSMark McLoughlin const char name_string[] = "Name"; 31533ad161aSMark McLoughlin 31633ad161aSMark McLoughlin len = sizeof (enum_name); 31733ad161aSMark McLoughlin status = RegEnumKeyEx( 31833ad161aSMark McLoughlin control_net_key, 31933ad161aSMark McLoughlin i, 32033ad161aSMark McLoughlin enum_name, 32133ad161aSMark McLoughlin &len, 32233ad161aSMark McLoughlin NULL, 32333ad161aSMark McLoughlin NULL, 32433ad161aSMark McLoughlin NULL, 32533ad161aSMark McLoughlin NULL); 32633ad161aSMark McLoughlin 32733ad161aSMark McLoughlin if (status == ERROR_NO_MORE_ITEMS) 32833ad161aSMark McLoughlin break; 32933ad161aSMark McLoughlin else if (status != ERROR_SUCCESS) { 33033ad161aSMark McLoughlin return -1; 33133ad161aSMark McLoughlin } 33233ad161aSMark McLoughlin 33333ad161aSMark McLoughlin snprintf(connection_string, 33433ad161aSMark McLoughlin sizeof(connection_string), 33533ad161aSMark McLoughlin "%s\\%s\\Connection", 33633ad161aSMark McLoughlin NETWORK_CONNECTIONS_KEY, enum_name); 33733ad161aSMark McLoughlin 33833ad161aSMark McLoughlin status = RegOpenKeyEx( 33933ad161aSMark McLoughlin HKEY_LOCAL_MACHINE, 34033ad161aSMark McLoughlin connection_string, 34133ad161aSMark McLoughlin 0, 34233ad161aSMark McLoughlin KEY_READ, 34333ad161aSMark McLoughlin &connection_key); 34433ad161aSMark McLoughlin 34533ad161aSMark McLoughlin if (status == ERROR_SUCCESS) { 34633ad161aSMark McLoughlin len = sizeof (name_data); 34733ad161aSMark McLoughlin status = RegQueryValueEx( 34833ad161aSMark McLoughlin connection_key, 34933ad161aSMark McLoughlin name_string, 35033ad161aSMark McLoughlin NULL, 35133ad161aSMark McLoughlin &name_type, 35233ad161aSMark McLoughlin (LPBYTE)name_data, 35333ad161aSMark McLoughlin &len); 35433ad161aSMark McLoughlin 35533ad161aSMark McLoughlin if (status != ERROR_SUCCESS || name_type != REG_SZ) { 35633ad161aSMark McLoughlin return -1; 35733ad161aSMark McLoughlin } 35833ad161aSMark McLoughlin else { 35933ad161aSMark McLoughlin if (is_tap_win32_dev(enum_name)) { 36033ad161aSMark McLoughlin snprintf(name, name_size, "%s", enum_name); 36133ad161aSMark McLoughlin if (actual_name) { 36233ad161aSMark McLoughlin if (strcmp(actual_name, "") != 0) { 36333ad161aSMark McLoughlin if (strcmp(name_data, actual_name) != 0) { 36433ad161aSMark McLoughlin RegCloseKey (connection_key); 36533ad161aSMark McLoughlin ++i; 36633ad161aSMark McLoughlin continue; 36733ad161aSMark McLoughlin } 36833ad161aSMark McLoughlin } 36933ad161aSMark McLoughlin else { 37033ad161aSMark McLoughlin snprintf(actual_name, actual_name_size, "%s", name_data); 37133ad161aSMark McLoughlin } 37233ad161aSMark McLoughlin } 37333ad161aSMark McLoughlin stop = 1; 37433ad161aSMark McLoughlin } 37533ad161aSMark McLoughlin } 37633ad161aSMark McLoughlin 37733ad161aSMark McLoughlin RegCloseKey (connection_key); 37833ad161aSMark McLoughlin } 37933ad161aSMark McLoughlin ++i; 38033ad161aSMark McLoughlin } 38133ad161aSMark McLoughlin 38233ad161aSMark McLoughlin RegCloseKey (control_net_key); 38333ad161aSMark McLoughlin 38433ad161aSMark McLoughlin if (stop == 0) 38533ad161aSMark McLoughlin return -1; 38633ad161aSMark McLoughlin 38733ad161aSMark McLoughlin return 0; 38833ad161aSMark McLoughlin } 38933ad161aSMark McLoughlin 39033ad161aSMark McLoughlin static int tap_win32_set_status(HANDLE handle, int status) 39133ad161aSMark McLoughlin { 39233ad161aSMark McLoughlin unsigned long len = 0; 39333ad161aSMark McLoughlin 39433ad161aSMark McLoughlin return DeviceIoControl(handle, TAP_IOCTL_SET_MEDIA_STATUS, 39533ad161aSMark McLoughlin &status, sizeof (status), 39633ad161aSMark McLoughlin &status, sizeof (status), &len, NULL); 39733ad161aSMark McLoughlin } 39833ad161aSMark McLoughlin 39933ad161aSMark McLoughlin static void tap_win32_overlapped_init(tap_win32_overlapped_t* const overlapped, const HANDLE handle) 40033ad161aSMark McLoughlin { 40133ad161aSMark McLoughlin overlapped->handle = handle; 40233ad161aSMark McLoughlin 40333ad161aSMark McLoughlin overlapped->read_event = CreateEvent(NULL, FALSE, FALSE, NULL); 40433ad161aSMark McLoughlin overlapped->write_event = CreateEvent(NULL, FALSE, FALSE, NULL); 40533ad161aSMark McLoughlin 40633ad161aSMark McLoughlin overlapped->read_overlapped.Offset = 0; 40733ad161aSMark McLoughlin overlapped->read_overlapped.OffsetHigh = 0; 40833ad161aSMark McLoughlin overlapped->read_overlapped.hEvent = overlapped->read_event; 40933ad161aSMark McLoughlin 41033ad161aSMark McLoughlin overlapped->write_overlapped.Offset = 0; 41133ad161aSMark McLoughlin overlapped->write_overlapped.OffsetHigh = 0; 41233ad161aSMark McLoughlin overlapped->write_overlapped.hEvent = overlapped->write_event; 41333ad161aSMark McLoughlin 41433ad161aSMark McLoughlin InitializeCriticalSection(&overlapped->output_queue_cs); 41533ad161aSMark McLoughlin InitializeCriticalSection(&overlapped->free_list_cs); 41633ad161aSMark McLoughlin 41733ad161aSMark McLoughlin overlapped->output_queue_semaphore = CreateSemaphore( 41833ad161aSMark McLoughlin NULL, // default security attributes 41933ad161aSMark McLoughlin 0, // initial count 42033ad161aSMark McLoughlin TUN_MAX_BUFFER_COUNT, // maximum count 42133ad161aSMark McLoughlin NULL); // unnamed semaphore 42233ad161aSMark McLoughlin 42333ad161aSMark McLoughlin if(!overlapped->output_queue_semaphore) { 42433ad161aSMark McLoughlin fprintf(stderr, "error creating output queue semaphore!\n"); 42533ad161aSMark McLoughlin } 42633ad161aSMark McLoughlin 42733ad161aSMark McLoughlin overlapped->free_list_semaphore = CreateSemaphore( 42833ad161aSMark McLoughlin NULL, // default security attributes 42933ad161aSMark McLoughlin TUN_MAX_BUFFER_COUNT, // initial count 43033ad161aSMark McLoughlin TUN_MAX_BUFFER_COUNT, // maximum count 43133ad161aSMark McLoughlin NULL); // unnamed semaphore 43233ad161aSMark McLoughlin 43333ad161aSMark McLoughlin if(!overlapped->free_list_semaphore) { 43433ad161aSMark McLoughlin fprintf(stderr, "error creating free list semaphore!\n"); 43533ad161aSMark McLoughlin } 43633ad161aSMark McLoughlin 43733ad161aSMark McLoughlin overlapped->free_list = overlapped->output_queue_front = overlapped->output_queue_back = NULL; 43833ad161aSMark McLoughlin 43933ad161aSMark McLoughlin { 44033ad161aSMark McLoughlin unsigned index; 44133ad161aSMark McLoughlin for(index = 0; index < TUN_MAX_BUFFER_COUNT; index++) { 44233ad161aSMark McLoughlin tun_buffer_t* element = &overlapped->buffers[index]; 44333ad161aSMark McLoughlin element->next = overlapped->free_list; 44433ad161aSMark McLoughlin overlapped->free_list = element; 44533ad161aSMark McLoughlin } 44633ad161aSMark McLoughlin } 44733ad161aSMark McLoughlin /* To count buffers, initially no-signal. */ 44833ad161aSMark McLoughlin overlapped->tap_semaphore = CreateSemaphore(NULL, 0, TUN_MAX_BUFFER_COUNT, NULL); 44933ad161aSMark McLoughlin if(!overlapped->tap_semaphore) 45033ad161aSMark McLoughlin fprintf(stderr, "error creating tap_semaphore.\n"); 45133ad161aSMark McLoughlin } 45233ad161aSMark McLoughlin 45333ad161aSMark McLoughlin static int tap_win32_write(tap_win32_overlapped_t *overlapped, 45433ad161aSMark McLoughlin const void *buffer, unsigned long size) 45533ad161aSMark McLoughlin { 45633ad161aSMark McLoughlin unsigned long write_size; 45733ad161aSMark McLoughlin BOOL result; 45833ad161aSMark McLoughlin DWORD error; 45933ad161aSMark McLoughlin 46033ad161aSMark McLoughlin result = GetOverlappedResult( overlapped->handle, &overlapped->write_overlapped, 46133ad161aSMark McLoughlin &write_size, FALSE); 46233ad161aSMark McLoughlin 46333ad161aSMark McLoughlin if (!result && GetLastError() == ERROR_IO_INCOMPLETE) 46433ad161aSMark McLoughlin WaitForSingleObject(overlapped->write_event, INFINITE); 46533ad161aSMark McLoughlin 46633ad161aSMark McLoughlin result = WriteFile(overlapped->handle, buffer, size, 46733ad161aSMark McLoughlin &write_size, &overlapped->write_overlapped); 46833ad161aSMark McLoughlin 46933ad161aSMark McLoughlin if (!result) { 47033ad161aSMark McLoughlin switch (error = GetLastError()) 47133ad161aSMark McLoughlin { 47233ad161aSMark McLoughlin case ERROR_IO_PENDING: 47333ad161aSMark McLoughlin #ifndef TUN_ASYNCHRONOUS_WRITES 47433ad161aSMark McLoughlin WaitForSingleObject(overlapped->write_event, INFINITE); 47533ad161aSMark McLoughlin #endif 47633ad161aSMark McLoughlin break; 47733ad161aSMark McLoughlin default: 47833ad161aSMark McLoughlin return -1; 47933ad161aSMark McLoughlin } 48033ad161aSMark McLoughlin } 48133ad161aSMark McLoughlin 48233ad161aSMark McLoughlin return 0; 48333ad161aSMark McLoughlin } 48433ad161aSMark McLoughlin 48533ad161aSMark McLoughlin static DWORD WINAPI tap_win32_thread_entry(LPVOID param) 48633ad161aSMark McLoughlin { 48733ad161aSMark McLoughlin tap_win32_overlapped_t *overlapped = (tap_win32_overlapped_t*)param; 48833ad161aSMark McLoughlin unsigned long read_size; 48933ad161aSMark McLoughlin BOOL result; 49033ad161aSMark McLoughlin DWORD dwError; 49133ad161aSMark McLoughlin tun_buffer_t* buffer = get_buffer_from_free_list(overlapped); 49233ad161aSMark McLoughlin 49333ad161aSMark McLoughlin 49433ad161aSMark McLoughlin for (;;) { 49533ad161aSMark McLoughlin result = ReadFile(overlapped->handle, 49633ad161aSMark McLoughlin buffer->buffer, 49733ad161aSMark McLoughlin sizeof(buffer->buffer), 49833ad161aSMark McLoughlin &read_size, 49933ad161aSMark McLoughlin &overlapped->read_overlapped); 50033ad161aSMark McLoughlin if (!result) { 50133ad161aSMark McLoughlin dwError = GetLastError(); 50233ad161aSMark McLoughlin if (dwError == ERROR_IO_PENDING) { 50333ad161aSMark McLoughlin WaitForSingleObject(overlapped->read_event, INFINITE); 50433ad161aSMark McLoughlin result = GetOverlappedResult( overlapped->handle, &overlapped->read_overlapped, 50533ad161aSMark McLoughlin &read_size, FALSE); 50633ad161aSMark McLoughlin if (!result) { 50733ad161aSMark McLoughlin #ifdef DEBUG_TAP_WIN32 50833ad161aSMark McLoughlin LPVOID lpBuffer; 50933ad161aSMark McLoughlin dwError = GetLastError(); 51033ad161aSMark McLoughlin FormatMessage( FORMAT_MESSAGE_ALLOCATE_BUFFER | FORMAT_MESSAGE_FROM_SYSTEM, 51133ad161aSMark McLoughlin NULL, dwError, MAKELANGID(LANG_NEUTRAL, SUBLANG_DEFAULT), 51233ad161aSMark McLoughlin (LPTSTR) & lpBuffer, 0, NULL ); 51333ad161aSMark McLoughlin fprintf(stderr, "Tap-Win32: Error GetOverlappedResult %d - %s\n", dwError, lpBuffer); 51433ad161aSMark McLoughlin LocalFree( lpBuffer ); 51533ad161aSMark McLoughlin #endif 51633ad161aSMark McLoughlin } 51733ad161aSMark McLoughlin } else { 51833ad161aSMark McLoughlin #ifdef DEBUG_TAP_WIN32 51933ad161aSMark McLoughlin LPVOID lpBuffer; 52033ad161aSMark McLoughlin FormatMessage( FORMAT_MESSAGE_ALLOCATE_BUFFER | FORMAT_MESSAGE_FROM_SYSTEM, 52133ad161aSMark McLoughlin NULL, dwError, MAKELANGID(LANG_NEUTRAL, SUBLANG_DEFAULT), 52233ad161aSMark McLoughlin (LPTSTR) & lpBuffer, 0, NULL ); 52333ad161aSMark McLoughlin fprintf(stderr, "Tap-Win32: Error ReadFile %d - %s\n", dwError, lpBuffer); 52433ad161aSMark McLoughlin LocalFree( lpBuffer ); 52533ad161aSMark McLoughlin #endif 52633ad161aSMark McLoughlin } 52733ad161aSMark McLoughlin } 52833ad161aSMark McLoughlin 52933ad161aSMark McLoughlin if(read_size > 0) { 53033ad161aSMark McLoughlin buffer->read_size = read_size; 53133ad161aSMark McLoughlin put_buffer_on_output_queue(overlapped, buffer); 53233ad161aSMark McLoughlin ReleaseSemaphore(overlapped->tap_semaphore, 1, NULL); 53333ad161aSMark McLoughlin buffer = get_buffer_from_free_list(overlapped); 53433ad161aSMark McLoughlin } 53533ad161aSMark McLoughlin } 53633ad161aSMark McLoughlin 53733ad161aSMark McLoughlin return 0; 53833ad161aSMark McLoughlin } 53933ad161aSMark McLoughlin 54033ad161aSMark McLoughlin static int tap_win32_read(tap_win32_overlapped_t *overlapped, 54133ad161aSMark McLoughlin uint8_t **pbuf, int max_size) 54233ad161aSMark McLoughlin { 54333ad161aSMark McLoughlin int size = 0; 54433ad161aSMark McLoughlin 54533ad161aSMark McLoughlin tun_buffer_t* buffer = get_buffer_from_output_queue_immediate(overlapped); 54633ad161aSMark McLoughlin 54733ad161aSMark McLoughlin if(buffer != NULL) { 54833ad161aSMark McLoughlin *pbuf = buffer->buffer; 54933ad161aSMark McLoughlin size = (int)buffer->read_size; 55033ad161aSMark McLoughlin if(size > max_size) { 55133ad161aSMark McLoughlin size = max_size; 55233ad161aSMark McLoughlin } 55333ad161aSMark McLoughlin } 55433ad161aSMark McLoughlin 55533ad161aSMark McLoughlin return size; 55633ad161aSMark McLoughlin } 55733ad161aSMark McLoughlin 55833ad161aSMark McLoughlin static void tap_win32_free_buffer(tap_win32_overlapped_t *overlapped, 55933ad161aSMark McLoughlin uint8_t *pbuf) 56033ad161aSMark McLoughlin { 56133ad161aSMark McLoughlin tun_buffer_t* buffer = (tun_buffer_t*)pbuf; 56233ad161aSMark McLoughlin put_buffer_on_free_list(overlapped, buffer); 56333ad161aSMark McLoughlin } 56433ad161aSMark McLoughlin 56533ad161aSMark McLoughlin static int tap_win32_open(tap_win32_overlapped_t **phandle, 56633ad161aSMark McLoughlin const char *prefered_name) 56733ad161aSMark McLoughlin { 56833ad161aSMark McLoughlin char device_path[256]; 56933ad161aSMark McLoughlin char device_guid[0x100]; 57033ad161aSMark McLoughlin int rc; 57133ad161aSMark McLoughlin HANDLE handle; 57233ad161aSMark McLoughlin BOOL bret; 57333ad161aSMark McLoughlin char name_buffer[0x100] = {0, }; 57433ad161aSMark McLoughlin struct { 57533ad161aSMark McLoughlin unsigned long major; 57633ad161aSMark McLoughlin unsigned long minor; 57733ad161aSMark McLoughlin unsigned long debug; 57833ad161aSMark McLoughlin } version; 57933ad161aSMark McLoughlin DWORD version_len; 58033ad161aSMark McLoughlin DWORD idThread; 58133ad161aSMark McLoughlin HANDLE hThread; 58233ad161aSMark McLoughlin 58333ad161aSMark McLoughlin if (prefered_name != NULL) 58433ad161aSMark McLoughlin snprintf(name_buffer, sizeof(name_buffer), "%s", prefered_name); 58533ad161aSMark McLoughlin 58633ad161aSMark McLoughlin rc = get_device_guid(device_guid, sizeof(device_guid), name_buffer, sizeof(name_buffer)); 58733ad161aSMark McLoughlin if (rc) 58833ad161aSMark McLoughlin return -1; 58933ad161aSMark McLoughlin 59033ad161aSMark McLoughlin snprintf (device_path, sizeof(device_path), "%s%s%s", 59133ad161aSMark McLoughlin USERMODEDEVICEDIR, 59233ad161aSMark McLoughlin device_guid, 59333ad161aSMark McLoughlin TAPSUFFIX); 59433ad161aSMark McLoughlin 59533ad161aSMark McLoughlin handle = CreateFile ( 59633ad161aSMark McLoughlin device_path, 59733ad161aSMark McLoughlin GENERIC_READ | GENERIC_WRITE, 59833ad161aSMark McLoughlin 0, 59933ad161aSMark McLoughlin 0, 60033ad161aSMark McLoughlin OPEN_EXISTING, 60133ad161aSMark McLoughlin FILE_ATTRIBUTE_SYSTEM | FILE_FLAG_OVERLAPPED, 60233ad161aSMark McLoughlin 0 ); 60333ad161aSMark McLoughlin 60433ad161aSMark McLoughlin if (handle == INVALID_HANDLE_VALUE) { 60533ad161aSMark McLoughlin return -1; 60633ad161aSMark McLoughlin } 60733ad161aSMark McLoughlin 60833ad161aSMark McLoughlin bret = DeviceIoControl(handle, TAP_IOCTL_GET_VERSION, 60933ad161aSMark McLoughlin &version, sizeof (version), 61033ad161aSMark McLoughlin &version, sizeof (version), &version_len, NULL); 61133ad161aSMark McLoughlin 61233ad161aSMark McLoughlin if (bret == FALSE) { 61333ad161aSMark McLoughlin CloseHandle(handle); 61433ad161aSMark McLoughlin return -1; 61533ad161aSMark McLoughlin } 61633ad161aSMark McLoughlin 61733ad161aSMark McLoughlin if (!tap_win32_set_status(handle, TRUE)) { 61833ad161aSMark McLoughlin return -1; 61933ad161aSMark McLoughlin } 62033ad161aSMark McLoughlin 62133ad161aSMark McLoughlin tap_win32_overlapped_init(&tap_overlapped, handle); 62233ad161aSMark McLoughlin 62333ad161aSMark McLoughlin *phandle = &tap_overlapped; 62433ad161aSMark McLoughlin 62533ad161aSMark McLoughlin hThread = CreateThread(NULL, 0, tap_win32_thread_entry, 62633ad161aSMark McLoughlin (LPVOID)&tap_overlapped, 0, &idThread); 62733ad161aSMark McLoughlin return 0; 62833ad161aSMark McLoughlin } 62933ad161aSMark McLoughlin 63033ad161aSMark McLoughlin /********************************************/ 63133ad161aSMark McLoughlin 63233ad161aSMark McLoughlin typedef struct TAPState { 633*dca91811SMark McLoughlin VLANClientState nc; 63433ad161aSMark McLoughlin tap_win32_overlapped_t *handle; 63533ad161aSMark McLoughlin } TAPState; 63633ad161aSMark McLoughlin 637*dca91811SMark McLoughlin static void tap_cleanup(VLANClientState *nc) 63833ad161aSMark McLoughlin { 639*dca91811SMark McLoughlin TAPState *s = DO_UPCAST(TAPState, nc, nc); 64033ad161aSMark McLoughlin 64133ad161aSMark McLoughlin qemu_del_wait_object(s->handle->tap_semaphore, NULL, NULL); 64233ad161aSMark McLoughlin 64333ad161aSMark McLoughlin /* FIXME: need to kill thread and close file handle: 64433ad161aSMark McLoughlin tap_win32_close(s); 64533ad161aSMark McLoughlin */ 64633ad161aSMark McLoughlin } 64733ad161aSMark McLoughlin 648*dca91811SMark McLoughlin static ssize_t tap_receive(VLANClientState *nc, const uint8_t *buf, size_t size) 64933ad161aSMark McLoughlin { 650*dca91811SMark McLoughlin TAPState *s = DO_UPCAST(TAPState, nc, nc); 65133ad161aSMark McLoughlin 65233ad161aSMark McLoughlin return tap_win32_write(s->handle, buf, size); 65333ad161aSMark McLoughlin } 65433ad161aSMark McLoughlin 65533ad161aSMark McLoughlin static void tap_win32_send(void *opaque) 65633ad161aSMark McLoughlin { 65733ad161aSMark McLoughlin TAPState *s = opaque; 65833ad161aSMark McLoughlin uint8_t *buf; 65933ad161aSMark McLoughlin int max_size = 4096; 66033ad161aSMark McLoughlin int size; 66133ad161aSMark McLoughlin 66233ad161aSMark McLoughlin size = tap_win32_read(s->handle, &buf, max_size); 66333ad161aSMark McLoughlin if (size > 0) { 664*dca91811SMark McLoughlin qemu_send_packet(&s->nc, buf, size); 66533ad161aSMark McLoughlin tap_win32_free_buffer(s->handle, buf); 66633ad161aSMark McLoughlin } 66733ad161aSMark McLoughlin } 66833ad161aSMark McLoughlin 669*dca91811SMark McLoughlin static NetClientInfo net_tap_win32_info = { 670*dca91811SMark McLoughlin .type = NET_CLIENT_TYPE_TAP, 671*dca91811SMark McLoughlin .size = sizeof(TAPState), 672*dca91811SMark McLoughlin .receive = tap_receive, 673*dca91811SMark McLoughlin .cleanup = tap_cleanup, 674*dca91811SMark McLoughlin }; 675*dca91811SMark McLoughlin 676a8ed73f7SMark McLoughlin static int tap_win32_init(VLANState *vlan, const char *model, 67733ad161aSMark McLoughlin const char *name, const char *ifname) 67833ad161aSMark McLoughlin { 679*dca91811SMark McLoughlin VLANClientState *nc; 68033ad161aSMark McLoughlin TAPState *s; 681*dca91811SMark McLoughlin tap_win32_overlapped_t *handle; 68233ad161aSMark McLoughlin 683*dca91811SMark McLoughlin if (tap_win32_open(&handle, ifname) < 0) { 68433ad161aSMark McLoughlin printf("tap: Could not open '%s'\n", ifname); 68533ad161aSMark McLoughlin return -1; 68633ad161aSMark McLoughlin } 68733ad161aSMark McLoughlin 688*dca91811SMark McLoughlin nc = qemu_new_net_client(&net_tap_win32_info, vlan, NULL, model, name); 68933ad161aSMark McLoughlin 690*dca91811SMark McLoughlin snprintf(s->nc.info_str, sizeof(s->nc.info_str), 69133ad161aSMark McLoughlin "tap: ifname=%s", ifname); 69233ad161aSMark McLoughlin 693*dca91811SMark McLoughlin s = DO_UPCAST(TAPState, nc, nc); 694*dca91811SMark McLoughlin 695*dca91811SMark McLoughlin s->handle = handle; 696*dca91811SMark McLoughlin 69733ad161aSMark McLoughlin qemu_add_wait_object(s->handle->tap_semaphore, tap_win32_send, s); 698*dca91811SMark McLoughlin 69933ad161aSMark McLoughlin return 0; 70033ad161aSMark McLoughlin } 701a8ed73f7SMark McLoughlin 702a8ed73f7SMark McLoughlin int net_init_tap(QemuOpts *opts, Monitor *mon, const char *name, VLANState *vlan) 703a8ed73f7SMark McLoughlin { 704a8ed73f7SMark McLoughlin const char *ifname; 705a8ed73f7SMark McLoughlin 706a8ed73f7SMark McLoughlin ifname = qemu_opt_get(opts, "ifname"); 707a8ed73f7SMark McLoughlin 708a8ed73f7SMark McLoughlin if (!ifname) { 709a8ed73f7SMark McLoughlin qemu_error("tap: no interface name\n"); 710a8ed73f7SMark McLoughlin return -1; 711a8ed73f7SMark McLoughlin } 712a8ed73f7SMark McLoughlin 713a8ed73f7SMark McLoughlin if (tap_win32_init(vlan, "tap", name, ifname) == -1) { 714a8ed73f7SMark McLoughlin return -1; 715a8ed73f7SMark McLoughlin } 716a8ed73f7SMark McLoughlin 717a8ed73f7SMark McLoughlin if (vlan) { 718a8ed73f7SMark McLoughlin vlan->nb_host_devs++; 719a8ed73f7SMark McLoughlin } 720a8ed73f7SMark McLoughlin 721a8ed73f7SMark McLoughlin return 0; 722a8ed73f7SMark McLoughlin } 723a8ed73f7SMark McLoughlin 724a8ed73f7SMark McLoughlin int tap_has_ufo(VLANClientState *vc) 725a8ed73f7SMark McLoughlin { 726a8ed73f7SMark McLoughlin return 0; 727a8ed73f7SMark McLoughlin } 728a8ed73f7SMark McLoughlin 729a8ed73f7SMark McLoughlin int tap_has_vnet_hdr(VLANClientState *vc) 730a8ed73f7SMark McLoughlin { 731a8ed73f7SMark McLoughlin return 0; 732a8ed73f7SMark McLoughlin } 733a8ed73f7SMark McLoughlin 734a8ed73f7SMark McLoughlin void tap_using_vnet_hdr(VLANClientState *vc, int using_vnet_hdr) 735a8ed73f7SMark McLoughlin { 736a8ed73f7SMark McLoughlin } 737a8ed73f7SMark McLoughlin 738a8ed73f7SMark McLoughlin void tap_set_offload(VLANClientState *vc, int csum, int tso4, 739a8ed73f7SMark McLoughlin int tso6, int ecn, int ufo) 740a8ed73f7SMark McLoughlin { 741a8ed73f7SMark McLoughlin } 742