static inline size_t virNetServerTrackPendingAuthLocked(virNetServer *srv);
static inline size_t virNetServerTrackCompletedAuthLocked(virNetServer *srv);
-static int virNetServerOnceInit(void)
+static int
+virNetServerOnceInit(void)
{
if (!VIR_CLASS_NEW(virNetServer, virClassForObjectLockable()))
return -1;
VIR_ONCE_GLOBAL_INIT(virNetServer);
-unsigned long long virNetServerNextClientID(virNetServer *srv)
+
+unsigned long long
+virNetServerNextClientID(virNetServer *srv)
{
unsigned long long val;
return val;
}
-static int virNetServerProcessMsg(virNetServer *srv,
- virNetServerClient *client,
- virNetServerProgram *prog,
- virNetMessage *msg)
+
+static int
+virNetServerProcessMsg(virNetServer *srv,
+ virNetServerClient *client,
+ virNetServerProgram *prog,
+ virNetMessage *msg)
{
if (!prog) {
/* Only send back an error for type == CALL. Other
return 0;
}
-static void virNetServerHandleJob(void *jobOpaque, void *opaque)
+
+static void
+virNetServerHandleJob(void *jobOpaque,
+ void *opaque)
{
virNetServer *srv = opaque;
virNetServerJob *job = jobOpaque;
VIR_FREE(job);
}
+
/**
* virNetServerGetProgramLocked:
* @srv: server (must be locked by the caller)
return NULL;
}
+
static void
virNetServerDispatchNewMessage(virNetServerClient *client,
virNetMessage *msg,
}
}
-int virNetServerAddClient(virNetServer *srv,
- virNetServerClient *client)
+
+int
+virNetServerAddClient(virNetServer *srv,
+ virNetServerClient *client)
{
virObjectLock(srv);
return -1;
}
-static int virNetServerDispatchNewClient(virNetServerService *svc,
- virNetSocket *clientsock,
- void *opaque)
+
+static int
+virNetServerDispatchNewClient(virNetServerService *svc,
+ virNetSocket *clientsock,
+ void *opaque)
{
virNetServer *srv = opaque;
virNetServerClient *client;
}
-virNetServer *virNetServerNew(const char *name,
- unsigned long long next_client_id,
- size_t min_workers,
- size_t max_workers,
- size_t priority_workers,
- size_t max_clients,
- size_t max_anonymous_clients,
- int keepaliveInterval,
- unsigned int keepaliveCount,
- virNetServerClientPrivNew clientPrivNew,
- virNetServerClientPrivPreExecRestart clientPrivPreExecRestart,
- virFreeCallback clientPrivFree,
- void *clientPrivOpaque)
+virNetServer *
+virNetServerNew(const char *name,
+ unsigned long long next_client_id,
+ size_t min_workers,
+ size_t max_workers,
+ size_t priority_workers,
+ size_t max_clients,
+ size_t max_anonymous_clients,
+ int keepaliveInterval,
+ unsigned int keepaliveCount,
+ virNetServerClientPrivNew clientPrivNew,
+ virNetServerClientPrivPreExecRestart clientPrivPreExecRestart,
+ virFreeCallback clientPrivFree,
+ void *clientPrivOpaque)
{
virNetServer *srv;
}
-virNetServer *virNetServerNewPostExecRestart(virJSONValue *object,
- const char *name,
- virNetServerClientPrivNew clientPrivNew,
- virNetServerClientPrivNewPostExecRestart clientPrivNewPostExecRestart,
- virNetServerClientPrivPreExecRestart clientPrivPreExecRestart,
- virFreeCallback clientPrivFree,
- void *clientPrivOpaque)
+virNetServer *
+virNetServerNewPostExecRestart(virJSONValue *object,
+ const char *name,
+ virNetServerClientPrivNew clientPrivNew,
+ virNetServerClientPrivNewPostExecRestart clientPrivNewPostExecRestart,
+ virNetServerClientPrivPreExecRestart clientPrivPreExecRestart,
+ virFreeCallback clientPrivFree,
+ void *clientPrivOpaque)
{
virNetServer *srv = NULL;
virJSONValue *clients;
}
-virJSONValue *virNetServerPreExecRestart(virNetServer *srv)
+virJSONValue *
+virNetServerPreExecRestart(virNetServer *srv)
{
g_autoptr(virJSONValue) object = virJSONValueNewObject();
g_autoptr(virJSONValue) clients = virJSONValueNewArray();
}
-
-int virNetServerAddService(virNetServer *srv,
- virNetServerService *svc)
+int
+virNetServerAddService(virNetServer *srv,
+ virNetServerService *svc)
{
virObjectLock(srv);
}
-int virNetServerAddServiceTCP(virNetServer *srv,
- virSystemdActivation *act,
- const char *actname,
- const char *nodename,
- const char *service,
- int family,
- int auth,
- virNetTLSContext *tls,
- bool readonly,
- size_t max_queued_clients,
- size_t nrequests_client_max)
+int
+virNetServerAddServiceTCP(virNetServer *srv,
+ virSystemdActivation *act,
+ const char *actname,
+ const char *nodename,
+ const char *service,
+ int family,
+ int auth,
+ virNetTLSContext *tls,
+ bool readonly,
+ size_t max_queued_clients,
+ size_t nrequests_client_max)
{
virNetServerService *svc = NULL;
int ret;
}
-int virNetServerAddServiceUNIX(virNetServer *srv,
- virSystemdActivation *act,
- const char *actname,
- const char *path,
- mode_t mask,
- gid_t grp,
- int auth,
- virNetTLSContext *tls,
- bool readonly,
- size_t max_queued_clients,
- size_t nrequests_client_max)
+int
+virNetServerAddServiceUNIX(virNetServer *srv,
+ virSystemdActivation *act,
+ const char *actname,
+ const char *path,
+ mode_t mask,
+ gid_t grp,
+ int auth,
+ virNetTLSContext *tls,
+ bool readonly,
+ size_t max_queued_clients,
+ size_t nrequests_client_max)
{
virNetServerService *svc = NULL;
int ret;
}
-int virNetServerAddProgram(virNetServer *srv,
- virNetServerProgram *prog)
+int
+virNetServerAddProgram(virNetServer *srv,
+ virNetServerProgram *prog)
{
virObjectLock(srv);
return 0;
}
-int virNetServerSetTLSContext(virNetServer *srv,
- virNetTLSContext *tls)
+
+int
+virNetServerSetTLSContext(virNetServer *srv,
+ virNetTLSContext *tls)
{
srv->tls = virObjectRef(tls);
return 0;
}
-void virNetServerUpdateServices(virNetServer *srv,
- bool enabled)
+void
+virNetServerUpdateServices(virNetServer *srv,
+ bool enabled)
{
virObjectLock(srv);
virNetServerUpdateServicesLocked(srv, enabled);
virObjectUnlock(srv);
}
-void virNetServerDispose(void *obj)
+
+void
+virNetServerDispose(void *obj)
{
virNetServer *srv = obj;
size_t i;
g_free(srv->clients);
}
-void virNetServerClose(virNetServer *srv)
+
+void
+virNetServerClose(virNetServer *srv)
{
size_t i;
virObjectUnlock(srv);
}
+
void
virNetServerShutdownWait(virNetServer *srv)
{
virThreadPoolDrain(srv->workers);
}
+
static inline size_t
virNetServerTrackPendingAuthLocked(virNetServer *srv)
{
return ++srv->nclients_unauth;
}
+
static inline size_t
virNetServerTrackCompletedAuthLocked(virNetServer *srv)
{
return ret;
}
+
void
virNetServerProcessClients(virNetServer *srv)
{
virObjectUnlock(srv);
}
+
const char *
virNetServerGetName(virNetServer *srv)
{
return srv->name;
}
+
int
virNetServerGetThreadPoolParameters(virNetServer *srv,
size_t *minWorkers,
return 0;
}
+
int
virNetServerSetThreadPoolParameters(virNetServer *srv,
long long int minWorkers,
return ret;
}
+
size_t
virNetServerGetMaxClients(virNetServer *srv)
{
return ret;
}
+
size_t
virNetServerGetCurrentClients(virNetServer *srv)
{
return ret;
}
+
size_t
virNetServerGetMaxUnauthClients(virNetServer *srv)
{
return ret;
}
+
size_t
virNetServerGetCurrentUnauthClients(virNetServer *srv)
{
}
-bool virNetServerNeedsAuth(virNetServer *srv,
- int auth)
+bool
+virNetServerNeedsAuth(virNetServer *srv,
+ int auth)
{
bool ret = false;
size_t i;
return ret;
}
+
int
virNetServerGetClients(virNetServer *srv,
virNetServerClient ***clts)
return nclients;
}
+
virNetServerClient *
virNetServerGetClient(virNetServer *srv,
unsigned long long id)
return ret;
}
+
int
virNetServerSetClientLimits(virNetServer *srv,
long long int maxClients,
return ret;
}
+
static virNetTLSContext *
virNetServerGetTLSContext(virNetServer *srv)
{
return ctxt;
}
+
int
virNetServerUpdateTlsFiles(virNetServer *srv)
{