不知道大家有没有碰到过这样的问题，即在LINUX下的程序有时候会碰到多个进程访问同一个文件，
以及一个进程的不同线程对一个文件的同步问题，我尝试用了系统提供的fcntl函数来给文件加锁，
但是这只是一个进程互斥锁，对于多线程的访问，后面的操作会覆盖前面的，看了stevens大爷的
网络编程的第9章中的my_lock和my_unlock的例子，还是不能很好的解决多线程同步的问题，
而他在11章利用信号灯对两个函数的另一种实现在LINUX下不行，因为LINUX下不支持有名信号灯，
哪位大虾能给提供一个比较好的解决方法，能给提供源代码的（上面两个函数的）我再加300分！

如果使用进程间同步，使用IPC（信号量（SYS-V）、消息队列（SYS-V）、SOCKET）都行
如果使用线程同步，建议使用posix 信号量和消息队列
这些都没问题，如果不能实现文件互斥，那么最大可能是你设计的文件互斥逻辑可能存在问题

/* recordio */

#include 
#include 
#include 
#include 
#include "recordio.h"


int initrecord(const char* pathname, unsigned int reclen)
{
int fd;
int rs;
RECORDINFO info;

if ( (fd = open(pathname, O_RDWR|O_CREAT, 0660)) == -1 ) {

perror("Fail to open file for initializing record");
return -1;
}

if ( (rs = read(fd, &info, sizeof(RECORDINFO))) == -1 ) {

perror("Fail to read record info for initializing record");
return -1;
}

if ( rs == 0 ) {

info.reclen = reclen;
info.recnum = 0;

if ( write(fd, &info, sizeof(RECORDINFO)) == -1 ) {

perror("Fail to write record info for initializing record");
return -1;
}
}

close(fd);
return 0;
}


int addrecord(const char* pathname, void* buf, unsigned int reclen, unsigned int recnum)
{
int fd;
int rs;
struct flock lock;

lock.l_type = F_WRLCK;
lock.l_start = 0;
lock.l_whence = SEEK_SET;
lock.l_len = 0;

if ( (fd = open(pathname, O_WRONLY|O_APPEND)) == -1 ) {

perror("Fail to open file for adding record");
return -1;
}

if ( fcntl(fd, F_SETLKW, &lock) == -1 ) {

      perror("Fail to lock file for adding record");
return -1;
}

        lock.l_type = F_UNLCK;

rs = write(fd, buf, reclen * recnum);

if ( fcntl(fd, F_SETLKW, &lock) == -1 ) {

perror("Fail to unlock file for adding record");
return -1;
}

close(fd);
return rs;
}


int getrecord(const char* pathname, void* buf, unsigned int reclen, unsigned int recnum)
{
int fd;
int len;
RECORDINFO info;
struct flock lock;

lock.l_type = F_WRLCK;
lock.l_start = 0;
lock.l_whence = SEEK_SET;
lock.l_len = 0;

if ( (fd = open(pathname, O_RDWR)) == -1 ) {

perror("Fail to open file for geting record");
return -1;
}

if ( fcntl(fd, F_SETLKW, &lock) == -1 ) {

perror("Fail to lock file for geting record");
return -1;
}

lock.l_type = F_UNLCK;

if ( read(fd, &info, sizeof(RECORDINFO)) != sizeof(RECORDINFO) ) {

perror("Fail to read record info");
return -1;
}

if ( info.reclen != reclen ) {

fprintf(stderr, "Invalid reclen parameter n");
return -1;
}

if ( lseek(fd, sizeof(RECORDINFO) + info.reclen * info.recnum, SEEK_SET) == -1 ) {

perror("Fail to seek read position");
return -1;
}

if ( (len = read(fd, buf, reclen * recnum)) == -1 ) {

perror("Fail to get record");
return -1;
}

if ( len == 0 ) {

if ( ftruncate(fd, sizeof(RECORDINFO)) == -1 ) {

perror("Fail to truncate file");
return -1;
}

info.recnum = 0;
if ( lseek(fd, 0, SEEK_SET) == -1 ) {


perror("Fail to return beginning");           
return -1;                 
}

if ( write(fd, &info, sizeof(RECORDINFO)) == -1 ) {

perror("Fail to update record info");
return -1;
        }

 if ( fcntl(fd, F_SETLKW, &lock) == -1 ) {

 perror("Fail to unlock file for geting record");
 return -1;
 }
 
close(fd);
return 0;

} else { 

info.recnum +=  len / info.reclen;

if ( lseek(fd, 0, SEEK_SET) == -1 ) {

perror("Fail to return beginning");
return -1;
}

if ( write(fd, &info, sizeof(RECORDINFO)) == -1 ) {

perror("Fail to update record info");
return -1;
}

if ( fcntl(fd, F_SETLKW, &lock) == -1 ) {
               
     perror("Fail to unlock file for geting record");
return -1;

}

close(fd);
return len;
}

}