History log of /3.0.3-GA/ep-engine/src/dcp-producer.cc (Results 1 - 25 of 103)
Revision (<<< Hide revision tags) (Show revision tags >>>) Date Author Comments
Revision tags: v4.6.5, v4.6.3, v4.6.4, v4.6.2, v4.6.1, v4.6.0, v4.6.0-DP, v4.5.1, v4.1.2, v3.1.6, v4.5.0, v4.1.1, v3.1.5, v3.1.4, v3.1.3, v4.1.0, v3.1.2, v3.1.1, v4.0.0, v3.1.0
# a3f61753 19-Feb-2015 Manu Dhundi <manu@couchbase.com>

MB-13479: Indicate rollback to DCP clients if purge_seqno > snap_start_seqno

The replica may not get all the items if there are purged items in the active
node. Hence this solution propo

MB-13479: Indicate rollback to DCP clients if purge_seqno > snap_start_seqno

The replica may not get all the items if there are purged items in the active
node. Hence this solution proposes to indicate a rollback to seqno 0 in case
the purge_seqno > snap_start_seqno.
Note: Since the occurrence of this scenario is pretty rare, rolling back to 0
may not be a bad thing.

Change-Id: I5c8403115110be136df5d4cb4e2704edc2a4c9e4
Reviewed-on: http://review.couchbase.org/47094
Tested-by: Manu Dhundi <manu@couchbase.com>
Reviewed-by: Michael Wiederhold <mike@couchbase.com>

show more ...


# 4073e680 04-Feb-2015 abhinavdangeti <abhinav@couchbase.com>

[Backport] MB-13286: New DcpProducer to have paused status set to true

DcpOpen will create a new DcpProducer and if one with a
similar name already exists (e.g - during rebalance),
t

[Backport] MB-13286: New DcpProducer to have paused status set to true

DcpOpen will create a new DcpProducer and if one with a
similar name already exists (e.g - during rebalance),
this new producer will replace the older one, and the
paused status will need to be set to true, to let the
notification for the new connection to be sent to
memcached.

Change-Id: I40c22601a7d29141741608339c58caa486a698b2
Reviewed-on: http://review.couchbase.org/46374
Reviewed-by: Chiyoung Seo <chiyoung@couchbase.com>
Tested-by: abhinav dangeti <abhinav@couchbase.com>
Reviewed-on: http://review.couchbase.org/46511

show more ...


Revision tags: v3.0.2
# 3d867be1 06-Nov-2014 Mike Wiederhold <mike@couchbase.com>

MB-12551: Add all arguments to noop log message

Change-Id: Id6e8aac2bf9e398dc8c929eb122651884d27b7c1
Reviewed-on: http://review.couchbase.org/42862
Reviewed-by: Chiyoung Seo <chiyoun

MB-12551: Add all arguments to noop log message

Change-Id: Id6e8aac2bf9e398dc8c929eb122651884d27b7c1
Reviewed-on: http://review.couchbase.org/42862
Reviewed-by: Chiyoung Seo <chiyoung@couchbase.com>
Tested-by: Michael Wiederhold <mike@couchbase.com>

show more ...


# 138a67c7 14-Oct-2014 Mike Wiederhold <mike@couchbase.com>

MB-12271: Set the default dcp producer noop interval to 20 seconds

This is a fix to support backwards compatibility between 3.0 and
3.0.1+ versions of Couchbase. The problem is that 3.0

MB-12271: Set the default dcp producer noop interval to 20 seconds

This is a fix to support backwards compatibility between 3.0 and
3.0.1+ versions of Couchbase. The problem is that 3.0 has a noop
interval of 20 seconds by default and 3.0.1 has a default noop
interval of 200 seconds. In 3.0.1 the consumer explicitly sets
the noop interval of the producer so in 3.0.1+ clusters the 20
second default will be overriden by the consumer, but in the
scenario when a 3.0.1+ node connects to a 3.0 node the 20 second
default will remain.

Change-Id: I2e18e9ad68037f3a82abe5167f2bca89f381f318
Reviewed-on: http://review.couchbase.org/42136
Reviewed-by: Chiyoung Seo <chiyoung@couchbase.com>
Tested-by: Michael Wiederhold <mike@couchbase.com>

show more ...


# 6aa436f1 11-Oct-2014 Mike Wiederhold <mike@couchbase.com>

MB-12271: Set noop interval individually for dcp connections

We need to do this because it might be the case that two servers
have their respective noop intervals set to different values

MB-12271: Set noop interval individually for dcp connections

We need to do this because it might be the case that two servers
have their respective noop intervals set to different values. If
they are this can cause the connections to be disconnected because
each side is expecting to see a noop at different times.

Change-Id: I6ff475ccba407547e7285fa431b86ad9bf9cdc24
Reviewed-on: http://review.couchbase.org/42049
Reviewed-by: Chiyoung Seo <chiyoung@couchbase.com>
Tested-by: Michael Wiederhold <mike@couchbase.com>

show more ...


# 16cc72d4 23-Sep-2014 Mike Wiederhold <mike@couchbase.com>

MB-11642: Change the priority based on the type of dcp connection

Change-Id: I1b9a6846879385308bee3920bfa182fc41e39b4f
Reviewed-on: http://review.couchbase.org/41758
Reviewed-by: Sun

MB-11642: Change the priority based on the type of dcp connection

Change-Id: I1b9a6846879385308bee3920bfa182fc41e39b4f
Reviewed-on: http://review.couchbase.org/41758
Reviewed-by: Sundararaman Sridharan <sundar@couchbase.com>
Tested-by: Michael Wiederhold <mike@couchbase.com>

show more ...


Revision tags: v3.0.0
# 90defd6d 26-Aug-2014 Mike Wiederhold <mike@couchbase.com>

Rename all classes/variables with upr to dcp

Change-Id: Iaf644f5034fdb30a14c400ec55def22d8bb0ba87
Reviewed-on: http://review.couchbase.org/40942
Reviewed-by: Chiyoung Seo <chiyoung@c

Rename all classes/variables with upr to dcp

Change-Id: Iaf644f5034fdb30a14c400ec55def22d8bb0ba87
Reviewed-on: http://review.couchbase.org/40942
Reviewed-by: Chiyoung Seo <chiyoung@couchbase.com>
Reviewed-by: Sundararaman Sridharan <sundar@couchbase.com>
Tested-by: Michael Wiederhold <mike@couchbase.com>

show more ...


# 5ad7924a 26-Aug-2014 Mike Wiederhold <mike@couchbase.com>

Replace upr with dcp in all file names

Change-Id: Ia418e96b5bcebf40ef99e3c27ce3fb8f20f68f0e
Reviewed-on: http://review.couchbase.org/40941
Reviewed-by: Chiyoung Seo <chiyoung@couchba

Replace upr with dcp in all file names

Change-Id: Ia418e96b5bcebf40ef99e3c27ce3fb8f20f68f0e
Reviewed-on: http://review.couchbase.org/40941
Reviewed-by: Chiyoung Seo <chiyoung@couchbase.com>
Reviewed-by: Sundararaman Sridharan <sundar@couchbase.com>
Tested-by: Michael Wiederhold <mike@couchbase.com>

show more ...


# 4f8f59f1 13-Aug-2014 Sundar Sridharan <sundar.sridharan@gmail.com>

MB-11642 Batch load dcp mutations if replication

Instead of loading 1 mutation per vbucket send out 10
dcp mutations per dcp step() if it is a intra-cluster
replication stream.
T

MB-11642 Batch load dcp mutations if replication

Instead of loading 1 mutation per vbucket send out 10
dcp mutations per dcp step() if it is a intra-cluster
replication stream.
This is done so that intra-cluster replication is always
faster than XDCR and views.
Noticeable improvement seen in intra-cluster replication
Change-Id: I15fc0081852e8e11027a20febe3224acdf21b661
Reviewed-on: http://review.couchbase.org/40392
Reviewed-by: Chiyoung Seo <chiyoung@couchbase.com>
Tested-by: Sundararaman Sridharan <sundar@couchbase.com>

show more ...


# 12b288d4 28-Jul-2014 Sundar Sridharan <sundar.sridharan@gmail.com>

MB-11821 rename upr to dcp in stats and logs

Change-Id: Ib2cf48190b2bf274f953b8da1b1cd1373de190c2
Reviewed-on: http://review.couchbase.org/39898
Reviewed-by: Michael Wiederhold <mike

MB-11821 rename upr to dcp in stats and logs

Change-Id: Ib2cf48190b2bf274f953b8da1b1cd1373de190c2
Reviewed-on: http://review.couchbase.org/39898
Reviewed-by: Michael Wiederhold <mike@couchbase.com>
Tested-by: Michael Wiederhold <mike@couchbase.com>

show more ...


# 25be1793 23-Jul-2014 Trond Norbye <trond.norbye@gmail.com>

Refactor: adaptions due to rename of upr api to dcp in memcached

Change-Id: Ifc9768f6064e090e1c28b1dd6138120cf18489fa
Reviewed-on: http://review.couchbase.org/39763
Reviewed-by: Chiy

Refactor: adaptions due to rename of upr api to dcp in memcached

Change-Id: Ifc9768f6064e090e1c28b1dd6138120cf18489fa
Reviewed-on: http://review.couchbase.org/39763
Reviewed-by: Chiyoung Seo <chiyoung@couchbase.com>
Tested-by: Trond Norbye <trond.norbye@gmail.com>

show more ...


# 1652e450 17-Jul-2014 Mike Wiederhold <mike@couchbase.com>

MB-11721: Send acks for snapshot markers during the takeover phase

By sending acks for snapshot markers we can make sure that all items
hve actually been processed on the new master befo

MB-11721: Send acks for snapshot markers during the takeover phase

By sending acks for snapshot markers we can make sure that all items
hve actually been processed on the new master before sending any
set vbucket state messages. This change will reduce the time that
a vbucket might be unavailable due to state changes.

Change-Id: I70b64035c4684754bfcdb632f29cb83fecf161a1
Reviewed-on: http://review.couchbase.org/39375
Reviewed-by: Chiyoung Seo <chiyoung@couchbase.com>
Tested-by: Michael Wiederhold <mike@couchbase.com>

show more ...


# 996b5778 10-Jul-2014 Mike Wiederhold <mike@couchbase.com>

MB-11592: Use a queue_item in a MutationResponse instead of and Item

This will allow us to pull queued_items out of the CheckpointManager
and into and ActiveStream without adding any mem

MB-11592: Use a queue_item in a MutationResponse instead of and Item

This will allow us to pull queued_items out of the CheckpointManager
and into and ActiveStream without adding any memory overhead. This
also simplified the cleanup of a MutationResponse because we no
longer need to seperately delete the item contained inside this
class.

Change-Id: I0fc67ac66da6bd0c0ad0cd0369ee0a377d2b3bd9
Reviewed-on: http://review.couchbase.org/39283
Reviewed-by: Chiyoung Seo <chiyoung@couchbase.com>
Tested-by: Michael Wiederhold <mike@couchbase.com>

show more ...


# d6defe62 10-Jul-2014 Chiyoung Seo <chiyoung.seo@gmail.com>

Reduce the lock contention in notifying UPR connections of an event

This change uses partitioned spinlocks to reduce the lock
contention in notifying UPR connections of mutation events.

Reduce the lock contention in notifying UPR connections of an event

This change uses partitioned spinlocks to reduce the lock
contention in notifying UPR connections of mutation events.

Change-Id: I0e2898f8e10efcbf76ae200f7d9a0f42ebe4badd
Reviewed-on: http://review.couchbase.org/39254
Reviewed-by: Michael Wiederhold <mike@couchbase.com>
Tested-by: Chiyoung Seo <chiyoung@couchbase.com>

show more ...


# 7ac0a894 09-Jul-2014 Mike Wiederhold <mike@couchbase.com>

MB-11676: Properly set the end seqno for disk only streams

It's possible that if there were no persisted disk items that we
would not schedule a backfill and go straight to the in-memory

MB-11676: Properly set the end seqno for disk only streams

It's possible that if there were no persisted disk items that we
would not schedule a backfill and go straight to the in-memory
phase which is incorrect for a disk only stream. This change also
makes sure that the end seqno is reported correctly in the stats
for a disk only stream.

Change-Id: I30c473149fb37f38e47f5c8c87c7d7db60608223
Reviewed-on: http://review.couchbase.org/39242
Reviewed-by: Chiyoung Seo <chiyoung@couchbase.com>
Tested-by: Michael Wiederhold <mike@couchbase.com>

show more ...


# 8677524e 30-Jun-2014 Mike Wiederhold <mike@couchbase.com>

MB-11361: Make upr no-ops optional

Clients that are both on localhost do not need to use no-ops and
can choose not to turn this feature on for their connection.

Change-Id: I0d11

MB-11361: Make upr no-ops optional

Clients that are both on localhost do not need to use no-ops and
can choose not to turn this feature on for their connection.

Change-Id: I0d1186461e3aee5efde05cce0472f64655a809ab
Reviewed-on: http://review.couchbase.org/38991
Reviewed-by: Chiyoung Seo <chiyoung@couchbase.com>
Tested-by: Michael Wiederhold <mike@couchbase.com>

show more ...


# 62f5f3f8 13-Jun-2014 Mike Wiederhold <mike@couchbase.com>

MB-11361: Implement upr noop command

The upr noop command is used to detect dead connections. It is sent
once every 3 minutes and waits 3 minutes for a response. If no
response comes

MB-11361: Implement upr noop command

The upr noop command is used to detect dead connections. It is sent
once every 3 minutes and waits 3 minutes for a response. If no
response comes in that time the connection is deemed to be dead. The
noop command is only sent when flow control is turned on by the
consumer.

Change-Id: I2eb9fc201eeb91878f9339c6b3b582cd2ca5da06
Reviewed-on: http://review.couchbase.org/38439
Reviewed-by: Chiyoung Seo <chiyoung@couchbase.com>
Tested-by: Michael Wiederhold <mike@couchbase.com>

show more ...


# 25b9a267 02-Jul-2014 Chiyoung Seo <chiyoung.seo@gmail.com>

MB-11601 Fix to the memory leak in processing UPR messages.

If UPR_MUTATION fails to be sent or a message type is UPR_DELETION,
then we should free an Item instance after processing an

MB-11601 Fix to the memory leak in processing UPR messages.

If UPR_MUTATION fails to be sent or a message type is UPR_DELETION,
then we should free an Item instance after processing an
UPR_MUTATION or UPR_DELETION message.

Change-Id: I61849a1074f829b00d5191eb1417ee60059d4716
Reviewed-on: http://review.couchbase.org/39065
Reviewed-by: abhinav dangeti <abhinav@couchbase.com>
Tested-by: Chiyoung Seo <chiyoung@couchbase.com>

show more ...


# 4609ee12 30-Jun-2014 Chiyoung Seo <chiyoung.seo@gmail.com>

Synchronize UPRProducer::handleResponse API through the lock.

Change-Id: I782d8e0c126a23174d50eb89c628f91d791dbe39
Reviewed-on: http://review.couchbase.org/38995
Reviewed-by: abhinav

Synchronize UPRProducer::handleResponse API through the lock.

Change-Id: I782d8e0c126a23174d50eb89c628f91d791dbe39
Reviewed-on: http://review.couchbase.org/38995
Reviewed-by: abhinav dangeti <abhinav@couchbase.com>
Tested-by: Chiyoung Seo <chiyoung@couchbase.com>

show more ...


# d83efb2e 29-Jun-2014 Mike Wiederhold <mike@couchbase.com>

MB-11579: Use the upr latest flag to set the end seqno to the vb high seqno

The "latest" flag is used to create a stream and get everything up to the
latest mutation that the vbucket cur

MB-11579: Use the upr latest flag to set the end seqno to the vb high seqno

The "latest" flag is used to create a stream and get everything up to the
latest mutation that the vbucket currently contains. This flag should be
used by clients sho are interested in getting the latest mutations, but
do not want to have to figure out what the latest seqno is by using stats.

Change-Id: I86b6b3cebab46351b41ecdc11194c5b5607a4f28
Reviewed-on: http://review.couchbase.org/38937
Reviewed-by: Chiyoung Seo <chiyoung@couchbase.com>
Tested-by: Michael Wiederhold <mike@couchbase.com>

show more ...


# f4522b33 29-Jun-2014 Chiyoung Seo <chiyoung.seo@gmail.com>

Fix to the potential starvation in UPR producer streams.

This change makes sure that all the streams belonging to a given
UPR produer are visited in a round-robin manner.

Change

Fix to the potential starvation in UPR producer streams.

This change makes sure that all the streams belonging to a given
UPR produer are visited in a round-robin manner.

Change-Id: Ieb5a546a932dbe1ba891ef2393747da336ed12ae
Reviewed-on: http://review.couchbase.org/38929
Reviewed-by: Michael Wiederhold <mike@couchbase.com>
Tested-by: Chiyoung Seo <chiyoung@couchbase.com>

show more ...


# 7ce04f43 27-Jun-2014 Chiyoung Seo <chiyoung.seo@gmail.com>

MB-11347 Set thread local to NULL before calling upr_producers API

As upr_message_producers APIs provided by memcached layer can
allocate additional memory that will be freed later, we s

MB-11347 Set thread local to NULL before calling upr_producers API

As upr_message_producers APIs provided by memcached layer can
allocate additional memory that will be freed later, we should
set the thread local to NULL before calling those APIs, so that
the allocated memory inside those APIs shouldn't be accounted for
a given bucket instance.

Change-Id: I31eac3fdc505fbde32a9b54ac8914d9d56e8992a
Reviewed-on: http://review.couchbase.org/38863
Reviewed-by: abhinav dangeti <abhinav@couchbase.com>
Tested-by: Chiyoung Seo <chiyoung@couchbase.com>

show more ...


# f43d865d 18-Jun-2014 Mike Wiederhold <mike@couchbase.com>

Revert "MB-11361: Implement upr noop command"

We will add this back once some of the other components fix
issues that were caused by this patch.

This reverts commit e2e75cb16b1e

Revert "MB-11361: Implement upr noop command"

We will add this back once some of the other components fix
issues that were caused by this patch.

This reverts commit e2e75cb16b1e5bf715e9437a55580df46a72a011.

Change-Id: I46c1d14ac60044f6a6b34f2fcd08f615eefe219b
Reviewed-on: http://review.couchbase.org/38438
Tested-by: Aliaksey Kandratsenka <alkondratenko@gmail.com>
Reviewed-by: Michael Wiederhold <mike@couchbase.com>
Tested-by: Michael Wiederhold <mike@couchbase.com>

show more ...


# e2e75cb1 13-Jun-2014 Mike Wiederhold <mike@couchbase.com>

MB-11361: Implement upr noop command

The upr noop command is used to detect dead connections. It is sent
once every 3 minutes and waits 3 minutes for a response. If no
response comes

MB-11361: Implement upr noop command

The upr noop command is used to detect dead connections. It is sent
once every 3 minutes and waits 3 minutes for a response. If no
response comes in that time the connection is deemed to be dead. The
noop command is only sent when flow control is turned on by the
consumer.

Change-Id: Ib6f1eb51810d9c641ca52d1e3cda8ae9ffa3684c
Reviewed-on: http://review.couchbase.org/38355
Reviewed-by: abhinav dangeti <abhinav@couchbase.com>
Tested-by: Michael Wiederhold <mike@couchbase.com>

show more ...


# 2a30f371 16-Jun-2014 Mike Wiederhold <mike@couchbase.com>

MB-11421: Supports ack should be false for upr connections

Upr doesn't support ack/nack logic.

Change-Id: I5ba3d1cf323f527ce59ed2d8dd901566f3bcd1f5
Reviewed-on: http://review.co

MB-11421: Supports ack should be false for upr connections

Upr doesn't support ack/nack logic.

Change-Id: I5ba3d1cf323f527ce59ed2d8dd901566f3bcd1f5
Reviewed-on: http://review.couchbase.org/38347
Reviewed-by: abhinav dangeti <abhinav@couchbase.com>
Reviewed-by: Sundararaman Sridharan <sundar@couchbase.com>
Tested-by: Michael Wiederhold <mike@couchbase.com>

show more ...


12345