initial load of upstream version 1.06.32

[xmlrpc-c] / examples / xmlrpc_asynch_client.c

diff --git a/examples/xmlrpc_asynch_client.c b/examples/xmlrpc_asynch_client.c
new file mode 100644 (file)
index 0000000..ae812e1
--- /dev/null
+++ b/examples/xmlrpc_asynch_client.c
@@ -0,0 +1,122 @@
+/* A simple asynchronous XML-RPC client written in C, as an example of
+   Xmlrpc-c asynchronous RPC facilities.  This is the same as the 
+   simpler synchronous client xmlprc_sample_add_client.c, except that
+   it adds 3 different pairs of numbers with the summation RPCs going on
+   simultaneously.
+
+   Use this with xmlrpc_sample_add_server.  Note that that server
+   intentionally takes extra time to add 1 to anything, so you can see
+   our 5+1 RPC finish after our 5+0 and 5+2 RPCs.
+*/
+
+#include <stdlib.h>
+#include <stdio.h>
+
+#include <xmlrpc-c/base.h>
+#include <xmlrpc-c/client.h>
+
+#include "config.h"  /* information about this build environment */
+
+#define NAME "Xmlrpc-c Asynchronous Test Client"
+#define VERSION "1.0"
+
+static void 
+die_if_fault_occurred (xmlrpc_env * const envP) {
+    if (envP->fault_occurred) {
+        fprintf(stderr, "Something failed. %s (XML-RPC fault code %d)\n",
+                envP->fault_string, envP->fault_code);
+        exit(1);
+    }
+}
+
+
+
+static void 
+handle_sample_add_response(const char *   const server_url,
+                           const char *   const method_name,
+                           xmlrpc_value * const param_array,
+                           void *         const user_data ATTR_UNUSED,
+                           xmlrpc_env *   const faultP,
+                           xmlrpc_value * const resultP) {
+
+    xmlrpc_env env;
+    xmlrpc_int addend, adder;
+    
+    /* Initialize our error environment variable */
+    xmlrpc_env_init(&env);
+
+    /* Our first four arguments provide helpful context.  Let's grab the
+       addends from our parameter array. 
+    */
+    xmlrpc_decompose_value(&env, param_array, "(ii)", &addend, &adder);
+    die_if_fault_occurred(&env);
+
+    printf("RPC with method '%s' at URL '%s' to add %d and %d "
+           "has completed\n", method_name, server_url, addend, adder);
+    
+    if (faultP->fault_occurred)
+        printf("The RPC failed.  %s", faultP->fault_string);
+    else {
+        xmlrpc_int sum;
+
+        xmlrpc_read_int(&env, resultP, &sum);
+        die_if_fault_occurred(&env);
+
+        printf("The sum is  %d\n", sum);
+    }
+}
+
+
+
+int 
+main(int           const argc, 
+     const char ** const argv ATTR_UNUSED) {
+
+    char * const serverUrl = "http://localhost:8080/RPC2";
+    char * const methodName = "sample.add";
+
+    xmlrpc_env env;
+    xmlrpc_client * clientP;
+    xmlrpc_int adder;
+
+    if (argc-1 > 0) {
+        fprintf(stderr, "This program has no arguments\n");
+        exit(1);
+    }
+
+    /* Initialize our error environment variable */
+    xmlrpc_env_init(&env);
+
+    /* Required before any use of Xmlrpc-c client library: */
+    xmlrpc_client_setup_global_const(&env);
+    die_if_fault_occurred(&env);
+
+    xmlrpc_client_create(&env, XMLRPC_CLIENT_NO_FLAGS, NAME, VERSION, NULL, 0,
+                         &clientP);
+    die_if_fault_occurred(&env);
+
+    for (adder = 0; adder < 3; ++adder) {
+        printf("Making XMLRPC call to server url '%s' method '%s' "
+               "to request the sum "
+               "of 5 and %d...\n", serverUrl, methodName, adder);
+
+        /* request the remote procedure call */
+        xmlrpc_client_start_rpcf(&env, clientP, serverUrl, methodName,
+                                  handle_sample_add_response, NULL,
+                                  "(ii)", (xmlrpc_int32) 5, adder);
+        die_if_fault_occurred(&env);
+    }
+    
+    printf("RPCs all requested.  Waiting for & handling responses...\n");
+
+    /* Wait for all RPCs to be done.  With some transports, this is also
+       what causes them to go.
+    */
+    xmlrpc_client_event_loop_finish(clientP);
+
+    printf("All RPCs finished.\n");
+
+    xmlrpc_client_destroy(clientP);
+
+    return 0;
+}