forked from OpenDDS/OpenDDS
-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathChangeLog-RTPS-2
3853 lines (2536 loc) · 137 KB
/
ChangeLog-RTPS-2
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
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
433
434
435
436
437
438
439
440
441
442
443
444
445
446
447
448
449
450
451
452
453
454
455
456
457
458
459
460
461
462
463
464
465
466
467
468
469
470
471
472
473
474
475
476
477
478
479
480
481
482
483
484
485
486
487
488
489
490
491
492
493
494
495
496
497
498
499
500
501
502
503
504
505
506
507
508
509
510
511
512
513
514
515
516
517
518
519
520
521
522
523
524
525
526
527
528
529
530
531
532
533
534
535
536
537
538
539
540
541
542
543
544
545
546
547
548
549
550
551
552
553
554
555
556
557
558
559
560
561
562
563
564
565
566
567
568
569
570
571
572
573
574
575
576
577
578
579
580
581
582
583
584
585
586
587
588
589
590
591
592
593
594
595
596
597
598
599
600
601
602
603
604
605
606
607
608
609
610
611
612
613
614
615
616
617
618
619
620
621
622
623
624
625
626
627
628
629
630
631
632
633
634
635
636
637
638
639
640
641
642
643
644
645
646
647
648
649
650
651
652
653
654
655
656
657
658
659
660
661
662
663
664
665
666
667
668
669
670
671
672
673
674
675
676
677
678
679
680
681
682
683
684
685
686
687
688
689
690
691
692
693
694
695
696
697
698
699
700
701
702
703
704
705
706
707
708
709
710
711
712
713
714
715
716
717
718
719
720
721
722
723
724
725
726
727
728
729
730
731
732
733
734
735
736
737
738
739
740
741
742
743
744
745
746
747
748
749
750
751
752
753
754
755
756
757
758
759
760
761
762
763
764
765
766
767
768
769
770
771
772
773
774
775
776
777
778
779
780
781
782
783
784
785
786
787
788
789
790
791
792
793
794
795
796
797
798
799
800
801
802
803
804
805
806
807
808
809
810
811
812
813
814
815
816
817
818
819
820
821
822
823
824
825
826
827
828
829
830
831
832
833
834
835
836
837
838
839
840
841
842
843
844
845
846
847
848
849
850
851
852
853
854
855
856
857
858
859
860
861
862
863
864
865
866
867
868
869
870
871
872
873
874
875
876
877
878
879
880
881
882
883
884
885
886
887
888
889
890
891
892
893
894
895
896
897
898
899
900
901
902
903
904
905
906
907
908
909
910
911
912
913
914
915
916
917
918
919
920
921
922
923
924
925
926
927
928
929
930
931
932
933
934
935
936
937
938
939
940
941
942
943
944
945
946
947
948
949
950
951
952
953
954
955
956
957
958
959
960
961
962
963
964
965
966
967
968
969
970
971
972
973
974
975
976
977
978
979
980
981
982
983
984
985
986
987
988
989
990
991
992
993
994
995
996
997
998
999
1000
Sat Jan 21 02:32:58 UTC 2012 Adam Mitz <[email protected]>
* dds/DCPS/transport/framework/TransportSendBuffer.h:
* dds/DCPS/transport/framework/TransportSendBuffer.cpp:
Release stored data when the send buffer is destroyed.
* dds/DCPS/transport/framework/DataLink.h:
* dds/DCPS/transport/framework/DataLink.inl:
* dds/DCPS/transport/framework/DataLink.cpp:
* dds/DCPS/transport/framework/TransportImpl.h:
* dds/DCPS/transport/framework/TransportImpl.inl:
The framework should not assume a data link that has its last
association removed will be stopped (immediately or after a delay).
Instead now the framework will invoke the release_datalink() virtual
method on the derived transport impl which can decide what to do
about the data link that the framework is no longer using.
* dds/DCPS/transport/multicast/MulticastTransport.h:
* dds/DCPS/transport/multicast/MulticastTransport.cpp:
* dds/DCPS/transport/rtps_udp/RtpsUdpTransport.h:
* dds/DCPS/transport/rtps_udp/RtpsUdpTransport.cpp:
* dds/DCPS/transport/tcp/TcpTransport.h:
* dds/DCPS/transport/tcp/TcpTransport.cpp:
* dds/DCPS/transport/udp/UdpTransport.h:
* dds/DCPS/transport/udp/UdpTransport.cpp:
Adapted to data link management changes described above.
Fri Jan 20 23:59:28 UTC 2012 Adam Mitz <[email protected]>
* bin/dcps_tests.lst:
At least for now, require "-Config RTPS" to run RTPS tests.
Fri Jan 20 22:53:50 UTC 2012 Jeff Schmitz <[email protected]>
* tests/DCPS/BuiltInTopicTest/dcps.ini:
* tests/DCPS/BuiltInTopicTest/monitor.cpp:
* tests/DCPS/BuiltInTopicTest/publisher.cpp:
* tests/DCPS/BuiltInTopicTest/run_test.pl:
* tests/DCPS/BuiltInTopicTest/subscriber.cpp:
Added support for RTPS testing (currently failing).
* tests/DCPS/BuiltInTopicTest/pub.ini:
* tests/DCPS/BuiltInTopicTest/sub.ini:
Removed these files.
Fri Jan 20 22:10:58 UTC 2012 Jeff Schmitz <[email protected]>
* bin/dcps_tests.lst:
Update for new ini files.
Fri Jan 20 21:44:45 UTC 2012 Jeff Schmitz <[email protected]>
* tests/DCPS/SetQosDeadline/publisher.cpp:
* tests/DCPS/SetQosDeadline/rtps_disc.ini:
* tests/DCPS/SetQosDeadline/run_test.pl:
* tests/DCPS/SetQosDeadline/subscriber.cpp:
Allow rtps_disc mode.
* tests/DCPS/SetQosPartition/SetQosPartition.mpc:
* tests/DCPS/SetQosPartition/publisher.cpp:
* tests/DCPS/SetQosPartition/rtps_disc.ini:
* tests/DCPS/SetQosPartition/rtps_disc_tcp.ini:
* tests/DCPS/SetQosPartition/run_test.pl:
* tests/DCPS/SetQosPartition/subscriber.cpp:
Allow rtps_disc and rtps_disc_tcp mode.
Fri Jan 20 20:04:14 UTC 2012 Adam Mitz <[email protected]>
* dds/DCPS/RTPS/RtpsDiscovery.h:
* dds/DCPS/RTPS/RtpsDiscovery.cpp:
* dds/DCPS/RTPS/Sedp.cpp:
Provide a configurable parameter "SedpMulticast" which can disable
the use of multicast by the SEDP portion of discovery.
Allow the d0 configurable parameter to be defaulted by an enviornment
variable "OPENDDS_RTPS_DEFAULT_D0", which will be used for the nightly
build machines (to avoid interference).
* dds/DCPS/transport/framework/DataLink.h:
* dds/DCPS/transport/framework/DataLink.cpp:
* dds/DCPS/transport/framework/ReceiveListenerSet.h:
* dds/DCPS/transport/framework/ReceiveListenerSet.inl:
data_received() can now be called with a "destination" reader,
identified by subscription id (GUID).
* dds/DCPS/transport/rtps_udp/RtpsUdpReceiveStrategy.cpp:
Use the above feature in the transport framework to allow delivering
Data submessages to a specific reader instead of all matched readers.
* tests/DCPS/RtpsDiscovery/dcps.ini:
* tests/DCPS/RtpsDiscovery/dcps_rtps_udp.ini:
Turn off SedpMulticast for testing.
Fri Jan 20 19:02:44 UTC 2012 Jeff Schmitz <[email protected]>
* tests/DCPS/DcpsIntegration/topic.cpp:
Accicentally commented out.
Fri Jan 20 17:15:19 UTC 2012 Jeff Schmitz <[email protected]>
* tests/DCPS/ContentFilteredTopic/rtps_disc.ini:
* tests/DCPS/DcpsIntegration/rtps_disc.ini:
* tests/DCPS/DcpsIntegration/rtps_disc_tcp.ini:
* tests/DCPS/Messenger/rtps_disc.ini:
* tests/DCPS/Messenger/rtps_disc_tcp.ini:
* tests/DCPS/RtpsDiscovery/dcps.ini:
* tests/DCPS/RtpsDiscovery/dcps_rtps_udp.ini:
Configure RTPS discovery with a shorter resend period (2s).
Fri Jan 20 16:44:04 UTC 2012 Jeff Schmitz <[email protected]>
* tests/DCPS/DcpsIntegration/rtps_disc.ini:
* tests/DCPS/DcpsIntegration/rtps_disc_tcp.ini:
* tests/DCPS/DcpsIntegration/run_test-topic.pl:
* tests/DCPS/DcpsIntegration/topic.cpp:
Allow test to run in rtps_disc or rtps_disc_tcp modes.
Fri Jan 20 15:46:27 UTC 2012 Adam Mitz <[email protected]>
* Merged from trunk r5111 through r5254.
Fri Jan 20 15:02:34 UTC 2012 Jeff Schmitz <[email protected]>
* tests/DCPS/ContentFilteredTopic/ContentFilteredTopicTest.cpp:
Make reader and writer reliable.
Don't wait for acks when using RTPS discovery.
* tests/DCPS/ContentFilteredTopic/run_test.pl:
* tests/DCPS/ContentFilteredTopic/rtps_disc.ini
Run with RTPS discovery using argument rtps_disc
Thu Jan 19 21:11:58 UTC 2012 Adam Mitz <[email protected]>
* dds/DCPS/transport/framework/DataLink.cpp:
Revert change from my prior commit. This was just for checking
the datalink_release_delay_ in cancel_release(), and it doesn't
seem to be working.
* dds/DCPS/transport/rtps_udp/RtpsUdpDataLink.cpp:
Manage disabling of the heartbeat timer in the handle_timeout()
itself to avoid needing to call into the ACE Reactor while locked.
* tests/DCPS/Messenger/subscriber.cpp:
Enable RELIABILITY QoS in the Data Reader when running
with the rtps_udp transport.
Thu Jan 19 20:39:31 UTC 2012 Jeff Schmitz <[email protected]>
* dds/DCPS/RTPS/Sedp.cpp:
Fix shutdown crash accessing pub_bit() or sub_bit()
while shutting down.
Thu Jan 19 19:49:26 UTC 2012 Jeff Schmitz <[email protected]>
* dds/DCPS/RTPS/ParameterListConverter.cpp:
* dds/DCPS/RTPS/Sedp.cpp:
* dds/DCPS/RTPS/Spdp.cpp:
Consistent logging.
Log errors unconditionally.
Remove unnecessary TODO comments.
Thu Jan 19 18:29:36 UTC 2012 Adam Mitz <[email protected]>
* dds/DCPS/transport/rtps_udp/RtpsUdpDataLink.h:
* dds/DCPS/transport/rtps_udp/RtpsUdpDataLink.cpp:
* dds/DCPS/transport/rtps_udp/RtpsUdpTransport.h:
* dds/DCPS/transport/rtps_udp/RtpsUdpTransport.cpp:
Locking for shared data structures. Condition variable for
the transport to wait for handshake events.
* tests/DCPS/RtpsDiscovery/run_test.pl:
Corrected error logging.
Thu Jan 19 18:24:50 UTC 2012 Jeff Schmitz <[email protected]>
* dds/DCPS/RTPS/Sedp.cpp:
Removed todo comment, added other, realated one.
Thu Jan 19 18:16:44 UTC 2012 Jeff Schmitz <[email protected]>
* dds/DCPS/RTPS/Sedp.cpp:
* dds/DCPS/RTPS/Spdp.h:
* dds/DCPS/RTPS/Spdp.cpp:
Added associated() method to tell caller if we know of any other
participants.
Don't publish samples when there are no other participants.
Log warning when running out of bit keys.
Remove Todo comments where there is no additional error handling.
* tests/DCPS/TransientLocalTest/DataWriterListenerImpl.cpp:
Fix log msg.
Thu Jan 19 16:45:53 UTC 2012 Jeff Schmitz <[email protected]>
* dds/DCPS/DataWriterImpl.h:
* dds/DCPS/DataWriterImpl.cpp:
Refactor determination if need sequence repair bit should be set.
Call when creating control message too.
Thu Jan 19 16:11:04 UTC 2012 Adam Mitz <[email protected]>
* dds/DCPS/AssociationData.h:
* dds/DCPS/DataReaderImpl.cpp:
* dds/DCPS/DataWriterImpl.cpp:
AssociationData now contains a "remote_reliable_" bool,
which indicates to each side if the other has enabled reliability.
* dds/DCPS/RTPS/Sedp.h:
* dds/DCPS/RTPS/Sedp.cpp:
Run the SEDP association steps on their own thread. This allows
the SPDP reactor thread to be available for the periodic send.
Reader-side associations need to start first.
Configure SEDP's transport with a "handshake_timeout_" value based
on the way the user has configured the Discovery object's resend
period, and removed opendds_discovery_guid_ since it's no longer used.
match_endpoints() can use a background thread if both sides are local.
* dds/DCPS/transport/framework/DataLink.cpp:
* dds/DCPS/transport/framework/TransportClient.h:
* dds/DCPS/transport/framework/TransportClient.cpp:
* dds/DCPS/transport/framework/TransportImpl.h:
* dds/DCPS/transport/framework/TransportImpl.cpp:
Use the new "remote_reliable_" flag in AssociationData so that the
individual transport types can have access to this bit of info.
Other minor cleanup.
* dds/DCPS/transport/multicast/MulticastTransport.h:
* dds/DCPS/transport/multicast/MulticastTransport.cpp:
* dds/DCPS/transport/tcp/TcpTransport.h:
* dds/DCPS/transport/tcp/TcpTransport.cpp:
* dds/DCPS/transport/udp/UdpTransport.h:
* dds/DCPS/transport/udp/UdpTransport.cpp:
Adapted the non-RTPS transports to the framework changes above.
* dds/DCPS/transport/rtps_udp/RtpsUdpDataLink.h:
* dds/DCPS/transport/rtps_udp/RtpsUdpDataLink.cpp:
* dds/DCPS/transport/rtps_udp/RtpsUdpInst.h:
* dds/DCPS/transport/rtps_udp/RtpsUdpInst.cpp:
* dds/DCPS/transport/rtps_udp/RtpsUdpReceiveStrategy.cpp:
* dds/DCPS/transport/rtps_udp/RtpsUdpTransport.h:
* dds/DCPS/transport/rtps_udp/RtpsUdpTransport.cpp:
Implemented handshaking for new RTPS associations. The writer side
will send a heartbeat and wait (for a configurable timeout) until
the reader acknowledges. This applies to reliable readers only.
Corrected handling of INFO_DST submessages and the "destination
prefix." Removed hacks previously needed by Discovery.
* bin/dcps_tests.lst:
* tests/DCPS/Messenger/run_test.pl:
Cleaned up logging options and added RTPS configs to the nightlies.
* tests/transport/rtps_reliability/rtps_reliability.cpp:
Added the initial heartbeat/acknack handshake.
* tests/transport/rtps/publisher.cpp:
* tests/transport/rtps/subscriber.cpp:
* tests/transport/simple/PubDriver.cpp:
* tests/transport/simple/SubDriver.cpp:
Adapted transport-level tests for "remote_reliable_".
Thu Jan 19 15:48:59 UTC 2012 Adam Mitz <[email protected]>
* dds/idl/CPPTemplate.txt:
* dds/DCPS/DataWriterImpl.cpp:
Need to use next_send_sample_ in the DataSampleListElement.
Updated generated code for newer use of the reader_info_ map.
* dds/DCPS/RTPS/Sedp.cpp:
Handle the fact that expectsInlinieQos appears on both the
participant and subscription discovery data.
* dds/DCPS/RTPS/Spdp.h:
* dds/DCPS/RTPS/Spdp.cpp:
Pass RepoId by reference.
* tests/DCPS/TransientLocalTest/run_test.pl:
Cleaned up Perl script.
* tools/dissector/packet-opendds.cpp:
* tools/dissector/sample_dissector.cpp:
Updated to compile against latest Wireshark version.
Wed Jan 18 20:55:52 UTC 2012 Jeff Schmitz <[email protected]>
* dds/DCPS/DataWriterImpl.cpp:
Track reader_info_, even when not building in content profile.
Increment sequence number when sending historic sample - make
all transports behave like the RTPS spec.
Update reader_info_ when sending control message or a
historic sample.
Tue Jan 17 20:19:12 UTC 2012 Jeff Schmitz <[email protected]>
* dds/DCPS/RTPS/Sedp.cpp:
If no Locators provided for endpoint, use default locators provided
by SPDP.
* dds/DCPS/RTPS/Spdp.h:
* dds/DCPS/RTPS/Spdp.cpp:
Provide access to default locators and expectsInlineQos for a
participant.
Tue Jan 17 18:15:52 UTC 2012 Jeff Schmitz <[email protected]>
* dds/DCPS/RTPS/Sedp.cpp:
Republish local publications and local subscriptions when topic_data
changes.
* tests/DCPS/RtpsDiscovery/RtpsDiscoveryTest.cpp:
Change topic_data on writer topic.
Tue Jan 17 15:58:35 UTC 2012 Jeff Schmitz <[email protected]>
* dds/DCPS/transport/rtps_udp/RtpsSampleHeader.cpp:
Set opendds header historic sample flag when the DataSubmessage
contains PID_ORIGINAL_WRITER_INFO.
Mon Jan 16 23:17:19 UTC 2012 Jeff Schmitz <[email protected]>
* dds/DCPS/transport/rtps_udp/RtpsSampleHeader.cpp:
If historic_sample_, populate and add OriginalWriterInfo to
DataSubmessage.
Mon Jan 16 19:42:44 UTC 2012 Jeff Schmitz <[email protected]>
* dds/DCPS/DataSampleList.h:
* dds/DCPS/DataSampleList.inl:
Add originalSequence_ to DataSampleListElement.
* dds/DCPS/RTPS/Sedp.h:
* dds/DCPS/RTPS/Sedp.cpp:
Add original_sequence_ to LocalEndpoint, and set when sending first
sample.
Fri Jan 13 18:43:53 UTC 2012 Jeff Schmitz <[email protected]>
* dds/DCPS/RTPS/Sedp.cpp:
Memory leaks in Sedp messaging.
Thu Jan 12 23:16:01 UTC 2012 Adam Mitz <[email protected]>
* dds/DCPS/GuidConverter.cpp:
Added built-in entity kinds for reader and writer.
* dds/DCPS/transport/rtps_udp/RtpsUdpDataLink.h:
* dds/DCPS/transport/rtps_udp/RtpsUdpDataLink.cpp:
* dds/DCPS/transport/rtps_udp/RtpsUdpTransport.cpp:
Continued enabling reliability for the SEDP endpoints.
Thu Jan 12 20:42:55 UTC 2012 Adam Mitz <[email protected]>
* dds/DCPS/transport/rtps_udp/RtpsUdpInst.h:
* dds/DCPS/transport/rtps_udp/RtpsUdpInst.cpp:
* dds/DCPS/transport/rtps_udp/RtpsUdpTransport.h:
* dds/DCPS/transport/rtps_udp/RtpsUdpTransport.cpp:
Provide a way for discovery to tell the transport about
its local GUID so that the DataLink can be created before
there are any associations made.
* dds/DCPS/RTPS/Sedp.cpp:
Use the above.
Thu Jan 12 17:28:15 UTC 2012 Adam Mitz <[email protected]>
* dds/DCPS/RTPS/Sedp.h:
* dds/DCPS/RTPS/Sedp.cpp:
Initialize the entityId in the GUID that's used for lookup.
Thu Jan 12 17:24:37 UTC 2012 Jeff Schmitz <[email protected]>
* dds/DCPS/RTPS/ParameterListConverter.cpp:
Make use of != operators for Qos policies in Qos_Helper.h
* dds/DCPS/RTPS/Sedp.cpp:
Remove temporary log messages. Proper format of one other.
Thu Jan 12 17:17:46 UTC 2012 Adam Mitz <[email protected]>
* dds/DCPS/RTPS/ParameterListConverter.cpp:
Initialize expectsInlineQos to its default (false).
* dds/DCPS/transport/framework/TransportClient.cpp:
Initialize repo_id_ for the use cases like RTPS BITs
that will never actually enable the transport.
Thu Jan 12 16:57:33 UTC 2012 Jeff Schmitz <[email protected]>
* dds/DCPS/RTPS/Sedp.cpp:
* dds/DCPS/RTPS/Spdp.h:
* dds/DCPS/RTPS/Spdp.cpp:
Added shutdown flag to eliminate transport callbacks while in
destructor.
Thu Jan 12 15:41:19 UTC 2012 Adam Mitz <[email protected]>
* dds/DCPS/RTPS/Spdp.cpp:
Need check for a valid Participant BIT Data Reader since it can
be null during the participant's shutdown.
Thu Jan 12 15:03:46 UTC 2012 Adam Mitz <[email protected]>
* dds/DCPS/RTPS/Sedp.cpp:
Added logging, these still need to be made conditional on debug level.
* java/tests/messenger/both/Both.java:
* java/tests/messenger/publisher/TestPublisher.java:
* java/tests/messenger/subscriber/TestSubscriber.java:
* tests/DCPS/Messenger/stack_subscriber.cpp:
Updated domain ID to match change to main messenger test.
* tests/DCPS/Messenger/run_test.pl:
Added timestamps to logging for rtps_disc_tcp, for use
during development.
Wed Jan 11 23:12:09 UTC 2012 Adam Mitz <[email protected]>
* dds/DCPS/RTPS/Sedp.cpp:
Fixed bugs.
* dds/DCPS/RTPS/Spdp.cpp:
Cleaned up new code for finding the unicast SPDP port.
* tests/DCPS/Messenger/Writer.cpp:
* tests/DCPS/Messenger/publisher.cpp:
* tests/DCPS/Messenger/rtps_disc.ini:
* tests/DCPS/Messenger/rtps_disc_tcp.ini:
* tests/DCPS/Messenger/run_test.pl:
* tests/DCPS/Messenger/subscriber.cpp:
Updated test for RTPS. Added the rtps_disc_tcp test scenario which
uses RTPS Discovery with the default OpenDDS TCP transport for user
topics.
Check total_count in the subscription matched status.
Use consistent logging levels for both processes.
Wed Jan 11 21:53:17 UTC 2012 Jeff Schmitz <[email protected]>
* dds/DCPS/RTPS/Spdp.h:
* dds/DCPS/RTPS/Spdp.cpp:
Try a series of unicast ports for SpdpTransport.
* tests/DCPS/Messenger/rtps_disc.ini:
* tests/DCPS/Messenger/run_test.pl:
Add ability to run messenger in RTPS discovery mode.
Wed Jan 11 21:53:01 UTC 2012 Adam Mitz <[email protected]>
* dds/DCPS/RTPS/Sedp.cpp:
Both QoS and filter params can change in the same
DiscoveredReaderData data sample.
Wed Jan 11 20:55:23 UTC 2012 Adam Mitz <[email protected]>
* dds/DCPS/RTPS/Sedp.cpp:
Fixed bugs in remove_publication() and subscription.
Wed Jan 11 20:06:58 UTC 2012 Jeff Schmitz <[email protected]>
* dds/DCPS/RTPS/Sedp.cpp:
Rerun match of endpoints for removal when ignoring topic.
Wed Jan 11 20:00:21 UTC 2012 Adam Mitz <[email protected]>
* dds/DCPS/RTPS/Sedp.h:
* dds/DCPS/RTPS/Sedp.cpp:
Move qosChanged() to anonymous-namespace instead of being members of
the class. Added paramsChanged() which is similar but works with the
content filtering parameters.
In cases where content filtering parameters change, invoke the
needed callbacks on DataWriterRemote.
Explicity check for dispose/unregister message types instead of
assuming that the non-SAMPLE_DATA ones are dispose/unregister.
Wed Jan 11 19:55:07 UTC 2012 Jeff Schmitz <[email protected]>
* dds/DCPS/RTPS/Sedp.cpp:
Rerun match of endpoints for removal when ignoring discovered pub/sub.
Wed Jan 11 19:25:36 UTC 2012 Jeff Schmitz <[email protected]>
* dds/DCPS/RTPS/Sedp.cpp:
Rerun match of endpoints for removal when removing local pub/sub.
Wed Jan 11 19:20:07 UTC 2012 Jeff Schmitz <[email protected]>
* dds/DCPS/RTPS/Sedp.cpp:
Rerun match of endpoints when modifying local pub/sub Qos values.
Wed Jan 11 19:00:23 UTC 2012 Adam Mitz <[email protected]>
* dds/DCPS/RTPS/Sedp.h:
* dds/DCPS/RTPS/Sedp.cpp:
Keep track of currently-matched endpoints in local publications and
subscriptions. Provide a method for unmatching when some publication
or subscription is going away. Ability to unmatch when QoS changes.
* tests/DCPS/ConfigFile/ConfigFile.cpp:
Update default passive_connect_duration_.
Wed Jan 11 18:52:58 UTC 2012 Jeff Schmitz <[email protected]>
* dds/DCPS/RTPS/Spdp.cpp:
Revert last change, release lock prior to actions destructive to
SpdpTransport.
Wed Jan 11 18:01:51 UTC 2012 Jeff Schmitz <[email protected]>
* dds/DCPS/RTPS/Spdp.cpp:
Don't obtain lock while in SpdpTransport destructor. It is already
held, and we are only setting a bool, which should be atomic.
Wed Jan 11 17:10:16 UTC 2012 Jeff Schmitz <[email protected]>
* dds/DCPS/RTPS/RtpsInfo.h:
* dds/DCPS/RTPS/RtpsInfo.cpp:
Lock, find Sedp in map, unlock, then use Sedp as general pattern.
Comment verifying acceptable holding of lock during Sedp call
where required.
Wed Jan 11 16:10:54 UTC 2012 Jeff Schmitz <[email protected]>
* dds/DCPS/RTPS/Sedp.cpp:
Call match_endpoints when discovered publication and subscription
are has Qos changed, or are disposed/removed.
Tue Jan 10 23:24:03 UTC 2012 Adam Mitz <[email protected]>
* dds/DCPS/RTPS/Sedp.cpp:
Initialize all QoS data members when constructing from BIT data.
* dds/DCPS/transport/framework/TransportConfig.cpp:
Extend the default passive connect duration to 60 seconds in order
to account for the (default) SPDP rebroadcast period of 30 seconds.
* dds/idl/CPPTemplate.txt:
Corrected a bug in how fixed-size data types use the allocators
with RTPS-compliant marshaling.
* tests/DCPS/RtpsDiscovery/RtpsDiscoveryTest.cpp:
* tests/DCPS/RtpsDiscovery/dcps_rtps_udp.ini:
Extended the test to write and read a sample.
Cleaned up the test and removed some sleeps.
When run with RTPS transport, need two insts -- one per participant.
Tue Jan 10 23:14:23 UTC 2012 Jeff Schmitz <[email protected]>
* dds/DCPS/RTPS/Sedp.cpp:
Don't access local publication/subscription iter unchecked.
Tue Jan 10 22:50:14 UTC 2012 Jeff Schmitz <[email protected]>
* dds/DCPS/RTPS/Sedp.cpp:
Make copy of DiscoveredWriterData/DiscoveredReader in data_received(),
instead of using input rdata/wdata, which are incomplete.
Tue Jan 10 22:36:26 UTC 2012 Jeff Schmitz <[email protected]>
* dds/DCPS/RTPS/Sedp.cpp:
Bug - was not setting local instance_handle.
Tue Jan 10 21:27:28 UTC 2012 Jeff Schmitz <[email protected]>
* dds/DCPS/RTPS/Sedp.cpp:
Deadlock - release lock when calling into part_bit within
data_received().
* dds/DCPS/RTPS/Spdp.cpp:
Added lock to data_received() overloads.
Same data_received() changes as above, releasing when calling into
pub_bit and sub_bit.
Copy more items in match() before releasing lock.
Mon Jan 9 23:09:39 UTC 2012 Jeff Schmitz <[email protected]>
* dds/DCPS/RTPS/RtpsInfo.h:
* dds/DCPS/RTPS/RtpsInfo.cpp:
Mutex protection.
Mon Jan 9 22:59:28 UTC 2012 Jeff Schmitz <[email protected]>
* dds/DCPS/RTPS/Sedp.cpp:
Mutex protection.
Add encapsulation header to the control messages.
Mon Jan 9 22:12:52 UTC 2012 Adam Mitz <[email protected]>
* dds/DCPS/RTPS/Sedp.cpp:
Implemented association_complete() on the active side.
* dds/DCPS/RTPS/Spdp.cpp:
Fix locking for shutdown of Spdp.
* tests/DCPS/RtpsDiscovery/RtpsDiscoveryTest.cpp:
* tests/DCPS/RtpsDiscovery/run_test.pl:
Extend test to write and read a TestMsg data sample.
Mon Jan 9 20:35:52 UTC 2012 Adam Mitz <[email protected]>
* dds/DCPS/RTPS/Sedp.h:
* dds/DCPS/RTPS/Sedp.cpp:
Implemented support for first being notified of a topic via one of
its (remote) subscriptions.
* dds/idl/marshal_generator.cpp:
Fixed bug in ParameterList internal vs. trailing padding.
* tests/DCPS/RtpsMessages/RtpsMessagesTest.cpp:
Extend error message from test.
Mon Jan 9 19:41:05 UTC 2012 Jeff Schmitz <[email protected]>
* dds/DCPS/RTPS/Sedp.cpp:
* dds/DCPS/RTPS/Spdp.cpp:
Mutex protection.
Mon Jan 9 18:49:04 UTC 2012 Jeff Schmitz <[email protected]>
* dds/DCPS/RTPS/Sedp.cpp:
Fix bug when looking up discovered subscriber - was passing
in writer guid, rather than reader guid.
Mon Jan 9 18:20:28 UTC 2012 Adam Mitz <[email protected]>
* tests/DCPS/RtpsMessages/RtpsMessagesTest.cpp:
Extended test to expose problem with internal padding in
a Parameter that's part of a ParameterList.
Mon Jan 9 17:46:59 UTC 2012 Jeff Schmitz <[email protected]>
* dds/DCPS/RTPS/ParameterListConverter.cpp:
* tests/DCPS/UnitTests/ut_ParameterListConverter.cpp:
Don't serialize content filter property when empty filter string.
When we *do* serialize, use "DDSSQL" in place of an empty
filterClassName.
Mon Jan 9 16:09:41 UTC 2012 Adam Mitz <[email protected]>
* tests/transport/rtps/publisher.cpp:
* tests/transport/rtps/subscriber.cpp:
* tests/transport/rtps_reliability/rtps_reliability.cpp:
Updated tests to use the new rtps_udp transport blob format.
Sun Jan 8 00:24:26 UTC 2012 Adam Mitz <[email protected]>
* tests/DCPS/UnitTests/ut_ParameterListConverter.cpp:
blob_to_locators() now requires a 3rd argument.
Fri Jan 6 23:17:19 UTC 2012 Jeff Schmitz <[email protected]>
* dds/DCPS/RTPS/Sedp.h:
* dds/DCPS/RTPS/Sedp.cpp:
Publish subscription data.
Fri Jan 6 22:57:47 UTC 2012 Adam Mitz <[email protected]>
* dds/DCPS/RTPS/BaseMessageUtils.h:
* dds/DCPS/RTPS/ParameterListConverter.cpp:
* dds/DCPS/RTPS/Sedp.h:
* dds/DCPS/RTPS/Sedp.cpp:
Keep track of content filtering info for local subscriptions.
Account for topics that Sedp first learns about through discovery
of publications or subscriptions using said topics.
Support requires_inline_qos().
* dds/DCPS/transport/rtps_udp/RtpsUdpDataLink.h:
* dds/DCPS/transport/rtps_udp/RtpsUdpDataLink.cpp:
* dds/DCPS/transport/rtps_udp/RtpsUdpTransport.h:
* dds/DCPS/transport/rtps_udp/RtpsUdpTransport.cpp:
Implemented requires_inline_qos().
* tests/DCPS/RtpsDiscovery/RtpsDiscovery.mpc:
* tests/DCPS/RtpsDiscovery/RtpsDiscoveryTest.cpp:
* tests/DCPS/RtpsDiscovery/dcps_rtps_udp.ini:
* tests/DCPS/RtpsDiscovery/run_test.pl:
Extend the test to run with different transport configs and also
to create a data reader and wait for the writer to match it.
This does not work yet.
Fri Jan 6 21:46:47 UTC 2012 Jeff Schmitz <[email protected]>
* dds/DCPS/RTPS/Sedp.h:
* dds/DCPS/RTPS/Sedp.cpp:
Cleanup.
Set headers consistently in common place.
Set headers in dispose msg.
Fri Jan 6 21:36:49 UTC 2012 Jeff Schmitz <[email protected]>
* dds/DCPS/RTPS/ParameterListConverter.cpp:
* tests/DCPS/UnitTests/ut_ParameterListConverter.cpp:
Account for reliability QOS with an index of 1.
Account for reliability QOS having different defaults for
reader and writer.
Fri Jan 6 19:48:09 UTC 2012 Jeff Schmitz <[email protected]>
* dds/DCPS/RTPS/Sedp.cpp:
Literal serialization of PL_CDR_LE value
Fri Jan 6 19:03:48 UTC 2012 Jeff Schmitz <[email protected]>
* dds/DCPS/RTPS/Sedp.cpp:
Serialize encapsulation header.
Set header publication ID, timestamp.
Fri Jan 6 18:11:41 UTC 2012 Adam Mitz <[email protected]>
* performance-tests/Bench/src/Publication.cpp:
* performance-tests/Bench/src/Subscription.cpp:
* performance-tests/DCPS/Priority/Subscriber.cpp:
* performance-tests/DCPS/Priority/Writer.cpp:
* tools/dissector/giop_base.cpp:
* tools/dissector/packet-datawriter.cpp:
* tools/dissector/packet-opendds.h:
* tools/dissector/packet-opendds.cpp:
* tools/dissector/packet-repo.cpp:
* tools/dissector/sample_manager.h:
Replaced uses of RepoIdConverter with GuidConverter.
The only remaining uses of RepoIdConverter should be in
the DCPSInfoRepo code or tests. The exception to this rule
is in the multicast transport, which should be fixed eventually.
Fri Jan 6 17:42:04 UTC 2012 Jeff Schmitz <[email protected]>
* dds/DCPS/RTPS/Sedp.h:
* dds/DCPS/RTPS/Sedp.cpp:
Refator message publication.
Publish durable data on new association.
* dds/DCPS/RTPS/Spdp.cpp:
Share mutex with Sedp.
Fri Jan 6 17:16:45 UTC 2012 Adam Mitz <[email protected]>
* dds/DCPS/RTPS/Spdp.cpp:
Fixed bugs in time value comparison and getting "empty" messages for
SPDP dispose/unregister. Improved logging.
* dds/DCPS/transport/framework/DataLink.h:
* dds/DCPS/transport/framework/DataLink.cpp:
Fixed doxygen and logging statements.
Fri Jan 6 16:35:54 UTC 2012 Jeff Schmitz <[email protected]>
* dds/DCPS/RTPS/Sedp.h:
* dds/DCPS/RTPS/Sedp.cpp:
beginnings of writing durable data.
Return a value from publish_unregister_dispose().
Fri Jan 6 15:37:45 UTC 2012 Jeff Schmitz <[email protected]>
* dds/DCPS/RTPS/ParameterListConverter.cpp:
* tests/DCPS/UnitTests/ut_ParameterListConverter.cpp:
Make locator changes for reader like writer.
Refactor add_ method names for locators
* dds/DCPS/RTPS/Sedp.h:
* dds/DCPS/RTPS/Sedp.cpp:
Handle update publication and remove publication.
Publish control message with one param (a guid).
Thu Jan 5 23:36:15 UTC 2012 Adam Mitz <[email protected]>
* dds/DCPS/RTPS/RtpsBaseMessageTypes.idl:
Added a comment on PID_ENDPOINT_GUID not being in the spec.
Changed the range of the vendor-specific PIDs for OpenDDS.
* dds/DCPS/RTPS/Sedp.h:
* dds/DCPS/RTPS/Sedp.cpp:
Started implementing logic to match associated readers and writers.
* dds/DCPS/transport/multicast/MulticastTransport.cpp:
Use ACE_INET_Addr::is_multicast() to check the config.
* dds/DCPS/transport/rtps_udp/RtpsUdpTransport.cpp:
Avoid a crash if the DataLink fails to initialize.
Thu Jan 5 22:13:21 UTC 2012 Jeff Schmitz <[email protected]>
* dds/DCPS/RTPS/ParameterListConverter.cpp:
Make use of new PID_ENDPOINT_GUID.
Encode from TransportLocators instead of RTPS locator lists to
preserve ordering.
Decode to TransportLocators instead of RTPS locator lists.
* tests/DCPS/UnitTests/ut_ParameterListConverter.cpp:
Tests for above changes.
Thu Jan 5 20:49:12 UTC 2012 Jeff Schmitz <[email protected]>
* dds/DCPS/RTPS/RtpsBaseMessageTypes.idl:
Added PID_ENDPOINT_GUID.
Thu Jan 5 19:10:10 UTC 2012 Jeff Schmitz <[email protected]>
* dds/DCPS/RTPS/BaseMessageUtils.h:
Added locators_to_blob(), the inverse of blob_to_locators().
* dds/DCPS/RTPS/RtpsBaseMessageTypes.idl:
Added PID_OPENDDS_LOCATOR custom pid.
Added opendds_locator to Parameter.
* dds/DCPS/RTPS/Sedp.cpp:
Remove TODO line, with intentional warning.
* dds/DCPS/transport/rtps_udp/RtpsUdpTransport.cpp:
Make use of locator_to_address().
Thu Jan 5 17:23:14 UTC 2012 Adam Mitz <[email protected]>
* dds/DCPS/RTPS/RtpsInfo.cpp:
Improve use of std::map operations.
* dds/DCPS/RTPS/Sedp.h:
* dds/DCPS/RTPS/Sedp.cpp:
Moved Writer constructor to the cpp file.
Added set of GUIDs (publications/subscriptions) to the Topic info.
Improve use of std::map operations.
Thu Jan 5 15:54:04 UTC 2012 Adam Mitz <[email protected]>
* dds/DCPS/RTPS/Sedp.h:
* dds/DCPS/RTPS/Sedp.cpp:
Keep track of ignored topic names. When receiving data samples
for remote publications and subscriptions, ignore the sample if
the publication/subscription, participant, or topic are in the
ignore lists.
* dds/DCPS/transport/rtps_udp/RtpsUdpInst.cpp:
Fix logging of ACE_INET_Addr objects. ACE uses a static
local character buffer so two addresses can't be logged at once.
* tests/DCPS/RtpsDiscovery/RtpsDiscoveryTest.cpp:
Extended the test to read the publication BIT. For now this fails.
Refactored the test so it's not all happening in main().
Fixed scope of _vars and usage issues with WaitSet.
Wed Jan 4 22:27:09 UTC 2012 Jeff Schmitz <[email protected]>
* tests/DCPS/RtpsDiscovery/run_test.pl:
Revert capture to test.log
Wed Jan 4 22:24:27 UTC 2012 Jeff Schmitz <[email protected]>
* dds/DCPS/RTPS/BaseMessageUtils.h:
Added locator_to_address().
Make blob_to_locators() accept a reference.
Wed Jan 4 20:49:39 UTC 2012 Adam Mitz <[email protected]>
* dds/DCPS/RepoIdBuilder.h:
* dds/DCPS/RepoIdBuilder.inl:
* dds/DCPS/RepoIdConverter.h:
* dds/DCPS/RepoIdConverter.cpp:
Removed methods that required assumptions about the way that
InstanceHandles and BuiltinTopicKeys were assigned. Those
asssumptions are no longer valid with RTPS discovery.
* dds/DCPS/Discovery.h: