| 127 | super()._handle_signals(signum, sigframe) |
| 128 | |
| 129 | def verify_environment(self): |
| 130 | if not self.config["verify_env"]: |
| 131 | return |
| 132 | v_dirs = [ |
| 133 | self.config["pki_dir"], |
| 134 | os.path.join(self.config["pki_dir"], "minions"), |
| 135 | os.path.join(self.config["pki_dir"], "minions_pre"), |
| 136 | os.path.join(self.config["pki_dir"], "minions_denied"), |
| 137 | os.path.join(self.config["pki_dir"], "minions_autosign"), |
| 138 | os.path.join(self.config["pki_dir"], "minions_rejected"), |
| 139 | self.config["cachedir"], |
| 140 | os.path.join(self.config["cachedir"], "jobs"), |
| 141 | os.path.join(self.config["cachedir"], "proc"), |
| 142 | self.config["sock_dir"], |
| 143 | self.config["token_dir"], |
| 144 | self.config["syndic_dir"], |
| 145 | self.config["sqlite_queue_dir"], |
| 146 | ] |
| 147 | pki_dir = self.config["pki_dir"] |
| 148 | if ( |
| 149 | self.config["cluster_id"] |
| 150 | and self.config["cluster_pki_dir"] |
| 151 | # and self.config["cluster_pki_dir"] != self.config["pki_dir"] |
| 152 | ): |
| 153 | v_dirs.extend( |
| 154 | [ |
| 155 | self.config["cluster_pki_dir"], |
| 156 | os.path.join(self.config["cluster_pki_dir"], "peers"), |
| 157 | os.path.join(self.config["cluster_pki_dir"], "minions"), |
| 158 | os.path.join(self.config["cluster_pki_dir"], "minions_pre"), |
| 159 | os.path.join(self.config["cluster_pki_dir"], "minions_denied"), |
| 160 | os.path.join(self.config["cluster_pki_dir"], "minions_autosign"), |
| 161 | os.path.join(self.config["cluster_pki_dir"], "minions_rejected"), |
| 162 | ] |
| 163 | ) |
| 164 | pki_dir = [self.config["pki_dir"], self.config["cluster_pki_dir"]] |
| 165 | |
| 166 | verify_env( |
| 167 | v_dirs, |
| 168 | self.config["user"], |
| 169 | permissive=self.config["permissive_pki_access"], |
| 170 | root_dir=self.config["root_dir"], |
| 171 | pki_dir=pki_dir, |
| 172 | ) |
| 173 | |
| 174 | def prepare(self): |
| 175 | """ |