there are places in the samba3 code that don't check properly for
[bbaumbach/samba-autobuild/.git] / source3 / lib / util_sock.c
1 /* 
2    Unix SMB/CIFS implementation.
3    Samba utility functions
4    Copyright (C) Andrew Tridgell 1992-1998
5    Copyright (C) Tim Potter      2000-2001
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
22 #include "includes.h"
23
24 /* the last IP received from */
25 struct in_addr lastip;
26
27 /* the last port received from */
28 int lastport=0;
29
30 int smb_read_error = 0;
31
32 /****************************************************************************
33  Determine if a file descriptor is in fact a socket.
34 ****************************************************************************/
35
36 BOOL is_a_socket(int fd)
37 {
38         int v,l;
39         l = sizeof(int);
40         return(getsockopt(fd, SOL_SOCKET, SO_TYPE, (char *)&v, &l) == 0);
41 }
42
43 enum SOCK_OPT_TYPES {OPT_BOOL,OPT_INT,OPT_ON};
44
45 typedef struct smb_socket_option {
46         const char *name;
47         int level;
48         int option;
49         int value;
50         int opttype;
51 } smb_socket_option;
52
53 static const smb_socket_option socket_options[] = {
54   {"SO_KEEPALIVE",      SOL_SOCKET,    SO_KEEPALIVE,    0,                 OPT_BOOL},
55   {"SO_REUSEADDR",      SOL_SOCKET,    SO_REUSEADDR,    0,                 OPT_BOOL},
56   {"SO_BROADCAST",      SOL_SOCKET,    SO_BROADCAST,    0,                 OPT_BOOL},
57 #ifdef TCP_NODELAY
58   {"TCP_NODELAY",       IPPROTO_TCP,   TCP_NODELAY,     0,                 OPT_BOOL},
59 #endif
60 #ifdef IPTOS_LOWDELAY
61   {"IPTOS_LOWDELAY",    IPPROTO_IP,    IP_TOS,          IPTOS_LOWDELAY,    OPT_ON},
62 #endif
63 #ifdef IPTOS_THROUGHPUT
64   {"IPTOS_THROUGHPUT",  IPPROTO_IP,    IP_TOS,          IPTOS_THROUGHPUT,  OPT_ON},
65 #endif
66 #ifdef SO_REUSEPORT
67   {"SO_REUSEPORT",      SOL_SOCKET,    SO_REUSEPORT,    0,                 OPT_BOOL},
68 #endif
69 #ifdef SO_SNDBUF
70   {"SO_SNDBUF",         SOL_SOCKET,    SO_SNDBUF,       0,                 OPT_INT},
71 #endif
72 #ifdef SO_RCVBUF
73   {"SO_RCVBUF",         SOL_SOCKET,    SO_RCVBUF,       0,                 OPT_INT},
74 #endif
75 #ifdef SO_SNDLOWAT
76   {"SO_SNDLOWAT",       SOL_SOCKET,    SO_SNDLOWAT,     0,                 OPT_INT},
77 #endif
78 #ifdef SO_RCVLOWAT
79   {"SO_RCVLOWAT",       SOL_SOCKET,    SO_RCVLOWAT,     0,                 OPT_INT},
80 #endif
81 #ifdef SO_SNDTIMEO
82   {"SO_SNDTIMEO",       SOL_SOCKET,    SO_SNDTIMEO,     0,                 OPT_INT},
83 #endif
84 #ifdef SO_RCVTIMEO
85   {"SO_RCVTIMEO",       SOL_SOCKET,    SO_RCVTIMEO,     0,                 OPT_INT},
86 #endif
87   {NULL,0,0,0,0}};
88
89 /****************************************************************************
90  Print socket options.
91 ****************************************************************************/
92
93 static void print_socket_options(int s)
94 {
95         int value, vlen = 4;
96         const smb_socket_option *p = &socket_options[0];
97
98         /* wrapped in if statement to prevent streams leak in SCO Openserver 5.0 */
99         /* reported on samba-technical  --jerry */
100         if ( DEBUGLEVEL >= 5 ) {
101         for (; p->name != NULL; p++) {
102                 if (getsockopt(s, p->level, p->option, (void *)&value, &vlen) == -1) {
103                         DEBUG(5,("Could not test socket option %s.\n", p->name));
104                 } else {
105                         DEBUG(5,("socket option %s = %d\n",p->name,value));
106                         }
107                 }
108         }
109  }
110
111 /****************************************************************************
112  Set user socket options.
113 ****************************************************************************/
114
115 void set_socket_options(int fd, const char *options)
116 {
117         fstring tok;
118
119         while (next_token(&options,tok," \t,", sizeof(tok))) {
120                 int ret=0,i;
121                 int value = 1;
122                 char *p;
123                 BOOL got_value = False;
124
125                 if ((p = strchr_m(tok,'='))) {
126                         *p = 0;
127                         value = atoi(p+1);
128                         got_value = True;
129                 }
130
131                 for (i=0;socket_options[i].name;i++)
132                         if (strequal(socket_options[i].name,tok))
133                                 break;
134
135                 if (!socket_options[i].name) {
136                         DEBUG(0,("Unknown socket option %s\n",tok));
137                         continue;
138                 }
139
140                 switch (socket_options[i].opttype) {
141                 case OPT_BOOL:
142                 case OPT_INT:
143                         ret = setsockopt(fd,socket_options[i].level,
144                                                 socket_options[i].option,(char *)&value,sizeof(int));
145                         break;
146
147                 case OPT_ON:
148                         if (got_value)
149                                 DEBUG(0,("syntax error - %s does not take a value\n",tok));
150
151                         {
152                                 int on = socket_options[i].value;
153                                 ret = setsockopt(fd,socket_options[i].level,
154                                                         socket_options[i].option,(char *)&on,sizeof(int));
155                         }
156                         break;    
157                 }
158       
159                 if (ret != 0)
160                         DEBUG(0,("Failed to set socket option %s (Error %s)\n",tok, strerror(errno) ));
161         }
162
163         print_socket_options(fd);
164 }
165
166 /****************************************************************************
167  Read from a socket.
168 ****************************************************************************/
169
170 ssize_t read_udp_socket(int fd,char *buf,size_t len)
171 {
172         ssize_t ret;
173         struct sockaddr_in sock;
174         socklen_t socklen = sizeof(sock);
175
176         memset((char *)&sock,'\0',socklen);
177         memset((char *)&lastip,'\0',sizeof(lastip));
178         ret = (ssize_t)sys_recvfrom(fd,buf,len,0,(struct sockaddr *)&sock,&socklen);
179         if (ret <= 0) {
180                 DEBUG(2,("read socket failed. ERRNO=%s\n",strerror(errno)));
181                 return(0);
182         }
183
184         lastip = sock.sin_addr;
185         lastport = ntohs(sock.sin_port);
186
187         DEBUG(10,("read_udp_socket: lastip %s lastport %d read: %lu\n",
188                         inet_ntoa(lastip), lastport, (unsigned long)ret));
189
190         return(ret);
191 }
192
193 /****************************************************************************
194  Read data from a socket with a timout in msec.
195  mincount = if timeout, minimum to read before returning
196  maxcount = number to be read.
197  time_out = timeout in milliseconds
198 ****************************************************************************/
199
200 ssize_t read_socket_with_timeout(int fd,char *buf,size_t mincnt,size_t maxcnt,unsigned int time_out)
201 {
202         fd_set fds;
203         int selrtn;
204         ssize_t readret;
205         size_t nread = 0;
206         struct timeval timeout;
207         
208         /* just checking .... */
209         if (maxcnt <= 0)
210                 return(0);
211         
212         smb_read_error = 0;
213         
214         /* Blocking read */
215         if (time_out <= 0) {
216                 if (mincnt == 0) mincnt = maxcnt;
217                 
218                 while (nread < mincnt) {
219                         readret = sys_read(fd, buf + nread, maxcnt - nread);
220                         
221                         if (readret == 0) {
222                                 DEBUG(5,("read_socket_with_timeout: blocking read. EOF from client.\n"));
223                                 smb_read_error = READ_EOF;
224                                 return -1;
225                         }
226                         
227                         if (readret == -1) {
228                                 DEBUG(0,("read_socket_with_timeout: read error = %s.\n", strerror(errno) ));
229                                 smb_read_error = READ_ERROR;
230                                 return -1;
231                         }
232                         nread += readret;
233                 }
234                 return((ssize_t)nread);
235         }
236         
237         /* Most difficult - timeout read */
238         /* If this is ever called on a disk file and 
239            mincnt is greater then the filesize then
240            system performance will suffer severely as 
241            select always returns true on disk files */
242         
243         /* Set initial timeout */
244         timeout.tv_sec = (time_t)(time_out / 1000);
245         timeout.tv_usec = (long)(1000 * (time_out % 1000));
246         
247         for (nread=0; nread < mincnt; ) {      
248                 FD_ZERO(&fds);
249                 FD_SET(fd,&fds);
250                 
251                 selrtn = sys_select_intr(fd+1,&fds,NULL,NULL,&timeout);
252                 
253                 /* Check if error */
254                 if (selrtn == -1) {
255                         /* something is wrong. Maybe the socket is dead? */
256                         DEBUG(0,("read_socket_with_timeout: timeout read. select error = %s.\n", strerror(errno) ));
257                         smb_read_error = READ_ERROR;
258                         return -1;
259                 }
260                 
261                 /* Did we timeout ? */
262                 if (selrtn == 0) {
263                         DEBUG(10,("read_socket_with_timeout: timeout read. select timed out.\n"));
264                         smb_read_error = READ_TIMEOUT;
265                         return -1;
266                 }
267                 
268                 readret = sys_read(fd, buf+nread, maxcnt-nread);
269                 
270                 if (readret == 0) {
271                         /* we got EOF on the file descriptor */
272                         DEBUG(5,("read_socket_with_timeout: timeout read. EOF from client.\n"));
273                         smb_read_error = READ_EOF;
274                         return -1;
275                 }
276                 
277                 if (readret == -1) {
278                         /* the descriptor is probably dead */
279                         DEBUG(0,("read_socket_with_timeout: timeout read. read error = %s.\n", strerror(errno) ));
280                         smb_read_error = READ_ERROR;
281                         return -1;
282                 }
283                 
284                 nread += readret;
285         }
286         
287         /* Return the number we got */
288         return (ssize_t)nread;
289 }
290
291 /****************************************************************************
292  Read data from the client, reading exactly N bytes. 
293 ****************************************************************************/
294
295 ssize_t read_data(int fd,char *buffer,size_t N)
296 {
297         ssize_t ret;
298         size_t total=0;  
299  
300         smb_read_error = 0;
301
302         while (total < N) {
303                 ret = sys_read(fd,buffer + total,N - total);
304
305                 if (ret == 0) {
306                         DEBUG(10,("read_data: read of %d returned 0. Error = %s\n", (int)(N - total), strerror(errno) ));
307                         smb_read_error = READ_EOF;
308                         return 0;
309                 }
310
311                 if (ret == -1) {
312                         DEBUG(0,("read_data: read failure for %d. Error = %s\n", (int)(N - total), strerror(errno) ));
313                         smb_read_error = READ_ERROR;
314                         return -1;
315                 }
316                 total += ret;
317         }
318         return (ssize_t)total;
319 }
320
321 /****************************************************************************
322  Read data from a socket, reading exactly N bytes. 
323 ****************************************************************************/
324
325 static ssize_t read_socket_data(int fd,char *buffer,size_t N)
326 {
327         ssize_t ret;
328         size_t total=0;  
329  
330         smb_read_error = 0;
331
332         while (total < N) {
333                 ret = sys_read(fd,buffer + total,N - total);
334
335                 if (ret == 0) {
336                         DEBUG(10,("read_socket_data: recv of %d returned 0. Error = %s\n", (int)(N - total), strerror(errno) ));
337                         smb_read_error = READ_EOF;
338                         return 0;
339                 }
340
341                 if (ret == -1) {
342                         DEBUG(0,("read_socket_data: recv failure for %d. Error = %s\n", (int)(N - total), strerror(errno) ));
343                         smb_read_error = READ_ERROR;
344                         return -1;
345                 }
346                 total += ret;
347         }
348         return (ssize_t)total;
349 }
350
351 /****************************************************************************
352  Write data to a fd.
353 ****************************************************************************/
354
355 ssize_t write_data(int fd,char *buffer,size_t N)
356 {
357         size_t total=0;
358         ssize_t ret;
359
360         while (total < N) {
361                 ret = sys_write(fd,buffer + total,N - total);
362
363                 if (ret == -1) {
364                         DEBUG(0,("write_data: write failure. Error = %s\n", strerror(errno) ));
365                         return -1;
366                 }
367                 if (ret == 0)
368                         return total;
369
370                 total += ret;
371         }
372         return (ssize_t)total;
373 }
374
375 /****************************************************************************
376  Write data to a socket - use send rather than write.
377 ****************************************************************************/
378
379 static ssize_t write_socket_data(int fd,char *buffer,size_t N)
380 {
381         size_t total=0;
382         ssize_t ret;
383
384         while (total < N) {
385                 ret = sys_send(fd,buffer + total,N - total,0);
386
387                 if (ret == -1) {
388                         DEBUG(0,("write_socket_data: write failure. Error = %s\n", strerror(errno) ));
389                         return -1;
390                 }
391                 if (ret == 0)
392                         return total;
393
394                 total += ret;
395         }
396         return (ssize_t)total;
397 }
398
399 /****************************************************************************
400  Write to a socket.
401 ****************************************************************************/
402
403 ssize_t write_socket(int fd,char *buf,size_t len)
404 {
405         ssize_t ret=0;
406
407         DEBUG(6,("write_socket(%d,%d)\n",fd,(int)len));
408         ret = write_socket_data(fd,buf,len);
409       
410         DEBUG(6,("write_socket(%d,%d) wrote %d\n",fd,(int)len,(int)ret));
411         if(ret <= 0)
412                 DEBUG(0,("write_socket: Error writing %d bytes to socket %d: ERRNO = %s\n", 
413                         (int)len, fd, strerror(errno) ));
414
415         return(ret);
416 }
417
418 /****************************************************************************
419  Send a keepalive packet (rfc1002).
420 ****************************************************************************/
421
422 BOOL send_keepalive(int client)
423 {
424         unsigned char buf[4];
425
426         buf[0] = SMBkeepalive;
427         buf[1] = buf[2] = buf[3] = 0;
428
429         return(write_socket_data(client,(char *)buf,4) == 4);
430 }
431
432
433 /****************************************************************************
434  Read 4 bytes of a smb packet and return the smb length of the packet.
435  Store the result in the buffer.
436  This version of the function will return a length of zero on receiving
437  a keepalive packet.
438  Timeout is in milliseconds.
439 ****************************************************************************/
440
441 static ssize_t read_smb_length_return_keepalive(int fd,char *inbuf,unsigned int timeout)
442 {
443         ssize_t len=0;
444         int msg_type;
445         BOOL ok = False;
446
447         while (!ok) {
448                 if (timeout > 0)
449                         ok = (read_socket_with_timeout(fd,inbuf,4,4,timeout) == 4);
450                 else 
451                         ok = (read_socket_data(fd,inbuf,4) == 4);
452
453                 if (!ok)
454                         return(-1);
455
456                 len = smb_len(inbuf);
457                 msg_type = CVAL(inbuf,0);
458
459                 if (msg_type == SMBkeepalive) 
460                         DEBUG(5,("Got keepalive packet\n"));
461         }
462
463         DEBUG(10,("got smb length of %lu\n",(unsigned long)len));
464
465         return(len);
466 }
467
468 /****************************************************************************
469  Read 4 bytes of a smb packet and return the smb length of the packet.
470  Store the result in the buffer. This version of the function will
471  never return a session keepalive (length of zero).
472  Timeout is in milliseconds.
473 ****************************************************************************/
474
475 ssize_t read_smb_length(int fd,char *inbuf,unsigned int timeout)
476 {
477         ssize_t len;
478
479         for(;;) {
480                 len = read_smb_length_return_keepalive(fd, inbuf, timeout);
481
482                 if(len < 0)
483                         return len;
484
485                 /* Ignore session keepalives. */
486                 if(CVAL(inbuf,0) != SMBkeepalive)
487                         break;
488         }
489
490         DEBUG(10,("read_smb_length: got smb length of %lu\n",
491                   (unsigned long)len));
492
493         return len;
494 }
495
496 /****************************************************************************
497  Read an smb from a fd. Note that the buffer *MUST* be of size
498  BUFFER_SIZE+SAFETY_MARGIN.
499  The timeout is in milliseconds. 
500  This function will return on receipt of a session keepalive packet.
501  Doesn't check the MAC on signed packets.
502 ****************************************************************************/
503
504 BOOL receive_smb_raw(int fd,char *buffer, unsigned int timeout)
505 {
506         ssize_t len,ret;
507
508         smb_read_error = 0;
509
510         memset(buffer,'\0',smb_size + 100);
511
512         len = read_smb_length_return_keepalive(fd,buffer,timeout);
513         if (len < 0) {
514                 DEBUG(10,("receive_smb_raw: length < 0!\n"));
515
516                 /*
517                  * Correct fix. smb_read_error may have already been
518                  * set. Only set it here if not already set. Global
519                  * variables still suck :-). JRA.
520                  */
521
522                 if (smb_read_error == 0)
523                         smb_read_error = READ_ERROR;
524                 return False;
525         }
526
527         /*
528          * A WRITEX with CAP_LARGE_WRITEX can be 64k worth of data plus 65 bytes
529          * of header. Don't print the error if this fits.... JRA.
530          */
531
532         if (len > (BUFFER_SIZE + LARGE_WRITEX_HDR_SIZE)) {
533                 DEBUG(0,("Invalid packet length! (%lu bytes).\n",(unsigned long)len));
534                 if (len > BUFFER_SIZE + (SAFETY_MARGIN/2)) {
535
536                         /*
537                          * Correct fix. smb_read_error may have already been
538                          * set. Only set it here if not already set. Global
539                          * variables still suck :-). JRA.
540                          */
541
542                         if (smb_read_error == 0)
543                                 smb_read_error = READ_ERROR;
544                         return False;
545                 }
546         }
547
548         if(len > 0) {
549                 ret = read_socket_data(fd,buffer+4,len);
550                 if (ret != len) {
551                         if (smb_read_error == 0)
552                                 smb_read_error = READ_ERROR;
553                         return False;
554                 }
555                 
556                 /* not all of samba3 properly checks for packet-termination of strings. This
557                    ensures that we don't run off into empty space. */
558                 SSVAL(buffer+4,len, 0);
559         }
560
561         return True;
562 }
563
564 /****************************************************************************
565  Wrapper for receive_smb_raw().
566  Checks the MAC on signed packets.
567 ****************************************************************************/
568
569 BOOL receive_smb(int fd,char *buffer, unsigned int timeout)
570 {
571         if (!receive_smb_raw(fd, buffer, timeout)) {
572                 return False;
573         }
574
575         /* Check the incoming SMB signature. */
576         if (!srv_check_sign_mac(buffer)) {
577                 DEBUG(0, ("receive_smb: SMB Signature verification failed on incoming packet!\n"));
578                 if (smb_read_error == 0)
579                         smb_read_error = READ_BAD_SIG;
580                 return False;
581         };
582
583         return(True);
584 }
585
586 /****************************************************************************
587  Send an smb to a fd.
588 ****************************************************************************/
589
590 BOOL send_smb(int fd,char *buffer)
591 {
592         size_t len;
593         size_t nwritten=0;
594         ssize_t ret;
595
596         /* Sign the outgoing packet if required. */
597         srv_calculate_sign_mac(buffer);
598
599         len = smb_len(buffer) + 4;
600
601         while (nwritten < len) {
602                 ret = write_socket(fd,buffer+nwritten,len - nwritten);
603                 if (ret <= 0) {
604                         DEBUG(0,("Error writing %d bytes to client. %d. (%s)\n",
605                                 (int)len,(int)ret, strerror(errno) ));
606                         return False;
607                 }
608                 nwritten += ret;
609         }
610
611         return True;
612 }
613
614 /****************************************************************************
615  Open a socket of the specified type, port, and address for incoming data.
616 ****************************************************************************/
617
618 int open_socket_in( int type, int port, int dlevel, uint32 socket_addr, BOOL rebind )
619 {
620         struct sockaddr_in sock;
621         int res;
622
623         memset( (char *)&sock, '\0', sizeof(sock) );
624
625 #ifdef HAVE_SOCK_SIN_LEN
626         sock.sin_len         = sizeof(sock);
627 #endif
628         sock.sin_port        = htons( port );
629         sock.sin_family      = AF_INET;
630         sock.sin_addr.s_addr = socket_addr;
631
632         res = socket( AF_INET, type, 0 );
633         if( res == -1 ) {
634                 if( DEBUGLVL(0) ) {
635                         dbgtext( "open_socket_in(): socket() call failed: " );
636                         dbgtext( "%s\n", strerror( errno ) );
637                 }
638                 return -1;
639         }
640
641         /* This block sets/clears the SO_REUSEADDR and possibly SO_REUSEPORT. */
642         {
643                 int val = rebind ? 1 : 0;
644                 if( setsockopt(res,SOL_SOCKET,SO_REUSEADDR,(char *)&val,sizeof(val)) == -1 ) {
645                         if( DEBUGLVL( dlevel ) ) {
646                                 dbgtext( "open_socket_in(): setsockopt: " );
647                                 dbgtext( "SO_REUSEADDR = %s ", val?"True":"False" );
648                                 dbgtext( "on port %d failed ", port );
649                                 dbgtext( "with error = %s\n", strerror(errno) );
650                         }
651                 }
652 #ifdef SO_REUSEPORT
653                 if( setsockopt(res,SOL_SOCKET,SO_REUSEPORT,(char *)&val,sizeof(val)) == -1 ) {
654                         if( DEBUGLVL( dlevel ) ) {
655                                 dbgtext( "open_socket_in(): setsockopt: ");
656                                 dbgtext( "SO_REUSEPORT = %s ", val?"True":"False" );
657                                 dbgtext( "on port %d failed ", port );
658                                 dbgtext( "with error = %s\n", strerror(errno) );
659                         }
660                 }
661 #endif /* SO_REUSEPORT */
662         }
663
664         /* now we've got a socket - we need to bind it */
665         if( bind( res, (struct sockaddr *)&sock, sizeof(sock) ) == -1 ) {
666                 if( DEBUGLVL(dlevel) && (port == SMB_PORT1 || port == SMB_PORT2 || port == NMB_PORT) ) {
667                         dbgtext( "bind failed on port %d ", port );
668                         dbgtext( "socket_addr = %s.\n", inet_ntoa( sock.sin_addr ) );
669                         dbgtext( "Error = %s\n", strerror(errno) );
670                 }
671                 close( res ); 
672                 return( -1 ); 
673         }
674
675         DEBUG( 10, ( "bind succeeded on port %d\n", port ) );
676
677         return( res );
678  }
679
680 /****************************************************************************
681  Create an outgoing socket. timeout is in milliseconds.
682 **************************************************************************/
683
684 int open_socket_out(int type, struct in_addr *addr, int port ,int timeout)
685 {
686         struct sockaddr_in sock_out;
687         int res,ret;
688         int connect_loop = 10;
689         int increment = 10;
690
691         /* create a socket to write to */
692         res = socket(PF_INET, type, 0);
693         if (res == -1) {
694                 DEBUG(0,("socket error\n"));
695                 return -1;
696         }
697
698         if (type != SOCK_STREAM)
699                 return(res);
700   
701         memset((char *)&sock_out,'\0',sizeof(sock_out));
702         putip((char *)&sock_out.sin_addr,(char *)addr);
703   
704         sock_out.sin_port = htons( port );
705         sock_out.sin_family = PF_INET;
706
707         /* set it non-blocking */
708         set_blocking(res,False);
709
710         DEBUG(3,("Connecting to %s at port %d\n",inet_ntoa(*addr),port));
711   
712         /* and connect it to the destination */
713   connect_again:
714
715         ret = connect(res,(struct sockaddr *)&sock_out,sizeof(sock_out));
716
717         /* Some systems return EAGAIN when they mean EINPROGRESS */
718         if (ret < 0 && (errno == EINPROGRESS || errno == EALREADY ||
719                         errno == EAGAIN) && (connect_loop < timeout) ) {
720                 msleep(connect_loop);
721                 connect_loop += increment;
722                 if (increment < 250) {
723                         /* After 8 rounds we end up at a max of 255 msec */
724                         increment *= 1.5;
725                 }
726                 goto connect_again;
727         }
728
729         if (ret < 0 && (errno == EINPROGRESS || errno == EALREADY ||
730                         errno == EAGAIN)) {
731                 DEBUG(1,("timeout connecting to %s:%d\n",inet_ntoa(*addr),port));
732                 close(res);
733                 return -1;
734         }
735
736 #ifdef EISCONN
737
738         if (ret < 0 && errno == EISCONN) {
739                 errno = 0;
740                 ret = 0;
741         }
742 #endif
743
744         if (ret < 0) {
745                 DEBUG(2,("error connecting to %s:%d (%s)\n",
746                                 inet_ntoa(*addr),port,strerror(errno)));
747                 close(res);
748                 return -1;
749         }
750
751         /* set it blocking again */
752         set_blocking(res,True);
753
754         return res;
755 }
756
757 /****************************************************************************
758  Open a connected UDP socket to host on port
759 **************************************************************************/
760
761 int open_udp_socket(const char *host, int port)
762 {
763         int type = SOCK_DGRAM;
764         struct sockaddr_in sock_out;
765         int res;
766         struct in_addr *addr;
767
768         addr = interpret_addr2(host);
769
770         res = socket(PF_INET, type, 0);
771         if (res == -1) {
772                 return -1;
773         }
774
775         memset((char *)&sock_out,'\0',sizeof(sock_out));
776         putip((char *)&sock_out.sin_addr,(char *)addr);
777         sock_out.sin_port = htons(port);
778         sock_out.sin_family = PF_INET;
779
780         if (connect(res,(struct sockaddr *)&sock_out,sizeof(sock_out))) {
781                 close(res);
782                 return -1;
783         }
784
785         return res;
786 }
787
788
789 /* the following 3 client_*() functions are nasty ways of allowing
790    some generic functions to get info that really should be hidden in
791    particular modules */
792 static int client_fd = -1;
793
794 void client_setfd(int fd)
795 {
796         client_fd = fd;
797 }
798
799 char *client_name(void)
800 {
801         return get_peer_name(client_fd,False);
802 }
803
804 char *client_addr(void)
805 {
806         return get_peer_addr(client_fd);
807 }
808
809 char *client_socket_addr(void)
810 {
811         return get_socket_addr(client_fd);
812 }
813
814 struct in_addr *client_inaddr(struct sockaddr *sa)
815 {
816         struct sockaddr_in *sockin = (struct sockaddr_in *) (sa);
817         int     length = sizeof(*sa);
818         
819         if (getpeername(client_fd, sa, &length) < 0) {
820                 DEBUG(0,("getpeername failed. Error was %s\n", strerror(errno) ));
821                 return NULL;
822         }
823         
824         return &sockin->sin_addr;
825 }
826
827 /*******************************************************************
828  Matchname - determine if host name matches IP address. Used to
829  confirm a hostname lookup to prevent spoof attacks.
830 ******************************************************************/
831
832 static BOOL matchname(char *remotehost,struct in_addr  addr)
833 {
834         struct hostent *hp;
835         int     i;
836         
837         if ((hp = sys_gethostbyname(remotehost)) == 0) {
838                 DEBUG(0,("sys_gethostbyname(%s): lookup failure.\n", remotehost));
839                 return False;
840         } 
841
842         /*
843          * Make sure that gethostbyname() returns the "correct" host name.
844          * Unfortunately, gethostbyname("localhost") sometimes yields
845          * "localhost.domain". Since the latter host name comes from the
846          * local DNS, we just have to trust it (all bets are off if the local
847          * DNS is perverted). We always check the address list, though.
848          */
849         
850         if (!strequal(remotehost, hp->h_name)
851             && !strequal(remotehost, "localhost")) {
852                 DEBUG(0,("host name/name mismatch: %s != %s\n",
853                          remotehost, hp->h_name));
854                 return False;
855         }
856         
857         /* Look up the host address in the address list we just got. */
858         for (i = 0; hp->h_addr_list[i]; i++) {
859                 if (memcmp(hp->h_addr_list[i], (char *) & addr, sizeof(addr)) == 0)
860                         return True;
861         }
862         
863         /*
864          * The host name does not map to the original host address. Perhaps
865          * someone has compromised a name server. More likely someone botched
866          * it, but that could be dangerous, too.
867          */
868         
869         DEBUG(0,("host name/address mismatch: %s != %s\n",
870                  inet_ntoa(addr), hp->h_name));
871         return False;
872 }
873
874 /*******************************************************************
875  Return the DNS name of the remote end of a socket.
876 ******************************************************************/
877
878 char *get_peer_name(int fd, BOOL force_lookup)
879 {
880         static pstring name_buf;
881         pstring tmp_name;
882         static fstring addr_buf;
883         struct hostent *hp;
884         struct in_addr addr;
885         char *p;
886
887         /* reverse lookups can be *very* expensive, and in many
888            situations won't work because many networks don't link dhcp
889            with dns. To avoid the delay we avoid the lookup if
890            possible */
891         if (!lp_hostname_lookups() && (force_lookup == False)) {
892                 return get_peer_addr(fd);
893         }
894         
895         p = get_peer_addr(fd);
896
897         /* it might be the same as the last one - save some DNS work */
898         if (strcmp(p, addr_buf) == 0) 
899                 return name_buf;
900
901         pstrcpy(name_buf,"UNKNOWN");
902         if (fd == -1) 
903                 return name_buf;
904
905         fstrcpy(addr_buf, p);
906
907         addr = *interpret_addr2(p);
908         
909         /* Look up the remote host name. */
910         if ((hp = gethostbyaddr((char *)&addr.s_addr, sizeof(addr.s_addr), AF_INET)) == 0) {
911                 DEBUG(1,("Gethostbyaddr failed for %s\n",p));
912                 pstrcpy(name_buf, p);
913         } else {
914                 pstrcpy(name_buf,(char *)hp->h_name);
915                 if (!matchname(name_buf, addr)) {
916                         DEBUG(0,("Matchname failed on %s %s\n",name_buf,p));
917                         pstrcpy(name_buf,"UNKNOWN");
918                 }
919         }
920
921         /* can't pass the same source and dest strings in when you 
922            use --enable-developer or the clobber_region() call will 
923            get you */
924         
925         pstrcpy( tmp_name, name_buf );
926         alpha_strcpy(name_buf, tmp_name, "_-.", sizeof(name_buf));
927         if (strstr(name_buf,"..")) {
928                 pstrcpy(name_buf, "UNKNOWN");
929         }
930
931         return name_buf;
932 }
933
934 /*******************************************************************
935  Return the IP addr of the remote end of a socket as a string.
936  ******************************************************************/
937
938 char *get_peer_addr(int fd)
939 {
940         struct sockaddr sa;
941         struct sockaddr_in *sockin = (struct sockaddr_in *) (&sa);
942         int     length = sizeof(sa);
943         static fstring addr_buf;
944
945         fstrcpy(addr_buf,"0.0.0.0");
946
947         if (fd == -1) {
948                 return addr_buf;
949         }
950         
951         if (getpeername(fd, &sa, &length) < 0) {
952                 DEBUG(0,("getpeername failed. Error was %s\n", strerror(errno) ));
953                 return addr_buf;
954         }
955         
956         fstrcpy(addr_buf,(char *)inet_ntoa(sockin->sin_addr));
957         
958         return addr_buf;
959 }
960
961 char *get_socket_addr(int fd)
962 {
963         struct sockaddr sa;
964         struct sockaddr_in *sockin = (struct sockaddr_in *) (&sa);
965         int     length = sizeof(sa);
966         static fstring addr_buf;
967
968         fstrcpy(addr_buf,"0.0.0.0");
969
970         if (fd == -1) {
971                 return addr_buf;
972         }
973         
974         if (getsockname(fd, &sa, &length) < 0) {
975                 DEBUG(0,("getpeername failed. Error was %s\n", strerror(errno) ));
976                 return addr_buf;
977         }
978         
979         fstrcpy(addr_buf,(char *)inet_ntoa(sockin->sin_addr));
980         
981         return addr_buf;
982 }
983
984 /*******************************************************************
985  Create protected unix domain socket.
986
987  Some unixes cannot set permissions on a ux-dom-sock, so we
988  have to make sure that the directory contains the protection
989  permissions instead.
990  ******************************************************************/
991
992 int create_pipe_sock(const char *socket_dir,
993                      const char *socket_name,
994                      mode_t dir_perms)
995 {
996 #ifdef HAVE_UNIXSOCKET
997         struct sockaddr_un sunaddr;
998         struct stat st;
999         int sock;
1000         mode_t old_umask;
1001         pstring path;
1002         
1003         old_umask = umask(0);
1004         
1005         /* Create the socket directory or reuse the existing one */
1006         
1007         if (lstat(socket_dir, &st) == -1) {
1008                 if (errno == ENOENT) {
1009                         /* Create directory */
1010                         if (mkdir(socket_dir, dir_perms) == -1) {
1011                                 DEBUG(0, ("error creating socket directory "
1012                                         "%s: %s\n", socket_dir, 
1013                                         strerror(errno)));
1014                                 goto out_umask;
1015                         }
1016                 } else {
1017                         DEBUG(0, ("lstat failed on socket directory %s: %s\n",
1018                                 socket_dir, strerror(errno)));
1019                         goto out_umask;
1020                 }
1021         } else {
1022                 /* Check ownership and permission on existing directory */
1023                 if (!S_ISDIR(st.st_mode)) {
1024                         DEBUG(0, ("socket directory %s isn't a directory\n",
1025                                 socket_dir));
1026                         goto out_umask;
1027                 }
1028                 if ((st.st_uid != sec_initial_uid()) || 
1029                                 ((st.st_mode & 0777) != dir_perms)) {
1030                         DEBUG(0, ("invalid permissions on socket directory "
1031                                 "%s\n", socket_dir));
1032                         goto out_umask;
1033                 }
1034         }
1035         
1036         /* Create the socket file */
1037         
1038         sock = socket(AF_UNIX, SOCK_STREAM, 0);
1039         
1040         if (sock == -1) {
1041                 perror("socket");
1042                 goto out_umask;
1043         }
1044         
1045         pstr_sprintf(path, "%s/%s", socket_dir, socket_name);
1046         
1047         unlink(path);
1048         memset(&sunaddr, 0, sizeof(sunaddr));
1049         sunaddr.sun_family = AF_UNIX;
1050         safe_strcpy(sunaddr.sun_path, path, sizeof(sunaddr.sun_path)-1);
1051         
1052         if (bind(sock, (struct sockaddr *)&sunaddr, sizeof(sunaddr)) == -1) {
1053                 DEBUG(0, ("bind failed on pipe socket %s: %s\n", path,
1054                         strerror(errno)));
1055                 goto out_close;
1056         }
1057         
1058         if (listen(sock, 5) == -1) {
1059                 DEBUG(0, ("listen failed on pipe socket %s: %s\n", path,
1060                         strerror(errno)));
1061                 goto out_close;
1062         }
1063         
1064         umask(old_umask);
1065         return sock;
1066
1067 out_close:
1068         close(sock);
1069
1070 out_umask:
1071         umask(old_umask);
1072         return -1;
1073
1074 #else
1075         DEBUG(0, ("create_pipe_sock: No Unix sockets on this system\n"));
1076         return -1;
1077 #endif /* HAVE_UNIXSOCKET */
1078 }