tianping526 opened a new issue, #294: URL: https://github.com/apache/rocketmq-clients/issues/294
```golang // github.com/apache/rocketmq-clients/[email protected]/rpc_client.go:98 // github.com/apache/rocketmq-clients/[email protected]/rpc_client.go:98 func (rc *rpcClient) QueryRoute(ctx context.Context, request *v2.QueryRouteRequest) (*v2.QueryRouteResponse, error) { rc.activityNanoTime = time.Now() // DATA RACE resp, err := rc.msc.QueryRoute(ctx, request) sugarBaseLogger.Debugf("queryRoute request: %v, response: %v, err: %v", request, resp, err) return resp, err } ================== ================== // github.com/apache/rocketmq-clients/[email protected]/rpc_client.go:137 // github.com/apache/rocketmq-clients/[email protected]/rpc_client.go:137 func (rc *rpcClient) ReceiveMessage(ctx context.Context, request *v2.ReceiveMessageRequest) (v2.MessagingService_ReceiveMessageClient, error) { rc.activityNanoTime = time.Now() // DATA RACE resp, err := rc.msc.ReceiveMessage(ctx, request) sugarBaseLogger.Debugf("receiveMessage request: %v, err: %v", request, err) return resp, err } ================== ================== // github.com/apache/rocketmq-clients/[email protected]/metric.go:166 func (dcmp *defaultClientMeterProvider) isEnabled() bool { return dcmp.clientMeter.enabled // DATA RACE } // github.com/apache/rocketmq-clients/[email protected]/metric.go:183 if !metric.GetOn() { dcmp.clientMeter.shutdown() sugarBaseLogger.Infof("metric is off, clientId=%s", dcmp.client.GetClientID()) dcmp.clientMeter = NewDefaultClientMeter(nil, false, nil, dcmp.client.GetClientID()) // DATA RACE return } ================== ================== // github.com/apache/rocketmq-clients/[email protected]/producer_options.go:117 func (ps *producerSettings) IsValidateMessageType() bool { return ps.validateMessageType // DATA RACE } // github.com/apache/rocketmq-clients/[email protected]/producer_options.go:163 } ps.validateMessageType = v.Publishing.GetValidateMessageType() ps.maxBodySizeBytes = int(v.Publishing.GetMaxBodySize()) // DATA RACE ================== ================== // github.com/apache/rocketmq-clients/[email protected]/message_id_codec.go:138 // github.com/apache/rocketmq-clients/[email protected]/message_id_codec.go:139 deltaSeconds := deltaSeconds() if seconds != deltaSeconds { // DATA RACE seconds = deltaSeconds // DATA RACE } ================== ================== // github.com/apache/rocketmq-clients/[email protected]/producer.go:288 if uMsg.pubMsg == nil { pubMessage, err = NewPublishingMessage(msg, p.pSetting, txEnabled) // DATA RACE if err != nil { return nil, err } } // github.com/apache/rocketmq-clients/[email protected]/producer_options.go:164 ps.validateMessageType = v.Publishing.GetValidateMessageType() ps.maxBodySizeBytes = int(v.Publishing.GetMaxBodySize()) // DATA RACE ``` -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
