bytemark/flexnbd-c
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity
Files
4cd7e764bbb340e094a8b17412afd8ffe0a03c10
flexnbd-c/src/server/flexnbd.h

67 lines
1.6 KiB
C
Raw Normal View History

Add mboxes
2012-06-27 15:45:33 +01:00
#ifndef FLEXNBD_H
#define FLEXNBD_H
#include "acl.h"
#include "mirror.h"
#include "serve.h"
flexnbd: Add a proxy mode This lets us proxy connections between NBD clients and servers, resiliently.
2013-02-15 16:52:16 +00:00
#include "proxy.h"
flexnbd serve: Make the killswitch per-client-thread This is a bit tricky, but calling shutdown() on a socket in a signal handler is safe, and (at least in linux) appears to cause any read() or write() calls blocked on that socket to return, even with SA_RESTART. I'm not confident enough about the rest of flexnbd's syscall error handling to turn SA_RESTART off for this signal...
2014-01-22 11:49:21 +00:00
#include "client.h"
Add mboxes
2012-06-27 15:45:33 +01:00
#include "self_pipe.h"
#include "mbox.h"
#include "control.h"
Free all possibly held mutexes in error handlers Now that we have 3 mutexes lying around, it's important that we check and free these if necessary if error() is called in any thread that can hold them. To do this, we now have flexthread.c, which defines a flexthread_mutex struct. This is a wrapper around a pthread_mutex_t and a pthread_t. The idea is that in the error handler, the thread can check whether it holds the mutex and can free it if and only if it does. This is important because pthread fast mutexes can be freed by *any* thread, not just the thread which holds them. Note: it is only ever safe for a thread to check if it holds the mutex itself. It is *never* safe to check if another thread holds a mutex without first locking that mutex, which makes the whole operation rather pointless.
2012-07-11 09:43:16 +01:00
#include "flexthread.h"
Add mboxes
2012-06-27 15:45:33 +01:00
/* Carries the "globals". */
struct flexnbd {
flexnbd: Add a proxy mode This lets us proxy connections between NBD clients and servers, resiliently.
2013-02-15 16:52:16 +00:00
/* Our serve pointer should never be dereferenced outside a
* flexnbd_switch_lock/unlock pair.
Add mboxes
2012-06-27 15:45:33 +01:00
*/
struct server * serve;
Remove listen mode Changing behaviour so that instead of rebinding after a successful migration and continuing as an ordinary server, we simply quit with a 0 exit code and let our caller restart us as a server if they want to. This means that everything in listen.c, listen.h, and anything making reference to a rebind address is unneeded.
2012-07-23 09:48:50 +01:00
Add mboxes
2012-06-27 15:45:33 +01:00
/* We only have a control object if a control socket name was
* passed on the command line.
*/
struct control * control;
/* File descriptor for a signalfd(2) signal stream. */
int signal_fd;
};
Remove listen mode Changing behaviour so that instead of rebinding after a successful migration and continuing as an ordinary server, we simply quit with a 0 exit code and let our caller restart us as a server if they want to. This means that everything in listen.c, listen.h, and anything making reference to a rebind address is unneeded.
2012-07-23 09:48:50 +01:00
Add mboxes
2012-06-27 15:45:33 +01:00
struct flexnbd * flexnbd_create(void);
struct flexnbd * flexnbd_create_serving(
char* s_ip_address,
char* s_port,
char* s_file,
flexnbd: Normalise some variable declarations
2013-02-01 15:20:43 +00:00
char* s_ctrl_sock,
Add mboxes
2012-06-27 15:45:33 +01:00
int default_deny,
int acl_entries,
char** s_acl_entries,
flexnbd: Make the killswitch runtime-selectable We're not actually using it in production right now because it doesn't shut its sockets down cleanly enough. This is a better option than reverting the functionality or keeping production downgraded until we sort out a handler that cleanly closes the sockets.
2013-07-03 09:56:35 +01:00
int max_nbd_clients,
int use_killswitch);
Add mboxes
2012-06-27 15:45:33 +01:00
struct flexnbd * flexnbd_create_listening(
flexnbd: Normalise some variable declarations
2013-02-01 15:20:43 +00:00
char* s_ip_address,
char* s_port,
Remove listen mode Changing behaviour so that instead of rebinding after a successful migration and continuing as an ordinary server, we simply quit with a 0 exit code and let our caller restart us as a server if they want to. This means that everything in listen.c, listen.h, and anything making reference to a rebind address is unneeded.
2012-07-23 09:48:50 +01:00
char* s_file,
flexnbd: Normalise some variable declarations
2013-02-01 15:20:43 +00:00
char* s_ctrl_sock,
Remove listen mode Changing behaviour so that instead of rebinding after a successful migration and continuing as an ordinary server, we simply quit with a 0 exit code and let our caller restart us as a server if they want to. This means that everything in listen.c, listen.h, and anything making reference to a rebind address is unneeded.
2012-07-23 09:48:50 +01:00
int default_deny,
flexnbd: Normalise some variable declarations
2013-02-01 15:20:43 +00:00
int acl_entries,
Remove listen mode Changing behaviour so that instead of rebinding after a successful migration and continuing as an ordinary server, we simply quit with a 0 exit code and let our caller restart us as a server if they want to. This means that everything in listen.c, listen.h, and anything making reference to a rebind address is unneeded.
2012-07-23 09:48:50 +01:00
char** s_acl_entries );
Add mboxes
2012-06-27 15:45:33 +01:00
void flexnbd_destroy( struct flexnbd * );
enum mirror_state;
enum mirror_state flexnbd_get_mirror_state( struct flexnbd * );
int flexnbd_default_deny( struct flexnbd * );
void flexnbd_set_server( struct flexnbd * flexnbd, struct server * serve );
int flexnbd_signal_fd( struct flexnbd * flexnbd );
int flexnbd_serve( struct flexnbd * flexnbd );
flexnbd: Add a proxy mode This lets us proxy connections between NBD clients and servers, resiliently.
2013-02-15 16:52:16 +00:00
int flexnbd_proxy( struct flexnbd * flexnbd );
Add mboxes
2012-06-27 15:45:33 +01:00
struct server * flexnbd_server( struct flexnbd * flexnbd );
void flexnbd_replace_acl( struct flexnbd * flexnbd, struct acl * acl );
struct status * flexnbd_status_create( struct flexnbd * flexnbd );
#endif
flexnbd: Add a proxy mode This lets us proxy connections between NBD clients and servers, resiliently.
2013-02-15 16:52:16 +00:00
Reference in New Issue Copy Permalink