Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 1,402 for wrote (0.09 sec)

  1. internal/ringbuffer/ring_buffer_test.go

    				t.Fatalf("write failed: %v", err)
    			}
    			wroteBytes += n
    			wrote.Write(buf[:n])
    			debugln("WRITE 4\t", n, wroteBytes)
    
    			// TryWriteByte
    			err = rb.TryWriteByte(buf[0])
    			if err != nil && err != ErrAcquireLock && err != ErrTooMuchDataToWrite && err != ErrIsFull {
    				t.Fatalf("write failed: %v", err)
    			}
    			if err == nil {
    				wroteBytes++
    				wrote.Write(buf[:1])
    				debugln("WRITE 5\t", 1, wroteBytes)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 15 00:11:04 UTC 2024
    - 26.8K bytes
    - Viewed (0)
  2. tests/test_tutorial/test_websockets/test_tutorial003_py39.py

            "/ws/5678"
        ) as connection_two:
            connection.send_text("Hello from 1234")
            data1 = connection.receive_text()
            assert data1 == "You wrote: Hello from 1234"
            data2 = connection_two.receive_text()
            client1_says = "Client #1234 says: Hello from 1234"
            assert data2 == client1_says
            data1 = connection.receive_text()
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sat Mar 18 12:29:59 UTC 2023
    - 1.3K bytes
    - Viewed (0)
  3. tests/test_tutorial/test_websockets/test_tutorial003.py

            "/ws/5678"
        ) as connection_two:
            connection.send_text("Hello from 1234")
            data1 = connection.receive_text()
            assert data1 == "You wrote: Hello from 1234"
            data2 = connection_two.receive_text()
            client1_says = "Client #1234 says: Hello from 1234"
            assert data2 == client1_says
            data1 = connection.receive_text()
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Thu Jul 29 09:26:07 UTC 2021
    - 872 bytes
    - Viewed (0)
  4. cni/pkg/install/kubeconfig.go

    	if err := file.AtomicWrite(kubeconfigFilepath, []byte(kc.Full), os.FileMode(cfg.KubeconfigMode)); err != nil {
    		installLog.Debugf("error writing kubeconfig: %w", err)
    		return err
    	}
    	installLog.Infof("wrote kubeconfig file %s with: \n%+v", kubeconfigFilepath, kc.Redacted)
    	return nil
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Aug 01 18:38:14 UTC 2024
    - 4K bytes
    - Viewed (0)
  5. internal/ringbuffer/ring_buffer.go

    	if len(p) == 0 {
    		return 0, r.setErr(nil, false)
    	}
    	r.mu.Lock()
    	defer r.mu.Unlock()
    	if err := r.err; err != nil {
    		if err == io.EOF {
    			err = ErrWriteOnClosed
    		}
    		return 0, err
    	}
    	wrote := 0
    	for len(p) > 0 {
    		n, err = r.write(p)
    		wrote += n
    		if !r.block || err == nil {
    			break
    		}
    		err = r.setErr(err, true)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 15 00:11:04 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  6. docs_src/websockets/tutorial003_py39.py

        await manager.connect(websocket)
        try:
            while True:
                data = await websocket.receive_text()
                await manager.send_personal_message(f"You wrote: {data}", websocket)
                await manager.broadcast(f"Client #{client_id} says: {data}")
        except WebSocketDisconnect:
            manager.disconnect(websocket)
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sat Mar 18 12:29:59 UTC 2023
    - 2.5K bytes
    - Viewed (0)
  7. docs_src/websockets/tutorial003.py

        await manager.connect(websocket)
        try:
            while True:
                data = await websocket.receive_text()
                await manager.send_personal_message(f"You wrote: {data}", websocket)
                await manager.broadcast(f"Client #{client_id} says: {data}")
        except WebSocketDisconnect:
            manager.disconnect(websocket)
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Aug 09 13:52:19 UTC 2020
    - 2.5K bytes
    - Viewed (0)
  8. tensorflow/c/c_test.c

      TF_NewWritableFile(full_path, &h, status);
      if (TF_GetCode(status) != TF_OK) {
        fprintf(stderr, "TF_NewWritableFile failed: %s\n", TF_Message(status));
        return 1;
      }
      fprintf(stderr, "wrote %s\n", full_path);
      free(full_path);
      TF_CloseWritableFile(h, status);
      if (TF_GetCode(status) != TF_OK) {
        fprintf(stderr, "TF_CloseWritableFile failed: %s\n", TF_Message(status));
      }
      TF_StringStreamDone(s);
    
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Wed Apr 24 20:50:35 UTC 2024
    - 2.8K bytes
    - Viewed (0)
  9. docs/tls/README.md

    ```sh
    ./certgen -host "10.10.0.3,10.10.0.4,10.10.0.5"
    ```
    
    A response similar to this one should be displayed:
    
    ```
    2018/11/21 10:16:18 wrote public.crt
    2018/11/21 10:16:18 wrote private.key
    ```
    
    ### 3.2 Use OpenSSL to Generate a Certificate
    
    Use one of the following methods to generate a certificate using `openssl`:
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 29 04:28:45 UTC 2022
    - 8.4K bytes
    - Viewed (0)
  10. src/main/java/jcifs/smb/SmbFileOutputStream.java

         *
         * @throws IOException
         *             if a network error occurs
         */
    
        @Override
        public void write ( int b ) throws IOException {
            this.tmp[ 0 ] = (byte) b;
            write(this.tmp, 0, 1);
        }
    
    
        /**
         * Writes b.length bytes from the specified byte array to this
         * file output stream.
         *
         * @throws IOException
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sat Nov 13 15:14:04 UTC 2021
    - 11.9K bytes
    - Viewed (0)
Back to top