-/*
- * Protypes for stored -- Kern Sibbald MM
- *
- * Version $Id$
- */
/*
Bacula® - The Network Backup Solution
- Copyright (C) 2000-2006 Free Software Foundation Europe e.V.
+ Copyright (C) 2000-2007 Free Software Foundation Europe e.V.
The main author of Bacula is Kern Sibbald, with contributions from
many others, a complete list can be found in the file AUTHORS.
(FSFE), Fiduciary Program, Sumatrastrasse 25, 8006 Zürich,
Switzerland, email:ftf@fsfeurope.org.
*/
+/*
+ * Protypes for stored -- Kern Sibbald MM
+ *
+ * Version $Id$
+ */
/* From stored.c */
uint32_t new_VolSessionId();
void set_new_volume_parameters(DCR *dcr);
void set_new_file_parameters(DCR *dcr);
bool is_device_unmounted(DEVICE *dev);
-void dev_lock(DEVICE *dev);
-void dev_unlock(DEVICE *dev);
+uint32_t get_jobid_from_tid();
/* From dircmd.c */
void *handle_connection_request(void *arg);
/* From fd_cmds.c */
void run_job(JCR *jcr);
-bool get_bootstrap_file(JCR *jcr, BSOCK *bsock);
+bool get_bootstrap_file(JCR *jcr, BSOCK *bsock);
+void do_fd_commands(JCR *jcr);
/* From job.c */
void stored_free_jcr(JCR *jcr);
const char *stream_to_ascii(char *buf, int stream, int fi);
bool write_record_to_block(DEV_BLOCK *block, DEV_RECORD *rec);
bool can_write_record_to_block(DEV_BLOCK *block, DEV_RECORD *rec);
-bool read_record_from_block(DEV_BLOCK *block, DEV_RECORD *rec);
+bool read_record_from_block(DCR *dcr, DEV_BLOCK *block, DEV_RECORD *rec);
DEV_RECORD *new_record();
void free_record(DEV_RECORD *rec);
void empty_record(DEV_RECORD *rec);
/* From reserve.c */
void init_reservations_lock();
void term_reservations_lock();
-void lock_reservations();
-void unlock_reservations();
+void _lock_reservations();
+void _unlock_reservations();
void release_volume(DCR *dcr);
-VOLRES *new_volume(DCR *dcr, const char *VolumeName);
+VOLRES *reserve_volume(DCR *dcr, const char *VolumeName);
VOLRES *find_volume(const char *VolumeName);
bool free_volume(DEVICE *dev);
-void free_unused_volume(DCR *dcr);
+void unreserve_device(DCR *dcr);
+bool volume_unused(DCR *dcr);
void create_volume_list();
void free_volume_list();
void list_volumes(void sendit(const char *msg, int len, void *sarg), void *arg);
int search_res_for_device(RCTX &rctx);
void release_msgs(JCR *jcr);
+extern int reservations_lock_count;
+
+#ifdef SD_DEBUG_LOCK
+#define lock_reservations() \
+ do { Dmsg4(sd_dbglvl, "lock_reservations at %s:%d precnt=%d JobId=%u\n", \
+ __FILE__, __LINE__, \
+ reservations_lock_count, get_jobid_from_tid()); \
+ _lock_reservations(); \
+ Dmsg1(sd_dbglvl, "lock_reservations: got lock JobId=%u\n", \
+ get_jobid_from_tid()); \
+ } while (0)
+#define unlock_reservations() \
+ do { Dmsg4(sd_dbglvl, "unlock_reservations at %s:%d precnt=%d JobId=%u\n", \
+ __FILE__, __LINE__, \
+ reservations_lock_count, get_jobid_from_tid()); \
+ _unlock_reservations(); } while (0)
+#else
+#define lock_reservations() _lock_reservations()
+#define unlock_reservations() _unlock_reservations()
+#endif
+
+
/* From spool.c */
bool begin_data_spool (DCR *dcr);
/* From wait.c */
int wait_for_sysop(DCR *dcr);
-bool wait_for_device(JCR *jcr, bool first);
+bool wait_for_device(JCR *jcr, int &retries);