diff --git a/src/broker/Data.h b/src/broker/Data.h index cf5f06b90d..5979de83ae 100644 --- a/src/broker/Data.h +++ b/src/broker/Data.h @@ -116,6 +116,7 @@ public: protected: DataVal() + : OpaqueVal(bro_broker::opaque_of_data_type) {} DECLARE_OPAQUE_VALUE(bro_broker::DataVal) @@ -236,7 +237,10 @@ public: broker::set::iterator it; protected: - SetIterator() {} + SetIterator() + : OpaqueVal(bro_broker::opaque_of_set_iterator) + {} + DECLARE_OPAQUE_VALUE(bro_broker::SetIterator) }; @@ -253,7 +257,10 @@ public: broker::table::iterator it; protected: - TableIterator() {} + TableIterator() + : OpaqueVal(bro_broker::opaque_of_table_iterator) + {} + DECLARE_OPAQUE_VALUE(bro_broker::TableIterator) }; @@ -270,7 +277,10 @@ public: broker::vector::iterator it; protected: - VectorIterator() {} + VectorIterator() + : OpaqueVal(bro_broker::opaque_of_vector_iterator) + {} + DECLARE_OPAQUE_VALUE(bro_broker::VectorIterator) }; @@ -287,7 +297,10 @@ public: broker::vector::iterator it; protected: - RecordIterator() {} + RecordIterator() + : OpaqueVal(bro_broker::opaque_of_record_iterator) + {} + DECLARE_OPAQUE_VALUE(bro_broker::RecordIterator) }; diff --git a/src/broker/Store.h b/src/broker/Store.h index 09799c8c68..e8e4fec03d 100644 --- a/src/broker/Store.h +++ b/src/broker/Store.h @@ -103,7 +103,9 @@ public: broker::store::proxy proxy; protected: - StoreHandleVal() = default; + StoreHandleVal() + : OpaqueVal(bro_broker::opaque_of_store_handle) + {} DECLARE_OPAQUE_VALUE(StoreHandleVal) }; diff --git a/testing/btest/Baseline/broker.opaque/out b/testing/btest/Baseline/broker.opaque/out index 35bf821c47..b4293c0100 100644 --- a/testing/btest/Baseline/broker.opaque/out +++ b/testing/btest/Baseline/broker.opaque/out @@ -1,53 +1,62 @@ ============ Topk +opaque of topk [b, a, c] [b, a, c] ============ HLL 3.000069 +opaque of cardinality 3.000069 3.000069 ============ Bloom 0 1 +opaque of bloomfilter 0 1 ============ Hashes +opaque of md5 5b9164ad6f496d9dee12ec7634ce253f 5b9164ad6f496d9dee12ec7634ce253f +opaque of sha1 30ae97492ce1da88d0e7117ace0a60a6f9e1e0bc 30ae97492ce1da88d0e7117ace0a60a6f9e1e0bc +opaque of sha256 25b6746d5172ed6352966a013d93ac846e1110d5a25e8f183b5931f4688842a1 25b6746d5172ed6352966a013d93ac846e1110d5a25e8f183b5931f4688842a1 ============ X509 +opaque of x509 [version=3, serial=040000000001154B5AC394, subject=CN=GlobalSign Root CA,OU=Root CA,O=GlobalSign nv-sa,C=BE, issuer=CN=GlobalSign Root CA,OU=Root CA,O=GlobalSign nv-sa,C=BE, cn=GlobalSign Root CA, not_valid_before=904651200.0, not_valid_after=1832673600.0, key_alg=rsaEncryption, sig_alg=sha1WithRSAEncryption, key_type=rsa, key_length=2048, exponent=65537, curve=] [version=3, serial=040000000001154B5AC394, subject=CN=GlobalSign Root CA,OU=Root CA,O=GlobalSign nv-sa,C=BE, issuer=CN=GlobalSign Root CA,OU=Root CA,O=GlobalSign nv-sa,C=BE, cn=GlobalSign Root CA, not_valid_before=904651200.0, not_valid_after=1832673600.0, key_alg=rsaEncryption, sig_alg=sha1WithRSAEncryption, key_type=rsa, key_length=2048, exponent=65537, curve=] ============ Entropy +opaque of entropy [entropy=4.715374, chi_square=591.981818, mean=75.472727, monte_carlo_pi=4.0, serial_correlation=-0.11027] [entropy=4.715374, chi_square=591.981818, mean=75.472727, monte_carlo_pi=4.0, serial_correlation=-0.11027] ============ broker::Data +opaque of Broker::Data broker::data{{hi, there}} broker::data{{hi, there}} T ============ broker::Set -| [data=broker::data{!}] | [data=broker::data{!}] +| [data=broker::data{!}] | [data=broker::data{!}] | opaque of Broker::SetIterator > [data=broker::data{hi}] | [data=broker::data{hi}] -| [data=broker::data{hi}] | [data=broker::data{hi}] +| [data=broker::data{hi}] | [data=broker::data{hi}] | opaque of Broker::SetIterator > [data=broker::data{there}] | [data=broker::data{there}] -| [data=broker::data{there}] | [data=broker::data{there}] +| [data=broker::data{there}] | [data=broker::data{there}] | opaque of Broker::SetIterator ============ broker::Table -| [key=[data=broker::data{!}], val=[data=broker::data{30}]] | [key=[data=broker::data{!}], val=[data=broker::data{30}]] +| [key=[data=broker::data{!}], val=[data=broker::data{30}]] | [key=[data=broker::data{!}], val=[data=broker::data{30}]] | opaque of Broker::TableIterator > [key=[data=broker::data{hi}], val=[data=broker::data{10}]] | [key=[data=broker::data{hi}], val=[data=broker::data{10}]] -| [key=[data=broker::data{hi}], val=[data=broker::data{10}]] | [key=[data=broker::data{hi}], val=[data=broker::data{10}]] +| [key=[data=broker::data{hi}], val=[data=broker::data{10}]] | [key=[data=broker::data{hi}], val=[data=broker::data{10}]] | opaque of Broker::TableIterator > [key=[data=broker::data{there}], val=[data=broker::data{20}]] | [key=[data=broker::data{there}], val=[data=broker::data{20}]] -| [key=[data=broker::data{there}], val=[data=broker::data{20}]] | [key=[data=broker::data{there}], val=[data=broker::data{20}]] +| [key=[data=broker::data{there}], val=[data=broker::data{20}]] | [key=[data=broker::data{there}], val=[data=broker::data{20}]] | opaque of Broker::TableIterator ============ broker::Vector -| [data=broker::data{hi}] | [data=broker::data{hi}] +| [data=broker::data{hi}] | [data=broker::data{hi}] | opaque of Broker::VectorIterator > [data=broker::data{there}] | [data=broker::data{there}] -| [data=broker::data{there}] | [data=broker::data{there}] +| [data=broker::data{there}] | [data=broker::data{there}] | opaque of Broker::VectorIterator > [data=broker::data{!}] | [data=broker::data{!}] -| [data=broker::data{!}] | [data=broker::data{!}] +| [data=broker::data{!}] | [data=broker::data{!}] | opaque of Broker::VectorIterator ============ broker::Record -| [data=broker::data{hi}] | [data=broker::data{hi}] +| [data=broker::data{hi}] | [data=broker::data{hi}] | opaque of Broker::RecordIterator > [data=broker::data{there}] | [data=broker::data{there}] -| [data=broker::data{there}] | [data=broker::data{there}] +| [data=broker::data{there}] | [data=broker::data{there}] | opaque of Broker::RecordIterator > [data=broker::data{!}] | [data=broker::data{!}] -| [data=broker::data{!}] | [data=broker::data{!}] +| [data=broker::data{!}] | [data=broker::data{!}] | opaque of Broker::RecordIterator diff --git a/testing/btest/broker/opaque.zeek b/testing/btest/broker/opaque.zeek index e0a3bef6c7..41823a59ed 100644 --- a/testing/btest/broker/opaque.zeek +++ b/testing/btest/broker/opaque.zeek @@ -11,6 +11,7 @@ event zeek_init() topk_add(k1, "b"); topk_add(k1, "c"); local k2 = Broker::__opaque_clone_through_serialization(k1); + print type_name(k2); print topk_get_top(k1, 5); topk_add(k1, "shoulnotshowup"); print topk_get_top(k2, 5); @@ -23,6 +24,7 @@ event zeek_init() print hll_cardinality_estimate(c1); local c2 = Broker::__opaque_clone_through_serialization(c1); + print type_name(c2); hll_cardinality_add(c1, 2004); print hll_cardinality_estimate(c2); @@ -38,6 +40,7 @@ event zeek_init() print bloomfilter_lookup(bf_cnt, 0); print bloomfilter_lookup(bf_cnt, 42); local bf_copy = Broker::__opaque_clone_through_serialization(bf_cnt); + print type_name(bf_copy); bloomfilter_add(bf_cnt, 0); print bloomfilter_lookup(bf_copy, 0); print bloomfilter_lookup(bf_copy, 42); @@ -48,6 +51,7 @@ event zeek_init() local md5a = md5_hash_init(); md5_hash_update(md5a, "one"); local md5b = Broker::__opaque_clone_through_serialization(md5a); + print type_name(md5b); md5_hash_update(md5a, "two"); md5_hash_update(md5b, "two"); print md5_hash_finish(md5a); @@ -56,6 +60,7 @@ event zeek_init() local sha1a = sha1_hash_init(); sha1_hash_update(sha1a, "one"); local sha1b = Broker::__opaque_clone_through_serialization(sha1a); + print type_name(sha1b); sha1_hash_update(sha1a, "two"); sha1_hash_update(sha1b, "two"); print sha1_hash_finish(sha1a); @@ -64,6 +69,7 @@ event zeek_init() local sha256a = sha256_hash_init(); sha256_hash_update(sha256a, "one"); local sha256b = Broker::__opaque_clone_through_serialization(sha256a); + print type_name(sha256b); sha256_hash_update(sha256a, "two"); sha256_hash_update(sha256b, "two"); print sha256_hash_finish(sha256a); @@ -72,6 +78,7 @@ event zeek_init() print "============ X509"; local x509 = x509_from_der("\x30\x82\x03\x75\x30\x82\x02\x5D\xA0\x03\x02\x01\x02\x02\x0B\x04\x00\x00\x00\x00\x01\x15\x4B\x5A\xC3\x94\x30\x0D\x06\x09\x2A\x86\x48\x86\xF7\x0D\x01\x01\x05\x05\x00\x30\x57\x31\x0B\x30\x09\x06\x03\x55\x04\x06\x13\x02\x42\x45\x31\x19\x30\x17\x06\x03\x55\x04\x0A\x13\x10\x47\x6C\x6F\x62\x61\x6C\x53\x69\x67\x6E\x20\x6E\x76\x2D\x73\x61\x31\x10\x30\x0E\x06\x03\x55\x04\x0B\x13\x07\x52\x6F\x6F\x74\x20\x43\x41\x31\x1B\x30\x19\x06\x03\x55\x04\x03\x13\x12\x47\x6C\x6F\x62\x61\x6C\x53\x69\x67\x6E\x20\x52\x6F\x6F\x74\x20\x43\x41\x30\x1E\x17\x0D\x39\x38\x30\x39\x30\x31\x31\x32\x30\x30\x30\x30\x5A\x17\x0D\x32\x38\x30\x31\x32\x38\x31\x32\x30\x30\x30\x30\x5A\x30\x57\x31\x0B\x30\x09\x06\x03\x55\x04\x06\x13\x02\x42\x45\x31\x19\x30\x17\x06\x03\x55\x04\x0A\x13\x10\x47\x6C\x6F\x62\x61\x6C\x53\x69\x67\x6E\x20\x6E\x76\x2D\x73\x61\x31\x10\x30\x0E\x06\x03\x55\x04\x0B\x13\x07\x52\x6F\x6F\x74\x20\x43\x41\x31\x1B\x30\x19\x06\x03\x55\x04\x03\x13\x12\x47\x6C\x6F\x62\x61\x6C\x53\x69\x67\x6E\x20\x52\x6F\x6F\x74\x20\x43\x41\x30\x82\x01\x22\x30\x0D\x06\x09\x2A\x86\x48\x86\xF7\x0D\x01\x01\x01\x05\x00\x03\x82\x01\x0F\x00\x30\x82\x01\x0A\x02\x82\x01\x01\x00\xDA\x0E\xE6\x99\x8D\xCE\xA3\xE3\x4F\x8A\x7E\xFB\xF1\x8B\x83\x25\x6B\xEA\x48\x1F\xF1\x2A\xB0\xB9\x95\x11\x04\xBD\xF0\x63\xD1\xE2\x67\x66\xCF\x1C\xDD\xCF\x1B\x48\x2B\xEE\x8D\x89\x8E\x9A\xAF\x29\x80\x65\xAB\xE9\xC7\x2D\x12\xCB\xAB\x1C\x4C\x70\x07\xA1\x3D\x0A\x30\xCD\x15\x8D\x4F\xF8\xDD\xD4\x8C\x50\x15\x1C\xEF\x50\xEE\xC4\x2E\xF7\xFC\xE9\x52\xF2\x91\x7D\xE0\x6D\xD5\x35\x30\x8E\x5E\x43\x73\xF2\x41\xE9\xD5\x6A\xE3\xB2\x89\x3A\x56\x39\x38\x6F\x06\x3C\x88\x69\x5B\x2A\x4D\xC5\xA7\x54\xB8\x6C\x89\xCC\x9B\xF9\x3C\xCA\xE5\xFD\x89\xF5\x12\x3C\x92\x78\x96\xD6\xDC\x74\x6E\x93\x44\x61\xD1\x8D\xC7\x46\xB2\x75\x0E\x86\xE8\x19\x8A\xD5\x6D\x6C\xD5\x78\x16\x95\xA2\xE9\xC8\x0A\x38\xEB\xF2\x24\x13\x4F\x73\x54\x93\x13\x85\x3A\x1B\xBC\x1E\x34\xB5\x8B\x05\x8C\xB9\x77\x8B\xB1\xDB\x1F\x20\x91\xAB\x09\x53\x6E\x90\xCE\x7B\x37\x74\xB9\x70\x47\x91\x22\x51\x63\x16\x79\xAE\xB1\xAE\x41\x26\x08\xC8\x19\x2B\xD1\x46\xAA\x48\xD6\x64\x2A\xD7\x83\x34\xFF\x2C\x2A\xC1\x6C\x19\x43\x4A\x07\x85\xE7\xD3\x7C\xF6\x21\x68\xEF\xEA\xF2\x52\x9F\x7F\x93\x90\xCF\x02\x03\x01\x00\x01\xA3\x42\x30\x40\x30\x0E\x06\x03\x55\x1D\x0F\x01\x01\xFF\x04\x04\x03\x02\x01\x06\x30\x0F\x06\x03\x55\x1D\x13\x01\x01\xFF\x04\x05\x30\x03\x01\x01\xFF\x30\x1D\x06\x03\x55\x1D\x0E\x04\x16\x04\x14\x60\x7B\x66\x1A\x45\x0D\x97\xCA\x89\x50\x2F\x7D\x04\xCD\x34\xA8\xFF\xFC\xFD\x4B\x30\x0D\x06\x09\x2A\x86\x48\x86\xF7\x0D\x01\x01\x05\x05\x00\x03\x82\x01\x01\x00\xD6\x73\xE7\x7C\x4F\x76\xD0\x8D\xBF\xEC\xBA\xA2\xBE\x34\xC5\x28\x32\xB5\x7C\xFC\x6C\x9C\x2C\x2B\xBD\x09\x9E\x53\xBF\x6B\x5E\xAA\x11\x48\xB6\xE5\x08\xA3\xB3\xCA\x3D\x61\x4D\xD3\x46\x09\xB3\x3E\xC3\xA0\xE3\x63\x55\x1B\xF2\xBA\xEF\xAD\x39\xE1\x43\xB9\x38\xA3\xE6\x2F\x8A\x26\x3B\xEF\xA0\x50\x56\xF9\xC6\x0A\xFD\x38\xCD\xC4\x0B\x70\x51\x94\x97\x98\x04\xDF\xC3\x5F\x94\xD5\x15\xC9\x14\x41\x9C\xC4\x5D\x75\x64\x15\x0D\xFF\x55\x30\xEC\x86\x8F\xFF\x0D\xEF\x2C\xB9\x63\x46\xF6\xAA\xFC\xDF\xBC\x69\xFD\x2E\x12\x48\x64\x9A\xE0\x95\xF0\xA6\xEF\x29\x8F\x01\xB1\x15\xB5\x0C\x1D\xA5\xFE\x69\x2C\x69\x24\x78\x1E\xB3\xA7\x1C\x71\x62\xEE\xCA\xC8\x97\xAC\x17\x5D\x8A\xC2\xF8\x47\x86\x6E\x2A\xC4\x56\x31\x95\xD0\x67\x89\x85\x2B\xF9\x6C\xA6\x5D\x46\x9D\x0C\xAA\x82\xE4\x99\x51\xDD\x70\xB7\xDB\x56\x3D\x61\xE4\x6A\xE1\x5C\xD6\xF6\xFE\x3D\xDE\x41\xCC\x07\xAE\x63\x52\xBF\x53\x53\xF4\x2B\xE9\xC7\xFD\xB6\xF7\x82\x5F\x85\xD2\x41\x18\xDB\x81\xB3\x04\x1C\xC5\x1F\xA4\x80\x6F\x15\x20\xC9\xDE\x0C\x88\x0A\x1D\xD6\x66\x55\xE2\xFC\x48\xC9\x29\x26\x69\xE0"); local x5092 = Broker::__opaque_clone_through_serialization(x509); + print type_name(x5092); print x509_parse(x509); print x509_parse(x5092); @@ -79,6 +86,7 @@ event zeek_init() local handle = entropy_test_init(); entropy_test_add(handle, "dh3Hie02uh^s#Sdf9L3frd243h$d78r2G4cM6*Q05d(7rh46f!0|4-f"); local handle2 = Broker::__opaque_clone_through_serialization(handle); + print type_name(handle2); print entropy_test_finish(handle); print entropy_test_finish(handle2); @@ -87,6 +95,7 @@ event zeek_init() Broker::set_insert(s1, "hi"); Broker::set_insert(s1, "there"); local d2 = Broker::__opaque_clone_through_serialization(s1$data); + print type_name(d2); print s1$data; print d2; print same_object(s1$data, d2) == F; @@ -101,7 +110,7 @@ event zeek_init() while ( ! Broker::set_iterator_last(i) ) { local ci = Broker::__opaque_clone_through_serialization(i); - print fmt("| %s | %s", Broker::set_iterator_value(i), Broker::set_iterator_value(ci)); + print fmt("| %s | %s | %s", Broker::set_iterator_value(i), Broker::set_iterator_value(ci), type_name(ci)); Broker::set_iterator_next(i); Broker::set_iterator_next(ci); if ( ! Broker::set_iterator_last(i) ) @@ -118,7 +127,7 @@ event zeek_init() while ( ! Broker::table_iterator_last(j) ) { local cj = Broker::__opaque_clone_through_serialization(j); - print fmt("| %s | %s", Broker::table_iterator_value(j), Broker::table_iterator_value(cj)); + print fmt("| %s | %s | %s", Broker::table_iterator_value(j), Broker::table_iterator_value(cj), type_name(cj)); Broker::table_iterator_next(j); Broker::table_iterator_next(cj); if ( ! Broker::table_iterator_last(j) ) @@ -135,7 +144,7 @@ event zeek_init() while ( ! Broker::vector_iterator_last(k) ) { local ck = Broker::__opaque_clone_through_serialization(k); - print fmt("| %s | %s", Broker::vector_iterator_value(k), Broker::vector_iterator_value(ck)); + print fmt("| %s | %s | %s", Broker::vector_iterator_value(k), Broker::vector_iterator_value(ck), type_name(ck)); Broker::vector_iterator_next(k); Broker::vector_iterator_next(ck); if ( ! Broker::vector_iterator_last(k) ) @@ -152,7 +161,7 @@ event zeek_init() while ( ! Broker::record_iterator_last(l) ) { local cl = Broker::__opaque_clone_through_serialization(l); - print fmt("| %s | %s", Broker::record_iterator_value(l), Broker::record_iterator_value(cl)); + print fmt("| %s | %s | %s", Broker::record_iterator_value(l), Broker::record_iterator_value(cl), type_name(cl)); Broker::record_iterator_next(l); Broker::record_iterator_next(cl); if ( ! Broker::record_iterator_last(l) )