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-2007 by CERN/IT/GD/CT & CNRS/IN2P3/LAL
* All rights reserved
*/
// $Id: dpm-extendfilelife.c,v 1.3 2007/07/19 15:53:24 grodid Exp $
// Created by GG (03/11/2004)
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys/types.h>
#include "dpm_api.h"
#include "serrno.h"
#define DEFPOLLINT 10
#include <signal.h> /* catch signals */
// gnu opts
#include "dpmgopts.h"
#include "dpmutils.h"
//********************************************************//
int main(int argc, char *argv[])
{
//struct dpm_filestatus *filestatuses;
int i;
int nbfiles;
//int nbprotocols;
//int nbreplies;
//static char *protocols[] = {"rfio"};
//int r = 0;
//char r_token[CA_MAXDPMTOKENLEN+1];
//struct dpm_putfilereq *reqfiles;
int status;
time_t lifetime;
time_t actual_lifetime;
//int nbprotos;
//char **lprotos;
int nbsurls;
//char **lsurls;
int thisarg;
int nbargs;
char **remargs;
#include "dpmgdebug.h"
if (argc < 2) {
fprintf (stderr, "usage: %s \
--dpmrtoken=request_token (no default) \
only-one-SURL\n", argv[0]);
exit (1);
}
// gnu opts
reset_global(); /* must be before parser */
prog_gname = strdup(argv[0]);
//Pprintf (" before arg_parse \n");
thisarg = arg_parse(argc, argv);
//Pprintf ("\n after arg_parse %s %d %d \n", argv[thisarg], argc, thisarg);
remargs = NULL;
nbargs = 0;
if ( argc > thisarg ) {
remargs = realloc(remargs, sizeof(char*)*(argc-thisarg));
}
while ( thisarg < argc ) {
remargs[nbargs++] = strdup(argv[thisarg++]);
}
if ( nbargs != 1 ) {
printf ("dpm-extendfilelife: one SURL, and only one, must be provided \n");
exit(1);
}
nbfiles = nbargs;
//Pprintf( " Last arg: %d %s %s \n\n", nbargs, remargs[0], remargs[nbargs-1]);
// Loading inputs
//Pprintf (" \n");
/*
#define V_LSTR(NAME, UNAME) \
nb ## NAME = 0; \
l ## NAME = NULL; \
item_store(DPM_ ## UNAME, &nb ## NAME, &l ## NAME); \
p_array( #UNAME , nb ## NAME, l ## NAME);
V_LSTR(protos, PROT)
*/
// Setting defaults
if ( ! dpm_rtoken ) {
perror ("dpm-extendfilelife: Reqid token option is mandatory, --dpmrtoken=request_token ");
exit(1);
}
if ( ! dpm_lifet ) {
dpm_lifet = 0;
}
nbsurls = nbargs;
lifetime = dpm_lifet;
//Pprintf (" \n");
if ((status = dpm_extendfilelife (dpm_rtoken,
remargs[0],
lifetime,
&actual_lifetime
)) < 0) {
sperror ("==> Failure in dpm-extendfilelife");
exit (1);
}
printf ("request state %s\n", status == DPM_SUCCESS ? "Done" : "Failed");
printf ("request status %d new_lifetime = %d \n", status, actual_lifetime);
if (status == DPM_FAILED)
exit (1);
return 0;
}
|