328ca92727731f34f8deb5749d13c04940cc6f0e
[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
557         return True;
558 }
559
560 /****************************************************************************
561  Wrapper for receive_smb_raw().
562  Checks the MAC on signed packets.
563 ****************************************************************************/
564
565 BOOL receive_smb(int fd,char *buffer, unsigned int timeout)
566 {
567         if (!receive_smb_raw(fd, buffer, timeout)) {
568                 return False;
569         }
570
571         /* Check the incoming SMB signature. */
572         if (!srv_check_sign_mac(buffer)) {
573                 DEBUG(0, ("receive_smb: SMB Signature verification failed on incoming packet!\n"));
574                 if (smb_read_error == 0)
575                         smb_read_error = READ_BAD_SIG;
576                 return False;
577         };
578
579         return(True);
580 }
581
582 /****************************************************************************
583  Send an smb to a fd.
584 ****************************************************************************/
585
586 BOOL send_smb(int fd,char *buffer)
587 {
588         size_t len;
589         size_t nwritten=0;
590         ssize_t ret;
591
592         /* Sign the outgoing packet if required. */
593         srv_calculate_sign_mac(buffer);
594
595         len = smb_len(buffer) + 4;
596
597         while (nwritten < len) {
598                 ret = write_socket(fd,buffer+nwritten,len - nwritten);
599                 if (ret <= 0) {
600                         DEBUG(0,("Error writing %d bytes to client. %d. (%s)\n",
601                                 (int)len,(int)ret, strerror(errno) ));
602                         return False;
603                 }
604                 nwritten += ret;
605         }
606
607         return True;
608 }
609
610 /****************************************************************************
611  Open a socket of the specified type, port, and address for incoming data.
612 ****************************************************************************/
613
614 int open_socket_in( int type, int port, int dlevel, uint32 socket_addr, BOOL rebind )
615 {
616         struct sockaddr_in sock;
617         int res;
618
619         memset( (char *)&sock, '\0', sizeof(sock) );
620
621 #ifdef HAVE_SOCK_SIN_LEN
622         sock.sin_len         = sizeof(sock);
623 #endif
624         sock.sin_port        = htons( port );
625         sock.sin_family      = AF_INET;
626         sock.sin_addr.s_addr = socket_addr;
627
628         res = socket( AF_INET, type, 0 );
629         if( res == -1 ) {
630                 if( DEBUGLVL(0) ) {
631                         dbgtext( "open_socket_in(): socket() call failed: " );
632                         dbgtext( "%s\n", strerror( errno ) );
633                 }
634                 return -1;
635         }
636
637         /* This block sets/clears the SO_REUSEADDR and possibly SO_REUSEPORT. */
638         {
639                 int val = rebind ? 1 : 0;
640                 if( setsockopt(res,SOL_SOCKET,SO_REUSEADDR,(char *)&val,sizeof(val)) == -1 ) {
641                         if( DEBUGLVL( dlevel ) ) {
642                                 dbgtext( "open_socket_in(): setsockopt: " );
643                                 dbgtext( "SO_REUSEADDR = %s ", val?"True":"False" );
644                                 dbgtext( "on port %d failed ", port );
645                                 dbgtext( "with error = %s\n", strerror(errno) );
646                         }
647                 }
648 #ifdef SO_REUSEPORT
649                 if( setsockopt(res,SOL_SOCKET,SO_REUSEPORT,(char *)&val,sizeof(val)) == -1 ) {
650                         if( DEBUGLVL( dlevel ) ) {
651                                 dbgtext( "open_socket_in(): setsockopt: ");
652                                 dbgtext( "SO_REUSEPORT = %s ", val?"True":"False" );
653                                 dbgtext( "on port %d failed ", port );
654                                 dbgtext( "with error = %s\n", strerror(errno) );
655                         }
656                 }
657 #endif /* SO_REUSEPORT */
658         }
659
660         /* now we've got a socket - we need to bind it */
661         if( bind( res, (struct sockaddr *)&sock, sizeof(sock) ) == -1 ) {
662                 if( DEBUGLVL(dlevel) && (port == SMB_PORT1 || port == SMB_PORT2 || port == NMB_PORT) ) {
663                         dbgtext( "bind failed on port %d ", port );
664                         dbgtext( "socket_addr = %s.\n", inet_ntoa( sock.sin_addr ) );
665                         dbgtext( "Error = %s\n", strerror(errno) );
666                 }
667                 close( res ); 
668                 return( -1 ); 
669         }
670
671         DEBUG( 10, ( "bind succeeded on port %d\n", port ) );
672
673         return( res );
674  }
675
676 /****************************************************************************
677  Create an outgoing socket. timeout is in milliseconds.
678 **************************************************************************/
679
680 int open_socket_out(int type, struct in_addr *addr, int port ,int timeout)
681 {
682         struct sockaddr_in sock_out;
683         int res,ret;
684         int connect_loop = 10;
685         int increment = 10;
686
687         /* create a socket to write to */
688         res = socket(PF_INET, type, 0);
689         if (res == -1) {
690                 DEBUG(0,("socket error\n"));
691                 return -1;
692         }
693
694         if (type != SOCK_STREAM)
695                 return(res);
696   
697         memset((char *)&sock_out,'\0',sizeof(sock_out));
698         putip((char *)&sock_out.sin_addr,(char *)addr);
699   
700         sock_out.sin_port = htons( port );
701         sock_out.sin_family = PF_INET;
702
703         /* set it non-blocking */
704         set_blocking(res,False);
705
706         DEBUG(3,("Connecting to %s at port %d\n",inet_ntoa(*addr),port));
707   
708         /* and connect it to the destination */
709   connect_again:
710
711         ret = connect(res,(struct sockaddr *)&sock_out,sizeof(sock_out));
712
713         /* Some systems return EAGAIN when they mean EINPROGRESS */
714         if (ret < 0 && (errno == EINPROGRESS || errno == EALREADY ||
715                         errno == EAGAIN) && (connect_loop < timeout) ) {
716                 msleep(connect_loop);
717                 connect_loop += increment;
718                 if (increment < 250) {
719                         /* After 8 rounds we end up at a max of 255 msec */
720                         increment *= 1.5;
721                 }
722                 goto connect_again;
723         }
724
725         if (ret < 0 && (errno == EINPROGRESS || errno == EALREADY ||
726                         errno == EAGAIN)) {
727                 DEBUG(1,("timeout connecting to %s:%d\n",inet_ntoa(*addr),port));
728                 close(res);
729                 return -1;
730         }
731
732 #ifdef EISCONN
733
734         if (ret < 0 && errno == EISCONN) {
735                 errno = 0;
736                 ret = 0;
737         }
738 #endif
739
740         if (ret < 0) {
741                 DEBUG(2,("error connecting to %s:%d (%s)\n",
742                                 inet_ntoa(*addr),port,strerror(errno)));
743                 close(res);
744                 return -1;
745         }
746
747         /* set it blocking again */
748         set_blocking(res,True);
749
750         return res;
751 }
752
753 /****************************************************************************
754  Open a connected UDP socket to host on port
755 **************************************************************************/
756
757 int open_udp_socket(const char *host, int port)
758 {
759         int type = SOCK_DGRAM;
760         struct sockaddr_in sock_out;
761         int res;
762         struct in_addr *addr;
763
764         addr = interpret_addr2(host);
765
766         res = socket(PF_INET, type, 0);
767         if (res == -1) {
768                 return -1;
769         }
770
771         memset((char *)&sock_out,'\0',sizeof(sock_out));
772         putip((char *)&sock_out.sin_addr,(char *)addr);
773         sock_out.sin_port = htons(port);
774         sock_out.sin_family = PF_INET;
775
776         if (connect(res,(struct sockaddr *)&sock_out,sizeof(sock_out))) {
777                 close(res);
778                 return -1;
779         }
780
781         return res;
782 }
783
784
785 /* the following 3 client_*() functions are nasty ways of allowing
786    some generic functions to get info that really should be hidden in
787    particular modules */
788 static int client_fd = -1;
789
790 void client_setfd(int fd)
791 {
792         client_fd = fd;
793 }
794
795 char *client_name(void)
796 {
797         return get_peer_name(client_fd,False);
798 }
799
800 char *client_addr(void)
801 {
802         return get_peer_addr(client_fd);
803 }
804
805 char *client_socket_addr(void)
806 {
807         return get_socket_addr(client_fd);
808 }
809
810 struct in_addr *client_inaddr(struct sockaddr *sa)
811 {
812         struct sockaddr_in *sockin = (struct sockaddr_in *) (sa);
813         int     length = sizeof(*sa);
814         
815         if (getpeername(client_fd, sa, &length) < 0) {
816                 DEBUG(0,("getpeername failed. Error was %s\n", strerror(errno) ));
817                 return NULL;
818         }
819         
820         return &sockin->sin_addr;
821 }
822
823 /*******************************************************************
824  Matchname - determine if host name matches IP address. Used to
825  confirm a hostname lookup to prevent spoof attacks.
826 ******************************************************************/
827
828 static BOOL matchname(char *remotehost,struct in_addr  addr)
829 {
830         struct hostent *hp;
831         int     i;
832         
833         if ((hp = sys_gethostbyname(remotehost)) == 0) {
834                 DEBUG(0,("sys_gethostbyname(%s): lookup failure.\n", remotehost));
835                 return False;
836         } 
837
838         /*
839          * Make sure that gethostbyname() returns the "correct" host name.
840          * Unfortunately, gethostbyname("localhost") sometimes yields
841          * "localhost.domain". Since the latter host name comes from the
842          * local DNS, we just have to trust it (all bets are off if the local
843          * DNS is perverted). We always check the address list, though.
844          */
845         
846         if (!strequal(remotehost, hp->h_name)
847             && !strequal(remotehost, "localhost")) {
848                 DEBUG(0,("host name/name mismatch: %s != %s\n",
849                          remotehost, hp->h_name));
850                 return False;
851         }
852         
853         /* Look up the host address in the address list we just got. */
854         for (i = 0; hp->h_addr_list[i]; i++) {
855                 if (memcmp(hp->h_addr_list[i], (char *) & addr, sizeof(addr)) == 0)
856                         return True;
857         }
858         
859         /*
860          * The host name does not map to the original host address. Perhaps
861          * someone has compromised a name server. More likely someone botched
862          * it, but that could be dangerous, too.
863          */
864         
865         DEBUG(0,("host name/address mismatch: %s != %s\n",
866                  inet_ntoa(addr), hp->h_name));
867         return False;
868 }
869
870 /*******************************************************************
871  Return the DNS name of the remote end of a socket.
872 ******************************************************************/
873
874 char *get_peer_name(int fd, BOOL force_lookup)
875 {
876         static pstring name_buf;
877         pstring tmp_name;
878         static fstring addr_buf;
879         struct hostent *hp;
880         struct in_addr addr;
881         char *p;
882
883         /* reverse lookups can be *very* expensive, and in many
884            situations won't work because many networks don't link dhcp
885            with dns. To avoid the delay we avoid the lookup if
886            possible */
887         if (!lp_hostname_lookups() && (force_lookup == False)) {
888                 return get_peer_addr(fd);
889         }
890         
891         p = get_peer_addr(fd);
892
893         /* it might be the same as the last one - save some DNS work */
894         if (strcmp(p, addr_buf) == 0) 
895                 return name_buf;
896
897         pstrcpy(name_buf,"UNKNOWN");
898         if (fd == -1) 
899                 return name_buf;
900
901         fstrcpy(addr_buf, p);
902
903         addr = *interpret_addr2(p);
904         
905         /* Look up the remote host name. */
906         if ((hp = gethostbyaddr((char *)&addr.s_addr, sizeof(addr.s_addr), AF_INET)) == 0) {
907                 DEBUG(1,("Gethostbyaddr failed for %s\n",p));
908                 pstrcpy(name_buf, p);
909         } else {
910                 pstrcpy(name_buf,(char *)hp->h_name);
911                 if (!matchname(name_buf, addr)) {
912                         DEBUG(0,("Matchname failed on %s %s\n",name_buf,p));
913                         pstrcpy(name_buf,"UNKNOWN");
914                 }
915         }
916
917         /* can't pass the same source and dest strings in when you 
918            use --enable-developer or the clobber_region() call will 
919            get you */
920         
921         pstrcpy( tmp_name, name_buf );
922         alpha_strcpy(name_buf, tmp_name, "_-.", sizeof(name_buf));
923         if (strstr(name_buf,"..")) {
924                 pstrcpy(name_buf, "UNKNOWN");
925         }
926
927         return name_buf;
928 }
929
930 /*******************************************************************
931  Return the IP addr of the remote end of a socket as a string.
932  ******************************************************************/
933
934 char *get_peer_addr(int fd)
935 {
936         struct sockaddr sa;
937         struct sockaddr_in *sockin = (struct sockaddr_in *) (&sa);
938         int     length = sizeof(sa);
939         static fstring addr_buf;
940
941         fstrcpy(addr_buf,"0.0.0.0");
942
943         if (fd == -1) {
944                 return addr_buf;
945         }
946         
947         if (getpeername(fd, &sa, &length) < 0) {
948                 DEBUG(0,("getpeername failed. Error was %s\n", strerror(errno) ));
949                 return addr_buf;
950         }
951         
952         fstrcpy(addr_buf,(char *)inet_ntoa(sockin->sin_addr));
953         
954         return addr_buf;
955 }
956
957 char *get_socket_addr(int fd)
958 {
959         struct sockaddr sa;
960         struct sockaddr_in *sockin = (struct sockaddr_in *) (&sa);
961         int     length = sizeof(sa);
962         static fstring addr_buf;
963
964         fstrcpy(addr_buf,"0.0.0.0");
965
966         if (fd == -1) {
967                 return addr_buf;
968         }
969         
970         if (getsockname(fd, &sa, &length) < 0) {
971                 DEBUG(0,("getpeername failed. Error was %s\n", strerror(errno) ));
972                 return addr_buf;
973         }
974         
975         fstrcpy(addr_buf,(char *)inet_ntoa(sockin->sin_addr));
976         
977         return addr_buf;
978 }
979
980 /*******************************************************************
981  Create protected unix domain socket.
982
983  Some unixes cannot set permissions on a ux-dom-sock, so we
984  have to make sure that the directory contains the protection
985  permissions instead.
986  ******************************************************************/
987
988 int create_pipe_sock(const char *socket_dir,
989                      const char *socket_name,
990                      mode_t dir_perms)
991 {
992 #ifdef HAVE_UNIXSOCKET
993         struct sockaddr_un sunaddr;
994         struct stat st;
995         int sock;
996         mode_t old_umask;
997         pstring path;
998         
999         old_umask = umask(0);
1000         
1001         /* Create the socket directory or reuse the existing one */
1002         
1003         if (lstat(socket_dir, &st) == -1) {
1004                 if (errno == ENOENT) {
1005                         /* Create directory */
1006                         if (mkdir(socket_dir, dir_perms) == -1) {
1007                                 DEBUG(0, ("error creating socket directory "
1008                                         "%s: %s\n", socket_dir, 
1009                                         strerror(errno)));
1010                                 goto out_umask;
1011                         }
1012                 } else {
1013                         DEBUG(0, ("lstat failed on socket directory %s: %s\n",
1014                                 socket_dir, strerror(errno)));
1015                         goto out_umask;
1016                 }
1017         } else {
1018                 /* Check ownership and permission on existing directory */
1019                 if (!S_ISDIR(st.st_mode)) {
1020                         DEBUG(0, ("socket directory %s isn't a directory\n",
1021                                 socket_dir));
1022                         goto out_umask;
1023                 }
1024                 if ((st.st_uid != sec_initial_uid()) || 
1025                                 ((st.st_mode & 0777) != dir_perms)) {
1026                         DEBUG(0, ("invalid permissions on socket directory "
1027                                 "%s\n", socket_dir));
1028                         goto out_umask;
1029                 }
1030         }
1031         
1032         /* Create the socket file */
1033         
1034         sock = socket(AF_UNIX, SOCK_STREAM, 0);
1035         
1036         if (sock == -1) {
1037                 perror("socket");
1038                 goto out_umask;
1039         }
1040         
1041         pstr_sprintf(path, "%s/%s", socket_dir, socket_name);
1042         
1043         unlink(path);
1044         memset(&sunaddr, 0, sizeof(sunaddr));
1045         sunaddr.sun_family = AF_UNIX;
1046         safe_strcpy(sunaddr.sun_path, path, sizeof(sunaddr.sun_path)-1);
1047         
1048         if (bind(sock, (struct sockaddr *)&sunaddr, sizeof(sunaddr)) == -1) {
1049                 DEBUG(0, ("bind failed on pipe socket %s: %s\n", path,
1050                         strerror(errno)));
1051                 goto out_close;
1052         }
1053         
1054         if (listen(sock, 5) == -1) {
1055                 DEBUG(0, ("listen failed on pipe socket %s: %s\n", path,
1056                         strerror(errno)));
1057                 goto out_close;
1058         }
1059         
1060         umask(old_umask);
1061         return sock;
1062
1063 out_close:
1064         close(sock);
1065
1066 out_umask:
1067         umask(old_umask);
1068         return -1;
1069
1070 #else
1071         DEBUG(0, ("create_pipe_sock: No Unix sockets on this system\n"));
1072         return -1;
1073 #endif /* HAVE_UNIXSOCKET */
1074 }