uber/cadence | Build 18 | common/persistence/statsComputer.go | Coveralls

29

func (sc *statsComputer) computeMutableStateStats(req *InternalGetWorkflowExecutionResponse) *MutableStateStats {

738✔

30

        executionInfoSize := computeExecutionInfoSize(req.State.ExecutionInfo)

738✔

31

738✔

32

        activityInfoCount := 0

738✔

33

        activityInfoSize := 0

738✔

34

        for _, ai := range req.State.ActivityInfos {

832✔

35

                activityInfoCount++

94✔

36

                activityInfoSize += computeActivityInfoSize(ai)

94✔

37

94✔

39

        timerInfoCount := 0

738✔

40

        timerInfoSize := 0

738✔

41

        for _, ti := range req.State.TimerInfos {

739✔

42

                timerInfoCount++

1✔

43

                timerInfoSize += computeTimerInfoSize(ti)

1✔

44

1✔

46

        childExecutionInfoCount := 0

738✔

47

        childExecutionInfoSize := 0

738✔

48

        for _, ci := range req.State.ChildExecutionInfos {

742✔

49

                childExecutionInfoCount++

4✔

50

                childExecutionInfoSize += computeChildInfoSize(ci)

4✔

51

4✔

53

        signalInfoCount := 0

738✔

54

        signalInfoSize := 0

738✔

55

        for _, si := range req.State.SignalInfos {

738✔

60

        bufferedEventsCount := 0

738✔

61

        bufferedEventsSize := 0

738✔

62

738✔

63

        for _, be := range req.State.BufferedEvents {

741✔

64

                bufferedEventsCount++

3✔

65

                bufferedEventsSize += len(be.Data)

3✔

66

3✔

68

        requestCancelInfoCount := len(req.State.RequestCancelInfos)

738✔

69

738✔

70

        totalSize := executionInfoSize

738✔

71

        totalSize += activityInfoSize

738✔

72

        totalSize += timerInfoSize

738✔

73

        totalSize += childExecutionInfoSize

738✔

74

        totalSize += signalInfoSize

738✔

75

        totalSize += bufferedEventsSize

738✔

76

738✔

77

        return &MutableStateStats{

738✔

78

                MutableStateSize:       totalSize,

738✔

79

                ExecutionInfoSize:      executionInfoSize,

738✔

80

                ActivityInfoSize:       activityInfoSize,

738✔

81

                TimerInfoSize:          timerInfoSize,

738✔

82

                ChildInfoSize:          childExecutionInfoSize,

738✔

83

                SignalInfoSize:         signalInfoSize,

738✔

84

                BufferedEventsSize:     bufferedEventsSize,

738✔

85

                ActivityInfoCount:      activityInfoCount,

738✔

86

                TimerInfoCount:         timerInfoCount,

738✔

87

                ChildInfoCount:         childExecutionInfoCount,

738✔

88

                SignalInfoCount:        signalInfoCount,

738✔

89

                BufferedEventsCount:    bufferedEventsCount,

738✔

90

                RequestCancelInfoCount: requestCancelInfoCount,

738✔

91

738✔

94

func (sc *statsComputer) computeMutableStateUpdateStats(req *InternalUpdateWorkflowExecutionRequest) *MutableStateUpdateSessionStats {

4,444✔

95

        if req.NewWorkflowSnapshot != nil {

4,619✔

96

                return mergeMutableStateUpdateSessionStats(sc.computeWorkflowMutationStats(&req.UpdateWorkflowMutation), sc.computeWorkflowSnapshotStats(req.NewWorkflowSnapshot))

175✔

97

175✔

98

        return sc.computeWorkflowMutationStats(&req.UpdateWorkflowMutation)

4,272✔

101

func (sc *statsComputer) computeMutableStateCreateStats(req *InternalCreateWorkflowExecutionRequest) *MutableStateUpdateSessionStats {

525✔

102

        return sc.computeWorkflowSnapshotStats(&req.NewWorkflowSnapshot)

525✔

103

525✔

105

func (sc *statsComputer) computeMutableStateConflictResolveStats(req *InternalConflictResolveWorkflowExecutionRequest) *MutableStateUpdateSessionStats {

3✔

106

        mss := sc.computeWorkflowSnapshotStats(&req.ResetWorkflowSnapshot)

3✔

107

        if req.NewWorkflowSnapshot != nil {

3✔

110

        if req.CurrentWorkflowMutation != nil {

3✔

113

        return mss

3✔

116

func (sc *statsComputer) computeWorkflowMutationStats(req *InternalWorkflowMutation) *MutableStateUpdateSessionStats {

4,445✔

117

        executionInfoSize := computeExecutionInfoSize(req.ExecutionInfo)

4,445✔

118

4,445✔

119

        activityInfoCount := 0

4,445✔

120

        activityInfoSize := 0

4,445✔

121

        for _, ai := range req.UpsertActivityInfos {

5,718✔

122

                activityInfoCount++

1,273✔

123

                activityInfoSize += computeActivityInfoSize(ai)

1,273✔

124

1,273✔

126

        timerInfoCount := 0

4,445✔

127

        timerInfoSize := 0

4,445✔

128

        for _, ti := range req.UpsertTimerInfos {

4,481✔

129

                timerInfoCount++

36✔

130

                timerInfoSize += computeTimerInfoSize(ti)

36✔

131

36✔

133

        childExecutionInfoCount := 0

4,445✔

134

        childExecutionInfoSize := 0

4,445✔

135

        for _, ci := range req.UpsertChildExecutionInfos {

4,488✔

136

                childExecutionInfoCount++

43✔

137

                childExecutionInfoSize += computeChildInfoSize(ci)

43✔

138

43✔

140

        signalInfoCount := 0

4,445✔

141

        signalInfoSize := 0

4,445✔

142

        for _, si := range req.UpsertSignalInfos {

4,461✔

143

                signalInfoCount++

16✔

144

                signalInfoSize += computeSignalInfoSize(si)

16✔

145

16✔

147

        bufferedEventsSize := 0

4,445✔

148

        if req.NewBufferedEvents != nil {

5,088✔

149

                bufferedEventsSize = len(req.NewBufferedEvents.Data)

643✔

150

643✔

152

        requestCancelInfoCount := len(req.UpsertRequestCancelInfos)

4,445✔

153

4,445✔

154

        deleteActivityInfoCount := len(req.DeleteActivityInfos)

4,445✔

155

4,445✔

156

        deleteTimerInfoCount := len(req.DeleteTimerInfos)

4,445✔

157

4,445✔

158

        deleteChildInfoCount := len(req.DeleteChildExecutionInfos)

4,445✔

159

4,445✔

160

        deleteSignalInfoCount := len(req.DeleteSignalInfos)

4,445✔

161

4,445✔

162

        deleteRequestCancelInfoCount := len(req.DeleteRequestCancelInfos)

4,445✔

163

4,445✔

164

        transferTasksCount := len(req.TransferTasks)

4,445✔

165

        crossClusterTasksCount := len(req.CrossClusterTasks)

4,445✔

166

        timerTasksCount := len(req.TimerTasks)

4,445✔

167

        replicationTasksCount := len(req.ReplicationTasks)

4,445✔

168

4,445✔

169

        totalSize := executionInfoSize

4,445✔

170

        totalSize += activityInfoSize

4,445✔

171

        totalSize += timerInfoSize

4,445✔

172

        totalSize += childExecutionInfoSize

4,445✔

173

        totalSize += signalInfoSize

4,445✔

174

        totalSize += bufferedEventsSize

4,445✔

175

4,445✔

176

        return &MutableStateUpdateSessionStats{

4,445✔

177

                MutableStateSize:             totalSize,

4,445✔

178

                ExecutionInfoSize:            executionInfoSize,

4,445✔

179

                ActivityInfoSize:             activityInfoSize,

4,445✔

180

                TimerInfoSize:                timerInfoSize,

4,445✔

181

                ChildInfoSize:                childExecutionInfoSize,

4,445✔

182

                SignalInfoSize:               signalInfoSize,

4,445✔

183

                BufferedEventsSize:           bufferedEventsSize,

4,445✔

184

                ActivityInfoCount:            activityInfoCount,

4,445✔

185

                TimerInfoCount:               timerInfoCount,

4,445✔

186

                ChildInfoCount:               childExecutionInfoCount,

4,445✔

187

                SignalInfoCount:              signalInfoCount,

4,445✔

188

                RequestCancelInfoCount:       requestCancelInfoCount,

4,445✔

189

                DeleteActivityInfoCount:      deleteActivityInfoCount,

4,445✔

190

                DeleteTimerInfoCount:         deleteTimerInfoCount,

4,445✔

191

                DeleteChildInfoCount:         deleteChildInfoCount,

4,445✔

192

                DeleteSignalInfoCount:        deleteSignalInfoCount,

4,445✔

193

                DeleteRequestCancelInfoCount: deleteRequestCancelInfoCount,

4,445✔

194

                TransferTasksCount:           transferTasksCount,

4,445✔

195

                CrossClusterTaskCount:        crossClusterTasksCount,

4,445✔

196

                TimerTasksCount:              timerTasksCount,

4,445✔

197

                ReplicationTasksCount:        replicationTasksCount,

4,445✔

198

4,445✔

201

func (sc *statsComputer) computeWorkflowSnapshotStats(req *InternalWorkflowSnapshot) *MutableStateUpdateSessionStats {

698✔

202

        executionInfoSize := computeExecutionInfoSize(req.ExecutionInfo)

698✔

203

698✔

204

        activityInfoCount := 0

698✔

205

        activityInfoSize := 0

698✔

206

        for _, ai := range req.ActivityInfos {

721✔

207

                activityInfoCount++

23✔

208

                activityInfoSize += computeActivityInfoSize(ai)

23✔

209

23✔

211

        timerInfoCount := 0

698✔

212

        timerInfoSize := 0

698✔

213

        for _, ti := range req.TimerInfos {

701✔

214

                timerInfoCount++

3✔

215

                timerInfoSize += computeTimerInfoSize(ti)

3✔

216

3✔

218

        childExecutionInfoCount := 0

698✔

219

        childExecutionInfoSize := 0

698✔

220

        for _, ci := range req.ChildExecutionInfos {

702✔

221

                childExecutionInfoCount++

4✔

222

                childExecutionInfoSize += computeChildInfoSize(ci)

4✔

223

4✔

225

        signalInfoCount := 0

698✔

226

        signalInfoSize := 0

698✔

227

        for _, si := range req.SignalInfos {

699✔

228

                signalInfoCount++

1✔

229

                signalInfoSize += computeSignalInfoSize(si)

1✔

230

1✔

232

        requestCancelInfoCount := len(req.RequestCancelInfos)

698✔

233

698✔

234

        transferTasksCount := len(req.TransferTasks)

698✔

235

        crossClusterTasksCount := len(req.CrossClusterTasks)

698✔

236

        timerTasksCount := len(req.TimerTasks)

698✔

237

        replicationTasksCount := len(req.ReplicationTasks)

698✔

238

698✔

239

        totalSize := executionInfoSize

698✔

240

        totalSize += activityInfoSize

698✔

241

        totalSize += timerInfoSize

698✔

242

        totalSize += childExecutionInfoSize

698✔

243

        totalSize += signalInfoSize

698✔

244

698✔

245

        return &MutableStateUpdateSessionStats{

698✔

246

                MutableStateSize:       totalSize,

698✔

247

                ExecutionInfoSize:      executionInfoSize,

698✔

248

                ActivityInfoSize:       activityInfoSize,

698✔

249

                TimerInfoSize:          timerInfoSize,

698✔

250

                ChildInfoSize:          childExecutionInfoSize,

698✔

251

                SignalInfoSize:         signalInfoSize,

698✔

252

                ActivityInfoCount:      activityInfoCount,

698✔

253

                TimerInfoCount:         timerInfoCount,

698✔

254

                ChildInfoCount:         childExecutionInfoCount,

698✔

255

                SignalInfoCount:        signalInfoCount,

698✔

256

                RequestCancelInfoCount: requestCancelInfoCount,

698✔

257

                TransferTasksCount:     transferTasksCount,

698✔

258

                CrossClusterTaskCount:  crossClusterTasksCount,

698✔

259

                TimerTasksCount:        timerTasksCount,

698✔

260

                ReplicationTasksCount:  replicationTasksCount,

698✔

261

698✔

264

func mergeMutableStateUpdateSessionStats(stats ...*MutableStateUpdateSessionStats) *MutableStateUpdateSessionStats {

175✔

265

        result := &MutableStateUpdateSessionStats{}

175✔

266

        for _, s := range stats {

522✔

267

                result.MutableStateSize += s.MutableStateSize

347✔

268

347✔

269

                result.ExecutionInfoSize += s.ExecutionInfoSize

347✔

270

                result.ActivityInfoSize += s.ActivityInfoSize

347✔

271

                result.TimerInfoSize += s.TimerInfoSize

347✔

272

                result.ChildInfoSize += s.ChildInfoSize

347✔

273

                result.SignalInfoSize += s.SignalInfoSize

347✔

274

                result.BufferedEventsSize += s.BufferedEventsSize

347✔

275

347✔

276

                result.ActivityInfoCount += s.ActivityInfoCount

347✔

277

                result.TimerInfoCount += s.TimerInfoCount

347✔

278

                result.ChildInfoCount += s.ChildInfoCount

347✔

279

                result.SignalInfoCount += s.SignalInfoCount

347✔

280

                result.RequestCancelInfoCount += s.RequestCancelInfoCount

347✔

281

347✔

282

                result.DeleteActivityInfoCount += s.DeleteActivityInfoCount

347✔

283

                result.DeleteTimerInfoCount += s.DeleteTimerInfoCount

347✔

284

                result.DeleteChildInfoCount += s.DeleteChildInfoCount

347✔

285

                result.DeleteSignalInfoCount += s.DeleteSignalInfoCount

347✔

286

                result.DeleteRequestCancelInfoCount += s.DeleteRequestCancelInfoCount

347✔

287

347✔

288

                result.TransferTasksCount += s.TransferTasksCount

347✔

289

                result.CrossClusterTaskCount += s.CrossClusterTaskCount

347✔

290

                result.TimerInfoCount += s.TimerInfoCount

347✔

291

                result.ReplicationTasksCount += s.ReplicationTasksCount

347✔

292

347✔

293

        return result

175✔

296

func computeExecutionInfoSize(executionInfo *InternalWorkflowExecutionInfo) int {

5,877✔

297

        size := len(executionInfo.WorkflowID)

5,877✔

298

        size += len(executionInfo.TaskList)

5,877✔

299

        size += len(executionInfo.WorkflowTypeName)

5,877✔

300

        size += len(executionInfo.ParentWorkflowID)

5,877✔

301

5,877✔

302

        return size

5,877✔

303

5,877✔

305

func computeActivityInfoSize(ai *InternalActivityInfo) int {

1,386✔

306

        size := len(ai.ActivityID)

1,386✔

307

        if ai.ScheduledEvent != nil {

1,388✔

308

                size += len(ai.ScheduledEvent.Data)

2✔

309

2✔

310

        if ai.StartedEvent != nil {

1,388✔

311

                size += len(ai.StartedEvent.Data)

2✔

312

2✔

313

        size += len(ai.Details)

1,386✔

314

1,386✔

315

        return size

1,386✔

318

func computeTimerInfoSize(ti *TimerInfo) int {

42✔

319

        size := len(ti.TimerID)

42✔

320

42✔

321

        return size

42✔

322

42✔

324

func computeChildInfoSize(ci *InternalChildExecutionInfo) int {

52✔

325

        size := 0

52✔

326

        if ci.InitiatedEvent != nil {

52✔

329

        if ci.StartedEvent != nil {

52✔

332

        return size

52✔

335

func computeSignalInfoSize(si *SignalInfo) int {

19✔

336

        size := len(si.SignalName)

19✔

337

        size += len(si.Input)

19✔

338

        size += len(si.Control)

19✔

339

19✔

340

        return size

19✔

341

19✔

uber / cadence / 018f5f66-582f-4a02-8ecc-259a2c7f45b8

Source File
Press 'n' to go to next uncovered line, 'b' for previous

1	// Copyright (c) 2017-2020 Uber Technologies, Inc.
2	// Portions of the Software are attributed to Copyright (c) 2020 Temporal Technologies Inc.
3	//
4	// Permission is hereby granted, free of charge, to any person obtaining a copy
5	// of this software and associated documentation files (the "Software"), to deal
6	// in the Software without restriction, including without limitation the rights
7	// to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
8	// copies of the Software, and to permit persons to whom the Software is
9	// furnished to do so, subject to the following conditions:
10	//
11	// The above copyright notice and this permission notice shall be included in
12	// all copies or substantial portions of the Software.
13	//
14	// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
15	// IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
16	// FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
17	// AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
18	// LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
19	// OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
20	// THE SOFTWARE.
21
22	package persistence
23
24	type (
25	// statsComputer is to computing struct sizes after serialization
26	statsComputer struct{}
27	)
28
29	func (sc statsComputer) computeMutableStateStats(req InternalGetWorkflowExecutionResponse) *MutableStateStats {	738✔
30	executionInfoSize := computeExecutionInfoSize(req.State.ExecutionInfo)	738✔
31		738✔
32	activityInfoCount := 0	738✔
33	activityInfoSize := 0	738✔
34	for _, ai := range req.State.ActivityInfos {	832✔
35	activityInfoCount++	94✔
36	activityInfoSize += computeActivityInfoSize(ai)	94✔
37	}	94✔
38
39	timerInfoCount := 0	738✔
40	timerInfoSize := 0	738✔
41	for _, ti := range req.State.TimerInfos {	739✔
42	timerInfoCount++	1✔
43	timerInfoSize += computeTimerInfoSize(ti)	1✔
44	}	1✔
45
46	childExecutionInfoCount := 0	738✔
47	childExecutionInfoSize := 0	738✔
48	for _, ci := range req.State.ChildExecutionInfos {	742✔
49	childExecutionInfoCount++	4✔
50	childExecutionInfoSize += computeChildInfoSize(ci)	4✔
51	}	4✔
52
53	signalInfoCount := 0	738✔
54	signalInfoSize := 0	738✔
55	for _, si := range req.State.SignalInfos {	738✔
UNCOV 56	signalInfoCount++	×
UNCOV 57	signalInfoSize += computeSignalInfoSize(si)	×
UNCOV 58	}	×
59
60	bufferedEventsCount := 0	738✔
61	bufferedEventsSize := 0	738✔
62		738✔
63	for _, be := range req.State.BufferedEvents {	741✔
64	bufferedEventsCount++	3✔
65	bufferedEventsSize += len(be.Data)	3✔
66	}	3✔
67
68	requestCancelInfoCount := len(req.State.RequestCancelInfos)	738✔
69		738✔
70	totalSize := executionInfoSize	738✔
71	totalSize += activityInfoSize	738✔
72	totalSize += timerInfoSize	738✔
73	totalSize += childExecutionInfoSize	738✔
74	totalSize += signalInfoSize	738✔
75	totalSize += bufferedEventsSize	738✔
76		738✔
77	return &MutableStateStats{	738✔
78	MutableStateSize: totalSize,	738✔
79	ExecutionInfoSize: executionInfoSize,	738✔
80	ActivityInfoSize: activityInfoSize,	738✔
81	TimerInfoSize: timerInfoSize,	738✔
82	ChildInfoSize: childExecutionInfoSize,	738✔
83	SignalInfoSize: signalInfoSize,	738✔
84	BufferedEventsSize: bufferedEventsSize,	738✔
85	ActivityInfoCount: activityInfoCount,	738✔
86	TimerInfoCount: timerInfoCount,	738✔
87	ChildInfoCount: childExecutionInfoCount,	738✔
88	SignalInfoCount: signalInfoCount,	738✔
89	BufferedEventsCount: bufferedEventsCount,	738✔
90	RequestCancelInfoCount: requestCancelInfoCount,	738✔
91	}	738✔
92	}
93
94	func (sc statsComputer) computeMutableStateUpdateStats(req InternalUpdateWorkflowExecutionRequest) *MutableStateUpdateSessionStats {	4,444✔
95	if req.NewWorkflowSnapshot != nil {	4,619✔
96	return mergeMutableStateUpdateSessionStats(sc.computeWorkflowMutationStats(&req.UpdateWorkflowMutation), sc.computeWorkflowSnapshotStats(req.NewWorkflowSnapshot))	175✔
97	}	175✔
98	return sc.computeWorkflowMutationStats(&req.UpdateWorkflowMutation)	4,272✔
99	}
100
101	func (sc statsComputer) computeMutableStateCreateStats(req InternalCreateWorkflowExecutionRequest) *MutableStateUpdateSessionStats {	525✔
102	return sc.computeWorkflowSnapshotStats(&req.NewWorkflowSnapshot)	525✔
103	}	525✔
104
105	func (sc statsComputer) computeMutableStateConflictResolveStats(req InternalConflictResolveWorkflowExecutionRequest) *MutableStateUpdateSessionStats {	3✔
106	mss := sc.computeWorkflowSnapshotStats(&req.ResetWorkflowSnapshot)	3✔
107	if req.NewWorkflowSnapshot != nil {	3✔
108	mss = mergeMutableStateUpdateSessionStats(mss, sc.computeWorkflowSnapshotStats(req.NewWorkflowSnapshot))	×
109	}	×
110	if req.CurrentWorkflowMutation != nil {	3✔
111	mss = mergeMutableStateUpdateSessionStats(mss, sc.computeWorkflowMutationStats(req.CurrentWorkflowMutation))	×
112	}	×
113	return mss	3✔
114	}
115
116	func (sc statsComputer) computeWorkflowMutationStats(req InternalWorkflowMutation) *MutableStateUpdateSessionStats {	4,445✔
117	executionInfoSize := computeExecutionInfoSize(req.ExecutionInfo)	4,445✔
118		4,445✔
119	activityInfoCount := 0	4,445✔
120	activityInfoSize := 0	4,445✔
121	for _, ai := range req.UpsertActivityInfos {	5,718✔
122	activityInfoCount++	1,273✔
123	activityInfoSize += computeActivityInfoSize(ai)	1,273✔
124	}	1,273✔
125
126	timerInfoCount := 0	4,445✔
127	timerInfoSize := 0	4,445✔
128	for _, ti := range req.UpsertTimerInfos {	4,481✔
129	timerInfoCount++	36✔
130	timerInfoSize += computeTimerInfoSize(ti)	36✔
131	}	36✔
132
133	childExecutionInfoCount := 0	4,445✔
134	childExecutionInfoSize := 0	4,445✔
135	for _, ci := range req.UpsertChildExecutionInfos {	4,488✔
136	childExecutionInfoCount++	43✔
137	childExecutionInfoSize += computeChildInfoSize(ci)	43✔
138	}	43✔
139
140	signalInfoCount := 0	4,445✔
141	signalInfoSize := 0	4,445✔
142	for _, si := range req.UpsertSignalInfos {	4,461✔
143	signalInfoCount++	16✔
144	signalInfoSize += computeSignalInfoSize(si)	16✔
145	}	16✔
146
147	bufferedEventsSize := 0	4,445✔
148	if req.NewBufferedEvents != nil {	5,088✔
149	bufferedEventsSize = len(req.NewBufferedEvents.Data)	643✔
150	}	643✔
151
152	requestCancelInfoCount := len(req.UpsertRequestCancelInfos)	4,445✔
153		4,445✔
154	deleteActivityInfoCount := len(req.DeleteActivityInfos)	4,445✔
155		4,445✔
156	deleteTimerInfoCount := len(req.DeleteTimerInfos)	4,445✔
157		4,445✔
158	deleteChildInfoCount := len(req.DeleteChildExecutionInfos)	4,445✔
159		4,445✔
160	deleteSignalInfoCount := len(req.DeleteSignalInfos)	4,445✔
161		4,445✔
162	deleteRequestCancelInfoCount := len(req.DeleteRequestCancelInfos)	4,445✔
163		4,445✔
164	transferTasksCount := len(req.TransferTasks)	4,445✔
165	crossClusterTasksCount := len(req.CrossClusterTasks)	4,445✔
166	timerTasksCount := len(req.TimerTasks)	4,445✔
167	replicationTasksCount := len(req.ReplicationTasks)	4,445✔
168		4,445✔
169	totalSize := executionInfoSize	4,445✔
170	totalSize += activityInfoSize	4,445✔
171	totalSize += timerInfoSize	4,445✔
172	totalSize += childExecutionInfoSize	4,445✔
173	totalSize += signalInfoSize	4,445✔
174	totalSize += bufferedEventsSize	4,445✔
175		4,445✔
176	return &MutableStateUpdateSessionStats{	4,445✔
177	MutableStateSize: totalSize,	4,445✔
178	ExecutionInfoSize: executionInfoSize,	4,445✔
179	ActivityInfoSize: activityInfoSize,	4,445✔
180	TimerInfoSize: timerInfoSize,	4,445✔
181	ChildInfoSize: childExecutionInfoSize,	4,445✔
182	SignalInfoSize: signalInfoSize,	4,445✔
183	BufferedEventsSize: bufferedEventsSize,	4,445✔
184	ActivityInfoCount: activityInfoCount,	4,445✔
185	TimerInfoCount: timerInfoCount,	4,445✔
186	ChildInfoCount: childExecutionInfoCount,	4,445✔
187	SignalInfoCount: signalInfoCount,	4,445✔
188	RequestCancelInfoCount: requestCancelInfoCount,	4,445✔
189	DeleteActivityInfoCount: deleteActivityInfoCount,	4,445✔
190	DeleteTimerInfoCount: deleteTimerInfoCount,	4,445✔
191	DeleteChildInfoCount: deleteChildInfoCount,	4,445✔
192	DeleteSignalInfoCount: deleteSignalInfoCount,	4,445✔
193	DeleteRequestCancelInfoCount: deleteRequestCancelInfoCount,	4,445✔
194	TransferTasksCount: transferTasksCount,	4,445✔
195	CrossClusterTaskCount: crossClusterTasksCount,	4,445✔
196	TimerTasksCount: timerTasksCount,	4,445✔
197	ReplicationTasksCount: replicationTasksCount,	4,445✔
198	}	4,445✔
199	}
200
201	func (sc statsComputer) computeWorkflowSnapshotStats(req InternalWorkflowSnapshot) *MutableStateUpdateSessionStats {	698✔
202	executionInfoSize := computeExecutionInfoSize(req.ExecutionInfo)	698✔
203		698✔
204	activityInfoCount := 0	698✔
205	activityInfoSize := 0	698✔
206	for _, ai := range req.ActivityInfos {	721✔
207	activityInfoCount++	23✔
208	activityInfoSize += computeActivityInfoSize(ai)	23✔
209	}	23✔
210
211	timerInfoCount := 0	698✔
212	timerInfoSize := 0	698✔
213	for _, ti := range req.TimerInfos {	701✔
214	timerInfoCount++	3✔
215	timerInfoSize += computeTimerInfoSize(ti)	3✔
216	}	3✔
217
218	childExecutionInfoCount := 0	698✔
219	childExecutionInfoSize := 0	698✔
220	for _, ci := range req.ChildExecutionInfos {	702✔
221	childExecutionInfoCount++	4✔
222	childExecutionInfoSize += computeChildInfoSize(ci)	4✔
223	}	4✔
224
225	signalInfoCount := 0	698✔
226	signalInfoSize := 0	698✔
227	for _, si := range req.SignalInfos {	699✔
228	signalInfoCount++	1✔
229	signalInfoSize += computeSignalInfoSize(si)	1✔
230	}	1✔
231
232	requestCancelInfoCount := len(req.RequestCancelInfos)	698✔
233		698✔
234	transferTasksCount := len(req.TransferTasks)	698✔
235	crossClusterTasksCount := len(req.CrossClusterTasks)	698✔
236	timerTasksCount := len(req.TimerTasks)	698✔
237	replicationTasksCount := len(req.ReplicationTasks)	698✔
238		698✔
239	totalSize := executionInfoSize	698✔
240	totalSize += activityInfoSize	698✔
241	totalSize += timerInfoSize	698✔
242	totalSize += childExecutionInfoSize	698✔
243	totalSize += signalInfoSize	698✔
244		698✔
245	return &MutableStateUpdateSessionStats{	698✔
246	MutableStateSize: totalSize,	698✔
247	ExecutionInfoSize: executionInfoSize,	698✔
248	ActivityInfoSize: activityInfoSize,	698✔
249	TimerInfoSize: timerInfoSize,	698✔
250	ChildInfoSize: childExecutionInfoSize,	698✔
251	SignalInfoSize: signalInfoSize,	698✔
252	ActivityInfoCount: activityInfoCount,	698✔
253	TimerInfoCount: timerInfoCount,	698✔
254	ChildInfoCount: childExecutionInfoCount,	698✔
255	SignalInfoCount: signalInfoCount,	698✔
256	RequestCancelInfoCount: requestCancelInfoCount,	698✔
257	TransferTasksCount: transferTasksCount,	698✔
258	CrossClusterTaskCount: crossClusterTasksCount,	698✔
259	TimerTasksCount: timerTasksCount,	698✔
260	ReplicationTasksCount: replicationTasksCount,	698✔
261	}	698✔
262	}
263
264	func mergeMutableStateUpdateSessionStats(stats ...MutableStateUpdateSessionStats) MutableStateUpdateSessionStats {	175✔
265	result := &MutableStateUpdateSessionStats{}	175✔
266	for _, s := range stats {	522✔
267	result.MutableStateSize += s.MutableStateSize	347✔
268		347✔
269	result.ExecutionInfoSize += s.ExecutionInfoSize	347✔
270	result.ActivityInfoSize += s.ActivityInfoSize	347✔
271	result.TimerInfoSize += s.TimerInfoSize	347✔
272	result.ChildInfoSize += s.ChildInfoSize	347✔
273	result.SignalInfoSize += s.SignalInfoSize	347✔
274	result.BufferedEventsSize += s.BufferedEventsSize	347✔
275		347✔
276	result.ActivityInfoCount += s.ActivityInfoCount	347✔
277	result.TimerInfoCount += s.TimerInfoCount	347✔
278	result.ChildInfoCount += s.ChildInfoCount	347✔
279	result.SignalInfoCount += s.SignalInfoCount	347✔
280	result.RequestCancelInfoCount += s.RequestCancelInfoCount	347✔
281		347✔
282	result.DeleteActivityInfoCount += s.DeleteActivityInfoCount	347✔
283	result.DeleteTimerInfoCount += s.DeleteTimerInfoCount	347✔
284	result.DeleteChildInfoCount += s.DeleteChildInfoCount	347✔
285	result.DeleteSignalInfoCount += s.DeleteSignalInfoCount	347✔
286	result.DeleteRequestCancelInfoCount += s.DeleteRequestCancelInfoCount	347✔
287		347✔
288	result.TransferTasksCount += s.TransferTasksCount	347✔
289	result.CrossClusterTaskCount += s.CrossClusterTaskCount	347✔
290	result.TimerInfoCount += s.TimerInfoCount	347✔
291	result.ReplicationTasksCount += s.ReplicationTasksCount	347✔
292	}	347✔
293	return result	175✔
294	}
295
296	func computeExecutionInfoSize(executionInfo *InternalWorkflowExecutionInfo) int {	5,877✔
297	size := len(executionInfo.WorkflowID)	5,877✔
298	size += len(executionInfo.TaskList)	5,877✔
299	size += len(executionInfo.WorkflowTypeName)	5,877✔
300	size += len(executionInfo.ParentWorkflowID)	5,877✔
301		5,877✔
302	return size	5,877✔
303	}	5,877✔
304
305	func computeActivityInfoSize(ai *InternalActivityInfo) int {	1,386✔
306	size := len(ai.ActivityID)	1,386✔
307	if ai.ScheduledEvent != nil {	1,388✔
308	size += len(ai.ScheduledEvent.Data)	2✔
309	}	2✔
310	if ai.StartedEvent != nil {	1,388✔
311	size += len(ai.StartedEvent.Data)	2✔
312	}	2✔
313	size += len(ai.Details)	1,386✔
314		1,386✔
315	return size	1,386✔
316	}
317
318	func computeTimerInfoSize(ti *TimerInfo) int {	42✔
319	size := len(ti.TimerID)	42✔
320		42✔
321	return size	42✔
322	}	42✔
323
324	func computeChildInfoSize(ci *InternalChildExecutionInfo) int {	52✔
325	size := 0	52✔
326	if ci.InitiatedEvent != nil {	52✔
327	size += len(ci.InitiatedEvent.Data)	×
328	}	×
329	if ci.StartedEvent != nil {	52✔
330	size += len(ci.StartedEvent.Data)	×
331	}	×
332	return size	52✔
333	}
334
335	func computeSignalInfoSize(si *SignalInfo) int {	19✔
336	size := len(si.SignalName)	19✔
337	size += len(si.Input)	19✔
338	size += len(si.Control)	19✔
339		19✔
340	return size	19✔
341	}	19✔

uber / cadence / 018f5f66-582f-4a02-8ecc-259a2c7f45b8

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous