Lines Matching refs:o
568 int hllSparseToDense(robj *o) { in hllSparseToDense() argument
569 sds sparse = o->ptr, dense; in hllSparseToDense()
617 sdsfree(o->ptr); in hllSparseToDense()
618 o->ptr = dense; in hllSparseToDense()
638 int hllSparseAdd(robj *o, unsigned char *ele, size_t elesize) { in hllSparseAdd() argument
656 o->ptr = sdsMakeRoomFor(o->ptr,3); in hllSparseAdd()
660 sparse = p = ((uint8_t*)o->ptr) + HLL_HDR_SIZE; in hllSparseAdd()
661 end = p + sdslen(o->ptr) - HLL_HDR_SIZE; in hllSparseAdd()
819 sdslen(o->ptr)+deltalen > server.hll_sparse_max_bytes) goto promote; in hllSparseAdd()
821 sdsIncrLen(o->ptr,deltalen); in hllSparseAdd()
851 sdsIncrLen(o->ptr,-1); in hllSparseAdd()
864 hdr = o->ptr; in hllSparseAdd()
869 if (hllSparseToDense(o) == C_ERR) return -1; /* Corrupted HLL. */ in hllSparseAdd()
870 hdr = o->ptr; in hllSparseAdd()
1027 int hllAdd(robj *o, unsigned char *ele, size_t elesize) { in hllAdd() argument
1028 struct hllhdr *hdr = o->ptr; in hllAdd()
1031 case HLL_SPARSE: return hllSparseAdd(o,ele,elesize); in hllAdd()
1090 robj *o; in createHLLObject() local
1114 o = createObject(OBJ_STRING,s); in createHLLObject()
1115 hdr = o->ptr; in createHLLObject()
1118 return o; in createHLLObject()
1124 int isHLLObjectOrReply(client *c, robj *o) { in isHLLObjectOrReply() argument
1128 if (checkType(c,o,OBJ_STRING)) in isHLLObjectOrReply()
1131 if (stringObjectLen(o) < sizeof(*hdr)) goto invalid; in isHLLObjectOrReply()
1132 hdr = o->ptr; in isHLLObjectOrReply()
1142 stringObjectLen(o) != HLL_DENSE_SIZE) goto invalid; in isHLLObjectOrReply()
1156 robj *o = lookupKeyWrite(c->db,c->argv[1]); in pfaddCommand() local
1160 if (o == NULL) { in pfaddCommand()
1164 o = createHLLObject(); in pfaddCommand()
1165 dbAdd(c->db,c->argv[1],o); in pfaddCommand()
1168 if (isHLLObjectOrReply(c,o) != C_OK) return; in pfaddCommand()
1169 o = dbUnshareStringValue(c->db,c->argv[1],o); in pfaddCommand()
1173 int retval = hllAdd(o, (unsigned char*)c->argv[j]->ptr, in pfaddCommand()
1184 hdr = o->ptr; in pfaddCommand()
1196 robj *o; in pfcountCommand() local
1215 robj *o = lookupKeyRead(c->db,c->argv[j]); in pfcountCommand() local
1216 if (o == NULL) continue; /* Assume empty HLL for non existing var.*/ in pfcountCommand()
1217 if (isHLLObjectOrReply(c,o) != C_OK) return; in pfcountCommand()
1221 if (hllMerge(registers,o) == C_ERR) { in pfcountCommand()
1236 o = lookupKeyWrite(c->db,c->argv[1]); in pfcountCommand()
1237 if (o == NULL) { in pfcountCommand()
1242 if (isHLLObjectOrReply(c,o) != C_OK) return; in pfcountCommand()
1243 o = dbUnshareStringValue(c->db,c->argv[1],o); in pfcountCommand()
1246 hdr = o->ptr; in pfcountCommand()
1296 robj *o = lookupKeyRead(c->db,c->argv[j]); in pfmergeCommand() local
1297 if (o == NULL) continue; /* Assume empty HLL for non existing var. */ in pfmergeCommand()
1298 if (isHLLObjectOrReply(c,o) != C_OK) return; in pfmergeCommand()
1302 if (hllMerge(max,o) == C_ERR) { in pfmergeCommand()
1309 robj *o = lookupKeyWrite(c->db,c->argv[1]); in pfmergeCommand() local
1310 if (o == NULL) { in pfmergeCommand()
1314 o = createHLLObject(); in pfmergeCommand()
1315 dbAdd(c->db,c->argv[1],o); in pfmergeCommand()
1320 o = dbUnshareStringValue(c->db,c->argv[1],o); in pfmergeCommand()
1324 if (hllSparseToDense(o) == C_ERR) { in pfmergeCommand()
1331 hdr = o->ptr; in pfmergeCommand()
1355 robj *o = NULL; in pfselftestCommand() local
1396 o = createHLLObject(); in pfselftestCommand()
1404 hllAdd(o,(unsigned char*)&ele,sizeof(ele)); in pfselftestCommand()
1409 hdr2 = o->ptr; in pfselftestCommand()
1417 if (j == checkpoint && hllCount(hdr,NULL) != hllCount(o->ptr,NULL)) { in pfselftestCommand()
1450 if (o) decrRefCount(o); in pfselftestCommand()
1458 robj *o; in pfdebugCommand() local
1461 o = lookupKeyWrite(c->db,c->argv[2]); in pfdebugCommand()
1462 if (o == NULL) { in pfdebugCommand()
1466 if (isHLLObjectOrReply(c,o) != C_OK) return; in pfdebugCommand()
1467 o = dbUnshareStringValue(c->db,c->argv[2],o); in pfdebugCommand()
1468 hdr = o->ptr; in pfdebugCommand()
1475 if (hllSparseToDense(o) == C_ERR) { in pfdebugCommand()
1482 hdr = o->ptr; in pfdebugCommand()
1495 uint8_t *p = o->ptr, *end = p+sdslen(o->ptr); in pfdebugCommand()
1539 if (hllSparseToDense(o) == C_ERR) { in pfdebugCommand()