Method sendUpdatedEntries

tx.go:867–880

* * send updated entries to watch manager for monitoring * and specifying the buckets to be deleted * @param pendingWriteList: the list of entries to be sent * @param deletedBuckets: the buckets to be deleted * * * @return: nil if success, error if any */

(pendingWriteList []*core.Entry, deletedBuckets map[core.BucketName]bool)

 * @return: nil if success, error if any
 */
func (tx *Tx) sendUpdatedEntries(pendingWriteList []*core.Entry, deletedBuckets map[core.BucketName]bool) {
	err := tx.db.watchMgr.sendUpdatedEntries(pendingWriteList, deletedBuckets, func(bucketId core.BucketId) (core.BucketName, error) {
		bucket, err := tx.db.bucketMgr.GetBucketById(bucketId)
		if err != nil {
			return "", err
		}

		return bucket.Name, nil
	})

	if err != nil {
		utils.GetLogger().Printf("send updated entries error: %v", err)
	}
}

/*
* send buckets to watch manager for specifying the bucket to be deleted