request.setVersion(registration.getVersion().getValue());
                request.setShareName(shareName);
                request.setServerAddress(serverAddress.getHostAddress());
                request.setFlags(registration.getFlags());

                WitnessRegisterResponse response = rpcClient.register(request);

                if (response != null && response.isSuccess()) {

)

// 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)
	log.SetPrefix("go_ios_exec: ")
	if debug {
		log.Println(strings.Join(os.Args, " "))
	}
	if len(os.Args) < 2 {
		log.Fatal("usage: go_ios_exec a.out")
	}

        log.debug("Sending VALIDATE_NEGOTIATE_INFO");
        final Smb2IoctlRequest req = new Smb2IoctlRequest(sess.getConfig(), Smb2IoctlRequest.FSCTL_VALIDATE_NEGOTIATE_INFO);
        req.setFlags(Smb2IoctlRequest.SMB2_O_IOCTL_IS_FSCTL);
        req.setInputData(new ValidateNegotiateInfoRequest(negoReq.getCapabilities(), negoReq.getClientGuid(),
                (short) negoReq.getSecurityMode(), negoReq.getDialects()));

                new Smb2IoctlRequest(context.getConfig(), Smb2IoctlRequest.FSCTL_QUERY_NETWORK_INTERFACE_INFO, new byte[16] // Reserved/Unused file ID
                );
        request.setMaxOutputResponse(65536);
        request.setFlags(Smb2IoctlRequest.SMB2_O_IOCTL_IS_FSCTL);

        // Note: This IOCTL must be sent on an existing session
        // The actual sending would need integration with the session's transport

            this.andx.headerStart = this.headerStart;
            this.andx.setCommand(this.andxCommand);
            this.andx.setErrorCode(getErrorCode());
            this.andx.setFlags(getFlags());
            this.andx.setFlags2(getFlags2());
            this.andx.setTid(getTid());
            this.andx.setPid(getPid());
            this.andx.setUid(getUid());
            this.andx.setMid(getMid());

	}
	return exec.Command("adb", args...)
}

const (
	deviceRoot   = "/data/local/tmp/go_android_exec"
	deviceGoroot = deviceRoot + "/goroot"
)

func main() {
	log.SetFlags(0)
	log.SetPrefix("go_android_exec: ")
	exitCode, err := runMain()
	if err != nil {
		log.Fatal(err)
	}
	os.Exit(exitCode)
}

func runMain() (int, error) {

        
        // Send session setup with channel binding
        Smb2SessionSetupRequest request = new Smb2SessionSetupRequest();
        request.setSessionId(session.getSessionId());
        request.setFlags(SMB2_SESSION_FLAG_BINDING);
        request.setSecurityBuffer(bindingHash);
        
        Smb2SessionSetupResponse response = (Smb2SessionSetupResponse) 
            channel.getTransport().send(request);
        

                }
                // Tag
                org = scm.getTag();
                val = interpolate(org);
                if (org != val) {
                    scm.setTag(val);
                }
                // Url
                org = scm.getUrl();
                val = interpolate(org);
                if (org != val) {
                    scm.setUrl(val);

                request.setVersion(registration.getVersion().getValue());
                request.setShareName(shareName);
                request.setServerAddress(serverAddress.getHostAddress());
                request.setFlags(registration.getFlags());
                
                WitnessRegisterResponse response = rpcClient.register(request);
                
                if (response.isSuccess()) {

            }
        }

        if (mojo instanceof Mojo mojoInstance) {
            Logger mojoLogger = LoggerFactory.getLogger(mojoDescriptor.getImplementation());
            mojoInstance.setLog(new MojoLogWrapper(mojoLogger));
        }

        if (mojo instanceof Contextualizable) {
            pluginValidationManager.reportPluginMojoValidationIssue(