Browse files

fixed error code checking for *write operations and return value in A…

…OF rewriting function
  • Loading branch information...
1 parent e8de5c7 commit c7543ab6f1ae4e4a3defafeecfd4cb2d7198a6c1 @antirez committed Jul 1, 2010
Showing with 6 additions and 6 deletions.
  1. +6 −6 redis.c
View
12 redis.c
@@ -8618,10 +8618,10 @@ static int rewriteAppendOnlyFile(char *filename) {
while((p = zipmapNext(p,&field,&flen,&val,&vlen)) != NULL) {
if (fwrite(cmd,sizeof(cmd)-1,1,fp) == 0) goto werr;
if (fwriteBulkObject(fp,key) == 0) goto werr;
- if (fwriteBulkString(fp,(char*)field,flen) == -1)
- return -1;
- if (fwriteBulkString(fp,(char*)val,vlen) == -1)
- return -1;
+ if (fwriteBulkString(fp,(char*)field,flen) == 0)
+ goto werr;
+ if (fwriteBulkString(fp,(char*)val,vlen) == 0)
+ goto werr;
}
} else {
dictIterator *di = dictGetIterator(o->ptr);
@@ -8633,8 +8633,8 @@ static int rewriteAppendOnlyFile(char *filename) {
if (fwrite(cmd,sizeof(cmd)-1,1,fp) == 0) goto werr;
if (fwriteBulkObject(fp,key) == 0) goto werr;
- if (fwriteBulkObject(fp,field) == -1) return -1;
- if (fwriteBulkObject(fp,val) == -1) return -1;
+ if (fwriteBulkObject(fp,field) == 0) goto werr;
+ if (fwriteBulkObject(fp,val) == 0) goto werr;
}
dictReleaseIterator(di);
}

0 comments on commit c7543ab

Please sign in to comment.