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
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
|
#ifndef H_PSM
#define H_PSM
/** \ingroup rpmtrans payload
* \file lib/psm.h
* Package state machine to handle a package from a transaction set.
*/
#define _RPMSQ_INTERNAL
#include <rpmsq.h>
#include <rpmcallback.h>
extern int _psm_debug;
typedef struct rpmpsm_s * rpmpsm;
/**
*/
#define PSM_VERBOSE 0x8000
#define PSM_INTERNAL 0x4000
#define PSM_SYSCALL 0x2000
#define PSM_DEAD 0x1000
#define _fv(_a) ((_a) | PSM_VERBOSE)
#define _fi(_a) ((_a) | PSM_INTERNAL)
#define _fs(_a) ((_a) | (PSM_INTERNAL | PSM_SYSCALL))
#define _fd(_a) ((_a) | (PSM_INTERNAL | PSM_DEAD))
typedef enum pkgStage_e {
PSM_UNKNOWN = 0,
PSM_INIT = 1,
PSM_PRE = 2,
PSM_PROCESS = 3,
PSM_POST = 4,
PSM_UNDO = 5,
PSM_FINI = 6,
PSM_PKGINSTALL = 7,
PSM_PKGERASE = 8,
PSM_PKGCOMMIT = 10,
PSM_PKGSAVE = 12,
PSM_CREATE = 17,
PSM_NOTIFY = 22,
PSM_DESTROY = 23,
PSM_COMMIT = 25,
PSM_CHROOT_IN = 51,
PSM_CHROOT_OUT = 52,
PSM_SCRIPT = 53,
PSM_TRIGGERS = 54,
PSM_IMMED_TRIGGERS = 55,
PSM_RPMIO_FLAGS = 56,
PSM_RPMDB_LOAD = 97,
PSM_RPMDB_ADD = 98,
PSM_RPMDB_REMOVE = 99
} pkgStage;
#undef _fv
#undef _fi
#undef _fs
#undef _fd
/**
*/
struct rpmpsm_s {
struct rpmsqElem sq; /*!< Scriptlet/signal queue element. */
rpmts ts; /*!< transaction set */
rpmte te; /*!< current transaction element */
rpmfi fi; /*!< transaction element file info */
FD_t cfd; /*!< Payload file handle. */
FD_t fd; /*!< Repackage file handle. */
Header oh; /*!< Repackage header. */
rpmdbMatchIterator mi;
const char * stepName;
const char * rpmio_flags;
const char * failedFile;
const char * pkgURL; /*!< Repackage URL. */
const char * pkgfn; /*!< Repackage file name. */
int scriptTag; /*!< Scriptlet data tag. */
int progTag; /*!< Scriptlet interpreter tag. */
int npkgs_installed; /*!< No. of installed instances. */
int scriptArg; /*!< Scriptlet package arg. */
int sense; /*!< One of RPMSENSE_TRIGGER{IN,UN,POSTUN}. */
int countCorrection; /*!< 0 if installing, -1 if removing. */
int chrootDone; /*!< Was chroot(2) done by pkgStage? */
int unorderedSuccessor; /*!< Can the PSM be run asynchronously? */
rpmCallbackType what; /*!< Callback type. */
unsigned long amount; /*!< Callback amount. */
unsigned long total; /*!< Callback total. */
rpmRC rc;
pkgStage goal;
pkgStage stage; /*!< Current psm stage. */
pkgStage nstage; /*!< Next psm stage. */
int nrefs; /*!< Reference count. */
};
#ifdef __cplusplus
extern "C" {
#endif
/**
* Unreference a package state machine instance.
* @param psm package state machine
* @param msg
* @return NULL always
*/
rpmpsm rpmpsmUnlink (rpmpsm psm,
const char * msg);
/** @todo Remove debugging entry from the ABI. */
rpmpsm XrpmpsmUnlink (rpmpsm psm,
const char * msg, const char * fn, unsigned ln);
#define rpmpsmUnlink(_psm, _msg) XrpmpsmUnlink(_psm, _msg, __FILE__, __LINE__)
/**
* Reference a package state machine instance.
* @param psm package state machine
* @param msg
* @return new package state machine reference
*/
rpmpsm rpmpsmLink (rpmpsm psm, const char * msg);
/** @todo Remove debugging entry from the ABI. */
rpmpsm XrpmpsmLink (rpmpsm psm, const char * msg,
const char * fn, unsigned ln);
#define rpmpsmLink(_psm, _msg) XrpmpsmLink(_psm, _msg, __FILE__, __LINE__)
/**
* Destroy a package state machine.
* @param psm package state machine
* @return NULL always
*/
rpmpsm rpmpsmFree(rpmpsm psm);
/**
* Create and load a package state machine.
* @param ts transaction set
* @param te transaction set element
* @param fi file info set
* @return new package state machine
*/
rpmpsm rpmpsmNew(rpmts ts, rpmte te, rpmfi fi);
/**
* Package state machine driver.
* @param psm package state machine data
* @param stage next stage
* @return 0 on success
*/
rpmRC rpmpsmStage(rpmpsm psm, pkgStage stage);
#define rpmpsmUNSAFE rpmpsmSTAGE
#ifdef __cplusplus
}
#endif
#endif /* H_PSM */
|
