Lines Matching refs:c

987 typedef void redisCommandProc(client *c);
1094 void freeClient(client *c);
1095 void freeClientAsync(client *c);
1096 void resetClient(client *c);
1098 void *addDeferredMultiBulkLength(client *c);
1099 void setDeferredMultiBulkLength(client *c, void *node, long length);
1100 void processInputBuffer(client *c);
1105 void addReplyBulk(client *c, robj *obj);
1106 void addReplyBulkCString(client *c, const char *s);
1107 void addReplyBulkCBuffer(client *c, const void *p, size_t len);
1108 void addReplyBulkLongLong(client *c, long long ll);
1109 void addReply(client *c, robj *obj);
1110 void addReplySds(client *c, sds s);
1111 void addReplyBulkSds(client *c, sds s);
1112 void addReplyError(client *c, const char *err);
1113 void addReplyStatus(client *c, const char *status);
1114 void addReplyDouble(client *c, double d);
1115 void addReplyHumanLongDouble(client *c, long double d);
1116 void addReplyLongLong(client *c, long long ll);
1117 void addReplyMultiBulkLen(client *c, long length);
1125 void rewriteClientCommandVector(client *c, int argc, ...);
1126 void rewriteClientCommandArgument(client *c, int i, robj *newval);
1127 void replaceClientCommandVector(client *c, int argc, robj **argv);
1128 unsigned long getClientOutputBufferMemoryUsage(client *c);
1130 void asyncCloseClientOnOutputBufferLimitReached(client *c);
1131 int getClientType(client *c);
1141 int clientHasPendingReplies(client *c);
1142 void unlinkClient(client *c);
1143 int writeToClient(int fd, client *c, int handler_installed);
1146 void addReplyErrorFormat(client *c, const char *fmt, ...)
1148 void addReplyStatusFormat(client *c, const char *fmt, ...)
1151 void addReplyErrorFormat(client *c, const char *fmt, ...);
1152 void addReplyStatusFormat(client *c, const char *fmt, ...);
1168 void unblockClientWaitingData(client *c);
1170 void popGenericCommand(client *c, int where);
1174 void unwatchAllKeys(client *c);
1175 void initClientMultiState(client *c);
1176 void freeClientMultiState(client *c);
1177 void queueMultiCommand(client *c);
1180 void discardTransaction(client *c);
1181 void flagTransaction(client *c);
1182 void execCommandPropagateMulti(client *c);
1212 int getLongFromObjectOrReply(client *c, robj *o, long *target, const char *msg);
1213 int checkType(client *c, robj *o, int type);
1214 int getLongLongFromObjectOrReply(client *c, robj *o, long long *target, const char *msg);
1215 int getDoubleFromObjectOrReply(client *c, robj *o, double *target, const char *msg);
1218 int getLongDoubleFromObjectOrReply(client *c, robj *o, long double *target, const char *msg);
1233 void replicationFeedMonitors(client *c, list *monitors, int dictid, robj **argv, int argc);
1237 void replicationCacheMaster(client *c);
1247 void unblockClientWaitingReplicas(client *c);
1251 char *replicationGetSlaveName(client *c);
1307 int processCommand(client *c);
1312 void call(client *c, int flags);
1315 void forceCommandPropagation(client *c, int flags);
1316 void preventCommandPropagation(client *c);
1317 void preventCommandAOF(client *c);
1318 void preventCommandReplication(client *c);
1377 robj *hashTypeLookupWriteOrCreate(client *c, robj *key);
1380 int pubsubUnsubscribeAllChannels(client *c, int notify);
1381 int pubsubUnsubscribeAllPatterns(client *c, int notify);
1408 robj *lookupKeyReadOrReply(client *c, robj *key, robj *reply);
1409 robj *lookupKeyWriteOrReply(client *c, robj *key, robj *reply);
1421 int selectDb(client *c, int id);
1428 void scanGenericCommand(client *c, robj *o, unsigned long cursor);
1429 int parseScanCursorOrReply(client *c, robj *o, unsigned long *cursor);
1467 void blockClient(client *c, int btype);
1468 void unblockClient(client *c);
1469 void replyToBlockedClientTimedOut(client *c);
1470 int getTimeoutFromObjectOrReply(client *c, robj *object, mstime_t *timeout, int unit);
1479 void authCommand(client *c);
1480 void pingCommand(client *c);
1481 void echoCommand(client *c);
1482 void commandCommand(client *c);
1483 void setCommand(client *c);
1484 void setnxCommand(client *c);
1485 void setexCommand(client *c);
1486 void psetexCommand(client *c);
1487 void getCommand(client *c);
1488 void delCommand(client *c);
1489 void existsCommand(client *c);
1490 void setbitCommand(client *c);
1491 void getbitCommand(client *c);
1492 void bitfieldCommand(client *c);
1493 void setrangeCommand(client *c);
1494 void getrangeCommand(client *c);
1495 void incrCommand(client *c);
1496 void decrCommand(client *c);
1497 void incrbyCommand(client *c);
1498 void decrbyCommand(client *c);
1499 void incrbyfloatCommand(client *c);
1500 void selectCommand(client *c);
1501 void randomkeyCommand(client *c);
1502 void keysCommand(client *c);
1503 void scanCommand(client *c);
1504 void dbsizeCommand(client *c);
1505 void lastsaveCommand(client *c);
1506 void saveCommand(client *c);
1507 void bgsaveCommand(client *c);
1508 void bgrewriteaofCommand(client *c);
1509 void shutdownCommand(client *c);
1510 void moveCommand(client *c);
1511 void renameCommand(client *c);
1512 void renamenxCommand(client *c);
1513 void lpushCommand(client *c);
1514 void rpushCommand(client *c);
1515 void lpushxCommand(client *c);
1516 void rpushxCommand(client *c);
1517 void linsertCommand(client *c);
1518 void lpopCommand(client *c);
1519 void rpopCommand(client *c);
1520 void llenCommand(client *c);
1521 void lindexCommand(client *c);
1522 void lrangeCommand(client *c);
1523 void ltrimCommand(client *c);
1524 void typeCommand(client *c);
1525 void lsetCommand(client *c);
1526 void saddCommand(client *c);
1527 void sremCommand(client *c);
1528 void smoveCommand(client *c);
1529 void sismemberCommand(client *c);
1530 void scardCommand(client *c);
1531 void spopCommand(client *c);
1532 void srandmemberCommand(client *c);
1533 void sinterCommand(client *c);
1534 void sinterstoreCommand(client *c);
1535 void sunionCommand(client *c);
1536 void sunionstoreCommand(client *c);
1537 void sdiffCommand(client *c);
1538 void sdiffstoreCommand(client *c);
1539 void sscanCommand(client *c);
1540 void syncCommand(client *c);
1541 void flushdbCommand(client *c);
1542 void flushallCommand(client *c);
1543 void sortCommand(client *c);
1544 void lremCommand(client *c);
1545 void rpoplpushCommand(client *c);
1546 void infoCommand(client *c);
1547 void mgetCommand(client *c);
1548 void monitorCommand(client *c);
1549 void expireCommand(client *c);
1550 void expireatCommand(client *c);
1551 void pexpireCommand(client *c);
1552 void pexpireatCommand(client *c);
1553 void getsetCommand(client *c);
1554 void ttlCommand(client *c);
1555 void touchCommand(client *c);
1556 void pttlCommand(client *c);
1557 void persistCommand(client *c);
1558 void slaveofCommand(client *c);
1559 void roleCommand(client *c);
1560 void debugCommand(client *c);
1561 void msetCommand(client *c);
1562 void msetnxCommand(client *c);
1563 void zaddCommand(client *c);
1564 void zincrbyCommand(client *c);
1565 void zrangeCommand(client *c);
1566 void zrangebyscoreCommand(client *c);
1567 void zrevrangebyscoreCommand(client *c);
1568 void zrangebylexCommand(client *c);
1569 void zrevrangebylexCommand(client *c);
1570 void zcountCommand(client *c);
1571 void zlexcountCommand(client *c);
1572 void zrevrangeCommand(client *c);
1573 void zcardCommand(client *c);
1574 void zremCommand(client *c);
1575 void zscoreCommand(client *c);
1576 void zremrangebyscoreCommand(client *c);
1577 void zremrangebylexCommand(client *c);
1578 void multiCommand(client *c);
1579 void execCommand(client *c);
1580 void discardCommand(client *c);
1581 void blpopCommand(client *c);
1582 void brpopCommand(client *c);
1583 void brpoplpushCommand(client *c);
1584 void appendCommand(client *c);
1585 void strlenCommand(client *c);
1586 void zrankCommand(client *c);
1587 void zrevrankCommand(client *c);
1588 void hsetCommand(client *c);
1589 void hsetnxCommand(client *c);
1590 void hgetCommand(client *c);
1591 void hmsetCommand(client *c);
1592 void hmgetCommand(client *c);
1593 void hdelCommand(client *c);
1594 void hlenCommand(client *c);
1595 void hstrlenCommand(client *c);
1596 void zremrangebyrankCommand(client *c);
1597 void zunionstoreCommand(client *c);
1598 void zinterstoreCommand(client *c);
1599 void zscanCommand(client *c);
1600 void hkeysCommand(client *c);
1601 void hvalsCommand(client *c);
1602 void hgetallCommand(client *c);
1603 void hexistsCommand(client *c);
1604 void hscanCommand(client *c);
1605 void configCommand(client *c);
1606 void hincrbyCommand(client *c);
1607 void hincrbyfloatCommand(client *c);
1608 void subscribeCommand(client *c);
1609 void unsubscribeCommand(client *c);
1610 void psubscribeCommand(client *c);
1611 void punsubscribeCommand(client *c);
1612 void publishCommand(client *c);
1613 void pubsubCommand(client *c);
1614 void watchCommand(client *c);
1615 void unwatchCommand(client *c);
1616 void clusterCommand(client *c);
1617 void restoreCommand(client *c);
1618 void migrateCommand(client *c);
1619 void askingCommand(client *c);
1620 void readonlyCommand(client *c);
1621 void readwriteCommand(client *c);
1622 void dumpCommand(client *c);
1623 void objectCommand(client *c);
1624 void clientCommand(client *c);
1625 void evalCommand(client *c);
1626 void evalShaCommand(client *c);
1627 void scriptCommand(client *c);
1628 void timeCommand(client *c);
1629 void bitopCommand(client *c);
1630 void bitcountCommand(client *c);
1631 void bitposCommand(client *c);
1632 void replconfCommand(client *c);
1633 void waitCommand(client *c);
1634 void geoencodeCommand(client *c);
1635 void geodecodeCommand(client *c);
1636 void georadiusByMemberCommand(client *c);
1637 void georadiusCommand(client *c);
1638 void geoaddCommand(client *c);
1639 void geohashCommand(client *c);
1640 void geoposCommand(client *c);
1641 void geodistCommand(client *c);
1642 void pfselftestCommand(client *c);
1643 void pfaddCommand(client *c);
1644 void pfcountCommand(client *c);
1645 void pfmergeCommand(client *c);
1646 void pfdebugCommand(client *c);
1647 void latencyCommand(client *c);
1657 void _serverAssertWithInfo(client *c, robj *o, char *estr, char *file, int line);