/usr/include/mongo/s/d_writeback.h is in mongodb-dev 1:2.4.9-1ubuntu2.
This file is owned by root:root, with mode 0o644.
The actual contents of the file can be viewed below.
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 | // @file d_writeback.h
/**
* Copyright (C) 2010 10gen Inc.
*
* This program is free software: you can redistribute it and/or modify
* it under the terms of the GNU Affero General Public License, version 3,
* as published by the Free Software Foundation.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU Affero General Public License for more details.
*
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <http://www.gnu.org/licenses/>.
*/
#pragma once
#include "mongo/pch.h"
#include "mongo/db/jsobj.h"
#include "mongo/util/queue.h"
#include "mongo/util/background.h"
namespace mongo {
/*
* The WriteBackManager keeps one queue of pending operations per mongos. The operations get here
* if they were directed to a chunk that is no longer in this mongod server. The operations are
* "written back" to the mongos server per its request (command 'writebacklisten').
*
* The class is thread safe.
*/
class WriteBackManager {
public:
class QueueInfo : boost::noncopyable {
public:
QueueInfo(){}
BlockingQueue<BSONObj> queue;
long long lastCall; // this is elapsed millis since startup
};
// a map from mongos's serverIDs to queues of "rejected" operations
// an operation is rejected if it targets data that does not live on this shard anymore
typedef map<string,shared_ptr<QueueInfo> > WriteBackQueuesMap;
public:
WriteBackManager();
~WriteBackManager();
/*
* @param remote server ID this operation came from
* @param op the operation itself
*
* Enqueues operation 'op' in server 'remote's queue. The operation will be written back to
* remote at a later stage.
*
* @return the writebackId generated
*/
OID queueWriteBack( const string& remote , BSONObjBuilder& opBuilder );
/*
* @param remote server ID
* @return the queue for operations that came from 'remote'
*
* Gets access to server 'remote's queue, which is synchronized.
*/
shared_ptr<QueueInfo> getWritebackQueue( const string& remote );
/*
* @return true if there is no operation queued for write back
*/
bool queuesEmpty() const;
/**
* appends a number of statistics
*/
void appendStats( BSONObjBuilder& b ) const;
/**
* removes queues that have been idle
* @return if something was removed
*/
bool cleanupOldQueues();
private:
// '_writebackQueueLock' protects only the map itself, since each queue is synchronized.
mutable mongo::mutex _writebackQueueLock;
WriteBackQueuesMap _writebackQueues;
class Cleaner : public PeriodicTask {
public:
virtual string taskName() const { return "WriteBackManager::cleaner"; }
virtual void taskDoWork();
};
Cleaner _cleaner;
};
// TODO collect global state in a central place and init during startup
extern WriteBackManager writeBackManager;
} // namespace mongo
|