hunk.code_window: 		if complianceI := einterfaces.GetComplianceInterface(); complianceI != nil {
   			complianceI.StartComplianceDailyJob()
   		}
   		if ldapI := einterfaces.GetLdapInterface(); ldapI != nil {
   			ldapI.StartLdapSyncJob()
   		}
   		// wait for kill signal before attempting to gracefully shutdown
   		// the running service
   		c := make(chan os.Signal)
   		signal.Notify(c, os.Interrupt, syscall.SIGINT, syscall.SIGTERM)
   		<-c
  
hunk.labels: keep keep keep keep replace replace replace replace keep keep keep keep keep
hunk.file_path: mattermost.go
hunk.type: replace
file: // Copyright 2013 The Go Authors. All rights reserved.
  // Use of this source code is governed by a BSD-style
  // license that can be found in the LICENSE file.
  
  package ssh
  
  // Key exchange tests.
  
  import (
  	"crypto/rand"
  	"reflect"
  	"testing"
  )
  
  func TestKexes(t *testing.T) {
  	type kexResultErr struct {
  		result *kexResult
  		err    error
  	}
  
  	for name, kex := range kexAlgoMap {
  		a, b := memPipe()
  
  		s := make(chan kexResultErr, 1)
  		c := make(chan kexResultErr, 1)
  		var magics handshakeMagics
  		go func() {
  			r, e := kex.Client(a, rand.Reader, &magics)
  			a.Close()
  			c <- kexResultErr{r, e}
  		}()
  		go func() {
  			r, e := kex.Server(b, rand.Reader, &magics, testSigners["ecdsa"])
  			b.Close()
  			s <- kexResultErr{r, e}
  		}()
  
  		clientRes := <-c
  		serverRes := <-s
  		if clientRes.err != nil {
  			t.Errorf("client: %v", clientRes.err)
  		}
  		if serverRes.err != nil {
  			t.Errorf("server: %v", serverRes.err)
  		}
  		if !reflect.DeepEqual(clientRes.result, serverRes.result) {
  			t.Errorf("kex %q: mismatch %#v, %#v", name, clientRes.result, serverRes.result)
  		}
  	}
  }
  