Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 641 - 650 of 886 for Async (0.03 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. internal/ioutil/wait_pipe.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package ioutil
    
    import (
    	"io"
    	"sync"
    )
    
    // PipeWriter is similar to io.PipeWriter with wait group
    type PipeWriter struct {
    	*io.PipeWriter
    	once sync.Once
    	done func()
    }
    
    // CloseWithError close with supplied error the writer end.
    func (w *PipeWriter) CloseWithError(err error) error {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Thu Apr 27 14:55:36 GMT 2023
    - 1.7K bytes
    - Click Count (0)
  2. internal/cachevalue/cache.go

    //
    // You should have received a copy of the GNU Affero General Public License
    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cachevalue
    
    import (
    	"context"
    	"sync"
    	"sync/atomic"
    	"time"
    )
    
    // Opts contains options for the cache.
    type Opts struct {
    	// When set to true, return the last cached value
    	// even if updating the value errors out.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri May 24 12:50:46 GMT 2024
    - 4.4K bytes
    - Click Count (0)
  3. cmd/perf-tests.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"context"
    	"encoding/gob"
    	"errors"
    	"fmt"
    	"io"
    	"math/rand"
    	"net/http"
    	"net/url"
    	"sync"
    	"sync/atomic"
    	"time"
    
    	"github.com/dustin/go-humanize"
    	"github.com/minio/madmin-go/v3"
    	"github.com/minio/minio-go/v7"
    	"github.com/minio/minio-go/v7/pkg/credentials"
    	xhttp "github.com/minio/minio/internal/http"
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 11.8K bytes
    - Click Count (0)
  4. schema/field_test.go

    package schema_test
    
    import (
    	"context"
    	"database/sql"
    	"reflect"
    	"sync"
    	"testing"
    	"time"
    
    	"gorm.io/gorm"
    	"gorm.io/gorm/schema"
    	"gorm.io/gorm/utils/tests"
    )
    
    func TestFieldValuerAndSetter(t *testing.T) {
    	var (
    		userSchema, _ = schema.Parse(&tests.User{}, &sync.Map{}, schema.NamingStrategy{})
    		user          = tests.User{
    			Model: gorm.Model{
    				ID:        10,
    				CreatedAt: time.Now(),
    Created: Sun Apr 05 09:35:12 GMT 2026
    - Last Modified: Sat Feb 19 09:02:53 GMT 2022
    - 12.7K bytes
    - Click Count (0)
  5. internal/pubsub/pubsub.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package pubsub
    
    import (
    	"bytes"
    	"encoding/json"
    	"fmt"
    	"sync"
    	"sync/atomic"
    )
    
    // GetByteBuffer returns a byte buffer from the pool.
    var GetByteBuffer = func() []byte {
    	return make([]byte, 0, 4096)
    }
    
    // Sub - subscriber entity.
    type Sub[T Maskable] struct {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Feb 06 16:57:30 GMT 2024
    - 5.2K bytes
    - Click Count (0)
  6. internal/bucket/replication/rule_test.go

    			opts:           ObjectOpts{Name: "c1test", DeleteMarker: false, OpType: ObjectReplicationType, Replica: false}, // 1. Replica mod sync enabled; not a replica
    			expectedResult: true,
    		},
    		// case 2 - rule with replica modification disabled; a replica
    		{
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 4.6K bytes
    - Click Count (0)
  7. go.sum

    golang.org/x/sync v0.0.0-20201020160332-67f06af15bc9/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
    golang.org/x/sync v0.0.0-20201207232520-09787c993a3a/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
    golang.org/x/sync v0.0.0-20220722155255-886fb9371eb4/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
    golang.org/x/sync v0.1.0/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 79.8K bytes
    - Click Count (0)
  8. src/test/java/org/codelibs/fess/auth/chain/LdapChainTest.java

            // Test successful password change when LDAP admin sync is enabled
            testLdapManager.changePasswordResult = true;
            testFessConfig.ldapAdminSyncPassword = true;
    
            boolean result = ldapChain.changePassword("testuser", "newpassword");
    
            assertTrue(result); // !changed || sync = !true || true = true
            assertEquals("testuser", testLdapManager.changePasswordUsername);
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Mar 13 23:01:26 GMT 2026
    - 9.5K bytes
    - Click Count (0)
  9. cmd/dynamic-timeouts.go

    //
    // You should have received a copy of the GNU Affero General Public License
    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"math"
    	"sync"
    	"sync/atomic"
    	"time"
    )
    
    const (
    	dynamicTimeoutIncreaseThresholdPct = 0.33 // Upper threshold for failures in order to increase timeout
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 4.5K bytes
    - Click Count (0)
  10. internal/s3select/progress.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package s3select
    
    import (
    	"context"
    	"errors"
    	"fmt"
    	"io"
    	"runtime"
    	"sync"
    	"sync/atomic"
    
    	"github.com/cosnicolaou/pbzip2"
    	"github.com/klauspost/compress/s2"
    	"github.com/klauspost/compress/zstd"
    	gzip "github.com/klauspost/pgzip"
    	"github.com/pierrec/lz4/v4"
    )
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 22 00:33:43 GMT 2024
    - 4.3K bytes
    - Click Count (0)
Back to Top