3 * Bacula Director -- User Agent Server
5 * Kern Sibbald, September MM
10 Bacula® - The Network Backup Solution
12 Copyright (C) 2000-2006 Free Software Foundation Europe e.V.
14 The main author of Bacula is Kern Sibbald, with contributions from
15 many others, a complete list can be found in the file AUTHORS.
16 This program is Free Software; you can redistribute it and/or
17 modify it under the terms of version two of the GNU General Public
18 License as published by the Free Software Foundation plus additions
19 that are listed in the file LICENSE.
21 This program is distributed in the hope that it will be useful, but
22 WITHOUT ANY WARRANTY; without even the implied warranty of
23 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
24 General Public License for more details.
26 You should have received a copy of the GNU General Public License
27 along with this program; if not, write to the Free Software
28 Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA
31 Bacula® is a registered trademark ofJohn Walker.
32 The licensor of Bacula is the Free Software Foundation Europe
33 (FSFE), Fiduciary Program, Sumatrastrasse 25, 8006 Zürich,
34 Switzerland, email:ftf@fsfeurope.org.
40 /* Imported variables */
43 extern struct s_res resources[];
46 /* Forward referenced functions */
47 extern "C" void *connect_thread(void *arg);
48 static void *handle_UA_client_request(void *arg);
51 /* Global variables */
52 static int started = FALSE;
53 static workq_t ua_workq;
60 /* Called here by Director daemon to start UA (user agent)
61 * command thread. This routine creates the thread and then
64 void start_UA_server(dlist *addrs)
68 static dlist *myaddrs = addrs;
70 if ((status=pthread_create(&thid, NULL, connect_thread, (void *)myaddrs)) != 0) {
72 Emsg1(M_ABORT, 0, _("Cannot create UA thread: %s\n"), be.strerror(status));
79 void *connect_thread(void *arg)
81 pthread_detach(pthread_self());
83 /* Permit 10 console connections */
84 bnet_thread_server((dlist*)arg, 10, &ua_workq, handle_UA_client_request);
89 * Create a Job Control Record for a control "job",
90 * filling in all the appropriate fields.
92 JCR *new_control_jcr(const char *base_name, int job_type)
95 jcr = new_jcr(sizeof(JCR), dird_free_jcr);
97 * The job and defaults are not really used, but
98 * we set them up to ensure that everything is correctly
102 jcr->job = (JOB *)GetNextRes(R_JOB, NULL);
103 set_jcr_defaults(jcr, jcr->job);
105 jcr->sd_auth_key = bstrdup("dummy"); /* dummy Storage daemon key */
106 create_unique_job_name(jcr, base_name);
107 jcr->sched_time = jcr->start_time;
108 jcr->JobType = job_type;
109 jcr->JobLevel = L_NONE;
110 set_jcr_job_status(jcr, JS_Running);
116 * Handle Director User Agent commands
119 static void *handle_UA_client_request(void *arg)
125 pthread_detach(pthread_self());
127 jcr = new_control_jcr("*Console*", JT_CONSOLE);
129 ua = new_ua_context(jcr);
130 ua->UA_sock = (BSOCK *)arg;
132 bnet_recv(ua->UA_sock); /* Get first message */
133 if (!authenticate_user_agent(ua)) {
138 stat = bnet_recv(ua->UA_sock);
140 pm_strcpy(ua->cmd, ua->UA_sock->msg);
142 if (ua->argc > 0 && ua->argk[0][0] == '.') {
143 do_a_dot_command(ua, ua->cmd);
145 do_a_command(ua, ua->cmd);
148 if (acl_access_ok(ua, Command_ACL, "messages", 8)) {
149 if (ua->auto_display_messages) {
150 pm_strcpy(ua->cmd, "messages");
151 qmessagescmd(ua, ua->cmd);
152 ua->user_notified_msg_pending = FALSE;
153 } else if (!ua->gui && !ua->user_notified_msg_pending && console_msg_pending) {
154 bsendmsg(ua, _("You have messages.\n"));
155 ua->user_notified_msg_pending = TRUE;
158 bnet_sig(ua->UA_sock, BNET_EOD); /* send end of command */
160 } else if (is_bnet_stop(ua->UA_sock)) {
162 } else { /* signal */
163 bnet_sig(ua->UA_sock, BNET_POLL);
176 * Create a UAContext for a Job that is running so that
177 * it can the User Agent routines and
178 * to ensure that the Job gets the proper output.
179 * This is a sort of mini-kludge, and should be
180 * unified at some point.
182 UAContext *new_ua_context(JCR *jcr)
186 ua = (UAContext *)malloc(sizeof(UAContext));
187 memset(ua, 0, sizeof(UAContext));
190 ua->cmd = get_pool_memory(PM_FNAME);
191 ua->args = get_pool_memory(PM_FNAME);
193 ua->automount = true;
197 void free_ua_context(UAContext *ua)
200 free_pool_memory(ua->cmd);
203 free_pool_memory(ua->args);
210 bnet_close(ua->UA_sock);
218 * Called from main Bacula thread
220 void term_ua_server()