191
// Do not mutate the returned pointer, as doing so will cause cache inconsistency.
192
// If there is no user data, this can return a nil value with no error.
193
>
func (m *userDataManagerImpl) GetUserData() (*persistencespb.VersionedTaskQueueUserData, chan struct{}, error) {
user_data_manager.go
194
>
m.lock.Lock()
195
>
defer m.lock.Unlock()
196
>
return m.getUserDataLocked()
197
>
}
198
199
>
func (m *userDataManagerImpl) getUserDataLocked() (*persistencespb.VersionedTaskQueueUserData, chan struct{}, error) {
user_data_manager.go
200
>
switch m.userDataState {
201
>
case userDataEnabled:
202
>
return m.userData, m.userDataChanged, nil
203
case userDataClosed:
204
return nil, nil, errTaskQueueClosed