source3/namepacket.c

   1 /*
   2    Unix SMB/Netbios implementation.
   3    Version 1.9.
   4    NBT netbios routines and daemon - version 2
   5    Copyright (C) Andrew Tridgell 1994-1995
   6
   7    This program is free software; you can redistribute it and/or modify
   8    it under the terms of the GNU General Public License as published by
   9    the Free Software Foundation; either version 2 of the License, or
  10    (at your option) any later version.
  11
  12    This program is distributed in the hope that it will be useful,
  13    but WITHOUT ANY WARRANTY; without even the implied warranty of
  14    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  15    GNU General Public License for more details.
  16
  17    You should have received a copy of the GNU General Public License
  18    along with this program; if not, write to the Free Software
  19    Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
  20
  21    Revision History:
  22
  23    14 jan 96: lkcl@pires.co.uk
  24    added multiple workgroup domain master support
  25
  26 */
  27
  28 #include "includes.h"
  29
  30 extern int ClientNMB;
  31 extern int ClientDGRAM;
  32
  33 extern int DEBUGLEVEL;
  34
  35 extern int num_response_packets;
  36
  37 BOOL CanRecurse = True;
  38 extern pstring scope;
  39 extern struct in_addr ipgrp;
  40
  41 static uint16 name_trn_id=0;
  42
  43
  44 /***************************************************************************
  45   updates the unique transaction identifier
  46   **************************************************************************/
  47 void debug_browse_data(char *outbuf, int len)
  48 {
  49     int i,j;
  50     for (i = 0; i < len; i+= 16)
  51       {
  52         DEBUG(4, ("%3x char ", i));
  53
  54         for (j = 0; j < 16; j++)
  55           {
  56             unsigned char x = outbuf[i+j];
  57             if (x < 32 || x > 127) x = '.';
  58
  59             if (i+j >= len) break;
  60             DEBUG(4, ("%c", x));
  61           }
  62
  63         DEBUG(4, (" hex ", i));
  64
  65         for (j = 0; j < 16; j++)
  66           {
  67             if (i+j >= len) break;
  68             DEBUG(4, (" %02x", outbuf[i+j]));
  69           }
  70
  71         DEBUG(4, ("\n"));
  72       }
  73
  74 }
  75
  76
  77 /***************************************************************************
  78   updates the unique transaction identifier
  79   **************************************************************************/
  80 static void update_name_trn_id(void)
  81 {
  82   if (!name_trn_id)
  83   {
  84     name_trn_id = (time(NULL)%(unsigned)0x7FFF) + (getpid()%(unsigned)100);
  85   }
  86   name_trn_id = (name_trn_id+1) % (unsigned)0x7FFF;
  87 }
  88
  89
  90 /****************************************************************************
  91   initiate a netbios packet
  92   ****************************************************************************/
  93 void initiate_netbios_packet(uint16 *id,
  94                                 int fd,int quest_type,char *name,int name_type,
  95                             int nb_flags,BOOL bcast,BOOL recurse,
  96                             struct in_addr to_ip)
  97 {
  98   struct packet_struct p;
  99   struct nmb_packet *nmb = &p.packet.nmb;
 100   struct res_rec additional_rec;
 101   char *packet_type = "unknown";
 102   int opcode = -1;
 103
 104   if (!id) return;
 105
 106   if (quest_type == NMB_STATUS) { packet_type = "nmb_status"; opcode = 0; }
 107   if (quest_type == NMB_QUERY ) { packet_type = "nmb_query"; opcode = 0; }
 108   if (quest_type == NMB_REG   ) { packet_type = "nmb_reg"; opcode = 5; }
 109   if (quest_type == NMB_REG_REFRESH ) { packet_type = "nmb_reg_refresh"; opcode = 9; }
 110   if (quest_type == NMB_REL   ) { packet_type = "nmb_rel"; opcode = 6; }
 111
 112   DEBUG(4,("initiating netbios packet: %s %s(%x) (bcast=%s) %s\n",
 113            packet_type, name, name_type, BOOLSTR(bcast), inet_ntoa(to_ip)));
 114
 115   if (opcode == -1) return;
 116
 117   bzero((char *)&p,sizeof(p));
 118
 119   if (*id == 0xffff) {
 120     update_name_trn_id();
 121     *id = name_trn_id; /* allow resending with same id */
 122   }
 123
 124   nmb->header.name_trn_id = *id;
 125   nmb->header.opcode = opcode;
 126   nmb->header.response = False;
 127
 128   nmb->header.nm_flags.bcast = bcast;
 129   nmb->header.nm_flags.recursion_available = False;
 130   nmb->header.nm_flags.recursion_desired = recurse;
 131   nmb->header.nm_flags.trunc = False;
 132   nmb->header.nm_flags.authoritative = False;
 133
 134   nmb->header.rcode = 0;
 135   nmb->header.qdcount = 1;
 136   nmb->header.ancount = 0;
 137   nmb->header.nscount = 0;
 138   nmb->header.arcount = (quest_type==NMB_REG ||
 139                          quest_type==NMB_REL ||
 140                          quest_type==NMB_REG_REFRESH) ? 1 : 0;
 141
 142   make_nmb_name(&nmb->question.question_name,name,name_type,scope);
 143
 144   nmb->question.question_type = quest_type;
 145   nmb->question.question_class = 0x1;
 146
 147   if (quest_type == NMB_REG ||
 148       quest_type == NMB_REG_REFRESH ||
 149       quest_type == NMB_REL)
 150     {
 151       nmb->additional = &additional_rec;
 152       bzero((char *)nmb->additional,sizeof(*nmb->additional));
 153
 154       nmb->additional->rr_name  = nmb->question.question_name;
 155       nmb->additional->rr_type  = nmb->question.question_type;
 156       nmb->additional->rr_class = nmb->question.question_class;
 157
 158       if (quest_type == NMB_REG || quest_type == NMB_REG_REFRESH)
 159         nmb->additional->ttl = lp_max_ttl();
 160       else
 161         nmb->additional->ttl = 0;
 162       nmb->additional->rdlength = 6;
 163       nmb->additional->rdata[0] = nb_flags;
 164       putip(&nmb->additional->rdata[2],(char *)iface_ip(to_ip));
 165     }
 166
 167   p.ip = to_ip;
 168   p.port = NMB_PORT;
 169   p.fd = fd;
 170   p.timestamp = time(NULL);
 171   p.packet_type = NMB_PACKET;
 172
 173   if (!send_packet(&p)) {
 174     DEBUG(3,("send_packet to %s %d failed\n",inet_ntoa(p.ip),p.port));
 175     *id = 0xffff;
 176   }
 177
 178   return;
 179 }
 180
 181
 182 /****************************************************************************
 183   reply to a netbios name packet
 184   ****************************************************************************/
 185 void reply_netbios_packet(struct packet_struct *p1,int trn_id,
 186                                 int rcode, int rcv_code, int opcode, BOOL recurse,
 187                                 struct nmb_name *rr_name,int rr_type,int rr_class,int ttl,
 188                                 char *data,int len)
 189 {
 190   struct packet_struct p;
 191   struct nmb_packet *nmb = &p.packet.nmb;
 192   struct res_rec answers;
 193   char *packet_type = "unknown";
 194   BOOL recursion_desired = False;
 195
 196   p = *p1;
 197
 198   switch (rcv_code)
 199   {
 200     case NMB_STATUS:
 201         {
 202       packet_type = "nmb_status";
 203       recursion_desired = True;
 204       break;
 205     }
 206     case NMB_QUERY:
 207         {
 208       packet_type = "nmb_query";
 209       recursion_desired = True;
 210       break;
 211     }
 212     case NMB_REG:
 213         {
 214       packet_type = "nmb_reg";
 215       recursion_desired = True;
 216       break;
 217     }
 218     case NMB_REL:
 219         {
 220       packet_type = "nmb_rel";
 221       recursion_desired = False;
 222       break;
 223     }
 224     case NMB_WAIT_ACK:
 225         {
 226       packet_type = "nmb_wack";
 227       recursion_desired = False;
 228       break;
 229     }
 230     default:
 231     {
 232       DEBUG(1,("replying netbios packet: %s %s\n",
 233                     packet_type, namestr(rr_name), inet_ntoa(p.ip)));
 234
 235       return;
 236     }
 237   }
 238
 239   DEBUG(4,("replying netbios packet: %s %s\n",
 240            packet_type, namestr(rr_name), inet_ntoa(p.ip)));
 241
 242   nmb->header.name_trn_id = trn_id;
 243   nmb->header.opcode = opcode;
 244   nmb->header.response = True;
 245   nmb->header.nm_flags.bcast = False;
 246   nmb->header.nm_flags.recursion_available = recurse;
 247   nmb->header.nm_flags.recursion_desired = recursion_desired;
 248   nmb->header.nm_flags.trunc = False;
 249   nmb->header.nm_flags.authoritative = True;
 250
 251   nmb->header.qdcount = 0;
 252   nmb->header.ancount = 1;
 253   nmb->header.nscount = 0;
 254   nmb->header.arcount = 0;
 255   nmb->header.rcode = rcode;
 256
 257   bzero((char*)&nmb->question,sizeof(nmb->question));
 258
 259   nmb->answers = &answers;
 260   bzero((char*)nmb->answers,sizeof(*nmb->answers));
 261
 262   nmb->answers->rr_name  = *rr_name;
 263   nmb->answers->rr_type  = rr_type;
 264   nmb->answers->rr_class = rr_class;
 265   nmb->answers->ttl      = ttl;
 266
 267   if (data && len)
 268     {
 269       nmb->answers->rdlength = len;
 270       memcpy(nmb->answers->rdata, data, len);
 271     }
 272
 273   p.packet_type = NMB_PACKET;
 274
 275   debug_nmb_packet(&p);
 276
 277   send_packet(&p);
 278 }
 279
 280
 281 /*******************************************************************
 282   the global packet linked-list. incoming entries are added to the
 283   end of this list.  it is supposed to remain fairly short so we
 284   won't bother with an end pointer.
 285   ******************************************************************/
 286 static struct packet_struct *packet_queue = NULL;
 287
 288 /*******************************************************************
 289   queue a packet into the packet queue
 290   ******************************************************************/
 291 void queue_packet(struct packet_struct *packet)
 292 {
 293   struct packet_struct *p;
 294
 295   if (!packet_queue) {
 296     packet->prev = NULL;
 297     packet->next = NULL;
 298     packet_queue = packet;
 299     return;
 300   }
 301
 302   /* find the bottom */
 303   for (p=packet_queue;p->next;p=p->next) ;
 304
 305   p->next = packet;
 306   packet->next = NULL;
 307   packet->prev = p;
 308 }
 309
 310 /****************************************************************************
 311   determine if a packet is for us. Note that to have any chance of
 312   being efficient we need to drop as many packets as possible at this
 313   stage as subsequent processing is expensive.
 314
 315   We also must make absolutely sure we don't tread on another machines
 316   property by answering a packet that is not for us.
 317   ****************************************************************************/
 318 static BOOL listening(struct packet_struct *p,struct nmb_name *n)
 319 {
 320   struct subnet_record *d;
 321   struct name_record *n1;
 322
 323   d = find_subnet(p->ip);
 324
 325   n1 = find_name_search(&d,n,FIND_LOCAL|FIND_WINS|FIND_SELF,p->ip);
 326
 327   return (n1 != NULL);
 328 }
 329
 330
 331 /****************************************************************************
 332   process udp 138 datagrams
 333   ****************************************************************************/
 334 static void process_dgram(struct packet_struct *p)
 335 {
 336   char *buf;
 337   char *buf2;
 338   int len;
 339   struct dgram_packet *dgram = &p->packet.dgram;
 340
 341   /* if we aren't listening to the destination name then ignore the packet */
 342   if (!listening(p,&dgram->dest_name))
 343     return;
 344
 345
 346   if (dgram->header.msg_type != 0x10 &&
 347       dgram->header.msg_type != 0x11 &&
 348       dgram->header.msg_type != 0x12) {
 349     /* don't process error packets etc yet */
 350     return;
 351   }
 352
 353   buf = &dgram->data[0];
 354   buf -= 4; /* XXXX for the pseudo tcp length -
 355                someday I need to get rid of this */
 356
 357   if (CVAL(buf,smb_com) != SMBtrans) return;
 358
 359   len = SVAL(buf,smb_vwv11);
 360   buf2 = smb_base(buf) + SVAL(buf,smb_vwv12);
 361
 362   DEBUG(4,("datagram from %s to %s for %s of type %d len=%d\n",
 363            namestr(&dgram->source_name),namestr(&dgram->dest_name),
 364            smb_buf(buf),CVAL(buf2,0),len));
 365
 366
 367   if (len <= 0) return;
 368
 369    /* datagram packet received for the browser mailslot */
 370    if (strequal(smb_buf(buf),BROWSE_MAILSLOT)) {
 371      process_browse_packet(p,buf2,len);
 372      return;
 373    }
 374
 375    /* datagram packet received for the domain log on mailslot */
 376    if (strequal(smb_buf(buf),NET_LOGON_MAILSLOT)) {
 377      process_logon_packet(p,buf2,len);
 378      return;
 379    }
 380 }
 381
 382 /****************************************************************************
 383   process a nmb packet
 384   ****************************************************************************/
 385 static void process_nmb(struct packet_struct *p)
 386 {
 387   struct nmb_packet *nmb = &p->packet.nmb;
 388
 389   debug_nmb_packet(p);
 390
 391   switch (nmb->header.opcode)
 392   {
 393     case 8: /* what is this?? */
 394     case NMB_REG:
 395     case NMB_REG_REFRESH:
 396     {
 397         if (nmb->header.qdcount==0 || nmb->header.arcount==0) break;
 398         if (nmb->header.response)
 399           response_netbios_packet(p); /* response to registration dealt
 400                                          with here */
 401         else
 402           reply_name_reg(p);
 403         break;
 404     }
 405
 406     case 0:
 407     {
 408           if (nmb->header.response)
 409           {
 410             switch (nmb->question.question_type)
 411               {
 412               case 0x0:
 413                 {
 414                   response_netbios_packet(p);
 415                   break;
 416                 }
 417               }
 418             return;
 419           }
 420       else if (nmb->header.qdcount>0)
 421           {
 422             switch (nmb->question.question_type)
 423               {
 424               case NMB_QUERY:
 425                 {
 426                   reply_name_query(p);
 427                   break;
 428                 }
 429               case NMB_STATUS:
 430                 {
 431                   reply_name_status(p);
 432                   break;
 433                 }
 434               }
 435             return;
 436           }
 437         break;
 438       }
 439
 440     case NMB_REL:
 441     {
 442       if (nmb->header.qdcount==0 || nmb->header.arcount==0)
 443           {
 444             DEBUG(2,("netbios release packet rejected\n"));
 445             break;
 446           }
 447
 448         if (nmb->header.response)
 449           response_netbios_packet(p); /* response to reply dealt with
 450                                          in here */
 451         else
 452           reply_name_release(p);
 453       break;
 454     }
 455   }
 456 }
 457
 458
 459 /*******************************************************************
 460   run elements off the packet queue till its empty
 461   ******************************************************************/
 462 void run_packet_queue()
 463 {
 464   struct packet_struct *p;
 465
 466   while ((p=packet_queue))
 467     {
 468       switch (p->packet_type)
 469         {
 470         case NMB_PACKET:
 471           process_nmb(p);
 472           break;
 473
 474         case DGRAM_PACKET:
 475           process_dgram(p);
 476           break;
 477         }
 478
 479       packet_queue = packet_queue->next;
 480       if (packet_queue) packet_queue->prev = NULL;
 481       free_packet(p);
 482     }
 483 }
 484
 485 /****************************************************************************
 486   listens for NMB or DGRAM packets, and queues them
 487   ***************************************************************************/
 488 void listen_for_packets(BOOL run_election)
 489 {
 490   fd_set fds;
 491   int selrtn;
 492   struct timeval timeout;
 493
 494 try_again:
 495
 496   FD_ZERO(&fds);
 497   FD_SET(ClientNMB,&fds);
 498   FD_SET(ClientDGRAM,&fds);
 499
 500   /* during elections and when expecting a netbios response packet we
 501      need to send election packets at tighter intervals
 502
 503      ideally it needs to be the interval (in ms) between time now and
 504      the time we are expecting the next netbios packet */
 505
 506   timeout.tv_sec = (run_election||num_response_packets) ? 1 : NMBD_SELECT_LOOP;
 507   timeout.tv_usec = 0;
 508
 509   selrtn = sys_select(&fds,&timeout);
 510
 511   if (FD_ISSET(ClientNMB,&fds))
 512     {
 513       struct packet_struct *packet = read_packet(ClientNMB, NMB_PACKET);
 514       if (packet) {
 515         if (ismyip(packet->ip) &&
 516             (packet->port == NMB_PORT || packet->port == DGRAM_PORT)) {
 517           DEBUG(7,("discarding own packet from %s:%d\n",
 518                    inet_ntoa(packet->ip),packet->port));
 519           free_packet(packet);
 520           goto try_again;
 521         } else {
 522           queue_packet(packet);
 523         }
 524       }
 525     }
 526
 527   if (FD_ISSET(ClientDGRAM,&fds))
 528     {
 529       struct packet_struct *packet = read_packet(ClientDGRAM, DGRAM_PACKET);
 530       if (packet) {
 531         if (ismyip(packet->ip) &&
 532               (packet->port == NMB_PORT || packet->port == DGRAM_PORT)) {
 533           DEBUG(7,("discarding own packet from %s:%d\n",
 534                    inet_ntoa(packet->ip),packet->port));
 535           free_packet(packet);
 536           goto try_again;
 537         } else {
 538           queue_packet(packet);
 539         }
 540       }
 541     }
 542 }
 543
 544
 545
 546 /****************************************************************************
 547   construct and send a netbios DGRAM
 548
 549   Note that this currently sends all answers to port 138. thats the
 550   wrong things to do! I should send to the requestors port. XXX
 551   **************************************************************************/
 552 BOOL send_mailslot_reply(char *mailslot,int fd,char *buf,int len,char *srcname,
 553                          char *dstname,int src_type,int dest_type,
 554                          struct in_addr dest_ip,struct in_addr src_ip)
 555 {
 556   struct packet_struct p;
 557   struct dgram_packet *dgram = &p.packet.dgram;
 558   struct in_addr wins_ip = ipgrp;
 559   char *ptr,*p2;
 560   char tmp[4];
 561
 562   /* ha ha. no. do NOT send packets to 255.255.255.255: it's a pseudo address */
 563   if (ip_equal(wins_ip, dest_ip)) return False;
 564
 565   bzero((char *)&p,sizeof(p));
 566
 567   update_name_trn_id();
 568
 569   dgram->header.msg_type = 0x11; /* DIRECT GROUP DATAGRAM */
 570   dgram->header.flags.node_type = M_NODE;
 571   dgram->header.flags.first = True;
 572   dgram->header.flags.more = False;
 573   dgram->header.dgm_id = name_trn_id;
 574   dgram->header.source_ip = src_ip;
 575   dgram->header.source_port = DGRAM_PORT;
 576   dgram->header.dgm_length = 0; /* let build_dgram() handle this */
 577   dgram->header.packet_offset = 0;
 578
 579   make_nmb_name(&dgram->source_name,srcname,src_type,scope);
 580   make_nmb_name(&dgram->dest_name,dstname,dest_type,scope);
 581
 582   ptr = &dgram->data[0];
 583
 584   /* now setup the smb part */
 585   ptr -= 4; /* XXX ugliness because of handling of tcp SMB length */
 586   memcpy(tmp,ptr,4);
 587   set_message(ptr,17,17 + len,True);
 588   memcpy(ptr,tmp,4);
 589
 590   CVAL(ptr,smb_com) = SMBtrans;
 591   SSVAL(ptr,smb_vwv1,len);
 592   SSVAL(ptr,smb_vwv11,len);
 593   SSVAL(ptr,smb_vwv12,70 + strlen(mailslot));
 594   SSVAL(ptr,smb_vwv13,3);
 595   SSVAL(ptr,smb_vwv14,1);
 596   SSVAL(ptr,smb_vwv15,1);
 597   SSVAL(ptr,smb_vwv16,2);
 598   p2 = smb_buf(ptr);
 599   strcpy(p2,mailslot);
 600   p2 = skip_string(p2,1);
 601
 602   memcpy(p2,buf,len);
 603   p2 += len;
 604
 605   dgram->datasize = PTR_DIFF(p2,ptr+4); /* +4 for tcp length */
 606
 607   p.ip = dest_ip;
 608   p.port = DGRAM_PORT;
 609   p.fd = ClientDGRAM;
 610   p.timestamp = time(NULL);
 611   p.packet_type = DGRAM_PACKET;
 612
 613   DEBUG(4,("send mailslot %s from %s %s", mailslot,
 614                     inet_ntoa(src_ip),namestr(&dgram->source_name)));
 615   DEBUG(4,("to %s %s\n", inet_ntoa(dest_ip),namestr(&dgram->dest_name)));
 616
 617   return(send_packet(&p));
 618 }