| Commit | Line | Data |
|---|---|---|
| 2910a90c MD |
1 | /* |
| 2 | * Copyright (c) 2011-2012 The DragonFly Project. All rights reserved. | |
| 3 | * | |
| 4 | * This code is derived from software contributed to The DragonFly Project | |
| 5 | * by Matthew Dillon <dillon@dragonflybsd.org> | |
| 6 | * by Venkatesh Srinivas <vsrinivas@dragonflybsd.org> | |
| 7 | * | |
| 8 | * Redistribution and use in source and binary forms, with or without | |
| 9 | * modification, are permitted provided that the following conditions | |
| 10 | * are met: | |
| 11 | * | |
| 12 | * 1. Redistributions of source code must retain the above copyright | |
| 13 | * notice, this list of conditions and the following disclaimer. | |
| 14 | * 2. Redistributions in binary form must reproduce the above copyright | |
| 15 | * notice, this list of conditions and the following disclaimer in | |
| 16 | * the documentation and/or other materials provided with the | |
| 17 | * distribution. | |
| 18 | * 3. Neither the name of The DragonFly Project nor the names of its | |
| 19 | * contributors may be used to endorse or promote products derived | |
| 20 | * from this software without specific, prior written permission. | |
| 21 | * | |
| 22 | * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS | |
| 23 | * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT | |
| 24 | * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS | |
| 25 | * FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE | |
| 26 | * COPYRIGHT HOLDERS OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, | |
| 27 | * INCIDENTAL, SPECIAL, EXEMPLARY OR CONSEQUENTIAL DAMAGES (INCLUDING, | |
| 28 | * BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; | |
| 29 | * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED | |
| 30 | * AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, | |
| 31 | * OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT | |
| 32 | * OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF | |
| 33 | * SUCH DAMAGE. | |
| 34 | */ | |
| 35 | ||
| 36 | /* | |
| 37 | * Rollup headers for hammer2 utility | |
| 38 | */ | |
| 39 | #include <sys/types.h> | |
| 9ab15106 | 40 | #include <sys/uio.h> |
| 2910a90c MD |
41 | #include <sys/mount.h> |
| 42 | #include <sys/file.h> | |
| 5ba65e34 MD |
43 | #include <sys/socket.h> |
| 44 | #include <sys/time.h> | |
| 45 | #include <sys/wait.h> | |
| 46 | #include <sys/tty.h> | |
| 9ab15106 | 47 | #include <sys/endian.h> |
| 5ba65e34 MD |
48 | |
| 49 | #include <netinet/in.h> | |
| 50 | #include <netinet/tcp.h> | |
| 51 | #include <arpa/inet.h> | |
| 52 | #include <netdb.h> | |
| 53 | ||
| 2910a90c MD |
54 | #include <vfs/hammer2/hammer2_disk.h> |
| 55 | #include <vfs/hammer2/hammer2_mount.h> | |
| 56 | #include <vfs/hammer2/hammer2_ioctl.h> | |
| 9ab15106 | 57 | #include <vfs/hammer2/hammer2_network.h> |
| 2910a90c MD |
58 | |
| 59 | #include <stdio.h> | |
| 60 | #include <stdlib.h> | |
| 61 | #include <stdarg.h> | |
| 62 | #include <stddef.h> | |
| 5ba65e34 | 63 | |
| 2910a90c | 64 | #include <errno.h> |
| 5ba65e34 MD |
65 | #include <fcntl.h> |
| 66 | #include <signal.h> | |
| 67 | #include <string.h> | |
| 68 | #include <unistd.h> | |
| 9ab15106 | 69 | #include <ctype.h> |
| ae183399 | 70 | #include <uuid.h> |
| 9ab15106 MD |
71 | #include <assert.h> |
| 72 | #include <pthread.h> | |
| 73 | #include <poll.h> | |
| 74 | ||
| 62efe6ec MD |
75 | #include <libutil.h> |
| 76 | ||
| 9ab15106 | 77 | #include "network.h" |
| 5ba65e34 | 78 | |
| 62efe6ec MD |
79 | #define HAMMER2_DEFAULT_DIR "/etc/hammer2" |
| 80 | #define HAMMER2_PATH_REMOTE HAMMER2_DEFAULT_DIR "/remote" | |
| 81 | ||
| 5ba65e34 | 82 | extern int DebugOpt; |
| bd878fc9 | 83 | extern int VerboseOpt; |
| 5ba65e34 | 84 | extern int NormalExit; |
| 2910a90c MD |
85 | |
| 86 | int hammer2_ioctl_handle(const char *sel_path); | |
| 9ab15106 MD |
87 | void hammer2_demon(void *(*func)(void *), void *arg); |
| 88 | void hammer2_bswap_head(hammer2_msg_hdr_t *head); | |
| 2910a90c MD |
89 | |
| 90 | int cmd_remote_connect(const char *sel_path, const char *url); | |
| 91 | int cmd_remote_disconnect(const char *sel_path, const char *url); | |
| 92 | int cmd_remote_status(const char *sel_path, int all_opt); | |
| ae183399 MD |
93 | |
| 94 | int cmd_pfs_list(const char *sel_path); | |
| 95 | int cmd_pfs_create(const char *sel_path, const char *name, | |
| 96 | uint8_t pfs_type, const char *uuid_str); | |
| 97 | int cmd_pfs_delete(const char *sel_path, const char *name); | |
| 98 | ||
| 62efe6ec | 99 | int cmd_service(void); |
| 9ab15106 | 100 | int cmd_leaf(const char *sel_path); |
| bd878fc9 MD |
101 | int cmd_shell(const char *hostname); |
| 102 | int cmd_show(const char *devpath); | |
| 62efe6ec MD |
103 | int cmd_rsainit(const char *dir_path); |
| 104 | int cmd_rsaenc(const char **keys, int nkeys); | |
| 105 | int cmd_rsadec(const char **keys, int nkeys); | |
| 9ab15106 MD |
106 | |
| 107 | void hammer2_ioq_init(hammer2_iocom_t *iocom, hammer2_ioq_t *ioq); | |
| 108 | void hammer2_ioq_done(hammer2_iocom_t *iocom, hammer2_ioq_t *ioq); | |
| 109 | void hammer2_iocom_init(hammer2_iocom_t *iocom, int sock_fd, int alt_fd); | |
| 110 | void hammer2_iocom_done(hammer2_iocom_t *iocom); | |
| 4a2e0eae | 111 | hammer2_msg_t *hammer2_allocmsg(hammer2_iocom_t *iocom, |
| 9ab15106 | 112 | uint32_t cmd, int aux_size); |
| 4a2e0eae MD |
113 | hammer2_msg_t *hammer2_allocreply(hammer2_msg_t *msg, |
| 114 | uint32_t cmd, int aux_size); | |
| 115 | void hammer2_replymsg(hammer2_msg_t *msg, uint16_t error); | |
| 116 | void hammer2_freemsg(hammer2_msg_t *msg); | |
| 9ab15106 MD |
117 | |
| 118 | void hammer2_iocom_core(hammer2_iocom_t *iocom, | |
| 119 | void (*iocom_recvmsg)(hammer2_iocom_t *), | |
| 120 | void (*iocom_sendmsg)(hammer2_iocom_t *), | |
| 121 | void (*iocom_altmsg)(hammer2_iocom_t *)); | |
| 4a2e0eae MD |
122 | hammer2_msg_t *hammer2_ioq_read(hammer2_iocom_t *iocom); |
| 123 | void hammer2_ioq_write(hammer2_msg_t *msg); | |
| 124 | ||
| 125 | void hammer2_ioq_stream(hammer2_msg_t *msg, int reply); | |
| 126 | void hammer2_iocom_drain(hammer2_iocom_t *iocom); | |
| 127 | void hammer2_iocom_flush(hammer2_iocom_t *iocom); | |
| 9ab15106 | 128 | |
| 62efe6ec | 129 | void hammer2_crypto_negotiate(hammer2_iocom_t *iocom); |
| 5cf97ec5 MD |
130 | void hammer2_crypto_decrypt(hammer2_iocom_t *iocom, hammer2_ioq_t *ioq); |
| 131 | void hammer2_crypto_decrypt_aux(hammer2_iocom_t *iocom, hammer2_ioq_t *ioq, | |
| 132 | hammer2_msg_t *msg, int already); | |
| 133 | int hammer2_crypto_encrypt(hammer2_iocom_t *iocom, hammer2_ioq_t *ioq, | |
| 134 | struct iovec *iov, int n); | |
| 135 | void hammer2_crypto_encrypt_wrote(hammer2_iocom_t *iocom, hammer2_ioq_t *ioq, | |
| 136 | int nact); | |
| 137 | ||
| bd878fc9 MD |
138 | const char *hammer2_time64_to_str(uint64_t htime64, char **strp); |
| 139 | const char *hammer2_uuid_to_str(uuid_t *uuid, char **strp); | |
| 140 | const char *hammer2_iptype_to_str(uint8_t type); | |
| 141 | const char *hammer2_pfstype_to_str(uint8_t type); | |
| 62efe6ec | 142 | |
| bd878fc9 | 143 | void hammer2_shell_remote(hammer2_msg_t *msg); |
| 4a2e0eae | 144 | void msg_printf(hammer2_msg_t *msg, const char *ctl, ...); |