leaf高能物理文件存储系统

/* * Copyright (C) 1999-2004 by CERN/IT/PDP/DM * All rights reserved */ #ifndef lint static char sccsid[] = "@(#)Cns_procreq.c,v 1.61 2004/03/03 08:51:31 CERN IT-PDP/DM Jean-Philippe Baud"; #endif /* not lint */ #include <stdio.h> #include <stdlib.h> #include <errno.h> #include <limits.h> #include <sys/stat.h> #include <time.h> #include <sys/types.h> #include <uuid/uuid.h> #include <python3.5m/Python.h> #include <fcntl.h> #include <time.h> #include <pthread.h> #if defined(_WIN32) #define R_OK 4 #define W_OK 2 #define X_OK 1 #define F_OK 0 #define S_ISGID 0002000 #define S_ISVTX 0001000 #include <winsock2.h> #else #include <unistd.h> #include <netinet/in.h> #endif #define MAXPATHLEN 1023 //the largest size of the file path #define UNIT_SIZE (1024*1024) #define PATH "/cdfs_data/" #define VIRPATH "/data/xrootdfs/file/" #include "marshall.h" #include "Cgrp.h" #include "Cns.h" #include "Cns_server.h" #include "Cpwd.h" #include "Cupv_api.h" #include "rfcntl.h" #include "serrno.h" #include "u64subr.h" #include "Cns_api.h" extern int being_shutdown; extern char localhost[CA_MAXHOSTNAMELEN+1]; struct transread_argument { char remote_path[100]; char local_path[100]; int start_location; int nums; int blocksize; }; void transread(const char *host,const char *filepath,const char *targetdir,const char *uid,const char *gid,int position,int size); /* Cns_logreq - log a request */ /* Split the message into lines so they don't exceed LOGBUFSZ-1 characters * A backslash is appended to a line to be continued * A continuation line is prefixed by '+ ' */ void Cns_logreq(char *func,char *logbuf) { int n1, n2; char *p; char savechrs1[2]; char savechrs2[2]; n1 = LOGBUFSZ - strlen (func) - 36; n2 = strlen (logbuf); p = logbuf; while (n2 > n1) { savechrs1[0] = *(p + n1); savechrs1[1] = *(p + n1 + 1); *(p + n1) = '\\'; *(p + n1 + 1) = '\0'; nslogit (func, NS098, p); if (p != logbuf) { *p = savechrs2[0]; *(p + 1) = savechrs2[1]; } p += n1 - 2; savechrs2[0] = *p; savechrs2[1] = *(p + 1); *p = '+'; *(p + 1) = ' '; *(p + 2) = savechrs1[0]; *(p + 3) = savechrs1[1]; n2 -= n1; } nslogit (func, NS098, p); if (p != logbuf) { *p = savechrs2[0]; *(p + 1) = savechrs2[1]; } } int marshall_DIRX (char **sbpp,struct Cns_file_metadata *fmd_entry) { char *sbp = *sbpp; marshall_HYPER (sbp, fmd_entry->fileid); marshall_WORD (sbp, fmd_entry->filemode); marshall_LONG (sbp, fmd_entry->nlink); marshall_LONG (sbp, fmd_entry->uid); marshall_LONG (sbp, fmd_entry->gid); marshall_HYPER (sbp, fmd_entry->filesize); marshall_TIME_T (sbp, fmd_entry->atime); marshall_TIME_T (sbp, fmd_entry->mtime); marshall_TIME_T (sbp, fmd_entry->ctime); marshall_WORD (sbp, fmd_entry->fileclass); marshall_BYTE (sbp, fmd_entry->status); marshall_STRING (sbp, fmd_entry->name); *sbpp = sbp; return (0); } int marshall_DIRXT (char **sbpp,int magic,struct Cns_file_metadata *fmd_entry,struct Cns_seg_metadata *smd_entry) { char *sbp = *sbpp; marshall_HYPER (sbp, fmd_entry->parent_fileid); if (magic >= CNS_MAGIC3) marshall_HYPER (sbp, smd_entry->s_fileid); marshall_WORD (sbp, smd_entry->copyno); marshall_WORD (sbp, smd_entry->fsec); marshall_HYPER (sbp, smd_entry->segsize); marshall_LONG (sbp, smd_entry->compression); marshall_BYTE (sbp, smd_entry->s_status); marshall_STRING (sbp, smd_entry->vid); if (magic >= CNS_MAGIC4) { marshall_STRING (sbp, smd_entry->checksum_name); marshall_LONG (sbp, smd_entry->checksum); } if (magic >= CNS_MAGIC2) marshall_WORD (sbp, smd_entry->side); marshall_LONG (sbp, smd_entry->fseq); marshall_OPAQUE (sbp, smd_entry->blockid, 4); marshall_STRING (sbp, fmd_entry->name); *sbpp = sbp; return (0); } /* Cns_srv_access - check accessibility of a file/directory */ int Cns_srv_access(int magic,char *req_data,char *clienthost,struct Cns_srv_thread_info *thip) { int amode; char basename[CA_MAXNAMELEN+1]; u_signed64 cwd; struct Cns_file_metadata fmd_entry; char func[16]; gid_t gid; char logbuf[CA_MAXPATHLEN+13]; mode_t mode; struct Cns_file_metadata parent_dir; char path[CA_MAXPATHLEN+1]; char *rbp; uid_t uid; strcpy (func, "Cns_srv_access"); rbp = req_data; unmarshall_LONG (rbp, uid); unmarshall_LONG (rbp, gid); nslogit (func, NS092, "access", uid, gid, clienthost); unmarshall_HYPER (rbp, cwd); if (unmarshall_STRINGN (rbp, path, CA_MAXPATHLEN+1)) return (SENAMETOOLONG); unmarshall_LONG (rbp, amode); sprintf (logbuf, "access %o %s", amode, path); Cns_logreq (func, logbuf); if (amode & ~(R_OK | W_OK | X_OK | F_OK)) return (EINVAL); if (Cns_splitname (cwd, path, basename)) return (serrno); if (*basename == '/') { /* Cns_access / */ parent_dir.fileid = 0; } else { /* check parent directory components for search permission */ if (Cns_chkdirperm (&thip->dbfd, cwd, path, S_IEXEC, uid, gid, clienthost, &parent_dir, NULL)) return (serrno); } /* get basename entry */ if (Cns_get_fmd_by_fullid (&thip->dbfd, parent_dir.fileid, basename, &fmd_entry, 0, NULL)) return (serrno); /* check permissions for basename */ if (amode == F_OK) return (0); mode = (amode & (R_OK|W_OK|X_OK)) << 6; if (Cns_chkentryperm (&fmd_entry, mode, uid, gid, clienthost)) return (EACCES); return (0); } /* Cns_srv_chclass - change class on directory */ int Cns_srv_chclass(int magic,char *req_data,char *clienthost,struct Cns_srv_thread_info *thip) { char basename[CA_MAXNAMELEN+1]; char class_name[CA_MAXCLASNAMELEN+1]; int classid; u_signed64 cwd; struct Cns_file_metadata fmd_entry; char func[16]; gid_t gid; char logbuf[CA_MAXPATHLEN+CA_MAXCLASNAMELEN+16]; struct Cns_class_metadata new_class_entry; Cns_dbrec_addr new_rec_addrc; struct Cns_class_metadata old_class_entry; Cns_dbrec_addr old_rec_addrc; struct Cns_file_metadata parent_dir; char path[CA_MAXPATHLEN+1]; char *rbp; Cns_dbrec_addr rec_addr; uid_t uid; strcpy (func, "Cns_srv_chclass"); rbp = req_data; unmarshall_LONG (rbp, uid); unmarshall_LONG (rbp, gid); nslogit (func, NS092, "chclass", uid, gid, clienthost); unmarshall_HYPER (rbp, cwd); if (unmarshall_STRINGN (rbp, path, CA_MAXPATHLEN+1)) return (SENAMETOOLONG); unmarshall_LONG (rbp, classid); if (unmarshall_STRINGN (rbp, class_name, CA_MAXCLASNAMELEN+1)) return (EINVAL); sprintf (logbuf, "chclass %s %d %s", path, classid, class_name); Cns_logreq (func, logbuf); if (Cns_splitname (cwd, path, basename)) return (serrno); if (*basename == '/') { /* Cns_chclass / */ parent_dir.fileid = 0; } else { /* check parent directory components for search permission */ if (Cns_chkdirperm (&thip->dbfd, cwd, path, S_IEXEC, uid, gid, clienthost, &parent_dir, NULL)) return (serrno); } /* start transaction */ (void) Cns_start_tr (thip->s, &thip->dbfd); /* is the class valid? */ if (classid > 0) { if (Cns_get_class_by_id (&thip->dbfd, classid, &new_class_entry, 1, &new_rec_addrc)) if (serrno == ENOENT) { sendrep (thip->s, MSG_ERR, "No such class\n"); return (EINVAL); } else return (serrno); if (*class_name && strcmp (class_name, new_class_entry.name)) return (EINVAL); } else { if (Cns_get_class_by_name (&thip->dbfd, class_name, &new_class_entry, 1, &new_rec_addrc)) if (serrno == ENOENT) { sendrep (thip->s, MSG_ERR, "No such class\n"); return (EINVAL); } else return (serrno); } /* get/lock basename entry */ if (Cns_get_fmd_by_fullid (&thip->dbfd, parent_dir.fileid, basename, &fmd_entry, 1, &rec_addr)) return (serrno); /* check if the user is authorized to chclass this entry */ if (uid != fmd_entry.uid && Cupv_check (uid, gid, clienthost, localhost, P_ADMIN)) return (EPERM); if ((fmd_entry.filemode & S_IFDIR) == 0) return (ENOTDIR); /* update entries */ if (fmd_entry.fileclass != new_class_entry.classid) { if (fmd_entry.fileclass > 0) { if (Cns_get_class_by_id (&thip->dbfd, fmd_entr