* Version $Id$
*/
/*
- Copyright (C) 2000, 2001, 2002 Kern Sibbald and John Walker
+ Copyright (C) 2000-2005 Kern Sibbald
This program is free software; you can redistribute it and/or
modify it under the terms of the GNU General Public License as
*/
-struct JCR;
+class JCR;
/* attr.c */
ATTR *new_attr();
char *bstrncpy (char *dest, POOL_MEM &src, int maxlen);
char *bstrncat (char *dest, const char *src, int maxlen);
char *bstrncat (char *dest, POOL_MEM &src, int maxlen);
+int cstrlen (const char *str);
void *b_malloc (const char *file, int line, size_t size);
#ifndef DEBUG
void *bmalloc (size_t size);
bool bnet_fsend (BSOCK *bs, const char *fmt, ...);
bool bnet_set_buffer_size (BSOCK *bs, uint32_t size, int rw);
bool bnet_sig (BSOCK *bs, int sig);
-int bnet_ssl_server (BSOCK *bsock, char *password, int ssl_need, int ssl_has);
-int bnet_ssl_client (BSOCK *bsock, char *password, int ssl_need);
-BSOCK * bnet_connect (JCR *jcr, int retry_interval,
- int max_retry_time, const char *name, char *host, char *service,
- int port, int verbose);
+int bnet_tls_server (TLS_CONTEXT *ctx, BSOCK *bsock,
+ alist *verify_list);
+int bnet_tls_client (TLS_CONTEXT *ctx, BSOCK *bsock);
+BSOCK * bnet_connect (JCR *jcr, int retry_interval,
+ int max_retry_time, const char *name, char *host, char *service,
+ int port, int verbose);
void bnet_close (BSOCK *bsock);
BSOCK * init_bsock (JCR *jcr, int sockfd, const char *who, const char *ip,
- int port, struct sockaddr *client_addr);
+ int port, struct sockaddr *client_addr);
BSOCK * dup_bsock (BSOCK *bsock);
void term_bsock (BSOCK *bsock);
const char *bnet_strerror (BSOCK *bsock);
int is_bnet_error (BSOCK *bsock);
void bnet_suppress_error_messages(BSOCK *bsock, bool flag);
dlist *bnet_host2ipaddrs(const char *host, int family, const char **errstr);
+int bnet_set_blocking (BSOCK *sock);
+int bnet_set_nonblocking (BSOCK *sock);
+void bnet_restore_blocking (BSOCK *sock, int flags);
/* bget_msg.c */
int bget_msg(BSOCK *sock);
int close_bpipe(BPIPE *bpipe);
/* cram-md5.c */
-int cram_md5_get_auth(BSOCK *bs, char *password, int ssl_need);
-int cram_md5_auth(BSOCK *bs, char *password, int ssl_need);
+int cram_md5_get_auth(BSOCK *bs, char *password, int *tls_remote_need);
+int cram_md5_auth(BSOCK *bs, char *password, int tls_local_need);
void hmac_md5(uint8_t* text, int text_len, uint8_t* key,
- int key_len, uint8_t *hmac);
+ int key_len, uint8_t *hmac);
/* crc32.c */
uint32_t bcrc32(uint8_t *buf, int len);
+/* crypto.c */
+int init_crypto (void);
+int cleanup_crypto (void);
+DIGEST * crypto_digest_new (crypto_digest_t type);
+bool crypto_digest_update (DIGEST *digest, const void *data, size_t length);
+bool crypto_digest_finalize (DIGEST *digest, void *dest, size_t *length);
+void crypto_digest_free (DIGEST *digest);
+SIGNATURE * crypto_sign_new (void);
+crypto_error_t crypto_sign_get_digest (SIGNATURE *sig, X509_KEYPAIR *keypair, DIGEST **digest);
+crypto_error_t crypto_sign_verify (SIGNATURE *sig, X509_KEYPAIR *keypair, DIGEST *digest);
+int crypto_sign_add_signer (SIGNATURE *sig, DIGEST *digest, X509_KEYPAIR *keypair);
+int crypto_sign_encode (SIGNATURE *sig, void *dest, size_t *length);
+SIGNATURE * crypto_sign_decode (const void *sigData, size_t length);
+void crypto_sign_free (SIGNATURE *sig);
+CRYPTO_SESSION * crypto_session_new (crypto_cipher_t cipher, alist *pubkeys);
+void crypto_session_free (CRYPTO_SESSION *cs);
+bool crypto_session_encode (CRYPTO_SESSION *cs, void *dest, size_t *length);
+crypto_error_t crypto_session_decode (const void *data, size_t length, alist *keypairs, CRYPTO_SESSION **session);
+CRYPTO_SESSION * crypto_session_decode (const void *data, size_t length);
+X509_KEYPAIR * crypto_keypair_new (void);
+X509_KEYPAIR * crypto_keypair_dup (X509_KEYPAIR *keypair);
+int crypto_keypair_load_cert (X509_KEYPAIR *keypair, const char *file);
+bool crypto_keypair_has_key (const char *file);
+int crypto_keypair_load_key (X509_KEYPAIR *keypair, const char *file, CRYPTO_PEM_PASSWD_CB *pem_callback, const void *pem_userdata);
+void crypto_keypair_free (X509_KEYPAIR *keypair);
+int crypto_default_pem_callback (char *buf, int size, const void *userdata);
+const char * crypto_digest_name (DIGEST *digest);
+crypto_digest_t crypto_digest_stream_type (int stream);
+const char * crypto_strerror (crypto_error_t error);
+
/* daemon.c */
void daemon_start ();
/* edit.c */
uint64_t str_to_uint64(char *str);
int64_t str_to_int64(char *str);
+#define str_to_int32(str) ((int32_t)str_to_int64(str))
char * edit_uint64_with_commas (uint64_t val, char *buf);
char * add_commas (char *val, char *buf);
char * edit_uint64 (uint64_t val, char *buf);
-int duration_to_utime (char *str, utime_t *value);
-int size_to_uint64(char *str, int str_len, uint64_t *rtn_value);
+char * edit_int64 (int64_t val, char *buf);
+bool duration_to_utime (char *str, utime_t *value);
+bool size_to_uint64(char *str, int str_len, uint64_t *rtn_value);
char *edit_utime (utime_t val, char *buf, int buf_len);
bool is_a_number (const char *num);
bool is_an_integer (const char *n);
void term_last_jobs_list();
void lock_last_jobs_list();
void unlock_last_jobs_list();
-void read_last_jobs_list(int fd, uint64_t addr);
+bool read_last_jobs_list(int fd, uint64_t addr);
uint64_t write_last_jobs_list(int fd, uint64_t addr);
void write_state_file(char *dir, const char *progname, int port);
void job_end_push(JCR *jcr, void job_end_cb(JCR *jcr,void *), void *ctx);
+void lock_jobs();
+void unlock_jobs();
+JCR *jcr_walk_start();
+JCR *jcr_walk_next(JCR *prev_jcr);
+void jcr_walk_end(JCR *jcr);
/* lex.c */
void lex_unget_char (LEX *lf);
const char * lex_tok_to_str (int token);
int lex_get_token (LEX *lf, int expect);
+void lex_set_default_error_handler (LEX *lf);
/* message.c */
void my_name_is (int argc, char *argv[], const char *name);
void free_msgs_res (MSGS *msgs);
void dequeue_messages (JCR *jcr);
void set_trace (int trace_flag);
-void set_exit_on_error (int value);
/* bnet_server.c */
void bnet_thread_server(dlist *addr, int max_clients, workq_t *client_wq,
- void *handle_client_request(void *bsock));
+ void *handle_client_request(void *bsock));
void bnet_stop_thread_server(pthread_t tid);
void bnet_server (int port, void handle_client_request(BSOCK *bsock));
int net_connect (int port);
/* python.c */
typedef int (EVENT_HANDLER)(JCR *jcr, const char *event);
-void init_python_interpreter(const char *progname, const char *scripts);
+void init_python_interpreter(const char *progname, const char *scripts,
+ const char *module);
void term_python_interpreter();
-extern EVENT_HANDLER *generate_event;
+//extern EVENT_HANDLER *generate_daemon_event;
+int generate_daemon_event(JCR *jcr, const char *event);
/* signal.c */
void init_signals (void terminate(int sig));
void init_stack_dump (void);
/* scan.c */
+void strip_leading_space (char *str);
void strip_trailing_junk (char *str);
void strip_trailing_slashes (char *dir);
bool skip_spaces (char **msg);
int fstrsch (const char *a, const char *b);
char *next_arg(char **s);
int parse_args(POOLMEM *cmd, POOLMEM **args, int *argc,
- char **argk, char **argv, int max_args);
+ char **argk, char **argv, int max_args);
void split_path_and_filename(const char *fname, POOLMEM **path,
- int *pnl, POOLMEM **file, int *fnl);
+ int *pnl, POOLMEM **file, int *fnl);
int bsscanf(const char *buf, const char *fmt, ...);
+/* tls.c */
+TLS_CONTEXT *new_tls_context (const char *ca_certfile,
+ const char *ca_certdir,
+ const char *certfile,
+ const char *keyfile,
+ CRYPTO_PEM_PASSWD_CB *pem_callback,
+ const void *pem_userdata,
+ const char *dhfile,
+ bool verify_peer);
+void free_tls_context (TLS_CONTEXT *ctx);
+#ifdef HAVE_TLS
+bool tls_postconnect_verify_host (TLS_CONNECTION *tls,
+ const char *host);
+bool tls_postconnect_verify_cn (TLS_CONNECTION *tls,
+ alist *verify_list);
+TLS_CONNECTION *new_tls_connection (TLS_CONTEXT *ctx, int fd);
+void free_tls_connection (TLS_CONNECTION *tls);
+bool tls_bsock_connect (BSOCK *bsock);
+bool tls_bsock_accept (BSOCK *bsock);
+void tls_bsock_shutdown (BSOCK *bsock);
+int tls_bsock_writen (BSOCK *bsock, char *ptr, int32_t nbytes);
+int tls_bsock_readn (BSOCK *bsock, char *ptr, int32_t nbytes);
+#endif /* HAVE_TLS */
+
+
/* util.c */
int is_buf_zero (char *buf, int len);
void lcase (char *str);
projects / bacula / bacula / blobdiff