| /f-stack/app/redis-5.0.5/src/ |
| H A D | t_stream.c | 806 argv[3] = createStringObject(nack->consumer->name,sdslen(nack->consumer->name)); in streamPropagateXCLAIM()
1043 nack->delivery_count++; in streamReplyWithRangeFromConsumerPEL()
1593 streamNACK *nack = zmalloc(sizeof(*nack)); in streamCreateNACK() local
1595 nack->delivery_count = 1; in streamCreateNACK()
1596 nack->consumer = consumer; in streamCreateNACK()
1597 return nack; in streamCreateNACK()
1686 streamFreeNACK(nack); in streamDelConsumer()
1902 if (nack != raxNotFound) { in xackCommand()
1905 streamFreeNACK(nack); in xackCommand()
2260 if (nack != raxNotFound) { in xclaimCommand()
[all …]
|
| H A D | rdb.c | 699 streamNACK *nack = ri.data; in rdbSaveStreamPEL() local
700 if ((n = rdbSaveMillisecondTime(rdb,nack->delivery_time)) == -1) in rdbSaveStreamPEL()
703 if ((n = rdbSaveLen(rdb,nack->delivery_count)) == -1) return -1; in rdbSaveStreamPEL()
1711 streamNACK *nack = streamCreateNACK(NULL); in rdbLoadObject() local
1712 nack->delivery_time = rdbLoadMillisecondTime(rdb,RDB_VERSION); in rdbLoadObject()
1713 nack->delivery_count = rdbLoadLen(rdb,NULL); in rdbLoadObject()
1714 if (!raxInsert(cgroup->pel,rawid,sizeof(rawid),nack,NULL)) in rdbLoadObject()
1739 streamNACK *nack = raxFind(cgroup->pel,rawid,sizeof(rawid)); in rdbLoadObject() local
1740 if (nack == raxNotFound) in rdbLoadObject()
1747 nack->consumer = consumer; in rdbLoadObject()
[all …]
|
| H A D | aof.c | 1139 …roupname, size_t groupname_len, streamConsumer *consumer, unsigned char *rawid, streamNACK *nack) { in rioWriteStreamPendingEntry() argument
1152 if (rioWriteBulkLongLong(r,nack->delivery_time) == 0) return 0; in rioWriteStreamPendingEntry()
1154 if (rioWriteBulkLongLong(r,nack->delivery_count) == 0) return 0; in rioWriteStreamPendingEntry()
1239 streamNACK *nack = ri_pel.data; in rewriteStreamObject() local
1242 ri_pel.key,nack) == 0) in rewriteStreamObject()
|
| H A D | defrag.c | 696 streamNACK *nack = ri->data, *newnack; in defragStreamConsumerPendingEntry() local
697 nack->consumer = ctx->c; /* update nack pointer to consumer */ in defragStreamConsumerPendingEntry()
698 newnack = activeDefragAlloc(nack); in defragStreamConsumerPendingEntry()
703 serverAssert(prev==nack); in defragStreamConsumerPendingEntry()
|
| /f-stack/freebsd/netgraph/ |
| H A D | ng_l2tp.c | 1315 int nack; in ng_l2tp_seq_recv_nr() local
1322 if ((nack = L2TP_SEQ_DIFF(nr, seq->rack)) <= 0) { in ng_l2tp_seq_recv_nr()
1331 KASSERT(nack <= L2TP_MAX_XWIN, in ng_l2tp_seq_recv_nr()
1339 for (i = 0; i < nack; i++) in ng_l2tp_seq_recv_nr()
1341 memmove(seq->xwin, seq->xwin + nack, in ng_l2tp_seq_recv_nr()
1343 memset(seq->xwin + (L2TP_MAX_XWIN - nack), 0, in ng_l2tp_seq_recv_nr()
1344 nack * sizeof(*seq->xwin)); in ng_l2tp_seq_recv_nr()
1354 seq->cwnd += nack; in ng_l2tp_seq_recv_nr()
1355 nack = 0; in ng_l2tp_seq_recv_nr()
1357 nack = seq->cwnd - seq->ssth; in ng_l2tp_seq_recv_nr()
[all …]
|
| /f-stack/freebsd/contrib/octeon-sdk/ |
| H A D | cvmx-sriomaintx-defs.h | 1416 uint32_t nack : 1; /**< Received packet-not-accepted acknowledge control member
1462 uint32_t nack : 1;
1478 uint32_t nack : 1; /**< Received packet-not-accepted acknowledge control member
1516 uint32_t nack : 1;
1605 uint32_t nack : 1; /**< Enable error rate counting of packet-not-accepted member
1644 uint32_t nack : 1;
1660 uint32_t nack : 1; /**< Enable error rate counting of packet-not-accepted member
1692 uint32_t nack : 1;
|
| /f-stack/dpdk/drivers/net/igc/base/ |
| H A D | igc_api.c | 367 bool nack = true; in igc_read_i2c_byte_generic() local
412 status = igc_clock_out_i2c_bit(hw, nack); in igc_read_i2c_byte_generic()
|
| /f-stack/dpdk/drivers/net/ixgbe/base/ |
| H A D | ixgbe_phy.c | 1984 bool nack = 1; in ixgbe_read_i2c_byte_generic_int() local
2030 status = ixgbe_clock_out_i2c_bit(hw, nack); in ixgbe_read_i2c_byte_generic_int()
|
| /f-stack/dpdk/doc/guides/contributing/ |
| H A D | patches.rst | 637 it may receive a ``nack``.
644 ``nack`` of those patches as appropriate.
|
| /f-stack/dpdk/drivers/net/e1000/base/ |
| H A D | e1000_82575.c | 3095 bool nack = true; in e1000_read_i2c_byte_generic() local
3140 status = e1000_clock_out_i2c_bit(hw, nack); in e1000_read_i2c_byte_generic()
|
| /f-stack/app/redis-5.0.5/ |
| H A D | 00-RELEASENOTES | 1071 Make comment about nack->consumer test for minidle more obvious.
|