BUG&优化项

陈清红

2025-04-14 880f3c0257eeb8c37761d484258fdd102a369a19

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
Quintiq file version 2.0
#parent: #root
MethodOverride ExecuteOutbound
{
  TextBody:
  [*
    connector := guard( this.DistributedServiceProviderBase().Connector(), null( DSP_ConnectorBase ) );
    if ( not isnull( connector ) )
    {  
      traverse ( this, RegisteredSlaveNode, slave, slave.NeedSent()  )
      { 
        assert( this.SentQueue().IsEmpty(), "Messsage left in sent queue" );
        
        current_mesage := guard ( slave.LastSentOperationMessage().NextMessage()
                                , this.OutboundMasterQueue().FirstMessage()
                                );
                                
        while ( not isnull( current_mesage ) )
        {
          message_copy := current_mesage.DeepCopy().astype( DSP_OperationMessage ); 
          this.SentQueue().AddMessage( &message_copy );        
          current_mesage := current_mesage.NextMessage();
        }
        
        connector.SentMessages( slave.NodeId(), this.SentQueue() );   
        
        this.SentQueue().Flush();
        
        slave.LastSentOperationMessage( relset, this.OutboundMasterQueue().LastMessage() );
      }
    }
    else
    {
      info( "Distributed Service Provider has no connector" );
    }
  *]
}