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

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

revision 25 by matty, Sat Jan 6 03:47:04 2001 UTC revision 432 by matthewc, Tue Jul 1 09:31:25 2003 UTC
# Line 1  Line 1 
1  /*  /* -*- c-basic-offset: 8 -*-
2     rdesktop: A Remote Desktop Protocol client.     rdesktop: A Remote Desktop Protocol client.
3     Protocol services - Multipoint Communications Service     Protocol services - Multipoint Communications Service
4     Copyright (C) Matthew Chapman 1999-2000     Copyright (C) Matthew Chapman 1999-2002
5        
6     This program is free software; you can redistribute it and/or modify     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     it under the terms of the GNU General Public License as published by
# Line 20  Line 20 
20    
21  #include "rdesktop.h"  #include "rdesktop.h"
22    
23  uint16 mcs_userid;  uint16 g_mcs_userid;
24    extern VCHANNEL g_channels[];
25    extern unsigned int g_num_channels;
26    
27  /* Parse an ASN.1 BER header */  /* Parse an ASN.1 BER header */
28  static BOOL  static BOOL
# Line 38  ber_parse_header(STREAM s, int tagval, i Line 40  ber_parse_header(STREAM s, int tagval, i
40    
41          if (tag != tagval)          if (tag != tagval)
42          {          {
43                  ERROR("expected tag %d, got %d\n", tagval, tag);                  error("expected tag %d, got %d\n", tagval, tag);
44                  return False;                  return False;
45          }          }
46    
# Line 89  ber_out_integer(STREAM s, int value) Line 91  ber_out_integer(STREAM s, int value)
91    
92  /* Output a DOMAIN_PARAMS structure (ASN.1 BER) */  /* Output a DOMAIN_PARAMS structure (ASN.1 BER) */
93  static void  static void
94  mcs_out_domain_params(STREAM s, int max_channels, int max_users,  mcs_out_domain_params(STREAM s, int max_channels, int max_users, int max_tokens, int max_pdusize)
                       int max_tokens, int max_pdusize)  
95  {  {
96          ber_out_header(s, MCS_TAG_DOMAIN_PARAMS, 32);          ber_out_header(s, MCS_TAG_DOMAIN_PARAMS, 32);
97          ber_out_integer(s, max_channels);          ber_out_integer(s, max_channels);
# Line 120  static void Line 121  static void
121  mcs_send_connect_initial(STREAM mcs_data)  mcs_send_connect_initial(STREAM mcs_data)
122  {  {
123          int datalen = mcs_data->end - mcs_data->data;          int datalen = mcs_data->end - mcs_data->data;
124          int length = 7 + 3 * 34 + 4 + datalen;          int length = 9 + 3 * 34 + 4 + datalen;
125          STREAM s;          STREAM s;
126    
127          s = iso_init(length + 5);          s = iso_init(length + 5);
128    
129          ber_out_header(s, MCS_CONNECT_INITIAL, length);          ber_out_header(s, MCS_CONNECT_INITIAL, length);
130          ber_out_header(s, BER_TAG_OCTET_STRING, 0);     /* calling domain */          ber_out_header(s, BER_TAG_OCTET_STRING, 1);     /* calling domain */
131          ber_out_header(s, BER_TAG_OCTET_STRING, 0);     /* called domain */          out_uint8(s, 1);
132            ber_out_header(s, BER_TAG_OCTET_STRING, 1);     /* called domain */
133            out_uint8(s, 1);
134    
135          ber_out_header(s, BER_TAG_BOOLEAN, 1);          ber_out_header(s, BER_TAG_BOOLEAN, 1);
136          out_uint8(s, 0xff);     /* upward flag */          out_uint8(s, 0xff);     /* upward flag */
137    
138          mcs_out_domain_params(s, 2, 2, 0, 0xffff);      /* target params */          mcs_out_domain_params(s, 34, 2, 0, 0xffff);     /* target params */
139          mcs_out_domain_params(s, 1, 1, 1, 0x420);       /* min params */          mcs_out_domain_params(s, 1, 1, 1, 0x420);       /* min params */
140          mcs_out_domain_params(s, 0xffff, 0xfc17, 0xffff, 0xffff);       /* max params */          mcs_out_domain_params(s, 0xffff, 0xfc17, 0xffff, 0xffff);       /* max params */
141    
# Line 161  mcs_recv_connect_response(STREAM mcs_dat Line 164  mcs_recv_connect_response(STREAM mcs_dat
164          in_uint8(s, result);          in_uint8(s, result);
165          if (result != 0)          if (result != 0)
166          {          {
167                  ERROR("MCS connect: %d\n", result);                  error("MCS connect: %d\n", result);
168                  return False;                  return False;
169          }          }
170    
# Line 170  mcs_recv_connect_response(STREAM mcs_dat Line 173  mcs_recv_connect_response(STREAM mcs_dat
173          mcs_parse_domain_params(s);          mcs_parse_domain_params(s);
174    
175          ber_parse_header(s, BER_TAG_OCTET_STRING, &length);          ber_parse_header(s, BER_TAG_OCTET_STRING, &length);
         if (length > mcs_data->size)  
         {  
                 WARN("MCS data length %d\n", length);  
                 length = mcs_data->size;  
         }  
   
         in_uint8a(s, mcs_data->data, length);  
         mcs_data->p = mcs_data->data;  
         mcs_data->end = mcs_data->data + length;  
176    
177            sec_process_mcs_data(s);
178            /*
179               if (length > mcs_data->size)
180               {
181               error("MCS data length %d, expected %d\n", length,
182               mcs_data->size);
183               length = mcs_data->size;
184               }
185    
186               in_uint8a(s, mcs_data->data, length);
187               mcs_data->p = mcs_data->data;
188               mcs_data->end = mcs_data->data + length;
189             */
190          return s_check_end(s);          return s_check_end(s);
191  }  }
192    
193  /* Send an EDrq message (ASN.1 PER) */  /* Send an EDrq message (ASN.1 PER) */
194  static void  static void
195  mcs_send_edrq()  mcs_send_edrq(void)
196  {  {
197          STREAM s;          STREAM s;
198    
# Line 201  mcs_send_edrq() Line 208  mcs_send_edrq()
208    
209  /* Send an AUrq message (ASN.1 PER) */  /* Send an AUrq message (ASN.1 PER) */
210  static void  static void
211  mcs_send_aurq()  mcs_send_aurq(void)
212  {  {
213          STREAM s;          STREAM s;
214    
# Line 215  mcs_send_aurq() Line 222  mcs_send_aurq()
222    
223  /* Expect a AUcf message (ASN.1 PER) */  /* Expect a AUcf message (ASN.1 PER) */
224  static BOOL  static BOOL
225  mcs_recv_aucf(uint16 *mcs_userid)  mcs_recv_aucf(uint16 * mcs_userid)
226  {  {
227          uint8 opcode, result;          uint8 opcode, result;
228          STREAM s;          STREAM s;
# Line 227  mcs_recv_aucf(uint16 *mcs_userid) Line 234  mcs_recv_aucf(uint16 *mcs_userid)
234          in_uint8(s, opcode);          in_uint8(s, opcode);
235          if ((opcode >> 2) != MCS_AUCF)          if ((opcode >> 2) != MCS_AUCF)
236          {          {
237                  ERROR("expected AUcf, got %d\n", opcode);                  error("expected AUcf, got %d\n", opcode);
238                  return False;                  return False;
239          }          }
240    
241          in_uint8(s, result);          in_uint8(s, result);
242          if (result != 0)          if (result != 0)
243          {          {
244                  ERROR("AUrq: %d\n", result);                  error("AUrq: %d\n", result);
245                  return False;                  return False;
246          }          }
247    
# Line 250  mcs_send_cjrq(uint16 chanid) Line 257  mcs_send_cjrq(uint16 chanid)
257  {  {
258          STREAM s;          STREAM s;
259    
260            DEBUG_RDP5(("Sending CJRQ for channel #%d\n", chanid));
261    
262          s = iso_init(5);          s = iso_init(5);
263    
264          out_uint8(s, (MCS_CJRQ << 2));          out_uint8(s, (MCS_CJRQ << 2));
265          out_uint16_be(s, mcs_userid);          out_uint16_be(s, g_mcs_userid);
266          out_uint16_be(s, chanid);          out_uint16_be(s, chanid);
267    
268          s_mark_end(s);          s_mark_end(s);
# Line 262  mcs_send_cjrq(uint16 chanid) Line 271  mcs_send_cjrq(uint16 chanid)
271    
272  /* Expect a CJcf message (ASN.1 PER) */  /* Expect a CJcf message (ASN.1 PER) */
273  static BOOL  static BOOL
274  mcs_recv_cjcf()  mcs_recv_cjcf(void)
275  {  {
276          uint8 opcode, result;          uint8 opcode, result;
277          STREAM s;          STREAM s;
# Line 274  mcs_recv_cjcf() Line 283  mcs_recv_cjcf()
283          in_uint8(s, opcode);          in_uint8(s, opcode);
284          if ((opcode >> 2) != MCS_CJCF)          if ((opcode >> 2) != MCS_CJCF)
285          {          {
286                  ERROR("expected CJcf, got %d\n", opcode);                  error("expected CJcf, got %d\n", opcode);
287                  return False;                  return False;
288          }          }
289    
290          in_uint8(s, result);          in_uint8(s, result);
291          if (result != 0)          if (result != 0)
292          {          {
293                  ERROR("CJrq: %d\n", result);                  error("CJrq: %d\n", result);
294                  return False;                  return False;
295          }          }
296    
# Line 304  mcs_init(int length) Line 313  mcs_init(int length)
313          return s;          return s;
314  }  }
315    
316  /* Send an MCS transport data packet */  /* Send an MCS transport data packet to a specific channel */
317  void  void
318  mcs_send(STREAM s)  mcs_send_to_channel(STREAM s, uint16 channel)
319  {  {
320          uint16 length;          uint16 length;
321    
# Line 315  mcs_send(STREAM s) Line 324  mcs_send(STREAM s)
324          length |= 0x8000;          length |= 0x8000;
325    
326          out_uint8(s, (MCS_SDRQ << 2));          out_uint8(s, (MCS_SDRQ << 2));
327          out_uint16_be(s, mcs_userid);          out_uint16_be(s, g_mcs_userid);
328          out_uint16_be(s, MCS_GLOBAL_CHANNEL);          out_uint16_be(s, channel);
329          out_uint8(s, 0x70);     /* flags */          out_uint8(s, 0x70);     /* flags */
330          out_uint16_be(s, length);          out_uint16_be(s, length);
331    
332          iso_send(s);          iso_send(s);
333  }  }
334    
335    /* Send an MCS transport data packet to the global channel */
336    void
337    mcs_send(STREAM s)
338    {
339            mcs_send_to_channel(s, MCS_GLOBAL_CHANNEL);
340    }
341    
342  /* Receive an MCS transport data packet */  /* Receive an MCS transport data packet */
343  STREAM  STREAM
344  mcs_recv()  mcs_recv(uint16 * channel)
345  {  {
346          uint8 opcode, appid, length;          uint8 opcode, appid, length;
347          STREAM s;          STREAM s;
# Line 340  mcs_recv() Line 356  mcs_recv()
356          {          {
357                  if (appid != MCS_DPUM)                  if (appid != MCS_DPUM)
358                  {                  {
359                          ERROR("expected data, got %d\n", opcode);                          error("expected data, got %d\n", opcode);
360                  }                  }
361                  return NULL;                  return NULL;
362          }          }
363    
364          in_uint8s(s, 5);        /* userid, chanid, flags */          in_uint8s(s, 2);        /* userid */
365            in_uint16_be(s, *channel);
366            in_uint8s(s, 1);        /* flags */
367          in_uint8(s, length);          in_uint8(s, length);
368          if (length & 0x80)          if (length & 0x80)
369                  in_uint8s(s, 1);        /* second byte of length */                  in_uint8s(s, 1);        /* second byte of length */
# Line 355  mcs_recv() Line 373  mcs_recv()
373    
374  /* Establish a connection up to the MCS layer */  /* Establish a connection up to the MCS layer */
375  BOOL  BOOL
376  mcs_connect(char *server, STREAM mcs_data)  mcs_connect(char *server, STREAM mcs_data, char *username)
377  {  {
378          if (!iso_connect(server))          unsigned int i;
379    
380            if (!iso_connect(server, username))
381                  return False;                  return False;
382    
383          mcs_send_connect_initial(mcs_data);          mcs_send_connect_initial(mcs_data);
# Line 367  mcs_connect(char *server, STREAM mcs_dat Line 387  mcs_connect(char *server, STREAM mcs_dat
387          mcs_send_edrq();          mcs_send_edrq();
388    
389          mcs_send_aurq();          mcs_send_aurq();
390          if (!mcs_recv_aucf(&mcs_userid))          if (!mcs_recv_aucf(&g_mcs_userid))
391                  goto error;                  goto error;
392    
393          mcs_send_cjrq(mcs_userid + 1001);          mcs_send_cjrq(g_mcs_userid + MCS_USERCHANNEL_BASE);
394    
395          if (!mcs_recv_cjcf())          if (!mcs_recv_cjcf())
396                  goto error;                  goto error;
397    
# Line 378  mcs_connect(char *server, STREAM mcs_dat Line 399  mcs_connect(char *server, STREAM mcs_dat
399          if (!mcs_recv_cjcf())          if (!mcs_recv_cjcf())
400                  goto error;                  goto error;
401    
402            for (i = 0; i < g_num_channels; i++)
403            {
404                    mcs_send_cjrq(g_channels[i].mcs_id);
405                    if (!mcs_recv_cjcf())
406                            goto error;
407            }
408          return True;          return True;
409    
410        error:        error:
# Line 387  mcs_connect(char *server, STREAM mcs_dat Line 414  mcs_connect(char *server, STREAM mcs_dat
414    
415  /* Disconnect from the MCS layer */  /* Disconnect from the MCS layer */
416  void  void
417  mcs_disconnect()  mcs_disconnect(void)
418  {  {
419          iso_disconnect();          iso_disconnect();
420  }  }
Legend:
Removed from v.25  
changed lines
  Added in v.432
  ViewVC Help
Powered by ViewVC 1.1.26