home *** CD-ROM | disk | FTP | other *** search
/ Magazyn Amiga 14 / MA_Cover_14.iso / internet / atalk_v1 / atalk2.p < prev    next >
Encoding:
Text File  |  1999-12-07  |  11.5 KB  |  476 lines
  1. ; 
  2. ; 
  3. ; (c) 1999 Cyborg 
  4.  
  5.     {* Include sys:coder/preass/Options.p *}
  6.  
  7.     {* String: Version="$VER: ATalk Net Client (C) CYBORG 1999"*}
  8.  
  9.     {* Structure sockaddr_in(),sin_len(BYTE),sin_family(BYTE),sin_port(WORD)
  10.                  sin_addr(LONG),DUMMY1(LONG),DUMMY2(LONG)*}
  11.     
  12.     {* Structure Sockaddr(),SA_Len(BYTE),SA_Family(BYTE)
  13.                  SA_Data[14]*}
  14.  
  15.     {* Structure Hostent,H_name(CHAR),h_aliases(APTR),h_addrtype(LONG)
  16.                  h_length(LONG),H_addr_list(CHAR)*}
  17.  
  18.     {* IncBlock: Puffer,2048*}
  19.  
  20.     {* Const AF_INET=2
  21.              Sock_STREAM=1
  22.              FIONBIO=$8004667e*}
  23.  
  24.     {* incVar: Addr*}
  25.  
  26.     {* Structure Node,ln_Succ(LONG),ln_pred(LONG),ln_Type(BYTE),ln_Pri(BYTE)
  27.                  ln_Name(LONG)*}
  28.  
  29.     {* Structure MsgList,LH_Head(LONG),LH_Tail(LONG),LH_TailPred(LONG),LH_Type(BYTE)
  30.                  pad(BYTE)*}
  31.  
  32.     {* Structure MsgPort,Node(STRUCT Node),mp_Flags(BYTE),mp_sigbit(BYTE)
  33.                  mp_sigTask(LONG),List(STRUCT MsgList)*}
  34.  
  35.     {* Structure Message,Node(STRUCT Node),Replyport(APTR),Length(WORD)*}
  36.  
  37.     {* Structure Window,NextWindow(APTR),LeftEdge(WORD),TopEdge(WORD),Width(WORD)
  38.                  Height(WORD),MouseY(WORD),MouseX(WORD),MinWidth(WORD),MinHeight(WORD)
  39.                  MaxWidth(WORD),MaxHeight(WORD),Flags(LONG),MenuStrip(APTR),Title(APTR)
  40.                  FirstRequest(APTR),DMRequest(APTR),ReqCount(WORD),WScreen(APTR)
  41.                  RPort(APTR),BorderLeft(BYTE),BorderTop(BYTE),BorderRight(BYTE)
  42.                  BorderBottom(BYTE),BorderRPort(APTR),FirstGadget(APTR),Parent(APTR)
  43.                  Descendant(APTR),Pointer(APTR),PtrHeight(BYTE),PtrWidth(BYTE),XOffset(BYTE)
  44.                  YOffset(BYTE),IDCMPFlags(LONG),UserPort(APTR),WindowPort(APTR)
  45.                  MessageKey(APTR),DetailPen(BYTE),BlockPen(BYTE),CheckMark(APTR)
  46.                  ScreenTitle(APTR),GZZMouseX(WORD),GZZMouseY(WORD),GZZWidth(WORD)
  47.                  GZZHeight(WORD),ExtData(APTR),UserData(APTR),WLayer(APTR),IFont(APTR)
  48.                  MoreFlags(LONG)*}
  49.  
  50.     {* incSysBlock: Windowname,200*}
  51.     {* incSysBlock: Eingabepuffer,500*}
  52.     {* incSysBlock: namepuffer,20*}
  53.  
  54.     {* NewProc=CountString[String][A0]*}
  55.     {* NewProc=Fillbuffer[][A0,d0,d1]*}
  56.     {* NewProc=MatchString[][A0,A1]*}
  57.     {* NewProc=getFilename[][]*}
  58.     {* NewProc=ASC2Zahl[][a5]*}
  59.  
  60.  
  61. recv[d0,d1,d2,d3]:
  62.     {* Stackframe Socket=d0,Zeiger=d1,Laenge=d2,time=d3,Readlen*}
  63.     While Time>0
  64.      {
  65.       Readlen=TCP_recv(Socket,Zeiger,Laenge,0)
  66.       If Readlen>0 breakwhile
  67.       Time==Time-25
  68.       Delay(25)
  69.      }
  70.     {* UnFrameReturn Readlen*}
  71.     
  72. CopyNextString[a0,a3]:
  73.         cmpi.l #0,laenge
  74.         beq .l13
  75.         cmpi.l #1,laenge
  76.         beq .l13
  77.         suba.l a2,a2
  78.         suba.l a1,a1
  79. .l1:    cmpi.b #`"`,(a0)
  80.         beq .l10
  81.         cmpi.b #` `,(a0)+
  82.         beq .l1
  83.         lea -1(a0),a1
  84. .l2:    cmpi.b #`"`,(a0)
  85.         beq .l11
  86.         cmpi.b #$0a,(a0)
  87.         beq .l12
  88.         cmpi.b #$00,(a0)
  89.         beq .l12
  90.         cmpi.b #` `,(a0)+
  91.         bne .l2
  92.         Lea -1(a0),a2
  93. .l3:    suba.l a1,a2
  94.         move.l A0,NextArg
  95.         Copymem(a1,a3,a2)
  96.         Move.l a2,d0
  97.         rts
  98. .l10:   lea 1(a0),a1
  99.         movea.l a1,a0
  100.         bra .l22
  101. .l11:   move.l a0,a2
  102.         bra .l3
  103. .l12:   move.l a0,a2
  104.         bra .l3
  105. .l13:   moveq.l #0,d0
  106.         RTS
  107. .l22:   cmpi.b #`"`,(a0)
  108.         beq .l11
  109.         cmpi.b #$0a,(a0)
  110.         beq .l12
  111.         cmpi.b #$00,(a0)
  112.         beq .l12
  113.         lea 1(a0),a0
  114.         bne .l22
  115.  
  116.     {* IncBlock: Hostname1,50*}
  117.     {* IncBlock: Hostname2,50*}
  118.     {* IncBlock: Port1asc,10*}
  119.     {* IncBlock: Port2asc,10*}
  120.     {* IncBlock: Message,100*}
  121.  
  122.  
  123. TCP_Write[d0,a0,d1,d2]:
  124.     {* StackFrame wr,Socket=d0,msg=a0,MsgLen=d1,flags=d2*}
  125.     While (Wr=TCP_Send(Socket,msg,msglen,flags))#msglen
  126.       {
  127.         Msg==Msg+Wr
  128.         Msglen==MsgLen-Wr
  129.       }
  130.     {* UnFrameReturn *}
  131.  
  132.  
  133. KPA[]:
  134.     TCP_Write(Socket1,"KPA",3,0)
  135.     TCP_Write(Socket2,"KPA",3,0)
  136.     {* Return *}
  137.  
  138. GetSigs[]:
  139.     Signals=SetSignal(0,0)
  140.     Signals==Signals&#$F000
  141.     {* Return Signals*}
  142.     
  143. {* String: Options="localhost localhost    "*}
  144.  
  145. Start:
  146.     OH=output()
  147.     MeineNummer1==#":"
  148.     MeineNummer2==#":"
  149. ;    Adresse==#Options
  150. ;    Laenge=Countstring(&Options)
  151.     If CopyNextString(Adresse,&Hostname1)=0 
  152.      {
  153.        Write(OH,"Kein Hostname angegeben\n",?)
  154.        {* Return 5*}
  155.      }
  156.     If CopyNextString(NextArg,&Hostname2)=0 
  157.      {
  158.        Write(OH,"Keinen 2.Hostnamen angegeben\n",?)
  159.        {* Return 5*}
  160.      }
  161. ;     If CopyNextString(NextArg,&Port1asc)#0 
  162. ;     {
  163. ;       CopynextString(NextArg,&Port2asc)
  164. ;     }
  165.     If (socket1=TCP_Socket(AF_INET,SOCK_STREAM,0))=-1
  166.      {
  167.       TCP_Errno()
  168.       TCP_vsyslog(7,"ATALK-Client V2 konnte Socket nicht öffnen :%m\n",0)
  169.       {* Return 10*}
  170.      }
  171.     If (socket2=TCP_Socket(AF_INET,SOCK_STREAM,0))=-1
  172.      {
  173.       TCP_Errno()
  174.       TCP_vsyslog(7,"ATALK-Client V2 konnte Socket nicht öffnen :%m\n",0)
  175.       TCP_CloseSocket(Socket1)
  176.       {* Return 10*}
  177.      }
  178.     If (he=TCP_gethostbyname(&Hostname1))=0
  179.      {
  180.       TCP_Errno()
  181.       TCP_vsyslog(7,"ATALK-Client V2 :%m\n",0)
  182.       TCP_CloseSocket(Socket1)
  183.       TCP_CloseSocket(Socket2)
  184.       {* Return 20*}
  185.      }
  186.     #AF_Inet=>sockaddr_in.sin_family
  187.     Zeiger=.lhostent.H_addr_list(he)
  188.     addr==(Zeiger)
  189.     addr==(Addr)
  190.     addr=>sockaddr_in.sin_addr
  191.     #518=>sockaddr_in.sin_port
  192.     If Port1asc#0
  193.      {
  194.       Port1=Asc2zahl(&Port1asc)
  195.       Port1=>sockaddr_in.sin_port
  196.      }
  197.     ret=TCP_Connect(Socket1,&Sockaddr_in,sizeof(sockaddr_in))
  198.     If ret=-1
  199.      {
  200.       TCP_Errno()
  201.       TCP_vsyslog(7,"ATALK-Client V2 kein Connect 1:%m\n",0)
  202.       TCP_CloseSocket(Socket1)
  203.       TCP_CloseSocket(Socket2)
  204.       {* Return 20*}
  205.      }
  206.     If (he=TCP_gethostbyname(&Hostname2))=0
  207.      {
  208.       TCP_Errno()
  209.       TCP_vsyslog(7,"ATALK-Client V2 :%m\n",0)
  210.       TCP_CloseSocket(Socket1)
  211.       TCP_CloseSocket(Socket2)
  212.       {* Return 20*}
  213.      }
  214.     
  215.     #AF_Inet=>sockaddr_in.sin_family
  216.     Zeiger=.lhostent.H_addr_list(he)
  217.     addr==(Zeiger)
  218.     addr==(Addr)
  219.     addr=>sockaddr_in.sin_addr
  220.     #518=>sockaddr_in.sin_port
  221.     If Port2asc#0
  222.      {
  223.       Port2=Asc2zahl(&Port2asc)
  224.       Port2=>sockaddr_in.sin_port
  225.      }
  226.     ret=TCP_Connect(Socket2,&Sockaddr_in,sizeof(sockaddr_in))
  227.     If ret=-1
  228.      {
  229.       TCP_Errno()
  230.       TCP_vsyslog(7,"ATALK-Client V2 kein Connect 2:%m\n",0)
  231.       TCP_CloseSocket(Socket1)
  232.       TCP_CloseSocket(Socket2)
  233.       {* Return 20*}
  234.      }
  235.     If TCP_IoCtlSocket(Socket1,FIONBIO,1)=-1
  236.      {
  237.       TCP_Errno()
  238.       TCP_vsyslog(5,"Atalk-Client V2 konnte nicht auf NON-BLOCKING schalten : %m\n",0)
  239.       TCP_Closesocket(Socket1)
  240.       TCP_Closesocket(Socket2)
  241.       {* Return 30*}
  242.      }
  243.     If TCP_IoCtlSocket(Socket2,FIONBIO,1)=-1
  244.      {
  245.       TCP_Errno()
  246.       TCP_vsyslog(5,"Atalk-Client V2 konnte nicht auf NON-BLOCKING schalten : %m\n",0)
  247.       TCP_Closesocket(Socket1)
  248.       TCP_Closesocket(Socket2)
  249.       {* Return 30*}
  250.      }
  251.     Fillbuffer(&Puffer,0,10)
  252. ;    KPA()
  253.     Readlen=recv(Socket1,&Puffer,9,500)
  254.     If readlen=-1 
  255.      {
  256.       TCP_Errno()
  257.       TCP_vsyslog(7,"ATALK-Client V2 - Server does not respond: %m\n",0)
  258.       TCP_CloseSocket(Socket1)
  259.       TCP_CloseSocket(Socket2)
  260.       {* Return 40*}
  261.      }  
  262.     If Matchstring(&Puffer,"AMIGATALK")#1
  263.      {
  264.       TCP_Errno()
  265.       TCP_vsyslog(7,"ATALK-Client V2 - falscher Servertype: %m\n",0)
  266.       TCP_CloseSocket(Socket1)
  267.       TCP_CloseSocket(Socket2)
  268.       {* Return 40*}
  269.      }      
  270. ;    KPA()
  271.     Readlen=recv(Socket2,&Puffer,9,500)
  272.     If readlen=-1 
  273.      {
  274.       TCP_Errno()
  275.       TCP_vsyslog(7,"ATALK-Client V2 - Server does not respond: %m\n",0)
  276.       TCP_CloseSocket(Socket1)
  277.       TCP_CloseSocket(Socket2)
  278.       {* Return 40*}
  279.      }  
  280.     If Matchstring(&Puffer,"AMIGATALK")#1
  281.      {
  282.       TCP_Errno()
  283.       TCP_vsyslog(7,"ATALK-Client V2 - falscher Servertype: %m\n",0)
  284.       TCP_CloseSocket(Socket1)
  285.       TCP_CloseSocket(Socket2)
  286.       {* Return 40*}
  287.      }      
  288. ;    KPA()
  289.     recv(Socket1,&MeineNummer1,3,500)
  290. ;    KPA()
  291.     recv(Socket2,&MeineNummer2,3,500)
  292.     TCP_Write(Socket1,"Netc",4,0)
  293.     TCP_Write(Socket2,"Netc",4,0)
  294.     Fillbuffer(&Puffer,0,1024)
  295.     While GetSigs()=0
  296.      {    
  297.        KPA()
  298.        If (Rl=Recv(Socket1,&Puffer,1024,50))>0
  299.         {
  300.           If Puffer#MeineNummer1
  301.             {
  302.               Message=="von "+Hostname1+" kommt:\n"
  303.               Bytes=Countstring(&Message)
  304.               TCP_Write(Socket2,&MeineNummer2,4,0)
  305.               TCP_Write(Socket2,&Message,Bytes,0)
  306.               TCP_Write(Socket2,&Puffer,rl,0)
  307.               Fillbuffer(&Puffer,0,1024)
  308.             }
  309.         }
  310.        If (Rl=Recv(Socket2,&Puffer,1024,50))>0
  311.         {
  312.           If Puffer#MeineNummer2
  313.             {
  314.               Message=="von "+Hostname2+" kommt:\n"
  315.               Bytes=Countstring(&Message)
  316.               TCP_Write(Socket1,&MeineNummer1,4,0)
  317.               TCP_Write(Socket1,&Message,Bytes,0)
  318.               TCP_Write(Socket1,&Puffer,rl,0)
  319.               Fillbuffer(&Puffer,0,1024)
  320.             }
  321.         }
  322.      }
  323.     TCP_CloseSocket(Socket1)
  324.     TCP_CloseSocket(Socket2)
  325.     TCP_vsyslog(7,"ATALK-Client V2 beendet sich.\n",0)
  326.     {* Return *}
  327.  
  328. CountString:
  329.         move.l a1,-(Sp)
  330.         move.l a0,a1
  331. .l1:    cmpi.b #$00,(a1)+
  332.         bne .l1
  333.         lea -1(a1),a1
  334.         sub.l a0,a1
  335.         move.l a1,d0
  336.         move.l (sp)+,a1
  337.         RTS
  338.  
  339.  
  340. FillBuffer:
  341.     subq.l #1,d1
  342. .l1:move.b d0,(a0)+
  343.     dbra  d1,.l1
  344.     RTS
  345.  
  346. Matchstring:
  347.     cmpi.b #0,(a0)
  348.     beq .error1
  349.     cmpi.b #0,(a1)
  350.     beq .error
  351.     move.b (a0)+,d0
  352.     move.b (a1)+,d1
  353.     bset #5,d0
  354.     bset #5,d1
  355.     cmp.b d0,d1
  356.     beq MatchString
  357.     bra.s .ende1
  358. .ok:moveq.l #1,d0
  359.     rts
  360. .error:
  361.     cmpi.b #0,(a0)
  362.     beq .ok
  363.     cmpi.b #$a,(a0)
  364.     beq .ok
  365.     bra.s .ende1
  366. .error1:
  367.     cmpi.b #0,(a1)
  368.     beq .ok
  369.     cmpi.b #$a,(a1)
  370.     beq .ok
  371. .ende1:
  372.     moveq.l #0,d0
  373.     RTS
  374.  
  375.  
  376. GetFilename:
  377.     {* IncBlock: Filename,256*}
  378.     {* IncVar: NextArg*}
  379.         cmpi.l #0,laenge
  380.         beq .l13
  381.         cmpi.l #1,laenge
  382.         beq .l13
  383.         suba.l a2,a2
  384.         suba.l a1,a1
  385.         Move.l Adresse,a0
  386. .l1:    cmpi.b #`"`,(a0)
  387.         beq .l10
  388.         cmpi.b #` `,(a0)+
  389.         beq .l1
  390.         lea -1(a0),a1
  391. .l2:    cmpi.b #`"`,(a0)
  392.         beq .l11
  393.         cmpi.b #$0a,(a0)
  394.         beq .l12
  395.         cmpi.b #$00,(a0)
  396.         beq .l12
  397.         cmpi.b #` `,(a0)+
  398.         bne .l2
  399.         Lea -1(a0),a2
  400. .l3:    suba.l a1,a2
  401.         move.l A0,NextArg
  402.         Copymem(a1,#Filename,a2)
  403.         Move.l a2,d0
  404.         rts
  405. .l10:   lea 1(a0),a1
  406.         movea.l a1,a0
  407.         bra .l22
  408. .l11:   move.l a0,a2
  409.         bra .l3
  410. .l12:   move.l a0,a2
  411.         bra .l3
  412. .l13:   moveq.l #0,d0
  413.         RTS
  414. .l22:   cmpi.b #`"`,(a0)
  415.         beq .l11
  416.         cmpi.b #$0a,(a0)
  417.         beq .l12
  418.         cmpi.b #$00,(a0)
  419.         beq .l12
  420.         lea 1(a0),a0
  421.         bne .l22
  422.  
  423.  
  424. CountString2[a0]:
  425.         move.l a1,-(Sp)
  426.         move.l a0,a1
  427. .l1:    cmpi.b #$0a,(a1)
  428.         beq .l2
  429.         cmpi.b #",",(a1)
  430.         beq .l2
  431.         cmpi.b #" ",(a1)
  432.         beq .l2
  433.         cmpi.b #$00,(a1)+
  434.         bne .l1
  435.         lea -1(a1),a1
  436. .l2:    sub.l a0,a1
  437.         move.l a1,d0
  438.         move.l (sp)+,a1
  439.         RTS
  440.  
  441. ASC2Zahl[a5]:
  442.     {* IncVar: Potenz*}
  443.     Countstring2(a5)
  444.     move.l d0,d7
  445.     subq.l #2,d7
  446.     move.l #1,d0
  447.     cmpi.w #$FFFF,d7
  448.     beq .la
  449. .l0:mulu.l #10,d0
  450.     dbra d7,.l0
  451. .la:move.l d0,d6
  452.     moveq.l #0,d1
  453.     move.l a5,a0
  454.     move.b #"+",d5
  455. .l1:moveq.l #0,d0
  456.     move.b (A0)+,d0
  457.     cmpi.b #"-",d0
  458.     bne .l2
  459.     move.b d0,d5
  460.     Divs.l #10,d6
  461.     bra .l1
  462. .l2:subi.b #$30,d0
  463.     andi.l #$FF,d0
  464.     Muls.l d6,d0
  465.     divs.l #10,d6
  466.     add.l d0,d1
  467.     cmpi.l #0,d6
  468.     bne .l1
  469.     lea 1(a0),a0
  470. ;    move.l a0,NextArg
  471.     move.l d1,d0
  472.     cmpi.b #"+",d5
  473.     beq .l3
  474.     neg.l d0
  475. .l3:RTS
  476.