Annotation of OpenXM/src/kan96xx/plugin/file2.c, Revision 1.1
1.1 ! maekawa 1: #include <stdio.h>
! 2: #include <sys/time.h>
! 3: #include <sys/types.h>
! 4: #include <unistd.h>
! 5: #include "file2.h"
! 6:
! 7: #ifdef KXX
! 8: #define GC_malloc(n) malloc(n)
! 9: #else
! 10: void *GC_malloc(int size);
! 11: #endif
! 12:
! 13: /* Note: 1997, 12/6 cf. SS475/kxx/openxxx.tex, SS475/memo1.txt
! 14: The functions in file2.c should not accept interruptions
! 15: during its critical operations. The synchronization mechanism
! 16: has not yet been implemented.
! 17: */
! 18:
! 19: static int debug1 = 0;
! 20: static int checkfp2(FILE2 *fp2,char *s);
! 21: static int checkfp2(FILE2 *fp2,char *s)
! 22: {
! 23: if (fp2 == NULL) {
! 24: fprintf(stderr,"%s: NULL pointer.\n",s);
! 25: return(-1);
! 26: }
! 27: if (fp2->initialized != 1) {
! 28: fprintf(stderr,"%s: fp is not initialized.\n",s);
! 29: return(-1);
! 30: }
! 31: return(0);
! 32: }
! 33:
! 34: FILE2 *fp2open(int fd) {
! 35: FILE2 *fp2;
! 36: if (debug1) {
! 37: printf("fp2open is called. \n");
! 38: }
! 39: fp2 = (FILE2 *) GC_malloc(sizeof(FILE2));
! 40: if (fd < 0) {
! 41: fprintf(stderr,"fp2open Invalid file descriptor %d\n",fd);
! 42: return(NULL);
! 43: }
! 44: if (fp2 == NULL) {
! 45: fprintf(stderr,"fp2open. No memory.\n");
! 46: return(NULL);
! 47: }
! 48: fp2->fd = fd;
! 49: fp2->initialized = 1;
! 50: checkfp2(fp2,"fp2open ");
! 51: fp2->readpos = 0;
! 52: fp2->readsize = 0;
! 53: fp2->writepos = 0;
! 54: fp2->limit = FILE2BSIZE;
! 55: fp2->watch = 0;
! 56: fp2->watchFile = NULL;
! 57: fp2->mathcapList = NULL;
! 58: return(fp2);
! 59: }
! 60:
! 61:
! 62: int fp2fflush(FILE2 *fp2) {
! 63: int r;
! 64: if (debug1) {
! 65: printf("fp2fflush is called with FILE2 *%x.\n", (int )fp2);
! 66: fp2dumpBuffer(fp2);
! 67: printf("--------------------------\n");
! 68: }
! 69: if (checkfp2(fp2,"fp2fflush ") == -1) return(-1);
! 70: if (fp2->writepos > 0) {
! 71: r = write(fp2->fd,fp2->writeBuf,fp2->writepos);
! 72: fp2->writepos = 0;
! 73: if (r <= 0) {
! 74: fprintf(stderr,"fp2fflush(): write failed on %d.\n",fp2->fd);
! 75: }
! 76: return(r);
! 77: }else{
! 78: return(0);
! 79: }
! 80: }
! 81:
! 82: int fp2fclose(FILE2 *fp2) {
! 83: int r;
! 84: if (checkfp2(fp2," fp2fclose ") == -1) return(-1);
! 85: r = fp2fflush(fp2);
! 86: if (r < 0) {
! 87: fprintf(stderr,"fp2fclose: flush error.\n");
! 88: return(-1);
! 89: }
! 90: return(close(fp2->fd));
! 91: }
! 92:
! 93: int fp2fputc(int c,FILE2 *fp2) {
! 94: if (debug1) {
! 95: printf("fp2fputc is called with %2x, fp2->writepos=%d, ",c,fp2->writepos);
! 96: printf("fp2 = %x.\n",(int) fp2);
! 97: }
! 98: if (fp2->watch) {
! 99: if (c >= ' ' && c <='z') {
! 100: fprintf(fp2->watchFile," %2x(%c)-> ",c,c);
! 101: }else{
! 102: fprintf(fp2->watchFile," %2x( )-> ",c);
! 103: }
! 104: fflush(NULL);
! 105: }
! 106: if (checkfp2(fp2," fp2fputc ") == -1) return(-1);
! 107: (fp2->writeBuf)[fp2->writepos] = c;
! 108: (fp2->writepos)++;
! 109: if (fp2->writepos < fp2->limit) {
! 110: return(c);
! 111: }else{
! 112: if (fp2fflush(fp2) <0) return(-1);
! 113: else return(c);
! 114: }
! 115: }
! 116:
! 117: int fp2fgetc(FILE2 *fp2) {
! 118: int c;
! 119: /* printf("fp2fgetc is called. "); fflush(NULL); */
! 120: if (checkfp2(fp2," fp2fgetc ") == -1) return(-1);
! 121: if (fp2->readpos < fp2->readsize) {
! 122: fp2->readpos++;
! 123: c = fp2->readBuf[fp2->readpos -1];
! 124: if (fp2->watch) {
! 125: if (c >= ' ' && c <= 'z') {
! 126: fprintf(fp2->watchFile," %2x(%c) ",c,c);
! 127: }else{
! 128: fprintf(fp2->watchFile," %2x( ) ",c);
! 129: }
! 130: fflush(NULL);
! 131: }
! 132: return(c);
! 133: }else{
! 134: fp2->readpos = 0;
! 135: fp2 ->readsize =
! 136: read(fp2->fd, fp2->readBuf, fp2->limit);
! 137: if (fp2->readsize == 0) {
! 138: if (fp2->watch) {
! 139: fprintf(fp2->watchFile," <%2x ",c);
! 140: fflush(NULL);
! 141: }
! 142: return(-1);
! 143: }
! 144: else {
! 145: return(fp2fgetc(fp2));
! 146: }
! 147: }
! 148: }
! 149:
! 150: int fp2select(FILE2 *fp2, int t) {
! 151: if (fp2->readpos < fp2->readsize) return(1);
! 152: else {
! 153: #ifdef KXX
! 154: return(oxSocketSelect0(fp2->fd,t));
! 155: #else
! 156: return(KsocketSelect0(fp2->fd,t));
! 157: #endif
! 158: }
! 159: }
! 160:
! 161: int fp2dumpBuffer(FILE2 *fp2) {
! 162: int i;
! 163: if (checkfp2(fp2," f2pdumpBuf ") == -1) {
! 164: return(-1);
! 165: }
! 166: printf("fd=%d\n",fp2->fd);
! 167: printf("initialied=%d\n",fp2->initialized);
! 168: printf("readpos=%d\n",fp2->readpos);
! 169: printf("readsize=%d\n",fp2->readsize);
! 170: printf("writepos=%d\n",fp2->writepos);
! 171: printf("limit=%d\n",fp2->limit);
! 172: for (i=0; i<fp2->readsize; i++) {
! 173: printf("readBuf[%d]=%2x ",i,fp2->readBuf[i]);
! 174: }
! 175: for (i=0; i<fp2->writepos; i++) {
! 176: printf("writeBuf[%d]=%2x ",i,fp2->writeBuf[i]);
! 177: }
! 178: printf("\n");
! 179: return(0);
! 180: }
! 181:
! 182: int fp2clearReadBuf(FILE2 *fp2) {
! 183: fd_set readfds;
! 184: struct timeval timeout;
! 185: extern int errno;
! 186: int fd;
! 187: #define TMP00SIZE 2000
! 188: char tmp00[TMP00SIZE];
! 189: int n;
! 190:
! 191: if (checkfp2(fp2," fp2clearReadBuf ") == -1) {
! 192: return(-1);
! 193: }
! 194:
! 195: fp2->readsize=0; fp2->readpos = 0; /* Clear the buffer. */
! 196:
! 197: fd = fp2->fd;
! 198: while (1) {
! 199: FD_ZERO(&readfds);
! 200: FD_SET(fd,&readfds);
! 201: timeout.tv_sec = 0;
! 202: timeout.tv_usec = (long) 0;
! 203: fp2->readpos = fp2->readsize = 0;
! 204: if (select(fd+1,&readfds,(fd_set *)NULL,(fd_set *)NULL,&timeout)<0) {
! 205: fprintf(stderr,"fp2clearReadBuf: Select error. Error no is %d. See /usr/include/sys/errno.h.\n",errno);
! 206: return(-1);
! 207: }
! 208: if (FD_ISSET(fd,&readfds)) {
! 209: n = read(fd,tmp00, TMP00SIZE);
! 210: if (n <= 0) {
! 211: fprintf(stderr,"fp2clearReadBuf: File is closed or read error.\n");
! 212: return(-1);
! 213: }
! 214: if ( n < TMP00SIZE ) {
! 215: return(0);
! 216: }
! 217: }else {
! 218: return(0);
! 219: }
! 220: }
! 221: }
! 222: int fp2write(FILE2 *os, char *data, int size) {
! 223: int i,r;
! 224: for (i=0; i<size; i++) {
! 225: r = fp2fputc(data[i],os);
! 226: }
! 227: return(r);
! 228: }
! 229:
! 230: int fp2watch(FILE2 *fp2,FILE *f)
! 231: {
! 232: if (f == NULL) {
! 233: fprintf(stderr,"fp2watch FILE *f is NULL.\n");
! 234: return(-1);
! 235: }
! 236: if (fp2 == NULL) {
! 237: fprintf(stderr,"fp2watch FILE2 *fp2 is NULL.\n");
! 238: return(-1);
! 239: }
! 240: if (fp2->watch) {
! 241: fprintf(stderr,"fp2watch: fp2 is already taking a log.");
! 242: return(-1);
! 243: }
! 244: fp2->watch = 1;
! 245: fp2->watchFile = f;
! 246: return(0);
! 247: }
! 248:
! 249: int fp2stopWatch(FILE2 *fp2)
! 250: {
! 251: if (fp2 == NULL) {
! 252: fprintf(stderr,"fp2stopWatch FILE2 *fp2 is NULL.\n");
! 253: return(-1);
! 254: }
! 255: if (!fp2->watch) {
! 256: fprintf(stderr,"fp2stopWatch: fp2 is not taking a log.");
! 257: return(-1);
! 258: }
! 259: fp2->watch=0;
! 260: if (fp2->watchFile != stdout) {
! 261: return(fclose(fp2->watchFile));
! 262: }
! 263: }
! 264:
FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>
![[BACK]](/icons/cvsweb/back.gif){kind=icon}
Return to file2.c CVS log ![[TXT]](/icons/cvsweb/text.gif){kind=icon}
![[DIR]](/icons/cvsweb/dir.gif){kind=icon}
Up to [local] / OpenXM / src / kan96xx / plugin