diff options
Diffstat (limited to 'common')
| -rw-r--r-- | common/arch.h | 19 | ||||
| -rw-r--r-- | common/defines.h | 66 | ||||
| -rw-r--r-- | common/file.c | 221 | ||||
| -rw-r--r-- | common/file.h | 28 | ||||
| -rw-r--r-- | common/list.c | 181 | ||||
| -rw-r--r-- | common/list.h | 43 | ||||
| -rw-r--r-- | common/os_calls.c | 558 | ||||
| -rw-r--r-- | common/os_calls.h | 65 | ||||
| -rw-r--r-- | common/parse.h | 5 | ||||
| -rw-r--r-- | common/ssl_calls.c | 161 | ||||
| -rw-r--r-- | common/ssl_calls.h | 55 | ||||
| -rw-r--r-- | common/thread_calls.c | 60 | ||||
| -rw-r--r-- | common/thread_calls.h | 29 | ||||
| -rw-r--r-- | common/xrdp_constants.h | 438 |
14 files changed, 1429 insertions, 500 deletions
diff --git a/common/arch.h b/common/arch.h index c63db197..b8d61381 100644 --- a/common/arch.h +++ b/common/arch.h @@ -18,6 +18,9 @@ */ +#if !defined(ARCH_H) +#define ARCH_H + /* check endianess */ #if __BYTE_ORDER == __LITTLE_ENDIAN #define L_ENDIAN @@ -39,3 +42,19 @@ #define THREAD_RV void* #define THREAD_CC #endif + +#if defined(__BORLANDC__) +#define APP_CC __cdecl +#define DEFAULT_CC __cdecl +#else +#define APP_CC +#define DEFAULT_CC +#endif + +#if defined(_WIN32) +#define EXPORT_CC __declspec(dllexport) +#else +#define EXPORT_CC +#endif + +#endif diff --git a/common/defines.h b/common/defines.h new file mode 100644 index 00000000..77c7d75c --- /dev/null +++ b/common/defines.h @@ -0,0 +1,66 @@ +/* + This program is free software; you can redistribute it and/or modify + it under the terms of the GNU General Public License as published by + the Free Software Foundation; either version 2 of the License, or + (at your option) any later version. + + This program is distributed in the hope that it will be useful, + but WITHOUT ANY WARRANTY; without even the implied warranty of + MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + GNU General Public License for more details. + + You should have received a copy of the GNU General Public License + along with this program; if not, write to the Free Software + Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA. + + xrdp: A Remote Desktop Protocol server. + Copyright (C) Jay Sorg 2004-2005 + + main define/macro file + +*/ + +#if !defined(DEFINES_H) +#define DEFINES_H + +/* check for debug */ +#ifdef XRDP_DEBUG +#define DEBUG(args) g_printf args; +#else +#define DEBUG(args) +#endif +/* other macros */ +#define MIN(x1, x2) ((x1) < (x2) ? (x1) : (x2)) +#define MAX(x1, x2) ((x1) > (x2) ? (x1) : (x2)) +#define HIWORD(in) (((in) & 0xffff0000) >> 16) +#define LOWORD(in) ((in) & 0x0000ffff) +#define MAKELONG(hi, lo) ((((hi) & 0xffff) << 16) | ((lo) & 0xffff)) +#define MAKERECT(r, x, y, cx, cy) \ +{ (r).left = x; (r).top = y; (r).right = (x) + (cx); (r).bottom = (y) + (cy); } +#define ISRECTEMPTY(r) (((r).right <= (r).left) || ((r).bottom <= (r).top)) +#define RECTOFFSET(r, dx, dy) \ +{ (r).left += dx; (r).top += dy; (r).right += dx; (r).bottom += dy; } +#define GETPIXEL8(d, x, y, w) (*(((unsigned char*)d) + ((y) * (w) + (x)))) +#define GETPIXEL16(d, x, y, w) (*(((unsigned short*)d) + ((y) * (w) + (x)))) +#define GETPIXEL32(d, x, y, w) (*(((unsigned int*)d) + ((y) * (w) + (x)))) +#define SETPIXEL8(d, x, y, w, v) \ +(*(((unsigned char*)d) + ((y) * (w) + (x))) = (v)) +#define SETPIXEL16(d, x, y, w, v) \ +(*(((unsigned short*)d) + ((y) * (w) + (x))) = (v)) +#define SETPIXEL32(d, x, y, w, v) \ +(*(((unsigned long*)d) + ((y) * (w) + (x))) = (v)) +#define COLOR8(r, g, b) \ +( \ + (((r) >> 5) << 0) | \ + (((g) >> 5) << 3) | \ + (((b) >> 6) << 6) \ +) +#define COLOR15(r, g, b) ((((r) >> 3) << 10) | (((g) >> 3) << 5) | ((b) >> 3)) +#define COLOR16(r, g, b) ((((r) >> 3) << 11) | (((g) >> 2) << 5) | ((b) >> 3)) +#define COLOR24(r, g, b) ((r) | ((g) << 8) | ((b) << 16)) +/* font macros */ +#define FONT_DATASIZE(f) ((((f)->height * (((f)->width + 7) / 8)) + 3) & ~3); +/* use crc for bitmap cache lookups */ +#define USE_CRC + +#endif diff --git a/common/file.c b/common/file.c new file mode 100644 index 00000000..8bd37cb8 --- /dev/null +++ b/common/file.c @@ -0,0 +1,221 @@ +/* + This program is free software; you can redistribute it and/or modify + it under the terms of the GNU General Public License as published by + the Free Software Foundation; either version 2 of the License, or + (at your option) any later version. + + This program is distributed in the hope that it will be useful, + but WITHOUT ANY WARRANTY; without even the implied warranty of + MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + GNU General Public License for more details. + + You should have received a copy of the GNU General Public License + along with this program; if not, write to the Free Software + Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA. + + xrdp: A Remote Desktop Protocol server. + Copyright (C) Jay Sorg 2004-2005 + + read a config file + +*/ + +#include "arch.h" +#include "os_calls.h" +#include "list.h" +#include "file.h" +#include "parse.h" + +/*****************************************************************************/ +int +file_read_sections(int fd, struct list* names) +{ + struct stream* s; + char text[256]; + char c; + int in_it; + int in_it_index; + int len; + int index; + + g_file_seek(fd, 0); + in_it_index = 0; + in_it = 0; + g_memset(text, 0, 256); + list_clear(names); + make_stream(s); + init_stream(s, 8192); + len = g_file_read(fd, s->data, 8192); + if (len > 0) + { + s->end = s->p + len; + for (index = 0; index < len; index++) + { + in_uint8(s, c); + if (c == '[') + { + in_it = 1; + } + else if (c == ']') + { + list_add_item(names, (long)g_strdup(text)); + in_it = 0; + in_it_index = 0; + g_memset(text, 0, 256); + } + else if (in_it) + { + text[in_it_index] = c; + in_it_index++; + } + } + } + free_stream(s); + return 0; +} + +/*****************************************************************************/ +int +file_read_line(struct stream* s, char* text) +{ + int i; + char c; + char* hold; + + if (!s_check(s)) + { + return 1; + } + hold = s->p; + i = 0; + in_uint8(s, c); + while (c != 10 && c != 13 && s_check(s)) + { + text[i] = c; + i++; + in_uint8(s, c); + } + if (c == 10 || c == 13) + { + while ((c == 10 || c == 13) && s_check(s)) + { + in_uint8(s, c); + } + s->p--; + } + text[i] = 0; + if (text[0] == '[') + { + s->p = hold; + return 1; + } + if (g_strlen(text) > 0) + { + return 0; + } + else + { + return 1; + } +} + +/*****************************************************************************/ +int +file_split_name_value(char* text, char* name, char* value) +{ + int len; + int i; + int value_index; + int name_index; + int on_to; + + value_index = 0; + name_index = 0; + on_to = 0; + name[0] = 0; + value[0] = 0; + len = g_strlen(text); + for (i = 0; i < len; i++) + { + if (text[i] == '=') + { + on_to = 1; + } + else if (on_to) + { + value[value_index] = text[i]; + value_index++; + value[value_index] = 0; + } + else + { + name[name_index] = text[i]; + name_index++; + name[name_index] = 0; + } + } + return 0; +} + +/*****************************************************************************/ +int +file_read_section(int fd, char* section, struct list* names, + struct list* values) +{ + struct stream* s; + char text[256]; + char name[256]; + char value[256]; + char c; + int in_it; + int in_it_index; + int len; + int index; + + g_file_seek(fd, 0); + in_it_index = 0; + in_it = 0; + g_memset(text, 0, 256); + list_clear(names); + list_clear(values); + make_stream(s); + init_stream(s, 8192); + len = g_file_read(fd, s->data, 8192); + if (len > 0) + { + s->end = s->p + len; + for (index = 0; index < len; index++) + { + in_uint8(s, c); + if (c == '[') + { + in_it = 1; + } + else if (c == ']') + { + if (g_strcmp(section, text) == 0) + { + file_read_line(s, text); + while (file_read_line(s, text) == 0) + { + file_split_name_value(text, name, value); + list_add_item(names, (long)g_strdup(name)); + list_add_item(values, (long)g_strdup(value)); + } + free_stream(s); + return 0; + } + in_it = 0; + in_it_index = 0; + g_memset(text, 0, 256); + } + else if (in_it) + { + text[in_it_index] = c; + in_it_index++; + } + } + } + free_stream(s); + return 0; +} diff --git a/common/file.h b/common/file.h new file mode 100644 index 00000000..86ca684f --- /dev/null +++ b/common/file.h @@ -0,0 +1,28 @@ +/* + This program is free software; you can redistribute it and/or modify + it under the terms of the GNU General Public License as published by + the Free Software Foundation; either version 2 of the License, or + (at your option) any later version. + + This program is distributed in the hope that it will be useful, + but WITHOUT ANY WARRANTY; without even the implied warranty of + MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + GNU General Public License for more details. + + You should have received a copy of the GNU General Public License + along with this program; if not, write to the Free Software + Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA. + + xrdp: A Remote Desktop Protocol server. + Copyright (C) Jay Sorg 2004-2005 + +*/ + +#if !defined(FILE_H) +#define FILE_H + +int file_read_sections(int fd, struct list* names); +int file_read_section(int fd, char* section, struct list* names, + struct list* values); + +#endif diff --git a/common/list.c b/common/list.c new file mode 100644 index 00000000..b1201d0a --- /dev/null +++ b/common/list.c @@ -0,0 +1,181 @@ +/* + This program is free software; you can redistribute it and/or modify + it under the terms of the GNU General Public License as published by + the Free Software Foundation; either version 2 of the License, or + (at your option) any later version. + + This program is distributed in the hope that it will be useful, + but WITHOUT ANY WARRANTY; without even the implied warranty of + MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + GNU General Public License for more details. + + You should have received a copy of the GNU General Public License + along with this program; if not, write to the Free Software + Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA. + + xrdp: A Remote Desktop Protocol server. + Copyright (C) Jay Sorg 2004-2005 + + simple list + +*/ + +#include "arch.h" +#include "os_calls.h" +#include "list.h" + +/*****************************************************************************/ +struct list* +list_create(void) +{ + struct list* self; + + self = (struct list*)g_malloc(sizeof(struct list), 1); + self->grow_by = 10; + self->alloc_size = 10; + self->items = (long*)g_malloc(sizeof(long) * 10, 1); + return self; +} + +/*****************************************************************************/ +void +list_delete(struct list* self) +{ + int i; + + if (self == 0) + { + return; + } + if (self->auto_free) + { + for (i = 0; i < self->count; i++) + { + g_free((void*)self->items[i]); + self->items[i] = 0; + } + } + g_free(self->items); + g_free(self); +} + +/*****************************************************************************/ +void +list_add_item(struct list* self, long item) +{ + long* p; + int i; + + if (self->count >= self->alloc_size) + { + i = self->alloc_size; + self->alloc_size += self->grow_by; + p = (long*)g_malloc(sizeof(long) * self->alloc_size, 1); + g_memcpy(p, self->items, sizeof(long) * i); + g_free(self->items); + self->items = p; + } + self->items[self->count] = item; + self->count++; +} + +/*****************************************************************************/ +long +list_get_item(struct list* self, int index) +{ + if (index < 0 || index >= self->count) + { + return 0; + } + return self->items[index]; +} + +/*****************************************************************************/ +void +list_clear(struct list* self) +{ + int i; + + if (self->auto_free) + { + for (i = 0; i < self->count; i++) + { + g_free((void*)self->items[i]); + self->items[i] = 0; + } + } + g_free(self->items); + self->count = 0; + self->grow_by = 10; + self->alloc_size = 10; + self->items = (long*)g_malloc(sizeof(long) * 10, 1); +} + +/*****************************************************************************/ +int +list_index_of(struct list* self, long item) +{ + int i; + + for (i = 0; i < self->count; i++) + { + if (self->items[i] == item) + { + return i; + } + } + return -1; +} + +/*****************************************************************************/ +void +list_remove_item(struct list* self, int index) +{ + int i; + + if (index >= 0 && index < self->count) + { + if (self->auto_free) + { + g_free((void*)self->items[index]); + self->items[index] = 0; + } + for (i = index; i < (self->count - 1); i++) + { + self->items[i] = self->items[i + 1]; + } + self->count--; + } +} + +/*****************************************************************************/ +void +list_insert_item(struct list* self, int index, long item) +{ + long* p; + int i; + + if (index == self->count) + { + list_add_item(self, item); + return; + } + if (index >= 0 && index < self->count) + { + self->count++; + if (self->count > self->alloc_size) + { + i = self->alloc_size; + self->alloc_size += self->grow_by; + p = (long*)g_malloc(sizeof(long) * self->alloc_size, 1); + g_memcpy(p, self->items, sizeof(long) * i); + g_free(self->items); + self->items = p; + } + for (i = (self->count - 2); i >= index; i--) + { + self->items[i + 1] = self->items[i]; + } + self->items[index] = item; + } +} diff --git a/common/list.h b/common/list.h new file mode 100644 index 00000000..c0c7b060 --- /dev/null +++ b/common/list.h @@ -0,0 +1,43 @@ +/* + This program is free software; you can redistribute it and/or modify + it under the terms of the GNU General Public License as published by + the Free Software Foundation; either version 2 of the License, or + (at your option) any later version. + + This program is distributed in the hope that it will be useful, + but WITHOUT ANY WARRANTY; without even the implied warranty of + MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + GNU General Public License for more details. + + You should have received a copy of the GNU General Public License + along with this program; if not, write to the Free Software + Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA. + + xrdp: A Remote Desktop Protocol server. + Copyright (C) Jay Sorg 2004-2005 + +*/ + +#if !defined(LIST_H) +#define LIST_H + +/* list */ +struct list +{ + long* items; + int count; + int alloc_size; + int grow_by; + int auto_free; +}; + +struct list* list_create(void); +void list_delete(struct list* self); +void list_add_item(struct list* self, long item); +long list_get_item(struct list* self, int index); +void list_clear(struct list* self); +int list_index_of(struct list* self, long item); +void list_remove_item(struct list* self, int index); +void list_insert_item(struct list* self, int index, long item); + +#endif diff --git a/common/os_calls.c b/common/os_calls.c index c276b4c0..0d6a4773 100644 --- a/common/os_calls.c +++ b/common/os_calls.c @@ -20,9 +20,6 @@ put all the os / arch define in here you want - if you want pthread calls define USE_PTHREAD in makefile - if you want openssl calls define USE_OPENSSL in makefile - */ #if defined(_WIN32) @@ -49,218 +46,16 @@ #include <stdarg.h> #include <stdio.h> -#if defined(USE_OPENSSL) -#include <openssl/rc4.h> -#include <openssl/md5.h> -#include <openssl/sha.h> -#include <openssl/bn.h> -#endif - -#if defined(USE_PTHREAD) -#include <pthread.h> -#endif - -/*#define MEMLEAK*/ - -#if defined(_WIN32) -static CRITICAL_SECTION g_term_mutex; -static int g_term = 0; -#elif defined(USE_PTHREAD) -static pthread_mutex_t g_term_mutex = PTHREAD_MUTEX_INITIALIZER; -static int g_term = 0; -#endif - -#if defined(MEMLEAK) -static int g_memsize = 0; -static int g_memid = 0; -static struct list* g_memlist = 0; - -/* for memory debugging */ -struct mem -{ - int size; - int id; -}; - -/* list */ -struct list -{ - long* items; - int count; - int alloc_size; - int grow_by; - int auto_free; -}; - -/*****************************************************************************/ -struct list* list_create(void) -{ - struct list* self; - - self = (struct list*)malloc(sizeof(struct list)); - memset(self, 0, sizeof(struct list)); - self->grow_by = 10; - self->alloc_size = 10; - self->items = (long*)malloc(sizeof(long) * 10); - memset(self->items, 0, sizeof(long) * 10); - return self; -} - -/*****************************************************************************/ -void list_delete(struct list* self) -{ - int i; - - if (self == 0) - { - return; - } - if (self->auto_free) - { - for (i = 0; i < self->count; i++) - { - free((void*)self->items[i]); - self->items[i] = 0; - } - } - free(self->items); - free(self); -} - -/*****************************************************************************/ -void list_add_item(struct list* self, long item) -{ - long* p; - int i; - - if (self->count >= self->alloc_size) - { - i = self->alloc_size; - self->alloc_size += self->grow_by; - p = (long*)malloc(sizeof(long) * self->alloc_size); - memset(p, 0, sizeof(long) * self->alloc_size); - memcpy(p, self->items, sizeof(long) * i); - free(self->items); - self->items = p; - } - self->items[self->count] = item; - self->count++; -} - -/*****************************************************************************/ -int list_index_of(struct list* self, long item) -{ - int i; - - for (i = 0; i < self->count; i++) - { - if (self->items[i] == item) - { - return i; - } - } - return -1; -} - -/*****************************************************************************/ -void list_remove_item(struct list* self, int index) -{ - int i; - - if (index >= 0 && index < self->count) - { - if (self->auto_free) - { - free((void*)self->items[index]); - self->items[index] = 0; - } - for (i = index; i < (self->count - 1); i++) - { - self->items[i] = self->items[i + 1]; - } - self->count--; - } -} - -/*****************************************************************************/ -long list_get_item(struct list* self, int index) -{ - if (index < 0 || index >= self->count) - { - return 0; - } - return self->items[index]; -} - -#endif - /* forward declarations */ -void g_printf(char* format, ...); -void g_pipe_sig(int sig_num); - -/*****************************************************************************/ -int g_init_system(void) -{ -#if defined(_WIN32) - WSADATA w; - - WSAStartup(2, &w); - InitializeCriticalSection(&g_term_mutex); -#else - signal(SIGPIPE, g_pipe_sig); -#endif -#if defined(MEMLEAK) - g_memlist = list_create(); -#endif - return 0; -} +void +g_printf(char* format, ...); +void +g_pipe_sig(int sig_num); /*****************************************************************************/ -int g_exit_system(void) +void* +g_malloc(int size, int zero) { -#if defined(_WIN32) - WSACleanup(); - DeleteCriticalSection(&g_term_mutex); -#endif -#if defined(MEMLEAK) - int i; - struct mem* p; - - for (i = 0; i < g_memlist->count; i++) - { - p = (struct mem*)list_get_item(g_memlist, i); - g_printf("leak size %d id %d\n\r", p->size, p->id); - } - g_printf("mem %d\n\r", g_memsize); - list_delete(g_memlist); - g_memlist = 0; -#endif - return 0; -} - -/*****************************************************************************/ -void* g_malloc(int size, int zero) -{ -#if defined(MEMLEAK) - char* rv; - struct mem* p; - - rv = (char*)malloc(size + sizeof(struct mem)); - if (zero) - { - memset(rv, 0, size + sizeof(struct mem)); - } - g_memsize += size; - p = (struct mem*)rv; - p->size = size; - p->id = g_memid; - if (g_memlist != 0) - { - list_add_item(g_memlist, (long)p); - } - g_memid++; - return rv + sizeof(struct mem); -#else char* rv; rv = (char*)malloc(size); @@ -269,37 +64,21 @@ void* g_malloc(int size, int zero) memset(rv, 0, size); } return rv; -#endif } /*****************************************************************************/ -void g_free(void* ptr) +void +g_free(void* ptr) { -#if defined(MEMLEAK) - struct mem* p; - int i; - - if (ptr != 0) - { - p = (struct mem*)(((char*)ptr) - sizeof(struct mem)); - g_memsize -= p->size; - i = list_index_of(g_memlist, (long)p); - if (i >= 0) - { - list_remove_item(g_memlist, i); - } - free(p); - } -#else if (ptr != 0) { free(ptr); } -#endif } /*****************************************************************************/ -void g_printf(char* format, ...) +void +g_printf(char* format, ...) { va_list ap; @@ -309,7 +88,8 @@ void g_printf(char* format, ...) } /*****************************************************************************/ -void g_sprintf(char* dest, char* format, ...) +void +g_sprintf(char* dest, char* format, ...) { va_list ap; @@ -320,7 +100,8 @@ void g_sprintf(char* dest, char* format, ...) /*****************************************************************************/ /* produce a hex dump */ -void g_hexdump(char* p, int len) +void +g_hexdump(char* p, int len) { unsigned char* line; int i; @@ -356,25 +137,29 @@ void g_hexdump(char* p, int len) } /*****************************************************************************/ -void g_memset(void* ptr, int val, int size) +void +g_memset(void* ptr, int val, int size) { memset(ptr, val, size); } /*****************************************************************************/ -void g_memcpy(void* d_ptr, const void* s_ptr, int size) +void +g_memcpy(void* d_ptr, const void* s_ptr, int size) { memcpy(d_ptr, s_ptr, size); } /*****************************************************************************/ -int g_getchar(void) +int +g_getchar(void) { return getchar(); } /*****************************************************************************/ -int g_tcp_set_no_delay(int sck) +int +g_tcp_set_no_delay(int sck) { int i; @@ -384,7 +169,8 @@ int g_tcp_set_no_delay(int sck) } /*****************************************************************************/ -int g_tcp_socket(void) +int +g_tcp_socket(void) { int rv; int i; @@ -396,7 +182,8 @@ int g_tcp_socket(void) } /*****************************************************************************/ -int g_tcp_local_socket(void) +int +g_tcp_local_socket(void) { #if defined(_WIN32) return 0; @@ -406,7 +193,8 @@ int g_tcp_local_socket(void) } /*****************************************************************************/ -void g_tcp_close(int sck) +void +g_tcp_close(int sck) { if (sck == 0) { @@ -421,7 +209,8 @@ void g_tcp_close(int sck) } /*****************************************************************************/ -int g_tcp_connect(int sck, char* address, char* port) +int +g_tcp_connect(int sck, char* address, char* port) { struct sockaddr_in s; struct hostent* h; @@ -451,7 +240,8 @@ int g_tcp_connect(int sck, char* address, char* port) } /*****************************************************************************/ -int g_tcp_set_non_blocking(int sck) +int +g_tcp_set_non_blocking(int sck) { unsigned long i; @@ -467,7 +257,8 @@ int g_tcp_set_non_blocking(int sck) } /*****************************************************************************/ -int g_tcp_bind(int sck, char* port) +int +g_tcp_bind(int sck, char* port) { struct sockaddr_in s; @@ -479,7 +270,8 @@ int g_tcp_bind(int sck, char* port) } /*****************************************************************************/ -int g_tcp_local_bind(int sck, char* port) +int +g_tcp_local_bind(int sck, char* port) { #if defined(_WIN32) return -1; @@ -494,13 +286,15 @@ int g_tcp_local_bind(int sck, char* port) } /*****************************************************************************/ -int g_tcp_listen(int sck) +int +g_tcp_listen(int sck) { return listen(sck, 2); } /*****************************************************************************/ -int g_tcp_accept(int sck) +int +g_tcp_accept(int sck) { struct sockaddr_in s; #if defined(_WIN32) @@ -515,7 +309,8 @@ int g_tcp_accept(int sck) } /*****************************************************************************/ -void g_sleep(int msecs) +void +g_sleep(int msecs) { #if defined(_WIN32) Sleep(msecs); @@ -525,7 +320,8 @@ void g_sleep(int msecs) } /*****************************************************************************/ -int g_tcp_last_error_would_block(int sck) +int +g_tcp_last_error_would_block(int sck) { #if defined(_WIN32) return WSAGetLastError() == WSAEWOULDBLOCK; @@ -535,19 +331,22 @@ int g_tcp_last_error_would_block(int sck) } /*****************************************************************************/ -int g_tcp_recv(int sck, void* ptr, int len, int flags) +int +g_tcp_recv(int sck, void* ptr, int len, int flags) { return recv(sck, ptr, len, flags); } /*****************************************************************************/ -int g_tcp_send(int sck, void* ptr, int len, int flags) +int +g_tcp_send(int sck, void* ptr, int len, int flags) { return send(sck, ptr, len, flags); } /*****************************************************************************/ -int g_tcp_select(int sck1, int sck2) +int +g_tcp_select(int sck1, int sck2) { fd_set rfds; struct timeval time; @@ -587,194 +386,8 @@ int g_tcp_select(int sck1, int sck2) } /*****************************************************************************/ -int g_is_term(void) -{ - int rv; - -#if defined(_WIN32) - EnterCriticalSection(&g_term_mutex); - rv = g_term; - LeaveCriticalSection(&g_term_mutex); -#elif defined (USE_PTHREAD) - pthread_mutex_lock(&g_term_mutex); - rv = g_term; - pthread_mutex_unlock(&g_term_mutex); -#else - rv = 1; -#endif - return rv; -} - -/*****************************************************************************/ -void g_set_term(int in_val) -{ -#if defined(_WIN32) - EnterCriticalSection(&g_term_mutex); - g_term = in_val; - LeaveCriticalSection(&g_term_mutex); -#elif defined(USE_PTHREAD) - pthread_mutex_lock(&g_term_mutex); - g_term = in_val; - pthread_mutex_unlock(&g_term_mutex); -#endif -} - -/*****************************************************************************/ -#if defined(_WIN32) -int g_thread_create(unsigned long (__stdcall * start_routine)(void*), void* arg) -{ - DWORD thread; - - return !CreateThread(0, 0, start_routine, arg, 0, &thread); -} -#elif defined(USE_PTHREAD) -int g_thread_create(void* (* start_routine)(void*), void* arg) -{ - pthread_t thread; - int rv; - - rv = pthread_create(&thread, 0, start_routine, arg); - pthread_detach(thread); - return rv; -} -#endif - -/*****************************************************************************/ -int g_get_threadid(void) -{ -#if defined(_WIN32) - return 0; -#elif defined(USE_PTHREAD) - return pthread_self(); -#else - return 0; -#endif -} - -#if defined(USE_OPENSSL) - -/* rc4 stuff */ - -/*****************************************************************************/ -void* g_rc4_info_create(void) -{ - return g_malloc(sizeof(RC4_KEY), 1);; -} - -/*****************************************************************************/ -void g_rc4_info_delete(void* rc4_info) -{ - g_free(rc4_info); -} - -/*****************************************************************************/ -void g_rc4_set_key(void* rc4_info, char* key, int len) -{ - RC4_set_key((RC4_KEY*)rc4_info, len, (unsigned char*)key); -} - -/*****************************************************************************/ -void g_rc4_crypt(void* rc4_info, char* data, int len) -{ - RC4((RC4_KEY*)rc4_info, len, (unsigned char*)data, (unsigned char*)data); -} - -/* sha1 stuff */ - -/*****************************************************************************/ -void* g_sha1_info_create(void) -{ - return g_malloc(sizeof(SHA_CTX), 1); -} - -/*****************************************************************************/ -void g_sha1_info_delete(void* sha1_info) -{ - g_free(sha1_info); -} - -/*****************************************************************************/ -void g_sha1_clear(void* sha1_info) -{ - SHA1_Init((SHA_CTX*)sha1_info); -} - -/*****************************************************************************/ -void g_sha1_transform(void* sha1_info, char* data, int len) -{ - SHA1_Update((SHA_CTX*)sha1_info, data, len); -} - -/*****************************************************************************/ -void g_sha1_complete(void* sha1_info, char* data) -{ - SHA1_Final((unsigned char*)data, (SHA_CTX*)sha1_info); -} - -/* md5 stuff */ - -/*****************************************************************************/ -void* g_md5_info_create(void) -{ - return g_malloc(sizeof(MD5_CTX), 1); -} - -/*****************************************************************************/ -void g_md5_info_delete(void* md5_info) -{ - g_free(md5_info); -} - -/*****************************************************************************/ -void g_md5_clear(void* md5_info) -{ - MD5_Init((MD5_CTX*)md5_info); -} - -/*****************************************************************************/ -void g_md5_transform(void* md5_info, char* data, int len) -{ - MD5_Update((MD5_CTX*)md5_info, data, len); -} - -/*****************************************************************************/ -void g_md5_complete(void* md5_info, char* data) -{ - MD5_Final((unsigned char*)data, (MD5_CTX*)md5_info); -} - -/*****************************************************************************/ -int g_mod_exp(char* out, char* in, char* mod, char* exp) -{ - BN_CTX* ctx; - BIGNUM lmod; - BIGNUM lexp; - BIGNUM lin; - BIGNUM lout; - int rv; - - ctx = BN_CTX_new(); - BN_init(&lmod); - BN_init(&lexp); - BN_init(&lin); - BN_init(&lout); - BN_bin2bn((unsigned char*)mod, 64, &lmod); - BN_bin2bn((unsigned char*)exp, 64, &lexp); - BN_bin2bn((unsigned char*)in, 64, &lin); - BN_mod_exp(&lout, &lin, &lexp, &lmod, ctx); - rv = BN_bn2bin(&lout, (unsigned char*)out); - BN_free(&lin); - BN_free(&lout); - BN_free(&lexp); - BN_free(&lmod); - BN_CTX_free(ctx); - return rv; -} - -#endif - -/*****************************************************************************/ -void g_random(char* data, int len) +void +g_random(char* data, int len) { #if defined(_WIN32) memset(data, 0x44, len); @@ -796,19 +409,22 @@ void g_random(char* data, int len) } /*****************************************************************************/ -int g_abs(int i) +int +g_abs(int i) { return abs(i); } /*****************************************************************************/ -int g_memcmp(void* s1, void* s2, int len) +int +g_memcmp(void* s1, void* s2, int len) { return memcmp(s1, s2, len); } /*****************************************************************************/ -int g_file_open(char* file_name) +int +g_file_open(char* file_name) { #if defined(_WIN32) return (int)CreateFile(file_name, GENERIC_READ | GENERIC_WRITE, @@ -820,7 +436,8 @@ int g_file_open(char* file_name) } /*****************************************************************************/ -int g_file_close(int fd) +int +g_file_close(int fd) { #if defined(_WIN32) CloseHandle((HANDLE)fd); @@ -832,7 +449,8 @@ int g_file_close(int fd) /*****************************************************************************/ /* read from file*/ -int g_file_read(int fd, char* ptr, int len) +int +g_file_read(int fd, char* ptr, int len) { #if defined(_WIN32) if (ReadFile((HANDLE)fd, (LPVOID)ptr, (DWORD)len, (LPDWORD)&len, 0)) @@ -850,7 +468,8 @@ int g_file_read(int fd, char* ptr, int len) /*****************************************************************************/ /* write to file */ -int g_file_write(int fd, char* ptr, int len) +int +g_file_write(int fd, char* ptr, int len) { #if defined(_WIN32) if (WriteFile((HANDLE)fd, (LPVOID)ptr, (DWORD)len, (LPDWORD)&len, 0)) @@ -868,7 +487,8 @@ int g_file_write(int fd, char* ptr, int len) /*****************************************************************************/ /* move file pointer */ -int g_file_seek(int fd, int offset) +int +g_file_seek(int fd, int offset) { #if defined(_WIN32) return SetFilePointer((HANDLE)fd, offset, 0, FILE_BEGIN); @@ -880,7 +500,8 @@ int g_file_seek(int fd, int offset) /*****************************************************************************/ /* do a write lock on a file */ /* return boolean */ -int g_file_lock(int fd, int start, int len) +int +g_file_lock(int fd, int start, int len) { #if defined(_WIN32) return LockFile((HANDLE)fd, start, 0, len, 0); @@ -900,7 +521,8 @@ int g_file_lock(int fd, int start, int len) } /*****************************************************************************/ -int g_strlen(char* text) +int +g_strlen(char* text) { if (text == 0) { @@ -910,7 +532,8 @@ int g_strlen(char* text) } /*****************************************************************************/ -char* g_strcpy(char* dest, char* src) +char* +g_strcpy(char* dest, char* src) { if (src == 0 && dest != 0) { @@ -925,7 +548,8 @@ char* g_strcpy(char* dest, char* src) } /*****************************************************************************/ -char* g_strncpy(char* dest, char* src, int len) +char* +g_strncpy(char* dest, char* src, int len) { char* rv; @@ -944,7 +568,8 @@ char* g_strncpy(char* dest, char* src, int len) } /*****************************************************************************/ -char* g_strcat(char* dest, char* src) +char* +g_strcat(char* dest, char* src) { if (dest == 0 || src == 0) { @@ -954,7 +579,8 @@ char* g_strcat(char* dest, char* src) } /*****************************************************************************/ -char* g_strdup(char* in) +char* +g_strdup(char* in) { int len; char* p; @@ -970,19 +596,22 @@ char* g_strdup(char* in) } /*****************************************************************************/ -int g_strcmp(char* c1, char* c2) +int +g_strcmp(char* c1, char* c2) { return strcmp(c1, c2); } /*****************************************************************************/ -int g_strncmp(char* c1, char* c2, int len) +int +g_strncmp(char* c1, char* c2, int len) { return strncmp(c1, c2, len); } /*****************************************************************************/ -long g_load_library(char* in) +long +g_load_library(char* in) { #if defined(_WIN32) return 0; @@ -992,7 +621,8 @@ long g_load_library(char* in) } /*****************************************************************************/ -int g_free_library(long lib) +int +g_free_library(long lib) { if (lib == 0) { @@ -1007,7 +637,8 @@ int g_free_library(long lib) /*****************************************************************************/ /* returns NULL if not found */ -void* g_get_proc_address(long lib, char* name) +void* +g_get_proc_address(long lib, char* name) { if (lib == 0) { @@ -1021,7 +652,8 @@ void* g_get_proc_address(long lib, char* name) } /*****************************************************************************/ -int g_system(char* aexec) +int +g_system(char* aexec) { #if defined(_WIN32) return 0; @@ -1031,17 +663,11 @@ int g_system(char* aexec) } /*****************************************************************************/ -void g_signal(int sig_num, void (*func)(int)) +void +g_signal(int sig_num, void (*func)(int)) { #if defined(_WIN32) #else signal(sig_num, func); #endif } - -/*****************************************************************************/ -void g_pipe_sig(int sig_num) -{ - /* do nothing */ - g_printf("got SIGPIPE(%d)\n\r", sig_num); -} diff --git a/common/os_calls.h b/common/os_calls.h index 7bc6bd89..81f90b66 100644 --- a/common/os_calls.h +++ b/common/os_calls.h @@ -20,23 +20,37 @@ */ +#if !defined(OS_CALLS_H) +#define OS_CALLS_H + int g_init_system(void); int g_exit_system(void); -void g_printf(char *format, ...); -void g_sprintf(char* dest, char* format, ...); -void g_hexdump(char* p, int len); -void* g_malloc(int size, int zero); -void* g_malloc1(int size, int zero); -void g_free(void* ptr); -void g_free1(void* ptr); -void g_memset(void* ptr, int val, int size); -void g_memcpy(void* d_ptr, const void* s_ptr, int size); -int g_getchar(void); -int g_tcp_set_no_delay(int sck); -int g_tcp_socket(void); -int g_tcp_local_socket(void); -void g_tcp_close(int sck); -int g_tcp_connect(int sck, char* address, char* port); +void +g_printf(char *format, ...); +void +g_sprintf(char* dest, char* format, ...); +void +g_hexdump(char* p, int len); +void* +g_malloc(int size, int zero); +void +g_free(void* ptr); +void +g_memset(void* ptr, int val, int size); +void +g_memcpy(void* d_ptr, const void* s_ptr, int size); +int +g_getchar(void); +int +g_tcp_set_no_delay(int sck); +int +g_tcp_socket(void); +int +g_tcp_local_socket(void); +void +g_tcp_close(int sck); +int +g_tcp_connect(int sck, char* address, char* port); int g_tcp_force_send(int sck, char* data, int len); int g_tcp_force_recv(int sck, char* data, int len); int g_tcp_set_non_blocking(int sck); @@ -48,26 +62,7 @@ int g_tcp_recv(int sck, void* ptr, int len, int flags); int g_tcp_send(int sck, void* ptr, int len, int flags); int g_tcp_last_error_would_block(int sck); int g_tcp_select(int sck1, int sck2); -int g_is_term(void); -void g_set_term(int in_val); void g_sleep(int msecs); -int g_thread_create(THREAD_RV (THREAD_CC * start_routine)(void*), void* arg); -int g_get_threadid(void); -void* g_rc4_info_create(void); -void g_rc4_info_delete(void* rc4_info); -void g_rc4_set_key(void* rc4_info, char* key, int len); -void g_rc4_crypt(void* rc4_info, char* data, int len); -void* g_sha1_info_create(void); -void g_sha1_info_delete(void* sha1_info); -void g_sha1_clear(void* sha1_info); -void g_sha1_transform(void* sha1_info, char* data, int len); -void g_sha1_complete(void* sha1_info, char* data); -void* g_md5_info_create(void); -void g_md5_info_delete(void* md5_info); -void g_md5_clear(void* md5_info); -void g_md5_transform(void* md5_info, char* data, int len); -void g_md5_complete(void* md5_info, char* data); -int g_mod_exp(char* out, char* in, char* mod, char* exp); void g_random(char* data, int len); int g_abs(int i); int g_memcmp(void* s1, void* s2, int len); @@ -89,3 +84,5 @@ int g_free_library(long lib); void* g_get_proc_address(long lib, char* name); int g_system(char* aexec); void g_signal(int sig_num, void (*func)(int)); + +#endif diff --git a/common/parse.h b/common/parse.h index e65f4c99..3c8b3fe6 100644 --- a/common/parse.h +++ b/common/parse.h @@ -21,6 +21,9 @@ /* modified for xrdp */ /* this is a super fast stream method, you bet */ +#if !defined(PARSE_H) +#define PARSE_H + #if defined(L_ENDIAN) #elif defined(B_ENDIAN) #else @@ -299,3 +302,5 @@ struct stream g_memset((s)->p, 0, (n)); \ (s)->p += (n); \ } + +#endif diff --git a/common/ssl_calls.c b/common/ssl_calls.c new file mode 100644 index 00000000..7840eeb2 --- /dev/null +++ b/common/ssl_calls.c @@ -0,0 +1,161 @@ +/* + This program is free software; you can redistribute it and/or modify + it under the terms of the GNU General Public License as published by + the Free Software Foundation; either version 2 of the License, or + (at your option) any later version. + + This program is distributed in the hope that it will be useful, + but WITHOUT ANY WARRANTY; without even the implied warranty of + MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + GNU General Public License for more details. + + You should have received a copy of the GNU General Public License + along with this program; if not, write to the Free Software + Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA. + + xrdp: A Remote Desktop Protocol server. + Copyright (C) Jay Sorg 2004-2005 + + ssl calls + +*/ + +#include "os_calls.h" + +#include <openssl/rc4.h> +#include <openssl/md5.h> +#include <openssl/sha.h> +#include <openssl/bn.h> + +/* rc4 stuff */ + +/*****************************************************************************/ +void* +g_rc4_info_create(void) +{ + return g_malloc(sizeof(RC4_KEY), 1);; +} + +/*****************************************************************************/ +void +g_rc4_info_delete(void* rc4_info) +{ + g_free(rc4_info); +} + +/*****************************************************************************/ +void +g_rc4_set_key(void* rc4_info, char* key, int len) +{ + RC4_set_key((RC4_KEY*)rc4_info, len, (unsigned char*)key); +} + +/*****************************************************************************/ +void +g_rc4_crypt(void* rc4_info, char* data, int len) +{ + RC4((RC4_KEY*)rc4_info, len, (unsigned char*)data, (unsigned char*)data); +} + +/* sha1 stuff */ + +/*****************************************************************************/ +void* +g_sha1_info_create(void) +{ + return g_malloc(sizeof(SHA_CTX), 1); +} + +/*****************************************************************************/ +void +g_sha1_info_delete(void* sha1_info) +{ + g_free(sha1_info); +} + +/*****************************************************************************/ +void +g_sha1_clear(void* sha1_info) +{ + SHA1_Init((SHA_CTX*)sha1_info); +} + +/*****************************************************************************/ +void +g_sha1_transform(void* sha1_info, char* data, int len) +{ + SHA1_Update((SHA_CTX*)sha1_info, data, len); +} + +/*****************************************************************************/ +void +g_sha1_complete(void* sha1_info, char* data) +{ + SHA1_Final((unsigned char*)data, (SHA_CTX*)sha1_info); +} + +/* md5 stuff */ + +/*****************************************************************************/ +void* +g_md5_info_create(void) +{ + return g_malloc(sizeof(MD5_CTX), 1); +} + +/*****************************************************************************/ +void +g_md5_info_delete(void* md5_info) +{ + g_free(md5_info); +} + +/*****************************************************************************/ +void +g_md5_clear(void* md5_info) +{ + MD5_Init((MD5_CTX*)md5_info); +} + +/*****************************************************************************/ +void +g_md5_transform(void* md5_info, char* data, int len) +{ + MD5_Update((MD5_CTX*)md5_info, data, len); +} + +/*****************************************************************************/ +void +g_md5_complete(void* md5_info, char* data) +{ + MD5_Final((unsigned char*)data, (MD5_CTX*)md5_info); +} + +/*****************************************************************************/ +int +g_mod_exp(char* out, char* in, char* mod, char* exp) +{ + BN_CTX* ctx; + BIGNUM lmod; + BIGNUM lexp; + BIGNUM lin; + BIGNUM lout; + int rv; + + ctx = BN_CTX_new(); + BN_init(&lmod); + BN_init(&lexp); + BN_init(&lin); + BN_init(&lout); + BN_bin2bn((unsigned char*)mod, 64, &lmod); + BN_bin2bn((unsigned char*)exp, 64, &lexp); + BN_bin2bn((unsigned char*)in, 64, &lin); + BN_mod_exp(&lout, &lin, &lexp, &lmod, ctx); + rv = BN_bn2bin(&lout, (unsigned char*)out); + BN_free(&lin); + BN_free(&lout); + BN_free(&lexp); + BN_free(&lmod); + BN_CTX_free(ctx); + return rv; +} diff --git a/common/ssl_calls.h b/common/ssl_calls.h new file mode 100644 index 00000000..1d736fae --- /dev/null +++ b/common/ssl_calls.h @@ -0,0 +1,55 @@ +/* + This program is free software; you can redistribute it and/or modify + it under the terms of the GNU General Public License as published by + the Free Software Foundation; either version 2 of the License, or + (at your option) any later version. + + This program is distributed in the hope that it will be useful, + but WITHOUT ANY WARRANTY; without even the implied warranty of + MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + GNU General Public License for more details. + + You should have received a copy of the GNU General Public License + along with this program; if not, write to the Free Software + Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA. + + xrdp: A Remote Desktop Protocol server. + Copyright (C) Jay Sorg 2004-2005 + +*/ + +#if !defined(SSL_CALLS_H) +#define SSL_CALLS_H + +void* +g_rc4_info_create(void); +void +g_rc4_info_delete(void* rc4_info); +void +g_rc4_set_key(void* rc4_info, char* key, int len); +void +g_rc4_crypt(void* rc4_info, char* data, int len); +void* +g_sha1_info_create(void); +void +g_sha1_info_delete(void* sha1_info); +void +g_sha1_clear(void* sha1_info); +void +g_sha1_transform(void* sha1_info, char* data, int len); +void +g_sha1_complete(void* sha1_info, char* data); +void* +g_md5_info_create(void); +void +g_md5_info_delete(void* md5_info); +void +g_md5_clear(void* md5_info); +void +g_md5_transform(void* md5_info, char* data, int len); +void +g_md5_complete(void* md5_info, char* data); +int +g_mod_exp(char* out, char* in, char* mod, char* exp); + +#endif diff --git a/common/thread_calls.c b/common/thread_calls.c new file mode 100644 index 00000000..ad2334d4 --- /dev/null +++ b/common/thread_calls.c @@ -0,0 +1,60 @@ +/* + This program is free software; you can redistribute it and/or modify + it under the terms of the GNU General Public License as published by + the Free Software Foundation; either version 2 of the License, or + (at your option) any later version. + + This program is distributed in the hope that it will be useful, + but WITHOUT ANY WARRANTY; without even the implied warranty of + MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + GNU General Public License for more details. + + You should have received a copy of the GNU General Public License + along with this program; if not, write to the Free Software + Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA. + + xrdp: A Remote Desktop Protocol server. + Copyright (C) Jay Sorg 2004-2005 + + thread calls + +*/ + +#if defined(_WIN32) +#include <windows.h> +#else +#include <pthread.h> +#endif + +/*****************************************************************************/ +#if defined(_WIN32) +int +g_thread_create(unsigned long (__stdcall * start_routine)(void*), void* arg) +{ + DWORD thread; + + return !CreateThread(0, 0, start_routine, arg, 0, &thread); +} +#else +int +g_thread_create(void* (* start_routine)(void*), void* arg) +{ + pthread_t thread; + int rv; + + rv = pthread_create(&thread, 0, start_routine, arg); + pthread_detach(thread); + return rv; +} +#endif + +/*****************************************************************************/ +int +g_get_threadid(void) +{ +#if defined(_WIN32) + return 0; +#else + return pthread_self(); +#endif +} diff --git a/common/thread_calls.h b/common/thread_calls.h new file mode 100644 index 00000000..700a8133 --- /dev/null +++ b/common/thread_calls.h @@ -0,0 +1,29 @@ +/* + This program is free software; you can redistribute it and/or modify + it under the terms of the GNU General Public License as published by + the Free Software Foundation; either version 2 of the License, or + (at your option) any later version. + + This program is distributed in the hope that it will be useful, + but WITHOUT ANY WARRANTY; without even the implied warranty of + MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + GNU General Public License for more details. + + You should have received a copy of the GNU General Public License + along with this program; if not, write to the Free Software + Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA. + + xrdp: A Remote Desktop Protocol server. + Copyright (C) Jay Sorg 2004-2005 + +*/ + +#if !defined(THREAD_CALLS_H) +#define THREAD_CALLS_H + +int +g_thread_create(THREAD_RV (THREAD_CC * start_routine)(void*), void* arg); +int +g_get_threadid(void); + +#endif diff --git a/common/xrdp_constants.h b/common/xrdp_constants.h new file mode 100644 index 00000000..0f40cd5c --- /dev/null +++ b/common/xrdp_constants.h @@ -0,0 +1,438 @@ +/* + rdesktop: A Remote Desktop Protocol client. + Miscellaneous protocol constants + Copyright (C) Matthew Chapman 1999-2002 + + This program is free software; you can redistribute it and/or modify + it under the terms of the GNU General Public License as published by + the Free Software Foundation; either version 2 of the License, or + (at your option) any later version. + + This program is distributed in the hope that it will be useful, + but WITHOUT ANY WARRANTY; without even the implied warranty of + MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + GNU General Public License for more details. + + You should have received a copy of the GNU General Public License + along with this program; if not, write to the Free Software + Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA. +*/ + +/* modified for xrdp */ + +#if !defined(XRDP_CONSTANTS_H) +#define XRDP_CONSTANTS_H + +/* TCP port for Remote Desktop Protocol */ +#define TCP_PORT_RDP 3389 + +#define ISO_PDU_CR 0xE0 /* Connection Request */ +#define ISO_PDU_CC 0xD0 /* Connection Confirm */ +#define ISO_PDU_DR 0x80 /* Disconnect Request */ +#define ISO_PDU_DT 0xF0 /* Data */ +#define ISO_PDU_ER 0x70 /* Error */ + +/* MCS PDU codes */ +#define MCS_EDRQ 1 /* Erect Domain Request */ +#define MCS_DPUM 8 /* Disconnect Provider Ultimatum */ +#define MCS_AURQ 10 /* Attach User Request */ +#define MCS_AUCF 11 /* Attach User Confirm */ +#define MCS_CJRQ 14 /* Channel Join Request */ +#define MCS_CJCF 15 /* Channel Join Confirm */ +#define MCS_SDRQ 25 /* Send Data Request */ +#define MCS_SDIN 26 /* Send Data Indication */ + +#define MCS_CONNECT_INITIAL 0x7f65 +#define MCS_CONNECT_RESPONSE 0x7f66 + +#define BER_TAG_BOOLEAN 1 +#define BER_TAG_INTEGER 2 +#define BER_TAG_OCTET_STRING 4 +#define BER_TAG_RESULT 10 +#define MCS_TAG_DOMAIN_PARAMS 0x30 + +#define MCS_GLOBAL_CHANNEL 1003 +#define MCS_USERCHANNEL_BASE 1001 + +/* RDP secure transport constants */ +#define SEC_RANDOM_SIZE 32 +#define SEC_MODULUS_SIZE 64 +#define SEC_PADDING_SIZE 8 +#define SEC_EXPONENT_SIZE 4 + +#define SEC_CLIENT_RANDOM 0x0001 +#define SEC_ENCRYPT 0x0008 +#define SEC_LOGON_INFO 0x0040 +#define SEC_LICENCE_NEG 0x0080 + +#define SEC_TAG_SRV_INFO 0x0c01 +#define SEC_TAG_SRV_CRYPT 0x0c02 +#define SEC_TAG_SRV_CHANNELS 0x0c03 + +#define SEC_TAG_CLI_INFO 0xc001 +#define SEC_TAG_CLI_CRYPT 0xc002 +#define SEC_TAG_CLI_CHANNELS 0xc003 +#define SEC_TAG_CLI_4 0xc004 + +#define SEC_TAG_PUBKEY 0x0006 +#define SEC_TAG_KEYSIG 0x0008 + +#define SEC_RSA_MAGIC 0x31415352 /* RSA1 */ + +/* RDP licensing constants */ +#define LICENCE_TOKEN_SIZE 10 +#define LICENCE_HWID_SIZE 20 +#define LICENCE_SIGNATURE_SIZE 16 + +#define LICENCE_TAG_DEMAND 0x01 +#define LICENCE_TAG_AUTHREQ 0x02 +#define LICENCE_TAG_ISSUE 0x03 +#define LICENCE_TAG_REISSUE 0x04 +#define LICENCE_TAG_PRESENT 0x12 +#define LICENCE_TAG_REQUEST 0x13 +#define LICENCE_TAG_AUTHRESP 0x15 +#define LICENCE_TAG_RESULT 0xff + +#define LICENCE_TAG_USER 0x000f +#define LICENCE_TAG_HOST 0x0010 + +/* RDP PDU codes */ +#define RDP_PDU_DEMAND_ACTIVE 1 +#define RDP_PDU_CONFIRM_ACTIVE 3 +#define RDP_PDU_DEACTIVATE 6 +#define RDP_PDU_DATA 7 + +#define RDP_DATA_PDU_UPDATE 2 +#define RDP_DATA_PDU_CONTROL 20 +#define RDP_DATA_PDU_POINTER 27 +#define RDP_DATA_PDU_INPUT 28 +#define RDP_DATA_PDU_SYNCHRONISE 31 +#define RDP_DATA_PDU_BELL 34 +#define RDP_DATA_PDU_LOGON 38 +#define RDP_DATA_PDU_FONT2 39 +#define RDP_DATA_PDU_DISCONNECT 47 + +#define RDP_CTL_REQUEST_CONTROL 1 +#define RDP_CTL_GRANT_CONTROL 2 +#define RDP_CTL_DETACH 3 +#define RDP_CTL_COOPERATE 4 + +#define RDP_UPDATE_ORDERS 0 +#define RDP_UPDATE_BITMAP 1 +#define RDP_UPDATE_PALETTE 2 +#define RDP_UPDATE_SYNCHRONIZE 3 + +#define RDP_POINTER_SYSTEM 1 +#define RDP_POINTER_MOVE 3 +#define RDP_POINTER_COLOR 6 +#define RDP_POINTER_CACHED 7 + +#define RDP_NULL_POINTER 0 +#define RDP_DEFAULT_POINTER 0x7F00 + +#define RDP_INPUT_SYNCHRONIZE 0 +#define RDP_INPUT_CODEPOINT 1 +#define RDP_INPUT_VIRTKEY 2 +#define RDP_INPUT_SCANCODE 4 +#define RDP_INPUT_MOUSE 0x8001 + +/* Device flags */ +#define KBD_FLAG_RIGHT 0x0001 +#define KBD_FLAG_EXT 0x0100 +#define KBD_FLAG_QUIET 0x1000 +#define KBD_FLAG_DOWN 0x4000 +#define KBD_FLAG_UP 0x8000 + +/* These are for synchronization; not for keystrokes */ +#define KBD_FLAG_SCROLL 0x0001 +#define KBD_FLAG_NUMLOCK 0x0002 +#define KBD_FLAG_CAPITAL 0x0004 + +/* See T.128 */ +#define RDP_KEYPRESS 0 +#define RDP_KEYRELEASE (KBD_FLAG_DOWN | KBD_FLAG_UP) + +#define MOUSE_FLAG_MOVE 0x0800 +#define MOUSE_FLAG_BUTTON1 0x1000 +#define MOUSE_FLAG_BUTTON2 0x2000 +#define MOUSE_FLAG_BUTTON3 0x4000 +#define MOUSE_FLAG_BUTTON4 0x0280 +#define MOUSE_FLAG_BUTTON5 0x0380 +#define MOUSE_FLAG_DOWN 0x8000 + +/* Raster operation masks */ +#define ROP2_S(rop3) (rop3 & 0xf) +#define ROP2_P(rop3) ((rop3 & 0x3) | ((rop3 & 0x30) >> 2)) + +#define ROP2_COPY 0xc +#define ROP2_XOR 0x6 +#define ROP2_AND 0x8 +#define ROP2_NXOR 0x9 +#define ROP2_OR 0xe + +#define MIX_TRANSPARENT 0 +#define MIX_OPAQUE 1 + +#define TEXT2_VERTICAL 0x04 +#define TEXT2_IMPLICIT_X 0x20 + +/* RDP bitmap cache (version 2) constants */ +#define BMPCACHE2_C0_CELLS 0x78 +#define BMPCACHE2_C1_CELLS 0x78 +#define BMPCACHE2_C2_CELLS 0x150 +#define BMPCACHE2_NUM_PSTCELLS 0x9f6 + +#define PDU_FLAG_FIRST 0x01 +#define PDU_FLAG_LAST 0x02 + +/* Maps to generalCapabilitySet in T.128 page 138 */ + +/* RDP capabilities */ +#define RDP_CAPSET_GENERAL 1 +#define RDP_CAPLEN_GENERAL 0x18 +#define OS_MAJOR_TYPE_UNIX 4 +#define OS_MINOR_TYPE_XSERVER 7 + +#define RDP_CAPSET_BITMAP 2 +#define RDP_CAPLEN_BITMAP 0x1C + +#define RDP_CAPSET_ORDER 3 +#define RDP_CAPLEN_ORDER 0x58 +#define ORDER_CAP_NEGOTIATE 2 +#define ORDER_CAP_NOSUPPORT 4 + +#define RDP_CAPSET_BMPCACHE 4 +#define RDP_CAPLEN_BMPCACHE 0x28 + +#define RDP_CAPSET_CONTROL 5 +#define RDP_CAPLEN_CONTROL 0x0C + +#define RDP_CAPSET_ACTIVATE 7 +#define RDP_CAPLEN_ACTIVATE 0x0C + +#define RDP_CAPSET_POINTER 8 +#define RDP_CAPLEN_POINTER 0x08 + +#define RDP_CAPSET_SHARE 9 +#define RDP_CAPLEN_SHARE 0x08 + +#define RDP_CAPSET_COLCACHE 10 +#define RDP_CAPLEN_COLCACHE 0x08 + +#define RDP_CAPSET_BMPCACHE2 19 +#define RDP_CAPLEN_BMPCACHE2 0x28 +#define BMPCACHE2_FLAG_PERSIST ((long)1<<31) + +#define RDP_SOURCE "MSTSC" + +/* Logon flags */ +#define RDP_LOGON_AUTO 0x0008 +#define RDP_LOGON_NORMAL 0x0033 +#define RDP_COMPRESSION 0x0080 +#define RDP_LOGON_BLOB 0x0100 +#define RDP_LOGON_LEAVE_AUDIO 0x2000 + +#define RDP5_DISABLE_NOTHING 0x00 +#define RDP5_NO_WALLPAPER 0x01 +#define RDP5_NO_FULLWINDOWDRAG 0x02 +#define RDP5_NO_MENUANIMATIONS 0x04 +#define RDP5_NO_THEMING 0x08 +#define RDP5_NO_CURSOR_SHADOW 0x20 +#define RDP5_NO_CURSORSETTINGS 0x40 /* disables cursor blinking */ + +/* compression types */ +#define RDP_MPPC_COMPRESSED 0x20 +#define RDP_MPPC_RESET 0x40 +#define RDP_MPPC_FLUSH 0x80 +#define RDP_MPPC_DICT_SIZE 8192 + +/* Keymap flags */ +#define MapRightShiftMask (1 << 0) +#define MapLeftShiftMask (1 << 1) +#define MapShiftMask (MapRightShiftMask | MapLeftShiftMask) + +#define MapRightAltMask (1 << 2) +#define MapLeftAltMask (1 << 3) +#define MapAltGrMask MapRightAltMask + +#define MapRightCtrlMask (1 << 4) +#define MapLeftCtrlMask (1 << 5) +#define MapCtrlMask (MapRightCtrlMask | MapLeftCtrlMask) + +#define MapRightWinMask (1 << 6) +#define MapLeftWinMask (1 << 7) +#define MapWinMask (MapRightWinMask | MapLeftWinMask) + +#define MapNumLockMask (1 << 8) +#define MapCapsLockMask (1 << 9) + +#define MapLocalStateMask (1 << 10) + +#define MapInhibitMask (1 << 11) + +#define MASK_ADD_BITS(var, mask) (var |= mask) +#define MASK_REMOVE_BITS(var, mask) (var &= ~mask) +#define MASK_HAS_BITS(var, mask) ((var & mask)>0) +#define MASK_CHANGE_BIT(var, mask, active) \ + (var = ((var & ~mask) | (active ? mask : 0))) + +/* Clipboard constants, "borrowed" from GCC system headers in + the w32 cross compiler */ + +#define CF_TEXT 1 +#define CF_BITMAP 2 +#define CF_METAFILEPICT 3 +#define CF_SYLK 4 +#define CF_DIF 5 +#define CF_TIFF 6 +#define CF_OEMTEXT 7 +#define CF_DIB 8 +#define CF_PALETTE 9 +#define CF_PENDATA 10 +#define CF_RIFF 11 +#define CF_WAVE 12 +#define CF_UNICODETEXT 13 +#define CF_ENHMETAFILE 14 +#define CF_HDROP 15 +#define CF_LOCALE 16 +#define CF_MAX 17 +#define CF_OWNERDISPLAY 128 +#define CF_DSPTEXT 129 +#define CF_DSPBITMAP 130 +#define CF_DSPMETAFILEPICT 131 +#define CF_DSPENHMETAFILE 142 +#define CF_PRIVATEFIRST 512 +#define CF_PRIVATELAST 767 +#define CF_GDIOBJFIRST 768 +#define CF_GDIOBJLAST 1023 + +/* Sound format constants */ +#define WAVE_FORMAT_PCM 1 +#define WAVE_FORMAT_ADPCM 2 +#define WAVE_FORMAT_ALAW 6 +#define WAVE_FORMAT_MULAW 7 + +/* Virtual channel options */ +#define CHANNEL_OPTION_INITIALIZED 0x80000000 +#define CHANNEL_OPTION_ENCRYPT_RDP 0x40000000 +#define CHANNEL_OPTION_COMPRESS_RDP 0x00800000 +#define CHANNEL_OPTION_SHOW_PROTOCOL 0x00200000 + +/* NT status codes for RDPDR */ +#define STATUS_SUCCESS 0x00000000 +#define STATUS_PENDING 0x00000103 + +#define STATUS_NO_MORE_FILES 0x80000006 +#define STATUS_DEVICE_PAPER_EMPTY 0x8000000e +#define STATUS_DEVICE_POWERED_OFF 0x8000000f +#define STATUS_DEVICE_OFF_LINE 0x80000010 +#define STATUS_DEVICE_BUSY 0x80000011 + +#define STATUS_INVALID_HANDLE 0xc0000008 +#define STATUS_INVALID_PARAMETER 0xc000000d +#define STATUS_NO_SUCH_FILE 0xc000000f +#define STATUS_INVALID_DEVICE_REQUEST 0xc0000010 +#define STATUS_ACCESS_DENIED 0xc0000022 +#define STATUS_OBJECT_NAME_COLLISION 0xc0000035 +#define STATUS_DISK_FULL 0xc000007f +#define STATUS_FILE_IS_A_DIRECTORY 0xc00000ba +#define STATUS_NOT_SUPPORTED 0xc00000bb +#define STATUS_TIMEOUT 0xc0000102 +#define STATUS_CANCELLED 0xc0000120 + +/* RDPDR constants */ +#define RDPDR_MAX_DEVICES 0x10 +#define DEVICE_TYPE_SERIAL 0x01 +#define DEVICE_TYPE_PARALLEL 0x02 +#define DEVICE_TYPE_PRINTER 0x04 +#define DEVICE_TYPE_DISK 0x08 +#define DEVICE_TYPE_SCARD 0x20 + +#define FILE_DIRECTORY_FILE 0x00000001 +#define FILE_NON_DIRECTORY_FILE 0x00000040 +#define FILE_OPEN_FOR_FREE_SPACE_QUERY 0x00800000 + +/* RDP5 disconnect PDU */ +#define exDiscReasonNoInfo 0x0000 +#define exDiscReasonAPIInitiatedDisconnect 0x0001 +#define exDiscReasonAPIInitiatedLogoff 0x0002 +#define exDiscReasonServerIdleTimeout 0x0003 +#define exDiscReasonServerLogonTimeout 0x0004 +#define exDiscReasonReplacedByOtherConnection 0x0005 +#define exDiscReasonOutOfMemory 0x0006 +#define exDiscReasonServerDeniedConnection 0x0007 +#define exDiscReasonServerDeniedConnectionFips 0x0008 +#define exDiscReasonLicenseInternal 0x0100 +#define exDiscReasonLicenseNoLicenseServer 0x0101 +#define exDiscReasonLicenseNoLicense 0x0102 +#define exDiscReasonLicenseErrClientMsg 0x0103 +#define exDiscReasonLicenseHwidDoesntMatchLicense 0x0104 +#define exDiscReasonLicenseErrClientLicense 0x0105 +#define exDiscReasonLicenseCantFinishProtocol 0x0106 +#define exDiscReasonLicenseClientEndedProtocol 0x0107 +#define exDiscReasonLicenseErrClientEncryption 0x0108 +#define exDiscReasonLicenseCantUpgradeLicense 0x0109 +#define exDiscReasonLicenseNoRemoteConnections 0x010a + +#define RDP_ORDER_STANDARD 0x01 +#define RDP_ORDER_SECONDARY 0x02 +#define RDP_ORDER_BOUNDS 0x04 +#define RDP_ORDER_CHANGE 0x08 +#define RDP_ORDER_DELTA 0x10 +#define RDP_ORDER_LASTBOUNDS 0x20 +#define RDP_ORDER_SMALL 0x40 +#define RDP_ORDER_TINY 0x80 + +#define RDP_ORDER_DESTBLT 0 +#define RDP_ORDER_PATBLT 1 +#define RDP_ORDER_SCREENBLT 2 +#define RDP_ORDER_LINE 9 +#define RDP_ORDER_RECT 10 +#define RDP_ORDER_DESKSAVE 11 +#define RDP_ORDER_MEMBLT 13 +#define RDP_ORDER_TRIBLT 14 +#define RDP_ORDER_POLYLINE 22 +#define RDP_ORDER_TEXT2 27 + +#define RDP_ORDER_RAW_BMPCACHE 0 +#define RDP_ORDER_COLCACHE 1 +#define RDP_ORDER_BMPCACHE 2 +#define RDP_ORDER_FONTCACHE 3 +#define RDP_ORDER_RAW_BMPCACHE2 4 +#define RDP_ORDER_BMPCACHE2 5 + +/* drawable types */ +#define WND_TYPE_BITMAP 0 +#define WND_TYPE_WND 1 +#define WND_TYPE_SCREEN 2 +#define WND_TYPE_BUTTON 3 +#define WND_TYPE_IMAGE 4 +#define WND_TYPE_EDIT 5 +#define WND_TYPE_LABEL 6 +#define WND_TYPE_COMBO 7 +#define WND_TYPE_SPECIAL 8 + +/* button states */ +#define BUTTON_STATE_UP 0 +#define BUTTON_STATE_DOWN 1 + +/* messages */ +#define WM_PAINT 3 +#define WM_KEYDOWN 15 +#define WM_KEYUP 16 +#define WM_MOUSEMOVE 100 +#define WM_LBUTTONUP 101 +#define WM_LBUTTONDOWN 102 +#define WM_RBUTTONUP 103 +#define WM_RBUTTONDOWN 104 +#define WM_BUTTON3UP 105 +#define WM_BUTTON3DOWN 106 +#define WM_BUTTON4UP 107 +#define WM_BUTTON4DOWN 108 +#define WM_BUTTON5UP 109 +#define WM_BUTTON5DOWN 110 +#define WM_INVALIDATE 200 + +#define CB_ITEMCHANGE 300 + +#endif |