Lines Matching refs:block

86         aofrwblock *block = listNodeValue(ln);  in aofRewriteBufferSize()  local
87 size += block->used; in aofRewriteBufferSize()
97 aofrwblock *block; in aofChildWriteDiffData() local
106 block = ln ? ln->value : NULL; in aofChildWriteDiffData()
107 if (server.aof_stop_sending_diff || !block) { in aofChildWriteDiffData()
112 if (block->used > 0) { in aofChildWriteDiffData()
114 block->buf,block->used); in aofChildWriteDiffData()
116 memmove(block->buf,block->buf+nwritten,block->used-nwritten); in aofChildWriteDiffData()
117 block->used -= nwritten; in aofChildWriteDiffData()
119 if (block->used == 0) listDelNode(server.aof_rewrite_buf_blocks,ln); in aofChildWriteDiffData()
126 aofrwblock *block = ln ? ln->value : NULL; in aofRewriteBufferAppend() local
131 if (block) { in aofRewriteBufferAppend()
132 unsigned long thislen = (block->free < len) ? block->free : len; in aofRewriteBufferAppend()
134 memcpy(block->buf+block->used, s, thislen); in aofRewriteBufferAppend()
135 block->used += thislen; in aofRewriteBufferAppend()
136 block->free -= thislen; in aofRewriteBufferAppend()
145 block = zmalloc(sizeof(*block)); in aofRewriteBufferAppend()
146 block->free = AOF_RW_BUF_BLOCK_SIZE; in aofRewriteBufferAppend()
147 block->used = 0; in aofRewriteBufferAppend()
148 listAddNodeTail(server.aof_rewrite_buf_blocks,block); in aofRewriteBufferAppend()
180 aofrwblock *block = listNodeValue(ln); in aofRewriteBufferWrite() local
183 if (block->used) { in aofRewriteBufferWrite()
184 nwritten = write(fd,block->buf,block->used); in aofRewriteBufferWrite()
185 if (nwritten != (ssize_t)block->used) { in aofRewriteBufferWrite()