/[rdesktop]/sourceforge.net/trunk/rdesktop/rdp.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

Diff of /sourceforge.net/trunk/rdesktop/rdp.c

Parent Directory Parent Directory | Revision Log Revision Log | View Patch Patch

revision 435 by astrand, Wed Jul 9 09:18:20 2003 UTC revision 624 by n-ki, Thu Mar 4 08:11:40 2004 UTC
# Line 18  Line 18 
18     Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.     Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
19  */  */
20    
21    #include <time.h>
22  #include "rdesktop.h"  #include "rdesktop.h"
23    
24  extern uint16 g_mcs_userid;  extern uint16 g_mcs_userid;
25  extern char username[16];  extern char g_username[16];
26  extern BOOL bitmap_compression;  extern BOOL g_bitmap_compression;
27  extern BOOL orders;  extern BOOL g_orders;
28  extern BOOL encryption;  extern BOOL g_encryption;
29  extern BOOL desktop_save;  extern BOOL g_desktop_save;
30  extern BOOL use_rdp5;  extern BOOL g_use_rdp5;
31  extern uint16 server_rdp_version;  extern uint16 g_server_rdp_version;
32  extern int server_bpp;  extern int g_server_bpp;
33    
34  uint8 *next_packet;  uint8 *g_next_packet;
35  uint32 rdp_shareid;  uint32 g_rdp_shareid;
36    
37  #if WITH_DEBUG  #if WITH_DEBUG
38  static uint32 packetno;  static uint32 g_packetno;
39  #endif  #endif
40    
41  /* Receive an RDP packet */  /* Receive an RDP packet */
# Line 44  rdp_recv(uint8 * type) Line 45  rdp_recv(uint8 * type)
45          static STREAM rdp_s;          static STREAM rdp_s;
46          uint16 length, pdu_type;          uint16 length, pdu_type;
47    
48          if ((rdp_s == NULL) || (next_packet >= rdp_s->end))          if ((rdp_s == NULL) || (g_next_packet >= rdp_s->end))
49          {          {
50                  rdp_s = sec_recv();                  rdp_s = sec_recv();
51                  if (rdp_s == NULL)                  if (rdp_s == NULL)
52                          return NULL;                          return NULL;
53    
54                  next_packet = rdp_s->p;                  g_next_packet = rdp_s->p;
55          }          }
56          else          else
57          {          {
58                  rdp_s->p = next_packet;                  rdp_s->p = g_next_packet;
59          }          }
60    
61          in_uint16_le(rdp_s, length);          in_uint16_le(rdp_s, length);
62          /* 32k packets are really 8, keepalive fix */          /* 32k packets are really 8, keepalive fix */
63          if (length == 0x8000)          if (length == 0x8000)
64          {          {
65                  next_packet += 8;                  g_next_packet += 8;
66                  *type = 0;                  *type = 0;
67                  return rdp_s;                  return rdp_s;
68          }          }
# Line 70  rdp_recv(uint8 * type) Line 71  rdp_recv(uint8 * type)
71          *type = pdu_type & 0xf;          *type = pdu_type & 0xf;
72    
73  #if WITH_DEBUG  #if WITH_DEBUG
74          DEBUG(("RDP packet #%d, (type %x)\n", ++packetno, *type));          DEBUG(("RDP packet #%d, (type %x)\n", ++g_packetno, *type));
75          //      hexdump(next_packet, length);          hexdump(g_next_packet, length);
76  #endif /*  */  #endif /*  */
77    
78          next_packet += length;          g_next_packet += length;
79          return rdp_s;          return rdp_s;
80  }  }
81    
# Line 84  rdp_init_data(int maxlen) Line 85  rdp_init_data(int maxlen)
85  {  {
86          STREAM s;          STREAM s;
87    
88          s = sec_init(encryption ? SEC_ENCRYPT : 0, maxlen + 18);          s = sec_init(g_encryption ? SEC_ENCRYPT : 0, maxlen + 18);
89          s_push_layer(s, rdp_hdr, 18);          s_push_layer(s, rdp_hdr, 18);
90    
91          return s;          return s;
# Line 103  rdp_send_data(STREAM s, uint8 data_pdu_t Line 104  rdp_send_data(STREAM s, uint8 data_pdu_t
104          out_uint16_le(s, (RDP_PDU_DATA | 0x10));          out_uint16_le(s, (RDP_PDU_DATA | 0x10));
105          out_uint16_le(s, (g_mcs_userid + 1001));          out_uint16_le(s, (g_mcs_userid + 1001));
106    
107          out_uint32_le(s, rdp_shareid);          out_uint32_le(s, g_rdp_shareid);
108          out_uint8(s, 0);        /* pad */          out_uint8(s, 0);        /* pad */
109          out_uint8(s, 1);        /* streamid */          out_uint8(s, 1);        /* streamid */
110          out_uint16_le(s, (length - 14));          out_uint16_le(s, (length - 14));
# Line 111  rdp_send_data(STREAM s, uint8 data_pdu_t Line 112  rdp_send_data(STREAM s, uint8 data_pdu_t
112          out_uint8(s, 0);        /* compress_type */          out_uint8(s, 0);        /* compress_type */
113          out_uint16(s, 0);       /* compress_len */          out_uint16(s, 0);       /* compress_len */
114    
115          sec_send(s, encryption ? SEC_ENCRYPT : 0);          sec_send(s, g_encryption ? SEC_ENCRYPT : 0);
116  }  }
117    
118  /* Output a string in Unicode */  /* Output a string in Unicode */
# Line 131  rdp_out_unistr(STREAM s, char *string, i Line 132  rdp_out_unistr(STREAM s, char *string, i
132          s->p += len;          s->p += len;
133  }  }
134    
135    /* Input a string in Unicode
136     *
137     * Returns str_len of string
138     */
139    int
140    rdp_in_unistr(STREAM s, char *string, int uni_len)
141    {
142            int i = 0;
143    
144            while (i < uni_len / 2)
145            {
146                    in_uint8a(s, &string[i++], 1);
147                    in_uint8s(s, 1);
148            }
149    
150            return i - 1;
151    }
152    
153    
154  /* Parse a logon info packet */  /* Parse a logon info packet */
155  static void  static void
156  rdp_send_logon_info(uint32 flags, char *domain, char *user,  rdp_send_logon_info(uint32 flags, char *domain, char *user,
157                      char *password, char *program, char *directory)                      char *password, char *program, char *directory)
158  {  {
159            char *ipaddr = tcp_get_address();
160          int len_domain = 2 * strlen(domain);          int len_domain = 2 * strlen(domain);
161          int len_user = 2 * strlen(user);          int len_user = 2 * strlen(user);
162          int len_password = 2 * strlen(password);          int len_password = 2 * strlen(password);
163          int len_program = 2 * strlen(program);          int len_program = 2 * strlen(program);
164          int len_directory = 2 * strlen(directory);          int len_directory = 2 * strlen(directory);
165          int len_ip = 2 * strlen("127.0.0.1");          int len_ip = 2 * strlen(ipaddr);
166          int len_dll = 2 * strlen("C:\\WINNT\\System32\\mstscax.dll");          int len_dll = 2 * strlen("C:\\WINNT\\System32\\mstscax.dll");
167          int packetlen = 0;          int packetlen = 0;
168          uint32 sec_flags = encryption ? (SEC_LOGON_INFO | SEC_ENCRYPT) : SEC_LOGON_INFO;          uint32 sec_flags = g_encryption ? (SEC_LOGON_INFO | SEC_ENCRYPT) : SEC_LOGON_INFO;
169          STREAM s;          STREAM s;
170            time_t t = time(NULL);
171            time_t tzone;
172    
173    #if 0
174            // enable rdp compression
175            flags |= RDP_COMPRESSION;
176    #endif
177    
178          if (!use_rdp5 || 1 == server_rdp_version)          if (!g_use_rdp5 || 1 == g_server_rdp_version)
179          {          {
180                  DEBUG_RDP5(("Sending RDP4-style Logon packet\n"));                  DEBUG_RDP5(("Sending RDP4-style Logon packet\n"));
181    
# Line 171  rdp_send_logon_info(uint32 flags, char * Line 199  rdp_send_logon_info(uint32 flags, char *
199          {          {
200                  flags |= RDP_LOGON_BLOB;                  flags |= RDP_LOGON_BLOB;
201                  DEBUG_RDP5(("Sending RDP5-style Logon packet\n"));                  DEBUG_RDP5(("Sending RDP5-style Logon packet\n"));
202                  packetlen = 4 + // Unknown uint32                  packetlen = 4 + /* Unknown uint32 */
203                          4 +     // flags                          4 +     /* flags */
204                          2 +     // len_domain                          2 +     /* len_domain */
205                          2 +     // len_user                          2 +     /* len_user */
206                          (flags & RDP_LOGON_AUTO ? 2 : 0) +      // len_password                          (flags & RDP_LOGON_AUTO ? 2 : 0) +      /* len_password */
207                          (flags & RDP_LOGON_BLOB ? 2 : 0) +      // Length of BLOB                          (flags & RDP_LOGON_BLOB ? 2 : 0) +      /* Length of BLOB */
208                          2 +     // len_program                          2 +     /* len_program */
209                          2 +     // len_directory                          2 +     /* len_directory */
210                          (0 < len_domain ? len_domain : 2) +     // domain                          (0 < len_domain ? len_domain : 2) +     /* domain */
211                          len_user + (flags & RDP_LOGON_AUTO ? len_password : 0) + 0 +    // We have no 512 byte BLOB. Perhaps we must?                          len_user + (flags & RDP_LOGON_AUTO ? len_password : 0) + 0 +    /* We have no 512 byte BLOB. Perhaps we must? */
212                          (flags & RDP_LOGON_BLOB && !(flags & RDP_LOGON_AUTO) ? 2 : 0) + // After the BLOB is a unknown int16. If there is a BLOB, that is.                          (flags & RDP_LOGON_BLOB && !(flags & RDP_LOGON_AUTO) ? 2 : 0) + /* After the BLOB is a unknown int16. If there is a BLOB, that is. */
213                          (0 < len_program ? len_program : 2) + (0 < len_directory ? len_directory : 2) + 2 +     // Unknown (2)                          (0 < len_program ? len_program : 2) + (0 < len_directory ? len_directory : 2) + 2 +     /* Unknown (2) */
214                          2 +     // Client ip length                          2 +     /* Client ip length */
215                          len_ip +        // Client ip                          len_ip +        /* Client ip */
216                          2 +     // DLL string length                          2 +     /* DLL string length */
217                          len_dll +       // DLL string                          len_dll +       /* DLL string */
218                          2 +     // Unknown                          2 +     /* Unknown */
219                          2 +     // Unknown                          2 +     /* Unknown */
220                          64 +    // Time zone #0                          64 +    /* Time zone #0 */
221                          2 +     // Unknown                          2 +     /* Unknown */
222                          64 +    // Time zone #1                          64 +    /* Time zone #1 */
223                          32;     // Unknown                          32;     /* Unknown */
224    
225                  s = sec_init(sec_flags, packetlen);                  s = sec_init(sec_flags, packetlen);
226                  DEBUG_RDP5(("Called sec_init with packetlen %d\n", packetlen));                  DEBUG_RDP5(("Called sec_init with packetlen %d\n", packetlen));
227    
228                  out_uint32(s, 0);       // Unknown                  out_uint32(s, 0);       /* Unknown */
229                  out_uint32_le(s, flags);                  out_uint32_le(s, flags);
230                  out_uint16_le(s, len_domain);                  out_uint16_le(s, len_domain);
231                  out_uint16_le(s, len_user);                  out_uint16_le(s, len_user);
# Line 243  rdp_send_logon_info(uint32 flags, char * Line 271  rdp_send_logon_info(uint32 flags, char *
271                          out_uint16_le(s, 0);                          out_uint16_le(s, 0);
272                  }                  }
273                  out_uint16_le(s, 2);                  out_uint16_le(s, 2);
274                  out_uint16_le(s, len_ip + 2);   // Length of client ip                  out_uint16_le(s, len_ip + 2);   /* Length of client ip */
275                  rdp_out_unistr(s, "127.0.0.1", len_ip);                  rdp_out_unistr(s, ipaddr, len_ip);
276                  out_uint16_le(s, len_dll + 2);                  out_uint16_le(s, len_dll + 2);
277                  rdp_out_unistr(s, "C:\\WINNT\\System32\\mstscax.dll", len_dll);                  rdp_out_unistr(s, "C:\\WINNT\\System32\\mstscax.dll", len_dll);
278                  out_uint16_le(s, 0xffc4);  
279                  out_uint16_le(s, 0xffff);                  tzone = (mktime(gmtime(&t)) - mktime(localtime(&t))) / 60;
280                    out_uint32_le(s, tzone);
281    
282                  rdp_out_unistr(s, "GTB, normaltid", 2 * strlen("GTB, normaltid"));                  rdp_out_unistr(s, "GTB, normaltid", 2 * strlen("GTB, normaltid"));
283                  out_uint8s(s, 62 - 2 * strlen("GTB, normaltid"));                  out_uint8s(s, 62 - 2 * strlen("GTB, normaltid"));
284    
   
285                  out_uint32_le(s, 0x0a0000);                  out_uint32_le(s, 0x0a0000);
286                  out_uint32_le(s, 0x050000);                  out_uint32_le(s, 0x050000);
287                  out_uint32_le(s, 3);                  out_uint32_le(s, 3);
# Line 358  rdp_out_general_caps(STREAM s) Line 387  rdp_out_general_caps(STREAM s)
387          out_uint16_le(s, 0x200);        /* Protocol version */          out_uint16_le(s, 0x200);        /* Protocol version */
388          out_uint16(s, 0);       /* Pad */          out_uint16(s, 0);       /* Pad */
389          out_uint16(s, 0);       /* Compression types */          out_uint16(s, 0);       /* Compression types */
390          out_uint16_le(s, use_rdp5 ? 0x40d : 0);          out_uint16_le(s, g_use_rdp5 ? 0x40d : 0);
391          /* Pad, according to T.128. 0x40d seems to          /* Pad, according to T.128. 0x40d seems to
392             trigger             trigger
393             the server to start sending RDP5 packets.             the server to start sending RDP5 packets.
# Line 387  rdp_out_bitmap_caps(STREAM s) Line 416  rdp_out_bitmap_caps(STREAM s)
416          out_uint16_le(s, 600);  /* Desktop height */          out_uint16_le(s, 600);  /* Desktop height */
417          out_uint16(s, 0);       /* Pad */          out_uint16(s, 0);       /* Pad */
418          out_uint16(s, 0);       /* Allow resize */          out_uint16(s, 0);       /* Allow resize */
419          out_uint16_le(s, bitmap_compression ? 1 : 0);   /* Support compression */          out_uint16_le(s, g_bitmap_compression ? 1 : 0); /* Support compression */
420          out_uint16(s, 0);       /* Unknown */          out_uint16(s, 0);       /* Unknown */
421          out_uint16_le(s, 1);    /* Unknown */          out_uint16_le(s, 1);    /* Unknown */
422          out_uint16(s, 0);       /* Pad */          out_uint16(s, 0);       /* Pad */
# Line 408  rdp_out_order_caps(STREAM s) Line 437  rdp_out_order_caps(STREAM s)
437          order_caps[8] = 1;      /* line */          order_caps[8] = 1;      /* line */
438          order_caps[9] = 1;      /* line */          order_caps[9] = 1;      /* line */
439          order_caps[10] = 1;     /* rect */          order_caps[10] = 1;     /* rect */
440          order_caps[11] = (desktop_save == False ? 0 : 1);       /* desksave */          order_caps[11] = (g_desktop_save == False ? 0 : 1);     /* desksave */
441          order_caps[13] = 1;     /* memblt */          order_caps[13] = 1;     /* memblt */
442          order_caps[14] = 1;     /* triblt */          order_caps[14] = 1;     /* triblt */
443          order_caps[22] = 1;     /* polyline */          order_caps[22] = 1;     /* polyline */
# Line 426  rdp_out_order_caps(STREAM s) Line 455  rdp_out_order_caps(STREAM s)
455          out_uint8p(s, order_caps, 32);  /* Orders supported */          out_uint8p(s, order_caps, 32);  /* Orders supported */
456          out_uint16_le(s, 0x6a1);        /* Text capability flags */          out_uint16_le(s, 0x6a1);        /* Text capability flags */
457          out_uint8s(s, 6);       /* Pad */          out_uint8s(s, 6);       /* Pad */
458          out_uint32_le(s, desktop_save == False ? 0 : 0x38400);  /* Desktop cache size */          out_uint32_le(s, g_desktop_save == False ? 0 : 0x38400);        /* Desktop cache size */
459          out_uint32(s, 0);       /* Unknown */          out_uint32(s, 0);       /* Unknown */
460          out_uint32_le(s, 0x4e4);        /* Unknown */          out_uint32_le(s, 0x4e4);        /* Unknown */
461  }  }
# Line 439  rdp_out_bmpcache_caps(STREAM s) Line 468  rdp_out_bmpcache_caps(STREAM s)
468          out_uint16_le(s, RDP_CAPSET_BMPCACHE);          out_uint16_le(s, RDP_CAPSET_BMPCACHE);
469          out_uint16_le(s, RDP_CAPLEN_BMPCACHE);          out_uint16_le(s, RDP_CAPLEN_BMPCACHE);
470    
471          Bpp = (server_bpp + 7) / 8;          Bpp = (g_server_bpp + 7) / 8;
472          out_uint8s(s, 24);      /* unused */          out_uint8s(s, 24);      /* unused */
473          out_uint16_le(s, 0x258);        /* entries */          out_uint16_le(s, 0x258);        /* entries */
474          out_uint16_le(s, 0x100 * Bpp);  /* max cell size */          out_uint16_le(s, 0x100 * Bpp);  /* max cell size */
# Line 546  static void Line 575  static void
575  rdp_send_confirm_active(void)  rdp_send_confirm_active(void)
576  {  {
577          STREAM s;          STREAM s;
578          uint32 sec_flags = encryption ? (RDP5_FLAG | SEC_ENCRYPT) : RDP5_FLAG;          uint32 sec_flags = g_encryption ? (RDP5_FLAG | SEC_ENCRYPT) : RDP5_FLAG;
579          uint16 caplen =          uint16 caplen =
580                  RDP_CAPLEN_GENERAL + RDP_CAPLEN_BITMAP + RDP_CAPLEN_ORDER +                  RDP_CAPLEN_GENERAL + RDP_CAPLEN_BITMAP + RDP_CAPLEN_ORDER +
581                  RDP_CAPLEN_BMPCACHE + RDP_CAPLEN_COLCACHE +                  RDP_CAPLEN_BMPCACHE + RDP_CAPLEN_COLCACHE +
# Line 559  rdp_send_confirm_active(void) Line 588  rdp_send_confirm_active(void)
588          out_uint16_le(s, (RDP_PDU_CONFIRM_ACTIVE | 0x10));      /* Version 1 */          out_uint16_le(s, (RDP_PDU_CONFIRM_ACTIVE | 0x10));      /* Version 1 */
589          out_uint16_le(s, (g_mcs_userid + 1001));          out_uint16_le(s, (g_mcs_userid + 1001));
590    
591          out_uint32_le(s, rdp_shareid);          out_uint32_le(s, g_rdp_shareid);
592          out_uint16_le(s, 0x3ea);        /* userid */          out_uint16_le(s, 0x3ea);        /* userid */
593          out_uint16_le(s, sizeof(RDP_SOURCE));          out_uint16_le(s, sizeof(RDP_SOURCE));
594          out_uint16_le(s, caplen);          out_uint16_le(s, caplen);
# Line 589  process_demand_active(STREAM s) Line 618  process_demand_active(STREAM s)
618  {  {
619          uint8 type;          uint8 type;
620    
621          in_uint32_le(s, rdp_shareid);          in_uint32_le(s, g_rdp_shareid);
622    
623          DEBUG(("DEMAND_ACTIVE(id=0x%x)\n", rdp_shareid));          DEBUG(("DEMAND_ACTIVE(id=0x%x)\n", g_rdp_shareid));
624    
625          rdp_send_confirm_active();          rdp_send_confirm_active();
626          rdp_send_synchronise();          rdp_send_synchronise();
# Line 600  process_demand_active(STREAM s) Line 629  process_demand_active(STREAM s)
629          rdp_recv(&type);        /* RDP_PDU_SYNCHRONIZE */          rdp_recv(&type);        /* RDP_PDU_SYNCHRONIZE */
630          rdp_recv(&type);        /* RDP_CTL_COOPERATE */          rdp_recv(&type);        /* RDP_CTL_COOPERATE */
631          rdp_recv(&type);        /* RDP_CTL_GRANT_CONTROL */          rdp_recv(&type);        /* RDP_CTL_GRANT_CONTROL */
632          rdp_send_input(0, RDP_INPUT_SYNCHRONIZE, 0, 0, 0);          rdp_send_input(0, RDP_INPUT_SYNCHRONIZE, 0, ui_get_numlock_state(read_keyboard_state()), 0);
633          rdp_send_fonts(1);          rdp_send_fonts(1);
634          rdp_send_fonts(2);          rdp_send_fonts(2);
635          rdp_recv(&type);        /* RDP_PDU_UNKNOWN 0x28 */          rdp_recv(&type);        /* RDP_PDU_UNKNOWN 0x28 */
636          reset_order_state();          reset_order_state();
637  }  }
638    
 /* Process a null system pointer PDU */  
 void  
 process_null_system_pointer_pdu(STREAM s)  
 {  
         // FIXME: We should probably set another cursor here,  
         // like the X window system base cursor or something.  
         ui_set_cursor(cache_get_cursor(0));  
 }  
   
639  /* Process a colour pointer PDU */  /* Process a colour pointer PDU */
640  void  void
641  process_colour_pointer_pdu(STREAM s)  process_colour_pointer_pdu(STREAM s)
# Line 648  process_cached_pointer_pdu(STREAM s) Line 668  process_cached_pointer_pdu(STREAM s)
668          ui_set_cursor(cache_get_cursor(cache_idx));          ui_set_cursor(cache_get_cursor(cache_idx));
669  }  }
670    
671    /* Process a system pointer PDU */
672    void
673    process_system_pointer_pdu(STREAM s)
674    {
675            uint16 system_pointer_type;
676    
677            in_uint16(s, system_pointer_type);
678            switch (system_pointer_type)
679            {
680                    case RDP_NULL_POINTER:
681                            ui_set_null_cursor();
682                            break;
683    
684                    default:
685                            unimpl("System pointer message 0x%x\n", system_pointer_type);
686            }
687    }
688    
689  /* Process a pointer PDU */  /* Process a pointer PDU */
690  static void  static void
# Line 676  process_pointer_pdu(STREAM s) Line 713  process_pointer_pdu(STREAM s)
713                          process_cached_pointer_pdu(s);                          process_cached_pointer_pdu(s);
714                          break;                          break;
715    
716                    case RDP_POINTER_SYSTEM:
717                            process_system_pointer_pdu(s);
718                            break;
719    
720                  default:                  default:
721                          DEBUG(("Pointer message 0x%x\n", message_type));                          unimpl("Pointer message 0x%x\n", message_type);
722          }          }
723  }  }
724    
# Line 712  process_bitmap_updates(STREAM s) Line 753  process_bitmap_updates(STREAM s)
753                  DEBUG(("BITMAP_UPDATE(l=%d,t=%d,r=%d,b=%d,w=%d,h=%d,Bpp=%d,cmp=%d)\n",                  DEBUG(("BITMAP_UPDATE(l=%d,t=%d,r=%d,b=%d,w=%d,h=%d,Bpp=%d,cmp=%d)\n",
754                         left, top, right, bottom, width, height, Bpp, compress));                         left, top, right, bottom, width, height, Bpp, compress));
755    
756                    /* Server may limit bpp - this is how we find out */
757                    if (g_server_bpp != bpp)
758                    {
759                            warning("Server limited colour depth to %d bits\n", bpp);
760                            g_server_bpp = bpp;
761                    }
762    
763                  if (!compress)                  if (!compress)
764                  {                  {
765                          int y;                          int y;
# Line 765  process_palette(STREAM s) Line 813  process_palette(STREAM s)
813          in_uint16_le(s, map.ncolours);          in_uint16_le(s, map.ncolours);
814          in_uint8s(s, 2);        /* pad */          in_uint8s(s, 2);        /* pad */
815    
816          map.colours = (COLOURENTRY *) xmalloc(3 * map.ncolours);          map.colours = (COLOURENTRY *) xmalloc(sizeof(COLOURENTRY) * map.ncolours);
817    
818          DEBUG(("PALETTE(c=%d)\n", map.ncolours));          DEBUG(("PALETTE(c=%d)\n", map.ncolours));
819    
# Line 822  static void Line 870  static void
870  process_data_pdu(STREAM s)  process_data_pdu(STREAM s)
871  {  {
872          uint8 data_pdu_type;          uint8 data_pdu_type;
873            uint8 ctype;
874            uint16 clen;
875            int roff, rlen, len, ret;
876            static struct stream ns;
877            static signed char *dict = 0;
878    
879          in_uint8s(s, 8);        /* shareid, pad, streamid, length */          in_uint8s(s, 6);        /* shareid, pad, streamid */
880            in_uint16(s, len);
881          in_uint8(s, data_pdu_type);          in_uint8(s, data_pdu_type);
882          in_uint8s(s, 3);        /* compress_type, compress_len */          in_uint8(s, ctype);
883            in_uint16(s, clen);
884            clen -= 18;
885    
886    #if 0
887            if (ctype & 0x20)
888            {
889                    if (!dict)
890                    {
891                            dict = (signed char *) malloc(8200 * sizeof(signed char));
892                            dict = (signed char *) memset(dict, 0, 8200 * sizeof(signed char));
893                    }
894    
895                    ret = decompress(s->p, clen, ctype, (signed char *) dict, &roff, &rlen);
896    
897                    len -= 18;
898    
899                    ns.data = xrealloc(ns.data, len);
900    
901                    ns.data = (unsigned char *) memcpy(ns.data, (unsigned char *) (dict + roff), len);
902    
903                    ns.size = len;
904                    ns.end = ns.data + ns.size;
905                    ns.p = ns.data;
906                    ns.rdp_hdr = ns.p;
907    
908                    s = &ns;
909            }
910    #endif
911    
912          switch (data_pdu_type)          switch (data_pdu_type)
913          {          {
# Line 846  process_data_pdu(STREAM s) Line 928  process_data_pdu(STREAM s)
928                          /* User logged on */                          /* User logged on */
929                          break;                          break;
930    
931                    case RDP_DATA_PDU_DISCONNECT:
932                            /* Normally received when user logs out or disconnects from a
933                               console session on Windows XP and 2003 Server */
934                            DEBUG(("Received disconnect PDU\n"));
935                            break;
936    
937                  default:                  default:
938                          unimpl("data PDU %d\n", data_pdu_type);                          unimpl("data PDU %d\n", data_pdu_type);
939          }          }
# Line 898  BOOL Line 986  BOOL
986  rdp_connect(char *server, uint32 flags, char *domain, char *password,  rdp_connect(char *server, uint32 flags, char *domain, char *password,
987              char *command, char *directory)              char *command, char *directory)
988  {  {
989          if (!sec_connect(server, username))          if (!sec_connect(server, g_username))
990                  return False;                  return False;
991    
992          rdp_send_logon_info(flags, domain, username, password, command, directory);          rdp_send_logon_info(flags, domain, g_username, password, command, directory);
993          return True;          return True;
994  }  }
995    
Legend:
Removed from v.435  
changed lines
  Added in v.624
  ViewVC Help
Powered by ViewVC 1.1.26