Search Options

Results per page
Sort
Preferred Languages
Advance

Results 101 - 110 of 1,815 for gwrite (0.43 sec)

  1. pkg/proxy/iptables/proxier.go

    			chainString := string(chain)
    			if isServiceChainName(chainString) {
    				natChains.Write(utiliptables.MakeChainLine(chain)) // flush
    				natRules.Write("-X", chainString)                  // delete
    			}
    		}
    		natRules.Write("COMMIT")
    		natLines := append(natChains.Bytes(), natRules.Bytes()...)
    		// Write it.
    		err = ipt.Restore(utiliptables.TableNAT, natLines, utiliptables.NoFlushTables, utiliptables.RestoreCounters)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 21 14:39:54 UTC 2024
    - 65.1K bytes
    - Viewed (0)
  2. src/strings/builder_test.go

    			fn: func() {
    				var a Builder
    				a.WriteByte('x')
    				b := a
    				b.Reset()
    				b.WriteByte('y')
    			},
    		},
    		{
    			name:      "Write",
    			wantPanic: true,
    			fn: func() {
    				var a Builder
    				a.Write([]byte("x"))
    				b := a
    				b.Write([]byte("y"))
    			},
    		},
    		{
    			name:      "WriteByte",
    			wantPanic: true,
    			fn: func() {
    				var a Builder
    				a.WriteByte('x')
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Feb 19 19:51:15 UTC 2024
    - 8.1K bytes
    - Viewed (0)
  3. cmd/background-newdisks-heal-ops_gen.go

    // EncodeMsg implements msgp.Encodable
    func (z *healingTracker) EncodeMsg(en *msgp.Writer) (err error) {
    	// map header, size 25
    	// write "ID"
    	err = en.Append(0xde, 0x0, 0x19, 0xa2, 0x49, 0x44)
    	if err != nil {
    		return
    	}
    	err = en.WriteString(z.ID)
    	if err != nil {
    		err = msgp.WrapError(err, "ID")
    		return
    	}
    	// write "PoolIndex"
    	err = en.Append(0xa9, 0x50, 0x6f, 0x6f, 0x6c, 0x49, 0x6e, 0x64, 0x65, 0x78)
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Wed Feb 28 17:05:40 UTC 2024
    - 21.5K bytes
    - Viewed (0)
  4. src/internal/poll/fd_plan9.go

    	fd.rmu.Unlock()
    	n, err := fd.raio.Wait()
    	fd.raio = nil
    	if isHangup(err) {
    		err = io.EOF
    	}
    	if isInterrupted(err) {
    		err = ErrDeadlineExceeded
    	}
    	return n, err
    }
    
    // Write implements io.Writer.
    func (fd *FD) Write(fn func([]byte) (int, error), b []byte) (int, error) {
    	if err := fd.writeLock(); err != nil {
    		return 0, err
    	}
    	defer fd.writeUnlock()
    	fd.wmu.Lock()
    	if fd.wtimedout {
    		fd.wmu.Unlock()
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon May 06 14:00:54 UTC 2024
    - 5.4K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/app/web/base/FessAdminAction.java

                runtime.registerData("forumLink", forumLink);
            }
        }
    
        protected abstract String getActionRole();
    
        protected void write(final String path, final byte[] data) {
            LdiFileUtil.write(path, data);
        }
    
        protected ServletContext getServletContext() {
            return LaServletContextUtil.getServletContext();
        }
    
    Registered: Wed Jun 12 13:08:18 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  6. internal/ringbuffer/ring_buffer.go

    	r.isFull = false
    	return b, r.readErr(true)
    }
    
    // Write writes len(p) bytes from p to the underlying buf.
    // It returns the number of bytes written from p (0 <= n <= len(p))
    // and any error encountered that caused the write to stop early.
    // If blocking n < len(p) will be returned only if an error occurred.
    // Write returns a non-nil error if it returns n < len(p).
    // Write will not modify the slice data, even temporarily.
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Wed May 15 00:11:04 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  7. platforms/core-execution/execution/src/main/java/org/gradle/internal/execution/history/impl/DefaultPreviousExecutionStateSerializer.java

                successful
            );
        }
    
        @Override
        public void write(Encoder encoder, PreviousExecutionState execution) throws Exception {
            originMetadataSerializer.write(encoder, execution.getOriginMetadata());
    
            hashCodeSerializer.write(encoder, execution.getCacheKey());
            implementationSnapshotSerializer.write(encoder, execution.getImplementation());
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Feb 02 08:25:58 UTC 2024
    - 8.7K bytes
    - Viewed (0)
  8. src/index/suffixarray/suffixarray.go

    	}
    	return nil
    }
    
    // Write writes the index x to w.
    func (x *Index) Write(w io.Writer) error {
    	// buffer for all writes
    	buf := make([]byte, bufSize)
    
    	// write length
    	if err := writeInt(w, buf, len(x.data)); err != nil {
    		return err
    	}
    
    	// write data
    	if _, err := w.Write(x.data); err != nil {
    		return err
    	}
    
    	// write index
    	sa := x.sa
    	for sa.len() > 0 {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 9.5K bytes
    - Viewed (0)
  9. src/vendor/golang.org/x/crypto/sha3/sha3_s390x.go

    func (s *asmState) resetBuf() {
    	max := (cap(s.storage) / s.rate) * s.rate
    	s.buf = s.storage[:0:max]
    }
    
    // Write (via the embedded io.Writer interface) adds more data to the running hash.
    // It never returns an error.
    func (s *asmState) Write(b []byte) (int, error) {
    	if s.state != spongeAbsorbing {
    		panic("sha3: Write after Read")
    	}
    	length := len(b)
    	for len(b) > 0 {
    		if len(s.buf) == 0 && len(b) >= cap(s.buf) {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Jun 04 16:19:04 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  10. platforms/core-configuration/dependency-management-serialization-codecs/src/main/kotlin/org/gradle/internal/serialize/codecs/dm/transform/InitialTransformStepNodeCodec.kt

        override suspend fun WriteContext.doEncode(value: TransformStepNode.InitialTransformStepNode) {
            writeLong(value.transformStepNodeId)
            write(value.targetComponentVariant)
            write(value.sourceAttributes)
            write(unpackTransformStep(value))
            write(value.inputArtifact)
        }
    
        override suspend fun ReadContext.doDecode(): TransformStepNode.InitialTransformStepNode {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Jun 04 18:56:44 UTC 2024
    - 2.6K bytes
    - Viewed (0)
Back to top