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
132
133
134
135
136
137
138
139
|
/*
* Copyright (C) 1998-2010 by CERN/IT/PDP/DM
* All rights reserved
*/
#ifndef lint
static char sccsid[] = "@(#)$RCSfile: rfmkdir.c,v $ $Revision: 3172 $ $Date: 2010-02-15 09:51:54 +0100 (Mon, 15 Feb 2010) $ CERN/IT/PDP/DM Olof Barring";
#endif /* not lint */
/*
* Make remote directory
*/
#include <errno.h>
#include <limits.h>
#include <string.h>
#include <sys/types.h>
#include <stdio.h>
#include <stdlib.h>
#include <sys/stat.h>
#include <rfio_api.h>
#if defined(_WIN32)
#include <winsock2.h>
#endif /* _WIN32 */
static char *ckpath();
char *getconfent();
int main(argc, argv)
int argc;
char *argv[];
{
extern char * optarg ;
extern int optind ;
int errflg = 0;
int mflag = 0;
int recursive = 0;
char *path,*root_path,*p;
int rc, c;
mode_t mode = 0777;
long int lmode = 0; /* For conversion, then casting to mode IN2P3*/
char *endprt; /* For conversion IN2P3*/
struct stat64 st;
#if defined(_WIN32)
WSADATA wsadata;
#endif /* _WIN32 */
if ( argc < 2 ) {
fprintf(stderr,"Usage: %s [-m mode] [-p] dirname ...\n",argv[0]);
exit(2);
}
while ( (c = getopt(argc,argv,"m:p")) != EOF ) {
switch(c) {
case 'm':
/* Converts mode into long then casts it - IN2P3 */
lmode = strtol(optarg, &endprt, 8);
if ( lmode > 0 && lmode <= 0777 && *endprt == '\0' ) mode = lmode;
else {
fprintf(stderr, "Invalid mode '%s'.\n", optarg);
exit(2);
}
mflag++;
break;
case 'p':
recursive++;
break;
case '?':
fprintf(stderr,"Usage: %s [-m mode] [-p] dirname ...\n",argv[0]);
exit(2);
}
}
#if defined(_WIN32)
if (WSAStartup (MAKEWORD (2, 0), &wsadata)) {
fprintf (stderr, "WSAStartup unsuccessful\n");
exit (2);
}
#endif
for (;optind<argc;optind++) {
path = ckpath(argv[optind]);
if ( recursive) {
root_path = (char *)malloc(strlen(path)+1);
strcpy(root_path,path);
while ( (p = strrchr(root_path,'/')) != NULL ) {
*p = '\0';
if ( !rfio_stat64(root_path,&st) ) break;
}
while ( strlen(root_path) != strlen(path) ) {
root_path[strlen(root_path)] = '/';
if ( rfio_mkdir(root_path,0777) && rfio_serrno() != EEXIST ) {
rfio_perror("mkdir()");
errflg++;
continue;
}
}
free(root_path);
} else {
if ( rfio_mkdir(path,0777) ) {
rfio_perror("mkdir()");
errflg++;
continue;
}
}
if ( mflag ) { /* must set requested mode + possible S_ISGID */
if ( rfio_stat64(path,&st) ) {
rfio_perror("stat()");
errflg++;
continue;
}
if ( rfio_chmod(path,(mode|st.st_mode&S_ISGID)) ) {
rfio_perror("chmod()");
errflg++;
continue;
}
}
}
if ( errflg)
exit(1);
else
exit(0);
}
static char *ckpath(path)
char *path;
{
char *cp;
static char newpath[BUFSIZ];
/* Special treatment for filenames starting with /scratch/... */
if (!strncmp ("/scratch/", path, 9) &&
(cp = (char *)getconfent ("SHIFT", "SCRATCH", 0)) != NULL) {
strcpy (newpath, cp);
strcat (newpath, path+9);
} else
strcpy(newpath,path);
return(newpath);
}
|
