2 Unix SMB/Netbios implementation.
4 printing backend routines
5 Copyright (C) Andrew Tridgell 1992-2000
6 Copyright (C) Jeremy Allison 2002
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 #include "system/syslog.h"
24 #include "system/filesys.h"
26 #include "../librpc/gen_ndr/ndr_spoolss.h"
27 #include "nt_printing.h"
28 #include "../librpc/gen_ndr/netlogon.h"
29 #include "printing/notify.h"
30 #include "printing/pcap.h"
31 #include "printing/printer_list.h"
32 #include "printing/queue_process.h"
34 #include "smbd/smbd.h"
38 #include "lib/param/loadparm.h"
39 #include "lib/util/sys_rw_data.h"
41 extern userdom_struct current_user_info
;
43 /* Current printer interface */
44 static bool remove_from_jobs_added(const char* sharename
, uint32_t jobid
);
47 the printing backend revolves around a tdb database that stores the
48 SMB view of the print queue
50 The key for this database is a jobid - a internally generated number that
51 uniquely identifies a print job
53 reading the print queue involves two steps:
54 - possibly running lpq and updating the internal database from that
55 - reading entries from the database
57 jobids are assigned when a job starts spooling.
60 static TDB_CONTEXT
*rap_tdb
;
61 static uint16_t next_rap_jobid
;
62 struct rap_jobid_key
{
67 /***************************************************************************
68 Nightmare. LANMAN jobid's are 16 bit numbers..... We must map them to 32
69 bit RPC jobids.... JRA.
70 ***************************************************************************/
72 uint16_t pjobid_to_rap(const char* sharename
, uint32_t jobid
)
76 struct rap_jobid_key jinfo
;
79 DEBUG(10,("pjobid_to_rap: called.\n"));
82 /* Create the in-memory tdb. */
83 rap_tdb
= tdb_open_log(NULL
, 0, TDB_INTERNAL
, (O_RDWR
|O_CREAT
), 0644);
89 fstrcpy( jinfo
.sharename
, sharename
);
91 key
.dptr
= (uint8_t *)&jinfo
;
92 key
.dsize
= sizeof(jinfo
);
94 data
= tdb_fetch(rap_tdb
, key
);
95 if (data
.dptr
&& data
.dsize
== sizeof(uint16_t)) {
96 rap_jobid
= SVAL(data
.dptr
, 0);
98 DEBUG(10,("pjobid_to_rap: jobid %u maps to RAP jobid %u\n",
99 (unsigned int)jobid
, (unsigned int)rap_jobid
));
102 SAFE_FREE(data
.dptr
);
103 /* Not found - create and store mapping. */
104 rap_jobid
= ++next_rap_jobid
;
106 rap_jobid
= ++next_rap_jobid
;
107 SSVAL(buf
,0,rap_jobid
);
109 data
.dsize
= sizeof(rap_jobid
);
110 tdb_store(rap_tdb
, key
, data
, TDB_REPLACE
);
111 tdb_store(rap_tdb
, data
, key
, TDB_REPLACE
);
113 DEBUG(10,("pjobid_to_rap: created jobid %u maps to RAP jobid %u\n",
114 (unsigned int)jobid
, (unsigned int)rap_jobid
));
118 bool rap_to_pjobid(uint16_t rap_jobid
, fstring sharename
, uint32_t *pjobid
)
123 DEBUG(10,("rap_to_pjobid called.\n"));
128 SSVAL(buf
,0,rap_jobid
);
130 key
.dsize
= sizeof(rap_jobid
);
131 data
= tdb_fetch(rap_tdb
, key
);
132 if ( data
.dptr
&& data
.dsize
== sizeof(struct rap_jobid_key
) )
134 struct rap_jobid_key
*jinfo
= (struct rap_jobid_key
*)data
.dptr
;
135 if (sharename
!= NULL
) {
136 fstrcpy( sharename
, jinfo
->sharename
);
138 *pjobid
= jinfo
->jobid
;
139 DEBUG(10,("rap_to_pjobid: jobid %u maps to RAP jobid %u\n",
140 (unsigned int)*pjobid
, (unsigned int)rap_jobid
));
141 SAFE_FREE(data
.dptr
);
145 DEBUG(10,("rap_to_pjobid: Failed to lookup RAP jobid %u\n",
146 (unsigned int)rap_jobid
));
147 SAFE_FREE(data
.dptr
);
151 void rap_jobid_delete(const char* sharename
, uint32_t jobid
)
155 struct rap_jobid_key jinfo
;
158 DEBUG(10,("rap_jobid_delete: called.\n"));
163 ZERO_STRUCT( jinfo
);
164 fstrcpy( jinfo
.sharename
, sharename
);
166 key
.dptr
= (uint8_t *)&jinfo
;
167 key
.dsize
= sizeof(jinfo
);
169 data
= tdb_fetch(rap_tdb
, key
);
170 if (!data
.dptr
|| (data
.dsize
!= sizeof(uint16_t))) {
171 DEBUG(10,("rap_jobid_delete: cannot find jobid %u\n",
172 (unsigned int)jobid
));
173 SAFE_FREE(data
.dptr
);
177 DEBUG(10,("rap_jobid_delete: deleting jobid %u\n",
178 (unsigned int)jobid
));
180 rap_jobid
= SVAL(data
.dptr
, 0);
181 SAFE_FREE(data
.dptr
);
182 SSVAL(buf
,0,rap_jobid
);
184 data
.dsize
= sizeof(rap_jobid
);
185 tdb_delete(rap_tdb
, key
);
186 tdb_delete(rap_tdb
, data
);
189 static int get_queue_status(const char* sharename
, print_status_struct
*);
191 /****************************************************************************
192 Initialise the printing backend. Called once at startup before the fork().
193 ****************************************************************************/
195 bool print_backend_init(struct messaging_context
*msg_ctx
)
197 const char *sversion
= "INFO/version";
198 int services
= lp_numservices();
201 char *print_cache_path
;
203 if (!printer_list_parent_init()) {
207 print_cache_path
= cache_path(talloc_tos(), "printing");
208 if (print_cache_path
== NULL
) {
211 ok
= directory_create_or_exist(print_cache_path
, 0755);
212 TALLOC_FREE(print_cache_path
);
217 print_cache_path
= cache_path(talloc_tos(), "printing.tdb");
218 if (print_cache_path
== NULL
) {
221 unlink(print_cache_path
);
222 TALLOC_FREE(print_cache_path
);
224 /* handle a Samba upgrade */
226 for (snum
= 0; snum
< services
; snum
++) {
227 struct tdb_print_db
*pdb
;
228 if (!lp_printable(snum
))
231 pdb
= get_print_db_byname(lp_const_servicename(snum
));
234 if (tdb_lock_bystring(pdb
->tdb
, sversion
) != 0) {
235 DEBUG(0,("print_backend_init: Failed to open printer %s database\n", lp_const_servicename(snum
) ));
236 release_print_db(pdb
);
239 if (tdb_fetch_int32(pdb
->tdb
, sversion
) != PRINT_DATABASE_VERSION
) {
240 tdb_wipe_all(pdb
->tdb
);
241 tdb_store_int32(pdb
->tdb
, sversion
, PRINT_DATABASE_VERSION
);
243 tdb_unlock_bystring(pdb
->tdb
, sversion
);
244 release_print_db(pdb
);
247 close_all_print_db(); /* Don't leave any open. */
249 /* do NT print initialization... */
250 return nt_printing_init(msg_ctx
);
253 /****************************************************************************
254 Shut down printing backend. Called once at shutdown to close the tdb.
255 ****************************************************************************/
257 void printing_end(void)
259 close_all_print_db(); /* Don't leave any open. */
262 /****************************************************************************
263 Retrieve the set of printing functions for a given service. This allows
264 us to set the printer function table based on the value of the 'printing'
267 Use the generic interface as the default and only use cups interface only
268 when asked for (and only when supported)
269 ****************************************************************************/
271 static struct printif
*get_printer_fns_from_type( enum printing_types type
)
273 struct printif
*printer_fns
= &generic_printif
;
276 if ( type
== PRINT_CUPS
) {
277 printer_fns
= &cups_printif
;
279 #endif /* HAVE_CUPS */
282 if ( type
== PRINT_IPRINT
) {
283 printer_fns
= &iprint_printif
;
285 #endif /* HAVE_IPRINT */
287 printer_fns
->type
= type
;
292 static struct printif
*get_printer_fns( int snum
)
294 return get_printer_fns_from_type( (enum printing_types
)lp_printing(snum
) );
298 /****************************************************************************
299 Useful function to generate a tdb key.
300 ****************************************************************************/
302 static TDB_DATA
print_key(uint32_t jobid
, uint32_t *tmp
)
306 SIVAL(tmp
, 0, jobid
);
307 ret
.dptr
= (uint8_t *)tmp
;
308 ret
.dsize
= sizeof(*tmp
);
312 /****************************************************************************
313 Pack the devicemode to store it in a tdb.
314 ****************************************************************************/
315 static int pack_devicemode(struct spoolss_DeviceMode
*devmode
, uint8_t *buf
, int buflen
)
317 enum ndr_err_code ndr_err
;
322 ndr_err
= ndr_push_struct_blob(&blob
, talloc_tos(),
324 (ndr_push_flags_fn_t
)
325 ndr_push_spoolss_DeviceMode
);
326 if (!NDR_ERR_CODE_IS_SUCCESS(ndr_err
)) {
327 DEBUG(10, ("pack_devicemode: "
328 "error encoding spoolss_DeviceMode\n"));
335 len
= tdb_pack(buf
, buflen
, "B", blob
.length
, blob
.data
);
338 DEBUG(8, ("Packed devicemode [%s]\n", devmode
->formname
));
345 /****************************************************************************
346 Unpack the devicemode to store it in a tdb.
347 ****************************************************************************/
348 static int unpack_devicemode(TALLOC_CTX
*mem_ctx
,
349 const uint8_t *buf
, int buflen
,
350 struct spoolss_DeviceMode
**devmode
)
352 struct spoolss_DeviceMode
*dm
;
353 enum ndr_err_code ndr_err
;
355 uint32_t data_len
= 0;
361 len
= tdb_unpack(buf
, buflen
, "B", &data_len
, &data
);
366 dm
= talloc_zero(mem_ctx
, struct spoolss_DeviceMode
);
371 blob
= data_blob_const(data
, data_len
);
373 ndr_err
= ndr_pull_struct_blob(&blob
, dm
, dm
,
374 (ndr_pull_flags_fn_t
)ndr_pull_spoolss_DeviceMode
);
375 if (!NDR_ERR_CODE_IS_SUCCESS(ndr_err
)) {
376 DEBUG(10, ("unpack_devicemode: "
377 "error parsing spoolss_DeviceMode\n"));
381 DEBUG(8, ("Unpacked devicemode [%s](%s)\n",
382 dm
->devicename
, dm
->formname
));
383 if (dm
->driverextra_data
.data
) {
384 DEBUG(8, ("with a private section of %d bytes\n",
385 dm
->__driverextra_length
));
395 /***********************************************************************
396 unpack a pjob from a tdb buffer
397 ***********************************************************************/
399 static int unpack_pjob(TALLOC_CTX
*mem_ctx
, uint8_t *buf
, int buflen
,
400 struct printjob
*pjob
)
404 uint32_t pjpid
, pjjobid
, pjsysjob
, pjfd
, pjstarttime
, pjstatus
;
405 uint32_t pjsize
, pjpage_count
, pjspooled
, pjsmbjob
;
411 len
+= tdb_unpack(buf
+len
, buflen
-len
, "ddddddddddfffff",
432 used
= unpack_devicemode(mem_ctx
, buf
+len
, buflen
-len
, &pjob
->devmode
);
440 pjob
->jobid
= pjjobid
;
441 pjob
->sysjob
= pjsysjob
;
443 pjob
->starttime
= pjstarttime
;
444 pjob
->status
= pjstatus
;
446 pjob
->page_count
= pjpage_count
;
447 pjob
->spooled
= pjspooled
;
448 pjob
->smbjob
= pjsmbjob
;
454 /****************************************************************************
455 Useful function to find a print job in the database.
456 ****************************************************************************/
458 static struct printjob
*print_job_find(TALLOC_CTX
*mem_ctx
,
459 const char *sharename
,
462 struct printjob
*pjob
;
465 struct tdb_print_db
*pdb
= get_print_db_byname(sharename
);
467 DEBUG(10,("print_job_find: looking up job %u for share %s\n",
468 (unsigned int)jobid
, sharename
));
474 ret
= tdb_fetch(pdb
->tdb
, print_key(jobid
, &tmp
));
475 release_print_db(pdb
);
478 DEBUG(10, ("print_job_find: failed to find jobid %u.\n",
483 pjob
= talloc_zero(mem_ctx
, struct printjob
);
488 if (unpack_pjob(mem_ctx
, ret
.dptr
, ret
.dsize
, pjob
) == -1) {
489 DEBUG(10, ("failed to unpack jobid %u.\n", jobid
));
495 DEBUG(10,("print_job_find: returning system job %d for jobid %u.\n",
496 pjob
->sysjob
, jobid
));
497 SMB_ASSERT(pjob
->jobid
== jobid
);
504 struct job_traverse_state
{
509 /* find spoolss jobid based on sysjob */
510 static int sysjob_to_jobid_traverse_fn(TDB_CONTEXT
*the_tdb
, TDB_DATA key
,
511 TDB_DATA data
, void *private_data
)
513 struct printjob
*pjob
;
514 struct job_traverse_state
*state
=
515 (struct job_traverse_state
*)private_data
;
517 if (!data
.dptr
|| data
.dsize
== 0)
520 pjob
= (struct printjob
*)data
.dptr
;
521 if (key
.dsize
!= sizeof(uint32_t))
524 if (state
->sysjob
== pjob
->sysjob
) {
525 state
->jobid
= pjob
->jobid
;
532 uint32_t sysjob_to_jobid_pdb(struct tdb_print_db
*pdb
, int sysjob
)
534 struct job_traverse_state state
;
536 state
.sysjob
= sysjob
;
537 state
.jobid
= (uint32_t)-1;
539 tdb_traverse(pdb
->tdb
, sysjob_to_jobid_traverse_fn
, &state
);
544 /****************************************************************************
545 This is a *horribly expensive call as we have to iterate through all the
546 current printer tdb's. Don't do this often ! JRA.
547 ****************************************************************************/
549 uint32_t sysjob_to_jobid(int unix_jobid
)
551 int services
= lp_numservices();
553 struct job_traverse_state state
;
555 state
.sysjob
= unix_jobid
;
556 state
.jobid
= (uint32_t)-1;
558 for (snum
= 0; snum
< services
; snum
++) {
559 struct tdb_print_db
*pdb
;
560 if (!lp_printable(snum
))
562 pdb
= get_print_db_byname(lp_const_servicename(snum
));
566 tdb_traverse(pdb
->tdb
, sysjob_to_jobid_traverse_fn
, &state
);
567 release_print_db(pdb
);
568 if (state
.jobid
!= (uint32_t)-1)
574 /* find sysjob based on spoolss jobid */
575 static int jobid_to_sysjob_traverse_fn(TDB_CONTEXT
*the_tdb
, TDB_DATA key
,
576 TDB_DATA data
, void *private_data
)
578 struct printjob
*pjob
;
579 struct job_traverse_state
*state
=
580 (struct job_traverse_state
*)private_data
;
582 if (!data
.dptr
|| data
.dsize
== 0)
585 pjob
= (struct printjob
*)data
.dptr
;
586 if (key
.dsize
!= sizeof(uint32_t))
589 if (state
->jobid
== pjob
->jobid
) {
590 state
->sysjob
= pjob
->sysjob
;
597 int jobid_to_sysjob_pdb(struct tdb_print_db
*pdb
, uint32_t jobid
)
599 struct job_traverse_state state
;
604 tdb_traverse(pdb
->tdb
, jobid_to_sysjob_traverse_fn
, &state
);
609 /****************************************************************************
610 Send notifications based on what has changed after a pjob_store.
611 ****************************************************************************/
613 static const struct {
615 uint32_t spoolss_status
;
616 } lpq_to_spoolss_status_map
[] = {
617 { LPQ_QUEUED
, JOB_STATUS_QUEUED
},
618 { LPQ_PAUSED
, JOB_STATUS_PAUSED
},
619 { LPQ_SPOOLING
, JOB_STATUS_SPOOLING
},
620 { LPQ_PRINTING
, JOB_STATUS_PRINTING
},
621 { LPQ_DELETING
, JOB_STATUS_DELETING
},
622 { LPQ_OFFLINE
, JOB_STATUS_OFFLINE
},
623 { LPQ_PAPEROUT
, JOB_STATUS_PAPEROUT
},
624 { LPQ_PRINTED
, JOB_STATUS_PRINTED
},
625 { LPQ_DELETED
, JOB_STATUS_DELETED
},
626 { LPQ_BLOCKED
, JOB_STATUS_BLOCKED_DEVQ
},
627 { LPQ_USER_INTERVENTION
, JOB_STATUS_USER_INTERVENTION
},
631 /* Convert a lpq status value stored in printing.tdb into the
632 appropriate win32 API constant. */
634 static uint32_t map_to_spoolss_status(uint32_t lpq_status
)
638 while (lpq_to_spoolss_status_map
[i
].lpq_status
!= -1) {
639 if (lpq_to_spoolss_status_map
[i
].lpq_status
== lpq_status
)
640 return lpq_to_spoolss_status_map
[i
].spoolss_status
;
647 /***************************************************************************
648 Append a jobid to the 'jobs changed' list.
649 ***************************************************************************/
651 static bool add_to_jobs_changed(struct tdb_print_db
*pdb
, uint32_t jobid
)
654 uint32_t store_jobid
;
656 SIVAL(&store_jobid
, 0, jobid
);
657 data
.dptr
= (uint8_t *) &store_jobid
;
660 DEBUG(10,("add_to_jobs_added: Added jobid %u\n", (unsigned int)jobid
));
662 return (tdb_append(pdb
->tdb
, string_tdb_data("INFO/jobs_changed"),
666 /***************************************************************************
667 Remove a jobid from the 'jobs changed' list.
668 ***************************************************************************/
670 static bool remove_from_jobs_changed(const char* sharename
, uint32_t jobid
)
672 struct tdb_print_db
*pdb
= get_print_db_byname(sharename
);
676 bool gotlock
= False
;
684 key
= string_tdb_data("INFO/jobs_changed");
686 if (tdb_chainlock_with_timeout(pdb
->tdb
, key
, 5) != 0)
691 data
= tdb_fetch(pdb
->tdb
, key
);
693 if (data
.dptr
== NULL
|| data
.dsize
== 0 || (data
.dsize
% 4 != 0))
696 job_count
= data
.dsize
/ 4;
697 for (i
= 0; i
< job_count
; i
++) {
700 ch_jobid
= IVAL(data
.dptr
, i
*4);
701 if (ch_jobid
== jobid
) {
702 if (i
< job_count
-1 )
703 memmove(data
.dptr
+ (i
*4), data
.dptr
+ (i
*4) + 4, (job_count
- i
- 1)*4 );
705 if (tdb_store(pdb
->tdb
, key
, data
, TDB_REPLACE
) != 0)
715 tdb_chainunlock(pdb
->tdb
, key
);
716 SAFE_FREE(data
.dptr
);
717 release_print_db(pdb
);
719 DEBUG(10,("remove_from_jobs_changed: removed jobid %u\n", (unsigned int)jobid
));
721 DEBUG(10,("remove_from_jobs_changed: Failed to remove jobid %u\n", (unsigned int)jobid
));
725 static void pjob_store_notify(struct tevent_context
*ev
,
726 struct messaging_context
*msg_ctx
,
727 const char* sharename
, uint32_t jobid
,
728 struct printjob
*old_data
,
729 struct printjob
*new_data
,
732 bool new_job
= false;
733 bool changed
= false;
735 if (old_data
== NULL
) {
739 /* ACHTUNG! Due to a bug in Samba's spoolss parsing of the
740 NOTIFY_INFO_DATA buffer, we *have* to send the job submission
741 time first or else we'll end up with potential alignment
742 errors. I don't think the systemtime should be spooled as
743 a string, but this gets us around that error.
744 --jerry (i'll feel dirty for this) */
747 notify_job_submitted(ev
, msg_ctx
,
748 sharename
, jobid
, new_data
->starttime
);
749 notify_job_username(ev
, msg_ctx
,
750 sharename
, jobid
, new_data
->user
);
751 notify_job_name(ev
, msg_ctx
,
752 sharename
, jobid
, new_data
->jobname
);
753 notify_job_status(ev
, msg_ctx
,
754 sharename
, jobid
, map_to_spoolss_status(new_data
->status
));
755 notify_job_total_bytes(ev
, msg_ctx
,
756 sharename
, jobid
, new_data
->size
);
757 notify_job_total_pages(ev
, msg_ctx
,
758 sharename
, jobid
, new_data
->page_count
);
760 if (!strequal(old_data
->jobname
, new_data
->jobname
)) {
761 notify_job_name(ev
, msg_ctx
, sharename
,
762 jobid
, new_data
->jobname
);
766 if (old_data
->status
!= new_data
->status
) {
767 notify_job_status(ev
, msg_ctx
,
769 map_to_spoolss_status(new_data
->status
));
772 if (old_data
->size
!= new_data
->size
) {
773 notify_job_total_bytes(ev
, msg_ctx
,
774 sharename
, jobid
, new_data
->size
);
777 if (old_data
->page_count
!= new_data
->page_count
) {
778 notify_job_total_pages(ev
, msg_ctx
,
780 new_data
->page_count
);
787 /****************************************************************************
788 Store a job structure back to the database.
789 ****************************************************************************/
791 static bool pjob_store(struct tevent_context
*ev
,
792 struct messaging_context
*msg_ctx
,
793 const char* sharename
, uint32_t jobid
,
794 struct printjob
*pjob
)
797 TDB_DATA old_data
, new_data
;
799 struct tdb_print_db
*pdb
= get_print_db_byname(sharename
);
801 int len
, newlen
, buflen
;
809 old_data
= tdb_fetch(pdb
->tdb
, print_key(jobid
, &tmp
));
811 /* Doh! Now we have to pack/unpack data since the NT_DEVICEMODE was added */
818 len
+= tdb_pack(buf
+len
, buflen
-len
, "ddddddddddfffff",
820 (uint32_t)pjob
->jobid
,
821 (uint32_t)pjob
->sysjob
,
823 (uint32_t)pjob
->starttime
,
824 (uint32_t)pjob
->status
,
825 (uint32_t)pjob
->size
,
826 (uint32_t)pjob
->page_count
,
827 (uint32_t)pjob
->spooled
,
828 (uint32_t)pjob
->smbjob
,
835 len
+= pack_devicemode(pjob
->devmode
, buf
+len
, buflen
-len
);
838 buf
= (uint8_t *)SMB_REALLOC(buf
, len
);
840 DEBUG(0,("pjob_store: failed to enlarge buffer!\n"));
845 } while ( buflen
!= len
);
851 new_data
.dsize
= len
;
852 ret
= (tdb_store(pdb
->tdb
, print_key(jobid
, &tmp
), new_data
,
855 /* Send notify updates for what has changed */
858 bool changed
= false;
859 struct printjob old_pjob
;
861 if (old_data
.dsize
) {
862 TALLOC_CTX
*tmp_ctx
= talloc_new(ev
);
866 len
= unpack_pjob(tmp_ctx
, old_data
.dptr
,
867 old_data
.dsize
, &old_pjob
);
869 pjob_store_notify(ev
,
871 sharename
, jobid
, &old_pjob
,
875 add_to_jobs_changed(pdb
, jobid
);
878 talloc_free(tmp_ctx
);
882 pjob_store_notify(ev
, msg_ctx
,
883 sharename
, jobid
, NULL
, pjob
,
889 release_print_db(pdb
);
890 SAFE_FREE( old_data
.dptr
);
896 /****************************************************************************
897 Remove a job structure from the database.
898 ****************************************************************************/
900 static void pjob_delete(struct tevent_context
*ev
,
901 struct messaging_context
*msg_ctx
,
902 const char* sharename
, uint32_t jobid
)
905 struct printjob
*pjob
;
906 uint32_t job_status
= 0;
907 struct tdb_print_db
*pdb
;
908 TALLOC_CTX
*tmp_ctx
= talloc_new(ev
);
909 if (tmp_ctx
== NULL
) {
913 pdb
= get_print_db_byname(sharename
);
918 pjob
= print_job_find(tmp_ctx
, sharename
, jobid
);
920 DEBUG(5, ("we were asked to delete nonexistent job %u\n",
925 /* We must cycle through JOB_STATUS_DELETING and
926 JOB_STATUS_DELETED for the port monitor to delete the job
929 job_status
= JOB_STATUS_DELETING
|JOB_STATUS_DELETED
;
930 notify_job_status(ev
, msg_ctx
, sharename
, jobid
, job_status
);
932 /* Remove from printing.tdb */
934 tdb_delete(pdb
->tdb
, print_key(jobid
, &tmp
));
935 remove_from_jobs_added(sharename
, jobid
);
936 rap_jobid_delete(sharename
, jobid
);
938 release_print_db(pdb
);
940 talloc_free(tmp_ctx
);
943 /****************************************************************************
944 List a unix job in the print database.
945 ****************************************************************************/
947 static void print_unix_job(struct tevent_context
*ev
,
948 struct messaging_context
*msg_ctx
,
949 const char *sharename
, print_queue_struct
*q
,
952 struct printjob pj
, *old_pj
;
953 TALLOC_CTX
*tmp_ctx
= talloc_new(ev
);
954 if (tmp_ctx
== NULL
) {
958 if (jobid
== (uint32_t)-1) {
959 jobid
= q
->sysjob
+ UNIX_JOB_START
;
962 /* Preserve the timestamp on an existing unix print job */
964 old_pj
= print_job_find(tmp_ctx
, sharename
, jobid
);
970 pj
.sysjob
= q
->sysjob
;
972 pj
.starttime
= old_pj
? old_pj
->starttime
: q
->time
;
973 pj
.status
= q
->status
;
976 fstrcpy(pj
.filename
, old_pj
? old_pj
->filename
: "");
977 if (jobid
< UNIX_JOB_START
) {
979 fstrcpy(pj
.jobname
, old_pj
? old_pj
->jobname
: "Remote Downlevel Document");
982 fstrcpy(pj
.jobname
, old_pj
? old_pj
->jobname
: q
->fs_file
);
984 fstrcpy(pj
.user
, old_pj
? old_pj
->user
: q
->fs_user
);
985 fstrcpy(pj
.queuename
, old_pj
? old_pj
->queuename
: sharename
);
987 pjob_store(ev
, msg_ctx
, sharename
, jobid
, &pj
);
988 talloc_free(tmp_ctx
);
992 struct traverse_struct
{
993 print_queue_struct
*queue
;
994 size_t qcount
, snum
, maxcount
, total_jobs
;
995 const char *sharename
;
997 const char *lprm_command
;
998 struct printif
*print_if
;
999 struct tevent_context
*ev
;
1000 struct messaging_context
*msg_ctx
;
1001 TALLOC_CTX
*mem_ctx
;
1004 /****************************************************************************
1005 Utility fn to delete any jobs that are no longer active.
1006 ****************************************************************************/
1008 static int traverse_fn_delete(TDB_CONTEXT
*t
, TDB_DATA key
, TDB_DATA data
, void *state
)
1010 struct traverse_struct
*ts
= (struct traverse_struct
*)state
;
1011 struct printjob pjob
;
1015 if ( key
.dsize
!= sizeof(jobid
) )
1018 if (unpack_pjob(ts
->mem_ctx
, data
.dptr
, data
.dsize
, &pjob
) == -1)
1020 talloc_free(pjob
.devmode
);
1024 /* remove a unix job if it isn't in the system queue any more */
1025 for (i
=0;i
<ts
->qcount
;i
++) {
1026 if (ts
->queue
[i
].sysjob
== pjob
.sysjob
) {
1030 if (i
== ts
->qcount
) {
1031 DEBUG(10,("traverse_fn_delete: pjob %u deleted due to !smbjob\n",
1032 (unsigned int)jobid
));
1033 pjob_delete(ts
->ev
, ts
->msg_ctx
,
1034 ts
->sharename
, jobid
);
1038 /* need to continue the the bottom of the function to
1039 save the correct attributes */
1042 /* maybe it hasn't been spooled yet */
1043 if (!pjob
.spooled
) {
1044 /* if a job is not spooled and the process doesn't
1045 exist then kill it. This cleans up after smbd
1047 if (!process_exists_by_pid(pjob
.pid
)) {
1048 DEBUG(10,("traverse_fn_delete: pjob %u deleted due to !process_exists (%u)\n",
1049 (unsigned int)jobid
, (unsigned int)pjob
.pid
));
1050 pjob_delete(ts
->ev
, ts
->msg_ctx
,
1051 ts
->sharename
, jobid
);
1057 /* this check only makes sense for jobs submitted from Windows clients */
1060 for (i
=0;i
<ts
->qcount
;i
++) {
1061 if ( pjob
.status
== LPQ_DELETED
)
1064 if (ts
->queue
[i
].sysjob
== pjob
.sysjob
) {
1066 /* try to clean up any jobs that need to be deleted */
1068 if ( pjob
.status
== LPQ_DELETING
) {
1071 result
= (*(ts
->print_if
->job_delete
))(
1072 ts
->sharename
, ts
->lprm_command
, &pjob
);
1074 if ( result
!= 0 ) {
1075 /* if we can't delete, then reset the job status */
1076 pjob
.status
= LPQ_QUEUED
;
1077 pjob_store(ts
->ev
, ts
->msg_ctx
,
1078 ts
->sharename
, jobid
, &pjob
);
1081 /* if we deleted the job, the remove the tdb record */
1084 ts
->sharename
, jobid
);
1085 pjob
.status
= LPQ_DELETED
;
1095 /* The job isn't in the system queue - we have to assume it has
1096 completed, so delete the database entry. */
1098 if (i
== ts
->qcount
) {
1100 /* A race can occur between the time a job is spooled and
1101 when it appears in the lpq output. This happens when
1102 the job is added to printing.tdb when another smbd
1103 running print_queue_update() has completed a lpq and
1104 is currently traversing the printing tdb and deleting jobs.
1105 Don't delete the job if it was submitted after the lpq_time. */
1107 if (pjob
.starttime
< ts
->lpq_time
) {
1108 DEBUG(10,("traverse_fn_delete: pjob %u deleted due to pjob.starttime (%u) < ts->lpq_time (%u)\n",
1109 (unsigned int)jobid
,
1110 (unsigned int)pjob
.starttime
,
1111 (unsigned int)ts
->lpq_time
));
1112 pjob_delete(ts
->ev
, ts
->msg_ctx
,
1113 ts
->sharename
, jobid
);
1119 /* Save the pjob attributes we will store. */
1120 ts
->queue
[i
].sysjob
= pjob
.sysjob
;
1121 ts
->queue
[i
].size
= pjob
.size
;
1122 ts
->queue
[i
].page_count
= pjob
.page_count
;
1123 ts
->queue
[i
].status
= pjob
.status
;
1124 ts
->queue
[i
].priority
= 1;
1125 ts
->queue
[i
].time
= pjob
.starttime
;
1126 fstrcpy(ts
->queue
[i
].fs_user
, pjob
.user
);
1127 fstrcpy(ts
->queue
[i
].fs_file
, pjob
.jobname
);
1134 /****************************************************************************
1135 Check if the print queue has been updated recently enough.
1136 ****************************************************************************/
1138 static void print_cache_flush(const char *sharename
)
1141 struct tdb_print_db
*pdb
= get_print_db_byname(sharename
);
1145 slprintf(key
, sizeof(key
)-1, "CACHE/%s", sharename
);
1146 tdb_store_int32(pdb
->tdb
, key
, -1);
1147 release_print_db(pdb
);
1150 /****************************************************************************
1151 Check if someone already thinks they are doing the update.
1152 ****************************************************************************/
1154 static pid_t
get_updating_pid(const char *sharename
)
1159 struct tdb_print_db
*pdb
= get_print_db_byname(sharename
);
1163 slprintf(keystr
, sizeof(keystr
)-1, "UPDATING/%s", sharename
);
1164 key
= string_tdb_data(keystr
);
1166 data
= tdb_fetch(pdb
->tdb
, key
);
1167 release_print_db(pdb
);
1168 if (!data
.dptr
|| data
.dsize
!= sizeof(pid_t
)) {
1169 SAFE_FREE(data
.dptr
);
1173 updating_pid
= IVAL(data
.dptr
, 0);
1174 SAFE_FREE(data
.dptr
);
1176 if (process_exists_by_pid(updating_pid
))
1177 return updating_pid
;
1182 /****************************************************************************
1183 Set the fact that we're doing the update, or have finished doing the update
1185 ****************************************************************************/
1187 static void set_updating_pid(const fstring sharename
, bool updating
)
1192 pid_t updating_pid
= getpid();
1195 struct tdb_print_db
*pdb
= get_print_db_byname(sharename
);
1200 slprintf(keystr
, sizeof(keystr
)-1, "UPDATING/%s", sharename
);
1201 key
= string_tdb_data(keystr
);
1203 DEBUG(5, ("set_updating_pid: %supdating lpq cache for print share %s\n",
1204 updating
? "" : "not ",
1208 tdb_delete(pdb
->tdb
, key
);
1209 release_print_db(pdb
);
1213 SIVAL( buffer
, 0, updating_pid
);
1215 data
.dsize
= 4; /* we always assume this is a 4 byte value */
1217 tdb_store(pdb
->tdb
, key
, data
, TDB_REPLACE
);
1218 release_print_db(pdb
);
1221 /****************************************************************************
1222 Sort print jobs by submittal time.
1223 ****************************************************************************/
1225 static int printjob_comp(print_queue_struct
*j1
, print_queue_struct
*j2
)
1236 /* Sort on job start time */
1238 if (j1
->time
== j2
->time
)
1240 return (j1
->time
> j2
->time
) ? 1 : -1;
1243 /****************************************************************************
1244 Store the sorted queue representation for later portmon retrieval.
1246 ****************************************************************************/
1248 static void store_queue_struct(struct tdb_print_db
*pdb
, struct traverse_struct
*pts
)
1251 int max_reported_jobs
= lp_max_reported_print_jobs(pts
->snum
);
1252 print_queue_struct
*queue
= pts
->queue
;
1255 unsigned int qcount
;
1257 if (max_reported_jobs
&& (max_reported_jobs
< pts
->qcount
))
1258 pts
->qcount
= max_reported_jobs
;
1261 /* Work out the size. */
1263 data
.dsize
+= tdb_pack(NULL
, 0, "d", qcount
);
1265 for (i
= 0; i
< pts
->qcount
; i
++) {
1266 if ( queue
[i
].status
== LPQ_DELETED
)
1270 data
.dsize
+= tdb_pack(NULL
, 0, "ddddddff",
1271 (uint32_t)queue
[i
].sysjob
,
1272 (uint32_t)queue
[i
].size
,
1273 (uint32_t)queue
[i
].page_count
,
1274 (uint32_t)queue
[i
].status
,
1275 (uint32_t)queue
[i
].priority
,
1276 (uint32_t)queue
[i
].time
,
1281 if ((data
.dptr
= (uint8_t *)SMB_MALLOC(data
.dsize
)) == NULL
)
1285 len
+= tdb_pack(data
.dptr
+ len
, data
.dsize
- len
, "d", qcount
);
1286 for (i
= 0; i
< pts
->qcount
; i
++) {
1287 if ( queue
[i
].status
== LPQ_DELETED
)
1290 len
+= tdb_pack(data
.dptr
+ len
, data
.dsize
- len
, "ddddddff",
1291 (uint32_t)queue
[i
].sysjob
,
1292 (uint32_t)queue
[i
].size
,
1293 (uint32_t)queue
[i
].page_count
,
1294 (uint32_t)queue
[i
].status
,
1295 (uint32_t)queue
[i
].priority
,
1296 (uint32_t)queue
[i
].time
,
1301 tdb_store(pdb
->tdb
, string_tdb_data("INFO/linear_queue_array"), data
,
1303 SAFE_FREE(data
.dptr
);
1307 static TDB_DATA
get_jobs_added_data(struct tdb_print_db
*pdb
)
1313 data
= tdb_fetch(pdb
->tdb
, string_tdb_data("INFO/jobs_added"));
1314 if (data
.dptr
== NULL
|| data
.dsize
== 0 || (data
.dsize
% 4 != 0)) {
1315 SAFE_FREE(data
.dptr
);
1322 static void check_job_added(const char *sharename
, TDB_DATA data
, uint32_t jobid
)
1325 unsigned int job_count
= data
.dsize
/ 4;
1327 for (i
= 0; i
< job_count
; i
++) {
1330 ch_jobid
= IVAL(data
.dptr
, i
*4);
1331 if (ch_jobid
== jobid
)
1332 remove_from_jobs_added(sharename
, jobid
);
1336 /****************************************************************************
1337 Check if the print queue has been updated recently enough.
1338 ****************************************************************************/
1340 static bool print_cache_expired(const char *sharename
, bool check_pending
)
1343 time_t last_qscan_time
, time_now
= time(NULL
);
1344 struct tdb_print_db
*pdb
= get_print_db_byname(sharename
);
1345 bool result
= False
;
1350 snprintf(key
, sizeof(key
), "CACHE/%s", sharename
);
1351 last_qscan_time
= (time_t)tdb_fetch_int32(pdb
->tdb
, key
);
1354 * Invalidate the queue for 3 reasons.
1355 * (1). last queue scan time == -1.
1356 * (2). Current time - last queue scan time > allowed cache time.
1357 * (3). last queue scan time > current time + MAX_CACHE_VALID_TIME (1 hour by default).
1358 * This last test picks up machines for which the clock has been moved
1359 * forward, an lpq scan done and then the clock moved back. Otherwise
1360 * that last lpq scan would stay around for a loooong loooong time... :-). JRA.
1363 if (last_qscan_time
== ((time_t)-1)
1364 || (time_now
- last_qscan_time
) >= lp_lpq_cache_time()
1365 || last_qscan_time
> (time_now
+ MAX_CACHE_VALID_TIME
))
1368 time_t msg_pending_time
;
1370 DEBUG(4, ("print_cache_expired: cache expired for queue %s "
1371 "(last_qscan_time = %d, time now = %d, qcachetime = %d)\n",
1372 sharename
, (int)last_qscan_time
, (int)time_now
,
1373 (int)lp_lpq_cache_time() ));
1375 /* check if another smbd has already sent a message to update the
1376 queue. Give the pending message one minute to clear and
1377 then send another message anyways. Make sure to check for
1378 clocks that have been run forward and then back again. */
1380 snprintf(key
, sizeof(key
), "MSG_PENDING/%s", sharename
);
1383 && tdb_fetch_uint32( pdb
->tdb
, key
, &u
)
1384 && (msg_pending_time
=u
) > 0
1385 && msg_pending_time
<= time_now
1386 && (time_now
- msg_pending_time
) < 60 )
1388 DEBUG(4,("print_cache_expired: message already pending for %s. Accepting cache\n",
1397 release_print_db(pdb
);
1401 /****************************************************************************
1402 main work for updating the lpq cache for a printer queue
1403 ****************************************************************************/
1405 static void print_queue_update_internal(struct tevent_context
*ev
,
1406 struct messaging_context
*msg_ctx
,
1407 const char *sharename
,
1408 struct printif
*current_printif
,
1409 char *lpq_command
, char *lprm_command
)
1412 print_queue_struct
*queue
= NULL
;
1413 print_status_struct status
;
1414 print_status_struct old_status
;
1415 struct printjob
*pjob
;
1416 struct traverse_struct tstruct
;
1419 fstring keystr
, cachestr
;
1420 struct tdb_print_db
*pdb
= get_print_db_byname(sharename
);
1421 TALLOC_CTX
*tmp_ctx
= talloc_new(ev
);
1423 if ((pdb
== NULL
) || (tmp_ctx
== NULL
)) {
1427 DEBUG(5,("print_queue_update_internal: printer = %s, type = %d, lpq command = [%s]\n",
1428 sharename
, current_printif
->type
, lpq_command
));
1431 * Update the cache time FIRST ! Stops others even
1432 * attempting to get the lock and doing this
1433 * if the lpq takes a long time.
1436 slprintf(cachestr
, sizeof(cachestr
)-1, "CACHE/%s", sharename
);
1437 tdb_store_int32(pdb
->tdb
, cachestr
, (int)time(NULL
));
1439 /* get the current queue using the appropriate interface */
1440 ZERO_STRUCT(status
);
1442 qcount
= (*(current_printif
->queue_get
))(sharename
,
1443 current_printif
->type
,
1444 lpq_command
, &queue
, &status
);
1446 DBG_NOTICE("%zu job%s in queue for %s\n",
1448 (qcount
!= 1) ? "s" : "",
1451 /* Sort the queue by submission time otherwise they are displayed
1454 TYPESAFE_QSORT(queue
, qcount
, printjob_comp
);
1457 any job in the internal database that is marked as spooled
1458 and doesn't exist in the system queue is considered finished
1459 and removed from the database
1461 any job in the system database but not in the internal database
1462 is added as a unix job
1464 fill in any system job numbers as we go
1466 jcdata
= get_jobs_added_data(pdb
);
1468 for (i
=0; i
<qcount
; i
++) {
1469 uint32_t jobid
= sysjob_to_jobid_pdb(pdb
, queue
[i
].sysjob
);
1470 if (jobid
== (uint32_t)-1) {
1471 /* assume its a unix print job */
1472 print_unix_job(ev
, msg_ctx
,
1473 sharename
, &queue
[i
], jobid
);
1477 /* we have an active SMB print job - update its status */
1478 pjob
= print_job_find(tmp_ctx
, sharename
, jobid
);
1480 /* err, somethings wrong. Probably smbd was restarted
1481 with jobs in the queue. All we can do is treat them
1482 like unix jobs. Pity. */
1483 DEBUG(1, ("queued print job %d not found in jobs list, "
1484 "assuming unix job\n", jobid
));
1485 print_unix_job(ev
, msg_ctx
,
1486 sharename
, &queue
[i
], jobid
);
1490 /* don't reset the status on jobs to be deleted */
1492 if ( pjob
->status
!= LPQ_DELETING
)
1493 pjob
->status
= queue
[i
].status
;
1495 pjob_store(ev
, msg_ctx
, sharename
, jobid
, pjob
);
1497 check_job_added(sharename
, jcdata
, jobid
);
1500 SAFE_FREE(jcdata
.dptr
);
1502 /* now delete any queued entries that don't appear in the
1504 tstruct
.queue
= queue
;
1505 tstruct
.qcount
= qcount
;
1507 tstruct
.total_jobs
= 0;
1508 tstruct
.lpq_time
= time(NULL
);
1509 tstruct
.sharename
= sharename
;
1510 tstruct
.lprm_command
= lprm_command
;
1511 tstruct
.print_if
= current_printif
;
1513 tstruct
.msg_ctx
= msg_ctx
;
1514 tstruct
.mem_ctx
= tmp_ctx
;
1516 tdb_traverse(pdb
->tdb
, traverse_fn_delete
, (void *)&tstruct
);
1518 /* Store the linearised queue, max jobs only. */
1519 store_queue_struct(pdb
, &tstruct
);
1521 SAFE_FREE(tstruct
.queue
);
1522 talloc_free(tmp_ctx
);
1524 DBG_DEBUG("printer %s INFO, total_jobs = %zu\n",
1526 tstruct
.total_jobs
);
1528 tdb_store_int32(pdb
->tdb
, "INFO/total_jobs", tstruct
.total_jobs
);
1530 get_queue_status(sharename
, &old_status
);
1531 if (old_status
.qcount
!= qcount
) {
1532 DBG_DEBUG("Queue status change %zu jobs -> %zu jobs "
1539 /* store the new queue status structure */
1540 slprintf(keystr
, sizeof(keystr
)-1, "STATUS/%s", sharename
);
1541 key
= string_tdb_data(keystr
);
1543 status
.qcount
= qcount
;
1544 data
.dptr
= (uint8_t *)&status
;
1545 data
.dsize
= sizeof(status
);
1546 tdb_store(pdb
->tdb
, key
, data
, TDB_REPLACE
);
1549 * Update the cache time again. We want to do this call
1550 * as little as possible...
1553 slprintf(keystr
, sizeof(keystr
)-1, "CACHE/%s", sharename
);
1554 tdb_store_int32(pdb
->tdb
, keystr
, (int32_t)time(NULL
));
1556 /* clear the msg pending record for this queue */
1558 snprintf(keystr
, sizeof(keystr
), "MSG_PENDING/%s", sharename
);
1560 if ( !tdb_store_uint32( pdb
->tdb
, keystr
, 0 ) ) {
1561 /* log a message but continue on */
1563 DEBUG(0,("print_queue_update: failed to store MSG_PENDING flag for [%s]!\n",
1567 release_print_db( pdb
);
1572 /****************************************************************************
1573 Update the internal database from the system print queue for a queue.
1574 obtain a lock on the print queue before proceeding (needed when mutiple
1575 smbd processes maytry to update the lpq cache concurrently).
1576 ****************************************************************************/
1578 static void print_queue_update_with_lock( struct tevent_context
*ev
,
1579 struct messaging_context
*msg_ctx
,
1580 const char *sharename
,
1581 struct printif
*current_printif
,
1582 char *lpq_command
, char *lprm_command
)
1585 struct tdb_print_db
*pdb
;
1587 DEBUG(5,("print_queue_update_with_lock: printer share = %s\n", sharename
));
1588 pdb
= get_print_db_byname(sharename
);
1592 if ( !print_cache_expired(sharename
, False
) ) {
1593 DEBUG(5,("print_queue_update_with_lock: print cache for %s is still ok\n", sharename
));
1594 release_print_db(pdb
);
1599 * Check to see if someone else is doing this update.
1600 * This is essentially a mutex on the update.
1603 if (get_updating_pid(sharename
) != -1) {
1604 release_print_db(pdb
);
1608 /* Lock the queue for the database update */
1610 slprintf(keystr
, sizeof(keystr
) - 1, "LOCK/%s", sharename
);
1611 /* Only wait 10 seconds for this. */
1612 if (tdb_lock_bystring_with_timeout(pdb
->tdb
, keystr
, 10) != 0) {
1613 DEBUG(0,("print_queue_update_with_lock: Failed to lock printer %s database\n", sharename
));
1614 release_print_db(pdb
);
1619 * Ensure that no one else got in here.
1620 * If the updating pid is still -1 then we are
1624 if (get_updating_pid(sharename
) != -1) {
1626 * Someone else is doing the update, exit.
1628 tdb_unlock_bystring(pdb
->tdb
, keystr
);
1629 release_print_db(pdb
);
1634 * We're going to do the update ourselves.
1637 /* Tell others we're doing the update. */
1638 set_updating_pid(sharename
, True
);
1641 * Allow others to enter and notice we're doing
1645 tdb_unlock_bystring(pdb
->tdb
, keystr
);
1647 /* do the main work now */
1649 print_queue_update_internal(ev
, msg_ctx
,
1650 sharename
, current_printif
,
1651 lpq_command
, lprm_command
);
1653 /* Delete our pid from the db. */
1654 set_updating_pid(sharename
, False
);
1655 release_print_db(pdb
);
1658 /****************************************************************************
1659 this is the receive function of the background lpq updater
1660 ****************************************************************************/
1661 void print_queue_receive(struct messaging_context
*msg
,
1664 struct server_id server_id
,
1668 char *lpqcommand
= NULL
, *lprmcommand
= NULL
;
1672 len
= tdb_unpack( (uint8_t *)data
->data
, data
->length
, "fdPP",
1679 SAFE_FREE(lpqcommand
);
1680 SAFE_FREE(lprmcommand
);
1681 DEBUG(0,("print_queue_receive: Got invalid print queue update message\n"));
1685 print_queue_update_with_lock(global_event_context(), msg
, sharename
,
1686 get_printer_fns_from_type((enum printing_types
)printing_type
),
1687 lpqcommand
, lprmcommand
);
1689 SAFE_FREE(lpqcommand
);
1690 SAFE_FREE(lprmcommand
);
1694 /****************************************************************************
1695 update the internal database from the system print queue for a queue
1696 ****************************************************************************/
1698 extern pid_t background_lpq_updater_pid
;
1700 static void print_queue_update(struct messaging_context
*msg_ctx
,
1701 int snum
, bool force
)
1705 char *lpqcommand
= NULL
;
1706 char *lprmcommand
= NULL
;
1707 uint8_t *buffer
= NULL
;
1710 struct tdb_print_db
*pdb
;
1712 struct printif
*current_printif
;
1713 TALLOC_CTX
*ctx
= talloc_tos();
1715 fstrcpy( sharename
, lp_const_servicename(snum
));
1717 /* don't strip out characters like '$' from the printername */
1719 lpqcommand
= talloc_string_sub2(ctx
,
1720 lp_lpq_command(talloc_tos(), snum
),
1722 lp_printername(talloc_tos(), snum
),
1723 false, false, false);
1727 lpqcommand
= talloc_sub_advanced(ctx
,
1728 lp_servicename(talloc_tos(), snum
),
1729 current_user_info
.unix_name
,
1731 get_current_gid(NULL
),
1732 get_current_username(),
1733 current_user_info
.domain
,
1739 lprmcommand
= talloc_string_sub2(ctx
,
1740 lp_lprm_command(talloc_tos(), snum
),
1742 lp_printername(talloc_tos(), snum
),
1743 false, false, false);
1747 lprmcommand
= talloc_sub_advanced(ctx
,
1748 lp_servicename(talloc_tos(), snum
),
1749 current_user_info
.unix_name
,
1751 get_current_gid(NULL
),
1752 get_current_username(),
1753 current_user_info
.domain
,
1760 * Make sure that the background queue process exists.
1761 * Otherwise just do the update ourselves
1764 if ( force
|| background_lpq_updater_pid
== -1 ) {
1765 DEBUG(4,("print_queue_update: updating queue [%s] myself\n", sharename
));
1766 current_printif
= get_printer_fns( snum
);
1767 print_queue_update_with_lock(global_event_context(), msg_ctx
,
1768 sharename
, current_printif
,
1769 lpqcommand
, lprmcommand
);
1774 type
= lp_printing(snum
);
1776 /* get the length */
1778 len
= tdb_pack( NULL
, 0, "fdPP",
1784 buffer
= SMB_XMALLOC_ARRAY( uint8_t, len
);
1786 /* now pack the buffer */
1787 newlen
= tdb_pack( buffer
, len
, "fdPP",
1793 SMB_ASSERT( newlen
== len
);
1795 DEBUG(10,("print_queue_update: Sending message -> printer = %s, "
1796 "type = %d, lpq command = [%s] lprm command = [%s]\n",
1797 sharename
, type
, lpqcommand
, lprmcommand
));
1799 /* here we set a msg pending record for other smbd processes
1800 to throttle the number of duplicate print_queue_update msgs
1803 pdb
= get_print_db_byname(sharename
);
1809 snprintf(key
, sizeof(key
), "MSG_PENDING/%s", sharename
);
1811 if ( !tdb_store_uint32( pdb
->tdb
, key
, time(NULL
) ) ) {
1812 /* log a message but continue on */
1814 DEBUG(0,("print_queue_update: failed to store MSG_PENDING flag for [%s]!\n",
1818 release_print_db( pdb
);
1820 /* finally send the message */
1822 messaging_send_buf(msg_ctx
, pid_to_procid(background_lpq_updater_pid
),
1823 MSG_PRINTER_UPDATE
, (uint8_t *)buffer
, len
);
1825 SAFE_FREE( buffer
);
1830 /****************************************************************************
1831 Create/Update an entry in the print tdb that will allow us to send notify
1832 updates only to interested smbd's.
1833 ****************************************************************************/
1835 bool print_notify_register_pid(int snum
)
1838 struct tdb_print_db
*pdb
= NULL
;
1839 TDB_CONTEXT
*tdb
= NULL
;
1840 const char *printername
;
1841 uint32_t mypid
= (uint32_t)getpid();
1845 /* if (snum == -1), then the change notify request was
1846 on a print server handle and we need to register on
1851 int num_services
= lp_numservices();
1854 for ( idx
=0; idx
<num_services
; idx
++ ) {
1855 if (lp_snum_ok(idx
) && lp_printable(idx
) )
1856 print_notify_register_pid(idx
);
1861 else /* register for a specific printer */
1863 printername
= lp_const_servicename(snum
);
1864 pdb
= get_print_db_byname(printername
);
1870 if (tdb_lock_bystring_with_timeout(tdb
, NOTIFY_PID_LIST_KEY
, 10) != 0) {
1871 DEBUG(0,("print_notify_register_pid: Failed to lock printer %s\n",
1874 release_print_db(pdb
);
1878 data
= get_printer_notify_pid_list( tdb
, printername
, True
);
1880 /* Add ourselves and increase the refcount. */
1882 for (i
= 0; i
< data
.dsize
; i
+= 8) {
1883 if (IVAL(data
.dptr
,i
) == mypid
) {
1884 uint32_t new_refcount
= IVAL(data
.dptr
, i
+4) + 1;
1885 SIVAL(data
.dptr
, i
+4, new_refcount
);
1890 if (i
== data
.dsize
) {
1891 /* We weren't in the list. Realloc. */
1892 data
.dptr
= (uint8_t *)SMB_REALLOC(data
.dptr
, data
.dsize
+ 8);
1894 DEBUG(0,("print_notify_register_pid: Relloc fail for printer %s\n",
1899 SIVAL(data
.dptr
,data
.dsize
- 8,mypid
);
1900 SIVAL(data
.dptr
,data
.dsize
- 4,1); /* Refcount. */
1903 /* Store back the record. */
1904 if (tdb_store_bystring(tdb
, NOTIFY_PID_LIST_KEY
, data
, TDB_REPLACE
) != 0) {
1905 DEBUG(0,("print_notify_register_pid: Failed to update pid \
1906 list for printer %s\n", printername
));
1914 tdb_unlock_bystring(tdb
, NOTIFY_PID_LIST_KEY
);
1916 release_print_db(pdb
);
1917 SAFE_FREE(data
.dptr
);
1921 /****************************************************************************
1922 Update an entry in the print tdb that will allow us to send notify
1923 updates only to interested smbd's.
1924 ****************************************************************************/
1926 bool print_notify_deregister_pid(int snum
)
1929 struct tdb_print_db
*pdb
= NULL
;
1930 TDB_CONTEXT
*tdb
= NULL
;
1931 const char *printername
;
1932 uint32_t mypid
= (uint32_t)getpid();
1936 /* if ( snum == -1 ), we are deregister a print server handle
1937 which means to deregister on all print queues */
1941 int num_services
= lp_numservices();
1944 for ( idx
=0; idx
<num_services
; idx
++ ) {
1945 if ( lp_snum_ok(idx
) && lp_printable(idx
) )
1946 print_notify_deregister_pid(idx
);
1951 else /* deregister a specific printer */
1953 printername
= lp_const_servicename(snum
);
1954 pdb
= get_print_db_byname(printername
);
1960 if (tdb_lock_bystring_with_timeout(tdb
, NOTIFY_PID_LIST_KEY
, 10) != 0) {
1961 DEBUG(0,("print_notify_register_pid: Failed to lock \
1962 printer %s database\n", printername
));
1964 release_print_db(pdb
);
1968 data
= get_printer_notify_pid_list( tdb
, printername
, True
);
1970 /* Reduce refcount. Remove ourselves if zero. */
1972 for (i
= 0; i
< data
.dsize
; ) {
1973 if (IVAL(data
.dptr
,i
) == mypid
) {
1974 uint32_t refcount
= IVAL(data
.dptr
, i
+4);
1978 if (refcount
== 0) {
1979 if (data
.dsize
- i
> 8)
1980 memmove( &data
.dptr
[i
], &data
.dptr
[i
+8], data
.dsize
- i
- 8);
1984 SIVAL(data
.dptr
, i
+4, refcount
);
1990 if (data
.dsize
== 0)
1991 SAFE_FREE(data
.dptr
);
1993 /* Store back the record. */
1994 if (tdb_store_bystring(tdb
, NOTIFY_PID_LIST_KEY
, data
, TDB_REPLACE
) != 0) {
1995 DEBUG(0,("print_notify_register_pid: Failed to update pid \
1996 list for printer %s\n", printername
));
2004 tdb_unlock_bystring(tdb
, NOTIFY_PID_LIST_KEY
);
2006 release_print_db(pdb
);
2007 SAFE_FREE(data
.dptr
);
2011 /****************************************************************************
2012 Check if a jobid is valid. It is valid if it exists in the database.
2013 ****************************************************************************/
2015 bool print_job_exists(const char* sharename
, uint32_t jobid
)
2017 struct tdb_print_db
*pdb
= get_print_db_byname(sharename
);
2023 ret
= tdb_exists(pdb
->tdb
, print_key(jobid
, &tmp
));
2024 release_print_db(pdb
);
2028 /****************************************************************************
2029 Return the device mode asigned to a specific print job.
2030 Only valid for the process doing the spooling and when the job
2031 has not been spooled.
2032 ****************************************************************************/
2034 struct spoolss_DeviceMode
*print_job_devmode(TALLOC_CTX
*mem_ctx
,
2035 const char *sharename
,
2038 struct printjob
*pjob
= print_job_find(mem_ctx
, sharename
, jobid
);
2043 return pjob
->devmode
;
2046 /****************************************************************************
2047 Set the name of a job. Only possible for owner.
2048 ****************************************************************************/
2050 bool print_job_set_name(struct tevent_context
*ev
,
2051 struct messaging_context
*msg_ctx
,
2052 const char *sharename
, uint32_t jobid
, const char *name
)
2054 struct printjob
*pjob
;
2056 TALLOC_CTX
*tmp_ctx
= talloc_new(ev
);
2057 if (tmp_ctx
== NULL
) {
2061 pjob
= print_job_find(tmp_ctx
, sharename
, jobid
);
2062 if (!pjob
|| pjob
->pid
!= getpid()) {
2067 fstrcpy(pjob
->jobname
, name
);
2068 ret
= pjob_store(ev
, msg_ctx
, sharename
, jobid
, pjob
);
2070 talloc_free(tmp_ctx
);
2074 /****************************************************************************
2075 Get the name of a job. Only possible for owner.
2076 ****************************************************************************/
2078 bool print_job_get_name(TALLOC_CTX
*mem_ctx
, const char *sharename
, uint32_t jobid
, char **name
)
2080 struct printjob
*pjob
;
2082 pjob
= print_job_find(mem_ctx
, sharename
, jobid
);
2083 if (!pjob
|| pjob
->pid
!= getpid()) {
2087 *name
= pjob
->jobname
;
2092 /***************************************************************************
2093 Remove a jobid from the 'jobs added' list.
2094 ***************************************************************************/
2096 static bool remove_from_jobs_added(const char* sharename
, uint32_t jobid
)
2098 struct tdb_print_db
*pdb
= get_print_db_byname(sharename
);
2100 size_t job_count
, i
;
2102 bool gotlock
= False
;
2110 key
= string_tdb_data("INFO/jobs_added");
2112 if (tdb_chainlock_with_timeout(pdb
->tdb
, key
, 5) != 0)
2117 data
= tdb_fetch(pdb
->tdb
, key
);
2119 if (data
.dptr
== NULL
|| data
.dsize
== 0 || (data
.dsize
% 4 != 0))
2122 job_count
= data
.dsize
/ 4;
2123 for (i
= 0; i
< job_count
; i
++) {
2126 ch_jobid
= IVAL(data
.dptr
, i
*4);
2127 if (ch_jobid
== jobid
) {
2128 if (i
< job_count
-1 )
2129 memmove(data
.dptr
+ (i
*4), data
.dptr
+ (i
*4) + 4, (job_count
- i
- 1)*4 );
2131 if (tdb_store(pdb
->tdb
, key
, data
, TDB_REPLACE
) != 0)
2141 tdb_chainunlock(pdb
->tdb
, key
);
2142 SAFE_FREE(data
.dptr
);
2143 release_print_db(pdb
);
2145 DEBUG(10,("remove_from_jobs_added: removed jobid %u\n", (unsigned int)jobid
));
2147 DEBUG(10,("remove_from_jobs_added: Failed to remove jobid %u\n", (unsigned int)jobid
));
2151 /****************************************************************************
2152 Delete a print job - don't update queue.
2153 ****************************************************************************/
2155 static bool print_job_delete1(struct tevent_context
*ev
,
2156 struct messaging_context
*msg_ctx
,
2157 int snum
, uint32_t jobid
)
2159 const char* sharename
= lp_const_servicename(snum
);
2160 struct printjob
*pjob
;
2162 struct printif
*current_printif
= get_printer_fns( snum
);
2164 TALLOC_CTX
*tmp_ctx
= talloc_new(ev
);
2165 if (tmp_ctx
== NULL
) {
2169 pjob
= print_job_find(tmp_ctx
, sharename
, jobid
);
2176 * If already deleting just return.
2179 if (pjob
->status
== LPQ_DELETING
) {
2184 /* Hrm - we need to be able to cope with deleting a job before it
2185 has reached the spooler. Just mark it as LPQ_DELETING and
2186 let the print_queue_update() code rmeove the record */
2189 if (pjob
->sysjob
== -1) {
2190 DEBUG(5, ("attempt to delete job %u not seen by lpr\n", (unsigned int)jobid
));
2193 /* Set the tdb entry to be deleting. */
2195 pjob
->status
= LPQ_DELETING
;
2196 pjob_store(ev
, msg_ctx
, sharename
, jobid
, pjob
);
2198 if (pjob
->spooled
&& pjob
->sysjob
!= -1)
2200 result
= (*(current_printif
->job_delete
))(
2201 lp_printername(talloc_tos(), snum
),
2202 lp_lprm_command(talloc_tos(), snum
),
2205 /* Delete the tdb entry if the delete succeeded or the job hasn't
2209 struct tdb_print_db
*pdb
= get_print_db_byname(sharename
);
2216 pjob_delete(ev
, msg_ctx
, sharename
, jobid
);
2217 /* Ensure we keep a rough count of the number of total jobs... */
2218 tdb_change_int32_atomic(pdb
->tdb
, "INFO/total_jobs", &njobs
, -1);
2219 release_print_db(pdb
);
2223 remove_from_jobs_added( sharename
, jobid
);
2225 ret
= (result
== 0);
2227 talloc_free(tmp_ctx
);
2231 /****************************************************************************
2232 Return true if the current user owns the print job.
2233 ****************************************************************************/
2235 static bool is_owner(const struct auth_session_info
*server_info
,
2236 const char *servicename
,
2239 struct printjob
*pjob
;
2241 TALLOC_CTX
*tmp_ctx
= talloc_new(server_info
);
2242 if (tmp_ctx
== NULL
) {
2246 pjob
= print_job_find(tmp_ctx
, servicename
, jobid
);
2247 if (!pjob
|| !server_info
) {
2252 ret
= strequal(pjob
->user
, server_info
->unix_info
->sanitized_username
);
2254 talloc_free(tmp_ctx
);
2258 /****************************************************************************
2260 ****************************************************************************/
2262 WERROR
print_job_delete(const struct auth_session_info
*server_info
,
2263 struct messaging_context
*msg_ctx
,
2264 int snum
, uint32_t jobid
)
2266 const char* sharename
= lp_const_servicename(snum
);
2267 struct printjob
*pjob
;
2270 TALLOC_CTX
*tmp_ctx
= talloc_new(msg_ctx
);
2271 if (tmp_ctx
== NULL
) {
2272 return WERR_NOT_ENOUGH_MEMORY
;
2275 owner
= is_owner(server_info
, lp_const_servicename(snum
), jobid
);
2277 /* Check access against security descriptor or whether the user
2281 !W_ERROR_IS_OK(print_access_check(server_info
, msg_ctx
, snum
,
2282 JOB_ACCESS_ADMINISTER
))) {
2283 DEBUG(0, ("print job delete denied."
2284 "User name: %s, Printer name: %s.",
2285 uidtoname(server_info
->unix_token
->uid
),
2286 lp_printername(tmp_ctx
, snum
)));
2288 werr
= WERR_ACCESS_DENIED
;
2293 * get the spooled filename of the print job
2294 * if this works, then the file has not been spooled
2295 * to the underlying print system. Just delete the
2296 * spool file & return.
2299 pjob
= print_job_find(tmp_ctx
, sharename
, jobid
);
2300 if (!pjob
|| pjob
->spooled
|| pjob
->pid
!= getpid()) {
2301 DEBUG(10, ("Skipping spool file removal for job %u\n", jobid
));
2303 DEBUG(10, ("Removing spool file [%s]\n", pjob
->filename
));
2304 if (unlink(pjob
->filename
) == -1) {
2305 werr
= map_werror_from_unix(errno
);
2310 if (!print_job_delete1(global_event_context(), msg_ctx
, snum
, jobid
)) {
2311 werr
= WERR_ACCESS_DENIED
;
2315 /* force update the database and say the delete failed if the
2318 print_queue_update(msg_ctx
, snum
, True
);
2320 pjob
= print_job_find(tmp_ctx
, sharename
, jobid
);
2321 if (pjob
&& (pjob
->status
!= LPQ_DELETING
)) {
2322 werr
= WERR_ACCESS_DENIED
;
2325 werr
= WERR_PRINTER_HAS_JOBS_QUEUED
;
2328 talloc_free(tmp_ctx
);
2332 /****************************************************************************
2334 ****************************************************************************/
2336 WERROR
print_job_pause(const struct auth_session_info
*server_info
,
2337 struct messaging_context
*msg_ctx
,
2338 int snum
, uint32_t jobid
)
2340 const char* sharename
= lp_const_servicename(snum
);
2341 struct printjob
*pjob
;
2343 struct printif
*current_printif
= get_printer_fns( snum
);
2345 TALLOC_CTX
*tmp_ctx
= talloc_new(msg_ctx
);
2346 if (tmp_ctx
== NULL
) {
2347 return WERR_NOT_ENOUGH_MEMORY
;
2350 pjob
= print_job_find(tmp_ctx
, sharename
, jobid
);
2351 if (!pjob
|| !server_info
) {
2352 DEBUG(10, ("print_job_pause: no pjob or user for jobid %u\n",
2353 (unsigned int)jobid
));
2354 werr
= WERR_INVALID_PARAMETER
;
2358 if (!pjob
->spooled
|| pjob
->sysjob
== -1) {
2359 DEBUG(10, ("print_job_pause: not spooled or bad sysjob = %d for jobid %u\n",
2360 (int)pjob
->sysjob
, (unsigned int)jobid
));
2361 werr
= WERR_INVALID_PARAMETER
;
2365 if (!is_owner(server_info
, lp_const_servicename(snum
), jobid
) &&
2366 !W_ERROR_IS_OK(print_access_check(server_info
, msg_ctx
, snum
,
2367 JOB_ACCESS_ADMINISTER
))) {
2368 DEBUG(0, ("print job pause denied."
2369 "User name: %s, Printer name: %s.",
2370 uidtoname(server_info
->unix_token
->uid
),
2371 lp_printername(tmp_ctx
, snum
)));
2373 werr
= WERR_ACCESS_DENIED
;
2377 /* need to pause the spooled entry */
2378 ret
= (*(current_printif
->job_pause
))(snum
, pjob
);
2381 werr
= WERR_INVALID_PARAMETER
;
2385 /* force update the database */
2386 print_cache_flush(lp_const_servicename(snum
));
2388 /* Send a printer notify message */
2390 notify_job_status(global_event_context(), msg_ctx
, sharename
, jobid
,
2393 /* how do we tell if this succeeded? */
2396 talloc_free(tmp_ctx
);
2400 /****************************************************************************
2402 ****************************************************************************/
2404 WERROR
print_job_resume(const struct auth_session_info
*server_info
,
2405 struct messaging_context
*msg_ctx
,
2406 int snum
, uint32_t jobid
)
2408 const char *sharename
= lp_const_servicename(snum
);
2409 struct printjob
*pjob
;
2411 struct printif
*current_printif
= get_printer_fns( snum
);
2413 TALLOC_CTX
*tmp_ctx
= talloc_new(msg_ctx
);
2414 if (tmp_ctx
== NULL
)
2415 return WERR_NOT_ENOUGH_MEMORY
;
2417 pjob
= print_job_find(tmp_ctx
, sharename
, jobid
);
2418 if (!pjob
|| !server_info
) {
2419 DEBUG(10, ("print_job_resume: no pjob or user for jobid %u\n",
2420 (unsigned int)jobid
));
2421 werr
= WERR_INVALID_PARAMETER
;
2425 if (!pjob
->spooled
|| pjob
->sysjob
== -1) {
2426 DEBUG(10, ("print_job_resume: not spooled or bad sysjob = %d for jobid %u\n",
2427 (int)pjob
->sysjob
, (unsigned int)jobid
));
2428 werr
= WERR_INVALID_PARAMETER
;
2432 if (!is_owner(server_info
, lp_const_servicename(snum
), jobid
) &&
2433 !W_ERROR_IS_OK(print_access_check(server_info
, msg_ctx
, snum
,
2434 JOB_ACCESS_ADMINISTER
))) {
2435 DEBUG(0, ("print job resume denied."
2436 "User name: %s, Printer name: %s.",
2437 uidtoname(server_info
->unix_token
->uid
),
2438 lp_printername(tmp_ctx
, snum
)));
2440 werr
= WERR_ACCESS_DENIED
;
2444 ret
= (*(current_printif
->job_resume
))(snum
, pjob
);
2447 werr
= WERR_INVALID_PARAMETER
;
2451 /* force update the database */
2452 print_cache_flush(lp_const_servicename(snum
));
2454 /* Send a printer notify message */
2456 notify_job_status(global_event_context(), msg_ctx
, sharename
, jobid
,
2461 talloc_free(tmp_ctx
);
2465 /****************************************************************************
2466 Write to a print file.
2467 ****************************************************************************/
2469 ssize_t
print_job_write(struct tevent_context
*ev
,
2470 struct messaging_context
*msg_ctx
,
2471 int snum
, uint32_t jobid
, const char *buf
, size_t size
)
2473 const char* sharename
= lp_const_servicename(snum
);
2474 ssize_t return_code
;
2475 struct printjob
*pjob
;
2476 TALLOC_CTX
*tmp_ctx
= talloc_new(ev
);
2477 if (tmp_ctx
== NULL
) {
2481 pjob
= print_job_find(tmp_ctx
, sharename
, jobid
);
2487 /* don't allow another process to get this info - it is meaningless */
2488 if (pjob
->pid
!= getpid()) {
2493 /* if SMBD is spooling this can't be allowed */
2494 if (pjob
->status
== PJOB_SMBD_SPOOLING
) {
2499 return_code
= write_data(pjob
->fd
, buf
, size
);
2500 if (return_code
> 0) {
2502 pjob_store(ev
, msg_ctx
, sharename
, jobid
, pjob
);
2505 talloc_free(tmp_ctx
);
2509 /****************************************************************************
2510 Get the queue status - do not update if db is out of date.
2511 ****************************************************************************/
2513 static int get_queue_status(const char* sharename
, print_status_struct
*status
)
2517 struct tdb_print_db
*pdb
= get_print_db_byname(sharename
);
2521 ZERO_STRUCTP(status
);
2528 fstr_sprintf(keystr
, "STATUS/%s", sharename
);
2529 data
= tdb_fetch(pdb
->tdb
, string_tdb_data(keystr
));
2531 if (data
.dsize
== sizeof(print_status_struct
))
2532 /* this memcpy is ok since the status struct was
2533 not packed before storing it in the tdb */
2534 memcpy(status
, data
.dptr
, sizeof(print_status_struct
));
2535 SAFE_FREE(data
.dptr
);
2538 len
= tdb_fetch_int32(pdb
->tdb
, "INFO/total_jobs");
2539 release_print_db(pdb
);
2540 return (len
== -1 ? 0 : len
);
2543 /****************************************************************************
2544 Determine the number of jobs in a queue.
2545 ****************************************************************************/
2547 int print_queue_length(struct messaging_context
*msg_ctx
, int snum
,
2548 print_status_struct
*pstatus
)
2550 const char* sharename
= lp_const_servicename( snum
);
2551 print_status_struct status
;
2554 ZERO_STRUCT( status
);
2556 /* make sure the database is up to date */
2557 if (print_cache_expired(lp_const_servicename(snum
), True
))
2558 print_queue_update(msg_ctx
, snum
, False
);
2560 /* also fetch the queue status */
2561 memset(&status
, 0, sizeof(status
));
2562 len
= get_queue_status(sharename
, &status
);
2570 /***************************************************************************
2571 Allocate a jobid. Hold the lock for as short a time as possible.
2572 ***************************************************************************/
2574 static WERROR
allocate_print_jobid(struct tdb_print_db
*pdb
, int snum
,
2575 const char *sharename
, uint32_t *pjobid
)
2579 enum TDB_ERROR terr
;
2582 *pjobid
= (uint32_t)-1;
2584 for (i
= 0; i
< 3; i
++) {
2585 /* Lock the database - only wait 20 seconds. */
2586 ret
= tdb_lock_bystring_with_timeout(pdb
->tdb
,
2587 "INFO/nextjob", 20);
2589 DEBUG(0, ("allocate_print_jobid: "
2590 "Failed to lock printing database %s\n",
2592 terr
= tdb_error(pdb
->tdb
);
2593 return ntstatus_to_werror(map_nt_error_from_tdb(terr
));
2596 if (!tdb_fetch_uint32(pdb
->tdb
, "INFO/nextjob", &jobid
)) {
2597 terr
= tdb_error(pdb
->tdb
);
2598 if (terr
!= TDB_ERR_NOEXIST
) {
2599 DEBUG(0, ("allocate_print_jobid: "
2600 "Failed to fetch INFO/nextjob "
2601 "for print queue %s\n", sharename
));
2602 tdb_unlock_bystring(pdb
->tdb
, "INFO/nextjob");
2603 return ntstatus_to_werror(map_nt_error_from_tdb(terr
));
2605 DEBUG(10, ("allocate_print_jobid: "
2606 "No existing jobid in %s\n", sharename
));
2610 DEBUG(10, ("allocate_print_jobid: "
2611 "Read jobid %u from %s\n", jobid
, sharename
));
2613 jobid
= NEXT_JOBID(jobid
);
2615 ret
= tdb_store_int32(pdb
->tdb
, "INFO/nextjob", jobid
);
2617 terr
= tdb_error(pdb
->tdb
);
2618 DEBUG(3, ("allocate_print_jobid: "
2619 "Failed to store INFO/nextjob.\n"));
2620 tdb_unlock_bystring(pdb
->tdb
, "INFO/nextjob");
2621 return ntstatus_to_werror(map_nt_error_from_tdb(terr
));
2624 /* We've finished with the INFO/nextjob lock. */
2625 tdb_unlock_bystring(pdb
->tdb
, "INFO/nextjob");
2627 if (!print_job_exists(sharename
, jobid
)) {
2630 DEBUG(10, ("allocate_print_jobid: "
2631 "Found jobid %u in %s\n", jobid
, sharename
));
2635 DEBUG(0, ("allocate_print_jobid: "
2636 "Failed to allocate a print job for queue %s\n",
2638 /* Probably full... */
2639 return WERR_NO_SPOOL_SPACE
;
2642 /* Store a dummy placeholder. */
2648 if (tdb_store(pdb
->tdb
, print_key(jobid
, &tmp
), dum
,
2650 DEBUG(3, ("allocate_print_jobid: "
2651 "jobid (%d) failed to store placeholder.\n",
2653 terr
= tdb_error(pdb
->tdb
);
2654 return ntstatus_to_werror(map_nt_error_from_tdb(terr
));
2662 /***************************************************************************
2663 Append a jobid to the 'jobs added' list.
2664 ***************************************************************************/
2666 static bool add_to_jobs_added(struct tdb_print_db
*pdb
, uint32_t jobid
)
2669 uint32_t store_jobid
;
2671 SIVAL(&store_jobid
, 0, jobid
);
2672 data
.dptr
= (uint8_t *)&store_jobid
;
2675 DEBUG(10,("add_to_jobs_added: Added jobid %u\n", (unsigned int)jobid
));
2677 return (tdb_append(pdb
->tdb
, string_tdb_data("INFO/jobs_added"),
2682 /***************************************************************************
2683 Do all checks needed to determine if we can start a job.
2684 ***************************************************************************/
2686 static WERROR
print_job_checks(const struct auth_session_info
*server_info
,
2687 struct messaging_context
*msg_ctx
,
2688 int snum
, int *njobs
)
2690 const char *sharename
= lp_const_servicename(snum
);
2691 uint64_t dspace
, dsize
;
2695 if (!W_ERROR_IS_OK(print_access_check(server_info
, msg_ctx
, snum
,
2696 PRINTER_ACCESS_USE
))) {
2697 DEBUG(3, ("print_job_checks: "
2698 "job start denied by security descriptor\n"));
2699 return WERR_ACCESS_DENIED
;
2702 if (!print_time_access_check(server_info
, msg_ctx
, sharename
)) {
2703 DEBUG(3, ("print_job_checks: "
2704 "job start denied by time check\n"));
2705 return WERR_ACCESS_DENIED
;
2708 /* see if we have sufficient disk space */
2709 if (lp_min_print_space(snum
)) {
2710 minspace
= lp_min_print_space(snum
);
2711 ret
= sys_fsusage(lp_path(talloc_tos(), snum
), &dspace
, &dsize
);
2712 if (ret
== 0 && dspace
< 2*minspace
) {
2713 DEBUG(3, ("print_job_checks: "
2714 "disk space check failed.\n"));
2715 return WERR_NO_SPOOL_SPACE
;
2719 /* for autoloaded printers, check that the printcap entry still exists */
2720 if (lp_autoloaded(snum
) && !pcap_printername_ok(sharename
)) {
2721 DEBUG(3, ("print_job_checks: printer name %s check failed.\n",
2723 return WERR_ACCESS_DENIED
;
2726 /* Insure the maximum queue size is not violated */
2727 *njobs
= print_queue_length(msg_ctx
, snum
, NULL
);
2728 if (*njobs
> lp_maxprintjobs(snum
)) {
2729 DEBUG(3, ("print_job_checks: Queue %s number of jobs (%d) "
2730 "larger than max printjobs per queue (%d).\n",
2731 sharename
, *njobs
, lp_maxprintjobs(snum
)));
2732 return WERR_NO_SPOOL_SPACE
;
2738 /***************************************************************************
2740 ***************************************************************************/
2742 static WERROR
print_job_spool_file(int snum
, uint32_t jobid
,
2743 const char *output_file
,
2744 struct printjob
*pjob
)
2752 /* if this file is within the printer path, it means that smbd
2753 * is spooling it and will pass us control when it is finished.
2754 * Verify that the file name is ok, within path, and it is
2755 * already already there */
2757 path
= lp_path(talloc_tos(), snum
);
2759 if (strncmp(output_file
, path
, len
) == 0 &&
2760 (output_file
[len
- 1] == '/' || output_file
[len
] == '/')) {
2762 /* verify path is not too long */
2763 if (strlen(output_file
) >= sizeof(pjob
->filename
)) {
2764 return WERR_INVALID_NAME
;
2767 /* verify that the file exists */
2768 if (sys_stat(output_file
, &st
, false) != 0) {
2769 return WERR_INVALID_NAME
;
2772 fstrcpy(pjob
->filename
, output_file
);
2774 DEBUG(3, ("print_job_spool_file:"
2775 "External spooling activated\n"));
2777 /* we do not open the file until spooling is done */
2779 pjob
->status
= PJOB_SMBD_SPOOLING
;
2785 slprintf(pjob
->filename
, sizeof(pjob
->filename
)-1,
2786 "%s/%sXXXXXX", lp_path(talloc_tos(), snum
),
2787 PRINT_SPOOL_PREFIX
);
2788 mask
= umask(S_IRWXO
| S_IRWXG
);
2789 pjob
->fd
= mkstemp(pjob
->filename
);
2792 if (pjob
->fd
== -1) {
2793 werr
= map_werror_from_unix(errno
);
2794 if (W_ERROR_EQUAL(werr
, WERR_ACCESS_DENIED
)) {
2795 /* Common setup error, force a report. */
2796 DEBUG(0, ("print_job_spool_file: "
2797 "insufficient permissions to open spool "
2798 "file %s.\n", pjob
->filename
));
2800 /* Normal case, report at level 3 and above. */
2801 DEBUG(3, ("print_job_spool_file: "
2802 "can't open spool file %s\n",
2811 /***************************************************************************
2812 Start spooling a job - return the jobid.
2813 ***************************************************************************/
2815 WERROR
print_job_start(const struct auth_session_info
*server_info
,
2816 struct messaging_context
*msg_ctx
,
2817 const char *clientmachine
,
2818 int snum
, const char *docname
, const char *filename
,
2819 struct spoolss_DeviceMode
*devmode
, uint32_t *_jobid
)
2823 struct printjob pjob
;
2824 const char *sharename
= lp_const_servicename(snum
);
2825 struct tdb_print_db
*pdb
= get_print_db_byname(sharename
);
2830 return WERR_INTERNAL_DB_CORRUPTION
;
2833 path
= lp_path(talloc_tos(), snum
);
2835 werr
= print_job_checks(server_info
, msg_ctx
, snum
, &njobs
);
2836 if (!W_ERROR_IS_OK(werr
)) {
2837 release_print_db(pdb
);
2841 DEBUG(10, ("print_job_start: "
2842 "Queue %s number of jobs (%d), max printjobs = %d\n",
2843 sharename
, njobs
, lp_maxprintjobs(snum
)));
2845 werr
= allocate_print_jobid(pdb
, snum
, sharename
, &jobid
);
2846 if (!W_ERROR_IS_OK(werr
)) {
2850 /* create the database entry */
2854 pjob
.pid
= getpid();
2858 pjob
.starttime
= time(NULL
);
2859 pjob
.status
= LPQ_SPOOLING
;
2861 pjob
.spooled
= False
;
2863 pjob
.devmode
= devmode
;
2865 fstrcpy(pjob
.jobname
, docname
);
2867 fstrcpy(pjob
.clientmachine
, clientmachine
);
2869 fstrcpy(pjob
.user
, lp_printjob_username(snum
));
2870 standard_sub_advanced(sharename
, server_info
->unix_info
->sanitized_username
,
2871 path
, server_info
->unix_token
->gid
,
2872 server_info
->unix_info
->sanitized_username
,
2873 server_info
->info
->domain_name
,
2874 pjob
.user
, sizeof(pjob
.user
));
2876 fstrcpy(pjob
.queuename
, lp_const_servicename(snum
));
2878 /* we have a job entry - now create the spool file */
2879 werr
= print_job_spool_file(snum
, jobid
, filename
, &pjob
);
2880 if (!W_ERROR_IS_OK(werr
)) {
2884 pjob_store(global_event_context(), msg_ctx
, sharename
, jobid
, &pjob
);
2886 /* Update the 'jobs added' entry used by print_queue_status. */
2887 add_to_jobs_added(pdb
, jobid
);
2889 /* Ensure we keep a rough count of the number of total jobs... */
2890 tdb_change_int32_atomic(pdb
->tdb
, "INFO/total_jobs", &njobs
, 1);
2892 release_print_db(pdb
);
2899 pjob_delete(global_event_context(), msg_ctx
, sharename
, jobid
);
2902 release_print_db(pdb
);
2904 DEBUG(3, ("print_job_start: returning fail. "
2905 "Error = %s\n", win_errstr(werr
)));
2909 /****************************************************************************
2910 Update the number of pages spooled to jobid
2911 ****************************************************************************/
2913 void print_job_endpage(struct messaging_context
*msg_ctx
,
2914 int snum
, uint32_t jobid
)
2916 const char* sharename
= lp_const_servicename(snum
);
2917 struct printjob
*pjob
;
2918 TALLOC_CTX
*tmp_ctx
= talloc_new(msg_ctx
);
2919 if (tmp_ctx
== NULL
) {
2923 pjob
= print_job_find(tmp_ctx
, sharename
, jobid
);
2927 /* don't allow another process to get this info - it is meaningless */
2928 if (pjob
->pid
!= getpid()) {
2933 pjob_store(global_event_context(), msg_ctx
, sharename
, jobid
, pjob
);
2935 talloc_free(tmp_ctx
);
2938 /****************************************************************************
2939 Print a file - called on closing the file. This spools the job.
2940 If normal close is false then we're tearing down the jobs - treat as an
2942 ****************************************************************************/
2944 NTSTATUS
print_job_end(struct messaging_context
*msg_ctx
, int snum
,
2945 uint32_t jobid
, enum file_close_type close_type
)
2947 const char* sharename
= lp_const_servicename(snum
);
2948 struct printjob
*pjob
;
2950 SMB_STRUCT_STAT sbuf
;
2951 struct printif
*current_printif
= get_printer_fns(snum
);
2952 NTSTATUS status
= NT_STATUS_UNSUCCESSFUL
;
2954 TALLOC_CTX
*tmp_ctx
= talloc_new(msg_ctx
);
2955 if (tmp_ctx
== NULL
) {
2956 return NT_STATUS_NO_MEMORY
;
2959 pjob
= print_job_find(tmp_ctx
, sharename
, jobid
);
2961 status
= NT_STATUS_PRINT_CANCELLED
;
2965 if (pjob
->spooled
|| pjob
->pid
!= getpid()) {
2966 status
= NT_STATUS_ACCESS_DENIED
;
2970 if (close_type
== NORMAL_CLOSE
|| close_type
== SHUTDOWN_CLOSE
) {
2971 if (pjob
->status
== PJOB_SMBD_SPOOLING
) {
2972 /* take over the file now, smbd is done */
2973 if (sys_stat(pjob
->filename
, &sbuf
, false) != 0) {
2974 status
= map_nt_error_from_unix(errno
);
2975 DEBUG(3, ("print_job_end: "
2976 "stat file failed for jobid %d\n",
2981 pjob
->status
= LPQ_SPOOLING
;
2985 if ((sys_fstat(pjob
->fd
, &sbuf
, false) != 0)) {
2986 status
= map_nt_error_from_unix(errno
);
2988 DEBUG(3, ("print_job_end: "
2989 "stat file failed for jobid %d\n",
2997 pjob
->size
= sbuf
.st_ex_size
;
3001 * Not a normal close, something has gone wrong. Cleanup.
3003 if (pjob
->fd
!= -1) {
3009 /* Technically, this is not quite right. If the printer has a separator
3010 * page turned on, the NT spooler prints the separator page even if the
3011 * print job is 0 bytes. 010215 JRR */
3012 if (pjob
->size
== 0 || pjob
->status
== LPQ_DELETING
) {
3013 /* don't bother spooling empty files or something being deleted. */
3014 DEBUG(5,("print_job_end: canceling spool of %s (%s)\n",
3015 pjob
->filename
, pjob
->size
? "deleted" : "zero length" ));
3016 unlink(pjob
->filename
);
3017 pjob_delete(global_event_context(), msg_ctx
, sharename
, jobid
);
3018 return NT_STATUS_OK
;
3021 /* don't strip out characters like '$' from the printername */
3022 lpq_cmd
= talloc_string_sub2(tmp_ctx
,
3023 lp_lpq_command(talloc_tos(), snum
),
3025 lp_printername(talloc_tos(), snum
),
3026 false, false, false);
3027 if (lpq_cmd
== NULL
) {
3028 status
= NT_STATUS_PRINT_CANCELLED
;
3031 lpq_cmd
= talloc_sub_advanced(tmp_ctx
,
3032 lp_servicename(talloc_tos(), snum
),
3033 current_user_info
.unix_name
,
3035 get_current_gid(NULL
),
3036 get_current_username(),
3037 current_user_info
.domain
,
3039 if (lpq_cmd
== NULL
) {
3040 status
= NT_STATUS_PRINT_CANCELLED
;
3044 ret
= (*(current_printif
->job_submit
))(snum
, pjob
,
3045 current_printif
->type
, lpq_cmd
);
3047 status
= NT_STATUS_PRINT_CANCELLED
;
3051 /* The print job has been successfully handed over to the back-end */
3053 pjob
->spooled
= True
;
3054 pjob
->status
= LPQ_QUEUED
;
3055 pjob_store(global_event_context(), msg_ctx
, sharename
, jobid
, pjob
);
3057 /* make sure the database is up to date */
3058 if (print_cache_expired(lp_const_servicename(snum
), True
))
3059 print_queue_update(msg_ctx
, snum
, False
);
3061 return NT_STATUS_OK
;
3065 /* The print job was not successfully started. Cleanup */
3066 /* Still need to add proper error return propagation! 010122:JRR */
3068 unlink(pjob
->filename
);
3069 pjob_delete(global_event_context(), msg_ctx
, sharename
, jobid
);
3071 talloc_free(tmp_ctx
);
3075 /****************************************************************************
3076 Get a snapshot of jobs in the system without traversing.
3077 ****************************************************************************/
3079 static bool get_stored_queue_info(struct messaging_context
*msg_ctx
,
3080 struct tdb_print_db
*pdb
, int snum
,
3081 int *pcount
, print_queue_struct
**ppqueue
)
3083 TDB_DATA data
, cgdata
, jcdata
;
3084 print_queue_struct
*queue
= NULL
;
3085 uint32_t qcount
= 0;
3086 uint32_t extra_count
= 0;
3087 uint32_t changed_count
= 0;
3088 int total_count
= 0;
3091 int max_reported_jobs
= lp_max_reported_print_jobs(snum
);
3093 const char* sharename
= lp_servicename(talloc_tos(), snum
);
3094 TALLOC_CTX
*tmp_ctx
= talloc_new(msg_ctx
);
3095 if (tmp_ctx
== NULL
) {
3099 /* make sure the database is up to date */
3100 if (print_cache_expired(lp_const_servicename(snum
), True
))
3101 print_queue_update(msg_ctx
, snum
, False
);
3107 ZERO_STRUCT(cgdata
);
3109 /* Get the stored queue data. */
3110 data
= tdb_fetch(pdb
->tdb
, string_tdb_data("INFO/linear_queue_array"));
3112 if (data
.dptr
&& data
.dsize
>= sizeof(qcount
))
3113 len
+= tdb_unpack(data
.dptr
+ len
, data
.dsize
- len
, "d", &qcount
);
3115 /* Get the added jobs list. */
3116 cgdata
= tdb_fetch(pdb
->tdb
, string_tdb_data("INFO/jobs_added"));
3117 if (cgdata
.dptr
!= NULL
&& (cgdata
.dsize
% 4 == 0))
3118 extra_count
= cgdata
.dsize
/4;
3120 /* Get the changed jobs list. */
3121 jcdata
= tdb_fetch(pdb
->tdb
, string_tdb_data("INFO/jobs_changed"));
3122 if (jcdata
.dptr
!= NULL
&& (jcdata
.dsize
% 4 == 0))
3123 changed_count
= jcdata
.dsize
/ 4;
3125 DEBUG(5,("get_stored_queue_info: qcount = %u, extra_count = %u\n", (unsigned int)qcount
, (unsigned int)extra_count
));
3127 /* Allocate the queue size. */
3128 if (qcount
== 0 && extra_count
== 0)
3131 if ((queue
= SMB_MALLOC_ARRAY(print_queue_struct
, qcount
+ extra_count
)) == NULL
)
3134 /* Retrieve the linearised queue data. */
3136 for(i
= 0; i
< qcount
; i
++) {
3137 uint32_t qjob
, qsize
, qpage_count
, qstatus
, qpriority
, qtime
;
3138 len
+= tdb_unpack(data
.dptr
+ len
, data
.dsize
- len
, "ddddddff",
3147 queue
[i
].sysjob
= qjob
;
3148 queue
[i
].size
= qsize
;
3149 queue
[i
].page_count
= qpage_count
;
3150 queue
[i
].status
= qstatus
;
3151 queue
[i
].priority
= qpriority
;
3152 queue
[i
].time
= qtime
;
3155 total_count
= qcount
;
3157 /* Add new jobids to the queue. */
3158 for (i
= 0; i
< extra_count
; i
++) {
3160 struct printjob
*pjob
;
3162 jobid
= IVAL(cgdata
.dptr
, i
*4);
3163 DEBUG(5,("get_stored_queue_info: added job = %u\n", (unsigned int)jobid
));
3164 pjob
= print_job_find(tmp_ctx
, lp_const_servicename(snum
), jobid
);
3166 DEBUG(5,("get_stored_queue_info: failed to find added job = %u\n", (unsigned int)jobid
));
3167 remove_from_jobs_added(sharename
, jobid
);
3171 queue
[total_count
].sysjob
= pjob
->sysjob
;
3172 queue
[total_count
].size
= pjob
->size
;
3173 queue
[total_count
].page_count
= pjob
->page_count
;
3174 queue
[total_count
].status
= pjob
->status
;
3175 queue
[total_count
].priority
= 1;
3176 queue
[total_count
].time
= pjob
->starttime
;
3177 fstrcpy(queue
[total_count
].fs_user
, pjob
->user
);
3178 fstrcpy(queue
[total_count
].fs_file
, pjob
->jobname
);
3183 /* Update the changed jobids. */
3184 for (i
= 0; i
< changed_count
; i
++) {
3185 uint32_t jobid
= IVAL(jcdata
.dptr
, i
* 4);
3186 struct printjob
*pjob
;
3190 pjob
= print_job_find(tmp_ctx
, sharename
, jobid
);
3192 DEBUG(5,("get_stored_queue_info: failed to find "
3193 "changed job = %u\n",
3194 (unsigned int)jobid
));
3195 remove_from_jobs_changed(sharename
, jobid
);
3199 for (j
= 0; j
< total_count
; j
++) {
3200 if (queue
[j
].sysjob
== pjob
->sysjob
) {
3207 DEBUG(5,("get_stored_queue_info: changed job: %u\n",
3208 (unsigned int)jobid
));
3210 queue
[j
].sysjob
= pjob
->sysjob
;
3211 queue
[j
].size
= pjob
->size
;
3212 queue
[j
].page_count
= pjob
->page_count
;
3213 queue
[j
].status
= pjob
->status
;
3214 queue
[j
].priority
= 1;
3215 queue
[j
].time
= pjob
->starttime
;
3216 fstrcpy(queue
[j
].fs_user
, pjob
->user
);
3217 fstrcpy(queue
[j
].fs_file
, pjob
->jobname
);
3220 DEBUG(5,("updated queue[%u], jobid: %u, sysjob: %u, "
3222 (unsigned int)j
, (unsigned int)jobid
,
3223 (unsigned int)queue
[j
].sysjob
, pjob
->jobname
));
3226 remove_from_jobs_changed(sharename
, jobid
);
3229 /* Sort the queue by submission time otherwise they are displayed
3232 TYPESAFE_QSORT(queue
, total_count
, printjob_comp
);
3234 DEBUG(5,("get_stored_queue_info: total_count = %u\n", (unsigned int)total_count
));
3236 if (max_reported_jobs
&& total_count
> max_reported_jobs
)
3237 total_count
= max_reported_jobs
;
3240 *pcount
= total_count
;
3246 SAFE_FREE(data
.dptr
);
3247 SAFE_FREE(cgdata
.dptr
);
3248 talloc_free(tmp_ctx
);
3252 /****************************************************************************
3253 Get a printer queue listing.
3254 set queue = NULL and status = NULL if you just want to update the cache
3255 ****************************************************************************/
3257 int print_queue_status(struct messaging_context
*msg_ctx
, int snum
,
3258 print_queue_struct
**ppqueue
,
3259 print_status_struct
*status
)
3263 const char *sharename
;
3264 struct tdb_print_db
*pdb
;
3267 /* make sure the database is up to date */
3269 if (print_cache_expired(lp_const_servicename(snum
), True
))
3270 print_queue_update(msg_ctx
, snum
, False
);
3272 /* return if we are done */
3273 if ( !ppqueue
|| !status
)
3277 sharename
= lp_const_servicename(snum
);
3278 pdb
= get_print_db_byname(sharename
);
3284 * Fetch the queue status. We must do this first, as there may
3285 * be no jobs in the queue.
3288 ZERO_STRUCTP(status
);
3289 slprintf(keystr
, sizeof(keystr
)-1, "STATUS/%s", sharename
);
3290 key
= string_tdb_data(keystr
);
3292 data
= tdb_fetch(pdb
->tdb
, key
);
3294 if (data
.dsize
== sizeof(*status
)) {
3295 /* this memcpy is ok since the status struct was
3296 not packed before storing it in the tdb */
3297 memcpy(status
, data
.dptr
, sizeof(*status
));
3299 SAFE_FREE(data
.dptr
);
3303 * Now, fetch the print queue information. We first count the number
3304 * of entries, and then only retrieve the queue if necessary.
3307 if (!get_stored_queue_info(msg_ctx
, pdb
, snum
, &count
, ppqueue
)) {
3308 release_print_db(pdb
);
3312 release_print_db(pdb
);
3316 /****************************************************************************
3318 ****************************************************************************/
3320 WERROR
print_queue_pause(const struct auth_session_info
*server_info
,
3321 struct messaging_context
*msg_ctx
, int snum
)
3324 struct printif
*current_printif
= get_printer_fns( snum
);
3326 if (!W_ERROR_IS_OK(print_access_check(server_info
, msg_ctx
, snum
,
3327 PRINTER_ACCESS_ADMINISTER
))) {
3328 return WERR_ACCESS_DENIED
;
3334 ret
= (*(current_printif
->queue_pause
))(snum
);
3339 return WERR_INVALID_PARAMETER
;
3342 /* force update the database */
3343 print_cache_flush(lp_const_servicename(snum
));
3345 /* Send a printer notify message */
3347 notify_printer_status(global_event_context(), msg_ctx
, snum
,
3348 PRINTER_STATUS_PAUSED
);
3353 /****************************************************************************
3355 ****************************************************************************/
3357 WERROR
print_queue_resume(const struct auth_session_info
*server_info
,
3358 struct messaging_context
*msg_ctx
, int snum
)
3361 struct printif
*current_printif
= get_printer_fns( snum
);
3363 if (!W_ERROR_IS_OK(print_access_check(server_info
, msg_ctx
, snum
,
3364 PRINTER_ACCESS_ADMINISTER
))) {
3365 return WERR_ACCESS_DENIED
;
3370 ret
= (*(current_printif
->queue_resume
))(snum
);
3375 return WERR_INVALID_PARAMETER
;
3378 /* make sure the database is up to date */
3379 if (print_cache_expired(lp_const_servicename(snum
), True
))
3380 print_queue_update(msg_ctx
, snum
, True
);
3382 /* Send a printer notify message */
3384 notify_printer_status(global_event_context(), msg_ctx
, snum
,
3390 /****************************************************************************
3391 Purge a queue - implemented by deleting all jobs that we can delete.
3392 ****************************************************************************/
3394 WERROR
print_queue_purge(const struct auth_session_info
*server_info
,
3395 struct messaging_context
*msg_ctx
, int snum
)
3397 print_queue_struct
*queue
;
3398 print_status_struct status
;
3402 /* Force and update so the count is accurate (i.e. not a cached count) */
3403 print_queue_update(msg_ctx
, snum
, True
);
3405 can_job_admin
= W_ERROR_IS_OK(print_access_check(server_info
,
3408 JOB_ACCESS_ADMINISTER
));
3409 njobs
= print_queue_status(msg_ctx
, snum
, &queue
, &status
);
3411 if ( can_job_admin
)
3414 for (i
= 0; i
< njobs
; i
++) {
3415 struct tdb_print_db
*pdb
;
3418 pdb
= get_print_db_byname(lp_const_servicename(snum
));
3420 DEBUG(1, ("failed to find printdb for %s\n",
3421 lp_const_servicename(snum
)));
3424 jobid
= sysjob_to_jobid_pdb(pdb
, queue
[i
].sysjob
);
3425 if (jobid
== (uint32_t)-1) {
3426 DEBUG(2, ("jobid for system job %d not found\n",
3428 continue; /* unix job */
3430 owner
= is_owner(server_info
, lp_const_servicename(snum
),
3433 if (owner
|| can_job_admin
) {
3434 print_job_delete1(global_event_context(), msg_ctx
,
3439 if ( can_job_admin
)
3442 /* update the cache */
3443 print_queue_update(msg_ctx
, snum
, True
);