|
29 | 29 |
|
30 | 30 | import com.tencent.beacon.core.info.BeaconPubParams; |
31 | 31 | import com.tencent.beacon.event.open.BeaconReport; |
32 | | -import com.tencent.cos.xml.common.ClientErrorCode; |
33 | 32 | import com.tencent.cos.xml.base.BuildConfig; |
| 33 | +import com.tencent.cos.xml.common.ClientErrorCode; |
34 | 34 | import com.tencent.cos.xml.exception.CosXmlClientException; |
35 | 35 | import com.tencent.cos.xml.exception.CosXmlServiceException; |
36 | 36 | import com.tencent.cos.xml.model.CosXmlRequest; |
37 | | -import com.tencent.cos.xml.model.object.BasePutObjectRequest; |
38 | | -import com.tencent.cos.xml.model.object.GetObjectRequest; |
39 | 37 | import com.tencent.cos.xml.model.object.ObjectRequest; |
40 | 38 | import com.tencent.cos.xml.transfer.TransferTaskMetrics; |
41 | 39 | import com.tencent.qcloud.core.common.QCloudAuthenticationException; |
|
53 | 51 | import java.net.ConnectException; |
54 | 52 | import java.net.HttpRetryException; |
55 | 53 | import java.net.InetAddress; |
56 | | -import java.net.InetSocketAddress; |
57 | 54 | import java.net.NoRouteToHostException; |
58 | 55 | import java.net.SocketTimeoutException; |
59 | 56 | import java.net.UnknownHostException; |
@@ -164,45 +161,45 @@ public void reportDownloadTaskServiceException(CosXmlRequest request, QCloudServ |
164 | 161 | createTransferExtra("DownloadTask", request)); |
165 | 162 | } |
166 | 163 |
|
167 | | - private String cosUploadName(boolean cse) { |
168 | | - return cse? "COSUploadTask-CSE" : "COSUploadTask"; |
169 | | - } |
170 | | - |
171 | | - private String cosDownloadName(boolean cse) { |
172 | | - return cse? "COSDownloadTask-CSE" : "COSDownloadTask"; |
173 | | - } |
| 164 | +// private String cosUploadName(boolean cse) { |
| 165 | +// return cse? "COSUploadTask-CSE" : "COSUploadTask"; |
| 166 | +// } |
| 167 | +// |
| 168 | +// private String cosDownloadName(boolean cse) { |
| 169 | +// return cse? "COSDownloadTask-CSE" : "COSDownloadTask"; |
| 170 | +// } |
174 | 171 |
|
175 | | - public void reportCOSUploadTaskSuccess(CosXmlRequest request, boolean cse) { |
176 | | - // 只需要一个 PutObjectRequest 壳,带上 HttpTaskMetrics 信息 |
177 | | - reportRequestSuccess(EVENT_CODE_UPLOAD, request, |
178 | | - Collections.singletonMap("name", cosUploadName(cse))); |
179 | | - } |
180 | | - |
181 | | - public void reportCOSUploadTaskClientException(CosXmlRequest request, QCloudClientException clientException, boolean cse) { |
182 | | - reportClientException(EVENT_CODE_UPLOAD, request, clientException, |
183 | | - createTransferExtra(cosUploadName(cse), request)); |
184 | | - } |
185 | | - |
186 | | - public void reportCOSUploadTaskServiceException(CosXmlRequest request, QCloudServiceException serviceException, boolean cse) { |
187 | | - reportServiceException(EVENT_CODE_UPLOAD, request, serviceException, |
188 | | - createTransferExtra(cosUploadName(cse), request)); |
189 | | - } |
190 | | - |
191 | | - public void reportCOSDownloadTaskSuccess(CosXmlRequest request, boolean cse) { |
192 | | - // 只需要一个 GetObjectRequest 壳,带上 HttpTaskMetrics 信息 |
193 | | - reportRequestSuccess(EVENT_CODE_DOWNLOAD, request, |
194 | | - Collections.singletonMap("name", cosDownloadName(cse))); |
195 | | - } |
196 | | - |
197 | | - public void reportCOSDownloadTaskClientException(CosXmlRequest request, QCloudClientException clientException, boolean cse) { |
198 | | - reportClientException(EVENT_CODE_DOWNLOAD, request, clientException, |
199 | | - createTransferExtra(cosDownloadName(cse), request)); |
200 | | - } |
201 | | - |
202 | | - public void reportCOSDownloadTaskServiceException(CosXmlRequest request, QCloudServiceException serviceException, boolean cse) { |
203 | | - reportServiceException(EVENT_CODE_DOWNLOAD, request, serviceException, |
204 | | - createTransferExtra(cosDownloadName(cse), request)); |
205 | | - } |
| 172 | +// public void reportCOSUploadTaskSuccess(CosXmlRequest request, boolean cse) { |
| 173 | +// // 只需要一个 PutObjectRequest 壳,带上 HttpTaskMetrics 信息 |
| 174 | +// reportRequestSuccess(EVENT_CODE_UPLOAD, request, |
| 175 | +// Collections.singletonMap("name", cosUploadName(cse))); |
| 176 | +// } |
| 177 | +// |
| 178 | +// public void reportCOSUploadTaskClientException(CosXmlRequest request, QCloudClientException clientException, boolean cse) { |
| 179 | +// reportClientException(EVENT_CODE_UPLOAD, request, clientException, |
| 180 | +// createTransferExtra(cosUploadName(cse), request)); |
| 181 | +// } |
| 182 | +// |
| 183 | +// public void reportCOSUploadTaskServiceException(CosXmlRequest request, QCloudServiceException serviceException, boolean cse) { |
| 184 | +// reportServiceException(EVENT_CODE_UPLOAD, request, serviceException, |
| 185 | +// createTransferExtra(cosUploadName(cse), request)); |
| 186 | +// } |
| 187 | +// |
| 188 | +// public void reportCOSDownloadTaskSuccess(CosXmlRequest request, boolean cse) { |
| 189 | +// // 只需要一个 GetObjectRequest 壳,带上 HttpTaskMetrics 信息 |
| 190 | +// reportRequestSuccess(EVENT_CODE_DOWNLOAD, request, |
| 191 | +// Collections.singletonMap("name", cosDownloadName(cse))); |
| 192 | +// } |
| 193 | +// |
| 194 | +// public void reportCOSDownloadTaskClientException(CosXmlRequest request, QCloudClientException clientException, boolean cse) { |
| 195 | +// reportClientException(EVENT_CODE_DOWNLOAD, request, clientException, |
| 196 | +// createTransferExtra(cosDownloadName(cse), request)); |
| 197 | +// } |
| 198 | +// |
| 199 | +// public void reportCOSDownloadTaskServiceException(CosXmlRequest request, QCloudServiceException serviceException, boolean cse) { |
| 200 | +// reportServiceException(EVENT_CODE_DOWNLOAD, request, serviceException, |
| 201 | +// createTransferExtra(cosDownloadName(cse), request)); |
| 202 | +// } |
206 | 203 |
|
207 | 204 | public void reportCopyTaskSuccess(CosXmlRequest request) { |
208 | 205 | // 只需要一个 CopyObjectRequest 壳,带上 HttpTaskMetrics 信息 |
@@ -554,23 +551,23 @@ private Map<String, String> parseUrlParams(CosXmlRequest request) { |
554 | 551 | return params; |
555 | 552 | } |
556 | 553 |
|
557 | | - private BasePutObjectRequest emptyPutObjectRequestWithMetrics(HttpTaskMetrics taskMetrics) { |
558 | | - BasePutObjectRequest putObjectRequest = new BasePutObjectRequest("", "", ""); |
559 | | - putObjectRequest.attachMetrics(taskMetrics); |
560 | | - return putObjectRequest; |
561 | | - } |
| 554 | +// private BasePutObjectRequest emptyPutObjectRequestWithMetrics(HttpTaskMetrics taskMetrics) { |
| 555 | +// BasePutObjectRequest putObjectRequest = new BasePutObjectRequest("", "", ""); |
| 556 | +// putObjectRequest.attachMetrics(taskMetrics); |
| 557 | +// return putObjectRequest; |
| 558 | +// } |
562 | 559 |
|
563 | 560 | // private CopyObjectRequest emptyCopyObjectRequestWithMetrics(HttpTaskMetrics taskMetrics) { |
564 | 561 | // CopyObjectRequest copyObjectRequest = new CopyObjectRequest("", "", null); |
565 | 562 | // copyObjectRequest.attachMetrics(taskMetrics); |
566 | 563 | // return copyObjectRequest; |
567 | 564 | // } |
568 | 565 |
|
569 | | - private GetObjectRequest emptyGetObjectRequestWithMetrics(HttpTaskMetrics taskMetrics) { |
570 | | - GetObjectRequest getObjectRequest = new GetObjectRequest("", "", ""); |
571 | | - getObjectRequest.attachMetrics(taskMetrics); |
572 | | - return getObjectRequest; |
573 | | - } |
| 566 | +// private GetObjectRequest emptyGetObjectRequestWithMetrics(HttpTaskMetrics taskMetrics) { |
| 567 | +// GetObjectRequest getObjectRequest = new GetObjectRequest("", "", ""); |
| 568 | +// getObjectRequest.attachMetrics(taskMetrics); |
| 569 | +// return getObjectRequest; |
| 570 | +// } |
574 | 571 |
|
575 | 572 | private String parseEventCode(CosXmlRequest request) { |
576 | 573 |
|
@@ -661,26 +658,26 @@ private String flatInetAddressList(@Nullable List<InetAddress> ips) { |
661 | 658 | return ipString.toString(); |
662 | 659 | } |
663 | 660 |
|
664 | | - private String getConnectIp(@Nullable InetSocketAddress socketAddress) { |
665 | | - if (socketAddress == null || socketAddress.getAddress() == null) { |
666 | | - return ""; |
667 | | - } |
668 | | - return socketAddress.getAddress().getHostAddress(); |
669 | | - } |
670 | | - |
671 | | - private Map<String, String> getDownloadParams(String region, boolean isSuccess) { |
672 | | - Map<String, String> params = getCommonParams(); |
673 | | - params.put("result", isSuccess ? EVENT_PARAMS_SUCCESS : EVENT_PARAMS_FAILURE); |
674 | | - params.put("region", region); |
675 | | - return params; |
676 | | - } |
677 | | - |
678 | | - private Map<String, String> getUploadParams(String region, boolean isSuccess) { |
679 | | - Map<String, String> params = getCommonParams(); |
680 | | - params.put("result", isSuccess ? EVENT_PARAMS_SUCCESS : EVENT_PARAMS_FAILURE); |
681 | | - params.put("region", region); |
682 | | - return params; |
683 | | - } |
| 661 | +// private String getConnectIp(@Nullable InetSocketAddress socketAddress) { |
| 662 | +// if (socketAddress == null || socketAddress.getAddress() == null) { |
| 663 | +// return ""; |
| 664 | +// } |
| 665 | +// return socketAddress.getAddress().getHostAddress(); |
| 666 | +// } |
| 667 | +// |
| 668 | +// private Map<String, String> getDownloadParams(String region, boolean isSuccess) { |
| 669 | +// Map<String, String> params = getCommonParams(); |
| 670 | +// params.put("result", isSuccess ? EVENT_PARAMS_SUCCESS : EVENT_PARAMS_FAILURE); |
| 671 | +// params.put("region", region); |
| 672 | +// return params; |
| 673 | +// } |
| 674 | +// |
| 675 | +// private Map<String, String> getUploadParams(String region, boolean isSuccess) { |
| 676 | +// Map<String, String> params = getCommonParams(); |
| 677 | +// params.put("result", isSuccess ? EVENT_PARAMS_SUCCESS : EVENT_PARAMS_FAILURE); |
| 678 | +// params.put("region", region); |
| 679 | +// return params; |
| 680 | +// } |
684 | 681 |
|
685 | 682 | /** |
686 | 683 | * 获取公共参数 |
@@ -857,13 +854,13 @@ private boolean isUploadTaskRequest(CosXmlRequest cosXmlRequest) { |
857 | 854 | } |
858 | 855 |
|
859 | 856 |
|
860 | | - // 这里有点问题,复制任务还包括了一部分分片上传的请求 |
861 | | - private boolean isCopyTaskRequest(CosXmlRequest cosXmlRequest) { |
862 | | - |
863 | | - String requestName = cosXmlRequest.getClass().getSimpleName(); |
864 | | - return "UploadPartCopyRequest".equals(requestName) || |
865 | | - "CopyObjectRequest".equals(requestName); |
866 | | - } |
| 857 | +// // 这里有点问题,复制任务还包括了一部分分片上传的请求 |
| 858 | +// private boolean isCopyTaskRequest(CosXmlRequest cosXmlRequest) { |
| 859 | +// |
| 860 | +// String requestName = cosXmlRequest.getClass().getSimpleName(); |
| 861 | +// return "UploadPartCopyRequest".equals(requestName) || |
| 862 | +// "CopyObjectRequest".equals(requestName); |
| 863 | +// } |
867 | 864 |
|
868 | 865 | /** |
869 | 866 | * 是否上报(过滤掉不需要上报的异常) |
|
0 commit comments