mas01cr@239: #include "audioDB.h"
mas01cr@239: #include "adb.nsmap"
mas01cr@239: 
mas01cr@239: /* Command-line client definitions */
mas01cr@239: 
mas01cr@239: // FIXME: this can't propagate the sequence length argument (used for
mas01cr@239: // dudCount).  See adb__status() definition for the other half of
mas01cr@239: // this.  -- CSR, 2007-10-01
mas01cr@239: void audioDB::ws_status(const char*dbName, char* hostport){
mas01cr@239:   struct soap soap;
mas01cr@239:   adb__statusResponse adbStatusResponse;  
mas01cr@239:   
mas01cr@239:   // Query an existing adb database
mas01cr@239:   soap_init(&soap);
mas01cr@239:   if(soap_call_adb__status(&soap,hostport,NULL,(char*)dbName,adbStatusResponse)==SOAP_OK) {
mas01cr@239:     std::cout << "numFiles = " << adbStatusResponse.result.numFiles << std::endl;
mas01cr@239:     std::cout << "dim = " << adbStatusResponse.result.dim << std::endl;
mas01cr@239:     std::cout << "length = " << adbStatusResponse.result.length << std::endl;
mas01cr@239:     std::cout << "dudCount = " << adbStatusResponse.result.dudCount << std::endl;
mas01cr@239:     std::cout << "nullCount = " << adbStatusResponse.result.nullCount << std::endl;
mas01mc@324:     std::cout << "flags = " << (adbStatusResponse.result.flags & 0x00FFFFFF) << std::endl;
mas01cr@239:   } else {
mas01cr@239:     soap_print_fault(&soap,stderr);
mas01cr@239:   }
mas01cr@239:   
mas01cr@239:   soap_destroy(&soap);
mas01cr@239:   soap_end(&soap);
mas01cr@239:   soap_done(&soap);
mas01cr@239: }
mas01cr@239: 
mas01mc@334: void audioDB::ws_liszt(const char* dbName, char* Hostport){
mas01mc@334:   struct soap soap;
mas01mc@334:   adb__lisztResponse adbLisztResponse;
mas01mc@334: 
mas01mc@334:   soap_init(&soap);
mas01mc@334:   if(soap_call_adb__liszt(&soap, hostport, NULL, (char*)dbName, lisztOffset, lisztLength, adbLisztResponse)==SOAP_OK){
mas01mc@334:     for(int i = 0; i < adbLisztResponse.result.__sizeRkey; i++) {
mas01mc@334:       std::cout << "[" << i+lisztOffset << "] " << adbLisztResponse.result.Rkey[i] << " (" 
mas01mc@334: 		<< adbLisztResponse.result.Rlen[i] << ")" << std::endl;
mas01mc@334:     }
mas01mc@334:   } else {
mas01mc@334:     soap_print_fault(&soap, stderr);
mas01mc@334:   }
mas01mc@334: }
mas01mc@334: 
mas01mc@308: // WS_QUERY (CLIENT SIDE)
mas01mc@307: void audioDB::ws_query(const char*dbName, const char *featureFileName, const char* hostport){
mas01cr@239:   struct soap soap;
mas01cr@239:   adb__queryResponse adbQueryResponse;  
mas01mc@329:   VERB_LOG(1, "Calling fileName query on database %s with featureFile=%s\n", dbName, featureFileName);
mas01cr@333:   soap_init(&soap);
mas01cr@333:   if(soap_call_adb__query(&soap, hostport, NULL, (char *) dbName,
mas01cr@333: 			  (char *)featureFileName, (char *)trackFileName,
mas01cr@333: 			  (char *)timesFileName, (char *) powerFileName,
mas01cr@333: 			  queryType, queryPoint, 
mas01cr@333: 			  pointNN, trackNN, sequenceLength, 
mas01cr@333: 			  radius, absolute_threshold, relative_threshold,
mas01cr@333: 			  !usingQueryPoint, lsh_exact,
mas01cr@333: 			  adbQueryResponse) 
mas01cr@333:      == SOAP_OK) {
mas01cr@333:     if(radius == 0) {
mas01cr@333:       for(int i=0; i<adbQueryResponse.result.__sizeRlist; i++) {
mas01cr@333: 	std::cout << adbQueryResponse.result.Rlist[i] << " "
mas01cr@333: 		  << adbQueryResponse.result.Dist[i] << " "
mas01cr@333: 		  << adbQueryResponse.result.Qpos[i] << " " 
mas01cr@333: 		  << adbQueryResponse.result.Spos[i] << std::endl;
mas01cr@333:       }
mas01cr@333:     } else {
mas01cr@333:       for(int i = 0; i < adbQueryResponse.result.__sizeRlist; i++) {
mas01cr@333: 	std::cout << adbQueryResponse.result.Rlist[i] << " " 
mas01cr@333: 		  << adbQueryResponse.result.Spos[i] << std::endl;
mas01cr@333:       }
mas01cr@333:     }
mas01cr@333:   } else {
mas01cr@333:     soap_print_fault(&soap,stderr);
mas01cr@239:   }
mas01cr@333: 
mas01cr@239:   soap_destroy(&soap);
mas01cr@239:   soap_end(&soap);
mas01cr@239:   soap_done(&soap);
mas01cr@239: }
mas01mc@307: 
mas01mc@308: // WS_QUERY_BY_KEY (CLIENT SIDE)
mas01mc@328: void audioDB::ws_query_by_key(const char*dbName, const char *trackKey, const char* featureFileName, const char* hostport){
mas01mc@307:   struct soap soap;
mas01mc@307:   adb__queryResponse adbQueryResponse;  
mas01mc@314:   /*  JUST TRY TO USE A DATA STRUCTURE WITH PHP
mas01mc@314:       adb__sequenceQueryParms asqp;
mas01mc@314:       asqp.keyList = (char*)trackFileName;
mas01mc@314:       asqp.timesFileName = (char*)timesFileName;
mas01mc@314:       asqp.queryPoint = queryPoint;
mas01mc@314:       asqp.pointNN = pointNN;
mas01mc@314:       asqp.trackNN = trackNN;
mas01mc@314:       asqp.sequenceLength = sequenceLength;
mas01mc@314:       asqp.radius = radius;
mas01mc@314:       asqp.relative_threshold = relative_threshold;
mas01mc@314:       asqp.absolute_threshold = absolute_threshold;
mas01mc@314:       asqp.usingQueryPoint = usingQueryPoint;
mas01mc@314:       asqp.lsh_exact = lsh_exact;
mas01mc@314:   */
mas01mc@331:   VERB_LOG(1, "Calling %s query on database %s with %s=%s\n", (trackKey&&strlen(trackKey))?"KEY":"FILENAME", dbName, (trackKey&&strlen(trackKey))?"KEY":"FILENAME",(trackKey&&strlen(trackKey))?trackKey:featureFileName);
mas01mc@307:   soap_init(&soap);  
mas01mc@307:   if(queryType==O2_SEQUENCE_QUERY || queryType==O2_N_SEQUENCE_QUERY){
mas01mc@314:     if(soap_call_adb__sequenceQueryByKey(&soap,hostport,NULL,
mas01mc@328: 					 (char*)dbName,
mas01mc@328: 					 (char*)trackKey,
mas01mc@328: 					 (char*)featureFileName,
mas01mc@328: 					 queryType,
mas01mc@328: 					 (char*)trackFileName, // this means keyFileName 
mas01mc@328: 					 (char*)timesFileName,
mas01mc@314: 					   queryPoint,
mas01mc@328: 					 pointNN,
mas01mc@328: 					 trackNN,
mas01mc@328: 					 sequenceLength,
mas01mc@328: 					 radius,
mas01mc@328: 					 absolute_threshold,
mas01mc@328: 					 usingQueryPoint,
mas01mc@314: 					   lsh_exact,
mas01mc@314: 					 adbQueryResponse)==SOAP_OK){
mas01mc@307:       //std::std::cerr << "result list length:" << adbQueryResponse.result.__sizeRlist << std::std::endl;
mas01mc@307:       for(int i=0; i<adbQueryResponse.result.__sizeRlist; i++)
mas01mc@307: 	std::cout << adbQueryResponse.result.Rlist[i] << " " << adbQueryResponse.result.Dist[i] 
mas01mc@307: 		  << " " << adbQueryResponse.result.Qpos[i] << " " << adbQueryResponse.result.Spos[i] << std::endl;
mas01mc@307:     }
mas01mc@307:     else
mas01mc@307:       soap_print_fault(&soap,stderr);
mas01mc@307:   }else
mas01mc@307:     ;// FIX ME: WRITE NON-SEQUENCE QUERY BY KEY ?
mas01mc@307:   
mas01mc@307:   soap_destroy(&soap);
mas01mc@307:   soap_end(&soap);
mas01mc@307:   soap_done(&soap);
mas01mc@307: }
mas01mc@307: 
mas01cr@239: 
mas01cr@333: /* handy macros */
mas01cr@333: #define INTSTRINGIFY(val, str) \
mas01cr@333:   char str[256]; \
mas01cr@333:   snprintf(str, 256, "%d", val);
mas01cr@333: #define DOUBLESTRINGIFY(val, str) \
mas01cr@333:   char str[256]; \
mas01cr@333:   snprintf(str, 256, "%f", val);
mas01cr@333: 
mas01cr@239: /* Server definitions */
mas01cr@239: int adb__status(struct soap* soap, xsd__string dbName, adb__statusResponse &adbStatusResponse){
mas01cr@345:   const char *const argv[]={"./audioDB",COM_STATUS,"-d",dbName};
mas01cr@239:   const unsigned argc = 4;
mas01cr@239:   try {
mas01cr@239:     audioDB(argc, argv, &adbStatusResponse);
mas01cr@239:     return SOAP_OK;
mas01cr@239:   } catch(char *err) {
mas01cr@239:     soap_receiver_fault(soap, err, "");
mas01cr@239:     return SOAP_FAULT;
mas01cr@239:   }
mas01cr@239: }
mas01mc@334: 
mas01mc@334: int adb__liszt(struct soap* soap, xsd__string dbName, xsd__int lisztOffset, xsd__int lisztLength, 
mas01mc@334: 	       adb__lisztResponse& adbLisztResponse){
mas01mc@334: 
mas01mc@334:   INTSTRINGIFY(lisztOffset, lisztOffsetStr);
mas01mc@334:   INTSTRINGIFY(lisztLength, lisztLengthStr);
mas01mc@334: 
mas01cr@345:   const char* const argv[] = {"./audioDB", COM_LISZT, "-d",dbName, "--lisztOffset", lisztOffsetStr, "--lisztLength", lisztLengthStr};
mas01mc@334:   const unsigned argc = 8;
mas01mc@334:   try{
mas01mc@334:     audioDB(argc, argv, &adbLisztResponse);
mas01mc@334:     return SOAP_OK;
mas01mc@334:   } catch(char *err) {
mas01mc@334:     soap_receiver_fault(soap, err, "");
mas01mc@334:     return SOAP_FAULT;
mas01mc@334:   }
mas01mc@334: } 
mas01mc@334: 
mas01cr@239: // Literal translation of command line to web service
mas01cr@333: int adb__query(struct soap* soap, xsd__string dbName, 
mas01cr@333: 	       xsd__string qKey, xsd__string keyList, 
mas01cr@333: 	       xsd__string timesFileName, xsd__string powerFileName, 
mas01cr@333: 	       xsd__int qType, 
mas01cr@333: 	       xsd__int qPos, xsd__int pointNN, xsd__int trackNN, 
mas01cr@333: 	       xsd__int seqLen,
mas01cr@333: 	       xsd__double radius, 
mas01cr@333: 	       xsd__double absolute_threshold, xsd__double relative_threshold,
mas01cr@333: 	       xsd__int exhaustive, xsd__int lsh_exact,
mas01cr@333: 	       adb__queryResponse &adbQueryResponse){
mas01cr@239:   char queryType[256];
mas01mc@329: 
mas01mc@329:   fprintf(stderr,"Calling fileName query on database %s with featureFile=%s\n", dbName, qKey);
mas01mc@329: 
mas01cr@239:   for(int k=0; k<256; k++)
mas01cr@239:     queryType[k]='\0';
mas01cr@239:   if(qType == O2_POINT_QUERY)
mas01cr@239:     strncpy(queryType, "point", strlen("point"));
mas01cr@239:   else if (qType == O2_SEQUENCE_QUERY)
mas01cr@239:     strncpy(queryType, "sequence", strlen("sequence"));
mas01cr@239:   else if(qType == O2_TRACK_QUERY)
mas01cr@239:     strncpy(queryType,"track", strlen("track"));
mas01mc@324:   else if(qType == O2_N_SEQUENCE_QUERY)
mas01mc@324:     strncpy(queryType,"nsequence", strlen("nsequence"));
mas01cr@239: 
mas01cr@239:   if(pointNN==0)
mas01cr@239:     pointNN=10;
mas01cr@239:   if(trackNN==0)
mas01cr@239:     trackNN=10;
mas01cr@239:   if(seqLen==0)
mas01cr@239:     seqLen=16;
mas01cr@239: 
mas01cr@333:   INTSTRINGIFY(qPos, qPosStr);
mas01cr@333:   INTSTRINGIFY(pointNN, pointNNStr);
mas01cr@333:   INTSTRINGIFY(trackNN, trackNNStr);
mas01cr@333:   INTSTRINGIFY(seqLen, seqLenStr);
mas01cr@239: 
mas01cr@333:   /* We don't necessarily use these, but because of scope we do this
mas01cr@333:      anyway.  We waste 756 bytes of stack this way. */
mas01cr@333:   DOUBLESTRINGIFY(radius, radiusStr);
mas01cr@333:   DOUBLESTRINGIFY(absolute_threshold, absolute_thresholdStr);
mas01cr@333:   DOUBLESTRINGIFY(relative_threshold, relative_thresholdStr);
mas01cr@333: 
mas01cr@333:   unsigned int argc = 19;
mas01cr@333:   if (powerFileName) {
mas01cr@333:     argc += 2;
mas01cr@333:   }
mas01cr@333:   if (radius != 0) {
mas01cr@333:     argc += 2;
mas01cr@333:   }
mas01cr@333:   /* we can't use use_absolute_threshold and friends because we're not
mas01cr@333:      in the audioDB class here. */
mas01cr@333:   if (absolute_threshold != 0) {
mas01cr@333:     argc += 2;
mas01cr@333:   }
mas01cr@333:   if (relative_threshold != 0) {
mas01cr@333:     argc += 2;
mas01cr@333:   }
mas01cr@333:   if (exhaustive) {
mas01cr@333:     argc++;
mas01cr@333:   }
mas01cr@333:   if (lsh_exact) {
mas01cr@333:     argc++;
mas01cr@333:   }
mas01cr@333: 
mas01cr@345:   const char **argv = new const char*[argc+1];
mas01cr@333:   argv[0] = "./audioDB";
mas01cr@333:   argv[1] = COM_QUERY;
mas01cr@333:   argv[2] = queryType;
mas01cr@333:   argv[3] = COM_DATABASE;
mas01cr@333:   argv[4] = (char *) (ENSURE_STRING(dbName));
mas01cr@333:   argv[5] = COM_FEATURES;
mas01cr@333:   argv[6] = (char *) (ENSURE_STRING(qKey));
mas01cr@333:   argv[7] = COM_KEYLIST;
mas01cr@333:   argv[8] = (char *) (ENSURE_STRING(keyList));
mas01cr@333:   argv[9] = COM_TIMES;
mas01cr@333:   argv[10] = (char *) (ENSURE_STRING(timesFileName));
mas01cr@333:   argv[11] = COM_QPOINT;
mas01cr@333:   argv[12] = qPosStr;
mas01cr@333:   argv[13] = COM_POINTNN;
mas01cr@333:   argv[14] = pointNNStr;
mas01cr@333:   argv[15] = COM_TRACKNN;
mas01cr@333:   argv[16] = trackNNStr;
mas01cr@333:   argv[17] = COM_SEQLEN;
mas01cr@333:   argv[18] = seqLenStr;
mas01cr@333:   int argv_counter = 19;
mas01cr@333:   if (powerFileName) {
mas01cr@333:     argv[argv_counter++] = COM_QUERYPOWER;
mas01cr@333:     argv[argv_counter++] = powerFileName;
mas01cr@333:   }
mas01cr@333:   if (radius != 0) {
mas01cr@333:     argv[argv_counter++] = COM_RADIUS;
mas01cr@333:     argv[argv_counter++] = radiusStr;
mas01cr@333:   }
mas01cr@333:   if (absolute_threshold != 0) {
mas01cr@333:     argv[argv_counter++] = COM_ABSOLUTE_THRESH;
mas01cr@333:     argv[argv_counter++] = absolute_thresholdStr;
mas01cr@333:   }
mas01cr@333:   if (relative_threshold != 0) {
mas01cr@333:     argv[argv_counter++] = COM_RELATIVE_THRESH;
mas01cr@333:     argv[argv_counter++] = relative_thresholdStr;
mas01cr@333:   }
mas01cr@333:   if (exhaustive) {
mas01cr@333:     argv[argv_counter++] = COM_EXHAUSTIVE;
mas01cr@333:   }
mas01cr@333:   if (lsh_exact) {
mas01cr@333:     argv[argv_counter++] = COM_LSH_EXACT;
mas01cr@333:   }
mas01cr@333:   argv[argv_counter] = NULL;
mas01cr@333: 
mas01cr@333: 
mas01cr@239:   try {
mas01cr@239:     audioDB(argc, (char* const*)argv, &adbQueryResponse);
mas01cr@333:     delete [] argv;
mas01cr@239:     return SOAP_OK;
mas01cr@239:   } catch (char *err) {
mas01cr@239:     soap_receiver_fault(soap, err, "");
mas01cr@333:     delete [] argv;
mas01cr@239:     return SOAP_FAULT;
mas01cr@239:   }
mas01cr@239: }
mas01cr@239: 
mas01mc@314: int adb__sequenceQueryByKey(struct soap* soap,xsd__string dbName,
mas01mc@314: 			    xsd__string trackKey,
mas01mc@328: 			    xsd__string featureFileName,
mas01mc@314: 			    xsd__int queryType,
mas01mc@328: 			    xsd__string keyFileName,
mas01mc@314: 			    xsd__string timesFileName,
mas01mc@314: 			    xsd__int queryPoint,
mas01mc@314: 			    xsd__int pointNN,
mas01mc@314: 			    xsd__int trackNN,
mas01mc@314: 			    xsd__int sequenceLength,
mas01mc@314: 			    xsd__double radius,
mas01mc@314: 			    xsd__double absolute_threshold,
mas01mc@314: 			    xsd__int usingQueryPoint,
mas01mc@314: 			    xsd__int lsh_exact,
mas01mc@314: 			    struct adb__queryResponse& adbQueryResponse){
mas01mc@307:   char qtypeStr[256];
mas01cr@239: 
mas01mc@331:   fprintf(stderr, "Calling %s query on database %s with %s=%s\n", (trackKey&&strlen(trackKey))?"KEY":"FILENAME", dbName, (trackKey&&strlen(trackKey))?"KEY":"FILENAME",(trackKey&&strlen(trackKey))?trackKey:featureFileName);
mas01mc@329: 
mas01mc@314:   INTSTRINGIFY(queryPoint, qPosStr);
mas01mc@314:   INTSTRINGIFY(pointNN, pointNNStr);
mas01mc@314:   INTSTRINGIFY(trackNN, trackNNStr);
mas01mc@314:   INTSTRINGIFY(sequenceLength, seqLenStr);
mas01mc@314:   DOUBLESTRINGIFY(absolute_threshold, absolute_thresholdStr);
mas01mc@314:   DOUBLESTRINGIFY(radius, radiusStr);
mas01mc@307: 
mas01mc@307:   // WS queries only support 1-nearest neighbour point reporting
mas01mc@307:   // at the moment, until we figure out how to better serve results
mas01mc@307:   snprintf(qtypeStr, 256, "nsequence");
mas01mc@310:   const char *argv[]={
mas01cr@239:     "./audioDB",
mas01cr@239:     COM_QUERY,
mas01mc@307:     qtypeStr,
mas01cr@239:     COM_DATABASE,
mas01cr@239:     dbName, 
mas01mc@330:     (trackKey&&strlen(trackKey))?COM_QUERYKEY:COM_FEATURES,
mas01mc@330:     (trackKey&&strlen(trackKey))?ENSURE_STRING(trackKey):ENSURE_STRING(featureFileName),
mas01cr@239:     COM_KEYLIST,
mas01mc@328:     ENSURE_STRING(keyFileName),
mas01mc@314:     usingQueryPoint?COM_QPOINT:COM_EXHAUSTIVE,
mas01mc@314:     usingQueryPoint?qPosStr:"",
mas01cr@239:     COM_POINTNN,
mas01cr@239:     pointNNStr,
mas01cr@239:     COM_TRACKNN,
mas01cr@239:     trackNNStr,
mas01mc@307:     COM_RADIUS,
mas01mc@307:     radiusStr,
mas01cr@239:     COM_SEQLEN,
mas01cr@239:     seqLenStr,
mas01cr@239:     COM_ABSOLUTE_THRESH,
mas01mc@310:     absolute_thresholdStr,
mas01mc@314:     lsh_exact?COM_LSH_EXACT:""
mas01cr@239:   };
mas01cr@239: 
mas01mc@310:   const unsigned argc = 22;
mas01mc@310:   
mas01mc@310:  
mas01cr@239:   try {
mas01cr@239:     audioDB(argc, (char* const*)argv, &adbQueryResponse);
mas01cr@239:     return SOAP_OK;
mas01cr@239:   } catch (char *err) {
mas01cr@239:     soap_receiver_fault(soap, err, "");
mas01cr@239:     return SOAP_FAULT;
mas01cr@239:   }
mas01cr@239: }
mas01cr@239: 
mas01cr@239: /* Server loop */
mas01cr@239: void audioDB::startServer(){
mas01cr@239:   struct soap soap;
mas01cr@239:   int m, s; // master and slave sockets
mas01cr@239:   soap_init(&soap);
mas01cr@239:   // FIXME: largely this use of SO_REUSEADDR is to make writing (and
mas01cr@239:   // running) test cases more convenient, so that multiple test runs
mas01cr@239:   // in close succession don't fail because of a bin() error.
mas01cr@239:   // Investigate whether there are any potential drawbacks in this,
mas01cr@239:   // and also whether there's a better way to write the tests.  --
mas01cr@239:   // CSR, 2007-10-03
mas01cr@239:   soap.bind_flags |= SO_REUSEADDR;
mas01cr@239:   m = soap_bind(&soap, NULL, port, 100);
mas01cr@239:   if (m < 0)
mas01cr@239:     soap_print_fault(&soap, stderr);
mas01cr@239:   else
mas01cr@239:     {
mas01cr@239:       fprintf(stderr, "Socket connection successful: master socket = %d\n", m);
mas01mc@308:       // Make a global Web Services LSH Index (SINGLETON)
mas01mc@313:       if(WS_load_index && dbName && !index_exists(dbName, radius, sequenceLength)){
mas01mc@313:         error("Can't find requested index file:", index_get_name(dbName,radius,sequenceLength));
mas01mc@313:       }
mas01mc@308:       if(WS_load_index && dbName && index_exists(dbName, radius, sequenceLength)){
mas01mc@308: 	char* indexName = index_get_name(dbName, radius, sequenceLength);
mas01mc@308: 	fprintf(stderr, "Loading LSH hashtables: %s...\n", indexName);
mas01mc@308: 	lsh = new LSH(indexName, true);
mas01mc@308: 	assert(lsh);
mas01mc@308: 	SERVER_LSH_INDEX_SINGLETON = lsh;
mas01mc@308: 	fprintf(stderr, "LSH INDEX READY\n");
mas01mc@308: 	fflush(stderr);
mas01mc@308: 	delete[] indexName;
mas01mc@308:       }
mas01mc@324:       
mas01mc@324:       // Server-side path prefix to databases and features
mas01mc@324:       if(adb_root)
mas01mc@324: 	SERVER_ADB_ROOT = (char*)adb_root; // Server-side database root
mas01mc@324:       if(adb_feature_root)
mas01mc@324: 	SERVER_ADB_FEATURE_ROOT = (char*)adb_feature_root; // Server-side features root
mas01mc@338:       
mas01mc@338:       isServer = 1;  // From this point, errors are reported via SOAP to the client
mas01cr@239:       for (int i = 1; ; i++)
mas01cr@239: 	{
mas01cr@239: 	  s = soap_accept(&soap);
mas01cr@239: 	  if (s < 0)
mas01cr@239: 	    {
mas01cr@239: 	      soap_print_fault(&soap, stderr);
mas01cr@239: 	      break;
mas01cr@239: 	    }
mas01cr@239:           /* FIXME: find a way to play nice with logging when run from
mas01cr@239:              /etc/init.d scripts: at present this just goes nowhere */
mas01cr@239: 	  fprintf(stderr, "%d: accepted connection from IP=%lu.%lu.%lu.%lu socket=%d\n", i,
mas01cr@239: 		  (soap.ip >> 24)&0xFF, (soap.ip >> 16)&0xFF, (soap.ip >> 8)&0xFF, soap.ip&0xFF, s);
mas01cr@239: 	  if (soap_serve(&soap) != SOAP_OK) // process RPC request
mas01cr@239: 	    soap_print_fault(&soap, stderr); // print error
mas01cr@239: 	  fprintf(stderr, "request served\n");
mas01cr@239: 	  soap_destroy(&soap); // clean up class instances
mas01cr@239: 	  soap_end(&soap); // clean up everything and close socket
mas01cr@239: 	}
mas01cr@239:     }
mas01cr@239:   soap_done(&soap); // close master socket and detach environment
mas01cr@239: }