/* ** termXPR.c ** ** External transfer protocol support routines ** ** Copyright © 1990-1994 by Olaf `Olsen' Barthel ** All Rights Reserved */ #include "termGlobal.h" /*#define WriteRequest ReadRequest*/ /* These variables keep the transferred bytes and transfer * time in seconds. */ STATIC LONG ByteVal, ByteMax, TimeVal, TimeMax, LastTimeDif, LastPercent; /* Transfer statistics. */ STATIC ULONG CPS_Minimum, CPS_Maximum, CPS_Average, CPS_Current, CPS_Count, CPS_Last; LONG CPL_Min, CPL_Avg, CPL_Cur; /* The name of the file being transmitted, in case the * `override transfer path' feature is enabled. */ STATIC struct Buffer *CurrentFile; /* Yet another flag, this one determines whether we already told * the user that the file we are currently processing will fit * on the destination device. */ STATIC BYTE Alerted, CarrierMessage; STATIC UBYTE __far RealName[MAX_FILENAME_LENGTH]; STATIC ULONG LastSeconds; /* PrintBox(LONG Box,LONG Line,STRPTR String,...): * * Update the contents of a text box. */ STATIC VOID __stdargs PrintBox(LONG Box,LONG Line,STRPTR String,...) { UBYTE LocalBuffer[256]; va_list VarArgs; va_start(VarArgs,String); VSPrintf(LocalBuffer,String,VarArgs); va_end(VarArgs); LT_SetAttributes(TransferHandle,Box,LABX_Index,Line,LABX_Text,LocalBuffer,TAG_DONE); } /* OpenTransferWindow(): * * Local routine to open the transfer window. */ STATIC BYTE OpenTransferWindow(VOID) { /* Block window input. */ BlockWindows(); /* Try to open the transfer window panel. */ if(TransferPanel(LocaleString(MSG_TERMXPR_RECEIVE_FILES_TXT))) { /* Supply the log text. */ LogAction(LocaleString(MSG_TERMXPR_LOGMSG_INITIATE_BINARY_DOWNLOAD_TXT)); /* Return success. */ return(TRUE); } else { /* Re-enable window input. */ ReleaseWindows(); /* Return failure. */ return(FALSE); } } /* CheckAbort(BOOLEAN CheckCarrier): * * Check for transfer abort. */ STATIC LONG __regargs CheckAbort(BOOLEAN CheckCarrier) { struct IntuiMessage *Message; ULONG MsgClass, MsgQualifier; UWORD MsgCode; struct Gadget *MsgGadget; struct Window *MsgWindow; LONG Result = 0; /* No window available for output? */ if(!TransferWindow) { if(!OpenTransferWindow()) return(-1); } /* Are we to check the carrier status? */ if(CheckCarrier) { WriteRequest -> IOSer . io_Command = SDCMD_QUERY; DoIO(WriteRequest); /* Return error if carrier is lost. */ if(WriteRequest -> io_Status & CIAF_COMCD) { if(!CarrierMessage) { CarrierMessage = TRUE; AddTransferInfo(TRUE,LocaleString(MSG_TERMXPR_CARRIER_LOST_TXT)); } Online = FALSE; TransferError = TRUE; return(-1); } } /* Process all incoming messages. */ while(Message = (struct IntuiMessage *)GT_GetIMsg(TransferWindow -> UserPort)) { MsgClass = Message -> Class; MsgQualifier = Message -> Qualifier; MsgCode = Message -> Code; MsgGadget = (struct Gadget *)Message -> IAddress; MsgWindow = Message -> IDCMPWindow; GT_ReplyIMsg(Message); if(MsgWindow == TransferWindow) { LT_HandleInput(TransferHandle,MsgQualifier,&MsgClass,&MsgCode,&MsgGadget); if(!Result) { if(MsgClass == IDCMP_CLOSEWINDOW) { LogAction(LocaleString(MSG_TERMXPR_LOGMSG_TRANSFER_ABORTED_TXT)); TransferAborted = TRUE; Result = -1; } if(MsgClass == IDCMP_GADGETUP) { switch(MsgGadget -> GadgetID) { case GAD_TRANSFER_ABORT: LogAction(LocaleString(MSG_TERMXPR_LOGMSG_TRANSFER_ABORTED_TXT)); TransferAborted = TRUE; Result = -1; break; case GAD_TRANSFER_SKIP: LogAction(LocaleString(MSG_TERMXPR_LOGMSG_FILE_SKIPPED_TXT)); Result = 1; break; case GAD_TRANSFER_ABORT_FILE: LogAction(LocaleString(MSG_TERMXPR_LOGMSG_FILE_ABORTED_TXT)); Result = 2; break; } } } } else { if(TransferPerfWindow) { struct RastPort *RPort = TransferPerfWindow -> RPort; if(MsgClass == IDCMP_NEWSIZE) { SetAPen(RPort,0); RectFill(RPort,TransferPerfWindow -> BorderLeft,TransferPerfWindow -> BorderTop,TransferPerfWindow -> Width - (TransferPerfWindow -> BorderRight + 1),TransferPerfWindow -> Height - (TransferPerfWindow -> BorderBottom + 1)); CPL_Min = CPL_Avg = CPL_Cur = -1; } if(MsgClass == IDCMP_CLOSEWINDOW) { PutWindowInfo(WINDOW_PERF,TransferPerfWindow -> LeftEdge,TransferPerfWindow -> TopEdge,TransferPerfWindow -> Width,TransferPerfWindow -> Height); CloseWindowSafely(TransferPerfWindow); TransferPerfWindow = NULL; } } } } return(Result); } /* NewFileName(STRPTR Source,STRPTR Buffer): * * Build a valid file and path name, including path * substitution, etc. */ STATIC STRPTR __regargs NewFileName(STRPTR Source,STRPTR Buffer) { if(Config -> MiscConfig -> OverridePath && !Uploading) { if(DownloadPath) strcpy(Buffer,DownloadPath); else strcpy(Buffer,Config -> PathConfig -> BinaryDownloadPath); if(!Buffer[0]) { if(!GetCurrentDirName(Buffer,MAX_FILENAME_LENGTH)) Buffer[0] = 0; } if(Buffer[0]) { if(AddPart(Buffer,FilePart(Source),MAX_FILENAME_LENGTH)) return(Buffer); } } else { if(FilePart(Source) == Source) { if(GetCurrentDirName(Buffer,MAX_FILENAME_LENGTH)) { if(AddPart(Buffer,Source,MAX_FILENAME_LENGTH)) return(Buffer); } } } strcpy(Buffer,Source); return(Source); } /* IdentifySource(STRPTR Name,STRPTR BBSName,struct DateStamp *OpenDate): * * Attach source information (BBS name, date and time) to a file. */ STATIC VOID __regargs IdentifySource(STRPTR Name,STRPTR BBSName,struct DateStamp *OpenDate) { UBYTE LocalBuffer[MAX_FILENAME_LENGTH], Time[40], Date[40]; struct DateTime DateTime; CopyMem(OpenDate,&DateTime . dat_Stamp,sizeof(struct DateStamp)); /* Prepare for date conversion. */ DateTime . dat_Format = FORMAT_DOS; DateTime . dat_Flags = 0; DateTime . dat_StrDay = NULL; DateTime . dat_StrDate = Date; DateTime . dat_StrTime = Time; /* Convert the date. */ if(DateToStr(&DateTime)) { StripSpaces(BBSName); StripSpaces(Date); StripSpaces(Time); if(BBSName[0]) SPrintf(LocalBuffer,"%s %s %s",BBSName,Date,Time); else SPrintf(LocalBuffer,"%s %s",Date,Time); SetComment(Name,LocalBuffer); } } /* GetSeconds(STRPTR String): * * Tries to turn a string of the format hh:mm:ss into * an integer number. */ STATIC LONG __regargs GetSeconds(STRPTR String) { UBYTE Buffer[20]; LONG Seconds = 0; memset(Buffer,0,20); strcpy(Buffer,String); Seconds += Atol(&Buffer[6]); Buffer[5] = 0; Seconds += Atol(&Buffer[3]) * 60; Buffer[2] = 0; Seconds += Atol(&Buffer[0]) * 3600; return(Seconds); } /* TruncateName(STRPTR FileName): * * Truncates a file name to a maximum of 48 characters. */ STATIC STRPTR __regargs TruncateName(STRPTR FileName) { WORD Len = strlen(FileName); if(Len > 48) { WORD i; for(i = Len - 48 ; i < Len ; i++) { if(i >= Len - 44 && FileName[i] == '/') { STATIC UBYTE __far NameBuffer[MAX_FILENAME_LENGTH]; strcpy(NameBuffer,".../"); strcat(NameBuffer,&FileName[i + 1]); return(NameBuffer); } } } return(FileName); } /* CalculateBlocks(LONG Size,LONG BlockSize): * * Calculate the number of blocks a file will * occupy if saved to a disk. */ STATIC LONG __regargs CalculateBlocks(LONG Size,LONG BlockSize) { LONG Blocks = 1; /* One for the file header. */ BYTE HasExtension = FALSE, /* No extension block yet. */ Extension = 0; /* How many block pointers yet. */ /* Round to next block. */ Size = ((Size + BlockSize - 1) / BlockSize) * BlockSize; while(Size) { /* Add another block. */ Blocks++; /* Subtract another block. */ Size -= BlockSize; /* Add another block pointer, if 72 have been * added, add another extension block. */ if((Extension++) == 72) { /* If no extension block has been generated * yet, we were running on the block pointers * of the file header itself. */ if(!HasExtension) HasExtension = TRUE; else Blocks++; /* Reset extension block counter. */ Extension = 0; } } return(Blocks); } /* GetOptionMode(struct xpr_option *Option): * * Turn text into a boolean value. */ STATIC BYTE __regargs GetOptionMode(struct xpr_option *Option) { if(Option) { STATIC STRPTR TrueOptions[] = { "ON", "TRUE", "T", "YES", "Y", NULL }; register WORD i; for(i = 0 ; TrueOptions[i] ; i++) { if(!Stricmp(Option -> xpro_value,TrueOptions[i])) return(TRUE); } } return(FALSE); } /* SerialErrorReport(struct IOExtSer *Request): * * Report a certain I/O error cause. */ STATIC BYTE __regargs SerialErrorReport(struct IOExtSer *Request) { STRPTR ErrorMessage; BYTE IsFatal; switch(Request -> IOSer . io_Error) { case SerErr_LineErr: ErrorMessage = LocaleString(MSG_TERMXPR_ERROR_HARDWARE_DATA_OVERRUN_TXT); IsFatal = FALSE; break; case SerErr_ParityErr: ErrorMessage = LocaleString(MSG_TERMXPR_ERROR_PARITY_ERROR_TXT); IsFatal = TRUE; break; case SerErr_TimerErr: ErrorMessage = LocaleString(MSG_TERMXPR_ERROR_TIMER_ERROR_TXT); IsFatal = FALSE; break; case SerErr_BufOverflow: ErrorMessage = LocaleString(MSG_TERMXPR_ERROR_READ_BUFFER_OVERFLOWED_TXT); IsFatal = FALSE; break; case SerErr_NoDSR: ErrorMessage = LocaleString(MSG_TERMXPR_ERROR_NO_DSR_TXT); IsFatal = TRUE; break; case SerErr_DetectedBreak: ErrorMessage = LocaleString(MSG_TERMXPR_ERROR_BREAK_DETECTED_TXT); IsFatal = TRUE; break; default: ErrorMessage = LocaleString(MSG_TERMXPR_ERROR_UNKNOWN_CAUSE_TXT); IsFatal = FALSE; break; } AddTransferInfo(TRUE,LocaleString(MSG_TERMXPR_ERROR_TEMPLATE_TXT),Request -> IOSer . io_Error,ErrorMessage); if(IsFatal) { TransferError = TRUE; return(TRUE); } else return(FALSE); } /* xpr_fopen(STRPTR FileName,STRPTR AccessMode): * * Open a file for random access. */ LONG __saveds __asm xpr_fopen(register __a0 STRPTR FileName,register __a1 STRPTR AccessMode) { UBYTE RealName[MAX_FILENAME_LENGTH]; struct Buffer *File; Alerted = CarrierMessage = FALSE; /* Reset transfer counters. */ ByteVal = ByteMax = TimeVal = TimeMax = LastTimeDif = 0; LastPercent = -1; /* Reset CPS statistics. */ CPS_Minimum = (ULONG)~0; CPS_Maximum = 0; CPS_Average = 0; CPS_Current = 0; CPS_Count = 0; CPS_Last = 0; /* No window available for output? */ if(!TransferWindow) OpenTransferWindow(); if(OriginalName[0]) { if(!Stricmp(ShrunkenName,FileName)) FileName = OriginalName; } /* Determine the file name. */ FileName = NewFileName(FileName,RealName); /* Determine file transfer mode... */ if(File = BufferOpen(FileName,AccessMode)) { switch(AccessMode[0]) { case 'r': LogAction(LocaleString(MSG_TERMXPR_LOGMSG_SEND_FILE_TXT),FileName); break; case 'w': LogAction(LocaleString(MSG_TERMXPR_LOGMSG_RECEIVE_FILE_TXT),FileName); break; case 'a': LogAction(LocaleString(MSG_TERMXPR_LOGMSG_UPDATE_FILE_TXT),FileName); break; } CurrentFile = File; } DidTransfer = TRUE; return((LONG)File); } /* xpr_fclose(struct Buffer *File): * * Close a file opened by xpr_fopen. */ LONG __saveds __asm xpr_fclose(register __a0 struct Buffer *File) { UBYTE RealName[MAX_FILENAME_LENGTH]; struct DateStamp OpenDate; BYTE WriteAccess, Used; /* Save some information. */ OpenDate = File -> OpenDate; WriteAccess = File -> WriteAccess; Used = File -> Used; /* Get the name of the file. */ if(!NameFromFH(File -> FileHandle,RealName,MAX_FILENAME_LENGTH)) RealName[0] = 0; /* Close the file and see what it brings... */ if(BufferClose(File) && RealName[0]) { /* Did any access take place at all? * xprzmodem.library for example just * opens and closes a file in order to * see if it exists. */ if(!Used) LogAction(LocaleString(MSG_TERMXPR_CLOSE_FILE_TXT),RealName); else { /* Did we receive or send a file? */ if(WriteAccess) { LONG Size; /* Did the file remain empty? */ if(!(Size = GetFileSize(RealName))) { AddTransferInfo(TRUE,LocaleString(MSG_TERMXPR_FILE_REMOVED_TXT),FilePart(RealName)); /* Delete empty file. */ if(DeleteFile(RealName)) LogAction(LocaleString(MSG_TERMXPR_CLOSE_FILE_REMOVED_TXT),RealName); else LogAction(LocaleString(MSG_TERMXPR_CLOSE_FILE_TXT),RealName); } else { struct Node *SomeNode; if(ByteMax) { if(Size >= ByteMax) AddTransferInfo(FALSE,LocaleString(MSG_TERMXPR_FILE_RECEIVED_TXT),FilePart(RealName)); else AddTransferInfo(TRUE,LocaleString(MSG_TERMXPR_INCOMPLETE_FILE_RECEIVED_TXT),FilePart(RealName)); } /* Try to identify the file type. */ switch(Config -> MiscConfig -> IdentifyFiles) { case IDENTIFY_IGNORE: if(Config -> MiscConfig -> CreateIcons) Identify(RealName,FALSE); break; case IDENTIFY_FILETYPE: Identify(RealName,TRUE); break; case IDENTIFY_SOURCE: IdentifySource(RealName,CurrentBBSName,&OpenDate); if(Config -> MiscConfig -> CreateIcons) Identify(RealName,FALSE); break; } if(CPS_Minimum == (ULONG)~0) CPS_Minimum = 0; if(CPS_Count == 0) { CPS_Average = 0; CPS_Count = 1; } LogAction(LocaleString(MSG_TERMXPR_CLOSE_FILE_BYTES_TXT),RealName,Size,CPS_Minimum,CPS_Average / CPS_Count,CPS_Maximum); if(SomeNode = CreateGenericListNode(0,RealName)) AddGenericListNode(GenericListTable[GLIST_DOWNLOAD],SomeNode,ADD_GLIST_BOTTOM); } } else { /* Set the archived bit on files we uploaded? */ if(Config -> MiscConfig -> SetArchivedBit) { struct FileInfoBlock *FileInfo; if(FileInfo = (struct FileInfoBlock *)AllocDosObject(DOS_FIB,TAG_DONE)) { BPTR FileLock; /* Get a lock on it. */ if(FileLock = Lock(RealName,ACCESS_READ)) { /* Examine the file. */ if(Examine(FileLock,FileInfo)) { /* Remove the lock. */ UnLock(FileLock); /* Set the `archived' bit. */ SetProtection(RealName,FileInfo -> fib_Protection | FIBF_ARCHIVE); } else UnLock(FileLock); } FreeDosObject(DOS_FIB,FileInfo); } } AddTransferInfo(FALSE,LocaleString(MSG_TERMXPR_FILE_SENT_TXT),FilePart(RealName)); LogAction(LocaleString(MSG_TERMXPR_CLOSE_FILE_TXT),RealName); RemoveUploadListItem(RealName); } } } CurrentFile = NULL; return(1); } /* xpr_fread(APTR Buffer,LONG Size,LONG Count,struct Buffer *File): * * Read a few bytes from a file. */ LONG __saveds __asm xpr_fread(register __a0 APTR Buffer,register __d0 LONG Size,register __d1 LONG Count,register __a1 struct Buffer *File) { return(BufferRead(File,Buffer,Size * Count) / Size); } /* xpr_fwrite(APTR Buffer,LONG Size,LONG Count,struct Buffer *File): * * Write a few bytes to a file. */ LONG __saveds __asm xpr_fwrite(register __a0 APTR Buffer,register __d0 LONG Size,register __d1 LONG Count,register __a1 struct Buffer *File) { return(BufferWrite(File,Buffer,Size * Count) / Size); } /* xpr_fseek(struct Buffer *File,LONG Offset,LONG Origin): * * Move the read/write pointer in a file. */ LONG __saveds __asm xpr_fseek(register __a0 struct Buffer *File,register __d0 LONG Offset,register __d1 LONG Origin) { return(BufferSeek(File,Offset,Origin) ? 0 : -1); } /* xpr_sread(APTR Buffer,LONG Size,LONG Timeout): * * Read a few bytes from the serial port (including * timeouts). */ LONG __saveds __asm xpr_sread(register __a0 APTR Buffer,register __d0 LONG Size,register __d1 ULONG Timeout) { /* No window available for output? */ if(!TransferWindow) { if(!OpenTransferWindow()) return(-1); } /* Are both IORequests available? */ if(WriteRequest && ReadRequest) { /* Valid size parameter? */ if(Size > 0) { /* How many bytes are still in the serial buffer? */ WriteRequest -> IOSer . io_Command = SDCMD_QUERY; DoIO(WriteRequest); /* Return error if carrier is lost. */ if(Config -> SerialConfig -> CheckCarrier) { if(WriteRequest -> io_Status & CIAF_COMCD) { if(!CarrierMessage) { CarrierMessage = TRUE; AddTransferInfo(TRUE,LocaleString(MSG_TERMXPR_CARRIER_LOST_TXT)); } Online = FALSE; TransferError = TRUE; return(-1); } } /* ALWAYS */ { register ULONG Waiting; if(Waiting = WriteRequest -> IOSer . io_Actual) { /* No timeout specified? Read as many * bytes as available. */ if(!Timeout) { if(Waiting > Size) Waiting = Size; ReadRequest -> IOSer . io_Command = CMD_READ; ReadRequest -> IOSer . io_Data = Buffer; ReadRequest -> IOSer . io_Length = Waiting; if(DoIO(ReadRequest)) { if(SerialErrorReport(ReadRequest)) return(-1); else Waiting = ReadRequest -> IOSer . io_Actual; } BytesIn += Waiting; return((LONG)Waiting); } /* Enough data pending to be read? */ if(Waiting >= Size) { ReadRequest -> IOSer . io_Command = CMD_READ; ReadRequest -> IOSer . io_Data = Buffer; ReadRequest -> IOSer . io_Length = Size; if(DoIO(ReadRequest)) { if(SerialErrorReport(ReadRequest)) return(-1); else Size = ReadRequest -> IOSer . io_Actual; } BytesIn += Size; return(Size); } } else { /* No timeout & no bytes available: * return immediately. */ if(!Timeout) return(0); } } /* ALWAYS */ { register ULONG SignalSet, SerialMask = PORTMASK(ReadPort), WindowMask = PORTMASK(TransferWindow -> UserPort); /* Set up the timer. */ TimeRequest -> tr_node . io_Command = TR_ADDREQUEST; TimeRequest -> tr_time . tv_secs = Timeout / MILLION; TimeRequest -> tr_time . tv_micro = Timeout % MILLION; /* Set up the read request. */ ReadRequest -> IOSer . io_Command = CMD_READ; ReadRequest -> IOSer . io_Data = Buffer; ReadRequest -> IOSer . io_Length = Size; /* Prevent early termination. */ ClrSignal(SerialMask | SIG_TIMER); /* Start IO... */ SendIO(ReadRequest); SendIO(TimeRequest); FOREVER { SignalSet = Wait(SerialMask | SIG_TIMER | WindowMask); /* Abort file transfer? */ if(SignalSet & WindowMask) { if(CheckAbort(FALSE) == -1) { if(!CheckIO(ReadRequest)) AbortIO(ReadRequest); if(!CheckIO(TimeRequest)) AbortIO(TimeRequest); WaitIO(ReadRequest); WaitIO(TimeRequest); SendAbort = TRUE; return(-1); } } /* Receive buffer filled? */ if(SignalSet & SerialMask) { /* Abort the timer request. */ if(!CheckIO(TimeRequest)) AbortIO(TimeRequest); WaitIO(TimeRequest); /* Did the request terminate gracefully? */ if(WaitIO(ReadRequest)) { if(SerialErrorReport(ReadRequest)) return(-1); else Size = ReadRequest -> IOSer . io_Actual; } BytesIn += Size; return(Size); } /* Hit by timeout? */ if(SignalSet & SIG_TIMER) { /* Abort the read request. */ if(!CheckIO(ReadRequest)) AbortIO(ReadRequest); WaitIO(ReadRequest); /* Remove the timer request. */ WaitIO(TimeRequest); /* Did the driver receive any * data? */ if(ReadRequest -> IOSer . io_Actual) { BytesIn += ReadRequest -> IOSer . io_Actual; return((LONG)ReadRequest -> IOSer . io_Actual); } else { /* Take a second look and query the number of * bytes ready to be received, there may * still be some bytes in the buffer. * Note: this depends on the way the * driver handles read abort. */ WriteRequest -> IOSer . io_Command = SDCMD_QUERY; DoIO(WriteRequest); /* Don't read too much. */ if(Size > WriteRequest -> IOSer . io_Actual) Size = WriteRequest -> IOSer . io_Actual; /* Are there any bytes to be transferred? */ if(Size) { /* Read the data. */ ReadRequest -> IOSer . io_Command = CMD_READ; ReadRequest -> IOSer . io_Data = Buffer; ReadRequest -> IOSer . io_Length = Size; /* Read the data. */ if(DoIO(ReadRequest)) { if(SerialErrorReport(ReadRequest)) return(-1); else Size = ReadRequest -> IOSer . io_Actual; } BytesIn += Size; } return(Size); } } } } } else return(0); } else return(-1); } /* xpr_swrite(APTR Buffer,LONG Size): * * Write a few bytes to the serial port. */ LONG __saveds __asm xpr_swrite(register __a0 APTR Buffer,register __d0 LONG Size) { if(WriteRequest) { /* Return error if carrier is lost. */ if(Config -> SerialConfig -> CheckCarrier) { /* Query the serial status bits. */ WriteRequest -> IOSer . io_Command = SDCMD_QUERY; DoIO(WriteRequest); /* Is the carrier signal still present? */ if(WriteRequest -> io_Status & CIAF_COMCD) { if(!CarrierMessage) { CarrierMessage = TRUE; AddTransferInfo(TRUE,LocaleString(MSG_TERMXPR_CARRIER_LOST_TXT)); } Online = FALSE; TransferError = TRUE; return(-1); } } /* Send the data. */ WriteRequest -> IOSer . io_Command = CMD_WRITE; WriteRequest -> IOSer . io_Data = Buffer; WriteRequest -> IOSer . io_Length = Size; if(DoIO(WriteRequest)) { if(SerialErrorReport(WriteRequest)) return(-1); } else BytesOut += Size; return(0); } else return(-1); } /* xpr_sflush(): * * Release the contents of all serial buffers. */ LONG __saveds __asm xpr_sflush() { if(WriteRequest) { WriteRequest -> IOSer . io_Command = CMD_CLEAR; if(DoIO(WriteRequest)) { if(SerialErrorReport(WriteRequest)) return(-1); } return(0); } else return(-1); } /* xpr_update(struct XPR_UPDATE *UpdateInfo): * * Update the information displayed in the transfer window. */ LONG __saveds __asm xpr_update(register __a0 struct XPR_UPDATE *UpdateInfo) { /* No window available for output? */ if(!TransferWindow) { if(!OpenTransferWindow()) return(0); } if(UpdateInfo) { BYTE NewByte = FALSE, NewTime = FALSE; if(TransferWindow -> Flags & WFLG_ZOOMED) { BOOLEAN Refresh; if(!TransferZoomed) { ULONG Micros; CurrentTime(&LastSeconds,&Micros); Refresh = TRUE; TransferZoomed = TRUE; } else { ULONG Seconds,Micros; CurrentTime(&Seconds,&Micros); if(Seconds > LastSeconds) { LastSeconds = Seconds; Refresh = TRUE; } } if(Refresh) { if(LastPercent > 0) SPrintf(TransferTitleBuffer,"%s [%s %ld%%]",TransferWindowTitle,TruncateName(RealName),LastPercent); else SPrintf(TransferTitleBuffer,"%s [%s]",TransferWindowTitle,TruncateName(RealName)); SetWindowTitles(TransferWindow,TransferTitleBuffer,(STRPTR)-1); } } else { if(TransferZoomed) { SetWindowTitles(TransferWindow,TransferWindowTitle,(STRPTR)-1); TransferZoomed = FALSE; } } if((UpdateInfo -> xpru_updatemask & XPRU_PROTOCOL) && UpdateInfo -> xpru_protocol) LT_SetAttributes(TransferHandle,GAD_TRANSFER_PROTOCOL,GTTX_Text,UpdateInfo -> xpru_protocol,TAG_DONE); if((UpdateInfo -> xpru_updatemask & XPRU_MSG) && UpdateInfo -> xpru_msg) AddTransferInfo(FALSE,UpdateInfo -> xpru_msg); if((UpdateInfo -> xpru_updatemask & XPRU_ERRORMSG) && UpdateInfo -> xpru_errormsg) AddTransferInfo(TRUE,UpdateInfo -> xpru_errormsg); if((UpdateInfo -> xpru_updatemask & XPRU_FILENAME) && UpdateInfo -> xpru_filename) { STRPTR FileName = UpdateInfo -> xpru_filename; if(OriginalName[0]) { if(!Stricmp(ShrunkenName,FileName)) FileName = OriginalName; } FileName = NewFileName(FileName,RealName); LT_SetAttributes(TransferHandle,GAD_TRANSFER_FILE,LABX_Index,0,LABX_Text,TruncateName(FileName),TAG_DONE); if(FileTransferInfo) { if(FileTransferInfo -> CurrentFile) { struct FileTransferNode *Node = (struct FileTransferNode *)FileTransferInfo -> CurrentFile -> Node . mln_Succ; if(Node -> Node . mln_Succ) LT_SetAttributes(TransferHandle,GAD_TRANSFER_FILE,LABX_Index,1,LABX_Text,TruncateName(Node -> Name),TAG_DONE); else LT_SetAttributes(TransferHandle,GAD_TRANSFER_FILE,LABX_Index,1,LABX_Text,LocaleString(MSG_GLOBAL_NONE_TXT),TAG_DONE); } PrintBox(GAD_TRANSFER_SIZE,2,ConvNumber,FileTransferInfo -> TotalSize); if(FileTransferInfo -> TotalFiles) PrintBox(GAD_TRANSFER_SIZE,4,LocaleString(MSG_TRANSFERPANEL_NUMBER_TO_GO_PERCENT_TXT),FileTransferInfo -> DoneFiles,FileTransferInfo -> TotalFiles,(100 * FileTransferInfo -> DoneFiles) / FileTransferInfo -> TotalFiles); else PrintBox(GAD_TRANSFER_SIZE,4,LocaleString(MSG_TRANSFERPANEL_NUMBER_TO_GO_PERCENT_TXT),FileTransferInfo -> DoneFiles,FileTransferInfo -> TotalFiles,0); } } if((UpdateInfo -> xpru_updatemask & XPRU_FILESIZE) && UpdateInfo -> xpru_filesize != -1) { if(CurrentFile) { if(CurrentFile -> DirLock) PrintBox(GAD_TRANSFER_SIZE,0,ConvNumber10,UpdateInfo -> xpru_filesize); else PrintBox(GAD_TRANSFER_SIZE,0,ConvNumber,UpdateInfo -> xpru_filesize); } else PrintBox(GAD_TRANSFER_SIZE,0,ConvNumber,UpdateInfo -> xpru_filesize); if(ByteMax = UpdateInfo -> xpru_filesize) NewByte = TRUE; } if((UpdateInfo -> xpru_updatemask & XPRU_BYTES) && UpdateInfo -> xpru_bytes != -1) { if(CurrentFile) { if(CurrentFile -> DirLock) PrintBox(GAD_TRANSFER_SIZE,1,ConvNumber10,ByteVal = UpdateInfo -> xpru_bytes); else PrintBox(GAD_TRANSFER_SIZE,1,ConvNumber,ByteVal = UpdateInfo -> xpru_bytes); } else PrintBox(GAD_TRANSFER_SIZE,1,ConvNumber,ByteVal = UpdateInfo -> xpru_bytes); if(FileTransferInfo) { ULONG Len = FileTransferInfo -> DoneSize + UpdateInfo -> xpru_bytes; if(FileTransferInfo -> TotalSize) PrintBox(GAD_TRANSFER_SIZE,3,LocaleString(MSG_TRANSFERPANEL_NUMBER_PERCENT_TXT),Len,(100 * Len) / FileTransferInfo -> TotalSize); else PrintBox(GAD_TRANSFER_SIZE,3,LocaleString(MSG_TRANSFERPANEL_NUMBER_PERCENT_TXT),Len,0); } if(ByteMax) NewByte = TRUE; if(CurrentFile) { if(CurrentFile -> DirLock && !Uploading) { if(CurrentFile -> InfoData . id_NumBlocks && CurrentFile -> InfoData . id_BytesPerBlock) { if(ByteMax) { register LONG Space = CurrentFile -> InfoData . id_NumBlocks - CurrentFile -> InfoData . id_NumBlocksUsed; if(Space >= 0) { register LONG Blocks = CalculateBlocks(ByteMax,CurrentFile -> InfoData . id_BytesPerBlock); if(Space < Blocks) { if(!Alerted) { Alerted = TRUE; Say(LocaleString(MSG_TERMXPR_SAY_FILE_MAY_NOT_FIT_TXT)); } PrintBox(GAD_TRANSFER_FILE,2,LocaleString(MSG_TERMXPR_BYTES_FULL_TXT),Space * CurrentFile -> InfoData . id_BytesPerBlock,100 * (CurrentFile -> InfoData . id_NumBlocksUsed) / CurrentFile -> InfoData . id_NumBlocks,LocaleString(MSG_TERMXPR_FILE_MAY_NOT_FIT_TXT)); } else PrintBox(GAD_TRANSFER_FILE,2,LocaleString(MSG_TERMXPR_BYTES_FULL_TXT),Space * CurrentFile -> InfoData . id_BytesPerBlock,100 * (CurrentFile -> InfoData . id_NumBlocksUsed) / CurrentFile -> InfoData . id_NumBlocks,""); } else PrintBox(GAD_TRANSFER_FILE,2,LocaleString(MSG_TERMXPR_BYTES_FULL_TXT),(CurrentFile -> InfoData . id_NumBlocks - CurrentFile -> InfoData . id_NumBlocksUsed) * CurrentFile -> InfoData . id_BytesPerBlock,100 * (CurrentFile -> InfoData . id_NumBlocksUsed) / CurrentFile -> InfoData . id_NumBlocks); } else PrintBox(GAD_TRANSFER_FILE,2,LocaleString(MSG_TERMXPR_BYTES_FULL_TXT),(CurrentFile -> InfoData . id_NumBlocks - CurrentFile -> InfoData . id_NumBlocksUsed) * CurrentFile -> InfoData . id_BytesPerBlock,100 * (CurrentFile -> InfoData . id_NumBlocksUsed) / CurrentFile -> InfoData . id_NumBlocks); } } } } if((UpdateInfo -> xpru_updatemask & XPRU_BLOCKS) && UpdateInfo -> xpru_blocks != -1) PrintBox(GAD_TRANSFER_SIZE,5,ConvNumber,UpdateInfo -> xpru_blocks); if((UpdateInfo -> xpru_updatemask & XPRU_DATARATE) && UpdateInfo -> xpru_datarate > 0) { register LONG Change; CPS_Current = UpdateInfo -> xpru_datarate; if(CPS_Last) { if(CPS_Last < UpdateInfo -> xpru_datarate) Change = (100 * (UpdateInfo -> xpru_datarate - CPS_Last)) / CPS_Last; else Change = (100 * (CPS_Last - UpdateInfo -> xpru_datarate)) / CPS_Last; } else Change = 100; if(Change > 1) { PrintBox(GAD_TRANSFER_SECONDS,0,ConvNumber,UpdateInfo -> xpru_datarate); CPS_Last = UpdateInfo -> xpru_datarate; } if(UpdateInfo -> xpru_datarate < CPS_Minimum) CPS_Minimum = UpdateInfo -> xpru_datarate; if(UpdateInfo -> xpru_datarate > CPS_Maximum) CPS_Maximum = UpdateInfo -> xpru_datarate; if((ULONG)(CPS_Average + UpdateInfo -> xpru_datarate) >= CPS_Average) { CPS_Average += UpdateInfo -> xpru_datarate; CPS_Count++; } } if((UpdateInfo -> xpru_updatemask & XPRU_CHARDELAY) && UpdateInfo -> xpru_chardelay != -1) PrintBox(GAD_TRANSFER_SECONDS,1,ConvNumber,UpdateInfo -> xpru_chardelay); if((UpdateInfo -> xpru_updatemask & XPRU_PACKETDELAY) && UpdateInfo -> xpru_packetdelay != -1) PrintBox(GAD_TRANSFER_SECONDS,2,ConvNumber,UpdateInfo -> xpru_packetdelay); if((UpdateInfo -> xpru_updatemask & XPRU_PACKETTYPE) && UpdateInfo -> xpru_packettype != -1) { if(UpdateInfo -> xpru_packettype > 32 && UpdateInfo -> xpru_packettype < 256) { if(IsPrintable[UpdateInfo -> xpru_packettype]) PrintBox(GAD_TRANSFER_SECONDS,3,"`%lc'",UpdateInfo -> xpru_packettype); else PrintBox(GAD_TRANSFER_SECONDS,3,ConvNumber,UpdateInfo -> xpru_packettype); } else PrintBox(GAD_TRANSFER_SECONDS,3,ConvNumber,UpdateInfo -> xpru_packettype); } if((UpdateInfo -> xpru_updatemask & XPRU_BLOCKCHECK) && UpdateInfo -> xpru_blockcheck) PrintBox(GAD_TRANSFER_SECONDS,4,UpdateInfo -> xpru_blockcheck); if((UpdateInfo -> xpru_updatemask & XPRU_BLOCKSIZE) && UpdateInfo -> xpru_blocksize != -1) PrintBox(GAD_TRANSFER_SECONDS,5,ConvNumber,UpdateInfo -> xpru_blocksize); if((UpdateInfo -> xpru_updatemask & XPRU_EXPECTTIME) && UpdateInfo -> xpru_expecttime) { PrintBox(GAD_TRANSFER_TOTALTIME,0,UpdateInfo -> xpru_expecttime); if(TimeMax = GetSeconds((STRPTR)UpdateInfo -> xpru_expecttime)) NewTime = TRUE; } if((UpdateInfo -> xpru_updatemask & XPRU_ELAPSEDTIME) && UpdateInfo -> xpru_elapsedtime) { PrintBox(GAD_TRANSFER_TOTALTIME,1,UpdateInfo -> xpru_elapsedtime); TimeVal = GetSeconds((STRPTR)UpdateInfo -> xpru_elapsedtime); if(TimeMax) NewTime = TRUE; } if((UpdateInfo -> xpru_updatemask & XPRU_ERRORS) && UpdateInfo -> xpru_errors != -1) PrintBox(GAD_TRANSFER_ERRORS,0,ConvNumber,UpdateInfo -> xpru_errors); if((UpdateInfo -> xpru_updatemask & XPRU_TIMEOUTS) && UpdateInfo -> xpru_timeouts != -1) PrintBox(GAD_TRANSFER_ERRORS,1,ConvNumber,UpdateInfo -> xpru_timeouts); if(NewByte) { LONG Percent; if(ByteMax) Percent = (100 * ByteVal) / ByteMax; else Percent = 0; if(Percent != LastPercent) { UBYTE LocalBuffer[10]; SPrintf(LocalBuffer,"%ld%%",Percent); LastPercent = Percent; LT_SetAttributes(TransferHandle,GAD_TRANSFER_PERCENT, LAGA_Percent, Percent, LAGA_InfoText, LocalBuffer, TAG_DONE); } } if(NewTime) { register LONG TimeDif,Change; if(TimeVal > TimeMax) TimeDif = 0; else TimeDif = TimeMax - TimeVal; if(LastTimeDif) { if(LastTimeDif < TimeDif) Change = (100 * (TimeDif - LastTimeDif)) / LastTimeDif; else Change = (100 * (LastTimeDif - TimeDif)) / LastTimeDif; } else Change = 100; /* Don't update the display unless the change * exceeds 2% of the previous value. */ if(Change > 2) { UBYTE LocalBuffer[10]; LONG Percent; LastTimeDif = TimeDif; if(TimeMax) Percent = (100 * TimeDif) / TimeMax; else Percent = 0; SPrintf(LocalBuffer,"%2ld:%02ld:%02ld",TimeDif / 3600,(TimeDif / 60) % 60,TimeDif % 60); LT_SetAttributes(TransferHandle,GAD_TRANSFER_TIME, LAGA_Percent, Percent, LAGA_InfoText, LocalBuffer, TAG_DONE); /* A rapidly changing transfer time display would * cause the transfer completion time display to * change at the same pace. As the completion time * display calculation is rather costly, a change smaller * than 5% of the previous value is silently ignored. */ if(Change > 5) { UBYTE DateTimeBuffer[256]; struct DateStamp Stamp; /* Obtain current time. */ DateStamp(&Stamp); /* Add the time to go. */ Stamp . ds_Tick += (TimeDif % 60) * TICKS_PER_SECOND; Stamp . ds_Minute += TimeDif / 60 + Stamp . ds_Tick / (60 * TICKS_PER_SECOND); Stamp . ds_Days += Stamp . ds_Minute / 1440; Stamp . ds_Tick %= 60 * TICKS_PER_SECOND; Stamp . ds_Minute %= 1440; /* Conversion succeeded? */ if(FormatStamp(&Stamp,NULL,NULL,DateTimeBuffer,TRUE)) PrintBox(GAD_TRANSFER_FILE,3,DateTimeBuffer); } } } } if(TransferPerfWindow) { struct RastPort *RPort = TransferPerfWindow -> RPort; LONG Height,Left,Top,Min,Avg,Cur; Left = TransferPerfWindow -> Width - (TransferPerfWindow -> BorderRight + 1); Height = TransferPerfWindow -> Height - (TransferPerfWindow -> BorderTop + TransferPerfWindow -> BorderBottom + 1); Top = TransferPerfWindow -> BorderTop + Height; if(CPS_Maximum && CPS_Maximum != ~0) { Min = (Height * CPS_Minimum) / CPS_Maximum; Cur = (Height * CPS_Current) / CPS_Maximum; if(CPS_Count) Avg = ((CPS_Average / CPS_Count) * Height) / CPS_Maximum; else Avg = 0; } else Min = Avg = Cur = 0; if(CPL_Min == -1) CPL_Min = Min; if(CPL_Avg == -1) CPL_Avg = Avg; if(CPL_Cur == -1) CPL_Cur = Cur; ScrollRaster(RPort,1,0,TransferPerfWindow -> BorderLeft,TransferPerfWindow -> BorderTop,TransferPerfWindow -> Width - (TransferPerfWindow -> BorderRight + 1),TransferPerfWindow -> Height - (TransferPerfWindow -> BorderBottom + 1)); if(CPL_Cur != -1 && Cur != -1) { SetAPen(RPort,DrawInfo -> dri_Pens[SHADOWPEN]); Move(RPort,Left,Top - CPL_Cur); Draw(RPort,Left,Top - Cur); } if(CPL_Min != -1 && Min != -1) { SetAPen(RPort,DrawInfo -> dri_Pens[HIGHLIGHTTEXTPEN]); Move(RPort,Left,Top - CPL_Min); Draw(RPort,Left,Top - Min); } if(CPL_Avg != -1 && Avg != -1) { SetAPen(RPort,DrawInfo -> dri_Pens[FILLPEN]); Move(RPort,Left,Top - CPL_Avg); Draw(RPort,Left,Top - Avg); } CPL_Min = Min; CPL_Avg = Avg; CPL_Cur = Cur; } return(1); } /* xpr_chkabort(): * * Check if the user has aborted the transfer. */ LONG __saveds __asm xpr_chkabort() { LONG Result; Result = CheckAbort(Config -> SerialConfig -> CheckCarrier); return(Result); } /* xpr_gets(STRPTR Prompt,STRPTR Buffer): * * Prompt the user for string input. */ LONG __saveds __asm xpr_gets(register __a0 STRPTR Prompt,register __a1 STRPTR Buffer) { enum { GAD_OK=1,GAD_CANCEL,GAD_STRING }; struct LayoutHandle *Handle; LONG Success = FALSE; UBYTE LocalBuffer[256]; if(strlen(Buffer) > 255) { CopyMem(Buffer,LocalBuffer,255); LocalBuffer[255] = 0; } else strcpy(LocalBuffer,Buffer); if(!Prompt) Prompt = LocaleString(MSG_TERMXPR_INPUT_REQUIRED_TXT); if(Handle = LT_CreateHandleTags(Window -> WScreen, LH_LocaleHook, &LocaleHook, TAG_DONE)) { struct Window *Window; LT_New(Handle, LA_Type, VERTICAL_KIND, TAG_DONE); { LT_New(Handle, LA_Type, VERTICAL_KIND, LA_LabelText, Prompt, TAG_DONE); { LT_New(Handle, LA_Type, STRING_KIND, LA_STRPTR, LocalBuffer, LA_ID, GAD_STRING, LA_Chars, 60, TAG_DONE); LT_EndGroup(Handle); } LT_New(Handle, LA_Type,VERTICAL_KIND, TAG_DONE); { LT_New(Handle, LA_Type, XBAR_KIND, LAXB_FullSize, TRUE, TAG_DONE); LT_EndGroup(Handle); } LT_New(Handle,LA_Type,HORIZONTAL_KIND, LAGR_SameSize, TRUE, LAGR_Spread, TRUE, TAG_DONE); { LT_New(Handle, LA_Type, BUTTON_KIND, LA_LabelID, MSG_TERMXPR_OKAY_GAD, LA_ID, GAD_OK, LABT_ReturnKey, TRUE, LABT_ExtraFat, TRUE, TAG_DONE); LT_New(Handle, LA_Type, BUTTON_KIND, LA_LabelID, MSG_GLOBAL_CANCEL_GAD, LA_ID, GAD_CANCEL, LABT_EscKey, TRUE, LABT_ExtraFat, TRUE, TAG_DONE); LT_EndGroup(Handle); } } if(Window = LT_Layout(Handle,LocaleString(MSG_GLOBAL_ENTER_TEXT_TXT),NULL,0,0,IDCMP_CLOSEWINDOW,0, LAWN_HelpHook, &GuideHook, WA_DepthGadget, TRUE, WA_CloseGadget, TRUE, WA_DragBar, TRUE, WA_RMBTrap, TRUE, WA_Activate, TRUE, TAG_DONE)) { struct IntuiMessage *Message; BOOLEAN Done = FALSE; ULONG MsgClass, MsgQualifier; UWORD MsgCode; struct Gadget *MsgGadget; PushWindow(Window); LT_ShowWindow(Handle,TRUE); LT_Activate(Handle,GAD_STRING); do { if(Wait(PORTMASK(Window -> UserPort) | SIG_BREAK) & SIG_BREAK) break; while(Message = (struct IntuiMessage *)GT_GetIMsg(Window -> UserPort)) { MsgClass = Message -> Class; MsgQualifier = Message -> Qualifier; MsgCode = Message -> Code; MsgGadget = (struct Gadget *)Message -> IAddress; GT_ReplyIMsg(Message); LT_HandleInput(Handle,MsgQualifier,&MsgClass,&MsgCode,&MsgGadget); if(MsgClass == IDCMP_CLOSEWINDOW) Done = TRUE; if(MsgClass == IDCMP_GADGETUP) { switch(MsgGadget -> GadgetID) { case GAD_STRING: if(MsgCode == '\r') { if(strcmp(Buffer,LocalBuffer)) NewOptions = TRUE; strcpy(Buffer,LocalBuffer); Success = Done = TRUE; LT_PressButton(Handle,GAD_OK); } break; case GAD_OK: if(strcmp(Buffer,LocalBuffer)) NewOptions = TRUE; strcpy(Buffer,LocalBuffer); Success = Done = TRUE; break; case GAD_CANCEL: Done = TRUE; break; } } } } while(!Done); PopWindow(); } LT_DeleteHandle(Handle); } return(Success); } /* xpr_setserial(LONG Status): * * Set/read the serial status (parameters). */ LONG __saveds __asm xpr_setserial(register __d0 LONG Status) { if(WriteRequest) { STATIC LONG XprBauds[12] = { 110, 300, 1200, 2400, 4800, 9600, 19200, 31250, 38400, 57600, 76800, 115200 }; LONG Return,i; WriteRequest -> IOSer . io_Command = SDCMD_QUERY; DoIO(WriteRequest); Return = WriteRequest -> io_SerFlags & 0xFF; if(WriteRequest -> io_ExtFlags & SEXTF_MSPON) Return |= ST_PARTYMARKON; if(WriteRequest -> io_ExtFlags & SEXTF_MARK) Return |= ST_PARTYMARK; if(WriteRequest -> io_StopBits == 2) Return |= ST_2BITS; if(WriteRequest -> io_ReadLen == 7) Return |= ST_READ7; if(WriteRequest -> io_WriteLen == 7) Return |= ST_WRITE7; for(i = 0 ; i < 12 ; i++) { if(XprBauds[i] >= WriteRequest -> io_Baud) { Return |= (i << 16); break; } } /* Update serial parameters, don't change * the baud rate however. */ if(Status != -1) { WriteRequest -> io_SerFlags = Status & 0xFF; WriteRequest -> io_ExtFlags = 0; if(Status & ST_PARTYMARKON) WriteRequest -> io_ExtFlags |= SEXTF_MSPON; if(Status & ST_PARTYMARK) WriteRequest -> io_ExtFlags |= SEXTF_MARK; if(Status & ST_2BITS) WriteRequest -> io_StopBits = 2; else WriteRequest -> io_StopBits = 1; if(Status & ST_READ7) WriteRequest -> io_ReadLen = 7; else WriteRequest -> io_ReadLen = 8; if(Status & ST_WRITE7) WriteRequest -> io_WriteLen = 7; else WriteRequest -> io_WriteLen = 8; ReadRequest -> io_Baud = WriteRequest -> io_Baud; ReadRequest -> io_SerFlags = WriteRequest -> io_SerFlags; ReadRequest -> io_ExtFlags = WriteRequest -> io_ExtFlags; ReadRequest -> io_StopBits = WriteRequest -> io_StopBits; ReadRequest -> io_ReadLen = WriteRequest -> io_ReadLen; ReadRequest -> io_WriteLen = WriteRequest -> io_WriteLen; WriteRequest -> IOSer . io_Command = SDCMD_SETPARAMS; DoIO(WriteRequest); ReadRequest -> IOSer . io_Command = SDCMD_SETPARAMS; DoIO(ReadRequest); GetFlags(Config,WriteRequest); } return(Return); } else return(-1); } /* xpr_ffirst(STRPTR Buffer,STRPTR Pattern): * * Batch file upload: find the first matching file and return * its name. */ LONG __saveds __asm xpr_ffirst(register __a0 STRPTR Buffer,register __a1 STRPTR Pattern) { if(FileTransferInfo) { FileTransferInfo -> DoneSize = 0; FileTransferInfo -> DoneFiles = 0; FileTransferInfo -> CurrentFile = (struct FileTransferNode *)FileTransferInfo -> FileList . mlh_Head; FileTransferInfo -> CurrentSize = FileTransferInfo -> CurrentFile -> Size; if(Config -> TransferConfig -> MangleFileNames) { UBYTE LocalName[MAX_FILENAME_LENGTH],*Char; strcpy(OriginalName,FileTransferInfo -> CurrentFile -> Name); ShrinkName(FilePart(FileTransferInfo -> CurrentFile -> Name),LocalName,12,TRUE); strcpy(Buffer,FileTransferInfo -> CurrentFile -> Name); Char = PathPart(Buffer); *Char = 0; AddPart(Buffer,LocalName,MAX_FILENAME_LENGTH); strcpy(ShrunkenName,Buffer); } else { OriginalName[0] = 0; strcpy(Buffer,FileTransferInfo -> CurrentFile -> Name); } return(1); } else return(0); } /* xpr_fnext(LONG OldState,STRPTR Buffer,STRPTR Pattern): * * Batch file upload: find the next matching file * - if any - and return its name. */ LONG __saveds __asm xpr_fnext(register __d0 LONG OldState,register __a0 STRPTR Buffer,register __a1 STRPTR Pattern) { if(FileTransferInfo) { if(FileTransferInfo -> CurrentFile -> Node . mln_Succ -> mln_Succ) { FileTransferInfo -> DoneSize += FileTransferInfo -> CurrentSize; FileTransferInfo -> DoneFiles += 1; FileTransferInfo -> CurrentFile = (struct FileTransferNode *)FileTransferInfo -> CurrentFile -> Node . mln_Succ; FileTransferInfo -> CurrentSize = FileTransferInfo -> CurrentFile -> Size; if(Config -> TransferConfig -> MangleFileNames) { UBYTE LocalName[MAX_FILENAME_LENGTH],*Char; strcpy(OriginalName,FileTransferInfo -> CurrentFile -> Name); ShrinkName(FilePart(FileTransferInfo -> CurrentFile -> Name),LocalName,12,TRUE); strcpy(Buffer,FileTransferInfo -> CurrentFile -> Name); Char = PathPart(Buffer); *Char = 0; AddPart(Buffer,LocalName,MAX_FILENAME_LENGTH); strcpy(ShrunkenName,Buffer); } else { OriginalName[0] = 0; strcpy(Buffer,FileTransferInfo -> CurrentFile -> Name); } return(1); } } return(0); } /* xpr_finfo(STRPTR FileName,LONG InfoType): * * Return information on a given file. */ LONG __saveds __asm xpr_finfo(register __a0 STRPTR FileName,register __d0 LONG InfoType) { struct FileInfoBlock *FileInfo; LONG Size; switch(InfoType) { /* Return the file size. */ case 1: Size = 0; if(FileInfo = (struct FileInfoBlock *)AllocDosObject(DOS_FIB,TAG_DONE)) { UBYTE RealName[MAX_FILENAME_LENGTH]; BPTR FileLock; if(OriginalName[0]) { if(!Stricmp(ShrunkenName,FileName)) FileName = NewFileName(OriginalName,RealName); else FileName = NewFileName(FileName,RealName); } else FileName = NewFileName(FileName,RealName); if(FileLock = Lock(FileName,ACCESS_READ)) { if(Examine(FileLock,FileInfo)) { if(FileInfo -> fib_DirEntryType < 0) Size = FileInfo -> fib_Size; } UnLock(FileLock); } FreeDosObject(DOS_FIB,FileInfo); } return(Size); /* Return the file transfer mode. */ case 2: return(BinaryTransfer ? 1 : 2); /* Ignore the rest. */ default:return(0); } } /* xpr_options(LONG NumOpts,struct xpr_option **Opts): * * Provide a more polished user interface to set the * transfer protocol options. */ ULONG __saveds __asm xpr_options(register __d0 LONG NumOpts,register __a0 struct xpr_option **Opts) { if(NumOpts && Opts) { enum { GAD_USE=1,GAD_CANCEL,GAD_SPECIAL }; struct LayoutHandle *Handle; ULONG Flags = NULL; /* We only have 32 bits! */ if(NumOpts > 32) NumOpts = 32; if(Handle = LT_CreateHandleTags(Window -> WScreen, LH_LocaleHook, &LocaleHook, TAG_DONE)) { struct Window *Window; LONG i,Split; if(NumOpts > 16) Split = NumOpts / 2; else Split = -1; LT_New(Handle, LA_Type, VERTICAL_KIND, TAG_DONE); { LT_New(Handle, LA_Type, HORIZONTAL_KIND, LA_LabelID, MSG_V36_1501, TAG_DONE); { LT_New(Handle, LA_Type, VERTICAL_KIND, TAG_DONE); { for(i = 0 ; i < NumOpts ; i++) { if(Opts[i]) { switch(Opts[i] -> xpro_type) { case XPRO_BOOLEAN: LT_New(Handle, LA_Type, CHECKBOX_KIND, LA_LabelText, Opts[i] -> xpro_description, LA_ID, GAD_SPECIAL + i, GTCB_Checked, GetOptionMode(Opts[i]), TAG_DONE); break; case XPRO_LONG: LT_New(Handle, LA_Type, INTEGER_KIND, LA_LabelText, Opts[i] -> xpro_description, LA_ID, GAD_SPECIAL + i, LA_Chars, 20, GTIN_Number, Atol(Opts[i] -> xpro_value), LAIN_UseIncrementers, TRUE, TAG_DONE); break; case XPRO_STRING: LT_New(Handle, LA_Type, STRING_KIND, LA_LabelText, Opts[i] -> xpro_description, LA_ID, GAD_SPECIAL + i, LA_Chars, 20, GTST_String, Opts[i] -> xpro_value, GTST_MaxChars, Opts[i] -> xpro_length - 1, TAG_DONE); break; case XPRO_COMMPAR: LT_New(Handle, LA_Type, STRING_KIND, LA_LabelText, Opts[i] -> xpro_description, LA_ID, GAD_SPECIAL + i, LA_Chars, 20, LA_HighLabel, TRUE, GTST_String, Opts[i] -> xpro_value, GTST_MaxChars, Opts[i] -> xpro_length - 1, TAG_DONE); break; case XPRO_HEADER: LT_New(Handle, LA_Type, TEXT_KIND, LA_LabelText, Opts[i] -> xpro_description, LA_HighLabel, TRUE, GTTX_Text, " ", TAG_DONE); break; case XPRO_COMMAND: LT_New(Handle, LA_Type, BUTTON_KIND, LA_LabelText, Opts[i] -> xpro_description, LA_ID, GAD_SPECIAL + i, LA_Chars, 20, TAG_DONE); break; } } if(i == Split) { LT_EndGroup(Handle); LT_New(Handle, LA_Type, VERTICAL_KIND, TAG_DONE); } } LT_EndGroup(Handle); } LT_EndGroup(Handle); } LT_New(Handle, LA_Type,VERTICAL_KIND, TAG_DONE); { LT_New(Handle, LA_Type, XBAR_KIND, LAXB_FullSize, TRUE, TAG_DONE); LT_EndGroup(Handle); } LT_New(Handle,LA_Type,HORIZONTAL_KIND, LAGR_SameSize, TRUE, LAGR_Spread, TRUE, TAG_DONE); { LT_New(Handle, LA_Type, BUTTON_KIND, LA_LabelID, MSG_GLOBAL_USE_GAD, LA_ID, GAD_USE, LABT_ReturnKey, TRUE, LABT_ExtraFat, TRUE, TAG_DONE); LT_New(Handle, LA_Type, BUTTON_KIND, LA_LabelID, MSG_GLOBAL_CANCEL_GAD, LA_ID, GAD_CANCEL, LABT_EscKey, TRUE, LABT_ExtraFat, TRUE, TAG_DONE); LT_EndGroup(Handle); } LT_EndGroup(Handle); } if(Window = LT_Layout(Handle,OptionTitle ? OptionTitle : LocaleString(MSG_TERMXPR_TRANSFER_OPTIONS_TXT),NULL,0,0,IDCMP_CLOSEWINDOW,0, LAWN_HelpHook, &GuideHook, WA_DepthGadget, TRUE, WA_CloseGadget, TRUE, WA_DragBar, TRUE, WA_RMBTrap, TRUE, WA_Activate, TRUE, TAG_DONE)) { struct IntuiMessage *Message; BOOLEAN Done = FALSE; ULONG MsgClass, MsgQualifier; UWORD MsgCode; struct Gadget *MsgGadget; BOOLEAN CheckFlags = FALSE; PushWindow(Window); LT_ShowWindow(Handle,TRUE); do { if(Wait(PORTMASK(Window -> UserPort) | SIG_BREAK) & SIG_BREAK) break; while(Message = (struct IntuiMessage *)GT_GetIMsg(Window -> UserPort)) { MsgClass = Message -> Class; MsgQualifier = Message -> Qualifier; MsgCode = Message -> Code; MsgGadget = (struct Gadget *)Message -> IAddress; GT_ReplyIMsg(Message); LT_HandleInput(Handle,MsgQualifier,&MsgClass,&MsgCode,&MsgGadget); if(MsgClass == IDCMP_CLOSEWINDOW) Done = TRUE; if(MsgClass == IDCMP_GADGETUP) { switch(MsgGadget -> GadgetID) { case GAD_USE: Done = CheckFlags = TRUE; break; case GAD_CANCEL: Done = TRUE; break; default: if(MsgGadget -> GadgetID - GAD_SPECIAL < NumOpts) { i = MsgGadget -> GadgetID - GAD_SPECIAL; if(Opts[i] -> xpro_type == XPRO_COMMAND || (Opts[i] -> xpro_type == XPRO_COMMPAR && MsgCode != '\t')) { Flags = (1L << i); XPRCommandSelected = Done = CheckFlags = TRUE; } } break; } } } } while(!Done); PopWindow(); if(CheckFlags) { LT_LockWindow(Window); for(i = 0 ; i < NumOpts ; i++) { if(Opts[i]) { switch(Opts[i] -> xpro_type) { case XPRO_BOOLEAN: if(LT_GetAttributes(Handle,GAD_SPECIAL + i,TAG_DONE) != GetOptionMode(Opts[i])) { Flags |= (1L << i); if(LT_GetAttributes(Handle,GAD_SPECIAL + i,TAG_DONE)) strcpy(Opts[i] -> xpro_value,"yes"); else strcpy(Opts[i] -> xpro_value,"no"); NewOptions = TRUE; } break; case XPRO_LONG: if(Atol(Opts[i] -> xpro_value) != LT_GetAttributes(Handle,GAD_SPECIAL + i,TAG_DONE)) { Flags |= (1L << i); SPrintf(Opts[i] -> xpro_value,"%ld",LT_GetAttributes(Handle,GAD_SPECIAL + i,TAG_DONE)); NewOptions = TRUE; } break; case XPRO_STRING: if(strcmp(Opts[i] -> xpro_value,(STRPTR)LT_GetAttributes(Handle,GAD_SPECIAL + i,TAG_DONE))) { Flags |= (1L << i); strcpy(Opts[i] -> xpro_value,(STRPTR)LT_GetAttributes(Handle,GAD_SPECIAL + i,TAG_DONE)); NewOptions = TRUE; } break; } } } LT_UnlockWindow(Window); } else Flags = NULL; } LT_DeleteHandle(Handle); } return(Flags); } else return(NULL); } /* xpr_unlink(STRPTR FileName): * * Remove (delete) a given file. */ LONG __saveds __asm xpr_unlink(register __a0 STRPTR FileName) { /* Sorry, but it is far too dangerous to let the protocol * remove any files with path name substitution enabled. * The protocol could accidentally hit the wrong file. */ if(!Config -> MiscConfig -> OverridePath) { if(OriginalName[0]) { if(!Stricmp(ShrunkenName,FileName)) FileName = OriginalName; } if(DeleteFile(FileName)) { LogAction(LocaleString(MSG_TERMXPR_LOGMSG_DELETE_FILE_TXT),FilePart(FileName)); return(0); } } return(-1); } /* xpr_squery(): * * Check how many characters are present in the serial buffer. */ LONG __saveds __asm xpr_squery() { if(WriteRequest) { WriteRequest -> IOSer . io_Command = SDCMD_QUERY; DoIO(WriteRequest); /* Return error if carrier is lost. */ if((WriteRequest -> io_Status & CIAF_COMCD) && Config -> SerialConfig -> CheckCarrier) { if(!CarrierMessage) { CarrierMessage = TRUE; AddTransferInfo(TRUE,LocaleString(MSG_TERMXPR_CARRIER_LOST_TXT)); } Online = FALSE; TransferError = TRUE; } else return((LONG)WriteRequest -> IOSer . io_Actual); } return(-1); } /* xpr_getptr(LONG InfoType): * * Return a pointer to the term custom screen. */ LONG __saveds __asm xpr_getptr(register __d0 LONG InfoType) { if(InfoType == 1) return((LONG)Window -> WScreen); else return(-1); } /* xpr_stealopts(STRPTR Prompt,STRPTR Buffer): * * Steal the contents of the options buffer (replacement * for xpr_gets). */ LONG __saveds __asm xpr_stealopts(register __a0 STRPTR Prompt,register __a1 STRPTR Buffer) { if(Buffer) strcpy(ProtocolOptsBuffer,Buffer); return(1); }