![[BACK]](/cvsweb/icons/back.gif){kind=icon}
Return to smbfile.c CVS log ![[TXT]](/cvsweb/icons/text.gif){kind=icon}
![[DIR]](/cvsweb/icons/dir.gif){kind=icon}
Up to [Synchronet] / sbbs / smblib|
Return to smbfile.c CVS log | Up to [Synchronet] / sbbs / smblib |
1.1 root 1: /* smbfile.c */
2:
3: /* Synchronet message base (SMB) FILE stream I/O routines */
4:
5: /* $Id: smbfile.c,v 1.7 2004/12/29 04:27:06 rswindell Exp $ */
6:
7: /****************************************************************************
8: * @format.tab-size 4 (Plain Text/Source Code File Header) *
9: * @format.use-tabs true (see http://www.synchro.net/ptsc_hdr.html) *
10: * *
11: * Copyright 2004 Rob Swindell - http://www.synchro.net/copyright.html *
12: * *
13: * This library is free software; you can redistribute it and/or *
14: * modify it under the terms of the GNU Lesser General Public License *
15: * as published by the Free Software Foundation; either version 2 *
16: * of the License, or (at your option) any later version. *
17: * See the GNU Lesser General Public License for more details: lgpl.txt or *
18: * http://www.fsf.org/copyleft/lesser.html *
19: * *
20: * Anonymous FTP access to the most recent released source is available at *
21: * ftp://vert.synchro.net, ftp://cvs.synchro.net and ftp://ftp.synchro.net *
22: * *
23: * Anonymous CVS access to the development source and modification history *
24: * is available at cvs.synchro.net:/cvsroot/sbbs, example: *
25: * cvs -d :pserver:[email protected]:/cvsroot/sbbs login *
26: * (just hit return, no password is necessary) *
27: * cvs -d :pserver:[email protected]:/cvsroot/sbbs checkout src *
28: * *
29: * For Synchronet coding style and modification guidelines, see *
30: * http://www.synchro.net/source.html *
31: * *
32: * You are encouraged to submit any modifications (preferably in Unix diff *
33: * format) via e-mail to [email protected] *
34: * *
35: * Note: If this box doesn't appear square, then you need to fix your tabs. *
36: ****************************************************************************/
37:
38: #include "smblib.h"
39:
40: int SMBCALL smb_feof(FILE* fp)
41: {
42: return(feof(fp));
43: }
44:
45: int SMBCALL smb_ferror(FILE* fp)
46: {
47: return(ferror(fp));
48: }
49:
50: int SMBCALL smb_fflush(FILE* fp)
51: {
52: return(fflush(fp));
53: }
54:
55: int SMBCALL smb_fgetc(FILE* fp)
56: {
57: return(fgetc(fp));
58: }
59:
60: int SMBCALL smb_fputc(int ch, FILE* fp)
61: {
62: return(fputc(ch,fp));
63: }
64:
65: int SMBCALL smb_fseek(FILE* fp, long offset, int whence)
66: {
67: return(fseek(fp,offset,whence));
68: }
69:
70: long SMBCALL smb_ftell(FILE* fp)
71: {
72: return(ftell(fp));
73: }
74:
75: long SMBCALL smb_fgetlength(FILE* fp)
76: {
77: return(filelength(fileno(fp)));
78: }
79:
80: int SMBCALL smb_fsetlength(FILE* fp, long length)
81: {
82: return(chsize(fileno(fp),length));
83: }
84:
85: void SMBCALL smb_rewind(FILE* fp)
86: {
87: rewind(fp);
88: }
89:
90: void SMBCALL smb_clearerr(FILE* fp)
91: {
92: clearerr(fp);
93: }
94:
95: size_t SMBCALL smb_fread(smb_t* smb, void* buf, size_t bytes, FILE* fp)
96: {
97: size_t ret;
98: time_t start=0;
99:
100: while(1) {
101: if((ret=fread(buf,sizeof(char),bytes,fp))==bytes)
102: return(ret);
103: if(get_errno()!=EDEADLOCK)
104: return(ret);
105: if(!start)
106: start=time(NULL);
107: else
108: if(time(NULL)-start>=(time_t)smb->retry_time)
109: break;
110: SLEEP(smb->retry_delay);
111: }
112: return(ret);
113: }
114:
115: #if defined(__BORLANDC__)
116: #pragma argsused
117: #endif
118:
119: size_t SMBCALL smb_fwrite(smb_t* smb, const void* buf, size_t bytes, FILE* fp)
120: {
121: return(fwrite(buf,1,bytes,fp));
122: }
123:
124: /****************************************************************************/
125: /* Opens a non-shareable file (FILE*) associated with a message base */
126: /* Retrys for retry_time number of seconds */
127: /* Return 0 on success, non-zero otherwise */
128: /****************************************************************************/
129: int SMBCALL smb_open_fp(smb_t* smb, FILE** fp, int share)
130: {
131: int file;
132: char path[MAX_PATH+1];
133: char* ext;
134: time_t start=0;
135:
136: if(fp==&smb->shd_fp)
137: ext="shd";
138: else if(fp==&smb->sid_fp)
139: ext="sid";
140: else if(fp==&smb->sdt_fp)
141: ext="sdt";
142: else if(fp==&smb->sda_fp)
143: ext="sda";
144: else if(fp==&smb->sha_fp)
145: ext="sha";
146: else if(fp==&smb->hash_fp)
147: ext="hash";
148: else {
149: safe_snprintf(smb->last_error,sizeof(smb->last_error)
150: ,"opening %s: Illegal FILE* pointer argument: %p"
151: ,smb->file, fp);
152: return(SMB_ERR_OPEN);
153: }
154:
155: if(*fp!=NULL) /* Already open! */
156: return(SMB_SUCCESS);
157:
158: SAFEPRINTF2(path,"%s.%s",smb->file,ext);
159:
160: while(1) {
161: if((file=sopen(path,O_RDWR|O_CREAT|O_BINARY,share,S_IREAD|S_IWRITE))!=-1)
162: break;
163: if(get_errno()!=EACCES && get_errno()!=EAGAIN) {
164: safe_snprintf(smb->last_error,sizeof(smb->last_error)
165: ,"%d '%s' opening %s"
166: ,get_errno(),STRERROR(get_errno()),path);
167: return(SMB_ERR_OPEN);
168: }
169: if(!start)
170: start=time(NULL);
171: else
172: if(time(NULL)-start>=(time_t)smb->retry_time) {
173: safe_snprintf(smb->last_error,sizeof(smb->last_error)
174: ,"timeout opening %s (retry_time=%ld)"
175: ,path,smb->retry_time);
176: return(SMB_ERR_TIMEOUT);
177: }
178: SLEEP(smb->retry_delay);
179: }
180: if((*fp=fdopen(file,"r+b"))==NULL) {
181: safe_snprintf(smb->last_error,sizeof(smb->last_error)
182: ,"%d '%s' fdopening %s (%d)"
183: ,get_errno(),STRERROR(get_errno()),path,file);
184: close(file);
185: return(SMB_ERR_OPEN);
186: }
187: setvbuf(*fp,NULL,_IOFBF,2*1024);
188: return(SMB_SUCCESS);
189: }
190:
191: /****************************************************************************/
192: /****************************************************************************/
193: void SMBCALL smb_close_fp(FILE** fp)
194: {
195: if(fp!=NULL) {
196: if(*fp!=NULL)
197: fclose(*fp);
198: *fp=NULL;
199: }
200: }
This archive runs on limited infrastructure. Preserving old code on modern bandwidth. Automated agents are requested to crawl responsibly.