1 files changed, 160 insertions, 0 deletions
diff --git a/vendor/voclient/libsamp/libxrpc/xrUtil.c b/vendor/voclient/libsamp/libxrpc/xrUtil.c
new file mode 100644
index 00000000..e8c3fb1b
--- /dev/null
+++ b/vendor/voclient/libsamp/libxrpc/xrUtil.c
@@ -0,0 +1,160 @@
+/** 
+ *  XRUTIL.C
+ *
+ *  Utility procedures.
+ *
+ *
+ *  @brief      Utility procedures.
+ *
+ *  @file       xrUtil.c
+ *  @author     Mike Fitzpatrick
+ *  @date       6/10/09
+ */
+
+#include <stdlib.h>
+#include <stdio.h>
+#include <unistd.h>
+#include <pthread.h>
+#include <signal.h>
+#include <string.h>
+#include <sys/socket.h>
+#include <netinet/in.h>
+
+#include <xmlrpc-c/base.h>
+#include <xmlrpc-c/client.h>
+#include <xmlrpc-c/server.h>
+#include <xmlrpc-c/server_abyss.h>
+
+#include "xrpc.h"
+
+
+extern	int  client_verbose;
+
+
+
+
+/** ************************************************************************
+ *  SIGTERM HANDLERS -- Setup the SIGTERM handler.
+ */
+xmlrpc_server_abyss_t *serverToTerminateP;
+
+void
+xr_setupSigtermHandler (xmlrpc_server_abyss_t *serverP)
+{
+    struct sigaction mysigaction;
+
+    sigemptyset (&mysigaction.sa_mask);
+    mysigaction.sa_flags = 0;
+    mysigaction.sa_handler = xr_svrSigtermHandler;
+    sigaction (SIGTERM, &mysigaction, NULL);
+}
+
+void
+xr_svrSigtermHandler (int signalClass)
+{
+    xmlrpc_env env;
+
+    xmlrpc_env_init (&env);
+    xmlrpc_server_abyss_terminate (&env, serverToTerminateP);
+    xr_dieIfFailed ("xmlrpc_server_abyss_terminate", env);
+
+    xmlrpc_env_clean (&env);
+}
+
+void
+xr_restoreSigtermHandler (void)
+{
+    struct sigaction mysigaction;
+
+    sigemptyset (&mysigaction.sa_mask);
+    mysigaction.sa_flags = 0;
+    mysigaction.sa_handler = SIG_DFL;
+    sigaction (SIGTERM, &mysigaction, NULL);
+}
+
+
+
+/** ************************************************************************
+ *  SIGPIPE HANDLERS -- Setup the SIGPIPE handlers.
+ */
+void
+xr_setupSigpipeHandlers (void)
+{
+    struct sigaction mysigaction;
+
+    sigemptyset (&mysigaction.sa_mask);
+    mysigaction.sa_flags = 0;
+    mysigaction.sa_handler = SIG_IGN;
+    sigaction (SIGPIPE, &mysigaction, NULL);
+}
+
+
+
+/** ************************************************************************
+ *  Utility procedures.
+ */
+
+/**
+ *  XR_GETPEERIPADDR -- Get the IP addr of the host on the server channel.
+ */
+char *
+xr_getPeerIpAddr (TSession * const abyssSessionP)
+{
+    struct abyss_unix_chaninfo * channelInfoP;
+    struct sockaddr_in * sockAddrInP;
+    static unsigned char *ipAddr, buf[32];
+
+
+    SessionGetChannelInfo (abyssSessionP, (void*)&channelInfoP);
+
+    sockAddrInP = (struct sockaddr_in *) &channelInfoP->peerAddr;
+    ipAddr      = (unsigned char *)&sockAddrInP->sin_addr.s_addr;
+
+    memset (buf, 0, 32);
+    sprintf ((char *)buf, "%u.%u.%u.%u", 
+	(unsigned int)ipAddr[0], (unsigned int)ipAddr[1], 
+	(unsigned int)ipAddr[2], (unsigned int)ipAddr[3]);
+
+    return ((char *)buf);
+}
+
+
+void
+xr_dieIfFailed (char *description, xmlrpc_env env)
+{
+    if (env.fault_occurred) {
+        fprintf (stderr, "%s failed. %s\n", description, env.fault_string);
+        exit (1);
+    }
+}
+
+
+void die_on_error (xmlrpc_env *env) 
+{
+    if (env->fault_occurred) {
+        fprintf(stderr, 
+	    "XML-RPC Fault: %s (%d)\n", env->fault_string, env->fault_code);
+        exit(1);
+    }
+}
+
+
+void warn_on_error (xmlrpc_env *env) 
+{
+    if (env->fault_occurred && client_verbose)
+        fprintf(stderr, 
+	    "XML-RPC Fault: %s (%d)\n", env->fault_string, env->fault_code);
+}
+
+
+void
+xr_dbgPrintParams ( xmlrpc_server_abyss_parms s )
+{
+    fprintf (stderr, "Server Params:\n");
+    fprintf (stderr, "\tport = %d\n", s.port_number);
+    fprintf (stderr, "\tlogfile = %s\n", s.log_file_name);
+    fprintf (stderr, "\tkeepalive_timeout = %d\n", s.keepalive_timeout);
+    fprintf (stderr, "\tkeepalive_max_conn = %d\n", s.keepalive_max_conn);
+    fprintf (stderr, "\ttimeout = %d\n", s.timeout);
+}
+