| changeset 2864 | 2e0b0af889be |
| parent 2309 | be1b94099f2d |
| 2862:27971a13089f | 2864:2e0b0af889be |
|---|---|
20 import dummy_thread as thread |
20 import dummy_thread as thread |
21 |
21 |
22 __pychecker__ = """maxreturns=0 maxbranches=0 no-callinit |
22 __pychecker__ = """maxreturns=0 maxbranches=0 no-callinit |
23 unusednames=printElemNumber,debug_strs no-special""" |
23 unusednames=printElemNumber,debug_strs no-special""" |
24 |
24 |
25 from google.appengine.api.api_base_pb import * |
|
26 class MemcacheServiceError(ProtocolBuffer.ProtocolMessage): |
25 class MemcacheServiceError(ProtocolBuffer.ProtocolMessage): |
27 |
26 |
28 OK = 0 |
27 OK = 0 |
29 UNSPECIFIED_ERROR = 1 |
28 UNSPECIFIED_ERROR = 1 |
30 |
29 |
73 def __str__(self, prefix="", printElemNumber=0): |
72 def __str__(self, prefix="", printElemNumber=0): |
74 res="" |
73 res="" |
75 return res |
74 return res |
76 |
75 |
77 |
76 |
78 _TEXT = ( |
77 def _BuildTagLookupTable(sparse, maxtag, default=None): |
79 "ErrorCode", |
78 return tuple([sparse.get(i, default) for i in xrange(0, 1+maxtag)]) |
80 ) |
79 |
81 |
80 |
82 _TYPES = ( |
81 _TEXT = _BuildTagLookupTable({ |
83 ProtocolBuffer.Encoder.NUMERIC, |
82 0: "ErrorCode", |
84 ) |
83 }, 0) |
84 |
|
85 _TYPES = _BuildTagLookupTable({ |
|
86 0: ProtocolBuffer.Encoder.NUMERIC, |
|
87 }, 0, ProtocolBuffer.Encoder.MAX_TYPE) |
|
85 |
88 |
86 _STYLE = """""" |
89 _STYLE = """""" |
87 _STYLE_CONTENT_TYPE = """""" |
90 _STYLE_CONTENT_TYPE = """""" |
88 class MemcacheGetRequest(ProtocolBuffer.ProtocolMessage): |
91 class MemcacheGetRequest(ProtocolBuffer.ProtocolMessage): |
89 has_name_space_ = 0 |
92 has_name_space_ = 0 |
181 res+=prefix+("key%s: %s\n" % (elm, self.DebugFormatString(e))) |
184 res+=prefix+("key%s: %s\n" % (elm, self.DebugFormatString(e))) |
182 cnt+=1 |
185 cnt+=1 |
183 if self.has_name_space_: res+=prefix+("name_space: %s\n" % self.DebugFormatString(self.name_space_)) |
186 if self.has_name_space_: res+=prefix+("name_space: %s\n" % self.DebugFormatString(self.name_space_)) |
184 return res |
187 return res |
185 |
188 |
189 |
|
190 def _BuildTagLookupTable(sparse, maxtag, default=None): |
|
191 return tuple([sparse.get(i, default) for i in xrange(0, 1+maxtag)]) |
|
192 |
|
186 kkey = 1 |
193 kkey = 1 |
187 kname_space = 2 |
194 kname_space = 2 |
188 |
195 |
189 _TEXT = ( |
196 _TEXT = _BuildTagLookupTable({ |
190 "ErrorCode", |
197 0: "ErrorCode", |
191 "key", |
198 1: "key", |
192 "name_space", |
199 2: "name_space", |
193 ) |
200 }, 2) |
194 |
201 |
195 _TYPES = ( |
202 _TYPES = _BuildTagLookupTable({ |
196 ProtocolBuffer.Encoder.NUMERIC, |
203 0: ProtocolBuffer.Encoder.NUMERIC, |
197 ProtocolBuffer.Encoder.STRING, |
204 1: ProtocolBuffer.Encoder.STRING, |
198 |
205 2: ProtocolBuffer.Encoder.STRING, |
199 ProtocolBuffer.Encoder.STRING, |
206 }, 2, ProtocolBuffer.Encoder.MAX_TYPE) |
200 |
|
201 ) |
|
202 |
207 |
203 _STYLE = """""" |
208 _STYLE = """""" |
204 _STYLE_CONTENT_TYPE = """""" |
209 _STYLE_CONTENT_TYPE = """""" |
205 class MemcacheGetResponse_Item(ProtocolBuffer.ProtocolMessage): |
210 class MemcacheGetResponse_Item(ProtocolBuffer.ProtocolMessage): |
206 has_key_ = 0 |
211 has_key_ = 0 |
401 res+=e.__str__(prefix + " ", printElemNumber) |
406 res+=e.__str__(prefix + " ", printElemNumber) |
402 res+=prefix+"}\n" |
407 res+=prefix+"}\n" |
403 cnt+=1 |
408 cnt+=1 |
404 return res |
409 return res |
405 |
410 |
411 |
|
412 def _BuildTagLookupTable(sparse, maxtag, default=None): |
|
413 return tuple([sparse.get(i, default) for i in xrange(0, 1+maxtag)]) |
|
414 |
|
406 kItemGroup = 1 |
415 kItemGroup = 1 |
407 kItemkey = 2 |
416 kItemkey = 2 |
408 kItemvalue = 3 |
417 kItemvalue = 3 |
409 kItemflags = 4 |
418 kItemflags = 4 |
410 |
419 |
411 _TEXT = ( |
420 _TEXT = _BuildTagLookupTable({ |
412 "ErrorCode", |
421 0: "ErrorCode", |
413 "Item", |
422 1: "Item", |
414 "key", |
423 2: "key", |
415 "value", |
424 3: "value", |
416 "flags", |
425 4: "flags", |
417 ) |
426 }, 4) |
418 |
427 |
419 _TYPES = ( |
428 _TYPES = _BuildTagLookupTable({ |
420 ProtocolBuffer.Encoder.NUMERIC, |
429 0: ProtocolBuffer.Encoder.NUMERIC, |
421 ProtocolBuffer.Encoder.STARTGROUP, |
430 1: ProtocolBuffer.Encoder.STARTGROUP, |
422 |
431 2: ProtocolBuffer.Encoder.STRING, |
423 ProtocolBuffer.Encoder.STRING, |
432 3: ProtocolBuffer.Encoder.STRING, |
424 |
433 4: ProtocolBuffer.Encoder.FLOAT, |
425 ProtocolBuffer.Encoder.STRING, |
434 }, 4, ProtocolBuffer.Encoder.MAX_TYPE) |
426 |
|
427 ProtocolBuffer.Encoder.FLOAT, |
|
428 |
|
429 ) |
|
430 |
435 |
431 _STYLE = """""" |
436 _STYLE = """""" |
432 _STYLE_CONTENT_TYPE = """""" |
437 _STYLE_CONTENT_TYPE = """""" |
433 class MemcacheSetRequest_Item(ProtocolBuffer.ProtocolMessage): |
438 class MemcacheSetRequest_Item(ProtocolBuffer.ProtocolMessage): |
434 has_key_ = 0 |
439 has_key_ = 0 |
724 res+=prefix+"}\n" |
729 res+=prefix+"}\n" |
725 cnt+=1 |
730 cnt+=1 |
726 if self.has_name_space_: res+=prefix+("name_space: %s\n" % self.DebugFormatString(self.name_space_)) |
731 if self.has_name_space_: res+=prefix+("name_space: %s\n" % self.DebugFormatString(self.name_space_)) |
727 return res |
732 return res |
728 |
733 |
734 |
|
735 def _BuildTagLookupTable(sparse, maxtag, default=None): |
|
736 return tuple([sparse.get(i, default) for i in xrange(0, 1+maxtag)]) |
|
737 |
|
729 kItemGroup = 1 |
738 kItemGroup = 1 |
730 kItemkey = 2 |
739 kItemkey = 2 |
731 kItemvalue = 3 |
740 kItemvalue = 3 |
732 kItemflags = 4 |
741 kItemflags = 4 |
733 kItemset_policy = 5 |
742 kItemset_policy = 5 |
734 kItemexpiration_time = 6 |
743 kItemexpiration_time = 6 |
735 kname_space = 7 |
744 kname_space = 7 |
736 |
745 |
737 _TEXT = ( |
746 _TEXT = _BuildTagLookupTable({ |
738 "ErrorCode", |
747 0: "ErrorCode", |
739 "Item", |
748 1: "Item", |
740 "key", |
749 2: "key", |
741 "value", |
750 3: "value", |
742 "flags", |
751 4: "flags", |
743 "set_policy", |
752 5: "set_policy", |
744 "expiration_time", |
753 6: "expiration_time", |
745 "name_space", |
754 7: "name_space", |
746 ) |
755 }, 7) |
747 |
756 |
748 _TYPES = ( |
757 _TYPES = _BuildTagLookupTable({ |
749 ProtocolBuffer.Encoder.NUMERIC, |
758 0: ProtocolBuffer.Encoder.NUMERIC, |
750 ProtocolBuffer.Encoder.STARTGROUP, |
759 1: ProtocolBuffer.Encoder.STARTGROUP, |
751 |
760 2: ProtocolBuffer.Encoder.STRING, |
752 ProtocolBuffer.Encoder.STRING, |
761 3: ProtocolBuffer.Encoder.STRING, |
753 |
762 4: ProtocolBuffer.Encoder.FLOAT, |
754 ProtocolBuffer.Encoder.STRING, |
763 5: ProtocolBuffer.Encoder.NUMERIC, |
755 |
764 6: ProtocolBuffer.Encoder.FLOAT, |
756 ProtocolBuffer.Encoder.FLOAT, |
765 7: ProtocolBuffer.Encoder.STRING, |
757 |
766 }, 7, ProtocolBuffer.Encoder.MAX_TYPE) |
758 ProtocolBuffer.Encoder.NUMERIC, |
|
759 |
|
760 ProtocolBuffer.Encoder.FLOAT, |
|
761 |
|
762 ProtocolBuffer.Encoder.STRING, |
|
763 |
|
764 ) |
|
765 |
767 |
766 _STYLE = """""" |
768 _STYLE = """""" |
767 _STYLE_CONTENT_TYPE = """""" |
769 _STYLE_CONTENT_TYPE = """""" |
768 class MemcacheSetResponse(ProtocolBuffer.ProtocolMessage): |
770 class MemcacheSetResponse(ProtocolBuffer.ProtocolMessage): |
769 |
771 |
848 if printElemNumber: elm="(%d)" % cnt |
850 if printElemNumber: elm="(%d)" % cnt |
849 res+=prefix+("set_status%s: %s\n" % (elm, self.DebugFormatInt32(e))) |
851 res+=prefix+("set_status%s: %s\n" % (elm, self.DebugFormatInt32(e))) |
850 cnt+=1 |
852 cnt+=1 |
851 return res |
853 return res |
852 |
854 |
855 |
|
856 def _BuildTagLookupTable(sparse, maxtag, default=None): |
|
857 return tuple([sparse.get(i, default) for i in xrange(0, 1+maxtag)]) |
|
858 |
|
853 kset_status = 1 |
859 kset_status = 1 |
854 |
860 |
855 _TEXT = ( |
861 _TEXT = _BuildTagLookupTable({ |
856 "ErrorCode", |
862 0: "ErrorCode", |
857 "set_status", |
863 1: "set_status", |
858 ) |
864 }, 1) |
859 |
865 |
860 _TYPES = ( |
866 _TYPES = _BuildTagLookupTable({ |
861 ProtocolBuffer.Encoder.NUMERIC, |
867 0: ProtocolBuffer.Encoder.NUMERIC, |
862 ProtocolBuffer.Encoder.NUMERIC, |
868 1: ProtocolBuffer.Encoder.NUMERIC, |
863 |
869 }, 1, ProtocolBuffer.Encoder.MAX_TYPE) |
864 ) |
|
865 |
870 |
866 _STYLE = """""" |
871 _STYLE = """""" |
867 _STYLE_CONTENT_TYPE = """""" |
872 _STYLE_CONTENT_TYPE = """""" |
868 class MemcacheDeleteRequest_Item(ProtocolBuffer.ProtocolMessage): |
873 class MemcacheDeleteRequest_Item(ProtocolBuffer.ProtocolMessage): |
869 has_key_ = 0 |
874 has_key_ = 0 |
1061 res+=prefix+"}\n" |
1066 res+=prefix+"}\n" |
1062 cnt+=1 |
1067 cnt+=1 |
1063 if self.has_name_space_: res+=prefix+("name_space: %s\n" % self.DebugFormatString(self.name_space_)) |
1068 if self.has_name_space_: res+=prefix+("name_space: %s\n" % self.DebugFormatString(self.name_space_)) |
1064 return res |
1069 return res |
1065 |
1070 |
1071 |
|
1072 def _BuildTagLookupTable(sparse, maxtag, default=None): |
|
1073 return tuple([sparse.get(i, default) for i in xrange(0, 1+maxtag)]) |
|
1074 |
|
1066 kItemGroup = 1 |
1075 kItemGroup = 1 |
1067 kItemkey = 2 |
1076 kItemkey = 2 |
1068 kItemdelete_time = 3 |
1077 kItemdelete_time = 3 |
1069 kname_space = 4 |
1078 kname_space = 4 |
1070 |
1079 |
1071 _TEXT = ( |
1080 _TEXT = _BuildTagLookupTable({ |
1072 "ErrorCode", |
1081 0: "ErrorCode", |
1073 "Item", |
1082 1: "Item", |
1074 "key", |
1083 2: "key", |
1075 "delete_time", |
1084 3: "delete_time", |
1076 "name_space", |
1085 4: "name_space", |
1077 ) |
1086 }, 4) |
1078 |
1087 |
1079 _TYPES = ( |
1088 _TYPES = _BuildTagLookupTable({ |
1080 ProtocolBuffer.Encoder.NUMERIC, |
1089 0: ProtocolBuffer.Encoder.NUMERIC, |
1081 ProtocolBuffer.Encoder.STARTGROUP, |
1090 1: ProtocolBuffer.Encoder.STARTGROUP, |
1082 |
1091 2: ProtocolBuffer.Encoder.STRING, |
1083 ProtocolBuffer.Encoder.STRING, |
1092 3: ProtocolBuffer.Encoder.FLOAT, |
1084 |
1093 4: ProtocolBuffer.Encoder.STRING, |
1085 ProtocolBuffer.Encoder.FLOAT, |
1094 }, 4, ProtocolBuffer.Encoder.MAX_TYPE) |
1086 |
|
1087 ProtocolBuffer.Encoder.STRING, |
|
1088 |
|
1089 ) |
|
1090 |
1095 |
1091 _STYLE = """""" |
1096 _STYLE = """""" |
1092 _STYLE_CONTENT_TYPE = """""" |
1097 _STYLE_CONTENT_TYPE = """""" |
1093 class MemcacheDeleteResponse(ProtocolBuffer.ProtocolMessage): |
1098 class MemcacheDeleteResponse(ProtocolBuffer.ProtocolMessage): |
1094 |
1099 |
1171 if printElemNumber: elm="(%d)" % cnt |
1176 if printElemNumber: elm="(%d)" % cnt |
1172 res+=prefix+("delete_status%s: %s\n" % (elm, self.DebugFormatInt32(e))) |
1177 res+=prefix+("delete_status%s: %s\n" % (elm, self.DebugFormatInt32(e))) |
1173 cnt+=1 |
1178 cnt+=1 |
1174 return res |
1179 return res |
1175 |
1180 |
1181 |
|
1182 def _BuildTagLookupTable(sparse, maxtag, default=None): |
|
1183 return tuple([sparse.get(i, default) for i in xrange(0, 1+maxtag)]) |
|
1184 |
|
1176 kdelete_status = 1 |
1185 kdelete_status = 1 |
1177 |
1186 |
1178 _TEXT = ( |
1187 _TEXT = _BuildTagLookupTable({ |
1179 "ErrorCode", |
1188 0: "ErrorCode", |
1180 "delete_status", |
1189 1: "delete_status", |
1181 ) |
1190 }, 1) |
1182 |
1191 |
1183 _TYPES = ( |
1192 _TYPES = _BuildTagLookupTable({ |
1184 ProtocolBuffer.Encoder.NUMERIC, |
1193 0: ProtocolBuffer.Encoder.NUMERIC, |
1185 ProtocolBuffer.Encoder.NUMERIC, |
1194 1: ProtocolBuffer.Encoder.NUMERIC, |
1186 |
1195 }, 1, ProtocolBuffer.Encoder.MAX_TYPE) |
1187 ) |
|
1188 |
1196 |
1189 _STYLE = """""" |
1197 _STYLE = """""" |
1190 _STYLE_CONTENT_TYPE = """""" |
1198 _STYLE_CONTENT_TYPE = """""" |
1191 class MemcacheIncrementRequest(ProtocolBuffer.ProtocolMessage): |
1199 class MemcacheIncrementRequest(ProtocolBuffer.ProtocolMessage): |
1192 |
1200 |
1207 name_space_ = "" |
1215 name_space_ = "" |
1208 has_delta_ = 0 |
1216 has_delta_ = 0 |
1209 delta_ = 1 |
1217 delta_ = 1 |
1210 has_direction_ = 0 |
1218 has_direction_ = 0 |
1211 direction_ = 1 |
1219 direction_ = 1 |
1220 has_initial_value_ = 0 |
|
1221 initial_value_ = 0 |
|
1212 |
1222 |
1213 def __init__(self, contents=None): |
1223 def __init__(self, contents=None): |
1214 if contents is not None: self.MergeFromString(contents) |
1224 if contents is not None: self.MergeFromString(contents) |
1215 |
1225 |
1216 def key(self): return self.key_ |
1226 def key(self): return self.key_ |
1262 if self.has_direction_: |
1272 if self.has_direction_: |
1263 self.has_direction_ = 0 |
1273 self.has_direction_ = 0 |
1264 self.direction_ = 1 |
1274 self.direction_ = 1 |
1265 |
1275 |
1266 def has_direction(self): return self.has_direction_ |
1276 def has_direction(self): return self.has_direction_ |
1277 |
|
1278 def initial_value(self): return self.initial_value_ |
|
1279 |
|
1280 def set_initial_value(self, x): |
|
1281 self.has_initial_value_ = 1 |
|
1282 self.initial_value_ = x |
|
1283 |
|
1284 def clear_initial_value(self): |
|
1285 if self.has_initial_value_: |
|
1286 self.has_initial_value_ = 0 |
|
1287 self.initial_value_ = 0 |
|
1288 |
|
1289 def has_initial_value(self): return self.has_initial_value_ |
|
1267 |
1290 |
1268 |
1291 |
1269 def MergeFrom(self, x): |
1292 def MergeFrom(self, x): |
1270 assert x is not self |
1293 assert x is not self |
1271 if (x.has_key()): self.set_key(x.key()) |
1294 if (x.has_key()): self.set_key(x.key()) |
1272 if (x.has_name_space()): self.set_name_space(x.name_space()) |
1295 if (x.has_name_space()): self.set_name_space(x.name_space()) |
1273 if (x.has_delta()): self.set_delta(x.delta()) |
1296 if (x.has_delta()): self.set_delta(x.delta()) |
1274 if (x.has_direction()): self.set_direction(x.direction()) |
1297 if (x.has_direction()): self.set_direction(x.direction()) |
1298 if (x.has_initial_value()): self.set_initial_value(x.initial_value()) |
|
1275 |
1299 |
1276 def Equals(self, x): |
1300 def Equals(self, x): |
1277 if x is self: return 1 |
1301 if x is self: return 1 |
1278 if self.has_key_ != x.has_key_: return 0 |
1302 if self.has_key_ != x.has_key_: return 0 |
1279 if self.has_key_ and self.key_ != x.key_: return 0 |
1303 if self.has_key_ and self.key_ != x.key_: return 0 |
1281 if self.has_name_space_ and self.name_space_ != x.name_space_: return 0 |
1305 if self.has_name_space_ and self.name_space_ != x.name_space_: return 0 |
1282 if self.has_delta_ != x.has_delta_: return 0 |
1306 if self.has_delta_ != x.has_delta_: return 0 |
1283 if self.has_delta_ and self.delta_ != x.delta_: return 0 |
1307 if self.has_delta_ and self.delta_ != x.delta_: return 0 |
1284 if self.has_direction_ != x.has_direction_: return 0 |
1308 if self.has_direction_ != x.has_direction_: return 0 |
1285 if self.has_direction_ and self.direction_ != x.direction_: return 0 |
1309 if self.has_direction_ and self.direction_ != x.direction_: return 0 |
1310 if self.has_initial_value_ != x.has_initial_value_: return 0 |
|
1311 if self.has_initial_value_ and self.initial_value_ != x.initial_value_: return 0 |
|
1286 return 1 |
1312 return 1 |
1287 |
1313 |
1288 def IsInitialized(self, debug_strs=None): |
1314 def IsInitialized(self, debug_strs=None): |
1289 initialized = 1 |
1315 initialized = 1 |
1290 if (not self.has_key_): |
1316 if (not self.has_key_): |
1297 n = 0 |
1323 n = 0 |
1298 n += self.lengthString(len(self.key_)) |
1324 n += self.lengthString(len(self.key_)) |
1299 if (self.has_name_space_): n += 1 + self.lengthString(len(self.name_space_)) |
1325 if (self.has_name_space_): n += 1 + self.lengthString(len(self.name_space_)) |
1300 if (self.has_delta_): n += 1 + self.lengthVarInt64(self.delta_) |
1326 if (self.has_delta_): n += 1 + self.lengthVarInt64(self.delta_) |
1301 if (self.has_direction_): n += 1 + self.lengthVarInt64(self.direction_) |
1327 if (self.has_direction_): n += 1 + self.lengthVarInt64(self.direction_) |
1328 if (self.has_initial_value_): n += 1 + self.lengthVarInt64(self.initial_value_) |
|
1302 return n + 1 |
1329 return n + 1 |
1303 |
1330 |
1304 def Clear(self): |
1331 def Clear(self): |
1305 self.clear_key() |
1332 self.clear_key() |
1306 self.clear_name_space() |
1333 self.clear_name_space() |
1307 self.clear_delta() |
1334 self.clear_delta() |
1308 self.clear_direction() |
1335 self.clear_direction() |
1336 self.clear_initial_value() |
|
1309 |
1337 |
1310 def OutputUnchecked(self, out): |
1338 def OutputUnchecked(self, out): |
1311 out.putVarInt32(10) |
1339 out.putVarInt32(10) |
1312 out.putPrefixedString(self.key_) |
1340 out.putPrefixedString(self.key_) |
1313 if (self.has_delta_): |
1341 if (self.has_delta_): |
1317 out.putVarInt32(24) |
1345 out.putVarInt32(24) |
1318 out.putVarInt32(self.direction_) |
1346 out.putVarInt32(self.direction_) |
1319 if (self.has_name_space_): |
1347 if (self.has_name_space_): |
1320 out.putVarInt32(34) |
1348 out.putVarInt32(34) |
1321 out.putPrefixedString(self.name_space_) |
1349 out.putPrefixedString(self.name_space_) |
1350 if (self.has_initial_value_): |
|
1351 out.putVarInt32(40) |
|
1352 out.putVarUint64(self.initial_value_) |
|
1322 |
1353 |
1323 def TryMerge(self, d): |
1354 def TryMerge(self, d): |
1324 while d.avail() > 0: |
1355 while d.avail() > 0: |
1325 tt = d.getVarInt32() |
1356 tt = d.getVarInt32() |
1326 if tt == 10: |
1357 if tt == 10: |
1332 if tt == 24: |
1363 if tt == 24: |
1333 self.set_direction(d.getVarInt32()) |
1364 self.set_direction(d.getVarInt32()) |
1334 continue |
1365 continue |
1335 if tt == 34: |
1366 if tt == 34: |
1336 self.set_name_space(d.getPrefixedString()) |
1367 self.set_name_space(d.getPrefixedString()) |
1368 continue |
|
1369 if tt == 40: |
|
1370 self.set_initial_value(d.getVarUint64()) |
|
1337 continue |
1371 continue |
1338 if (tt == 0): raise ProtocolBuffer.ProtocolBufferDecodeError |
1372 if (tt == 0): raise ProtocolBuffer.ProtocolBufferDecodeError |
1339 d.skipData(tt) |
1373 d.skipData(tt) |
1340 |
1374 |
1341 |
1375 |
1343 res="" |
1377 res="" |
1344 if self.has_key_: res+=prefix+("key: %s\n" % self.DebugFormatString(self.key_)) |
1378 if self.has_key_: res+=prefix+("key: %s\n" % self.DebugFormatString(self.key_)) |
1345 if self.has_name_space_: res+=prefix+("name_space: %s\n" % self.DebugFormatString(self.name_space_)) |
1379 if self.has_name_space_: res+=prefix+("name_space: %s\n" % self.DebugFormatString(self.name_space_)) |
1346 if self.has_delta_: res+=prefix+("delta: %s\n" % self.DebugFormatInt64(self.delta_)) |
1380 if self.has_delta_: res+=prefix+("delta: %s\n" % self.DebugFormatInt64(self.delta_)) |
1347 if self.has_direction_: res+=prefix+("direction: %s\n" % self.DebugFormatInt32(self.direction_)) |
1381 if self.has_direction_: res+=prefix+("direction: %s\n" % self.DebugFormatInt32(self.direction_)) |
1382 if self.has_initial_value_: res+=prefix+("initial_value: %s\n" % self.DebugFormatInt64(self.initial_value_)) |
|
1348 return res |
1383 return res |
1384 |
|
1385 |
|
1386 def _BuildTagLookupTable(sparse, maxtag, default=None): |
|
1387 return tuple([sparse.get(i, default) for i in xrange(0, 1+maxtag)]) |
|
1349 |
1388 |
1350 kkey = 1 |
1389 kkey = 1 |
1351 kname_space = 4 |
1390 kname_space = 4 |
1352 kdelta = 2 |
1391 kdelta = 2 |
1353 kdirection = 3 |
1392 kdirection = 3 |
1354 |
1393 kinitial_value = 5 |
1355 _TEXT = ( |
1394 |
1356 "ErrorCode", |
1395 _TEXT = _BuildTagLookupTable({ |
1357 "key", |
1396 0: "ErrorCode", |
1358 "delta", |
1397 1: "key", |
1359 "direction", |
1398 2: "delta", |
1360 "name_space", |
1399 3: "direction", |
1361 ) |
1400 4: "name_space", |
1362 |
1401 5: "initial_value", |
1363 _TYPES = ( |
1402 }, 5) |
1364 ProtocolBuffer.Encoder.NUMERIC, |
1403 |
1365 ProtocolBuffer.Encoder.STRING, |
1404 _TYPES = _BuildTagLookupTable({ |
1366 |
1405 0: ProtocolBuffer.Encoder.NUMERIC, |
1367 ProtocolBuffer.Encoder.NUMERIC, |
1406 1: ProtocolBuffer.Encoder.STRING, |
1368 |
1407 2: ProtocolBuffer.Encoder.NUMERIC, |
1369 ProtocolBuffer.Encoder.NUMERIC, |
1408 3: ProtocolBuffer.Encoder.NUMERIC, |
1370 |
1409 4: ProtocolBuffer.Encoder.STRING, |
1371 ProtocolBuffer.Encoder.STRING, |
1410 5: ProtocolBuffer.Encoder.NUMERIC, |
1372 |
1411 }, 5, ProtocolBuffer.Encoder.MAX_TYPE) |
1373 ) |
|
1374 |
1412 |
1375 _STYLE = """""" |
1413 _STYLE = """""" |
1376 _STYLE_CONTENT_TYPE = """""" |
1414 _STYLE_CONTENT_TYPE = """""" |
1377 class MemcacheIncrementResponse(ProtocolBuffer.ProtocolMessage): |
1415 class MemcacheIncrementResponse(ProtocolBuffer.ProtocolMessage): |
1378 has_new_value_ = 0 |
1416 has_new_value_ = 0 |
1435 def __str__(self, prefix="", printElemNumber=0): |
1473 def __str__(self, prefix="", printElemNumber=0): |
1436 res="" |
1474 res="" |
1437 if self.has_new_value_: res+=prefix+("new_value: %s\n" % self.DebugFormatInt64(self.new_value_)) |
1475 if self.has_new_value_: res+=prefix+("new_value: %s\n" % self.DebugFormatInt64(self.new_value_)) |
1438 return res |
1476 return res |
1439 |
1477 |
1478 |
|
1479 def _BuildTagLookupTable(sparse, maxtag, default=None): |
|
1480 return tuple([sparse.get(i, default) for i in xrange(0, 1+maxtag)]) |
|
1481 |
|
1440 knew_value = 1 |
1482 knew_value = 1 |
1441 |
1483 |
1442 _TEXT = ( |
1484 _TEXT = _BuildTagLookupTable({ |
1443 "ErrorCode", |
1485 0: "ErrorCode", |
1444 "new_value", |
1486 1: "new_value", |
1445 ) |
1487 }, 1) |
1446 |
1488 |
1447 _TYPES = ( |
1489 _TYPES = _BuildTagLookupTable({ |
1448 ProtocolBuffer.Encoder.NUMERIC, |
1490 0: ProtocolBuffer.Encoder.NUMERIC, |
1449 ProtocolBuffer.Encoder.NUMERIC, |
1491 1: ProtocolBuffer.Encoder.NUMERIC, |
1450 |
1492 }, 1, ProtocolBuffer.Encoder.MAX_TYPE) |
1451 ) |
|
1452 |
1493 |
1453 _STYLE = """""" |
1494 _STYLE = """""" |
1454 _STYLE_CONTENT_TYPE = """""" |
1495 _STYLE_CONTENT_TYPE = """""" |
1455 class MemcacheFlushRequest(ProtocolBuffer.ProtocolMessage): |
1496 class MemcacheFlushRequest(ProtocolBuffer.ProtocolMessage): |
1456 |
1497 |
1490 def __str__(self, prefix="", printElemNumber=0): |
1531 def __str__(self, prefix="", printElemNumber=0): |
1491 res="" |
1532 res="" |
1492 return res |
1533 return res |
1493 |
1534 |
1494 |
1535 |
1495 _TEXT = ( |
1536 def _BuildTagLookupTable(sparse, maxtag, default=None): |
1496 "ErrorCode", |
1537 return tuple([sparse.get(i, default) for i in xrange(0, 1+maxtag)]) |
1497 ) |
1538 |
1498 |
1539 |
1499 _TYPES = ( |
1540 _TEXT = _BuildTagLookupTable({ |
1500 ProtocolBuffer.Encoder.NUMERIC, |
1541 0: "ErrorCode", |
1501 ) |
1542 }, 0) |
1543 |
|
1544 _TYPES = _BuildTagLookupTable({ |
|
1545 0: ProtocolBuffer.Encoder.NUMERIC, |
|
1546 }, 0, ProtocolBuffer.Encoder.MAX_TYPE) |
|
1502 |
1547 |
1503 _STYLE = """""" |
1548 _STYLE = """""" |
1504 _STYLE_CONTENT_TYPE = """""" |
1549 _STYLE_CONTENT_TYPE = """""" |
1505 class MemcacheFlushResponse(ProtocolBuffer.ProtocolMessage): |
1550 class MemcacheFlushResponse(ProtocolBuffer.ProtocolMessage): |
1506 |
1551 |
1540 def __str__(self, prefix="", printElemNumber=0): |
1585 def __str__(self, prefix="", printElemNumber=0): |
1541 res="" |
1586 res="" |
1542 return res |
1587 return res |
1543 |
1588 |
1544 |
1589 |
1545 _TEXT = ( |
1590 def _BuildTagLookupTable(sparse, maxtag, default=None): |
1546 "ErrorCode", |
1591 return tuple([sparse.get(i, default) for i in xrange(0, 1+maxtag)]) |
1547 ) |
1592 |
1548 |
1593 |
1549 _TYPES = ( |
1594 _TEXT = _BuildTagLookupTable({ |
1550 ProtocolBuffer.Encoder.NUMERIC, |
1595 0: "ErrorCode", |
1551 ) |
1596 }, 0) |
1597 |
|
1598 _TYPES = _BuildTagLookupTable({ |
|
1599 0: ProtocolBuffer.Encoder.NUMERIC, |
|
1600 }, 0, ProtocolBuffer.Encoder.MAX_TYPE) |
|
1552 |
1601 |
1553 _STYLE = """""" |
1602 _STYLE = """""" |
1554 _STYLE_CONTENT_TYPE = """""" |
1603 _STYLE_CONTENT_TYPE = """""" |
1555 class MemcacheStatsRequest(ProtocolBuffer.ProtocolMessage): |
1604 class MemcacheStatsRequest(ProtocolBuffer.ProtocolMessage): |
1556 |
1605 |
1590 def __str__(self, prefix="", printElemNumber=0): |
1639 def __str__(self, prefix="", printElemNumber=0): |
1591 res="" |
1640 res="" |
1592 return res |
1641 return res |
1593 |
1642 |
1594 |
1643 |
1595 _TEXT = ( |
1644 def _BuildTagLookupTable(sparse, maxtag, default=None): |
1596 "ErrorCode", |
1645 return tuple([sparse.get(i, default) for i in xrange(0, 1+maxtag)]) |
1597 ) |
1646 |
1598 |
1647 |
1599 _TYPES = ( |
1648 _TEXT = _BuildTagLookupTable({ |
1600 ProtocolBuffer.Encoder.NUMERIC, |
1649 0: "ErrorCode", |
1601 ) |
1650 }, 0) |
1651 |
|
1652 _TYPES = _BuildTagLookupTable({ |
|
1653 0: ProtocolBuffer.Encoder.NUMERIC, |
|
1654 }, 0, ProtocolBuffer.Encoder.MAX_TYPE) |
|
1602 |
1655 |
1603 _STYLE = """""" |
1656 _STYLE = """""" |
1604 _STYLE_CONTENT_TYPE = """""" |
1657 _STYLE_CONTENT_TYPE = """""" |
1605 class MergedNamespaceStats(ProtocolBuffer.ProtocolMessage): |
1658 class MergedNamespaceStats(ProtocolBuffer.ProtocolMessage): |
1606 has_hits_ = 0 |
1659 has_hits_ = 0 |
1815 if self.has_items_: res+=prefix+("items: %s\n" % self.DebugFormatInt64(self.items_)) |
1868 if self.has_items_: res+=prefix+("items: %s\n" % self.DebugFormatInt64(self.items_)) |
1816 if self.has_bytes_: res+=prefix+("bytes: %s\n" % self.DebugFormatInt64(self.bytes_)) |
1869 if self.has_bytes_: res+=prefix+("bytes: %s\n" % self.DebugFormatInt64(self.bytes_)) |
1817 if self.has_oldest_item_age_: res+=prefix+("oldest_item_age: %s\n" % self.DebugFormatFixed32(self.oldest_item_age_)) |
1870 if self.has_oldest_item_age_: res+=prefix+("oldest_item_age: %s\n" % self.DebugFormatFixed32(self.oldest_item_age_)) |
1818 return res |
1871 return res |
1819 |
1872 |
1873 |
|
1874 def _BuildTagLookupTable(sparse, maxtag, default=None): |
|
1875 return tuple([sparse.get(i, default) for i in xrange(0, 1+maxtag)]) |
|
1876 |
|
1820 khits = 1 |
1877 khits = 1 |
1821 kmisses = 2 |
1878 kmisses = 2 |
1822 kbyte_hits = 3 |
1879 kbyte_hits = 3 |
1823 kitems = 4 |
1880 kitems = 4 |
1824 kbytes = 5 |
1881 kbytes = 5 |
1825 koldest_item_age = 6 |
1882 koldest_item_age = 6 |
1826 |
1883 |
1827 _TEXT = ( |
1884 _TEXT = _BuildTagLookupTable({ |
1828 "ErrorCode", |
1885 0: "ErrorCode", |
1829 "hits", |
1886 1: "hits", |
1830 "misses", |
1887 2: "misses", |
1831 "byte_hits", |
1888 3: "byte_hits", |
1832 "items", |
1889 4: "items", |
1833 "bytes", |
1890 5: "bytes", |
1834 "oldest_item_age", |
1891 6: "oldest_item_age", |
1835 ) |
1892 }, 6) |
1836 |
1893 |
1837 _TYPES = ( |
1894 _TYPES = _BuildTagLookupTable({ |
1838 ProtocolBuffer.Encoder.NUMERIC, |
1895 0: ProtocolBuffer.Encoder.NUMERIC, |
1839 ProtocolBuffer.Encoder.NUMERIC, |
1896 1: ProtocolBuffer.Encoder.NUMERIC, |
1840 |
1897 2: ProtocolBuffer.Encoder.NUMERIC, |
1841 ProtocolBuffer.Encoder.NUMERIC, |
1898 3: ProtocolBuffer.Encoder.NUMERIC, |
1842 |
1899 4: ProtocolBuffer.Encoder.NUMERIC, |
1843 ProtocolBuffer.Encoder.NUMERIC, |
1900 5: ProtocolBuffer.Encoder.NUMERIC, |
1844 |
1901 6: ProtocolBuffer.Encoder.FLOAT, |
1845 ProtocolBuffer.Encoder.NUMERIC, |
1902 }, 6, ProtocolBuffer.Encoder.MAX_TYPE) |
1846 |
|
1847 ProtocolBuffer.Encoder.NUMERIC, |
|
1848 |
|
1849 ProtocolBuffer.Encoder.FLOAT, |
|
1850 |
|
1851 ) |
|
1852 |
1903 |
1853 _STYLE = """""" |
1904 _STYLE = """""" |
1854 _STYLE_CONTENT_TYPE = """""" |
1905 _STYLE_CONTENT_TYPE = """""" |
1855 class MemcacheStatsResponse(ProtocolBuffer.ProtocolMessage): |
1906 class MemcacheStatsResponse(ProtocolBuffer.ProtocolMessage): |
1856 has_stats_ = 0 |
1907 has_stats_ = 0 |
1927 res+=prefix+"stats <\n" |
1978 res+=prefix+"stats <\n" |
1928 res+=self.stats_.__str__(prefix + " ", printElemNumber) |
1979 res+=self.stats_.__str__(prefix + " ", printElemNumber) |
1929 res+=prefix+">\n" |
1980 res+=prefix+">\n" |
1930 return res |
1981 return res |
1931 |
1982 |
1983 |
|
1984 def _BuildTagLookupTable(sparse, maxtag, default=None): |
|
1985 return tuple([sparse.get(i, default) for i in xrange(0, 1+maxtag)]) |
|
1986 |
|
1932 kstats = 1 |
1987 kstats = 1 |
1933 |
1988 |
1934 _TEXT = ( |
1989 _TEXT = _BuildTagLookupTable({ |
1935 "ErrorCode", |
1990 0: "ErrorCode", |
1936 "stats", |
1991 1: "stats", |
1937 ) |
1992 }, 1) |
1938 |
1993 |
1939 _TYPES = ( |
1994 _TYPES = _BuildTagLookupTable({ |
1940 ProtocolBuffer.Encoder.NUMERIC, |
1995 0: ProtocolBuffer.Encoder.NUMERIC, |
1941 ProtocolBuffer.Encoder.STRING, |
1996 1: ProtocolBuffer.Encoder.STRING, |
1942 |
1997 }, 1, ProtocolBuffer.Encoder.MAX_TYPE) |
1943 ) |
|
1944 |
1998 |
1945 _STYLE = """""" |
1999 _STYLE = """""" |
1946 _STYLE_CONTENT_TYPE = """""" |
2000 _STYLE_CONTENT_TYPE = """""" |
1947 |
2001 |
1948 __all__ = ['MemcacheServiceError','MemcacheGetRequest','MemcacheGetResponse','MemcacheGetResponse_Item','MemcacheSetRequest','MemcacheSetRequest_Item','MemcacheSetResponse','MemcacheDeleteRequest','MemcacheDeleteRequest_Item','MemcacheDeleteResponse','MemcacheIncrementRequest','MemcacheIncrementResponse','MemcacheFlushRequest','MemcacheFlushResponse','MemcacheStatsRequest','MergedNamespaceStats','MemcacheStatsResponse'] |
2002 __all__ = ['MemcacheServiceError','MemcacheGetRequest','MemcacheGetResponse','MemcacheGetResponse_Item','MemcacheSetRequest','MemcacheSetRequest_Item','MemcacheSetResponse','MemcacheDeleteRequest','MemcacheDeleteRequest_Item','MemcacheDeleteResponse','MemcacheIncrementRequest','MemcacheIncrementResponse','MemcacheFlushRequest','MemcacheFlushResponse','MemcacheStatsRequest','MergedNamespaceStats','MemcacheStatsResponse'] |