package org.webslinger.ext.commons.vfs.plan9;

 import java.util.Arrays;

 import java.util.Collection;

 import java.util.Collections;

 import java.net.URI;

 import org.apache.commons.vfs.FileName;

 import org.apache.commons.vfs.FileObject;

 import org.apache.commons.vfs.FileSystem;

 import org.apache.commons.vfs.FileSystemException;

 import org.apache.commons.vfs.FileSystemOptions;

 import org.apache.commons.vfs.provider.AbstractFileSystem;

 import org.apache.commons.vfs.provider.GenericFileName;

 import uk.ac.rdg.resc.jstyx.StyxException;

 import uk.ac.rdg.resc.jstyx.StyxUtils;

 import uk.ac.rdg.resc.jstyx.client.CStyxFile;

 import uk.ac.rdg.resc.jstyx.client.StyxConnection;

 import uk.ac.rdg.resc.jstyx.types.DirEntry;

 public class Plan9FileSystem extends AbstractFileSystem {

     protected String userName;

     protected String hostName;

     protected int port;

     protected StyxConnection connection;

     protected int useCount;

     public Plan9FileSystem(final FileName rootName, final FileSystemOptions fileSystemOptions) throws FileSystemException {

         super(rootName, null, fileSystemOptions);

         GenericFileName gfn = (GenericFileName) getRootName();

         userName = gfn.getUserName();

         hostName = gfn.getHostName();

         port = gfn.getPort();

         try {

             connection = getConnection();

             connection.connect();

         } catch (Exception e) {

             if (e instanceof FileSystemException) throw (FileSystemException) e;

             throw (FileSystemException) new FileSystemException(e.getMessage()).initCause(e);

         }

     }

     protected boolean checkMode(DirEntry entry, int mask) {

         long mode = entry.getMode();

         if (((mode >> 6) & mask) != 0) return true;

         if ((mode & mask) != 0) return true;

         return false;

     }

     public boolean isReadable(DirEntry entry) {

         return checkMode(entry, 040);

     }

     public boolean isWritable(DirEntry entry) {

         return checkMode(entry, 020);

     }

     protected FileObject createFile(final FileName name) throws FileSystemException {

         return new Plan9FileObject(name, this);

     }

     protected void addCapabilities(final Collection caps) {

         caps.addAll(Plan9FileProvider.capabilities);

     }

     public StyxConnection getNewConnection() {

         if (userName == null) {

             return new StyxConnection(hostName, port);

         } else {

             return new StyxConnection(hostName, port, userName);

         }

     }

     public StyxConnection getConnection() throws Exception {

         synchronized (this) {

             if (connection == null) {

                 connection = getNewConnection();

                 connection.connect();

             }

             useCount++;

             return connection;

         }

     }

     public void putConnection(StyxConnection connection) {

         synchronized (this) {

             useCount--;

             if (useCount == 0) {

                 connection.close();

                 connection = null;

             }

         }

     }

     protected void doCloseCommunicationLink() {

         System.err.println("doCloseCommunicationLink()");

         connection.close();

     }

 }