/[rdesktop]/sourceforge.net/trunk/rdesktop/rdesktop.c
This is repository of my old source code which isn't updated any more. Go to git.rot13.org for current projects!
ViewVC logotype

Annotation of /sourceforge.net/trunk/rdesktop/rdesktop.c

Parent Directory Parent Directory | Revision Log Revision Log


Revision 676 - (hide annotations)
Tue Apr 20 07:01:21 2004 UTC (20 years ago) by astrand
File MIME type: text/plain
File size: 23919 byte(s)
Applied disconnect handling patch from Jeroen Meijer

1 forsberg 350 /* -*- c-basic-offset: 8 -*-
2 matty 10 rdesktop: A Remote Desktop Protocol client.
3     Entrypoint and utility functions
4 n-ki 569 Copyright (C) Matthew Chapman 1999-2003
5 jsorg71 100
6 matty 10 This program is free software; you can redistribute it and/or modify
7     it under the terms of the GNU General Public License as published by
8     the Free Software Foundation; either version 2 of the License, or
9     (at your option) any later version.
10 jsorg71 100
11 matty 10 This program is distributed in the hope that it will be useful,
12     but WITHOUT ANY WARRANTY; without even the implied warranty of
13     MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
14     GNU General Public License for more details.
15 jsorg71 100
16 matty 10 You should have received a copy of the GNU General Public License
17     along with this program; if not, write to the Free Software
18     Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
19     */
20    
21 matty 30 #include <stdarg.h> /* va_list va_start va_end */
22 matty 24 #include <unistd.h> /* read close getuid getgid getpid getppid gethostname */
23     #include <fcntl.h> /* open */
24     #include <pwd.h> /* getpwuid */
25 matthewc 211 #include <termios.h> /* tcgetattr tcsetattr */
26 matty 24 #include <sys/stat.h> /* stat */
27     #include <sys/time.h> /* gettimeofday */
28     #include <sys/times.h> /* times */
29 stargo 570 #include <ctype.h> /* toupper */
30 astrand 325 #include <errno.h>
31 matty 10 #include "rdesktop.h"
32    
33 matthewc 220 #ifdef EGD_SOCKET
34     #include <sys/socket.h> /* socket connect */
35     #include <sys/un.h> /* sockaddr_un */
36     #endif
37    
38     #ifdef WITH_OPENSSL
39     #include <openssl/md5.h>
40     #else
41     #include "crypto/md5.h"
42     #endif
43    
44 astrand 479 char g_title[64] = "";
45     char g_username[64];
46 matty 10 char hostname[16];
47 matthewc 38 char keymapname[16];
48 astrand 66 int keylayout = 0x409; /* Defaults to US keyboard layout */
49 astrand 500
50     int g_width = 800; /* width is special: If 0, the
51     geometry will be fetched from
52     _NET_WORKAREA. If negative,
53     absolute value specifies the
54     percent of the whole screen. */
55 jsorg71 447 int g_height = 600;
56 jsorg71 58 int tcp_port_rdp = TCP_PORT_RDP;
57 jsorg71 438 int g_server_bpp = 8;
58 jsorg71 450 int g_win_button_size = 0; /* If zero, disable single app mode */
59 jsorg71 437 BOOL g_bitmap_compression = True;
60 jsorg71 447 BOOL g_sendmotion = True;
61 jsorg71 437 BOOL g_orders = True;
62     BOOL g_encryption = True;
63 forsberg 427 BOOL packet_encryption = True;
64 jsorg71 438 BOOL g_desktop_save = True;
65 jsorg71 447 BOOL g_fullscreen = False;
66 jsorg71 450 BOOL g_grab_keyboard = True;
67     BOOL g_hide_decorations = False;
68 astrand 458 BOOL g_use_rdp5 = True;
69 matthewc 482 BOOL g_console_session = False;
70 astrand 552 BOOL g_numlock_sync = False;
71 stargo 648 BOOL g_owncolmap = False;
72 astrand 651 BOOL g_ownbackstore = True; /* We can't rely on external BackingStore */
73 stargo 648 uint32 g_embed_wnd;
74 astrand 651 uint32 g_rdp5_performanceflags =
75     RDP5_NO_WALLPAPER | RDP5_NO_FULLWINDOWDRAG | RDP5_NO_MENUANIMATIONS;
76 matty 10
77 stargo 501 #ifdef WITH_RDPSND
78 matthewc 520 BOOL g_rdpsnd = False;
79 stargo 501 #endif
80    
81 n-ki 569 extern RDPDR_DEVICE g_rdpdr_device[];
82     extern uint32 g_num_devices;
83 astrand 651 extern char *g_rdpdr_clientname;
84 n-ki 569
85 astrand 333 #ifdef RDP2VNC
86     extern int rfb_port;
87     extern int defer_time;
88     void
89     rdp2vnc_connect(char *server, uint32 flags, char *domain, char *password,
90     char *shell, char *directory);
91     #endif
92 matty 10 /* Display usage information */
93 matty 25 static void
94     usage(char *program)
95 matty 10 {
96 matthewc 122 fprintf(stderr, "rdesktop: A Remote Desktop Protocol client.\n");
97 matthewc 304 fprintf(stderr, "Version " VERSION ". Copyright (C) 1999-2003 Matt Chapman.\n");
98 matthewc 122 fprintf(stderr, "See http://www.rdesktop.org/ for more information.\n\n");
99    
100 matthewc 222 fprintf(stderr, "Usage: %s [options] server[:port]\n", program);
101 astrand 333 #ifdef RDP2VNC
102     fprintf(stderr, " -V: vnc port\n");
103 forsberg 471 fprintf(stderr, " -Q: defer time (ms)\n");
104 astrand 333 #endif
105 astrand 111 fprintf(stderr, " -u: user name\n");
106     fprintf(stderr, " -d: domain\n");
107     fprintf(stderr, " -s: shell\n");
108     fprintf(stderr, " -c: working directory\n");
109 matthewc 211 fprintf(stderr, " -p: password (- to prompt)\n");
110 astrand 111 fprintf(stderr, " -n: client hostname\n");
111 matthewc 520 fprintf(stderr, " -k: keyboard layout on server (en-us, de, sv, etc.)\n");
112 astrand 111 fprintf(stderr, " -g: desktop geometry (WxH)\n");
113     fprintf(stderr, " -f: full-screen mode\n");
114     fprintf(stderr, " -b: force bitmap updates\n");
115 stargo 609 fprintf(stderr, " -B: use BackingStore of X-server (if available)\n");
116 astrand 111 fprintf(stderr, " -e: disable encryption (French TS)\n");
117 forsberg 471 fprintf(stderr, " -E: disable encryption from client to server\n");
118 astrand 111 fprintf(stderr, " -m: do not send motion events\n");
119 n-ki 279 fprintf(stderr, " -C: use private colour map\n");
120 matthewc 520 fprintf(stderr, " -D: hide window manager decorations\n");
121 astrand 111 fprintf(stderr, " -K: keep window manager key bindings\n");
122 matthewc 520 fprintf(stderr, " -S: caption button size (single application mode)\n");
123 matthewc 223 fprintf(stderr, " -T: window title\n");
124 n-ki 569 fprintf(stderr, " -N: enable numlock syncronization\n");
125 stargo 636 fprintf(stderr, " -X: embed into another window with a given id.\n");
126 matthewc 520 fprintf(stderr, " -a: connection colour depth\n");
127 astrand 651 fprintf(stderr,
128     " -x: RDP5 experience (m[odem 28.8], b[roadband], l[an] or hex number)\n");
129 n-ki 569 fprintf(stderr, " -r: enable specified device redirection (this flag can be repeated)\n");
130 astrand 608 fprintf(stderr,
131     " '-r comport:COM1=/dev/ttyS0': enable serial redirection of /dev/ttyS0 to COM1\n");
132 n-ki 578 fprintf(stderr, " or COM1=/dev/ttyS0,COM2=/dev/ttyS1\n");
133 astrand 608 fprintf(stderr,
134     " '-r disk:A=/mnt/floppy': enable redirection of /mnt/floppy to A:\n");
135 n-ki 569 fprintf(stderr, " or A=/mnt/floppy,D=/mnt/cdrom'\n");
136 forsberg 646 fprintf(stderr, " '-r clientname=<client name>': Set the client name displayed\n");
137     fprintf(stderr, " for redirected disks\n");
138 astrand 608 fprintf(stderr,
139     " '-r lptport:LPT1=/dev/lp0': enable parallel redirection of /dev/lp0 to LPT1\n");
140 n-ki 578 fprintf(stderr, " or LPT1=/dev/lp0,LPT2=/dev/lp1\n");
141 n-ki 569 fprintf(stderr, " '-r printer:mydeskjet': enable printer redirection\n");
142 astrand 608 fprintf(stderr,
143 n-ki 628 " or mydeskjet=\"HP LaserJet IIIP\" to enter server driver as well\n");
144 n-ki 630 fprintf(stderr, " '-r sound:[local|off|remote]': enable sound redirection\n");
145 n-ki 628 fprintf(stderr, " remote would leave sound on server\n");
146 matthewc 482 fprintf(stderr, " -0: attach to console\n");
147     fprintf(stderr, " -4: use RDP version 4\n");
148     fprintf(stderr, " -5: use RDP version 5 (default)\n");
149 matty 10 }
150    
151 astrand 676 void
152     print_disconnect_reason(uint16 reason)
153     {
154     char *text;
155    
156     switch (reason)
157     {
158     case exDiscReasonNoInfo:
159     text = "No information available";
160     break;
161    
162     case exDiscReasonAPIInitiatedDisconnect:
163     text = "Server initiated disconnect";
164     break;
165    
166     case exDiscReasonAPIInitiatedLogoff:
167     text = "Server initiated logoff";
168     break;
169    
170     case exDiscReasonServerIdleTimeout:
171     text = "Server idle timeout reached";
172     break;
173    
174     case exDiscReasonServerLogonTimeout:
175     text = "Server logon timeout reached";
176     break;
177    
178     case exDiscReasonReplacedByOtherConnection:
179     text = "The session was replaced";
180     break;
181    
182     case exDiscReasonOutOfMemory:
183     text = "The server is out of memory";
184     break;
185    
186     case exDiscReasonServerDeniedConnection:
187     text = "The server denied the connection";
188     break;
189    
190     case exDiscReasonServerDeniedConnectionFips:
191     text = "The server denied the connection for security reason";
192     break;
193    
194     case exDiscReasonLicenseInternal:
195     text = "Internal licensing error";
196     break;
197    
198     case exDiscReasonLicenseNoLicenseServer:
199     text = "No license server available";
200     break;
201    
202     case exDiscReasonLicenseNoLicense:
203     text = "No valid license available";
204     break;
205    
206     case exDiscReasonLicenseErrClientMsg:
207     text = "Invalid licensing message";
208     break;
209    
210     case exDiscReasonLicenseHwidDoesntMatchLicense:
211     text = "Hardware id doesn't match software license";
212     break;
213    
214     case exDiscReasonLicenseErrClientLicense:
215     text = "Client license error";
216     break;
217    
218     case exDiscReasonLicenseCantFinishProtocol:
219     text = "Network error during licensing protocol";
220     break;
221    
222     case exDiscReasonLicenseClientEndedProtocol:
223     text = "Licensing protocol was not completed";
224     break;
225    
226     case exDiscReasonLicenseErrClientEncryption:
227     text = "Incorrect client license enryption";
228     break;
229    
230     case exDiscReasonLicenseCantUpgradeLicense:
231     text = "Can't upgrade license";
232     break;
233    
234     case exDiscReasonLicenseNoRemoteConnections:
235     text = "The server is not licensed to accept remote connections";
236     break;
237    
238     default:
239     if (reason > 0x1000 && reason < 0x7fff)
240     {
241     text = "Internal protocol error";
242     }
243     else
244     {
245     text = "Unknown reason";
246     }
247     }
248     fprintf(stderr, "disconnect: %s.\n", text);
249     }
250    
251 matthewc 211 static BOOL
252     read_password(char *password, int size)
253     {
254     struct termios tios;
255     BOOL ret = False;
256     int istty = 0;
257     char *p;
258    
259     if (tcgetattr(STDIN_FILENO, &tios) == 0)
260     {
261     fprintf(stderr, "Password: ");
262     tios.c_lflag &= ~ECHO;
263     tcsetattr(STDIN_FILENO, TCSANOW, &tios);
264     istty = 1;
265     }
266    
267     if (fgets(password, size, stdin) != NULL)
268     {
269     ret = True;
270    
271     /* strip final newline */
272     p = strchr(password, '\n');
273     if (p != NULL)
274     *p = 0;
275     }
276    
277     if (istty)
278     {
279     tios.c_lflag |= ECHO;
280     tcsetattr(STDIN_FILENO, TCSANOW, &tios);
281     fprintf(stderr, "\n");
282     }
283    
284     return ret;
285     }
286    
287 astrand 444 static void
288     parse_server_and_port(char *server)
289     {
290     char *p;
291     #ifdef IPv6
292     int addr_colons;
293     #endif
294    
295     #ifdef IPv6
296     p = server;
297     addr_colons = 0;
298     while (*p)
299     if (*p++ == ':')
300     addr_colons++;
301     if (addr_colons >= 2)
302     {
303     /* numeric IPv6 style address format - [1:2:3::4]:port */
304     p = strchr(server, ']');
305     if (*server == '[' && p != NULL)
306     {
307     if (*(p + 1) == ':' && *(p + 2) != '\0')
308     tcp_port_rdp = strtol(p + 2, NULL, 10);
309     /* remove the port number and brackets from the address */
310     *p = '\0';
311     strncpy(server, server + 1, strlen(server));
312     }
313     }
314     else
315     {
316     /* dns name or IPv4 style address format - server.example.com:port or 1.2.3.4:port */
317     p = strchr(server, ':');
318     if (p != NULL)
319     {
320     tcp_port_rdp = strtol(p + 1, NULL, 10);
321     *p = 0;
322     }
323     }
324     #else /* no IPv6 support */
325     p = strchr(server, ':');
326     if (p != NULL)
327     {
328     tcp_port_rdp = strtol(p + 1, NULL, 10);
329     *p = 0;
330     }
331     #endif /* IPv6 */
332    
333     }
334    
335 matty 10 /* Client program */
336 matty 25 int
337     main(int argc, char *argv[])
338 matty 10 {
339 matthewc 222 char server[64];
340 matty 30 char fullhostname[64];
341 matty 21 char domain[16];
342 astrand 479 char password[64];
343 astrand 238 char shell[128];
344 matty 21 char directory[32];
345 astrand 676 BOOL prompt_password, deactivated;
346 matty 30 struct passwd *pw;
347 astrand 676 uint32 flags, ext_disc_reason = 0;
348 matthewc 222 char *p;
349 matty 10 int c;
350 n-ki 569
351 astrand 289 int username_option = 0;
352 matty 10
353 matty 21 flags = RDP_LOGON_NORMAL;
354 matthewc 211 prompt_password = False;
355 matty 21 domain[0] = password[0] = shell[0] = directory[0] = 0;
356 matthewc 240 strcpy(keymapname, "en-us");
357 stargo 636 g_embed_wnd = 0;
358 matty 21
359 n-ki 569 g_num_devices = 0;
360    
361 astrand 333 #ifdef RDP2VNC
362 forsberg 471 #define VNCOPT "V:Q:"
363 astrand 333 #else
364     #define VNCOPT
365     #endif
366    
367 stargo 637 while ((c = getopt(argc, argv, VNCOPT "u:d:s:c:p:n:k:g:fbBeEmCDKS:T:NX:a:x:r:045h?")) != -1)
368 matty 10 {
369     switch (c)
370     {
371 astrand 333 #ifdef RDP2VNC
372     case 'V':
373     rfb_port = strtol(optarg, NULL, 10);
374     if (rfb_port < 100)
375     rfb_port += 5900;
376     break;
377    
378 forsberg 471 case 'Q':
379 astrand 333 defer_time = strtol(optarg, NULL, 10);
380     if (defer_time < 0)
381     defer_time = 0;
382     break;
383     #endif
384    
385 matty 10 case 'u':
386 jsorg71 437 STRNCPY(g_username, optarg, sizeof(g_username));
387 astrand 289 username_option = 1;
388 matty 10 break;
389    
390 matty 21 case 'd':
391 matty 30 STRNCPY(domain, optarg, sizeof(domain));
392 matty 21 break;
393    
394     case 's':
395 matty 30 STRNCPY(shell, optarg, sizeof(shell));
396 matty 21 break;
397    
398     case 'c':
399 matty 30 STRNCPY(directory, optarg, sizeof(directory));
400 matty 21 break;
401    
402 matty 30 case 'p':
403 matthewc 211 if ((optarg[0] == '-') && (optarg[1] == 0))
404     {
405     prompt_password = True;
406     break;
407     }
408    
409 matty 30 STRNCPY(password, optarg, sizeof(password));
410     flags |= RDP_LOGON_AUTO;
411 matthewc 211
412     /* try to overwrite argument so it won't appear in ps */
413 n-ki 171 p = optarg;
414     while (*p)
415     *(p++) = 'X';
416 matty 30 break;
417    
418 matty 10 case 'n':
419 matty 30 STRNCPY(hostname, optarg, sizeof(hostname));
420 matty 10 break;
421    
422     case 'k':
423 astrand 82 STRNCPY(keymapname, optarg, sizeof(keymapname));
424 matty 10 break;
425    
426 matty 30 case 'g':
427 astrand 547 g_fullscreen = False;
428 astrand 263 if (!strcmp(optarg, "workarea"))
429     {
430 jsorg71 447 g_width = g_height = 0;
431 astrand 263 break;
432     }
433    
434 jsorg71 447 g_width = strtol(optarg, &p, 10);
435 astrand 500 if (g_width <= 0)
436     {
437     error("invalid geometry\n");
438     return 1;
439     }
440    
441 matty 30 if (*p == 'x')
442 jsorg71 447 g_height = strtol(p + 1, NULL, 10);
443 matty 30
444 astrand 500 if (g_height <= 0)
445 matty 30 {
446     error("invalid geometry\n");
447     return 1;
448     }
449 astrand 500
450     if (*p == '%')
451     g_width = -g_width;
452    
453 matty 10 break;
454    
455 matty 30 case 'f':
456 jsorg71 447 g_fullscreen = True;
457 matty 30 break;
458    
459 matty 10 case 'b':
460 jsorg71 437 g_orders = False;
461 matty 10 break;
462    
463 stargo 609 case 'B':
464     g_ownbackstore = False;
465     break;
466    
467 matty 30 case 'e':
468 jsorg71 437 g_encryption = False;
469 matty 10 break;
470 astrand 435 case 'E':
471 forsberg 427 packet_encryption = False;
472     break;
473 matty 30 case 'm':
474 jsorg71 447 g_sendmotion = False;
475 matty 28 break;
476 matty 29
477 n-ki 279 case 'C':
478 jsorg71 450 g_owncolmap = True;
479 n-ki 279 break;
480    
481 matthewc 520 case 'D':
482     g_hide_decorations = True;
483     break;
484    
485 astrand 76 case 'K':
486 jsorg71 450 g_grab_keyboard = False;
487 astrand 76 break;
488    
489 matthewc 520 case 'S':
490     if (!strcmp(optarg, "standard"))
491     {
492     g_win_button_size = 18;
493     break;
494     }
495    
496     g_win_button_size = strtol(optarg, &p, 10);
497    
498     if (*p)
499     {
500     error("invalid button size\n");
501     return 1;
502     }
503    
504     break;
505    
506 matthewc 223 case 'T':
507 jsorg71 450 STRNCPY(g_title, optarg, sizeof(g_title));
508 astrand 107 break;
509    
510 astrand 552 case 'N':
511     g_numlock_sync = True;
512     break;
513    
514 stargo 636 case 'X':
515     g_embed_wnd = strtol(optarg, NULL, 10);
516     break;
517 astrand 651
518 jsorg71 309 case 'a':
519 jsorg71 438 g_server_bpp = strtol(optarg, NULL, 10);
520     if (g_server_bpp != 8 && g_server_bpp != 16 && g_server_bpp != 15
521     && g_server_bpp != 24)
522 jsorg71 309 {
523     error("invalid server bpp\n");
524     return 1;
525     }
526     break;
527    
528 stargo 637 case 'x':
529 astrand 651
530 stargo 637 if (strncmp("modem", optarg, 1) == 0)
531     {
532 astrand 651 g_rdp5_performanceflags =
533     RDP5_NO_WALLPAPER | RDP5_NO_FULLWINDOWDRAG |
534     RDP5_NO_MENUANIMATIONS | RDP5_NO_THEMING;
535 stargo 637 }
536     else if (strncmp("broadband", optarg, 1) == 0)
537     {
538     g_rdp5_performanceflags = RDP5_NO_WALLPAPER;
539     }
540     else if (strncmp("lan", optarg, 1) == 0)
541     {
542     g_rdp5_performanceflags = RDP5_DISABLE_NOTHING;
543     }
544     else
545     {
546     g_rdp5_performanceflags = strtol(optarg, NULL, 16);
547     }
548     break;
549 astrand 651
550 matthewc 520 case 'r':
551 n-ki 569
552     if (strncmp("sound", optarg, 5) == 0)
553     {
554 n-ki 629 optarg += 5;
555    
556     if (*optarg == ':')
557 n-ki 628 {
558 n-ki 629 *optarg++;
559     while ((p = next_arg(optarg, ',')))
560     {
561     if (strncmp("remote", optarg, 6) == 0)
562     flags |= RDP_LOGON_LEAVE_AUDIO;
563 n-ki 628
564 n-ki 630 if (strncmp("local", optarg, 5) == 0)
565 stargo 501 #ifdef WITH_RDPSND
566 n-ki 629 g_rdpsnd = True;
567 matthewc 520 #else
568 n-ki 629 warning("Not compiled with sound support");
569 matthewc 520 #endif
570 n-ki 629
571     if (strncmp("off", optarg, 3) == 0)
572     g_rdpsnd = False;
573    
574     optarg = p;
575 n-ki 628 }
576     }
577     else
578     {
579     #ifdef WITH_RDPSND
580     g_rdpsnd = True;
581     #else
582     warning("Not compiled with sound support");
583     #endif
584     }
585 n-ki 569 }
586     else if (strncmp("disk", optarg, 4) == 0)
587     {
588     /* -r disk:h:=/mnt/floppy */
589     disk_enum_devices(&g_num_devices, optarg + 4);
590     }
591     else if (strncmp("comport", optarg, 7) == 0)
592     {
593     serial_enum_devices(&g_num_devices, optarg + 7);
594     }
595     else if (strncmp("lptport", optarg, 7) == 0)
596     {
597     parallel_enum_devices(&g_num_devices, optarg + 7);
598     }
599     else if (strncmp("printer", optarg, 7) == 0)
600     {
601     printer_enum_devices(&g_num_devices, optarg + 7);
602     }
603 forsberg 646 else if (strncmp("clientname", optarg, 7) == 0)
604     {
605 astrand 651 g_rdpdr_clientname = xmalloc(strlen(optarg + 11) + 1);
606 forsberg 646 strcpy(g_rdpdr_clientname, optarg + 11);
607     }
608 n-ki 569 else
609     {
610     warning("Unknown -r argument\n\n\tPossible arguments are: comport, disk, lptport, printer, sound\n");
611     }
612 stargo 501 break;
613 matthewc 520
614 matthewc 482 case '0':
615     g_console_session = True;
616     break;
617    
618 astrand 458 case '4':
619     g_use_rdp5 = False;
620     break;
621    
622 forsberg 350 case '5':
623 jsorg71 438 g_use_rdp5 = True;
624 forsberg 350 break;
625 astrand 458
626 matty 28 case 'h':
627 matty 10 case '?':
628     default:
629     usage(argv[0]);
630     return 1;
631     }
632     }
633    
634 stargo 610 if (argc - optind != 1)
635 matty 10 {
636     usage(argv[0]);
637     return 1;
638     }
639    
640 matthewc 222 STRNCPY(server, argv[optind], sizeof(server));
641 astrand 444 parse_server_and_port(server);
642 matty 10
643 astrand 289 if (!username_option)
644 matty 10 {
645     pw = getpwuid(getuid());
646     if ((pw == NULL) || (pw->pw_name == NULL))
647     {
648 matty 30 error("could not determine username, use -u\n");
649 matty 10 return 1;
650     }
651    
652 jsorg71 437 STRNCPY(g_username, pw->pw_name, sizeof(g_username));
653 matty 10 }
654    
655     if (hostname[0] == 0)
656     {
657 matty 30 if (gethostname(fullhostname, sizeof(fullhostname)) == -1)
658 matty 10 {
659 matty 30 error("could not determine local hostname, use -n\n");
660 matty 10 return 1;
661     }
662 matty 30
663     p = strchr(fullhostname, '.');
664     if (p != NULL)
665     *p = 0;
666    
667     STRNCPY(hostname, fullhostname, sizeof(hostname));
668 matty 10 }
669    
670 matthewc 211 if (prompt_password && read_password(password, sizeof(password)))
671     flags |= RDP_LOGON_AUTO;
672 matty 30
673 jsorg71 450 if (g_title[0] == 0)
674 astrand 107 {
675 jsorg71 450 strcpy(g_title, "rdesktop - ");
676     strncat(g_title, server, sizeof(g_title) - sizeof("rdesktop - "));
677 astrand 107 }
678 matty 12
679 astrand 333 #ifdef RDP2VNC
680     rdp2vnc_connect(server, flags, domain, password, shell, directory);
681 forsberg 424 return 0;
682 astrand 333 #else
683    
684 astrand 82 if (!ui_init())
685     return 1;
686 astrand 66
687 matthewc 474 #ifdef WITH_RDPSND
688 stargo 501 if (g_rdpsnd)
689     rdpsnd_init();
690 matthewc 474 #endif
691 n-ki 569 rdpdr_init();
692 forsberg 416
693 matthewc 53 if (!rdp_connect(server, flags, domain, password, shell, directory))
694     return 1;
695    
696 forsberg 427 /* By setting encryption to False here, we have an encrypted login
697     packet but unencrypted transfer of other packets */
698 astrand 435 if (!packet_encryption)
699 jsorg71 437 g_encryption = False;
700 forsberg 427
701    
702 matthewc 122 DEBUG(("Connection successful.\n"));
703 matthewc 211 memset(password, 0, sizeof(password));
704 matthewc 53
705 jsorg71 100 if (ui_create_window())
706 matty 10 {
707 astrand 676 rdp_main_loop(&deactivated, &ext_disc_reason);
708 matty 10 ui_destroy_window();
709     }
710    
711 matthewc 122 DEBUG(("Disconnecting...\n"));
712 matthewc 53 rdp_disconnect();
713 matthewc 188 ui_deinit();
714 astrand 333
715 astrand 676 if (ext_disc_reason >= 2)
716     print_disconnect_reason(ext_disc_reason);
717    
718     if (deactivated)
719     {
720     /* clean disconnect */
721 forsberg 424 return 0;
722 astrand 676 }
723 forsberg 424 else
724 astrand 676 {
725     if (ext_disc_reason == exDiscReasonAPIInitiatedDisconnect
726     || ext_disc_reason == exDiscReasonAPIInitiatedLogoff)
727     {
728     /* not so clean disconnect, but nothing to worry about */
729     return 0;
730     }
731     else
732     {
733     /* return error */
734     return 2;
735     }
736     }
737 forsberg 424
738 astrand 333 #endif
739    
740 matty 10 }
741    
742 matthewc 220 #ifdef EGD_SOCKET
743     /* Read 32 random bytes from PRNGD or EGD socket (based on OpenSSL RAND_egd) */
744     static BOOL
745     generate_random_egd(uint8 * buf)
746     {
747     struct sockaddr_un addr;
748     BOOL ret = False;
749     int fd;
750    
751     fd = socket(AF_UNIX, SOCK_STREAM, 0);
752     if (fd == -1)
753     return False;
754    
755     addr.sun_family = AF_UNIX;
756     memcpy(addr.sun_path, EGD_SOCKET, sizeof(EGD_SOCKET));
757 astrand 259 if (connect(fd, (struct sockaddr *) &addr, sizeof(addr)) == -1)
758 matthewc 220 goto err;
759    
760     /* PRNGD and EGD use a simple communications protocol */
761 astrand 259 buf[0] = 1; /* Non-blocking (similar to /dev/urandom) */
762     buf[1] = 32; /* Number of requested random bytes */
763 matthewc 220 if (write(fd, buf, 2) != 2)
764     goto err;
765    
766 astrand 259 if ((read(fd, buf, 1) != 1) || (buf[0] == 0)) /* Available? */
767 matthewc 220 goto err;
768    
769     if (read(fd, buf, 32) != 32)
770     goto err;
771    
772     ret = True;
773    
774 astrand 259 err:
775 matthewc 220 close(fd);
776     return ret;
777     }
778     #endif
779    
780 matty 10 /* Generate a 32-byte random for the secure transport code. */
781 matty 25 void
782 astrand 64 generate_random(uint8 * random)
783 matty 10 {
784     struct stat st;
785 matty 22 struct tms tmsbuf;
786 matthewc 220 MD5_CTX md5;
787     uint32 *r;
788     int fd, n;
789 matty 10
790 matthewc 220 /* If we have a kernel random device, try that first */
791 matty 30 if (((fd = open("/dev/urandom", O_RDONLY)) != -1)
792     || ((fd = open("/dev/random", O_RDONLY)) != -1))
793 matty 10 {
794 matthewc 220 n = read(fd, random, 32);
795 matty 10 close(fd);
796 matthewc 220 if (n == 32)
797     return;
798 matty 10 }
799    
800 matthewc 220 #ifdef EGD_SOCKET
801     /* As a second preference use an EGD */
802     if (generate_random_egd(random))
803     return;
804     #endif
805    
806 matty 10 /* Otherwise use whatever entropy we can gather - ideas welcome. */
807 astrand 259 r = (uint32 *) random;
808 matty 10 r[0] = (getpid()) | (getppid() << 16);
809     r[1] = (getuid()) | (getgid() << 16);
810 matty 24 r[2] = times(&tmsbuf); /* system uptime (clocks) */
811     gettimeofday((struct timeval *) &r[3], NULL); /* sec and usec */
812 matty 10 stat("/tmp", &st);
813     r[5] = st.st_atime;
814     r[6] = st.st_mtime;
815     r[7] = st.st_ctime;
816 matthewc 220
817     /* Hash both halves with MD5 to obscure possible patterns */
818     MD5_Init(&md5);
819 astrand 259 MD5_Update(&md5, random, 16);
820 matthewc 220 MD5_Final(random, &md5);
821 astrand 259 MD5_Update(&md5, random + 16, 16);
822     MD5_Final(random + 16, &md5);
823 matty 10 }
824    
825     /* malloc; exit if out of memory */
826 matty 25 void *
827     xmalloc(int size)
828 matty 10 {
829     void *mem = malloc(size);
830     if (mem == NULL)
831     {
832 matty 30 error("xmalloc %d\n", size);
833 matty 10 exit(1);
834     }
835     return mem;
836     }
837    
838     /* realloc; exit if out of memory */
839 matty 25 void *
840     xrealloc(void *oldmem, int size)
841 matty 10 {
842     void *mem = realloc(oldmem, size);
843     if (mem == NULL)
844     {
845 matty 30 error("xrealloc %d\n", size);
846 matty 10 exit(1);
847     }
848     return mem;
849     }
850    
851     /* free */
852 matty 25 void
853     xfree(void *mem)
854 matty 10 {
855     free(mem);
856     }
857    
858 matty 30 /* report an error */
859 matty 25 void
860 matty 30 error(char *format, ...)
861     {
862     va_list ap;
863    
864     fprintf(stderr, "ERROR: ");
865    
866     va_start(ap, format);
867     vfprintf(stderr, format, ap);
868     va_end(ap);
869     }
870    
871 matthewc 297 /* report a warning */
872     void
873     warning(char *format, ...)
874     {
875     va_list ap;
876    
877     fprintf(stderr, "WARNING: ");
878    
879     va_start(ap, format);
880     vfprintf(stderr, format, ap);
881     va_end(ap);
882     }
883    
884 matty 30 /* report an unimplemented protocol feature */
885     void
886     unimpl(char *format, ...)
887     {
888     va_list ap;
889    
890     fprintf(stderr, "NOT IMPLEMENTED: ");
891    
892     va_start(ap, format);
893     vfprintf(stderr, format, ap);
894     va_end(ap);
895     }
896    
897     /* produce a hex dump */
898     void
899 n-ki 569 hexdump(unsigned char *p, unsigned int len)
900 matty 10 {
901     unsigned char *line = p;
902 jsorg71 376 int i, thisline, offset = 0;
903 matty 10
904     while (offset < len)
905     {
906 matthewc 169 printf("%04x ", offset);
907 matty 10 thisline = len - offset;
908     if (thisline > 16)
909     thisline = 16;
910    
911     for (i = 0; i < thisline; i++)
912 matthewc 169 printf("%02x ", line[i]);
913 matty 10
914 matty 30 for (; i < 16; i++)
915 matthewc 169 printf(" ");
916 matty 30
917 matty 10 for (i = 0; i < thisline; i++)
918 matthewc 169 printf("%c", (line[i] >= 0x20 && line[i] < 0x7f) ? line[i] : '.');
919 matty 10
920 matthewc 169 printf("\n");
921 matty 10 offset += thisline;
922     line += thisline;
923     }
924     }
925 astrand 325
926 n-ki 569 /*
927 n-ki 583 input: src is the string we look in for needle.
928     Needle may be escaped by a backslash, in
929     that case we ignore that particular needle.
930 n-ki 569 return value: returns next src pointer, for
931     succesive executions, like in a while loop
932     if retval is 0, then there are no more args.
933     pitfalls:
934     src is modified. 0x00 chars are inserted to
935     terminate strings.
936     return val, points on the next val chr after ins
937     0x00
938 astrand 325
939 n-ki 569 example usage:
940     while( (pos = next_arg( optarg, ',')) ){
941     printf("%s\n",optarg);
942     optarg=pos;
943     }
944    
945     */
946     char *
947     next_arg(char *src, char needle)
948     {
949     char *nextval;
950 n-ki 571 char *p;
951 n-ki 575 char *mvp = 0;
952 n-ki 569
953 n-ki 575 /* EOS */
954 n-ki 569 if (*src == (char) 0x00)
955     return 0;
956    
957 n-ki 571 p = src;
958 n-ki 575 /* skip escaped needles */
959 astrand 580 while ((nextval = strchr(p, needle)))
960 n-ki 571 {
961 n-ki 575 mvp = nextval - 1;
962     /* found backslashed needle */
963 astrand 580 if (*mvp == '\\' && (mvp > src))
964 n-ki 575 {
965     /* move string one to the left */
966 astrand 580 while (*(mvp + 1) != (char) 0x00)
967 n-ki 575 {
968 astrand 580 *mvp = *(mvp + 1);
969 n-ki 575 *mvp++;
970     }
971 astrand 580 *mvp = (char) 0x00;
972 n-ki 575 p = nextval;
973     }
974     else
975     {
976 astrand 580 p = nextval + 1;
977 n-ki 571 break;
978 n-ki 575 }
979    
980 n-ki 571 }
981    
982 n-ki 575 /* more args available */
983 n-ki 569 if (nextval)
984     {
985     *nextval = (char) 0x00;
986     return ++nextval;
987     }
988    
989 n-ki 575 /* no more args after this, jump to EOS */
990 n-ki 569 nextval = src + strlen(src);
991     return nextval;
992     }
993    
994    
995 stargo 570 void
996 astrand 580 toupper_str(char *p)
997 n-ki 569 {
998 astrand 580 while (*p)
999     {
1000     if ((*p >= 'a') && (*p <= 'z'))
1001 stargo 570 *p = toupper((int) *p);
1002 n-ki 569 p++;
1003     }
1004     }
1005    
1006    
1007     /* not all clibs got ltoa */
1008     #define LTOA_BUFSIZE (sizeof(long) * 8 + 1)
1009    
1010     char *
1011 stargo 603 l_to_a(long N, int base)
1012 n-ki 569 {
1013     static char ret[LTOA_BUFSIZE];
1014    
1015 n-ki 583 char *head = ret, buf[LTOA_BUFSIZE], *tail = buf + sizeof(buf);
1016 n-ki 569
1017 n-ki 583 register int divrem;
1018    
1019     if (base < 36 || 2 > base)
1020 n-ki 569 base = 10;
1021    
1022 n-ki 583 if (N < 0)
1023 n-ki 569 {
1024     *head++ = '-';
1025 n-ki 583 N = -N;
1026 n-ki 569 }
1027    
1028 n-ki 583 tail = buf + sizeof(buf);
1029     *--tail = 0;
1030    
1031     do
1032 n-ki 569 {
1033 n-ki 583 divrem = N % base;
1034     *--tail = (divrem <= 9) ? divrem + '0' : divrem + 'a' - 10;
1035     N /= base;
1036 n-ki 569 }
1037 n-ki 583 while (N);
1038 n-ki 569
1039 n-ki 583 strcpy(head, tail);
1040 n-ki 569 return ret;
1041     }
1042    
1043    
1044 astrand 325 int
1045     load_licence(unsigned char **data)
1046     {
1047 matthewc 367 char *home, *path;
1048 astrand 325 struct stat st;
1049 matthewc 367 int fd, length;
1050 astrand 325
1051     home = getenv("HOME");
1052     if (home == NULL)
1053     return -1;
1054    
1055 forsberg 416 path = (char *) xmalloc(strlen(home) + strlen(hostname) + sizeof("/.rdesktop/licence."));
1056 astrand 325 sprintf(path, "%s/.rdesktop/licence.%s", home, hostname);
1057    
1058     fd = open(path, O_RDONLY);
1059     if (fd == -1)
1060     return -1;
1061    
1062     if (fstat(fd, &st))
1063     return -1;
1064    
1065 forsberg 416 *data = (uint8 *) xmalloc(st.st_size);
1066 matthewc 367 length = read(fd, *data, st.st_size);
1067     close(fd);
1068     xfree(path);
1069     return length;
1070 astrand 325 }
1071    
1072     void
1073     save_licence(unsigned char *data, int length)
1074     {
1075 matthewc 367 char *home, *path, *tmppath;
1076     int fd;
1077 astrand 325
1078     home = getenv("HOME");
1079     if (home == NULL)
1080     return;
1081    
1082 forsberg 416 path = (char *) xmalloc(strlen(home) + strlen(hostname) + sizeof("/.rdesktop/licence."));
1083 astrand 325
1084 matthewc 367 sprintf(path, "%s/.rdesktop", home);
1085     if ((mkdir(path, 0700) == -1) && errno != EEXIST)
1086 astrand 325 {
1087 matthewc 367 perror(path);
1088     return;
1089 astrand 325 }
1090    
1091 matthewc 367 /* write licence to licence.hostname.new, then atomically rename to licence.hostname */
1092 astrand 325
1093 matthewc 367 sprintf(path, "%s/.rdesktop/licence.%s", home, hostname);
1094 forsberg 416 tmppath = (char *) xmalloc(strlen(path) + sizeof(".new"));
1095 matthewc 367 strcpy(tmppath, path);
1096     strcat(tmppath, ".new");
1097    
1098 forsberg 416 fd = open(tmppath, O_WRONLY | O_CREAT | O_TRUNC, 0600);
1099 matthewc 367 if (fd == -1)
1100 astrand 325 {
1101 matthewc 367 perror(tmppath);
1102     return;
1103 astrand 325 }
1104    
1105 matthewc 367 if (write(fd, data, length) != length)
1106 astrand 325 {
1107 matthewc 367 perror(tmppath);
1108     unlink(tmppath);
1109 astrand 325 }
1110 matthewc 367 else if (rename(tmppath, path) == -1)
1111 astrand 325 {
1112 matthewc 367 perror(path);
1113     unlink(tmppath);
1114 astrand 325 }
1115    
1116 matthewc 367 close(fd);
1117     xfree(tmppath);
1118     xfree(path);
1119 astrand 325 }

  ViewVC Help
Powered by ViewVC 1.1.26