ss.setReuseAddress(true);
            } finally {
                ss.close();
            }

            DatagramSocket ds = new DatagramSocket(port);
            try {
                ds.setReuseAddress(true);
            } finally {
                ds.close();
            }

            return true;
        } catch (IOException e) {
            return false;
        }

    }

<?xml version="1.0" encoding="UTF-8"?>
<metadata>
    <groupId>org.codelibs.fess</groupId>
    <artifactId>fess-ds-atlassian</artifactId>
    <versioning>
        <latest>13.2.0</latest>
        <release>13.2.0</release>
        <versions>
            <version>12.2.0</version>
            <version>12.5.0</version>
            <version>12.6.0</version>
            <version>12.7.0</version>
            <version>13.0.0</version>

<?xml version="1.0" encoding="UTF-8"?>
<metadata modelVersion="1.1.0">
  <groupId>org.codelibs.fess</groupId>
  <artifactId>fess-ds-atlassian</artifactId>
  <version>12.2.0-SNAPSHOT</version>
  <versioning>
    <snapshot>
      <timestamp>20180814.210714</timestamp>
      <buildNumber>10</buildNumber>
    </snapshot>
    <lastUpdated>20180814210714</lastUpdated>
    <snapshotVersions>
      <snapshotVersion>
        <extension>jar</extension>

			} else {
				t.Errorf("parsePAXTime(%q): got parsing success, want failure", v.in)
			}
		}
		if ok && !ts.Equal(v.want) {
			t.Errorf("parsePAXTime(%q): got (%ds %dns), want (%ds %dns)",
				v.in, ts.Unix(), ts.Nanosecond(), v.want.Unix(), v.want.Nanosecond())
		}
	}
}

func TestFormatPAXTime(t *testing.T) {
	vectors := []struct {
		sec, nsec int64
		want      string

	"github.com/minio/minio/internal/logger"
)

// generates format string depending on the string length and padding.
func getFormatStr(strLen int, padding int) string {
	formatStr := fmt.Sprintf("%ds", strLen+padding)
	return "%" + formatStr
}

// Prints the formatted startup message.
func printStartupMessage(apiEndpoints []string, err error) {
	banner := strings.Repeat("-", len(MinioBannerName))

        serializer = null;
    }

    /**
     * Test DataSerializer can be instantiated
     */
    @Test
    public void test_constructor() {
        DataSerializer ds = new DataSerializer();
        assertNotNull(ds, "DataSerializer should be instantiable");
    }

    /**
     * Test serialization and deserialization of simple String
     */
    @Test
    public void test_serializeDeserialize_string() {

├── ldap/                      # LDAP integration
├── filter/                    # Servlet filters
├── validation/                # Custom validators
├── dict/                      # Dictionary management
└── ds/                        # Data store connectors

src/main/resources/
├── fess_config.properties     # Main configuration
├── app.xml, fess.xml          # DI configuration

                        set.add(e);
                    }
                }
            } catch (final IOException ioe) {
                log.debug("DS enumeration failed", ioe);
            }
        }

        final SmbTreeConnection treeConn = SmbTreeConnection.create(tc);
        try (SmbTreeHandleImpl th = treeConn.connectHost(locator, locator.getServerWithDfs());

package dsync

import (
	"fmt"
	"io"
	"net/http"
	"net/http/httptest"
	"sync"
	"sync/atomic"
	"time"

	"github.com/minio/mux"
)

const numberOfNodes = 5

var (
	ds          *Dsync
	nodes       = make([]*httptest.Server, numberOfNodes) // list of node IP addrs or hostname with ports.
	lockServers = make([]*lockServer, numberOfNodes)
)

    @Override
    public NavigableSet<E> descendingSet() {
      synchronized (mutex) {
        if (descendingSet == null) {
          NavigableSet<E> dS = Synchronized.navigableSet(delegate().descendingSet(), mutex);
          descendingSet = dS;
          return dS;
        }
        return descendingSet;
      }
    }

    @Override
    public @Nullable E floor(E e) {
      synchronized (mutex) {