fivedev/harbour-core
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity
Files
7a80cb71e671b13bb5e891d1d02bfe8fb6f11b48
harbour-core/harbour/src/rtl/filebuf.c
Viktor Szakats 393cafddb8 2010-06-03 16:54 UTC+0200 Viktor Szakats (harbour.01 syenar.hu) 
* src/lang/msghuiso.c
  * src/lang/msgskiso.c
  * src/lang/msgrukoi.c
  * src/lang/msgzhgb.c
  * src/lang/msghuwin.c
  * src/lang/msgskwin.c
  * src/lang/msg_tpl.c
  * src/lang/msgruwin.c
  * src/lang/msghr646.c
  * src/lang/msgsl646.c
  * src/lang/msgelwin.c
  * src/lang/msgro.c
  * src/lang/msgpt.c
  * src/lang/msghriso.c
  * src/lang/msghrwin.c
  * src/lang/msgsliso.c
  * src/lang/msgslwin.c
  * src/lang/msghe862.c
  * src/lang/msgcskam.c
  * src/lang/msggl.c
  * src/lang/msgtrwin.c
  * src/lang/msgbgiso.c
  * src/lang/msgeo.c
  * src/lang/msgskkam.c
  * src/lang/msgbgwin.c
  * src/lang/msges.c
  * src/lang/msgzhb5.c
  * src/lang/msgeu.c
  * src/lang/msgpl852.c
  * src/lang/msgsr852.c
  * src/lang/msgde.c
  * src/lang/msgtr857.c
  * src/lang/msgru866.c
  * src/lang/msgcs852.c
  * src/lang/msgfr.c
  * src/lang/msgis850.c
  * src/lang/msgnl.c
  * src/lang/msghu852.c
  * src/lang/msgsk852.c
  * src/lang/msgca.c
  * src/lang/msgplmaz.c
  * src/lang/msgpliso.c
  * src/lang/msgplwin.c
  * src/lang/msgbg866.c
  * src/lang/msgid.c
  * src/lang/msgltwin.c
  * src/lang/msgptiso.c
  * src/lang/msgsriso.c
  * src/lang/msgel.c
  * src/lang/msgdewin.c
  * src/lang/msghr852.c
  * src/lang/msgko.c
  * src/lang/msghewin.c
  * src/lang/msgit.c
  * src/lang/msgsl852.c
  * src/lang/msghucwi.c
  * src/lang/msgcsiso.c
  * src/lang/msgcswin.c
  * src/lang/msgeswin.c
  * src/vm/initsymb.c
  * src/vm/hashfunc.c
  * src/vm/macro.c
  * src/vm/evalhb.c
  * src/vm/mainwin.c
  * src/vm/strapi.c
  * src/vm/harbinit.prg
  * src/vm/pcount.c
  * src/vm/runner.c
  * src/vm/estack.c
  * src/vm/codebloc.c
  * src/vm/hashes.c
  * src/vm/maindllp/dllpcode.c
  * src/vm/maindllp/dllext.c
  * src/vm/dynsym.c
  * src/vm/debug.c
  * src/vm/maindllh.c
  * src/vm/itemapi.c
  * src/vm/garbage.c
  * src/vm/asort.c
  * src/vm/hvm.c
  * src/vm/pvalue.c
  * src/vm/cmdarg.c
  * src/vm/procaddr.c
  * src/vm/mainstd.c
  * src/vm/arrays.c
  * src/vm/task.c
  * src/vm/fm.c
  * src/vm/extrap.c
  * src/vm/proc.c
  * src/vm/thread.c
  * src/vm/memvars.c
  * src/vm/arrayshb.c
  * src/vm/memvclip.c
  * src/vm/vm.c
  * src/vm/hvmall.c
  * src/vm/main.c
  * src/vm/break.c
  * src/vm/eval.c
  * src/vm/extend.c
  * src/vm/dynlibhb.c
  * src/vm/set.c
  * src/vm/initexit.c
  * src/vm/classes.c
  * src/rtl/lennum.c
  * src/rtl/scroll.c
  * src/rtl/gtdos/gtdos.c
  * src/rtl/strxor.c
  * src/rtl/setposbs.c
  * src/rtl/fscopy.c
  * src/rtl/strcase.c
  * src/rtl/run.c
  * src/rtl/gtwin/gtwin.c
  * src/rtl/defpath.c
  * src/rtl/gtxwc/gtxwc.h
  * src/rtl/gtxwc/gtxwc.c
  * src/rtl/tscalars.c
  * src/rtl/hbdynhb.c
  * src/rtl/substr.c
  * src/rtl/round.c
  * src/rtl/oldbox.c
  * src/rtl/typefile.prg
  * src/rtl/tbcolumn.prg
  * src/rtl/math.c
  * src/rtl/getsys53.prg
  * src/rtl/objfunc.prg
  * src/rtl/empty.c
  * src/rtl/tobject.prg
  * src/rtl/gtcrs/gtcrs.h
  * src/rtl/hbzlibgz.c
  * src/rtl/trim.c
  * src/rtl/setpos.c
  * src/rtl/fnsplit.c
  * src/rtl/gtfunc.c
  * src/rtl/base64c.c
  * src/rtl/binnum.c
  * src/rtl/box.c
  * src/rtl/filehb.c
  * src/rtl/hbtoken.c
  * src/rtl/tscalard.c
  * src/rtl/fstemp.c
  * src/rtl/gtchrmap.c
  * src/rtl/tscalarl.c
  * src/rtl/tscalart.c
  * src/rtl/radiobhb.prg
  * src/rtl/type.c
  * src/rtl/tgethb.prg
  * src/rtl/strmatch.c
  * src/rtl/ampm.c
  * src/rtl/base64.prg
  * src/rtl/readkey.prg
  * src/rtl/hbsha1hm.c
  * src/rtl/errsys.prg
  * src/rtl/tpopup.prg
  * src/rtl/do.c
  * src/rtl/einstvau.prg
  * src/rtl/gtstd/gtstd.c
  * src/rtl/descend.c
  * src/rtl/gttrm/gttrm.c
  * src/rtl/maxrow.c
  * src/rtl/replic.c
  * src/rtl/xhelp.c
  * src/rtl/setta.prg
  * src/rtl/padr.c
  * src/rtl/hbstrfmt.c
  * src/rtl/listbox.prg
  * src/rtl/transfrm.c
  * src/rtl/hbntos.c
  * src/rtl/gttone.c
  * src/rtl/hbadler.c
  * src/rtl/at.c
  * src/rtl/hbdyn.c
  * src/rtl/tone.c
  * src/rtl/browse.prg
  * src/rtl/tget.prg
  * src/rtl/setfunc.prg
  * src/rtl/tscalaru.c
  * src/rtl/datec.c
  * src/rtl/pushbtn.prg
  * src/rtl/minmax.c
  * src/rtl/hbfeof.c
  * src/rtl/readvar.prg
  * src/rtl/hbmd5.c
  * src/rtl/dates.c
  * src/rtl/achoice.prg
  * src/rtl/hbascii.c
  * src/rtl/fkmax.c
  * src/rtl/padc.c
  * src/rtl/strzero.c
  * src/rtl/memvarbl.prg
  * src/rtl/gtcgi/gtcgi.c
  * src/rtl/natmsgu.c
  * src/rtl/mod.c
  * src/rtl/errapi.c
  * src/rtl/version.c
  * src/rtl/hbregexc.c
  * src/rtl/hbrandom.c
  * src/rtl/strtran.c
  * src/rtl/tscalar.prg
  * src/rtl/hbprocfn.c
  * src/rtl/hbsocket.c
  * src/rtl/errint.c
  * src/rtl/treport.prg
  * src/rtl/tscalarn.c
  * src/rtl/errapiu.c
  * src/rtl/hbinet.c
  * src/rtl/copyfile.c
  * src/rtl/gt.c
  * src/rtl/tpersist.prg
  * src/rtl/tgetint.prg
  * src/rtl/strtoexp.c
  * src/rtl/hbsha2hm.c
  * src/rtl/errintlo.c
  * src/rtl/dbedit.prg
  * src/rtl/einstvar.prg
  * src/rtl/gtapi.c
  * src/rtl/pad.c
  * src/rtl/direct.c
  * src/rtl/filesys.c
  * src/rtl/len.c
  * src/rtl/padl.c
  * src/rtl/lang.c
  * src/rtl/hbregex.c
  * src/rtl/einstv52.prg
  * src/rtl/hbbit.c
  * src/rtl/isprint.c
  * src/rtl/altd.prg
  * src/rtl/text.prg
  * src/rtl/saverest.c
  * src/rtl/diskspac.c
  * src/rtl/console.c
  * src/rtl/mousehb.c
  * src/rtl/hbinetz.c
  * src/rtl/chrasc.c
  * src/rtl/spfiles.c
  * src/rtl/dircmd.prg
  * src/rtl/memoedit.prg
  * src/rtl/gtos2/gtos2.c
  * src/rtl/right.c
  * src/rtl/hbi18n2.prg
  * src/rtl/philes.c
  * src/rtl/adir.prg
  * src/rtl/oldclear.c
  * src/rtl/hbbffnc.c
  * src/rtl/gui.prg
  * src/rtl/perfuncs.prg
  * src/rtl/hbgtcore.c
  * src/rtl/cdpapi.c
  * src/rtl/cputime.c
  * src/rtl/fieldbl.prg
  * src/rtl/dirdrive.c
  * src/rtl/str.c
  * src/rtl/wait.prg
  * src/rtl/hbi18n1.c
  * src/rtl/dateshb.c
  * src/rtl/menuto.prg
  * src/rtl/gtclip.c
  * src/rtl/mlcfunc.c
  * src/rtl/datesx.c
  * src/rtl/scrollbr.prg
  * src/rtl/hbfile.c
  * src/rtl/gtapiu.c
  * src/rtl/left.c
  * src/rtl/accept.c
  * src/rtl/defpathu.c
  * src/rtl/tscalarh.c
  * src/rtl/tbrowsys.prg
  * src/rtl/valtoexp.prg
  * src/rtl/tscalarp.c
  * src/rtl/is.c
  * src/rtl/idle.c
  * src/rtl/itemseri.c
  * src/rtl/getsys.prg
  * src/rtl/hbrunfun.c
  * src/rtl/setcolor.c
  * src/rtl/oemansi.c
  * src/rtl/philes53.c
  * src/rtl/xsavescr.c
  * src/rtl/hardcr.c
  * src/rtl/setkey.c
  * src/rtl/tgetlist.prg
  * src/rtl/gtsln/keytrans.c
  * src/rtl/gtsln/mousesln.c
  * src/rtl/gtsln/gtsln.c
  * src/rtl/gtsln/kbsln.c
  * src/rtl/gtsln/gtsln.h
  * src/rtl/disksphb.c
  * src/rtl/memvarhb.prg
  * src/rtl/tlabel.prg
  * src/rtl/hbzlib.c
  * src/rtl/strc.c
  * src/rtl/gtpca/gtpca.c
  * src/rtl/radiogrp.prg
  * src/rtl/scrrow.c
  * src/rtl/getlist.prg
  * src/rtl/valtype.c
  * src/rtl/shadow.c
  * src/rtl/net.c
  * src/rtl/stuff.c
  * src/rtl/dirscan.prg
  * src/rtl/hbznet.c
  * src/rtl/tscalara.c
  * src/rtl/space.c
  * src/rtl/checkbox.prg
  * src/rtl/gtgui/gtgui.c
  * src/rtl/hbhex.c
  * src/rtl/seconds.c
  * src/rtl/trace.c
  * src/rtl/samples.c
  * src/rtl/abs.c
  * src/rtl/input.prg
  * src/rtl/hbsha1.c
  * src/rtl/gt_tpl/gt_tpl.c
  * src/rtl/inkeyapi.c
  * src/rtl/filebuf.c
  * src/rtl/alert.prg
  * src/rtl/inkey.c
  * src/rtl/ttopbar.prg
  * src/rtl/mtran.c
  * src/rtl/gete.c
  * src/rtl/browdb.prg
  * src/rtl/setcurs.c
  * src/rtl/tmenusys.prg
  * src/rtl/tsymbol.prg
  * src/rtl/tclass.prg
  * src/rtl/hbproces.c
  * src/rtl/menusys.prg
  * src/rtl/cdpapihb.c
  * src/rtl/word.c
  * src/rtl/langapi.c
  * src/rtl/fmhb.c
  * src/rtl/ttextlin.prg
  * src/rtl/natmsg.c
  * src/rtl/gtwvt/gtwvt.h
  * src/rtl/gtwvt/gtwvt.c
  * src/rtl/tscalarb.c
  * src/rtl/mouse53.c
  * src/rtl/fssize.c
  * src/rtl/hbbfish.c
  * src/rtl/hbsha2.c
  * src/rtl/colorind.c
  * src/rtl/hbbyte.c
  * src/rtl/ati.c
  * src/rtl/gx.c
  * src/rtl/teditor.prg
  * src/rtl/mouseapi.c
  * src/rtl/soundex.c
  * src/rtl/memofile.c
  * src/rtl/getsyshb.prg
  * src/rtl/radiobtn.prg
  * src/rtl/tmenuitm.prg
  * src/rtl/gtsys.c
  * src/rtl/shadowu.c
  * src/rtl/hbstrsh.c
  * src/rtl/valtostr.c
  * src/rtl/file.c
  * src/rtl/strclear.c
  * src/rtl/val.c
  * src/rtl/gtkbstat.c
  * src/rtl/rat.c
  * src/rtl/hbcom.c
  * src/rtl/tbrowse.prg
  * src/rtl/tscalarc.c
  * src/rtl/devoutp.prg
  * src/codepage/ucmacce.c
  * src/codepage/cpno865.c
  * src/codepage/uckoi8.c
  * src/codepage/cppt850.c
  * src/codepage/uc885910.c
  * src/codepage/cpit850m.c
  * src/codepage/ucmacice.c
  * src/codepage/uc885914.c
  * src/codepage/uc874.c
  * src/codepage/uc857.c
  * src/codepage/cpru866.c
  * src/codepage/uc1250.c
  * src/codepage/uc1254.c
  * src/codepage/cpeswinm.c
  * src/codepage/cpcs852.c
  * src/codepage/cpes850.c
  * src/codepage/uc1258.c
  * src/codepage/cpis850.c
  * src/codepage/cphu852.c
  * src/codepage/cpsk852.c
  * src/codepage/uckam.c
  * src/codepage/cphu852c.c
  * src/codepage/uc424.c
  * src/codepage/ucmacrom.c
  * src/codepage/cpplmaz.c
  * src/codepage/uc862.c
  * src/codepage/cppliso.c
  * src/codepage/uc866.c
  * src/codepage/cpplwin.c
  * src/codepage/cpbg866.c
  * src/codepage/cpltwin.c
  * src/codepage/cpptiso.c
  * src/codepage/cpel737.c
  * src/codepage/cpsrwin.c
  * src/codepage/uc8859_3.c
  * src/codepage/cpfr850.c
  * src/codepage/cpes850c.c
  * src/codepage/cphr852.c
  * src/codepage/uc8859_7.c
  * src/codepage/ucmacgrk.c
  * src/codepage/uc037.c
  * src/codepage/uc850.c
  * src/codepage/cpesiso.c
  * src/codepage/uc885911.c
  * src/codepage/cpeswin.c
  * src/codepage/uc885915.c
  * src/codepage/uc875.c
  * src/codepage/cprukoi.c
  * src/codepage/uc1251.c
  * src/codepage/uc1255.c
  * src/codepage/cpruiso.c
  * src/codepage/cpsv850m.c
  * src/codepage/cpde850m.c
  * src/codepage/cpruwin.c
  * src/codepage/cpsl646.c
  * src/codepage/cppt860.c
  * src/codepage/cpfriso.c
  * src/codepage/cpnl850m.c
  * src/codepage/uc863.c
  * src/codepage/cpfrwin.c
  * src/codepage/cpsliso.c
  * src/codepage/ucmaz.c
  * src/codepage/cpslwin.c
  * src/codepage/uc1026.c
  * src/codepage/cpcskam.c
  * src/codepage/cpbgiso.c
  * src/codepage/uc8859_4.c
  * src/codepage/cpnl850.c
  * src/codepage/cpbgwin.c
  * src/codepage/cpskkam.c
  * src/codepage/uc8859_8.c
  * src/codepage/cppl852.c
  * src/codepage/cpde850.c
  * src/codepage/cpsv850.c
  * src/codepage/uc855.c
  * src/codepage/cptr857.c
  * src/codepage/uc885916.c
  * src/codepage/cproiso.c
  * src/codepage/cpfi850.c
  * src/codepage/ucascii.c
  * src/codepage/cprowin.c
  * src/codepage/uc1252.c
  * src/codepage/uc1256.c
  * src/codepage/ucatari.c
  * src/codepage/cpitisb.c
  * src/codepage/uc860.c
  * src/codepage/ucmaccyr.c
  * src/codepage/uc864.c
  * src/codepage/uc1006.c
  * src/codepage/cpel437.c
  * src/codepage/uc8859_1.c
  * src/codepage/cpdeiso.c
  * src/codepage/cpsviso.c
  * src/codepage/uc88591b.c
  * src/codepage/cpdewin.c
  * src/codepage/cpsvwin.c
  * src/codepage/uc8859_5.c
  * src/codepage/cpit850.c
  * src/codepage/uc8859_9.c
  * src/codepage/cpis861.c
  * src/codepage/cpsl852.c
  * src/codepage/cpcsiso.c
  * src/codepage/cpes850m.c
  * src/codepage/ucnext.c
  * src/codepage/cpcswin.c
  * src/codepage/uc852.c
  * src/codepage/uc737.c
  * src/codepage/ucmactrk.c
  * src/codepage/uc885913.c
  * src/codepage/cphuiso.c
  * src/codepage/uc775.c
  * src/codepage/uc856.c
  * src/codepage/cpskiso.c
  * src/codepage/cphuwin.c
  * src/codepage/cpskwin.c
  * src/codepage/cp_tpl.c
  * src/codepage/uc1253.c
  * src/codepage/uc646_yu.c
  * src/codepage/uc1257.c
  * src/codepage/uc500.c
  * src/codepage/cphr646.c
  * src/codepage/cpeliso.c
  * src/codepage/cpelwin.c
  * src/codepage/cpro852.c
  * src/codepage/cpfr850m.c
  * src/codepage/uc861.c
  * src/codepage/cphriso.c
  * src/codepage/uc865.c
  * src/codepage/cphrwin.c
  * src/codepage/cpitiso.c
  * src/codepage/cpsv437c.c
  * src/codepage/cpitwin.c
  * src/codepage/uc869.c
  * src/codepage/cptriso.c
  * src/codepage/cpdk865.c
  * src/codepage/uc8859_2.c
  * src/codepage/cptrwin.c
  * src/codepage/uc8859_6.c
  * src/rdd/dbfntx/dbfntx1.c
  * src/rdd/dbfntx/dbfntx0.prg
  * src/rdd/dbsql.c
  * src/rdd/dbdelim.prg
  * src/rdd/hbdbsort.c
  * src/rdd/rddordu.prg
  * src/rdd/dbjoin.prg
  * src/rdd/workarea.c
  * src/rdd/dbnubs.c
  * src/rdd/wacore.c
  * src/rdd/rddinfo.c
  * src/rdd/dbstruxu.prg
  * src/rdd/dblist.prg
  * src/rdd/dbfuncs.prg
  * src/rdd/sdf1.c
  * src/rdd/dbdetach.c
  * src/rdd/dbtotal.prg
  * src/rdd/dbstrux.prg
  * src/rdd/dbsort.prg
  * src/rdd/dbfnsx/dbfnsx1.c
  * src/rdd/dbcmd.c
  * src/rdd/dbdrop.c
  * src/rdd/delim1.c
  * src/rdd/dbf1.c
  * src/rdd/dbrename.c
  * src/rdd/rddsys.prg
  * src/rdd/dbcmd53.c
  * src/rdd/usrrdd/usrrdd.c
  * src/rdd/usrrdd/rdds/arrayrdd.prg
  * src/rdd/usrrdd/rdds/dbtcdx.prg
  * src/rdd/usrrdd/rdds/fptcdx.prg
  * src/rdd/usrrdd/rdds/hscdx.prg
  * src/rdd/usrrdd/rdds/logrdd.prg
  * src/rdd/usrrdd/rdds/rlcdx.prg
  * src/rdd/usrrdd/rdds/smtcdx.prg
  * src/rdd/dbcmdhb.c
  * src/rdd/wafunc.c
  * src/rdd/rddord.prg
  * src/rdd/dbexists.c
  * src/rdd/dbsdf.prg
  * src/rdd/dbupdat.prg
  * src/rdd/ordwldsk.c
  * src/rdd/hbsix/sxord.c
  * src/rdd/hbsix/sxsem.c
  * src/rdd/hbsix/sxini.prg
  * src/rdd/hbsix/sxredir.c
  * src/rdd/hbsix/sxfname.c
  * src/rdd/hbsix/sxtable.c
  * src/rdd/hbsix/sxcompat.prg
  * src/rdd/hbsix/sxtrig.prg
  * src/rdd/hbsix/sxdate.c
  * src/rdd/hbsix/sxutil.c
  * src/rdd/hbsix/sxcompr.c
  * src/rdd/hbsix/sxcrypt.c
  * src/rdd/fieldhb.c
  * src/rdd/ordcount.c
    * Deleted 'www.' from harbour-project.org website name.
      (www.harbour-project.org -> harbour-project.org)
2010-06-03 15:09:04 +00:00

739 lines
20 KiB
C
Raw Blame History

/*
* $Id$
*/
/*
* Harbour Project source code:
* functions to access files with shared handles and locks
* (buffers in the future)
*
* Copyright 2008 Przemyslaw Czerpak <druzus / at / priv.onet.pl>
* www - http://harbour-project.org
*
* This program is free software; you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation; either version 2, or (at your option)
* any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this software; see the file COPYING. If not, write to
* the Free Software Foundation, Inc., 59 Temple Place, Suite 330,
* Boston, MA 02111-1307 USA (or visit the web site http://www.gnu.org/).
*
* As a special exception, the Harbour Project gives permission for
* additional uses of the text contained in its release of Harbour.
*
* The exception is that, if you link the Harbour libraries with other
* files to produce an executable, this does not by itself cause the
* resulting executable to be covered by the GNU General Public License.
* Your use of that executable is in no way restricted on account of
* linking the Harbour library code into it.
*
* This exception does not however invalidate any other reasons why
* the executable file might be covered by the GNU General Public License.
*
* This exception applies only to the code released by the Harbour
* Project under the name Harbour. If you copy code from other
* Harbour Project or Free Software Foundation releases into a copy of
* Harbour, as the General Public License permits, the exception does
* not apply to the code that you add in this way. To avoid misleading
* anyone as to the status of such modified files, you must delete
* this exception notice from them.
*
* If you write modifications of your own for Harbour, it is your choice
* whether to permit this exception to apply to your modifications.
* If you do not wish that, delete this exception notice.
*
*/
/* this has to be declared before hbapifs.h is included */
#define _HB_FILE_INTERNAL_
#include "hbapi.h"
#include "hbapifs.h"
#include "hbapierr.h"
#include "hbthread.h"
#include "hbvm.h"
#if !defined( HB_OS_WIN_CE )
# include <sys/types.h>
# include <sys/stat.h>
#endif
#define HB_FLOCK_RESIZE 16
typedef struct
{
HB_FOFFSET start;
HB_FOFFSET len;
}
HB_FLOCK, * PHB_FLOCK;
typedef struct _HB_FILE
{
const HB_FILE_FUNCS * pFuncs;
HB_ULONG device;
HB_ULONG inode;
int used;
HB_BOOL shared;
HB_BOOL readonly;
HB_FHANDLE hFile;
HB_FHANDLE hFileRO;
PHB_FLOCK pLocks;
HB_UINT uiLocks;
HB_UINT uiSize;
struct _HB_FILE * pNext;
struct _HB_FILE * pPrev;
}
HB_FILE;
static const HB_FILE_FUNCS * s_fileMethods( void );
static HB_CRITICAL_NEW( s_fileMtx );
static PHB_FILE s_openFiles = NULL;
/*
void hb_fileDsp( PHB_FILE pFile, const char * szMsg )
{
HB_UINT uiPos = 0;
fprintf( stderr, "\r\n[%s][", szMsg );
while( uiPos < pFile->uiLocks )
{
PHB_FLOCK pLock = &pFile->pLocks[ uiPos ];
fprintf( stderr, "%lld:%lld ", pLock->start, pLock->len );
++uiPos;
}
fprintf( stderr, "]" );
fflush(stderr);
}
*/
static PHB_FILE hb_fileFind( HB_ULONG device, HB_ULONG inode )
{
if( s_openFiles && ( device || inode ) )
{
PHB_FILE pFile = s_openFiles;
do
{
if( pFile->device == device && pFile->inode == inode )
return pFile;
pFile = pFile->pNext;
}
while( s_openFiles != pFile );
}
return NULL;
}
static PHB_FILE hb_fileNew( HB_FHANDLE hFile, HB_BOOL fShared, HB_BOOL fReadonly,
HB_ULONG device, HB_ULONG inode, HB_BOOL fBind )
{
PHB_FILE pFile = hb_fileFind( device, inode );
if( !pFile )
{
pFile = ( PHB_FILE ) hb_xgrab( sizeof( HB_FILE ) );
memset( pFile, 0, sizeof( HB_FILE ) );
pFile->pFuncs = s_fileMethods();
pFile->device = device;
pFile->inode = inode;
pFile->hFile = hFile;
pFile->hFileRO = FS_ERROR;
pFile->shared = fShared;
pFile->readonly = fReadonly;
if( fBind )
{
if( s_openFiles )
{
pFile->pNext = s_openFiles;
pFile->pPrev = s_openFiles->pPrev;
pFile->pPrev->pNext = pFile;
s_openFiles->pPrev = pFile;
}
else
s_openFiles = pFile->pNext = pFile->pPrev = pFile;
}
}
pFile->used++;
return pFile;
}
static HB_UINT hb_fileFindOffset( PHB_FILE pFile, HB_FOFFSET ulOffset )
{
HB_UINT uiFirst, uiLast, uiMiddle;
uiFirst = 0;
uiLast = pFile->uiLocks;
uiMiddle = uiLast >> 1;
while( uiFirst < uiLast )
{
HB_FOFFSET ulEnd = pFile->pLocks[ uiMiddle ].start +
pFile->pLocks[ uiMiddle ].len;
if( ulEnd <= ulOffset )
uiFirst = uiMiddle + 1;
else
uiLast = uiMiddle;
uiMiddle = ( uiFirst + uiLast ) >> 1;
}
return uiMiddle;
}
static void hb_fileInsertLock( PHB_FILE pFile, HB_UINT uiPos,
HB_FOFFSET ulStart, HB_FOFFSET ulLen )
{
if( pFile->uiLocks == pFile->uiSize )
{
pFile->uiSize += HB_FLOCK_RESIZE;
pFile->pLocks = ( PHB_FLOCK ) hb_xrealloc( pFile->pLocks,
sizeof( HB_FLOCK ) * pFile->uiSize );
memset( &pFile->pLocks[ pFile->uiLocks ], 0,
sizeof( HB_FLOCK ) * HB_FLOCK_RESIZE );
}
memmove( &pFile->pLocks[ uiPos + 1 ], &pFile->pLocks[ uiPos ],
( pFile->uiLocks - uiPos ) * sizeof( HB_FLOCK ) );
pFile->pLocks[ uiPos ].start = ulStart;
pFile->pLocks[ uiPos ].len = ulLen;
pFile->uiLocks++;
}
static void hb_fileDeleteLock( PHB_FILE pFile, HB_UINT uiPos )
{
pFile->uiLocks--;
memmove( &pFile->pLocks[ uiPos ], &pFile->pLocks[ uiPos + 1 ],
( pFile->uiLocks - uiPos ) * sizeof( HB_FLOCK ) );
if( pFile->uiSize - pFile->uiLocks >= ( HB_FLOCK_RESIZE << 1 ) )
{
pFile->uiSize -= HB_FLOCK_RESIZE;
pFile->pLocks = ( PHB_FLOCK ) hb_xrealloc( pFile->pLocks,
sizeof( HB_FLOCK ) * pFile->uiSize );
}
}
static HB_BOOL hb_fileSetLock( PHB_FILE pFile, HB_BOOL * pfLockFS,
HB_FOFFSET ulStart, HB_FOFFSET ulLen )
{
HB_BOOL fLJoin, fRJoin;
HB_UINT uiPos;
uiPos = hb_fileFindOffset( pFile, ulStart );
fLJoin = fRJoin = HB_FALSE;
if( uiPos < pFile->uiLocks )
{
PHB_FLOCK pLock = &pFile->pLocks[ uiPos ];
if( ulStart + ulLen > pLock->start )
return HB_FALSE;
if( ulStart + ulLen == pLock->start )
fRJoin = HB_TRUE;
}
if( uiPos > 0 )
{
PHB_FLOCK pLock = &pFile->pLocks[ uiPos - 1 ];
if( pLock->start + pLock->len == ulStart )
fLJoin = HB_TRUE;
}
if( fLJoin )
{
if( fRJoin )
{
pFile->pLocks[ uiPos - 1 ].len += ulLen + pFile->pLocks[ uiPos ].len;
hb_fileDeleteLock( pFile, uiPos );
}
else
pFile->pLocks[ uiPos - 1 ].len += ulLen;
}
else if( fRJoin )
{
pFile->pLocks[ uiPos ].start -= ulLen;
pFile->pLocks[ uiPos ].len += ulLen;
}
else
hb_fileInsertLock( pFile, uiPos, ulStart, ulLen );
if( pFile->shared )
* pfLockFS = HB_TRUE;
return HB_TRUE;
}
static HB_BOOL hb_fileUnlock( PHB_FILE pFile, HB_BOOL * pfLockFS,
HB_FOFFSET ulStart, HB_FOFFSET ulLen )
{
HB_BOOL fResult = HB_FALSE;
HB_UINT uiPos;
uiPos = hb_fileFindOffset( pFile, ulStart );
if( uiPos < pFile->uiLocks )
{
PHB_FLOCK pLock = &pFile->pLocks[ uiPos ];
if( ulStart >= pLock->start &&
ulStart + ulLen <= pLock->start + pLock->len )
{
if( ulStart == pLock->start )
{
if( ulLen == pLock->len )
hb_fileDeleteLock( pFile, uiPos );
else
{
pLock->start += ulLen;
pLock->len -= ulLen;
}
}
else if( ulStart + ulLen == pLock->start + pLock->len )
pLock->len -= ulLen;
else
{
hb_fileInsertLock( pFile, uiPos + 1, ulStart + ulLen,
pLock->start + pLock->len - ulStart - ulLen );
pLock->len = ulStart - pLock->start;
}
if( pFile->shared )
* pfLockFS = HB_TRUE;
fResult = HB_TRUE;
}
}
return fResult;
}
/*
* file methods
*/
static HB_BOOL s_fileAccept( const char * pFilename )
{
return pFilename && *pFilename;
}
static PHB_FILE s_fileExtOpen( const char * pFilename, const char * pDefExt,
HB_USHORT uiExFlags, const char * pPaths,
PHB_ITEM pError )
{
PHB_FILE pFile = NULL;
#if defined( HB_OS_UNIX )
struct stat statbuf;
HB_BOOL fResult;
#endif
HB_BOOL fShared, fReadonly;
HB_FHANDLE hFile;
char * pszFile;
fShared = ( uiExFlags & ( FO_DENYREAD | FO_DENYWRITE | FO_EXCLUSIVE ) ) == 0;
fReadonly = ( uiExFlags & ( FO_READ | FO_WRITE | FO_READWRITE ) ) == FO_READ;
pszFile = hb_fsExtName( pFilename, pDefExt, uiExFlags, pPaths );
#if defined( HB_OS_UNIX )
hb_vmUnlock();
fResult = stat( ( char * ) pszFile, &statbuf ) == 0;
hb_fsSetIOError( fResult, 0 );
hb_vmLock();
if( fResult )
{
hb_threadEnterCriticalSection( &s_fileMtx );
pFile = hb_fileFind( statbuf.st_dev, statbuf.st_ino );
if( pFile )
{
if( !fShared || ! pFile->shared || ( uiExFlags & FXO_TRUNCATE ) != 0 )
fResult = HB_FALSE;
else if( !fReadonly && pFile->readonly )
pFile = NULL;
else
pFile->used++;
}
hb_threadLeaveCriticalSection( &s_fileMtx );
}
if( pFile )
{
if( !fResult )
{
hb_fsSetError( ( uiExFlags & FXO_TRUNCATE ) ? 5 : 32 );
pFile = NULL;
}
else if( uiExFlags & FXO_COPYNAME )
hb_strncpy( ( char * ) pFilename, ( char * ) pszFile, HB_PATH_MAX - 1 );
if( pError )
{
hb_errPutFileName( pError, pszFile );
if( !fResult )
{
hb_errPutOsCode( pError, hb_fsError() );
hb_errPutGenCode( pError, ( HB_ERRCODE ) ( ( uiExFlags & FXO_TRUNCATE ) ? EG_CREATE : EG_OPEN ) );
}
}
}
else
#endif
{
hFile = hb_fsExtOpen( pFilename, pDefExt, uiExFlags, pPaths, pError );
if( hFile != FS_ERROR )
{
HB_ULONG device = 0, inode = 0;
#if defined( HB_OS_UNIX )
hb_vmUnlock();
if( fstat( hFile, &statbuf ) == 0 )
{
device = ( HB_ULONG ) statbuf.st_dev;
inode = ( HB_ULONG ) statbuf.st_ino;
}
hb_vmLock();
#endif
hb_threadEnterCriticalSection( &s_fileMtx );
pFile = hb_fileNew( hFile, fShared, fReadonly, device, inode, HB_TRUE );
if( pFile->hFile != hFile )
{
if( pFile->hFileRO == FS_ERROR && !fReadonly && pFile->readonly )
{
pFile->hFileRO = pFile->hFile;
pFile->hFile = hFile;
pFile->readonly = HB_FALSE;
hFile = FS_ERROR;
}
if( pFile->uiLocks == 0 )
{
#if !defined( HB_USE_SHARELOCKS ) || defined( HB_USE_BSDLOCKS )
if( pFile->hFileRO != FS_ERROR )
{
hb_fsClose( pFile->hFileRO );
pFile->hFileRO = FS_ERROR;
}
#endif
if( hFile != FS_ERROR )
{
hb_fsClose( hFile );
hFile = FS_ERROR;
#if defined( HB_USE_SHARELOCKS ) && !defined( HB_USE_BSDLOCKS )
/* TOFIX: possible race condition */
hb_fsLockLarge( hFile, HB_SHARELOCK_POS, HB_SHARELOCK_SIZE,
FL_LOCK | FLX_SHARED );
#endif
}
}
}
else
hFile = FS_ERROR;
hb_threadLeaveCriticalSection( &s_fileMtx );
if( hFile != FS_ERROR )
{
/* TOFIX: possible race condition in MT mode,
* close() is not safe due to existing locks
* which are removed.
*/
hb_fsClose( hFile );
}
}
}
hb_xfree( pszFile );
return pFile;
}
static void s_fileClose( PHB_FILE pFile )
{
HB_FHANDLE hFile = FS_ERROR, hFileRO = FS_ERROR;
hb_threadEnterCriticalSection( &s_fileMtx );
if( --pFile->used == 0 )
{
if( pFile->pNext )
{
pFile->pPrev->pNext = pFile->pNext;
pFile->pNext->pPrev = pFile->pPrev;
if( pFile == s_openFiles )
{
s_openFiles = pFile->pNext;
if( pFile == s_openFiles )
s_openFiles = NULL;
}
}
hFile = pFile->hFile;
hFileRO = pFile->hFileRO;
if( pFile->pLocks )
hb_xfree( pFile->pLocks );
hb_xfree( pFile );
}
hb_threadLeaveCriticalSection( &s_fileMtx );
hb_fsSetError( 0 );
if( hFile != FS_ERROR )
hb_fsClose( hFile );
if( hFileRO != FS_ERROR )
hb_fsClose( hFileRO );
}
static HB_BOOL s_fileLock( PHB_FILE pFile, HB_FOFFSET ulStart, HB_FOFFSET ulLen,
int iType )
{
HB_BOOL fResult, fLockFS = HB_FALSE;
if( ( iType & FL_MASK ) == FL_UNLOCK )
{
hb_threadEnterCriticalSection( &s_fileMtx );
fResult = hb_fileUnlock( pFile, &fLockFS, ulStart, ulLen );
hb_threadLeaveCriticalSection( &s_fileMtx );
if( fLockFS )
hb_fsLockLarge( pFile->hFile, ulStart, ulLen, ( HB_USHORT ) iType );
else
hb_fsSetError( fResult ? 0 : 33 );
}
else
{
hb_threadEnterCriticalSection( &s_fileMtx );
fResult = hb_fileSetLock( pFile, &fLockFS, ulStart, ulLen );
hb_threadLeaveCriticalSection( &s_fileMtx );
if( fLockFS )
{
fResult = hb_fsLockLarge( pFile->hFile, ulStart, ulLen, ( HB_USHORT ) iType );
if( !fResult )
{
hb_threadEnterCriticalSection( &s_fileMtx );
hb_fileUnlock( pFile, &fLockFS, ulStart, ulLen );
hb_threadLeaveCriticalSection( &s_fileMtx );
}
}
else
hb_fsSetError( fResult ? 0 : 33 );
}
return fResult;
}
static HB_SIZE s_fileReadAt( PHB_FILE pFile, void * buffer, HB_SIZE nSize,
HB_FOFFSET llOffset )
{
return hb_fsReadAt( pFile->hFile, buffer, nSize, llOffset );
}
static HB_SIZE s_fileWriteAt( PHB_FILE pFile, const void * buffer, HB_SIZE nSize,
HB_FOFFSET llOffset )
{
return hb_fsWriteAt( pFile->hFile, buffer, nSize, llOffset );
}
static HB_BOOL s_fileTruncAt( PHB_FILE pFile, HB_FOFFSET llOffset )
{
return hb_fsTruncAt( pFile->hFile, llOffset );
}
static HB_FOFFSET s_fileSize( PHB_FILE pFile )
{
return hb_fsSeekLarge( pFile->hFile, 0, FS_END );
}
static void s_fileFlush( PHB_FILE pFile, HB_BOOL fDirty )
{
HB_SYMBOL_UNUSED( pFile );
HB_SYMBOL_UNUSED( fDirty );
}
static void s_fileCommit( PHB_FILE pFile )
{
hb_fsCommit( pFile->hFile );
}
static HB_FHANDLE s_fileHandle( PHB_FILE pFile )
{
return pFile ? pFile->hFile : FS_ERROR;
}
static const HB_FILE_FUNCS * s_fileMethods( void )
{
/* methods table */
static const HB_FILE_FUNCS s_fileFuncs =
{
s_fileAccept,
hb_spFileExists,
hb_fsDelete,
hb_fsRename,
s_fileExtOpen,
s_fileClose,
s_fileLock,
s_fileReadAt,
s_fileWriteAt,
s_fileTruncAt,
s_fileSize,
s_fileFlush,
s_fileCommit,
s_fileHandle
};
return &s_fileFuncs;
}
#define HB_FILE_TYPE_MAX 32
static const HB_FILE_FUNCS * s_pFileTypes[ HB_FILE_TYPE_MAX ];
static int s_iFileTypes = 0;
/*
* public API functions
*/
HB_BOOL hb_fileRegister( const HB_FILE_FUNCS * pFuncs )
{
HB_BOOL fResult = HB_FALSE;
hb_threadEnterCriticalSection( &s_fileMtx );
if( s_iFileTypes < HB_FILE_TYPE_MAX )
{
s_pFileTypes[ s_iFileTypes ] = pFuncs;
s_iFileTypes++;
fResult = HB_TRUE;
}
hb_threadLeaveCriticalSection( &s_fileMtx );
return fResult;
}
HB_BOOL hb_fileDelete( const char * pFilename )
{
int i = s_iFileTypes;
while( --i >= 0 )
{
if( s_pFileTypes[ i ]->Accept( pFilename ) )
return s_pFileTypes[ i ]->Delete( pFilename );
}
return hb_fsDelete( pFilename );
}
HB_BOOL hb_fileExists( const char * pFilename, char * pRetPath )
{
int i = s_iFileTypes;
while( --i >= 0 )
{
if( s_pFileTypes[ i ]->Accept( pFilename ) )
return s_pFileTypes[ i ]->Exists( pFilename, pRetPath );
}
return hb_spFileExists( pFilename, pRetPath );
}
HB_BOOL hb_fileRename( const char * pFilename, const char * pszNewName )
{
int i = s_iFileTypes;
while( --i >= 0 )
{
if( s_pFileTypes[ i ]->Accept( pFilename ) )
return s_pFileTypes[ i ]->Rename( pFilename, pszNewName );
}
return hb_fsRename( pFilename, pszNewName );
}
PHB_FILE hb_fileExtOpen( const char * pFilename, const char * pDefExt,
HB_USHORT uiExFlags, const char * pPaths,
PHB_ITEM pError )
{
int i = s_iFileTypes;
while( --i >= 0 )
{
if( s_pFileTypes[ i ]->Accept( pFilename ) )
return s_pFileTypes[ i ]->Open( pFilename, pDefExt, uiExFlags, pPaths, pError );
}
return s_fileExtOpen( pFilename, pDefExt, uiExFlags, pPaths, pError );
}
void hb_fileClose( PHB_FILE pFile )
{
pFile->pFuncs->Close( pFile );
}
HB_BOOL hb_fileLock( PHB_FILE pFile, HB_FOFFSET ulStart, HB_FOFFSET ulLen,
int iType )
{
return pFile->pFuncs->Lock( pFile, ulStart, ulLen, iType );
}
HB_SIZE hb_fileReadAt( PHB_FILE pFile, void * buffer, HB_SIZE nSize,
HB_FOFFSET llOffset )
{
return pFile->pFuncs->ReadAt( pFile, buffer, nSize, llOffset );
}
HB_SIZE hb_fileWriteAt( PHB_FILE pFile, const void * buffer, HB_SIZE nSize,
HB_FOFFSET llOffset )
{
return pFile->pFuncs->WriteAt( pFile, buffer, nSize, llOffset );
}
HB_BOOL hb_fileTruncAt( PHB_FILE pFile, HB_FOFFSET llOffset )
{
return pFile->pFuncs->TruncAt( pFile, llOffset );
}
HB_FOFFSET hb_fileSize( PHB_FILE pFile )
{
return pFile->pFuncs->Size( pFile );
}
void hb_fileFlush( PHB_FILE pFile, HB_BOOL fDirty )
{
pFile->pFuncs->Flush( pFile, fDirty );
}
void hb_fileCommit( PHB_FILE pFile )
{
pFile->pFuncs->Commit( pFile );
}
HB_FHANDLE hb_fileHandle( PHB_FILE pFile )
{
return pFile->pFuncs->Handle( pFile );
}
/* internal FILE structures only */
PHB_FILE hb_fileCreateTemp( const char * pszDir, const char * pszPrefix,
HB_FATTR ulAttr, char * pszName )
{
PHB_FILE pFile = NULL;
HB_FHANDLE hFile;
hFile = hb_fsCreateTemp( pszDir, pszPrefix, ulAttr, pszName );
if( hFile != FS_ERROR )
pFile = hb_fileNew( hFile, HB_FALSE, HB_FALSE, 0, 0, HB_FALSE );
return pFile;
}
PHB_FILE hb_fileCreateTempEx( char * pszName,
const char * pszDir,
const char * pszPrefix,
const char * pszExt,
HB_FATTR ulAttr )
{
PHB_FILE pFile = NULL;
HB_FHANDLE hFile;
hFile = hb_fsCreateTempEx( pszName, pszDir, pszPrefix, pszExt, ulAttr );
if( hFile != FS_ERROR )
pFile = hb_fileNew( hFile, HB_FALSE, HB_FALSE, 0, 0, HB_FALSE );
return pFile;
}
Reference in New Issue View Git Blame Copy Permalink