chirp_types.h

Go to the documentation of this file.

/*
Copyright (C) 2003-2004 Douglas Thain and the University of Wisconsin
Copyright (C) 2005- The University of Notre Dame
This software is distributed under the GNU General Public License.
See the file COPYING for details.
*/

#ifndef CHIRP_TYPES_H
#define CHIRP_TYPES_H

#include "chirp_protocol.h"

#include "buffer.h"
#include "int_sizes.h"

#include <fcntl.h>
#include <sys/types.h>

#include <inttypes.h>
#include <stdint.h>
#include <time.h>

struct chirp_stat {
        INT64_T cst_dev;        
        INT64_T cst_ino;        
        INT64_T cst_mode;       
        INT64_T cst_nlink;      
        INT64_T cst_uid;        
        INT64_T cst_gid;        
        INT64_T cst_rdev;       
        INT64_T cst_size;       
        INT64_T cst_blksize;    
        INT64_T cst_blocks;     
        INT64_T cst_atime;      
        INT64_T cst_mtime;      
        INT64_T cst_ctime;      
};

#define chirp_stat_encode(B, info) \
        do {\
                buffer_putfstring(B, "%" PRId64, (info)->cst_dev);\
                buffer_putfstring(B, " %" PRId64, (info)->cst_ino);\
                buffer_putfstring(B, " %" PRId64, (info)->cst_mode);\
                buffer_putfstring(B, " %" PRId64, (info)->cst_nlink);\
                buffer_putfstring(B, " %" PRId64, (info)->cst_uid);\
                buffer_putfstring(B, " %" PRId64, (info)->cst_gid);\
                buffer_putfstring(B, " %" PRId64, (info)->cst_rdev);\
                buffer_putfstring(B, " %" PRId64, (info)->cst_size);\
                buffer_putfstring(B, " %" PRId64, (info)->cst_blksize);\
                buffer_putfstring(B, " %" PRId64, (info)->cst_blocks);\
                buffer_putfstring(B, " %" PRId64, (info)->cst_atime);\
                buffer_putfstring(B, " %" PRId64, (info)->cst_mtime);\
                buffer_putfstring(B, " %" PRId64, (info)->cst_ctime);\
        } while (0)


struct chirp_statfs {
        INT64_T f_type;         
        INT64_T f_blocks;       
        INT64_T f_bavail;       
        INT64_T f_bsize;        
        INT64_T f_bfree;        
        INT64_T f_files;        
        INT64_T f_ffree;        
};

#define chirp_statfs_encode(B, info) \
        do {\
                buffer_putfstring(B, "%" PRId64, (info)->f_type);\
                buffer_putfstring(B, " %" PRId64, (info)->f_bsize);\
                buffer_putfstring(B, " %" PRId64, (info)->f_blocks);\
                buffer_putfstring(B, " %" PRId64, (info)->f_bfree);\
                buffer_putfstring(B, " %" PRId64, (info)->f_bavail);\
                buffer_putfstring(B, " %" PRId64, (info)->f_files);\
                buffer_putfstring(B, " %" PRId64, (info)->f_ffree);\
        } while (0)

struct chirp_dirent {
        char *name;                     
        int lstatus;            
        struct chirp_stat info;         
        struct chirp_dirent *next;
};

struct chirp_searchent {
        char path[CHIRP_PATH_MAX];                      
        struct chirp_stat info; 
        int errsource;
        int err;
};

struct chirp_searchstream {
        struct chirp_searchent entry;
        const char *current;
        buffer_t B;
};

#define CHIRP_SEARCH struct chirp_searchstream

#define CHIRP_SEARCH_STOPATFIRST (1<<0)
#define CHIRP_SEARCH_METADATA    (1<<1)
#define CHIRP_SEARCH_INCLUDEROOT (1<<2)
#define CHIRP_SEARCH_PERIOD      (1<<3)
#define CHIRP_SEARCH_R_OK        (1<<4)
#define CHIRP_SEARCH_W_OK        (1<<5)
#define CHIRP_SEARCH_X_OK        (1<<6)

#define CHIRP_SEARCH_ERR_OPEN    1
#define CHIRP_SEARCH_ERR_READ    2
#define CHIRP_SEARCH_ERR_CLOSE   3
#define CHIRP_SEARCH_ERR_STAT    4

#define CHIRP_SEARCH_DELIMITER   '|'
#define CHIRP_SEARCH_DEPTH_MAX   200

typedef enum {
        CHIRP_BULKIO_PREAD,  
        CHIRP_BULKIO_PWRITE, 
        CHIRP_BULKIO_SREAD,  
        CHIRP_BULKIO_SWRITE, 
        CHIRP_BULKIO_FSTAT,  
        CHIRP_BULKIO_FSYNC   
} chirp_bulkio_t;

struct chirp_bulkio {
        chirp_bulkio_t type;       
        struct chirp_file *file;   
        struct chirp_stat *info;   
        void *buffer;              
        INT64_T length;            
        INT64_T stride_length;     
        INT64_T stride_skip;       
        INT64_T offset;            
        INT64_T result;            
        INT64_T errnum;            
};

struct chirp_audit {
        char name[CHIRP_PATH_MAX];      
        INT64_T nfiles;                 
        INT64_T ndirs;                  
        INT64_T nbytes;                 
};

typedef void (*chirp_dir_t) (const char *path, void *arg);

typedef void (*chirp_longdir_t) (const char *path, struct chirp_stat * info, void *arg);

typedef void (*chirp_loc_t) (const char *location, void *arg);


typedef int64_t chirp_jobid_t;
#define PRICHIRP_JOBID_T  PRId64
#define SCNCHIRP_JOBID_T  SCNd64

#define CHIRP_DIGEST_MAX 128

#endif

/* vim: set noexpandtab tabstop=4: */