Merge from vendor branch LESS:
[dragonfly.git] / sbin / jscan / jsession.c
CommitLineData
bb406b71
MD
1/*
2 * Copyright (c) 2005 The DragonFly Project. All rights reserved.
3 *
4 * This code is derived from software contributed to The DragonFly Project
5 * by Matthew Dillon <dillon@backplane.com>
6 *
7 * Redistribution and use in source and binary forms, with or without
8 * modification, are permitted provided that the following conditions
9 * are met:
10 *
11 * 1. Redistributions of source code must retain the above copyright
12 * notice, this list of conditions and the following disclaimer.
13 * 2. Redistributions in binary form must reproduce the above copyright
14 * notice, this list of conditions and the following disclaimer in
15 * the documentation and/or other materials provided with the
16 * distribution.
17 * 3. Neither the name of The DragonFly Project nor the names of its
18 * contributors may be used to endorse or promote products derived
19 * from this software without specific, prior written permission.
20 *
21 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
22 * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
23 * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS
24 * FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE
25 * COPYRIGHT HOLDERS OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT,
26 * INCIDENTAL, SPECIAL, EXEMPLARY OR CONSEQUENTIAL DAMAGES (INCLUDING,
27 * BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
28 * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED
29 * AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
30 * OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT
31 * OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
32 * SUCH DAMAGE.
33 *
36456e49 34 * $DragonFly: src/sbin/jscan/jsession.c,v 1.3 2005/09/07 19:10:09 dillon Exp $
bb406b71
MD
35 */
36
37#include "jscan.h"
38
39void
40jsession_init(struct jsession *ss, struct jfile *jfin,
a9cb3889
MD
41 enum jdirection direction,
42 const char *transid_file, int64_t transid)
bb406b71
MD
43{
44 bzero(ss, sizeof(*ss));
45 ss->ss_jfin = jfin;
a9cb3889 46 ss->ss_direction = direction;
bb406b71
MD
47 ss->ss_transid = transid;
48 ss->ss_transid_file = transid_file;
49 ss->ss_transid_fd = -1;
50}
51
36456e49
MD
52/*
53 * Update the last-processed transid. If operating in the reverse
54 * direction we have to write out transid - 1 so the next reverse
55 * processing operation does not re-execute the transid just executed
56 * and so the next forward processing operation does.
57 */
bb406b71
MD
58void
59jsession_update_transid(struct jsession *ss __unused, int64_t transid)
60{
61 char buf[32];
62
63 if (ss->ss_transid_file) {
64 if (ss->ss_transid_fd < 0) {
65 ss->ss_transid_fd = open(ss->ss_transid_file, O_RDWR|O_CREAT, 0666);
66 }
67 if (ss->ss_transid_fd < 0) {
68 fprintf(stderr, "Cannot open/create %s\n", ss->ss_transid_file);
69 exit(1);
70 }
36456e49
MD
71 if (ss->ss_direction == JD_FORWARDS)
72 snprintf(buf, sizeof(buf), "%016llx\n", transid);
73 else
74 snprintf(buf, sizeof(buf), "%016llx\n", transid - 1);
bb406b71
MD
75 lseek(ss->ss_transid_fd, 0L, 0);
76 write(ss->ss_transid_fd, buf, strlen(buf));
77 if (fsync_opt > 1)
78 fsync(ss->ss_transid_fd);
79 }
80}
81
36456e49
MD
82/*
83 * Returns non-zero if the data can be dumped into the specified session.
84 */
85int
86jsession_check(struct jsession *ss, struct jdata *jd)
87{
88 if (ss->ss_direction == JD_FORWARDS) {
89 if (jd->jd_transid > ss->ss_transid)
90 return(1);
91 } else {
92 if (jd->jd_transid <= ss->ss_transid)
93 return(1);
94 }
95 return(0);
96}
97
bb406b71
MD
98void
99jsession_term(struct jsession *ss)
100{
101 if (ss->ss_transid_fd >= 0) {
102 close(ss->ss_transid_fd);
103 ss->ss_transid_fd = -1;
104 }
105}
106