CARVIEW |
Select Language
HTTP/2 200
date: Wed, 23 Jul 2025 02:01:35 GMT
content-type: text/html; charset=utf-8
vary: X-PJAX, X-PJAX-Container, Turbo-Visit, Turbo-Frame, X-Requested-With,Accept-Encoding, Accept, X-Requested-With
x-repository-download: git clone https://github.com/googleapis/java-pubsub.git
etag: W/"dced43777b42d001502f64fa10fdc615"
cache-control: max-age=0, private, must-revalidate
strict-transport-security: max-age=31536000; includeSubdomains; preload
x-frame-options: deny
x-content-type-options: nosniff
x-xss-protection: 0
referrer-policy: no-referrer-when-downgrade
content-security-policy: default-src 'none'; base-uri 'self'; child-src github.githubassets.com github.com/assets-cdn/worker/ github.com/assets/ gist.github.com/assets-cdn/worker/; connect-src 'self' uploads.github.com www.githubstatus.com collector.github.com raw.githubusercontent.com api.github.com github-cloud.s3.amazonaws.com github-production-repository-file-5c1aeb.s3.amazonaws.com github-production-upload-manifest-file-7fdce7.s3.amazonaws.com github-production-user-asset-6210df.s3.amazonaws.com *.rel.tunnels.api.visualstudio.com wss://*.rel.tunnels.api.visualstudio.com objects-origin.githubusercontent.com copilot-proxy.githubusercontent.com proxy.individual.githubcopilot.com proxy.business.githubcopilot.com proxy.enterprise.githubcopilot.com *.actions.githubusercontent.com wss://*.actions.githubusercontent.com productionresultssa0.blob.core.windows.net/ productionresultssa1.blob.core.windows.net/ productionresultssa2.blob.core.windows.net/ productionresultssa3.blob.core.windows.net/ productionresultssa4.blob.core.windows.net/ productionresultssa5.blob.core.windows.net/ productionresultssa6.blob.core.windows.net/ productionresultssa7.blob.core.windows.net/ productionresultssa8.blob.core.windows.net/ productionresultssa9.blob.core.windows.net/ productionresultssa10.blob.core.windows.net/ productionresultssa11.blob.core.windows.net/ productionresultssa12.blob.core.windows.net/ productionresultssa13.blob.core.windows.net/ productionresultssa14.blob.core.windows.net/ productionresultssa15.blob.core.windows.net/ productionresultssa16.blob.core.windows.net/ productionresultssa17.blob.core.windows.net/ productionresultssa18.blob.core.windows.net/ productionresultssa19.blob.core.windows.net/ github-production-repository-image-32fea6.s3.amazonaws.com github-production-release-asset-2e65be.s3.amazonaws.com insights.github.com wss://alive.github.com api.githubcopilot.com api.individual.githubcopilot.com api.business.githubcopilot.com api.enterprise.githubcopilot.com; font-src github.githubassets.com; form-action 'self' github.com gist.github.com copilot-workspace.githubnext.com objects-origin.githubusercontent.com; frame-ancestors 'none'; frame-src viewscreen.githubusercontent.com notebooks.githubusercontent.com; img-src 'self' data: blob: github.githubassets.com media.githubusercontent.com camo.githubusercontent.com identicons.github.com avatars.githubusercontent.com private-avatars.githubusercontent.com github-cloud.s3.amazonaws.com objects.githubusercontent.com release-assets.githubusercontent.com secured-user-images.githubusercontent.com/ user-images.githubusercontent.com/ private-user-images.githubusercontent.com opengraph.githubassets.com copilotprodattachments.blob.core.windows.net/github-production-copilot-attachments/ github-production-user-asset-6210df.s3.amazonaws.com customer-stories-feed.github.com spotlights-feed.github.com objects-origin.githubusercontent.com *.githubusercontent.com; manifest-src 'self'; media-src github.com user-images.githubusercontent.com/ secured-user-images.githubusercontent.com/ private-user-images.githubusercontent.com github-production-user-asset-6210df.s3.amazonaws.com gist.github.com; script-src github.githubassets.com; style-src 'unsafe-inline' github.githubassets.com; upgrade-insecure-requests; worker-src github.githubassets.com github.com/assets-cdn/worker/ github.com/assets/ gist.github.com/assets-cdn/worker/
server: github.com
content-encoding: gzip
accept-ranges: bytes
set-cookie: _gh_sess=zkc33piqcZiSTLLgI2WZJ4JxrE2%2FXaPSK3J6srGymEKDEpIONsw4n%2F4j5LSQVu7vP6eehSyNuQdX2CB5B5DZ%2B15ayqrD%2FNf9r2eJ8pbGR2ZRZSL0tsKrN%2BSn7sKrAXhPxYMNlouNFiEfAAVtxGORSsbq6qq9zmWaD79MyLVZkAcsQnEz%2B5JwHsXSHSDuXbstHRgW2HqiAEXmegZfx4CgVoDOFU2vW3uUbtx4MeWilhyXHL2cgTba%2BcNPE%2F8Uct%2FidYkTg3H9aXterHknhBoqTw%3D%3D--FgOZ4yX7nmzqXz9E--gVxdBZnpelK4KhPHp7mW0Q%3D%3D; Path=/; HttpOnly; Secure; SameSite=Lax
set-cookie: _octo=GH1.1.1560135425.1753236095; Path=/; Domain=github.com; Expires=Thu, 23 Jul 2026 02:01:35 GMT; Secure; SameSite=Lax
set-cookie: logged_in=no; Path=/; Domain=github.com; Expires=Thu, 23 Jul 2026 02:01:35 GMT; HttpOnly; Secure; SameSite=Lax
x-github-request-id: E588:3CF5A2:250DD3:346D7B:6880427F
feat: track batch size using serialized size of PublishRequest (#2113) · googleapis/java-pubsub@be78e64 · GitHub
Copy file name to clipboardExpand all lines: google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/Publisher.java
Copy file name to clipboardExpand all lines: google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/PublisherImplTest.java
Skip to content
Navigation Menu
{{ message }}
-
Notifications
You must be signed in to change notification settings - Fork 98
Commit be78e64
feat: track batch size using serialized size of PublishRequest (#2113)
* feat: track batch size using serialized size of PublishRequest
* fix: compare against batchedBytes instead of messageSize in flush condition
* fix: also count static overhead in flow control
* fix: adjust thresholds in tests
* fix: clean up merge issue
* fix: revert use of topicNameSize in MessageFlowController
* fix: store topicNameSize as initialBatchedBytes in MessagesBatch
---------
Co-authored-by: Mike Prieto <michaelpri10@gmail.com>1 parent 6c67798 commit be78e64Copy full SHA for be78e64
File tree
Expand file treeCollapse file tree
2 files changed
+20
-9
lines changedFilter options
- google-cloud-pubsub/src
- main/java/com/google/cloud/pubsub/v1
- test/java/com/google/cloud/pubsub/v1
Expand file treeCollapse file tree
2 files changed
+20
-9
lines changedgoogle-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/Publisher.java
Copy file name to clipboardExpand all lines: google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/Publisher.java+16-5Lines changed: 16 additions & 5 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
46 | 46 |
| |
47 | 47 |
| |
48 | 48 |
| |
| 49 | + | |
49 | 50 |
| |
50 | 51 |
| |
51 | 52 |
| |
| |||
99 | 100 |
| |
100 | 101 |
| |
101 | 102 |
| |
| 103 | + | |
102 | 104 |
| |
103 | 105 |
| |
104 | 106 |
| |
| |||
145 | 147 |
| |
146 | 148 |
| |
147 | 149 |
| |
| 150 | + | |
| 151 | + | |
148 | 152 |
| |
149 | 153 |
| |
150 | 154 |
| |
| |||
309 | 313 |
| |
310 | 314 |
| |
311 | 315 |
| |
312 |
| - | |
| 316 | + | |
313 | 317 |
| |
314 | 318 |
| |
315 | 319 |
| |
| |||
636 | 640 |
| |
637 | 641 |
| |
638 | 642 |
| |
639 |
| - | |
| 643 | + | |
| 644 | + | |
| 645 | + | |
640 | 646 |
| |
641 | 647 |
| |
642 | 648 |
| |
| |||
1093 | 1099 |
| |
1094 | 1100 |
| |
1095 | 1101 |
| |
| 1102 | + | |
1096 | 1103 |
| |
1097 | 1104 |
| |
1098 | 1105 |
| |
1099 | 1106 |
| |
1100 |
| - | |
| 1107 | + | |
| 1108 | + | |
1101 | 1109 |
| |
| 1110 | + | |
1102 | 1111 |
| |
1103 | 1112 |
| |
1104 | 1113 |
| |
| |||
1111 | 1120 |
| |
1112 | 1121 |
| |
1113 | 1122 |
| |
1114 |
| - | |
| 1123 | + | |
1115 | 1124 |
| |
1116 | 1125 |
| |
1117 | 1126 |
| |
| |||
1150 | 1159 |
| |
1151 | 1160 |
| |
1152 | 1161 |
| |
1153 |
| - | |
| 1162 | + | |
| 1163 | + | |
| 1164 | + | |
1154 | 1165 |
| |
1155 | 1166 |
| |
1156 | 1167 |
| |
|
google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/PublisherImplTest.java
Copy file name to clipboardExpand all lines: google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/PublisherImplTest.java+4-4Lines changed: 4 additions & 4 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
447 | 447 |
| |
448 | 448 |
| |
449 | 449 |
| |
450 |
| - | |
| 450 | + | |
451 | 451 |
| |
452 | 452 |
| |
453 | 453 |
| |
| |||
1150 | 1150 |
| |
1151 | 1151 |
| |
1152 | 1152 |
| |
1153 |
| - | |
| 1153 | + | |
1154 | 1154 |
| |
1155 | 1155 |
| |
1156 | 1156 |
| |
| |||
1192 | 1192 |
| |
1193 | 1193 |
| |
1194 | 1194 |
| |
1195 |
| - | |
| 1195 | + | |
1196 | 1196 |
| |
1197 | 1197 |
| |
1198 | 1198 |
| |
| |||
1238 | 1238 |
| |
1239 | 1239 |
| |
1240 | 1240 |
| |
1241 |
| - | |
| 1241 | + | |
1242 | 1242 |
| |
1243 | 1243 |
| |
1244 | 1244 |
| |
|
You can’t perform that action at this time.
0 commit comments