Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 83 for conns (0.1 sec)

  1. src/main/java/jcifs/smb/SmbTreeConnectionTrace.java

     *
     */
    class SmbTreeConnectionTrace extends SmbTreeConnection {
    
        SmbTreeConnectionTrace ( CIFSContext ctx ) {
            super(ctx);
        }
    
    
        SmbTreeConnectionTrace ( SmbTreeConnection conn ) {
            super(conn);
        }
    
    
        @Override
        protected void finalize () throws Throwable {
            checkRelease();
        }
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sat Jul 20 08:41:19 UTC 2019
    - 1.1K bytes
    - Viewed (0)
  2. regression-test/src/androidTest/java/okhttp/regression/compare/AndroidHttpEngineTest.kt

        req.start()
        return completableFuture
      }
    
      @Test
      fun urlConnection() {
        val conn = engine.openConnection(URL("https://google.com/robots.txt")) as HttpURLConnection
    
        val text =
          conn.inputStream.use {
            it.bufferedReader().readText()
          }
    
        assertEquals(200, conn.responseCode)
    
        assertTrue(text.contains("Disallow"))
      }
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Mar 24 13:19:43 UTC 2024
    - 6.2K bytes
    - Viewed (0)
  3. internal/http/dial_dnscache.go

    		baseDialCtx = (&net.Dialer{
    			Timeout:   30 * time.Second,
    			KeepAlive: 30 * time.Second,
    		}).DialContext
    	}
    
    	return func(ctx context.Context, network, addr string) (conn net.Conn, err error) {
    		host, port, err := net.SplitHostPort(addr)
    		if err != nil {
    			return nil, err
    		}
    
    		if net.ParseIP(host) != nil {
    			// For IP only setups there is no need for DNS lookups.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 03 19:30:51 UTC 2023
    - 2.6K bytes
    - Viewed (0)
  4. schema/relationship.go

    				relForeignKeys = append(relForeignKeys, ref.ForeignKey.DBName)
    			} else if ref.PrimaryValue != "" {
    				conds = append(conds, clause.Eq{
    					Column: clause.Column{Table: rel.JoinTable.Table, Name: ref.ForeignKey.DBName},
    					Value:  ref.PrimaryValue,
    				})
    			} else {
    				conds = append(conds, clause.Eq{
    					Column: clause.Column{Table: rel.JoinTable.Table, Name: ref.ForeignKey.DBName},
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Wed Jun 12 03:46:59 UTC 2024
    - 22.7K bytes
    - Viewed (0)
  5. internal/grid/manager.go

    // Auth is handled internally, as well as disconnecting any connections from the same host.
    func (m *Manager) IncomingConn(ctx context.Context, conn net.Conn) {
    	remoteAddr := conn.RemoteAddr().String()
    	// will write an OpConnectResponse message to the remote and log it once locally.
    	defer conn.Close()
    	writeErr := func(err error) {
    		if err == nil {
    			return
    		}
    		if errors.Is(err, io.EOF) {
    			return
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  6. internal/grid/README.md

        }
    
        err := manager.RegisterSingleHandler(grid.HandlerDiskInfo, handler)
    ```
    
    Sample call:
    ```go
        // Get a connection to the remote host
        conn := manager.Connection(host)
    	
        payload := []byte("request")
        response, err := conn.SingleRequest(ctx, grid.HandlerDiskInfo, payload)
    ```
    
    If the error type is `*RemoteErr`, then the error was returned by the remote server. Otherwise it is a local error.
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 9.4K bytes
    - Viewed (0)
  7. src/main/java/jcifs/smb1/smb1/SmbTransport.java

                            return conn;
                        }
                    }
                }
    
                conn = new SmbTransport( address, port, localAddr, localPort );
                CONNECTIONS.add( 0, conn );
            }
    
            return conn;
        }
    
        class ServerData {
            byte flags;
            int flags2;
            int maxMpxCount;
            int maxBufferSize;
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 21:10:40 UTC 2019
    - 31.2K bytes
    - Viewed (0)
  8. internal/event/target/nats.go

    }
    
    // NATSTarget - NATS target.
    type NATSTarget struct {
    	initOnce once.Init
    
    	id         event.TargetID
    	args       NATSArgs
    	natsConn   *nats.Conn
    	stanConn   stan.Conn
    	jstream    nats.JetStream
    	store      store.Store[event.Event]
    	loggerOnce logger.LogOnce
    	quitCh     chan struct{}
    }
    
    // ID - returns target ID.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 12.9K bytes
    - Viewed (0)
  9. api/go1.7.txt

    pkg net/http/httptrace, type DNSStartInfo struct
    pkg net/http/httptrace, type DNSStartInfo struct, Host string
    pkg net/http/httptrace, type GotConnInfo struct
    pkg net/http/httptrace, type GotConnInfo struct, Conn net.Conn
    pkg net/http/httptrace, type GotConnInfo struct, IdleTime time.Duration
    pkg net/http/httptrace, type GotConnInfo struct, Reused bool
    pkg net/http/httptrace, type GotConnInfo struct, WasIdle bool
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Tue Jun 28 15:08:11 UTC 2016
    - 13.6K bytes
    - Viewed (0)
  10. tests/prepared_stmt_test.go

    			tx.Create(&user)
    
    			var result User
    			tx.First(&result)
    			wg.Done()
    		}()
    	}
    	wg.Wait()
    
    	conn, ok := tx.ConnPool.(*gorm.PreparedStmtDB)
    	AssertEqual(t, ok, true)
    	AssertEqual(t, len(conn.Stmts), 2)
    	for _, stmt := range conn.Stmts {
    		if stmt == nil {
    			t.Fatalf("stmt cannot bee nil")
    		}
    	}
    
    	AssertEqual(t, sqlDB.Stats().InUse, 0)
    }
    
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Thu Aug 22 11:02:05 UTC 2024
    - 8.5K bytes
    - Viewed (0)
Back to top