2 Unix SMB/CIFS implementation.
3 Samba utility functions
4 Copyright (C) Andrew Tridgell 1992-1998
5 Copyright (C) Jeremy Allison 2001-2007
6 Copyright (C) Simo Sorce 2001
7 Copyright (C) Jim McDonough <jmcd@us.ibm.com> 2003
8 Copyright (C) James Peach 2006
10 This program is free software; you can redistribute it and/or modify
11 it under the terms of the GNU General Public License as published by
12 the Free Software Foundation; either version 3 of the License, or
13 (at your option) any later version.
15 This program is distributed in the hope that it will be useful,
16 but WITHOUT ANY WARRANTY; without even the implied warranty of
17 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
18 GNU General Public License for more details.
20 You should have received a copy of the GNU General Public License
21 along with this program. If not, see <http://www.gnu.org/licenses/>.
25 #include "system/passwd.h"
26 #include "system/filesys.h"
28 #include "ctdbd_conn.h"
29 #include "../lib/util/util_pw.h"
31 #include <ccan/hash/hash.h>
32 #include "libcli/security/security.h"
35 #ifdef HAVE_SYS_PRCTL_H
36 #include <sys/prctl.h>
39 /* Max allowable allococation - 256mb - 0x10000000 */
40 #define MAX_ALLOC_SIZE (1024*1024*256)
42 #if (defined(HAVE_NETGROUP) && defined (WITH_AUTOMOUNT))
43 #ifdef WITH_NISPLUS_HOME
44 #ifdef BROKEN_NISPLUS_INCLUDE_FILES
46 * The following lines are needed due to buggy include files
47 * in Solaris 2.6 which define GROUP in both /usr/include/sys/acl.h and
48 * also in /usr/include/rpcsvc/nis.h. The definitions conflict. JRA.
49 * Also GROUP_OBJ is defined as 0x4 in /usr/include/sys/acl.h and as
50 * an enum in /usr/include/rpcsvc/nis.h.
57 #if defined(GROUP_OBJ)
61 #endif /* BROKEN_NISPLUS_INCLUDE_FILES */
63 #include <rpcsvc/nis.h>
65 #endif /* WITH_NISPLUS_HOME */
66 #endif /* HAVE_NETGROUP && WITH_AUTOMOUNT */
68 static enum protocol_types Protocol
= PROTOCOL_COREPLUS
;
70 enum protocol_types
get_Protocol(void)
75 void set_Protocol(enum protocol_types p
)
80 static enum remote_arch_types ra_type
= RA_UNKNOWN
;
82 void gfree_all( void )
91 /*******************************************************************
92 Check if a file exists - call vfs_file_exist for samba files.
93 ********************************************************************/
95 bool file_exist_stat(const char *fname
,SMB_STRUCT_STAT
*sbuf
,
96 bool fake_dir_create_times
)
102 if (sys_stat(fname
, sbuf
, fake_dir_create_times
) != 0)
105 return((S_ISREG(sbuf
->st_ex_mode
)) || (S_ISFIFO(sbuf
->st_ex_mode
)));
108 /*******************************************************************
109 Check if a unix domain socket exists - call vfs_file_exist for samba files.
110 ********************************************************************/
112 bool socket_exist(const char *fname
)
115 if (sys_stat(fname
, &st
, false) != 0)
118 return S_ISSOCK(st
.st_ex_mode
);
121 /*******************************************************************
122 Returns the size in bytes of the named given the stat struct.
123 ********************************************************************/
125 uint64_t get_file_size_stat(const SMB_STRUCT_STAT
*sbuf
)
127 return sbuf
->st_ex_size
;
130 /****************************************************************************
131 Check two stats have identical dev and ino fields.
132 ****************************************************************************/
134 bool check_same_dev_ino(const SMB_STRUCT_STAT
*sbuf1
,
135 const SMB_STRUCT_STAT
*sbuf2
)
137 if (sbuf1
->st_ex_dev
!= sbuf2
->st_ex_dev
||
138 sbuf1
->st_ex_ino
!= sbuf2
->st_ex_ino
) {
144 /****************************************************************************
145 Check if a stat struct is identical for use.
146 ****************************************************************************/
148 bool check_same_stat(const SMB_STRUCT_STAT
*sbuf1
,
149 const SMB_STRUCT_STAT
*sbuf2
)
151 if (sbuf1
->st_ex_uid
!= sbuf2
->st_ex_uid
||
152 sbuf1
->st_ex_gid
!= sbuf2
->st_ex_gid
||
153 !check_same_dev_ino(sbuf1
, sbuf2
)) {
159 /*******************************************************************
160 Show a smb message structure.
161 ********************************************************************/
163 void show_msg(const char *buf
)
171 DEBUG(5,("size=%d\nsmb_com=0x%x\nsmb_rcls=%d\nsmb_reh=%d\nsmb_err=%d\nsmb_flg=%d\nsmb_flg2=%d\n",
173 (int)CVAL(buf
,smb_com
),
174 (int)CVAL(buf
,smb_rcls
),
175 (int)CVAL(buf
,smb_reh
),
176 (int)SVAL(buf
,smb_err
),
177 (int)CVAL(buf
,smb_flg
),
178 (int)SVAL(buf
,smb_flg2
)));
179 DEBUGADD(5,("smb_tid=%d\nsmb_pid=%d\nsmb_uid=%d\nsmb_mid=%d\n",
180 (int)SVAL(buf
,smb_tid
),
181 (int)SVAL(buf
,smb_pid
),
182 (int)SVAL(buf
,smb_uid
),
183 (int)SVAL(buf
,smb_mid
)));
184 DEBUGADD(5,("smt_wct=%d\n",(int)CVAL(buf
,smb_wct
)));
186 for (i
=0;i
<(int)CVAL(buf
,smb_wct
);i
++)
187 DEBUGADD(5,("smb_vwv[%2d]=%5d (0x%X)\n",i
,
188 SVAL(buf
,smb_vwv
+2*i
),SVAL(buf
,smb_vwv
+2*i
)));
190 bcc
= (int)SVAL(buf
,smb_vwv
+2*(CVAL(buf
,smb_wct
)));
192 DEBUGADD(5,("smb_bcc=%d\n",bcc
));
200 dump_data(10, (const uint8
*)smb_buf_const(buf
), bcc
);
203 /*******************************************************************
204 Setup only the byte count for a smb message.
205 ********************************************************************/
207 int set_message_bcc(char *buf
,int num_bytes
)
209 int num_words
= CVAL(buf
,smb_wct
);
210 SSVAL(buf
,smb_vwv
+ num_words
*SIZEOFWORD
,num_bytes
);
211 _smb_setlen(buf
,smb_size
+ num_words
*2 + num_bytes
- 4);
212 return (smb_size
+ num_words
*2 + num_bytes
);
215 /*******************************************************************
216 Add a data blob to the end of a smb_buf, adjusting bcc and smb_len.
217 Return the bytes added
218 ********************************************************************/
220 ssize_t
message_push_blob(uint8
**outbuf
, DATA_BLOB blob
)
222 size_t newlen
= smb_len(*outbuf
) + 4 + blob
.length
;
225 if (!(tmp
= talloc_realloc(NULL
, *outbuf
, uint8
, newlen
))) {
226 DEBUG(0, ("talloc failed\n"));
231 memcpy(tmp
+ smb_len(tmp
) + 4, blob
.data
, blob
.length
);
232 set_message_bcc((char *)tmp
, smb_buflen(tmp
) + blob
.length
);
236 /*******************************************************************
237 Reduce a file name, removing .. elements.
238 ********************************************************************/
240 static char *dos_clean_name(TALLOC_CTX
*ctx
, const char *s
)
245 DEBUG(3,("dos_clean_name [%s]\n",s
));
247 /* remove any double slashes */
248 str
= talloc_all_string_sub(ctx
, s
, "\\\\", "\\");
253 /* Remove leading .\\ characters */
254 if(strncmp(str
, ".\\", 2) == 0) {
255 trim_string(str
, ".\\", NULL
);
257 str
= talloc_strdup(ctx
, ".\\");
264 while ((p
= strstr_m(str
,"\\..\\")) != NULL
) {
270 if ((p
=strrchr_m(str
,'\\')) != NULL
) {
275 str
= talloc_asprintf(ctx
,
284 trim_string(str
,NULL
,"\\..");
285 return talloc_all_string_sub(ctx
, str
, "\\.\\", "\\");
288 /*******************************************************************
289 Reduce a file name, removing .. elements.
290 ********************************************************************/
292 char *unix_clean_name(TALLOC_CTX
*ctx
, const char *s
)
297 DEBUG(3,("unix_clean_name [%s]\n",s
));
299 /* remove any double slashes */
300 str
= talloc_all_string_sub(ctx
, s
, "//","/");
305 /* Remove leading ./ characters */
306 if(strncmp(str
, "./", 2) == 0) {
307 trim_string(str
, "./", NULL
);
309 str
= talloc_strdup(ctx
, "./");
316 while ((p
= strstr_m(str
,"/../")) != NULL
) {
322 if ((p
=strrchr_m(str
,'/')) != NULL
) {
327 str
= talloc_asprintf(ctx
,
336 trim_string(str
,NULL
,"/..");
337 return talloc_all_string_sub(ctx
, str
, "/./", "/");
340 char *clean_name(TALLOC_CTX
*ctx
, const char *s
)
342 char *str
= dos_clean_name(ctx
, s
);
346 return unix_clean_name(ctx
, str
);
349 /*******************************************************************
350 Write data into an fd at a given offset. Ignore seek errors.
351 ********************************************************************/
353 ssize_t
write_data_at_offset(int fd
, const char *buffer
, size_t N
, off_t pos
)
358 if (pos
== (off_t
)-1) {
359 return write_data(fd
, buffer
, N
);
361 #if defined(HAVE_PWRITE) || defined(HAVE_PRWITE64)
363 ret
= sys_pwrite(fd
,buffer
+ total
,N
- total
, pos
);
364 if (ret
== -1 && errno
== ESPIPE
) {
365 return write_data(fd
, buffer
+ total
,N
- total
);
368 DEBUG(0,("write_data_at_offset: write failure. Error = %s\n", strerror(errno
) ));
377 return (ssize_t
)total
;
379 /* Use lseek and write_data. */
380 if (lseek(fd
, pos
, SEEK_SET
) == -1) {
381 if (errno
!= ESPIPE
) {
385 return write_data(fd
, buffer
, N
);
389 static int reinit_after_fork_pipe
[2] = { -1, -1 };
391 NTSTATUS
init_before_fork(void)
395 ret
= pipe(reinit_after_fork_pipe
);
399 status
= map_nt_error_from_unix_common(errno
);
401 DEBUG(0, ("Error creating child_pipe: %s\n",
411 * Detect died parent by detecting EOF on the pipe
413 static void reinit_after_fork_pipe_handler(struct tevent_context
*ev
,
414 struct tevent_fd
*fde
,
420 if (sys_read(reinit_after_fork_pipe
[0], &c
, 1) != 1) {
422 * we have reached EOF on stdin, which means the
423 * parent has exited. Shutdown the server
425 (void)kill(getpid(), SIGTERM
);
430 NTSTATUS
reinit_after_fork(struct messaging_context
*msg_ctx
,
431 struct tevent_context
*ev_ctx
,
432 bool parent_longlived
)
434 NTSTATUS status
= NT_STATUS_OK
;
436 if (reinit_after_fork_pipe
[1] != -1) {
437 close(reinit_after_fork_pipe
[1]);
438 reinit_after_fork_pipe
[1] = -1;
441 /* Reset the state of the random
442 * number generation system, so
443 * children do not get the same random
444 * numbers as each other */
445 set_need_random_reseed();
447 /* tdb needs special fork handling */
448 if (tdb_reopen_all(parent_longlived
? 1 : 0) != 0) {
449 DEBUG(0,("tdb_reopen_all failed.\n"));
450 status
= NT_STATUS_OPEN_FAILED
;
454 if (ev_ctx
&& tevent_re_initialise(ev_ctx
) != 0) {
455 smb_panic(__location__
": Failed to re-initialise event context");
458 if (reinit_after_fork_pipe
[0] != -1) {
459 struct tevent_fd
*fde
;
461 fde
= tevent_add_fd(ev_ctx
, ev_ctx
/* TALLOC_CTX */,
462 reinit_after_fork_pipe
[0], TEVENT_FD_READ
,
463 reinit_after_fork_pipe_handler
, NULL
);
465 smb_panic(__location__
": Failed to add reinit_after_fork pipe event");
471 * For clustering, we need to re-init our ctdbd connection after the
474 status
= messaging_reinit(msg_ctx
);
475 if (!NT_STATUS_IS_OK(status
)) {
476 DEBUG(0,("messaging_reinit() failed: %s\n",
484 /****************************************************************************
485 (Hopefully) efficient array append.
486 ****************************************************************************/
488 void add_to_large_array(TALLOC_CTX
*mem_ctx
, size_t element_size
,
489 void *element
, void *_array
, uint32
*num_elements
,
492 void **array
= (void **)_array
;
494 if (*array_size
< 0) {
498 if (*array
== NULL
) {
499 if (*array_size
== 0) {
503 if (*array_size
>= MAX_ALLOC_SIZE
/element_size
) {
507 *array
= TALLOC(mem_ctx
, element_size
* (*array_size
));
508 if (*array
== NULL
) {
513 if (*num_elements
== *array_size
) {
516 if (*array_size
>= MAX_ALLOC_SIZE
/element_size
) {
520 *array
= TALLOC_REALLOC(mem_ctx
, *array
,
521 element_size
* (*array_size
));
523 if (*array
== NULL
) {
528 memcpy((char *)(*array
) + element_size
*(*num_elements
),
529 element
, element_size
);
539 /****************************************************************************
540 Get my own domain name, or "" if we have none.
541 ****************************************************************************/
543 char *get_mydnsdomname(TALLOC_CTX
*ctx
)
548 domname
= get_mydnsfullname();
553 p
= strchr_m(domname
, '.');
556 return talloc_strdup(ctx
, p
);
558 return talloc_strdup(ctx
, "");
562 #if (defined(HAVE_NETGROUP) && defined(WITH_AUTOMOUNT))
563 /******************************************************************
564 Remove any mount options such as -rsize=2048,wsize=2048 etc.
565 Based on a fix from <Thomas.Hepper@icem.de>.
566 Returns a malloc'ed string.
567 *******************************************************************/
569 static char *strip_mount_options(TALLOC_CTX
*ctx
, const char *str
)
573 while(*p
&& !isspace(*p
))
575 while(*p
&& isspace(*p
))
578 return talloc_strdup(ctx
, p
);
584 /*******************************************************************
585 Patch from jkf@soton.ac.uk
586 Split Luke's automount_server into YP lookup and string splitter
587 so can easily implement automount_path().
588 Returns a malloc'ed string.
589 *******************************************************************/
591 #ifdef WITH_NISPLUS_HOME
592 char *automount_lookup(TALLOC_CTX
*ctx
, const char *user_name
)
596 char *nis_map
= (char *)lp_nis_home_map_name();
598 char buffer
[NIS_MAXATTRVAL
+ 1];
603 snprintf(buffer
, sizeof(buffer
), "[key=%s],%s", user_name
, nis_map
);
604 DEBUG(5, ("NIS+ querystring: %s\n", buffer
));
606 if (result
= nis_list(buffer
, FOLLOW_PATH
|EXPAND_NAME
|HARD_LOOKUP
, NULL
, NULL
)) {
607 if (result
->status
!= NIS_SUCCESS
) {
608 DEBUG(3, ("NIS+ query failed: %s\n", nis_sperrno(result
->status
)));
610 object
= result
->objects
.objects_val
;
611 if (object
->zo_data
.zo_type
== ENTRY_OBJ
) {
612 entry
= &object
->zo_data
.objdata_u
.en_data
;
613 DEBUG(5, ("NIS+ entry type: %s\n", entry
->en_type
));
614 DEBUG(3, ("NIS+ result: %s\n", entry
->en_cols
.en_cols_val
[1].ec_value
.ec_value_val
));
616 value
= talloc_strdup(ctx
,
617 entry
->en_cols
.en_cols_val
[1].ec_value
.ec_value_val
);
619 nis_freeresult(result
);
622 value
= talloc_string_sub(ctx
,
629 nis_freeresult(result
);
632 value
= strip_mount_options(ctx
, value
);
633 DEBUG(4, ("NIS+ Lookup: %s resulted in %s\n",
638 #else /* WITH_NISPLUS_HOME */
640 char *automount_lookup(TALLOC_CTX
*ctx
, const char *user_name
)
644 int nis_error
; /* returned by yp all functions */
645 char *nis_result
; /* yp_match inits this */
646 int nis_result_len
; /* and set this */
647 char *nis_domain
; /* yp_get_default_domain inits this */
648 char *nis_map
= lp_nis_home_map_name(talloc_tos());
650 if ((nis_error
= yp_get_default_domain(&nis_domain
)) != 0) {
651 DEBUG(3, ("YP Error: %s\n", yperr_string(nis_error
)));
655 DEBUG(5, ("NIS Domain: %s\n", nis_domain
));
657 if ((nis_error
= yp_match(nis_domain
, nis_map
, user_name
,
658 strlen(user_name
), &nis_result
,
659 &nis_result_len
)) == 0) {
660 if (nis_result_len
> 0 && nis_result
[nis_result_len
] == '\n') {
661 nis_result
[nis_result_len
] = '\0';
663 value
= talloc_strdup(ctx
, nis_result
);
667 value
= strip_mount_options(ctx
, value
);
668 } else if(nis_error
== YPERR_KEY
) {
669 DEBUG(3, ("YP Key not found: while looking up \"%s\" in map \"%s\"\n",
670 user_name
, nis_map
));
671 DEBUG(3, ("using defaults for server and home directory\n"));
673 DEBUG(3, ("YP Error: \"%s\" while looking up \"%s\" in map \"%s\"\n",
674 yperr_string(nis_error
), user_name
, nis_map
));
678 DEBUG(4, ("YP Lookup: %s resulted in %s\n", user_name
, value
));
682 #endif /* WITH_NISPLUS_HOME */
685 bool process_exists(const struct server_id pid
)
687 return serverid_exists(&pid
);
690 /*******************************************************************
691 Convert a uid into a user name.
692 ********************************************************************/
694 const char *uidtoname(uid_t uid
)
696 TALLOC_CTX
*ctx
= talloc_tos();
698 struct passwd
*pass
= NULL
;
700 pass
= getpwuid_alloc(ctx
,uid
);
702 name
= talloc_strdup(ctx
,pass
->pw_name
);
705 name
= talloc_asprintf(ctx
,
712 /*******************************************************************
713 Convert a gid into a group name.
714 ********************************************************************/
716 char *gidtoname(gid_t gid
)
722 return talloc_strdup(talloc_tos(), grp
->gr_name
);
725 return talloc_asprintf(talloc_tos(),
731 /*******************************************************************
732 Convert a user name into a uid.
733 ********************************************************************/
735 uid_t
nametouid(const char *name
)
741 pass
= Get_Pwnam_alloc(talloc_tos(), name
);
748 u
= (uid_t
)strtol(name
, &p
, 0);
749 if ((p
!= name
) && (*p
== '\0'))
755 /*******************************************************************
756 Convert a name to a gid_t if possible. Return -1 if not a group.
757 ********************************************************************/
759 gid_t
nametogid(const char *name
)
765 g
= (gid_t
)strtol(name
, &p
, 0);
766 if ((p
!= name
) && (*p
== '\0'))
769 grp
= getgrnam(name
);
775 /*******************************************************************
776 Something really nasty happened - panic !
777 ********************************************************************/
779 void smb_panic_s3(const char *why
)
784 DEBUG(0,("PANIC (pid %llu): %s\n",
785 (unsigned long long)getpid(), why
));
788 #if defined(HAVE_PRCTL) && defined(PR_SET_PTRACER)
790 * Make sure all children can attach a debugger.
792 prctl(PR_SET_PTRACER
, getpid(), 0, 0, 0);
795 cmd
= lp_panic_action(talloc_tos());
797 DEBUG(0, ("smb_panic(): calling panic action [%s]\n", cmd
));
798 result
= system(cmd
);
801 DEBUG(0, ("smb_panic(): fork failed in panic action: %s\n",
804 DEBUG(0, ("smb_panic(): action returned status %d\n",
805 WEXITSTATUS(result
)));
811 /*******************************************************************
812 Print a backtrace of the stack to the debug log. This function
813 DELIBERATELY LEAKS MEMORY. The expectation is that you should
814 exit shortly after calling it.
815 ********************************************************************/
817 #ifdef HAVE_LIBUNWIND_H
818 #include <libunwind.h>
821 #ifdef HAVE_EXECINFO_H
822 #include <execinfo.h>
829 void log_stack_trace(void)
831 #ifdef HAVE_LIBUNWIND
832 /* Try to use libunwind before any other technique since on ia64
833 * libunwind correctly walks the stack in more circumstances than
841 unw_word_t ip
, sp
, off
;
843 procname
[sizeof(procname
) - 1] = '\0';
845 if (unw_getcontext(&uc
) != 0) {
846 goto libunwind_failed
;
849 if (unw_init_local(&cursor
, &uc
) != 0) {
850 goto libunwind_failed
;
853 DEBUG(0, ("BACKTRACE:\n"));
857 unw_get_reg(&cursor
, UNW_REG_IP
, &ip
);
858 unw_get_reg(&cursor
, UNW_REG_SP
, &sp
);
860 switch (unw_get_proc_name(&cursor
,
861 procname
, sizeof(procname
) - 1, &off
) ) {
865 /* Name truncated. */
866 DEBUGADD(0, (" #%u %s + %#llx [ip=%#llx] [sp=%#llx]\n",
867 i
, procname
, (long long)off
,
868 (long long)ip
, (long long) sp
));
871 /* case -UNW_ENOINFO: */
872 /* case -UNW_EUNSPEC: */
873 /* No symbol name found. */
874 DEBUGADD(0, (" #%u %s [ip=%#llx] [sp=%#llx]\n",
875 i
, "<unknown symbol>",
876 (long long)ip
, (long long) sp
));
879 } while (unw_step(&cursor
) > 0);
884 DEBUG(0, ("unable to produce a stack trace with libunwind\n"));
886 #elif HAVE_BACKTRACE_SYMBOLS
887 void *backtrace_stack
[BACKTRACE_STACK_SIZE
];
888 size_t backtrace_size
;
889 char **backtrace_strings
;
891 /* get the backtrace (stack frames) */
892 backtrace_size
= backtrace(backtrace_stack
,BACKTRACE_STACK_SIZE
);
893 backtrace_strings
= backtrace_symbols(backtrace_stack
, backtrace_size
);
895 DEBUG(0, ("BACKTRACE: %lu stack frames:\n",
896 (unsigned long)backtrace_size
));
898 if (backtrace_strings
) {
901 for (i
= 0; i
< backtrace_size
; i
++)
902 DEBUGADD(0, (" #%u %s\n", i
, backtrace_strings
[i
]));
904 /* Leak the backtrace_strings, rather than risk what free() might do */
909 /* The IRIX libexc library provides an API for unwinding the stack. See
910 * libexc(3) for details. Apparantly trace_back_stack leaks memory, but
911 * since we are about to abort anyway, it hardly matters.
914 #define NAMESIZE 32 /* Arbitrary */
916 __uint64_t addrs
[BACKTRACE_STACK_SIZE
];
917 char * names
[BACKTRACE_STACK_SIZE
];
918 char namebuf
[BACKTRACE_STACK_SIZE
* NAMESIZE
];
927 /* We need to be root so we can open our /proc entry to walk
928 * our stack. It also helps when we want to dump core.
932 for (i
= 0; i
< BACKTRACE_STACK_SIZE
; i
++) {
933 names
[i
] = namebuf
+ (i
* NAMESIZE
);
936 levels
= trace_back_stack(0, addrs
, names
,
937 BACKTRACE_STACK_SIZE
, NAMESIZE
- 1);
939 DEBUG(0, ("BACKTRACE: %d stack frames:\n", levels
));
940 for (i
= 0; i
< levels
; i
++) {
941 DEBUGADD(0, (" #%d 0x%llx %s\n", i
, addrs
[i
], names
[i
]));
946 DEBUG(0, ("unable to produce a stack trace on this platform\n"));
950 /*******************************************************************
951 A readdir wrapper which just returns the file name.
952 ********************************************************************/
954 const char *readdirname(DIR *p
)
962 ptr
= (struct dirent
*)readdir(p
);
973 #ifdef HAVE_BROKEN_READDIR_NAME
974 /* using /usr/ucb/cc is BAD */
978 return talloc_strdup(talloc_tos(), dname
);
981 /*******************************************************************
982 Utility function used to decide if the last component
983 of a path matches a (possibly wildcarded) entry in a namelist.
984 ********************************************************************/
986 bool is_in_path(const char *name
, name_compare_entry
*namelist
, bool case_sensitive
)
988 const char *last_component
;
990 /* if we have no list it's obviously not in the path */
991 if((namelist
== NULL
) || ((namelist
!= NULL
) && (namelist
[0].name
== NULL
))) {
995 DEBUG(8, ("is_in_path: %s\n", name
));
997 /* Get the last component of the unix name. */
998 last_component
= strrchr_m(name
, '/');
999 if (!last_component
) {
1000 last_component
= name
;
1002 last_component
++; /* Go past '/' */
1005 for(; namelist
->name
!= NULL
; namelist
++) {
1006 if(namelist
->is_wild
) {
1007 if (mask_match(last_component
, namelist
->name
, case_sensitive
)) {
1008 DEBUG(8,("is_in_path: mask match succeeded\n"));
1012 if((case_sensitive
&& (strcmp(last_component
, namelist
->name
) == 0))||
1013 (!case_sensitive
&& (strcasecmp_m(last_component
, namelist
->name
) == 0))) {
1014 DEBUG(8,("is_in_path: match succeeded\n"));
1019 DEBUG(8,("is_in_path: match not found\n"));
1023 /*******************************************************************
1024 Strip a '/' separated list into an array of
1025 name_compare_enties structures suitable for
1026 passing to is_in_path(). We do this for
1027 speed so we can pre-parse all the names in the list
1028 and don't do it for each call to is_in_path().
1029 We also check if the entry contains a wildcard to
1030 remove a potentially expensive call to mask_match
1032 ********************************************************************/
1034 void set_namearray(name_compare_entry
**ppname_array
, const char *namelist_in
)
1040 int num_entries
= 0;
1043 (*ppname_array
) = NULL
;
1045 if((namelist_in
== NULL
) || ((namelist_in
!= NULL
) && (*namelist_in
== '\0')))
1048 namelist
= talloc_strdup(talloc_tos(), namelist_in
);
1049 if (namelist
== NULL
) {
1050 DEBUG(0,("set_namearray: talloc fail\n"));
1055 namelist_end
= &namelist
[strlen(namelist
)];
1057 /* We need to make two passes over the string. The
1058 first to count the number of elements, the second
1062 while(nameptr
<= namelist_end
) {
1063 if ( *nameptr
== '/' ) {
1064 /* cope with multiple (useless) /s) */
1068 /* anything left? */
1069 if ( *nameptr
== '\0' )
1072 /* find the next '/' or consume remaining */
1073 name_end
= strchr_m(nameptr
, '/');
1074 if (name_end
== NULL
) {
1075 /* Point nameptr at the terminating '\0' */
1076 nameptr
+= strlen(nameptr
);
1078 /* next segment please */
1079 nameptr
= name_end
+ 1;
1084 if(num_entries
== 0) {
1085 talloc_free(namelist
);
1089 if(( (*ppname_array
) = SMB_MALLOC_ARRAY(name_compare_entry
, num_entries
+ 1)) == NULL
) {
1090 DEBUG(0,("set_namearray: malloc fail\n"));
1091 talloc_free(namelist
);
1095 /* Now copy out the names */
1098 while(nameptr
<= namelist_end
) {
1099 if ( *nameptr
== '/' ) {
1100 /* cope with multiple (useless) /s) */
1104 /* anything left? */
1105 if ( *nameptr
== '\0' )
1108 /* find the next '/' or consume remaining */
1109 name_end
= strchr_m(nameptr
, '/');
1110 if (name_end
!= NULL
) {
1114 (*ppname_array
)[i
].is_wild
= ms_has_wild(nameptr
);
1115 if(((*ppname_array
)[i
].name
= SMB_STRDUP(nameptr
)) == NULL
) {
1116 DEBUG(0,("set_namearray: malloc fail (1)\n"));
1117 talloc_free(namelist
);
1121 if (name_end
== NULL
) {
1122 /* Point nameptr at the terminating '\0' */
1123 nameptr
+= strlen(nameptr
);
1125 /* next segment please */
1126 nameptr
= name_end
+ 1;
1131 (*ppname_array
)[i
].name
= NULL
;
1133 talloc_free(namelist
);
1138 #define DBGC_CLASS DBGC_LOCKING
1140 /****************************************************************************
1141 Simple routine to query existing file locks. Cruft in NFS and 64->32 bit mapping
1142 is dealt with in posix.c
1143 Returns True if we have information regarding this lock region (and returns
1144 F_UNLCK in *ptype if the region is unlocked). False if the call failed.
1145 ****************************************************************************/
1147 bool fcntl_getlock(int fd
, off_t
*poffset
, off_t
*pcount
, int *ptype
, pid_t
*ppid
)
1152 DEBUG(8,("fcntl_getlock fd=%d offset=%.0f count=%.0f type=%d\n",
1153 fd
,(double)*poffset
,(double)*pcount
,*ptype
));
1155 lock
.l_type
= *ptype
;
1156 lock
.l_whence
= SEEK_SET
;
1157 lock
.l_start
= *poffset
;
1158 lock
.l_len
= *pcount
;
1161 ret
= sys_fcntl_ptr(fd
,F_GETLK
,&lock
);
1165 DEBUG(3,("fcntl_getlock: lock request failed at offset %.0f count %.0f type %d (%s)\n",
1166 (double)*poffset
,(double)*pcount
,*ptype
,strerror(errno
)));
1171 *ptype
= lock
.l_type
;
1172 *poffset
= lock
.l_start
;
1173 *pcount
= lock
.l_len
;
1176 DEBUG(3,("fcntl_getlock: fd %d is returned info %d pid %u\n",
1177 fd
, (int)lock
.l_type
, (unsigned int)lock
.l_pid
));
1182 #define DBGC_CLASS DBGC_ALL
1184 /*******************************************************************
1185 Is the name specified one of my netbios names.
1186 Returns true if it is equal, false otherwise.
1187 ********************************************************************/
1189 bool is_myname(const char *s
)
1194 for (n
=0; my_netbios_names(n
); n
++) {
1195 const char *nbt_name
= my_netbios_names(n
);
1197 if (strncasecmp_m(nbt_name
, s
, MAX_NETBIOSNAME_LEN
-1) == 0) {
1202 DEBUG(8, ("is_myname(\"%s\") returns %d\n", s
, ret
));
1206 /*******************************************************************
1207 we distinguish between 2K and XP by the "Native Lan Manager" string
1208 WinXP => "Windows 2002 5.1"
1209 WinXP 64bit => "Windows XP 5.2"
1210 Win2k => "Windows 2000 5.0"
1211 NT4 => "Windows NT 4.0"
1212 Win9x => "Windows 4.0"
1213 Windows 2003 doesn't set the native lan manager string but
1214 they do set the domain to "Windows 2003 5.2" (probably a bug).
1215 ********************************************************************/
1217 void ra_lanman_string( const char *native_lanman
)
1219 if ( strcmp( native_lanman
, "Windows 2002 5.1" ) == 0 )
1220 set_remote_arch( RA_WINXP
);
1221 else if ( strcmp( native_lanman
, "Windows XP 5.2" ) == 0 )
1222 set_remote_arch( RA_WINXP64
);
1223 else if ( strcmp( native_lanman
, "Windows Server 2003 5.2" ) == 0 )
1224 set_remote_arch( RA_WIN2K3
);
1227 static const char *remote_arch_str
;
1229 const char *get_remote_arch_str(void)
1231 if (!remote_arch_str
) {
1234 return remote_arch_str
;
1237 /*******************************************************************
1238 Set the horrid remote_arch string based on an enum.
1239 ********************************************************************/
1241 void set_remote_arch(enum remote_arch_types type
)
1246 remote_arch_str
= "WfWg";
1249 remote_arch_str
= "OS2";
1252 remote_arch_str
= "Win95";
1255 remote_arch_str
= "WinNT";
1258 remote_arch_str
= "Win2K";
1261 remote_arch_str
= "WinXP";
1264 remote_arch_str
= "WinXP64";
1267 remote_arch_str
= "Win2K3";
1270 remote_arch_str
= "Vista";
1273 remote_arch_str
= "Samba";
1276 remote_arch_str
= "CIFSFS";
1279 remote_arch_str
= "OSX";
1282 ra_type
= RA_UNKNOWN
;
1283 remote_arch_str
= "UNKNOWN";
1287 DEBUG(10,("set_remote_arch: Client arch is \'%s\'\n",
1291 /*******************************************************************
1292 Get the remote_arch type.
1293 ********************************************************************/
1295 enum remote_arch_types
get_remote_arch(void)
1300 const char *tab_depth(int level
, int depth
)
1302 if( CHECK_DEBUGLVL(level
) ) {
1303 dbgtext("%*s", depth
*4, "");
1308 /*****************************************************************************
1309 Provide a checksum on a string
1311 Input: s - the null-terminated character string for which the checksum
1314 Output: The checksum value calculated for s.
1315 *****************************************************************************/
1317 int str_checksum(const char *s
)
1321 return hash(s
, strlen(s
), 0);
1324 /*****************************************************************
1325 Zero a memory area then free it. Used to catch bugs faster.
1326 *****************************************************************/
1328 void zero_free(void *p
, size_t size
)
1334 /*****************************************************************
1335 Set our open file limit to a requested max and return the limit.
1336 *****************************************************************/
1338 int set_maxfiles(int requested_max
)
1340 #if (defined(HAVE_GETRLIMIT) && defined(RLIMIT_NOFILE))
1342 int saved_current_limit
;
1344 if(getrlimit(RLIMIT_NOFILE
, &rlp
)) {
1345 DEBUG(0,("set_maxfiles: getrlimit (1) for RLIMIT_NOFILE failed with error %s\n",
1348 return requested_max
;
1352 * Set the fd limit to be real_max_open_files + MAX_OPEN_FUDGEFACTOR to
1353 * account for the extra fd we need
1354 * as well as the log files and standard
1355 * handles etc. Save the limit we want to set in case
1356 * we are running on an OS that doesn't support this limit (AIX)
1357 * which always returns RLIM_INFINITY for rlp.rlim_max.
1360 /* Try raising the hard (max) limit to the requested amount. */
1362 #if defined(RLIM_INFINITY)
1363 if (rlp
.rlim_max
!= RLIM_INFINITY
) {
1364 int orig_max
= rlp
.rlim_max
;
1366 if ( rlp
.rlim_max
< requested_max
)
1367 rlp
.rlim_max
= requested_max
;
1369 /* This failing is not an error - many systems (Linux) don't
1370 support our default request of 10,000 open files. JRA. */
1372 if(setrlimit(RLIMIT_NOFILE
, &rlp
)) {
1373 DEBUG(3,("set_maxfiles: setrlimit for RLIMIT_NOFILE for %d max files failed with error %s\n",
1374 (int)rlp
.rlim_max
, strerror(errno
) ));
1376 /* Set failed - restore original value from get. */
1377 rlp
.rlim_max
= orig_max
;
1382 /* Now try setting the soft (current) limit. */
1384 saved_current_limit
= rlp
.rlim_cur
= MIN(requested_max
,rlp
.rlim_max
);
1386 if(setrlimit(RLIMIT_NOFILE
, &rlp
)) {
1387 DEBUG(0,("set_maxfiles: setrlimit for RLIMIT_NOFILE for %d files failed with error %s\n",
1388 (int)rlp
.rlim_cur
, strerror(errno
) ));
1390 return saved_current_limit
;
1393 if(getrlimit(RLIMIT_NOFILE
, &rlp
)) {
1394 DEBUG(0,("set_maxfiles: getrlimit (2) for RLIMIT_NOFILE failed with error %s\n",
1397 return saved_current_limit
;
1400 #if defined(RLIM_INFINITY)
1401 if(rlp
.rlim_cur
== RLIM_INFINITY
)
1402 return saved_current_limit
;
1405 if((int)rlp
.rlim_cur
> saved_current_limit
)
1406 return saved_current_limit
;
1408 return rlp
.rlim_cur
;
1409 #else /* !defined(HAVE_GETRLIMIT) || !defined(RLIMIT_NOFILE) */
1411 * No way to know - just guess...
1413 return requested_max
;
1417 /*****************************************************************
1418 malloc that aborts with smb_panic on fail or zero size.
1419 *****************************************************************/
1421 void *smb_xmalloc_array(size_t size
, unsigned int count
)
1425 smb_panic("smb_xmalloc_array: called with zero size");
1427 if (count
>= MAX_ALLOC_SIZE
/size
) {
1428 smb_panic("smb_xmalloc_array: alloc size too large");
1430 if ((p
= SMB_MALLOC(size
*count
)) == NULL
) {
1431 DEBUG(0, ("smb_xmalloc_array failed to allocate %lu * %lu bytes\n",
1432 (unsigned long)size
, (unsigned long)count
));
1433 smb_panic("smb_xmalloc_array: malloc failed");
1439 vasprintf that aborts on malloc fail
1442 int smb_xvasprintf(char **ptr
, const char *format
, va_list ap
)
1449 n
= vasprintf(ptr
, format
, ap2
);
1451 if (n
== -1 || ! *ptr
) {
1452 smb_panic("smb_xvasprintf: out of memory");
1457 /*****************************************************************
1458 Get local hostname and cache result.
1459 *****************************************************************/
1461 char *myhostname(void)
1465 ret
= get_myname(NULL
);
1470 /*****************************************************************
1471 Get local hostname and cache result.
1472 *****************************************************************/
1474 char *myhostname_upper(void)
1478 char *name
= get_myname(NULL
);
1482 ret
= strupper_talloc(NULL
, name
);
1489 * @brief Returns an absolute path to a file concatenating the provided
1490 * @a rootpath and @a basename
1492 * @param name Filename, relative to @a rootpath
1494 * @retval Pointer to a string containing the full path.
1497 static char *xx_path(const char *name
, const char *rootpath
)
1501 fname
= talloc_strdup(talloc_tos(), rootpath
);
1505 trim_string(fname
,"","/");
1507 if (!directory_exist(fname
)) {
1508 if (mkdir(fname
,0755) == -1) {
1509 /* Did someone else win the race ? */
1510 if (errno
!= EEXIST
) {
1511 DEBUG(1, ("Unable to create directory %s for file %s. "
1512 "Error was %s\n", fname
, name
, strerror(errno
)));
1518 return talloc_asprintf_append(fname
, "/%s", name
);
1522 * @brief Returns an absolute path to a file in the Samba lock directory.
1524 * @param name File to find, relative to LOCKDIR.
1526 * @retval Pointer to a talloc'ed string containing the full path.
1529 char *lock_path(const char *name
)
1531 return xx_path(name
, lp_lockdir());
1535 * @brief Returns an absolute path to a file in the Samba state directory.
1537 * @param name File to find, relative to STATEDIR.
1539 * @retval Pointer to a talloc'ed string containing the full path.
1542 char *state_path(const char *name
)
1544 return xx_path(name
, lp_statedir());
1548 * @brief Returns an absolute path to a file in the Samba cache directory.
1550 * @param name File to find, relative to CACHEDIR.
1552 * @retval Pointer to a talloc'ed string containing the full path.
1555 char *cache_path(const char *name
)
1557 return xx_path(name
, lp_cachedir());
1560 /*******************************************************************
1561 Given a filename - get its directory name
1562 ********************************************************************/
1564 bool parent_dirname(TALLOC_CTX
*mem_ctx
, const char *dir
, char **parent
,
1570 p
= strrchr_m(dir
, '/'); /* Find final '/', if any */
1573 if (!(*parent
= talloc_strdup(mem_ctx
, "."))) {
1584 if (!(*parent
= (char *)talloc_memdup(mem_ctx
, dir
, len
+1))) {
1587 (*parent
)[len
] = '\0';
1595 /*******************************************************************
1596 Determine if a pattern contains any Microsoft wildcard characters.
1597 *******************************************************************/
1599 bool ms_has_wild(const char *s
)
1603 if (lp_posix_pathnames()) {
1604 /* With posix pathnames no characters are wild. */
1608 while ((c
= *s
++)) {
1621 bool ms_has_wild_w(const smb_ucs2_t
*s
)
1624 if (!s
) return False
;
1625 while ((c
= *s
++)) {
1627 case UCS2_CHAR('*'):
1628 case UCS2_CHAR('?'):
1629 case UCS2_CHAR('<'):
1630 case UCS2_CHAR('>'):
1631 case UCS2_CHAR('"'):
1638 /*******************************************************************
1639 A wrapper that handles case sensitivity and the special handling
1641 *******************************************************************/
1643 bool mask_match(const char *string
, const char *pattern
, bool is_case_sensitive
)
1645 if (ISDOTDOT(string
))
1650 return ms_fnmatch(pattern
, string
, Protocol
<= PROTOCOL_LANMAN2
, is_case_sensitive
) == 0;
1653 /*******************************************************************
1654 A wrapper that handles case sensitivity and the special handling
1655 of the ".." name. Varient that is only called by old search code which requires
1656 pattern translation.
1657 *******************************************************************/
1659 bool mask_match_search(const char *string
, const char *pattern
, bool is_case_sensitive
)
1661 if (ISDOTDOT(string
))
1666 return ms_fnmatch(pattern
, string
, True
, is_case_sensitive
) == 0;
1669 /*******************************************************************
1670 A wrapper that handles a list of patters and calls mask_match()
1671 on each. Returns True if any of the patterns match.
1672 *******************************************************************/
1674 bool mask_match_list(const char *string
, char **list
, int listLen
, bool is_case_sensitive
)
1676 while (listLen
-- > 0) {
1677 if (mask_match(string
, *list
++, is_case_sensitive
))
1683 /*********************************************************
1684 Recursive routine that is called by unix_wild_match.
1685 *********************************************************/
1687 static bool unix_do_match(const char *regexp
, const char *str
)
1691 for( p
= regexp
; *p
&& *str
; ) {
1702 * Look for a character matching
1703 * the one after the '*'.
1707 return true; /* Automatic match */
1710 while(*str
&& (*p
!= *str
))
1714 * Patch from weidel@multichart.de. In the case of the regexp
1715 * '*XX*' we want to ensure there are at least 2 'X' characters
1716 * in the string after the '*' for a match to be made.
1723 * Eat all the characters that match, but count how many there were.
1726 while(*str
&& (*p
== *str
)) {
1732 * Now check that if the regexp had n identical characters that
1733 * matchcount had at least that many matches.
1736 while ( *(p
+1) && (*(p
+1) == *p
)) {
1741 if ( matchcount
<= 0 )
1745 str
--; /* We've eaten the match char after the '*' */
1747 if(unix_do_match(p
, str
))
1769 if (!*p
&& str
[0] == '.' && str
[1] == 0)
1772 if (!*str
&& *p
== '?') {
1778 if(!*str
&& (*p
== '*' && p
[1] == '\0'))
1784 /*******************************************************************
1785 Simple case insensitive interface to a UNIX wildcard matcher.
1786 Returns True if match, False if not.
1787 *******************************************************************/
1789 bool unix_wild_match(const char *pattern
, const char *string
)
1791 TALLOC_CTX
*ctx
= talloc_stackframe();
1797 p2
= talloc_strdup(ctx
,pattern
);
1798 s2
= talloc_strdup(ctx
,string
);
1803 if (!strlower_m(p2
)) {
1807 if (!strlower_m(s2
)) {
1812 /* Remove any *? and ** from the pattern as they are meaningless */
1813 for(p
= p2
; *p
; p
++) {
1814 while( *p
== '*' && (p
[1] == '?' ||p
[1] == '*')) {
1815 memmove(&p
[1], &p
[2], strlen(&p
[2])+1);
1819 if (strequal(p2
,"*")) {
1824 ret
= unix_do_match(p2
, s2
);
1829 /**********************************************************************
1830 Converts a name to a fully qualified domain name.
1831 Returns true if lookup succeeded, false if not (then fqdn is set to name)
1832 Uses getaddrinfo() with AI_CANONNAME flag to obtain the official
1833 canonical name of the host. getaddrinfo() may use a variety of sources
1834 including /etc/hosts to obtain the domainname. It expects aliases in
1835 /etc/hosts to NOT be the FQDN. The FQDN should come first.
1836 ***********************************************************************/
1838 bool name_to_fqdn(fstring fqdn
, const char *name
)
1841 struct addrinfo hints
;
1842 struct addrinfo
*result
;
1845 /* Configure hints to obtain canonical name */
1847 memset(&hints
, 0, sizeof(struct addrinfo
));
1848 hints
.ai_family
= AF_UNSPEC
; /* Allow IPv4 or IPv6 */
1849 hints
.ai_socktype
= SOCK_DGRAM
; /* Datagram socket */
1850 hints
.ai_flags
= AI_CANONNAME
; /* Get host's FQDN */
1851 hints
.ai_protocol
= 0; /* Any protocol */
1853 s
= getaddrinfo(name
, NULL
, &hints
, &result
);
1855 DEBUG(1, ("getaddrinfo: %s\n", gai_strerror(s
)));
1856 DEBUG(10,("name_to_fqdn: lookup for %s failed.\n", name
));
1857 fstrcpy(fqdn
, name
);
1860 full
= result
->ai_canonname
;
1862 /* Find out if the FQDN is returned as an alias
1863 * to cope with /etc/hosts files where the first
1864 * name is not the FQDN but the short name.
1865 * getaddrinfo provides no easy way of handling aliases
1866 * in /etc/hosts. Users should make sure the FQDN
1867 * comes first in /etc/hosts. */
1868 if (full
&& (! strchr_m(full
, '.'))) {
1869 DEBUG(1, ("WARNING: your /etc/hosts file may be broken!\n"));
1870 DEBUGADD(1, (" Full qualified domain names (FQDNs) should not be specified\n"));
1871 DEBUGADD(1, (" as an alias in /etc/hosts. FQDN should be the first name\n"));
1872 DEBUGADD(1, (" prior to any aliases.\n"));
1874 if (full
&& (strcasecmp_m(full
, "localhost.localdomain") == 0)) {
1875 DEBUG(1, ("WARNING: your /etc/hosts file may be broken!\n"));
1876 DEBUGADD(1, (" Specifing the machine hostname for address 127.0.0.1 may lead\n"));
1877 DEBUGADD(1, (" to Kerberos authentication problems as localhost.localdomain\n"));
1878 DEBUGADD(1, (" may end up being used instead of the real machine FQDN.\n"));
1881 DEBUG(10,("name_to_fqdn: lookup for %s -> %s.\n", name
, full
));
1882 fstrcpy(fqdn
, full
);
1883 freeaddrinfo(result
); /* No longer needed */
1887 /**********************************************************************
1888 Append a DATA_BLOB to a talloc'ed object
1889 ***********************************************************************/
1891 void *talloc_append_blob(TALLOC_CTX
*mem_ctx
, void *buf
, DATA_BLOB blob
)
1893 size_t old_size
= 0;
1896 if (blob
.length
== 0) {
1901 old_size
= talloc_get_size(buf
);
1904 result
= (char *)TALLOC_REALLOC(mem_ctx
, buf
, old_size
+ blob
.length
);
1905 if (result
== NULL
) {
1909 memcpy(result
+ old_size
, blob
.data
, blob
.length
);
1913 uint32
map_share_mode_to_deny_mode(uint32 share_access
, uint32 private_options
)
1915 switch (share_access
& ~FILE_SHARE_DELETE
) {
1916 case FILE_SHARE_NONE
:
1918 case FILE_SHARE_READ
:
1920 case FILE_SHARE_WRITE
:
1922 case FILE_SHARE_READ
|FILE_SHARE_WRITE
:
1925 if (private_options
& NTCREATEX_OPTIONS_PRIVATE_DENY_DOS
) {
1927 } else if (private_options
& NTCREATEX_OPTIONS_PRIVATE_DENY_FCB
) {
1934 pid_t
procid_to_pid(const struct server_id
*proc
)
1939 static uint32 my_vnn
= NONCLUSTER_VNN
;
1941 void set_my_vnn(uint32 vnn
)
1943 DEBUG(10, ("vnn pid %d = %u\n", (int)getpid(), (unsigned int)vnn
));
1947 uint32
get_my_vnn(void)
1952 static uint64_t my_unique_id
= 0;
1954 void set_my_unique_id(uint64_t unique_id
)
1956 my_unique_id
= unique_id
;
1959 struct server_id
pid_to_procid(pid_t pid
)
1961 struct server_id result
;
1964 result
.unique_id
= my_unique_id
;
1965 result
.vnn
= my_vnn
;
1969 struct server_id
procid_self(void)
1971 return pid_to_procid(getpid());
1974 static struct idr_context
*task_id_tree
;
1976 static int free_task_id(struct server_id
*server_id
)
1978 idr_remove(task_id_tree
, server_id
->task_id
);
1982 /* Return a server_id with a unique task_id element. Free the
1983 * returned pointer to de-allocate the task_id via a talloc destructor
1984 * (ie, use talloc_free()) */
1985 struct server_id
*new_server_id_task(TALLOC_CTX
*mem_ctx
)
1987 struct server_id
*server_id
;
1989 if (!task_id_tree
) {
1990 task_id_tree
= idr_init(NULL
);
1991 if (!task_id_tree
) {
1996 server_id
= talloc(mem_ctx
, struct server_id
);
2001 *server_id
= procid_self();
2003 /* 0 is the default server_id, so we need to start with 1 */
2004 task_id
= idr_get_new_above(task_id_tree
, server_id
, 1, INT32_MAX
);
2006 if (task_id
== -1) {
2007 talloc_free(server_id
);
2011 talloc_set_destructor(server_id
, free_task_id
);
2012 server_id
->task_id
= task_id
;
2016 bool procid_is_me(const struct server_id
*pid
)
2018 if (pid
->pid
!= getpid())
2020 if (pid
->task_id
!= 0)
2022 if (pid
->vnn
!= my_vnn
)
2027 struct server_id
interpret_pid(const char *pid_string
)
2029 return server_id_from_string(get_my_vnn(), pid_string
);
2032 char *procid_str_static(const struct server_id
*pid
)
2034 return server_id_str(talloc_tos(), pid
);
2037 bool procid_valid(const struct server_id
*pid
)
2039 return (pid
->pid
!= (uint64_t)-1);
2042 bool procid_is_local(const struct server_id
*pid
)
2044 return pid
->vnn
== my_vnn
;
2047 /****************************************************************
2048 Check if an offset into a buffer is safe.
2049 If this returns True it's safe to indirect into the byte at
2051 ****************************************************************/
2053 bool is_offset_safe(const char *buf_base
, size_t buf_len
, char *ptr
, size_t off
)
2055 const char *end_base
= buf_base
+ buf_len
;
2056 char *end_ptr
= ptr
+ off
;
2058 if (!buf_base
|| !ptr
) {
2062 if (end_base
< buf_base
|| end_ptr
< ptr
) {
2063 return False
; /* wrap. */
2066 if (end_ptr
< end_base
) {
2072 /****************************************************************
2073 Return a safe pointer into a buffer, or NULL.
2074 ****************************************************************/
2076 char *get_safe_ptr(const char *buf_base
, size_t buf_len
, char *ptr
, size_t off
)
2078 return is_offset_safe(buf_base
, buf_len
, ptr
, off
) ?
2082 /****************************************************************
2083 Return a safe pointer into a string within a buffer, or NULL.
2084 ****************************************************************/
2086 char *get_safe_str_ptr(const char *buf_base
, size_t buf_len
, char *ptr
, size_t off
)
2088 if (!is_offset_safe(buf_base
, buf_len
, ptr
, off
)) {
2091 /* Check if a valid string exists at this offset. */
2092 if (skip_string(buf_base
,buf_len
, ptr
+ off
) == NULL
) {
2098 /****************************************************************
2099 Return an SVAL at a pointer, or failval if beyond the end.
2100 ****************************************************************/
2102 int get_safe_SVAL(const char *buf_base
, size_t buf_len
, char *ptr
, size_t off
, int failval
)
2105 * Note we use off+1 here, not off+2 as SVAL accesses ptr[0] and ptr[1],
2108 if (!is_offset_safe(buf_base
, buf_len
, ptr
, off
+1)) {
2111 return SVAL(ptr
,off
);
2114 /****************************************************************
2115 Return an IVAL at a pointer, or failval if beyond the end.
2116 ****************************************************************/
2118 int get_safe_IVAL(const char *buf_base
, size_t buf_len
, char *ptr
, size_t off
, int failval
)
2121 * Note we use off+3 here, not off+4 as IVAL accesses
2122 * ptr[0] ptr[1] ptr[2] ptr[3] NOT ptr[4].
2124 if (!is_offset_safe(buf_base
, buf_len
, ptr
, off
+3)) {
2127 return IVAL(ptr
,off
);
2130 /****************************************************************
2131 Split DOM\user into DOM and user. Do not mix with winbind variants of that
2132 call (they take care of winbind separator and other winbind specific settings).
2133 ****************************************************************/
2135 void split_domain_user(TALLOC_CTX
*mem_ctx
,
2136 const char *full_name
,
2140 const char *p
= NULL
;
2142 p
= strchr_m(full_name
, '\\');
2145 *domain
= talloc_strndup(mem_ctx
, full_name
,
2146 PTR_DIFF(p
, full_name
));
2147 *user
= talloc_strdup(mem_ctx
, p
+1);
2149 *domain
= talloc_strdup(mem_ctx
, "");
2150 *user
= talloc_strdup(mem_ctx
, full_name
);
2154 /****************************************************************
2155 strip off leading '\\' from a hostname
2156 ****************************************************************/
2158 const char *strip_hostname(const char *s
)
2164 if (strlen_m(s
) < 3) {
2168 if (s
[0] == '\\') s
++;
2169 if (s
[0] == '\\') s
++;
2174 bool any_nt_status_not_ok(NTSTATUS err1
, NTSTATUS err2
, NTSTATUS
*result
)
2176 if (!NT_STATUS_IS_OK(err1
)) {
2180 if (!NT_STATUS_IS_OK(err2
)) {
2187 int timeval_to_msec(struct timeval t
)
2189 return t
.tv_sec
* 1000 + (t
.tv_usec
+999) / 1000;
2192 /*******************************************************************
2193 Check a given DOS pathname is valid for a share.
2194 ********************************************************************/
2196 char *valid_share_pathname(TALLOC_CTX
*ctx
, const char *dos_pathname
)
2200 if (!dos_pathname
) {
2204 ptr
= talloc_strdup(ctx
, dos_pathname
);
2208 /* Convert any '\' paths to '/' */
2210 ptr
= unix_clean_name(ctx
, ptr
);
2215 /* NT is braindead - it wants a C: prefix to a pathname ! So strip it. */
2216 if (strlen(ptr
) > 2 && ptr
[1] == ':' && ptr
[0] != '/')
2219 /* Only absolute paths allowed. */
2226 /*******************************************************************
2227 Return True if the filename is one of the special executable types.
2228 ********************************************************************/
2230 bool is_executable(const char *fname
)
2232 if ((fname
= strrchr_m(fname
,'.'))) {
2233 if (strequal(fname
,".com") ||
2234 strequal(fname
,".dll") ||
2235 strequal(fname
,".exe") ||
2236 strequal(fname
,".sym")) {
2243 /****************************************************************************
2244 Open a file with a share mode - old openX method - map into NTCreate.
2245 ****************************************************************************/
2247 bool map_open_params_to_ntcreate(const char *smb_base_fname
,
2248 int deny_mode
, int open_func
,
2249 uint32
*paccess_mask
,
2250 uint32
*pshare_mode
,
2251 uint32
*pcreate_disposition
,
2252 uint32
*pcreate_options
,
2253 uint32_t *pprivate_flags
)
2257 uint32 create_disposition
;
2258 uint32 create_options
= FILE_NON_DIRECTORY_FILE
;
2259 uint32_t private_flags
= 0;
2261 DEBUG(10,("map_open_params_to_ntcreate: fname = %s, deny_mode = 0x%x, "
2262 "open_func = 0x%x\n",
2263 smb_base_fname
, (unsigned int)deny_mode
,
2264 (unsigned int)open_func
));
2266 /* Create the NT compatible access_mask. */
2267 switch (GET_OPENX_MODE(deny_mode
)) {
2268 case DOS_OPEN_EXEC
: /* Implies read-only - used to be FILE_READ_DATA */
2269 case DOS_OPEN_RDONLY
:
2270 access_mask
= FILE_GENERIC_READ
;
2272 case DOS_OPEN_WRONLY
:
2273 access_mask
= FILE_GENERIC_WRITE
;
2277 access_mask
= FILE_GENERIC_READ
|FILE_GENERIC_WRITE
;
2280 DEBUG(10,("map_open_params_to_ntcreate: bad open mode = 0x%x\n",
2281 (unsigned int)GET_OPENX_MODE(deny_mode
)));
2285 /* Create the NT compatible create_disposition. */
2286 switch (open_func
) {
2287 case OPENX_FILE_EXISTS_FAIL
|OPENX_FILE_CREATE_IF_NOT_EXIST
:
2288 create_disposition
= FILE_CREATE
;
2291 case OPENX_FILE_EXISTS_OPEN
:
2292 create_disposition
= FILE_OPEN
;
2295 case OPENX_FILE_EXISTS_OPEN
|OPENX_FILE_CREATE_IF_NOT_EXIST
:
2296 create_disposition
= FILE_OPEN_IF
;
2299 case OPENX_FILE_EXISTS_TRUNCATE
:
2300 create_disposition
= FILE_OVERWRITE
;
2303 case OPENX_FILE_EXISTS_TRUNCATE
|OPENX_FILE_CREATE_IF_NOT_EXIST
:
2304 create_disposition
= FILE_OVERWRITE_IF
;
2308 /* From samba4 - to be confirmed. */
2309 if (GET_OPENX_MODE(deny_mode
) == DOS_OPEN_EXEC
) {
2310 create_disposition
= FILE_CREATE
;
2313 DEBUG(10,("map_open_params_to_ntcreate: bad "
2314 "open_func 0x%x\n", (unsigned int)open_func
));
2318 /* Create the NT compatible share modes. */
2319 switch (GET_DENY_MODE(deny_mode
)) {
2321 share_mode
= FILE_SHARE_NONE
;
2325 share_mode
= FILE_SHARE_READ
;
2329 share_mode
= FILE_SHARE_WRITE
;
2333 share_mode
= FILE_SHARE_READ
|FILE_SHARE_WRITE
;
2337 private_flags
|= NTCREATEX_OPTIONS_PRIVATE_DENY_DOS
;
2338 if (is_executable(smb_base_fname
)) {
2339 share_mode
= FILE_SHARE_READ
|FILE_SHARE_WRITE
;
2341 if (GET_OPENX_MODE(deny_mode
) == DOS_OPEN_RDONLY
) {
2342 share_mode
= FILE_SHARE_READ
;
2344 share_mode
= FILE_SHARE_NONE
;
2350 private_flags
|= NTCREATEX_OPTIONS_PRIVATE_DENY_FCB
;
2351 share_mode
= FILE_SHARE_NONE
;
2355 DEBUG(10,("map_open_params_to_ntcreate: bad deny_mode 0x%x\n",
2356 (unsigned int)GET_DENY_MODE(deny_mode
) ));
2360 DEBUG(10,("map_open_params_to_ntcreate: file %s, access_mask = 0x%x, "
2361 "share_mode = 0x%x, create_disposition = 0x%x, "
2362 "create_options = 0x%x private_flags = 0x%x\n",
2364 (unsigned int)access_mask
,
2365 (unsigned int)share_mode
,
2366 (unsigned int)create_disposition
,
2367 (unsigned int)create_options
,
2368 (unsigned int)private_flags
));
2371 *paccess_mask
= access_mask
;
2374 *pshare_mode
= share_mode
;
2376 if (pcreate_disposition
) {
2377 *pcreate_disposition
= create_disposition
;
2379 if (pcreate_options
) {
2380 *pcreate_options
= create_options
;
2382 if (pprivate_flags
) {
2383 *pprivate_flags
= private_flags
;
2390 /*************************************************************************
2391 Return a talloced copy of a struct security_unix_token. NULL on fail.
2392 *************************************************************************/
2394 struct security_unix_token
*copy_unix_token(TALLOC_CTX
*ctx
, const struct security_unix_token
*tok
)
2396 struct security_unix_token
*cpy
;
2398 cpy
= talloc(ctx
, struct security_unix_token
);
2403 cpy
->uid
= tok
->uid
;
2404 cpy
->gid
= tok
->gid
;
2405 cpy
->ngroups
= tok
->ngroups
;
2407 /* Make this a talloc child of cpy. */
2408 cpy
->groups
= (gid_t
*)talloc_memdup(
2409 cpy
, tok
->groups
, tok
->ngroups
* sizeof(gid_t
));
2420 /****************************************************************************
2421 Check that a file matches a particular file type.
2422 ****************************************************************************/
2424 bool dir_check_ftype(uint32_t mode
, uint32_t dirtype
)
2428 /* Check the "may have" search bits. */
2429 if (((mode
& ~dirtype
) &
2430 (FILE_ATTRIBUTE_HIDDEN
|
2431 FILE_ATTRIBUTE_SYSTEM
|
2432 FILE_ATTRIBUTE_DIRECTORY
)) != 0) {
2436 /* Check the "must have" bits,
2437 which are the may have bits shifted eight */
2438 /* If must have bit is set, the file/dir can
2439 not be returned in search unless the matching
2440 file attribute is set */
2441 mask
= ((dirtype
>> 8) & (FILE_ATTRIBUTE_DIRECTORY
|
2442 FILE_ATTRIBUTE_ARCHIVE
|
2443 FILE_ATTRIBUTE_READONLY
|
2444 FILE_ATTRIBUTE_HIDDEN
|
2445 FILE_ATTRIBUTE_SYSTEM
)); /* & 0x37 */
2447 if((mask
& (mode
& (FILE_ATTRIBUTE_DIRECTORY
|
2448 FILE_ATTRIBUTE_ARCHIVE
|
2449 FILE_ATTRIBUTE_READONLY
|
2450 FILE_ATTRIBUTE_HIDDEN
|
2451 FILE_ATTRIBUTE_SYSTEM
))) == mask
) {
2452 /* check if matching attribute present */