Search Options

Results per page
Sort
Preferred Languages
Advance

Results 801 - 810 of 1,341 for varr (0.02 sec)

  1. internal/event/target/amqp.go

    		return false, err
    	}
    	defer func() {
    		ch.Close()
    	}()
    	return true, nil
    }
    
    func (target *AMQPTarget) channel() (*amqp091.Channel, chan amqp091.Confirmation, error) {
    	var err error
    	var conn *amqp091.Connection
    	var ch *amqp091.Channel
    
    	isAMQPClosedErr := func(err error) bool {
    		if err == amqp091.ErrClosed {
    			return true
    		}
    
    		if nerr, ok := err.(*net.OpError); ok {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 10K bytes
    - Viewed (0)
  2. internal/store/queuestore_test.go

    package store
    
    import (
    	"fmt"
    	"os"
    	"path/filepath"
    	"reflect"
    	"testing"
    )
    
    type TestItem struct {
    	Name     string `json:"Name"`
    	Property string `json:"property"`
    }
    
    var (
    	// TestDir
    	queueDir = filepath.Join(os.TempDir(), "minio_test")
    	// Sample test item.
    	testItem = TestItem{Name: "test-item", Property: "property"}
    	// Ext for test item
    	testItemExt = ".test"
    )
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.7K bytes
    - Viewed (0)
  3. misc/ios/go_ios_exec.go

    	"strings"
    	"syscall"
    )
    
    const debug = false
    
    var tmpdir string
    
    var (
    	devID    string
    	appID    string
    	teamID   string
    	bundleID string
    	deviceID string
    )
    
    // lock is a file lock to serialize iOS runs. It is global to avoid the
    // garbage collector finalizing it, closing the file and releasing the
    // lock prematurely.
    var lock *os.File
    
    func main() {
    	log.SetFlags(0)
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Tue Jun 18 16:32:49 UTC 2024
    - 8.7K bytes
    - Viewed (0)
  4. callbacks/preload.go

    	var (
    		reflectValue     = tx.Statement.ReflectValue
    		relForeignKeys   []string
    		relForeignFields []*schema.Field
    		foreignFields    []*schema.Field
    		foreignValues    [][]interface{}
    		identityMap      = map[string][]reflect.Value{}
    		inlineConds      []interface{}
    	)
    
    	if rel.JoinTable != nil {
    		var (
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Wed Jun 12 10:52:33 UTC 2024
    - 11.6K bytes
    - Viewed (0)
  5. internal/s3select/sql/analysis.go

    // function combined with a row function is meaningless ("AVG(s.Age) +
    // s.Salary"). Analysis determines if such a scenario exists so an
    // error can be returned.
    
    var (
    	// Fatal error for query processing.
    	errNestedAggregation      = errors.New("Cannot nest aggregations")
    	errFunctionNotImplemented = errors.New("Function is not yet implemented")
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Dec 23 07:19:11 UTC 2023
    - 8.5K bytes
    - Viewed (0)
  6. internal/dsync/drwmutex_test.go

    		resource := "test"
    		runtime.GOMAXPROCS(gomaxprocs)
    		// Number of active readers + 10000 * number of active writers.
    		var activity int32
    		cdone := make(chan bool)
    		go writer(resource, numIterations, &activity, cdone)
    		var i int
    		for i = 0; i < numReaders/2; i++ {
    			go reader(resource, numIterations, &activity, cdone)
    		}
    		go writer(resource, numIterations, &activity, cdone)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Dec 24 03:49:07 UTC 2022
    - 9.7K bytes
    - Viewed (0)
  7. okhttp/src/test/java/okhttp3/internal/ws/WebSocketHttpTest.kt

      // Flaky https://github.com/square/okhttp/issues/4953
      @RegisterExtension
      var clientTestRule = configureClientTestRule()
    
      @RegisterExtension
      var platform = PlatformRule()
    
      @RegisterExtension
      var testLogHandler = TestLogHandler(OkHttpClient::class.java)
      private lateinit var webServer: MockWebServer
      private val handshakeCertificates = platform.localhostHandshakeCertificates()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Mar 31 17:16:15 UTC 2024
    - 35.2K bytes
    - Viewed (0)
  8. src/archive/zip/zip_test.go

    	}
    	for i := 0; i < nFiles; i++ {
    		want := fmt.Sprintf("%d.dat", i)
    		if zr.File[i].Name != want {
    			t.Fatalf("File(%d) = %q, want %q", i, zr.File[i].Name, want)
    		}
    	}
    }
    
    func TestModTime(t *testing.T) {
    	var testTime = time.Date(2009, time.November, 10, 23, 45, 58, 0, time.UTC)
    	fh := new(FileHeader)
    	fh.SetModTime(testTime)
    	outTime := fh.ModTime()
    	if !outTime.Equal(testTime) {
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 19.6K bytes
    - Viewed (0)
  9. src/main/webapp/WEB-INF/view/admin/failureurl/admin_failureurl.jsp

                                                    </tr>
                                                    </thead>
                                                    <tbody>
                                                    <c:forEach var="data" varStatus="s"
                                                               items="${failureUrlItems}">
                                                        <tr data-href="${contextPath}/admin/failureurl/details/4/${f:u(data.id)}">
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 13 07:47:04 UTC 2020
    - 13.3K bytes
    - Viewed (0)
  10. src/main/webapp/WEB-INF/view/admin/scheduler/admin_scheduler.jsp

                                                </tr>
                                                </thead>
                                                <tbody>
                                                <c:forEach var="data" varStatus="s"
                                                           items="${scheduledJobItems}">
                                                    <tr
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Wed Feb 12 20:25:27 UTC 2020
    - 6.4K bytes
    - Viewed (0)
Back to top