0.9.8.10
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Modules Pages
UpdateRecTable.h
Go to the documentation of this file.
1 /* -*- c++ -*-
2  * Copyright (C) 2007-2015 Hypertable, Inc.
3  *
4  * This file is part of Hypertable.
5  *
6  * Hypertable is free software; you can redistribute it and/or
7  * modify it under the terms of the GNU General Public License
8  * as published by the Free Software Foundation; either version 3
9  * of the License, or any later version.
10  *
11  * Hypertable is distributed in the hope that it will be useful,
12  * but WITHOUT ANY WARRANTY; without even the implied warranty of
13  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
14  * GNU General Public License for more details.
15  *
16  * You should have received a copy of the GNU General Public License
17  * along with this program; if not, write to the Free Software
18  * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA
19  * 02110-1301, USA.
20  */
21 
26 
27 #ifndef Hypertable_RangeServer_UpdateRecTable_h
28 #define Hypertable_RangeServer_UpdateRecTable_h
29 
33 
35 
36 #include <AsyncComm/Clock.h>
37 
38 #include <unordered_map>
39 #include <vector>
40 
41 namespace Hypertable {
42 
45 
48  public:
50  for (auto r : requests)
51  delete r;
52  for (auto entry : range_map)
53  delete entry.second;
54  }
56  uint64_t cluster_id;
60  std::vector<UpdateRequest *> requests;
65  std::unordered_map<Range *, UpdateRecRangeList *> range_map;
67  uint64_t total_count {};
68  uint64_t total_buffer_size {};
69  std::string error_msg;
70  int32_t error {};
71  uint32_t flags {};
72  uint32_t commit_interval {};
73  uint32_t commit_iteration {};
74  uint32_t transfer_count {};
75  uint32_t total_added {};
76  };
77 
79 }
80 
81 #endif // Hypertable_RangeServer_UpdateRecTable_h
std::vector< UpdateRequest * > requests
Vector of corresponding client requests.
chrono::time_point< fast_clock > time_point
Definition: fast_clock.h:42
Declarations for TableIdentifier and TableIdentifierManaged.
Holds updates destined for a specific table.
ClockT::time_point expire_time
Request expiration time.
std::unordered_map< Range *, UpdateRecRangeList * > range_map
A dynamic, resizable and reference counted memory buffer.
Definition: DynamicBuffer.h:42
Declaration of ClockT.
TableInfoPtr table_info
TableInfo object for destination table.
uint64_t cluster_id
Cluster from which these updates originated.
Hypertable definitions
TableIdentifier id
Table identifier for destination table.
Declarations for TableInfo.
std::shared_ptr< TableInfo > TableInfoPtr
Smart pointer to TableInfo.
Definition: TableInfo.h:312
Declarations for UpdateRequest.
Declarations for UpdateRecRange.