+/*
+ * Edit codes into (Un)MountCommand, Write(First)PartCommand
+ * %% = %
+ * %a = archive device name
+ * %e = erase (set if cannot mount and first part)
+ * %n = part number
+ * %m = mount point
+ * %v = last part name
+ *
+ * omsg = edited output message
+ * imsg = input string containing edit codes (%x)
+ *
+ */
+void DEVICE::edit_mount_codes(POOL_MEM &omsg, const char *imsg)
+{
+ const char *p;
+ const char *str;
+ char add[20];
+
+ POOL_MEM archive_name(PM_FNAME);
+
+ omsg.c_str()[0] = 0;
+ Dmsg1(800, "edit_mount_codes: %s\n", imsg);
+ for (p=imsg; *p; p++) {
+ if (*p == '%') {
+ switch (*++p) {
+ case '%':
+ str = "%";
+ break;
+ case 'a':
+ str = dev_name;
+ break;
+ case 'e':
+ if (num_dvd_parts == 0) {
+ if (truncating || blank_dvd) {
+ str = "2";
+ } else {
+ str = "1";
+ }
+ } else {
+ str = "0";
+ }
+ break;
+ case 'n':
+ bsnprintf(add, sizeof(add), "%d", part);
+ str = add;
+ break;
+ case 'm':
+ str = device->mount_point;
+ break;
+ case 'v':
+ make_spooled_dvd_filename(this, archive_name);
+ str = archive_name.c_str();
+ break;
+ default:
+ add[0] = '%';
+ add[1] = *p;
+ add[2] = 0;
+ str = add;
+ break;
+ }
+ } else {
+ add[0] = *p;
+ add[1] = 0;
+ str = add;
+ }
+ Dmsg1(1900, "add_str %s\n", str);
+ pm_strcat(omsg, (char *)str);
+ Dmsg1(1800, "omsg=%s\n", omsg.c_str());
+ }
+}
+
+/* return the last timer interval (ms) */
+btime_t DEVICE::get_timer_count()
+{
+ btime_t old = last_timer;
+ last_timer = get_current_btime();
+ return last_timer - old;
+}
+
+/* read from fd */
+ssize_t DEVICE::read(void *buf, size_t len)
+{
+ ssize_t read_len ;
+
+ get_timer_count();
+
+ if (this->is_tape()) {
+ read_len = tape_read(fd, buf, len);
+ } else {
+ read_len = ::read(fd, buf, len);
+ }
+
+ last_tick = get_timer_count();
+
+ DevReadTime += last_tick;
+ VolCatInfo.VolReadTime += last_tick;
+
+ if (read_len > 0) { /* skip error */
+ DevReadBytes += read_len;
+ }
+
+ return read_len;
+}
+
+/* write to fd */
+ssize_t DEVICE::write(const void *buf, size_t len)
+{
+ ssize_t write_len ;
+
+ get_timer_count();
+
+ if (this->is_tape()) {
+ write_len = tape_write(fd, buf, len);
+ } else {
+ write_len = ::write(fd, buf, len);
+ }
+
+ last_tick = get_timer_count();
+
+ DevWriteTime += last_tick;
+ VolCatInfo.VolWriteTime += last_tick;
+
+ if (write_len > 0) { /* skip error */
+ DevWriteBytes += write_len;
+ }
+
+ return write_len;
+}
+