2 Unix SMB/CIFS implementation.
3 NBT netbios routines and daemon - version 2
4 Copyright (C) Andrew Tridgell 1994-1998
5 Copyright (C) Luke Kenneth Casson Leighton 1994-1998
6 Copyright (C) Jeremy Allison 1994-1998
8 This program is free software; you can redistribute it and/or modify
9 it under the terms of the GNU General Public License as published by
10 the Free Software Foundation; either version 3 of the License, or
11 (at your option) any later version.
13 This program is distributed in the hope that it will be useful,
14 but WITHOUT ANY WARRANTY; without even the implied warranty of
15 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
16 GNU General Public License for more details.
18 You should have received a copy of the GNU General Public License
19 along with this program. If not, see <http://www.gnu.org/licenses/>.
23 /* this file handles asynchronous browse synchronisation requests. The
24 requests are done by forking and putting the result in a file in the
25 locks directory. We do it this way because we don't want nmbd to be
26 blocked waiting for some server to respond on a TCP connection. This
27 also allows us to have more than 1 sync going at once (tridge) */
30 #include "system/filesys.h"
31 #include "../librpc/gen_ndr/svcctl.h"
32 #include "nmbd/nmbd.h"
33 #include "libsmb/clirap.h"
36 struct sync_record
*next
, *prev
;
44 /* a linked list of current sync connections */
45 static struct sync_record
*syncs
;
49 /*******************************************************************
50 This is the NetServerEnum callback.
51 Note sname and comment are in UNIX codepage format.
52 ******************************************************************/
54 static void callback(const char *sname
, uint32 stype
,
55 const char *comment
, void *state
)
57 x_fprintf(fp
,"\"%s\" %08X \"%s\"\n", sname
, stype
, comment
);
60 /*******************************************************************
61 Synchronise browse lists with another browse server.
62 Log in on the remote server's SMB port to their IPC$ service,
63 do a NetServerEnum and record the results in fname
64 ******************************************************************/
66 static void sync_child(char *name
, int nm_type
,
68 struct in_addr ip
, bool local
, bool servers
,
71 fstring unix_workgroup
;
72 struct cli_state
*cli
;
73 uint32 local_type
= local
? SV_TYPE_LOCAL_LIST_ONLY
: 0;
74 struct nmb_name called
, calling
;
75 struct sockaddr_storage ss
;
78 /* W2K DMB's return empty browse lists on port 445. Use 139.
79 * Patch from Andy Levine andyl@epicrealm.com.
82 cli
= cli_initialise();
87 cli_set_port(cli
, 139);
89 in_addr_to_sockaddr_storage(&ss
, ip
);
90 status
= cli_connect(cli
, name
, &ss
);
91 if (!NT_STATUS_IS_OK(status
)) {
96 make_nmb_name(&calling
, get_local_machine_name(), 0x0);
97 make_nmb_name(&called
, name
, nm_type
);
99 if (!cli_session_request(cli
, &calling
, &called
)) {
104 status
= cli_negprot(cli
);
105 if (!NT_STATUS_IS_OK(status
)) {
110 if (!NT_STATUS_IS_OK(cli_session_setup(cli
, "", "", 1, "", 0,
116 if (!NT_STATUS_IS_OK(cli_tcon_andx(cli
, "IPC$", "IPC", "", 1))) {
121 /* All the cli_XX functions take UNIX character set. */
122 fstrcpy(unix_workgroup
, cli
->server_domain
? cli
->server_domain
: workgroup
);
124 /* Fetch a workgroup list. */
125 cli_NetServerEnum(cli
, unix_workgroup
,
126 local_type
|SV_TYPE_DOMAIN_ENUM
,
129 /* Now fetch a server list. */
131 fstrcpy(unix_workgroup
, workgroup
);
132 cli_NetServerEnum(cli
, unix_workgroup
,
133 local
?SV_TYPE_LOCAL_LIST_ONLY
:SV_TYPE_ALL
,
140 /*******************************************************************
141 initialise a browse sync with another browse server. Log in on the
142 remote server's SMB port to their IPC$ service, do a NetServerEnum
143 and record the results
144 ******************************************************************/
146 void sync_browse_lists(struct work_record
*work
,
147 char *name
, int nm_type
,
148 struct in_addr ip
, bool local
, bool servers
)
150 struct sync_record
*s
;
153 START_PROFILE(sync_browse_lists
);
154 /* Check we're not trying to sync with ourselves. This can
155 happen if we are a domain *and* a local master browser. */
158 END_PROFILE(sync_browse_lists
);
162 s
= SMB_MALLOC_P(struct sync_record
);
167 unstrcpy(s
->workgroup
, work
->work_group
);
168 unstrcpy(s
->server
, name
);
171 if (asprintf(&s
->fname
, "%s/sync.%d", lp_lockdir(), counter
++) < 0) {
175 /* Safe to use as 0 means no size change. */
176 all_string_sub(s
->fname
,"//", "/", 0);
180 /* the parent forks and returns, leaving the child to do the
181 actual sync and call END_PROFILE*/
183 if ((s
->pid
= sys_fork())) return;
185 BlockSignals( False
, SIGTERM
);
187 DEBUG(2,("Initiating browse sync for %s to %s(%s)\n",
188 work
->work_group
, name
, inet_ntoa(ip
)));
190 fp
= x_fopen(s
->fname
,O_WRONLY
|O_CREAT
|O_TRUNC
, 0644);
192 END_PROFILE(sync_browse_lists
);
196 sync_child(name
, nm_type
, work
->work_group
, ip
, local
, servers
,
200 END_PROFILE(sync_browse_lists
);
204 /**********************************************************************
205 Handle one line from a completed sync file.
206 **********************************************************************/
208 static void complete_one(struct sync_record
*s
,
209 char *sname
, uint32 stype
, char *comment
)
211 struct work_record
*work
;
212 struct server_record
*servrec
;
214 stype
&= ~SV_TYPE_LOCAL_LIST_ONLY
;
216 if (stype
& SV_TYPE_DOMAIN_ENUM
) {
217 /* See if we can find the workgroup on this subnet. */
218 if((work
=find_workgroup_on_subnet(unicast_subnet
, sname
))) {
219 /* We already know about this workgroup -
221 update_workgroup_ttl(work
,lp_max_ttl());
223 /* Create the workgroup on the subnet. */
224 work
= create_workgroup_on_subnet(unicast_subnet
,
225 sname
, lp_max_ttl());
227 /* remember who the master is */
228 unstrcpy(work
->local_master_browser_name
, comment
);
234 work
= find_workgroup_on_subnet(unicast_subnet
, s
->workgroup
);
236 DEBUG(3,("workgroup %s doesn't exist on unicast subnet?\n",
241 if ((servrec
= find_server_in_workgroup( work
, sname
))) {
242 /* Check that this is not a locally known
243 server - if so ignore the entry. */
244 if(!(servrec
->serv
.type
& SV_TYPE_LOCAL_LIST_ONLY
)) {
245 /* We already know about this server - update
247 update_server_ttl(servrec
, lp_max_ttl());
248 /* Update the type. */
249 servrec
->serv
.type
= stype
;
254 /* Create the server in the workgroup. */
255 create_server_on_workgroup(work
, sname
,stype
, lp_max_ttl(), comment
);
258 /**********************************************************************
259 Read the completed sync info.
260 **********************************************************************/
262 static void complete_sync(struct sync_record
*s
)
273 f
= x_fopen(s
->fname
,O_RDONLY
, 0);
279 TALLOC_CTX
*frame
= NULL
;
281 if (!fgets_slash(line
,sizeof(line
),f
))
286 frame
= talloc_stackframe();
287 if (!next_token_talloc(frame
,&ptr
,&server
,NULL
) ||
288 !next_token_talloc(frame
,&ptr
,&type_str
,NULL
) ||
289 !next_token_talloc(frame
,&ptr
,&comment
,NULL
)) {
294 sscanf(type_str
, "%X", &type
);
296 complete_one(s
, server
, type
, comment
);
305 DEBUG(2,("sync with %s(%s) for workgroup %s completed (%d records)\n",
306 s
->server
, inet_ntoa(s
->ip
), s
->workgroup
, count
));
309 /**********************************************************************
310 Check for completion of any of the child processes.
311 **********************************************************************/
313 void sync_check_completion(void)
315 struct sync_record
*s
, *next
;
317 for (s
=syncs
;s
;s
=next
) {
319 if (!process_exists_by_pid(s
->pid
)) {
320 /* it has completed - grab the info */
322 DLIST_REMOVE(syncs
, s
);