map.c 25 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810
  1. // Protocol Buffers - Google's data interchange format
  2. // Copyright 2014 Google Inc. All rights reserved.
  3. // https://developers.google.com/protocol-buffers/
  4. //
  5. // Redistribution and use in source and binary forms, with or without
  6. // modification, are permitted provided that the following conditions are
  7. // met:
  8. //
  9. // * Redistributions of source code must retain the above copyright
  10. // notice, this list of conditions and the following disclaimer.
  11. // * Redistributions in binary form must reproduce the above
  12. // copyright notice, this list of conditions and the following disclaimer
  13. // in the documentation and/or other materials provided with the
  14. // distribution.
  15. // * Neither the name of Google Inc. nor the names of its
  16. // contributors may be used to endorse or promote products derived from
  17. // this software without specific prior written permission.
  18. //
  19. // THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
  20. // "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
  21. // LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
  22. // A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
  23. // OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
  24. // SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
  25. // LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
  26. // DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
  27. // THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
  28. // (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
  29. // OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
  30. #include "protobuf.h"
  31. // -----------------------------------------------------------------------------
  32. // Basic map operations on top of upb's strtable.
  33. //
  34. // Note that we roll our own `Map` container here because, as for
  35. // `RepeatedField`, we want a strongly-typed container. This is so that any user
  36. // errors due to incorrect map key or value types are raised as close as
  37. // possible to the error site, rather than at some deferred point (e.g.,
  38. // serialization).
  39. //
  40. // We build our `Map` on top of upb_strtable so that we're able to take
  41. // advantage of the native_slot storage abstraction, as RepeatedField does.
  42. // (This is not quite a perfect mapping -- see the key conversions below -- but
  43. // gives us full support and error-checking for all value types for free.)
  44. // -----------------------------------------------------------------------------
  45. // Map values are stored using the native_slot abstraction (as with repeated
  46. // field values), but keys are a bit special. Since we use a strtable, we need
  47. // to store keys as sequences of bytes such that equality of those bytes maps
  48. // one-to-one to equality of keys. We store strings directly (i.e., they map to
  49. // their own bytes) and integers as native integers (using the native_slot
  50. // abstraction).
  51. // Note that there is another tradeoff here in keeping string keys as native
  52. // strings rather than Ruby strings: traversing the Map requires conversion to
  53. // Ruby string values on every traversal, potentially creating more garbage. We
  54. // should consider ways to cache a Ruby version of the key if this becomes an
  55. // issue later.
  56. // Forms a key to use with the underlying strtable from a Ruby key value. |buf|
  57. // must point to TABLE_KEY_BUF_LENGTH bytes of temporary space, used to
  58. // construct a key byte sequence if needed. |out_key| and |out_length| provide
  59. // the resulting key data/length.
  60. #define TABLE_KEY_BUF_LENGTH 8 // sizeof(uint64_t)
  61. static VALUE table_key(Map* self, VALUE key,
  62. char* buf,
  63. const char** out_key,
  64. size_t* out_length) {
  65. switch (self->key_type) {
  66. case UPB_TYPE_BYTES:
  67. case UPB_TYPE_STRING:
  68. // Strings: use string content directly.
  69. Check_Type(key, T_STRING);
  70. key = native_slot_encode_and_freeze_string(self->key_type, key);
  71. *out_key = RSTRING_PTR(key);
  72. *out_length = RSTRING_LEN(key);
  73. break;
  74. case UPB_TYPE_BOOL:
  75. case UPB_TYPE_INT32:
  76. case UPB_TYPE_INT64:
  77. case UPB_TYPE_UINT32:
  78. case UPB_TYPE_UINT64:
  79. native_slot_set(self->key_type, Qnil, buf, key);
  80. *out_key = buf;
  81. *out_length = native_slot_size(self->key_type);
  82. break;
  83. default:
  84. // Map constructor should not allow a Map with another key type to be
  85. // constructed.
  86. assert(false);
  87. break;
  88. }
  89. return key;
  90. }
  91. static VALUE table_key_to_ruby(Map* self, const char* buf, size_t length) {
  92. switch (self->key_type) {
  93. case UPB_TYPE_BYTES:
  94. case UPB_TYPE_STRING: {
  95. VALUE ret = rb_str_new(buf, length);
  96. rb_enc_associate(ret,
  97. (self->key_type == UPB_TYPE_BYTES) ?
  98. kRubyString8bitEncoding : kRubyStringUtf8Encoding);
  99. return ret;
  100. }
  101. case UPB_TYPE_BOOL:
  102. case UPB_TYPE_INT32:
  103. case UPB_TYPE_INT64:
  104. case UPB_TYPE_UINT32:
  105. case UPB_TYPE_UINT64:
  106. return native_slot_get(self->key_type, Qnil, buf);
  107. default:
  108. assert(false);
  109. return Qnil;
  110. }
  111. }
  112. static void* value_memory(upb_value* v) {
  113. return (void*)(&v->val);
  114. }
  115. // -----------------------------------------------------------------------------
  116. // Map container type.
  117. // -----------------------------------------------------------------------------
  118. const rb_data_type_t Map_type = {
  119. "Google::Protobuf::Map",
  120. { Map_mark, Map_free, NULL },
  121. };
  122. VALUE cMap;
  123. Map* ruby_to_Map(VALUE _self) {
  124. Map* self;
  125. TypedData_Get_Struct(_self, Map, &Map_type, self);
  126. return self;
  127. }
  128. void Map_mark(void* _self) {
  129. Map* self = _self;
  130. rb_gc_mark(self->value_type_class);
  131. if (self->value_type == UPB_TYPE_STRING ||
  132. self->value_type == UPB_TYPE_BYTES ||
  133. self->value_type == UPB_TYPE_MESSAGE) {
  134. upb_strtable_iter it;
  135. for (upb_strtable_begin(&it, &self->table);
  136. !upb_strtable_done(&it);
  137. upb_strtable_next(&it)) {
  138. upb_value v = upb_strtable_iter_value(&it);
  139. void* mem = value_memory(&v);
  140. native_slot_mark(self->value_type, mem);
  141. }
  142. }
  143. }
  144. void Map_free(void* _self) {
  145. Map* self = _self;
  146. upb_strtable_uninit(&self->table);
  147. xfree(self);
  148. }
  149. VALUE Map_alloc(VALUE klass) {
  150. Map* self = ALLOC(Map);
  151. memset(self, 0, sizeof(Map));
  152. self->value_type_class = Qnil;
  153. return TypedData_Wrap_Struct(klass, &Map_type, self);
  154. }
  155. static bool needs_typeclass(upb_fieldtype_t type) {
  156. switch (type) {
  157. case UPB_TYPE_MESSAGE:
  158. case UPB_TYPE_ENUM:
  159. return true;
  160. default:
  161. return false;
  162. }
  163. }
  164. /*
  165. * call-seq:
  166. * Map.new(key_type, value_type, value_typeclass = nil, init_hashmap = {})
  167. * => new map
  168. *
  169. * Allocates a new Map container. This constructor may be called with 2, 3, or 4
  170. * arguments. The first two arguments are always present and are symbols (taking
  171. * on the same values as field-type symbols in message descriptors) that
  172. * indicate the type of the map key and value fields.
  173. *
  174. * The supported key types are: :int32, :int64, :uint32, :uint64, :bool,
  175. * :string, :bytes.
  176. *
  177. * The supported value types are: :int32, :int64, :uint32, :uint64, :bool,
  178. * :string, :bytes, :enum, :message.
  179. *
  180. * The third argument, value_typeclass, must be present if value_type is :enum
  181. * or :message. As in RepeatedField#new, this argument must be a message class
  182. * (for :message) or enum module (for :enum).
  183. *
  184. * The last argument, if present, provides initial content for map. Note that
  185. * this may be an ordinary Ruby hashmap or another Map instance with identical
  186. * key and value types. Also note that this argument may be present whether or
  187. * not value_typeclass is present (and it is unambiguously separate from
  188. * value_typeclass because value_typeclass's presence is strictly determined by
  189. * value_type). The contents of this initial hashmap or Map instance are
  190. * shallow-copied into the new Map: the original map is unmodified, but
  191. * references to underlying objects will be shared if the value type is a
  192. * message type.
  193. */
  194. VALUE Map_init(int argc, VALUE* argv, VALUE _self) {
  195. Map* self = ruby_to_Map(_self);
  196. int init_value_arg;
  197. // We take either two args (:key_type, :value_type), three args (:key_type,
  198. // :value_type, "ValueMessageType"), or four args (the above plus an initial
  199. // hashmap).
  200. if (argc < 2 || argc > 4) {
  201. rb_raise(rb_eArgError, "Map constructor expects 2, 3 or 4 arguments.");
  202. }
  203. self->key_type = ruby_to_fieldtype(argv[0]);
  204. self->value_type = ruby_to_fieldtype(argv[1]);
  205. // Check that the key type is an allowed type.
  206. switch (self->key_type) {
  207. case UPB_TYPE_INT32:
  208. case UPB_TYPE_INT64:
  209. case UPB_TYPE_UINT32:
  210. case UPB_TYPE_UINT64:
  211. case UPB_TYPE_BOOL:
  212. case UPB_TYPE_STRING:
  213. case UPB_TYPE_BYTES:
  214. // These are OK.
  215. break;
  216. default:
  217. rb_raise(rb_eArgError, "Invalid key type for map.");
  218. }
  219. init_value_arg = 2;
  220. if (needs_typeclass(self->value_type) && argc > 2) {
  221. self->value_type_class = argv[2];
  222. validate_type_class(self->value_type, self->value_type_class);
  223. init_value_arg = 3;
  224. }
  225. // Table value type is always UINT64: this ensures enough space to store the
  226. // native_slot value.
  227. if (!upb_strtable_init(&self->table, UPB_CTYPE_UINT64)) {
  228. rb_raise(rb_eRuntimeError, "Could not allocate table.");
  229. }
  230. if (argc > init_value_arg) {
  231. Map_merge_into_self(_self, argv[init_value_arg]);
  232. }
  233. return Qnil;
  234. }
  235. /*
  236. * call-seq:
  237. * Map.each(&block)
  238. *
  239. * Invokes &block on each |key, value| pair in the map, in unspecified order.
  240. * Note that Map also includes Enumerable; map thus acts like a normal Ruby
  241. * sequence.
  242. */
  243. VALUE Map_each(VALUE _self) {
  244. Map* self = ruby_to_Map(_self);
  245. upb_strtable_iter it;
  246. for (upb_strtable_begin(&it, &self->table);
  247. !upb_strtable_done(&it);
  248. upb_strtable_next(&it)) {
  249. VALUE key = table_key_to_ruby(
  250. self, upb_strtable_iter_key(&it), upb_strtable_iter_keylength(&it));
  251. upb_value v = upb_strtable_iter_value(&it);
  252. void* mem = value_memory(&v);
  253. VALUE value = native_slot_get(self->value_type,
  254. self->value_type_class,
  255. mem);
  256. rb_yield_values(2, key, value);
  257. }
  258. return Qnil;
  259. }
  260. /*
  261. * call-seq:
  262. * Map.keys => [list_of_keys]
  263. *
  264. * Returns the list of keys contained in the map, in unspecified order.
  265. */
  266. VALUE Map_keys(VALUE _self) {
  267. Map* self = ruby_to_Map(_self);
  268. VALUE ret = rb_ary_new();
  269. upb_strtable_iter it;
  270. for (upb_strtable_begin(&it, &self->table);
  271. !upb_strtable_done(&it);
  272. upb_strtable_next(&it)) {
  273. VALUE key = table_key_to_ruby(
  274. self, upb_strtable_iter_key(&it), upb_strtable_iter_keylength(&it));
  275. rb_ary_push(ret, key);
  276. }
  277. return ret;
  278. }
  279. /*
  280. * call-seq:
  281. * Map.values => [list_of_values]
  282. *
  283. * Returns the list of values contained in the map, in unspecified order.
  284. */
  285. VALUE Map_values(VALUE _self) {
  286. Map* self = ruby_to_Map(_self);
  287. VALUE ret = rb_ary_new();
  288. upb_strtable_iter it;
  289. for (upb_strtable_begin(&it, &self->table);
  290. !upb_strtable_done(&it);
  291. upb_strtable_next(&it)) {
  292. upb_value v = upb_strtable_iter_value(&it);
  293. void* mem = value_memory(&v);
  294. VALUE value = native_slot_get(self->value_type,
  295. self->value_type_class,
  296. mem);
  297. rb_ary_push(ret, value);
  298. }
  299. return ret;
  300. }
  301. /*
  302. * call-seq:
  303. * Map.[](key) => value
  304. *
  305. * Accesses the element at the given key. Throws an exception if the key type is
  306. * incorrect. Returns nil when the key is not present in the map.
  307. */
  308. VALUE Map_index(VALUE _self, VALUE key) {
  309. Map* self = ruby_to_Map(_self);
  310. char keybuf[TABLE_KEY_BUF_LENGTH];
  311. const char* keyval = NULL;
  312. size_t length = 0;
  313. upb_value v;
  314. key = table_key(self, key, keybuf, &keyval, &length);
  315. if (upb_strtable_lookup2(&self->table, keyval, length, &v)) {
  316. void* mem = value_memory(&v);
  317. return native_slot_get(self->value_type, self->value_type_class, mem);
  318. } else {
  319. return Qnil;
  320. }
  321. }
  322. /*
  323. * call-seq:
  324. * Map.[]=(key, value) => value
  325. *
  326. * Inserts or overwrites the value at the given key with the given new value.
  327. * Throws an exception if the key type is incorrect. Returns the new value that
  328. * was just inserted.
  329. */
  330. VALUE Map_index_set(VALUE _self, VALUE key, VALUE value) {
  331. Map* self = ruby_to_Map(_self);
  332. char keybuf[TABLE_KEY_BUF_LENGTH];
  333. const char* keyval = NULL;
  334. size_t length = 0;
  335. upb_value v;
  336. void* mem;
  337. key = table_key(self, key, keybuf, &keyval, &length);
  338. mem = value_memory(&v);
  339. native_slot_set(self->value_type, self->value_type_class, mem, value);
  340. // Replace any existing value by issuing a 'remove' operation first.
  341. upb_strtable_remove2(&self->table, keyval, length, NULL);
  342. if (!upb_strtable_insert2(&self->table, keyval, length, v)) {
  343. rb_raise(rb_eRuntimeError, "Could not insert into table");
  344. }
  345. // Ruby hashmap's :[]= method also returns the inserted value.
  346. return value;
  347. }
  348. /*
  349. * call-seq:
  350. * Map.has_key?(key) => bool
  351. *
  352. * Returns true if the given key is present in the map. Throws an exception if
  353. * the key has the wrong type.
  354. */
  355. VALUE Map_has_key(VALUE _self, VALUE key) {
  356. Map* self = ruby_to_Map(_self);
  357. char keybuf[TABLE_KEY_BUF_LENGTH];
  358. const char* keyval = NULL;
  359. size_t length = 0;
  360. key = table_key(self, key, keybuf, &keyval, &length);
  361. if (upb_strtable_lookup2(&self->table, keyval, length, NULL)) {
  362. return Qtrue;
  363. } else {
  364. return Qfalse;
  365. }
  366. }
  367. /*
  368. * call-seq:
  369. * Map.delete(key) => old_value
  370. *
  371. * Deletes the value at the given key, if any, returning either the old value or
  372. * nil if none was present. Throws an exception if the key is of the wrong type.
  373. */
  374. VALUE Map_delete(VALUE _self, VALUE key) {
  375. Map* self = ruby_to_Map(_self);
  376. char keybuf[TABLE_KEY_BUF_LENGTH];
  377. const char* keyval = NULL;
  378. size_t length = 0;
  379. upb_value v;
  380. key = table_key(self, key, keybuf, &keyval, &length);
  381. if (upb_strtable_remove2(&self->table, keyval, length, &v)) {
  382. void* mem = value_memory(&v);
  383. return native_slot_get(self->value_type, self->value_type_class, mem);
  384. } else {
  385. return Qnil;
  386. }
  387. }
  388. /*
  389. * call-seq:
  390. * Map.clear
  391. *
  392. * Removes all entries from the map.
  393. */
  394. VALUE Map_clear(VALUE _self) {
  395. Map* self = ruby_to_Map(_self);
  396. // Uninit and reinit the table -- this is faster than iterating and doing a
  397. // delete-lookup on each key.
  398. upb_strtable_uninit(&self->table);
  399. if (!upb_strtable_init(&self->table, UPB_CTYPE_INT64)) {
  400. rb_raise(rb_eRuntimeError, "Unable to re-initialize table");
  401. }
  402. return Qnil;
  403. }
  404. /*
  405. * call-seq:
  406. * Map.length
  407. *
  408. * Returns the number of entries (key-value pairs) in the map.
  409. */
  410. VALUE Map_length(VALUE _self) {
  411. Map* self = ruby_to_Map(_self);
  412. return ULL2NUM(upb_strtable_count(&self->table));
  413. }
  414. static VALUE Map_new_this_type(VALUE _self) {
  415. Map* self = ruby_to_Map(_self);
  416. VALUE new_map = Qnil;
  417. VALUE key_type = fieldtype_to_ruby(self->key_type);
  418. VALUE value_type = fieldtype_to_ruby(self->value_type);
  419. if (self->value_type_class != Qnil) {
  420. new_map = rb_funcall(CLASS_OF(_self), rb_intern("new"), 3,
  421. key_type, value_type, self->value_type_class);
  422. } else {
  423. new_map = rb_funcall(CLASS_OF(_self), rb_intern("new"), 2,
  424. key_type, value_type);
  425. }
  426. return new_map;
  427. }
  428. /*
  429. * call-seq:
  430. * Map.dup => new_map
  431. *
  432. * Duplicates this map with a shallow copy. References to all non-primitive
  433. * element objects (e.g., submessages) are shared.
  434. */
  435. VALUE Map_dup(VALUE _self) {
  436. Map* self = ruby_to_Map(_self);
  437. VALUE new_map = Map_new_this_type(_self);
  438. Map* new_self = ruby_to_Map(new_map);
  439. upb_strtable_iter it;
  440. for (upb_strtable_begin(&it, &self->table);
  441. !upb_strtable_done(&it);
  442. upb_strtable_next(&it)) {
  443. upb_value v = upb_strtable_iter_value(&it);
  444. void* mem = value_memory(&v);
  445. upb_value dup;
  446. void* dup_mem = value_memory(&dup);
  447. native_slot_dup(self->value_type, dup_mem, mem);
  448. if (!upb_strtable_insert2(&new_self->table,
  449. upb_strtable_iter_key(&it),
  450. upb_strtable_iter_keylength(&it),
  451. dup)) {
  452. rb_raise(rb_eRuntimeError, "Error inserting value into new table");
  453. }
  454. }
  455. return new_map;
  456. }
  457. // Used by Google::Protobuf.deep_copy but not exposed directly.
  458. VALUE Map_deep_copy(VALUE _self) {
  459. Map* self = ruby_to_Map(_self);
  460. VALUE new_map = Map_new_this_type(_self);
  461. Map* new_self = ruby_to_Map(new_map);
  462. upb_strtable_iter it;
  463. for (upb_strtable_begin(&it, &self->table);
  464. !upb_strtable_done(&it);
  465. upb_strtable_next(&it)) {
  466. upb_value v = upb_strtable_iter_value(&it);
  467. void* mem = value_memory(&v);
  468. upb_value dup;
  469. void* dup_mem = value_memory(&dup);
  470. native_slot_deep_copy(self->value_type, dup_mem, mem);
  471. if (!upb_strtable_insert2(&new_self->table,
  472. upb_strtable_iter_key(&it),
  473. upb_strtable_iter_keylength(&it),
  474. dup)) {
  475. rb_raise(rb_eRuntimeError, "Error inserting value into new table");
  476. }
  477. }
  478. return new_map;
  479. }
  480. /*
  481. * call-seq:
  482. * Map.==(other) => boolean
  483. *
  484. * Compares this map to another. Maps are equal if they have identical key sets,
  485. * and for each key, the values in both maps compare equal. Elements are
  486. * compared as per normal Ruby semantics, by calling their :== methods (or
  487. * performing a more efficient comparison for primitive types).
  488. *
  489. * Maps with dissimilar key types or value types/typeclasses are never equal,
  490. * even if value comparison (for example, between integers and floats) would
  491. * have otherwise indicated that every element has equal value.
  492. */
  493. VALUE Map_eq(VALUE _self, VALUE _other) {
  494. Map* self = ruby_to_Map(_self);
  495. Map* other;
  496. upb_strtable_iter it;
  497. // Allow comparisons to Ruby hashmaps by converting to a temporary Map
  498. // instance. Slow, but workable.
  499. if (TYPE(_other) == T_HASH) {
  500. VALUE other_map = Map_new_this_type(_self);
  501. Map_merge_into_self(other_map, _other);
  502. _other = other_map;
  503. }
  504. other = ruby_to_Map(_other);
  505. if (self == other) {
  506. return Qtrue;
  507. }
  508. if (self->key_type != other->key_type ||
  509. self->value_type != other->value_type ||
  510. self->value_type_class != other->value_type_class) {
  511. return Qfalse;
  512. }
  513. if (upb_strtable_count(&self->table) != upb_strtable_count(&other->table)) {
  514. return Qfalse;
  515. }
  516. // For each member of self, check that an equal member exists at the same key
  517. // in other.
  518. for (upb_strtable_begin(&it, &self->table);
  519. !upb_strtable_done(&it);
  520. upb_strtable_next(&it)) {
  521. upb_value v = upb_strtable_iter_value(&it);
  522. void* mem = value_memory(&v);
  523. upb_value other_v;
  524. void* other_mem = value_memory(&other_v);
  525. if (!upb_strtable_lookup2(&other->table,
  526. upb_strtable_iter_key(&it),
  527. upb_strtable_iter_keylength(&it),
  528. &other_v)) {
  529. // Not present in other map.
  530. return Qfalse;
  531. }
  532. if (!native_slot_eq(self->value_type, mem, other_mem)) {
  533. // Present, but value not equal.
  534. return Qfalse;
  535. }
  536. }
  537. return Qtrue;
  538. }
  539. /*
  540. * call-seq:
  541. * Map.hash => hash_value
  542. *
  543. * Returns a hash value based on this map's contents.
  544. */
  545. VALUE Map_hash(VALUE _self) {
  546. Map* self = ruby_to_Map(_self);
  547. st_index_t h = rb_hash_start(0);
  548. VALUE hash_sym = rb_intern("hash");
  549. upb_strtable_iter it;
  550. for (upb_strtable_begin(&it, &self->table);
  551. !upb_strtable_done(&it);
  552. upb_strtable_next(&it)) {
  553. VALUE key = table_key_to_ruby(
  554. self, upb_strtable_iter_key(&it), upb_strtable_iter_keylength(&it));
  555. upb_value v = upb_strtable_iter_value(&it);
  556. void* mem = value_memory(&v);
  557. VALUE value = native_slot_get(self->value_type,
  558. self->value_type_class,
  559. mem);
  560. h = rb_hash_uint(h, NUM2LONG(rb_funcall(key, hash_sym, 0)));
  561. h = rb_hash_uint(h, NUM2LONG(rb_funcall(value, hash_sym, 0)));
  562. }
  563. return INT2FIX(h);
  564. }
  565. /*
  566. * call-seq:
  567. * Map.inspect => string
  568. *
  569. * Returns a string representing this map's elements. It will be formatted as
  570. * "{key => value, key => value, ...}", with each key and value string
  571. * representation computed by its own #inspect method.
  572. */
  573. VALUE Map_inspect(VALUE _self) {
  574. Map* self = ruby_to_Map(_self);
  575. VALUE str = rb_str_new2("{");
  576. bool first = true;
  577. VALUE inspect_sym = rb_intern("inspect");
  578. upb_strtable_iter it;
  579. for (upb_strtable_begin(&it, &self->table);
  580. !upb_strtable_done(&it);
  581. upb_strtable_next(&it)) {
  582. VALUE key = table_key_to_ruby(
  583. self, upb_strtable_iter_key(&it), upb_strtable_iter_keylength(&it));
  584. upb_value v = upb_strtable_iter_value(&it);
  585. void* mem = value_memory(&v);
  586. VALUE value = native_slot_get(self->value_type,
  587. self->value_type_class,
  588. mem);
  589. if (!first) {
  590. str = rb_str_cat2(str, ", ");
  591. } else {
  592. first = false;
  593. }
  594. str = rb_str_append(str, rb_funcall(key, inspect_sym, 0));
  595. str = rb_str_cat2(str, "=>");
  596. str = rb_str_append(str, rb_funcall(value, inspect_sym, 0));
  597. }
  598. str = rb_str_cat2(str, "}");
  599. return str;
  600. }
  601. /*
  602. * call-seq:
  603. * Map.merge(other_map) => map
  604. *
  605. * Copies key/value pairs from other_map into a copy of this map. If a key is
  606. * set in other_map and this map, the value from other_map overwrites the value
  607. * in the new copy of this map. Returns the new copy of this map with merged
  608. * contents.
  609. */
  610. VALUE Map_merge(VALUE _self, VALUE hashmap) {
  611. VALUE dupped = Map_dup(_self);
  612. return Map_merge_into_self(dupped, hashmap);
  613. }
  614. static int merge_into_self_callback(VALUE key, VALUE value, VALUE self) {
  615. Map_index_set(self, key, value);
  616. return ST_CONTINUE;
  617. }
  618. // Used only internally -- shared by #merge and #initialize.
  619. VALUE Map_merge_into_self(VALUE _self, VALUE hashmap) {
  620. if (TYPE(hashmap) == T_HASH) {
  621. rb_hash_foreach(hashmap, merge_into_self_callback, _self);
  622. } else if (RB_TYPE_P(hashmap, T_DATA) && RTYPEDDATA_P(hashmap) &&
  623. RTYPEDDATA_TYPE(hashmap) == &Map_type) {
  624. Map* self = ruby_to_Map(_self);
  625. Map* other = ruby_to_Map(hashmap);
  626. upb_strtable_iter it;
  627. if (self->key_type != other->key_type ||
  628. self->value_type != other->value_type ||
  629. self->value_type_class != other->value_type_class) {
  630. rb_raise(rb_eArgError, "Attempt to merge Map with mismatching types");
  631. }
  632. for (upb_strtable_begin(&it, &other->table);
  633. !upb_strtable_done(&it);
  634. upb_strtable_next(&it)) {
  635. // Replace any existing value by issuing a 'remove' operation first.
  636. upb_value v;
  637. upb_value oldv;
  638. upb_strtable_remove2(&self->table,
  639. upb_strtable_iter_key(&it),
  640. upb_strtable_iter_keylength(&it),
  641. &oldv);
  642. v = upb_strtable_iter_value(&it);
  643. upb_strtable_insert2(&self->table,
  644. upb_strtable_iter_key(&it),
  645. upb_strtable_iter_keylength(&it),
  646. v);
  647. }
  648. } else {
  649. rb_raise(rb_eArgError, "Unknown type merging into Map");
  650. }
  651. return _self;
  652. }
  653. // Internal method: map iterator initialization (used for serialization).
  654. void Map_begin(VALUE _self, Map_iter* iter) {
  655. Map* self = ruby_to_Map(_self);
  656. iter->self = self;
  657. upb_strtable_begin(&iter->it, &self->table);
  658. }
  659. void Map_next(Map_iter* iter) {
  660. upb_strtable_next(&iter->it);
  661. }
  662. bool Map_done(Map_iter* iter) {
  663. return upb_strtable_done(&iter->it);
  664. }
  665. VALUE Map_iter_key(Map_iter* iter) {
  666. return table_key_to_ruby(
  667. iter->self,
  668. upb_strtable_iter_key(&iter->it),
  669. upb_strtable_iter_keylength(&iter->it));
  670. }
  671. VALUE Map_iter_value(Map_iter* iter) {
  672. upb_value v = upb_strtable_iter_value(&iter->it);
  673. void* mem = value_memory(&v);
  674. return native_slot_get(iter->self->value_type,
  675. iter->self->value_type_class,
  676. mem);
  677. }
  678. void Map_register(VALUE module) {
  679. VALUE klass = rb_define_class_under(module, "Map", rb_cObject);
  680. rb_define_alloc_func(klass, Map_alloc);
  681. cMap = klass;
  682. rb_gc_register_address(&cMap);
  683. rb_define_method(klass, "initialize", Map_init, -1);
  684. rb_define_method(klass, "each", Map_each, 0);
  685. rb_define_method(klass, "keys", Map_keys, 0);
  686. rb_define_method(klass, "values", Map_values, 0);
  687. rb_define_method(klass, "[]", Map_index, 1);
  688. rb_define_method(klass, "[]=", Map_index_set, 2);
  689. rb_define_method(klass, "has_key?", Map_has_key, 1);
  690. rb_define_method(klass, "delete", Map_delete, 1);
  691. rb_define_method(klass, "clear", Map_clear, 0);
  692. rb_define_method(klass, "length", Map_length, 0);
  693. rb_define_method(klass, "dup", Map_dup, 0);
  694. rb_define_method(klass, "==", Map_eq, 1);
  695. rb_define_method(klass, "hash", Map_hash, 0);
  696. rb_define_method(klass, "inspect", Map_inspect, 0);
  697. rb_define_method(klass, "merge", Map_merge, 1);
  698. rb_include_module(klass, rb_mEnumerable);
  699. }