- Sort Score
- Result 10 results
- Languages All
Results 321 - 330 of 664 for encoder (0.42 sec)
-
cmd/listen-notification-handlers.go
tmpEvt := struct{ Records []event.Event }{[]event.Event{{}}} for { select { case ev := <-localCh: buf.Reset() tmpEvt.Records[0] = ev if err := enc.Encode(tmpEvt); err != nil { bugLogIf(ctx, err, "event: Encode failed") continue } mergeCh <- append(grid.GetByteBuffer()[:0], buf.Bytes()...) case <-ctx.Done(): grid.PutByteBuffer(buf.Bytes()) return } }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue Feb 18 16:25:55 UTC 2025 - 6K bytes - Viewed (0) -
android/guava/src/com/google/common/hash/Hasher.java
* } * * <p>If you wish to avoid this, you should either prepend or append the size of each chunk. Keep in * mind that when dealing with char sequences, the encoded form of two concatenated char sequences * is not equivalent to the concatenation of their encoded form. Therefore, {@link * #putString(CharSequence, Charset)} should only be used consistently with <i>complete</i> * sequences and not broken into chunks. *
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Mar 17 20:26:29 UTC 2025 - 5.5K bytes - Viewed (0) -
cmd/tier.go
return d, nil } // configReader returns a PutObjReader and ObjectOptions needed to save config // using a PutObject API. PutObjReader encrypts json encoded tier configurations // if KMS is enabled, otherwise simply yields the json encoded bytes as is. // Similarly, ObjectOptions value depends on KMS' status. func (config *TierConfigMgr) configReader(ctx context.Context) (*PutObjReader, *ObjectOptions, error) {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 15.6K bytes - Viewed (0) -
cmd/admin-handlers-site-replication.go
return } info, err := globalSiteReplicationSys.GetClusterInfo(ctx) if err != nil { writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL) return } if err = json.NewEncoder(w).Encode(info); err != nil { writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL) return } } func (a adminAPIHandlers) SRPeerGetIDPSettings(w http.ResponseWriter, r *http.Request) { ctx := r.Context()
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 19.3K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb2/lease/Smb2LeaseKeyTest.java
assertThrows(IllegalArgumentException.class, () -> new Smb2LeaseKey(new byte[17])); assertThrows(IllegalArgumentException.class, () -> new Smb2LeaseKey(new byte[0])); } @Test @DisplayName("Should encode lease key to buffer") void testEncode() { byte[] testBytes = new byte[] { 0x11, 0x22, 0x33, 0x44, 0x55, 0x66, 0x77, (byte) 0x88, (byte) 0x99, (byte) 0xAA, (byte) 0xBB,
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 21 00:16:17 UTC 2025 - 6K bytes - Viewed (0) -
cmd/signature-v2.go
// // returns ErrNone if matches. S3 errors otherwise. func doesPresignV2SignatureMatch(r *http.Request) APIErrorCode { // r.RequestURI will have raw encoded URI as sent by the client. tokens := strings.SplitN(r.RequestURI, "?", 2) encodedResource := tokens[0] encodedQuery := "" if len(tokens) == 2 { encodedQuery = tokens[1] } var (
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 12.2K bytes - Viewed (0) -
src/main/webapp/WEB-INF/orig/view/error/redirect.jsp
redirectPage.append("/error/badrequest/"); response.sendRedirect(redirectPage.toString()); } else if(!"badAuth".equals(type)) { redirectPage.append("/error/notfound/?url="); redirectPage.append(java.net.URLEncoder.encode(requestUri , "UTF-8")); response.sendRedirect(redirectPage.toString()); }
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sat Dec 23 06:18:48 UTC 2023 - 1.2K bytes - Viewed (0) -
src/main/webapp/WEB-INF/view/error/redirect.jsp
redirectPage.append("/error/badrequest/"); response.sendRedirect(redirectPage.toString()); } else if(!"badAuth".equals(type)) { redirectPage.append("/error/notfound/?url="); redirectPage.append(java.net.URLEncoder.encode(requestUri , "UTF-8")); response.sendRedirect(redirectPage.toString()); }
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sat Dec 23 06:18:48 UTC 2023 - 1.2K bytes - Viewed (0) -
android/guava/src/com/google/common/escape/package-info.java
* or implied. See the License for the specific language governing permissions and limitations under * the License. */ /** * Interfaces, utilities, and simple implementations of escapers and encoders. The primary type is * {@link Escaper}. * * <p>Additional escapers implementations are found in the applicable packages: {@link * com.google.common.html.HtmlEscapers} in {@code com.google.common.html}, {@link
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sat Dec 21 14:50:24 UTC 2024 - 1.3K bytes - Viewed (0) -
src/cmd/asm/internal/asm/testdata/386enc.s
// Use of this source code is governed by a BSD-style // license that can be found in the LICENSE file. #include "../../../../../runtime/textflag.h" TEXT asmtest(SB),DUPOK|NOSPLIT,$0 // Instructions that were encoded with BYTE sequences. // Included to simplify validation of CL that fixed that. MOVQ (AX), M0 // 0f6f00 MOVQ M0, 8(SP) // 0f7f442408 MOVQ 8(SP), M0 // 0f6f442408 MOVQ M0, (AX) // 0f7f00 MOVQ M0, (BX) // 0f7f03
Registered: Tue Sep 09 11:13:09 UTC 2025 - Last Modified: Tue Apr 11 18:32:50 UTC 2023 - 1.2K bytes - Viewed (0)