printing/printing_db.c

ソースコードを見る。

関数
tdb_print_db *	get_print_db_byname (const char *printername)
void	release_print_db (struct tdb_print_db *pdb)
void	close_all_print_db (void)
TDB_DATA	get_printer_notify_pid_list (TDB_CONTEXT *tdb, const char *printer_name, BOOL cleanlist)
変数
static struct tdb_print_db *	print_db_head

---

関数

struct tdb_print_db* get_print_db_byname

(

const char *

printername

)

printing_db.c の 33 行で定義されています。

参照先 tdb_print_db::next・num_open・print_db_head・tdb_print_db::printer_name・tdb_print_db::ref_count・strequal()・tdb_print_db::tdb.

参照元 get_queue_status()・get_updating_pid()・pjob_delete()・pjob_store()・print_backend_init()・print_cache_expired()・print_cache_flush()・print_job_delete1()・print_job_exists()・print_job_find()・print_job_start()・print_notify_deregister_pid()・print_notify_pid_list()・print_notify_register_pid()・print_queue_status()・print_queue_update()・print_queue_update_internal()・print_queue_update_with_lock()・remove_from_jobs_changed()・set_updating_pid()・sysjob_to_jobid().

{
        struct tdb_print_db *p = NULL, *last_entry = NULL;
        int num_open = 0;
        pstring printdb_path;
        BOOL done_become_root = False;

        SMB_ASSERT(printername != NULL);

        for (p = print_db_head, last_entry = print_db_head; p; p = p->next) {
                /* Ensure the list terminates... JRA. */
                SMB_ASSERT(p->next != print_db_head);

                if (p->tdb && strequal(p->printer_name, printername)) {
                        DLIST_PROMOTE(print_db_head, p);
                        p->ref_count++;
                        return p;
                }
                num_open++;
                last_entry = p;
        }

        /* Not found. */
        if (num_open >= MAX_PRINT_DBS_OPEN) {
                /* Try and recycle the last entry. */
                if (print_db_head && last_entry) {
                        DLIST_PROMOTE(print_db_head, last_entry);
                }

                for (p = print_db_head; p; p = p->next) {
                        if (p->ref_count)
                                continue;
                        if (p->tdb) {
                                if (tdb_close(print_db_head->tdb)) {
                                        DEBUG(0,("get_print_db: Failed to close tdb for printer %s\n",
                                                                print_db_head->printer_name ));
                                        return NULL;
                                }
                        }
                        p->tdb = NULL;
                        p->ref_count = 0;
                        memset(p->printer_name, '\0', sizeof(p->printer_name));
                        break;
                }
                if (p && print_db_head) {
                        DLIST_PROMOTE(print_db_head, p);
                        p = print_db_head;
                }
        }
       
        if (!p) {
                /* Create one. */
                p = SMB_MALLOC_P(struct tdb_print_db);
                if (!p) {
                        DEBUG(0,("get_print_db: malloc fail !\n"));
                        return NULL;
                }
                ZERO_STRUCTP(p);
                DLIST_ADD(print_db_head, p);
        }

        pstrcpy(printdb_path, lock_path("printing/"));
        pstrcat(printdb_path, printername);
        pstrcat(printdb_path, ".tdb");

        if (geteuid() != 0) {
                become_root();
                done_become_root = True;
        }

        p->tdb = tdb_open_log(printdb_path, 5000, TDB_DEFAULT, O_RDWR|O_CREAT, 
                0600);

        if (done_become_root)
                unbecome_root();

        if (!p->tdb) {
                DEBUG(0,("get_print_db: Failed to open printer backend database %s.\n",
                                        printdb_path ));
                DLIST_REMOVE(print_db_head, p);
                SAFE_FREE(p);
                return NULL;
        }
        fstrcpy(p->printer_name, printername);
        p->ref_count++;
        return p;
}

void release_print_db

(

struct tdb_print_db *

pdb

)

printing_db.c の 125 行で定義されています。

参照先 tdb_print_db::ref_count.

参照元 get_queue_status()・get_updating_pid()・pjob_delete()・pjob_store()・print_backend_init()・print_cache_expired()・print_cache_flush()・print_job_delete1()・print_job_exists()・print_job_find()・print_job_start()・print_notify_deregister_pid()・print_notify_pid_list()・print_notify_register_pid()・print_queue_status()・print_queue_update()・print_queue_update_internal()・print_queue_update_with_lock()・remove_from_jobs_changed()・set_updating_pid()・sysjob_to_jobid().

{
        pdb->ref_count--;
        SMB_ASSERT(pdb->ref_count >= 0);
}

void close_all_print_db

(

void

)

printing_db.c の 135 行で定義されています。

参照先 tdb_print_db::next・print_db_head・tdb_print_db::tdb・tdb_close().

参照元 del_a_printer()・print_backend_init()・printing_end().

{
        struct tdb_print_db *p = NULL, *next_p = NULL;

        for (p = print_db_head; p; p = next_p) {
                next_p = p->next;

                if (p->tdb)
                        tdb_close(p->tdb);
                DLIST_REMOVE(print_db_head, p);
                ZERO_STRUCTP(p);
                SAFE_FREE(p);
        }
}

TDB_DATA get_printer_notify_pid_list	(	TDB_CONTEXT *	tdb,
		const char *	printer_name,
		BOOL	cleanlist
	)

printing_db.c の 156 行で定義されています。

参照先 TDB_DATA::dptr・TDB_DATA::dsize・process_exists_by_pid()・sys_getpid()・tdb・tdb_delete_bystring()・tdb_fetch_bystring().

参照元 print_notify_deregister_pid()・print_notify_pid_list()・print_notify_register_pid().

{
        TDB_DATA data;
        size_t i;

        ZERO_STRUCT(data);

        data = tdb_fetch_bystring( tdb, NOTIFY_PID_LIST_KEY );

        if (!data.dptr) {
                ZERO_STRUCT(data);
                return data;
        }

        if (data.dsize % 8) {
                DEBUG(0,("get_printer_notify_pid_list: Size of record for printer %s not a multiple of 8 !\n", printer_name ));
                tdb_delete_bystring(tdb, NOTIFY_PID_LIST_KEY );
                SAFE_FREE(data.dptr);
                ZERO_STRUCT(data);
                return data;
        }

        if (!cleanlist)
                return data;

        /*
         * Weed out all dead entries.
         */

        for( i = 0; i < data.dsize; i += 8) {
                pid_t pid = (pid_t)IVAL(data.dptr, i);

                if (pid == sys_getpid())
                        continue;

                /* Entry is dead if process doesn't exist or refcount is zero. */

                while ((i < data.dsize) && ((IVAL(data.dptr, i + 4) == 0) || !process_exists_by_pid(pid))) {

                        /* Refcount == zero is a logic error and should never happen. */
                        if (IVAL(data.dptr, i + 4) == 0) {
                                DEBUG(0,("get_printer_notify_pid_list: Refcount == 0 for pid = %u printer %s !\n",
                                                        (unsigned int)pid, printer_name ));
                        }

                        if (data.dsize - i > 8)
                                memmove( &data.dptr[i], &data.dptr[i+8], data.dsize - i - 8);
                        data.dsize -= 8;
                }
        }

        return data;
}

---

変数

struct tdb_print_db* print_db_head [static]

printing_db.c の 26 行で定義されています。

参照元 close_all_print_db()・get_print_db_byname().

---