![[BACK]](/icons/cvsweb/back.gif){kind=icon}
Return to ws_fileio.c CVS log ![[TXT]](/icons/cvsweb/text.gif){kind=icon}
![[DIR]](/icons/cvsweb/dir.gif){kind=icon}
Up to [local] / OpenXM_contrib2 / asir2000 / io|
Return to ws_fileio.c CVS log | Up to [local] / OpenXM_contrib2 / asir2000 / io |
1.1 ! noro 1: /* $OpenXM: OpenXM/src/asir99/io/ws_fileio.c,v 1.2 1999/11/19 10:41:08 noro Exp $ */
! 2: #if defined(VISUAL) || MPI
! 3: #include<stdio.h>
! 4: #include"wsio.h"
! 5:
! 6: STREAM* WSIO_open(int, char *);
! 7: int WSIO_read (char *, int, STREAM *);
! 8: int WSIO_write (char *, int, STREAM *);
! 9: int WSIO_flushbuf(STREAM *);
! 10: int WSIO_fillbuf(STREAM *);
! 11:
! 12: int cread (data, element_size, count, s)
! 13: char* data;
! 14: unsigned element_size;
! 15: int count;
! 16: STREAM* s;
! 17: {
! 18: int length,total,r;
! 19: char *p;
! 20:
! 21: if (!s || !s->read_flag || !data
! 22: || !element_size || !count)
! 23: return 0;
! 24:
! 25: length = element_size * count;
! 26:
! 27: total = length;
! 28: p = data;
! 29: while ( length > (r = s->buf_size - s->p) ) {
! 30: memcpy((void *)p,(void *)(s->buf+s->p),r);
! 31: s->p += r;
! 32: p += r;
! 33: length -= r;
! 34: if ( !WSIO_fillbuf(s) )
! 35: return (total-length)/ element_size;
! 36: }
! 37: memcpy((void *)p,(void *)(s->buf+s->p),length);
! 38: s->p += length;
! 39: return count;
! 40: }
! 41:
! 42: int cwrite (data, element_size, count, s)
! 43: char* data;
! 44: unsigned element_size;
! 45: int count;
! 46: STREAM* s;
! 47: {
! 48: int length,total,r;
! 49: char *p;
! 50:
! 51: if (!s || s->read_flag || !data
! 52: || !element_size || !count)
! 53: return 0;
! 54:
! 55: length = element_size * count;
! 56:
! 57: total = length;
! 58: p = data;
! 59: while ( length > (r = s->buf_size - s->p) ) {
! 60: memcpy((void *)(s->buf+s->p),(void *)p,r);
! 61: s->p += r;
! 62: p += r;
! 63: length -= r;
! 64: if ( !WSIO_flushbuf(s) )
! 65: return (total-length)/ element_size;
! 66: }
! 67: memcpy((void *)(s->buf+s->p),(void *)p,length);
! 68: s->p += length;
! 69: return count;
! 70: }
! 71:
! 72: int cflush(s)
! 73: STREAM* s;
! 74: {
! 75: if (!s || s->read_flag)
! 76: return EOF;
! 77:
! 78: if (!WSIO_flushbuf(s))
! 79: return EOF;
! 80: else
! 81: return 0;
! 82: }
! 83:
! 84: int WSIO_fillbuf(s)
! 85: STREAM* s;
! 86: {
! 87: s->buf_size = WSIO_read(s->buf, s->max_buf_size, s);
! 88: s->p = 0;
! 89:
! 90: return s->buf_size;
! 91: }
! 92:
! 93: int WSIO_flushbuf(s)
! 94: STREAM* s;
! 95: {
! 96: int rst;
! 97:
! 98:
! 99: rst = WSIO_write(s->buf, s->p, s);
! 100: s->p = 0;
! 101:
! 102: return rst;
! 103: }
! 104:
! 105: STREAM* WSIO_open(fildes, mode)
! 106: int fildes;
! 107: char* mode;
! 108: {
! 109: STREAM* rst = 0;
! 110: int flag = 0;
! 111:
! 112: rst = (STREAM*)malloc(sizeof(STREAM));
! 113: if (rst) {
! 114: #if defined(VISUAL)
! 115: _fileno(&rst->fp) = -1;
! 116: #elif MPI
! 117: #if defined(sparc)
! 118: (&rst->fp)->_file = -1;
! 119: #else
! 120: fileno(&rst->fp) = -1;
! 121: #endif
! 122: #endif
! 123: rst->fildes = fildes;
! 124:
! 125: if (mode[0] == 'r') {
! 126: rst->read_flag = 1;
! 127: rst->p = WSIO_STRING_LENGTH;
! 128: } else {
! 129: rst->read_flag = 0;
! 130: rst->p = 0;
! 131: }
! 132: rst->max_buf_size = rst->buf_size = WSIO_STRING_LENGTH;
! 133: rst->buf = (char*)malloc(WSIO_STRING_LENGTH);
! 134: if (!rst->buf) {
! 135: free (rst);
! 136: rst = 0;
! 137: }
! 138: rst->eof = 0;
! 139: rst->error = 0;
! 140: }
! 141: return rst;
! 142: }
! 143:
! 144: int WSIO_read (data, count, s)
! 145: char* data;
! 146: int count;
! 147: STREAM* s;
! 148: {
! 149: int size;
! 150:
! 151: if (!s)
! 152: return 0;
! 153:
! 154: #if defined(VISUAL)
! 155: size = recv(s->fildes,data,count,0);
! 156: #elif MPI
! 157: {
! 158: MPI_Status status;
! 159:
! 160: MPI_Recv(&size,1,MPI_INT,s->fildes,0,MPI_COMM_WORLD,&status);
! 161: if ( size > count )
! 162: size = count;
! 163: MPI_Recv(data,size,MPI_CHAR,s->fildes,0,MPI_COMM_WORLD,&status);
! 164: }
! 165: #endif
! 166: return size;
! 167: }
! 168:
! 169: int WSIO_write (data, count, s)
! 170: char* data;
! 171: int count;
! 172: STREAM* s;
! 173: {
! 174: int size;
! 175:
! 176: if (!s || !count)
! 177: return 0;
! 178:
! 179: #if defined(VISUAL)
! 180: size = send(s->fildes,data,count,0);
! 181: return size;
! 182: #elif MPI
! 183: MPI_Ssend(&count,1,MPI_INT,s->fildes,0,MPI_COMM_WORLD);
! 184: MPI_Ssend(data,count,MPI_CHAR,s->fildes,0,MPI_COMM_WORLD);
! 185: return count;
! 186: #endif
! 187: }
! 188:
! 189: #if MPI
! 190: int mpi_nprocs,mpi_myid;
! 191:
! 192: void mpi_init()
! 193: {
! 194: int argc;
! 195: char *argv[1];
! 196:
! 197: argc = 0; argv[0] = 0;
! 198: MPI_Init(&argc,&argv);
! 199: MPI_Comm_size(MPI_COMM_WORLD,&mpi_nprocs);
! 200: MPI_Comm_rank(MPI_COMM_WORLD,&mpi_myid);
! 201: }
! 202:
! 203: void mpi_finalize()
! 204: {
! 205: MPI_Finalize();
! 206: }
! 207: #endif
! 208: #endif