1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131
|
/*
* Copyright (C) 2004-2006 by CERN/IT/GD/CT & CNRS/IN2P3/LAL
* All rights reserved
*/
// $Id: srm2_testReleaseSpace.c,v 1.2 2007/01/17 14:18:38 grodid Exp $
#include "srmv2H.h"
#include "srmSoapBinding.nsmap"
#define DEFPOLLINT 10
#define SRM_EP_PATH "/v2_1_1/srm"
#ifdef GFAL_SECURE
#include "cgsi_plugin.h"
#endif
#include "parsesurl.ic"
#include "soapcallns1.ic"
main(argc, argv)
int argc;
char **argv;
{
int flags;
int i;
int nbfiles;
#if 0
int nbproto = 0;
static char *protocols[] = {
#if GFAL_ENABLE_RFIO
"rfio",
#endif
#if GFAL_ENABLE_DCAP
"gsidcap",
#endif
""
};
#endif
int r = 0;
char *r_token;
struct ns1__srmReleaseSpaceResponse_ rep;
//struct ArrayOfTSURLPermissionReturn *repfs;
struct ns1__srmReleaseSpaceRequest req;
struct ns1__TSURLInfo *reqfilep;
struct ns1__TReturnStatus *reqstatp;
char *sfn;
struct soap soap;
char *srm_endpoint;
static enum xsd__boolean trueoption = true_; // JPB
if (argc < 5) {
fprintf (stderr, "usage: %s endPoint s_token storage_system_info force_flag\n", argv[0]);
exit (1);
}
#if 0
if (parsesurl (argv[3], &srm_endpoint, &sfn) < 0) {
perror ("parsesurl");
exit (1);
}
#endif
soap_init (&soap);
#ifdef GFAL_SECURE
flags = CGSI_OPT_DISABLE_NAME_CHECK;
soap_register_plugin_arg (&soap, client_cgsi_plugin, &flags);
#endif
memset (&req, 0, sizeof(req));
/*
if ((req.spaceToken =
soap_malloc (&soap, sizeof(struct ns1__TSpaceToken))) == NULL) {
perror ("malloc");
soap_end (&soap);
exit (1);
}
*/
req.spaceToken = argv[2];
if ((req.storageSystemInfo =
//soap_malloc (&soap, sizeof(struct ns1__TStorageSystemInfo))) == NULL) {
soap_malloc (&soap, sizeof(struct ns1__TExtraInfo))) == NULL) {
perror ("malloc");
soap_end (&soap);
exit (1);
}
//req.storageSystemInfo->value = argv[3];
/*
req.storageSystemInfo->__sizeextraInfoArray = 1;
req.storageSystemInfo->extraInfoArray[0]->key = "0";
req.storageSystemInfo->extraInfoArray[0]->value = argv[3];
*/
req.storageSystemInfo->__sizeextraInfoArray = 0;
req.storageSystemInfo->extraInfoArray = NULL;
//printf("Step 1\n");
/* req.forceFileRelease = atoi(argv[4]); */
if ( atoi(argv[4]) == 1 )
req.forceFileRelease = &trueoption;
/* To send the request ... */
#if 0
if (soap_call_ns1__srmReleaseSpace (&soap, argv[1], "SrmReleaseSpace",
&req, &rep)) {
soap_print_fault (&soap, stderr);
soap_print_fault_location (&soap, stderr);
soap_end (&soap);
exit (1);
}
#else
srm_endpoint = argv[1];
SOAP_CALL_NS1(ReleaseSpace, re);
#endif
reqstatp = rep.srmReleaseSpaceResponse->returnStatus;
printf ("request status %s\n", soap_ns1__TStatusCode2s (&soap, reqstatp->statusCode));
printf ("request state %d\n", reqstatp->statusCode);
if (reqstatp->statusCode != SRM_USCORESUCCESS &&
reqstatp->statusCode != SRM_USCOREDONE) {
if (reqstatp->explanation)
printf ("explanation: %s\n", reqstatp->explanation);
soap_end (&soap);
exit (1);
}
soap_end (&soap);
exit (0);
}
|