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