workbench/devs/networks/e1000/handler.c

   1 /*
   2  * $Id$
   3  */
   4 /*
   5     This program is free software; you can redistribute it and/or modify
   6     it under the terms of the GNU General Public License as published by
   7     the Free Software Foundation; either version 2 of the License, or
   8     (at your option) any later version.
   9
  10     This program is distributed in the hope that it will be useful, but
  11     WITHOUT ANY WARRANTY; without even the implied warranty of
  12     MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
  13     General Public License for more details.
  14
  15     You should have received a copy of the GNU General Public License
  16     along with this program; if not, write to the Free Software
  17     Foundation, Inc., 59 Temple Place - Suite 330, Boston,
  18     MA 02111-1307, USA.
  19 */
  20
  21 #include <exec/types.h>
  22 #include <exec/resident.h>
  23 #include <exec/io.h>
  24 #include <exec/ports.h>
  25 #include <exec/errors.h>
  26
  27 #include <devices/sana2.h>
  28 #include <devices/sana2specialstats.h>
  29 #include <devices/newstyle.h>
  30
  31 #include <utility/utility.h>
  32 #include <utility/tagitem.h>
  33 #include <utility/hooks.h>
  34
  35 #include <proto/exec.h>
  36 #include <proto/dos.h>
  37 #include <proto/battclock.h>
  38
  39 #include <stdlib.h>
  40
  41 #include "e1000_osdep.h"
  42 #include "e1000.h"
  43 #include "e1000_defines.h"
  44 #include "e1000_api.h"
  45
  46 #include "unit.h"
  47 #include LC_LIBDEFS_FILE
  48
  49 #define KNOWN_EVENTS \
  50     (S2EVENT_ERROR | S2EVENT_TX | S2EVENT_RX | S2EVENT_ONLINE \
  51     | S2EVENT_OFFLINE | S2EVENT_BUFF | S2EVENT_HARDWARE | S2EVENT_SOFTWARE)
  52
  53 static BOOL CmdInvalid(LIBBASETYPEPTR LIBBASE, struct IOSana2Req *request);
  54 static BOOL CmdRead(LIBBASETYPEPTR LIBBASE, struct IOSana2Req *request);
  55 static BOOL CmdWrite(LIBBASETYPEPTR LIBBASE, struct IOSana2Req *request);
  56 static BOOL CmdFlush(LIBBASETYPEPTR LIBBASE, struct IORequest *request);
  57 static BOOL CmdS2DeviceQuery(LIBBASETYPEPTR LIBBASE, struct IOSana2Req *request);
  58 static BOOL CmdGetStationAddress(LIBBASETYPEPTR LIBBASE, struct IOSana2Req *request);
  59 static BOOL CmdConfigInterface(LIBBASETYPEPTR LIBBASE, struct IOSana2Req *request);
  60 static BOOL CmdBroadcast(LIBBASETYPEPTR LIBBASE, struct IOSana2Req *request);
  61 static BOOL CmdTrackType(LIBBASETYPEPTR LIBBASE, struct IOSana2Req *request);
  62 static BOOL CmdUntrackType(LIBBASETYPEPTR LIBBASE, struct IOSana2Req *request);
  63 static BOOL CmdGetTypeStats(LIBBASETYPEPTR LIBBASE, struct IOSana2Req *request);
  64 static BOOL CmdGetGlobalStats(LIBBASETYPEPTR LIBBASE, struct IOSana2Req *request);
  65 static BOOL CmdDeviceQuery(LIBBASETYPEPTR LIBBASE, struct IOStdReq *request);
  66 static BOOL CmdOnEvent(LIBBASETYPEPTR LIBBASE, struct IOSana2Req *request);
  67 static BOOL CmdReadOrphan(LIBBASETYPEPTR LIBBASE, struct IOSana2Req *request);
  68 static BOOL CmdOnline(LIBBASETYPEPTR LIBBASE, struct IOSana2Req *request);
  69 static BOOL CmdOffline(LIBBASETYPEPTR LIBBASE, struct IOSana2Req *request);
  70 static BOOL CmdAddMulticastAddresses(LIBBASETYPEPTR LIBBASE, struct IOSana2Req *request);
  71 static BOOL CmdDelMulticastAddresses(LIBBASETYPEPTR LIBBASE, struct IOSana2Req *request);
  72
  73 static const UWORD supported_commands[] =
  74 {
  75     CMD_READ,
  76     CMD_WRITE,
  77     CMD_FLUSH,
  78     S2_DEVICEQUERY,
  79     S2_GETSTATIONADDRESS,
  80     S2_CONFIGINTERFACE,
  81     S2_ADDMULTICASTADDRESS,
  82     S2_DELMULTICASTADDRESS,
  83     S2_MULTICAST,
  84     S2_BROADCAST,
  85     S2_TRACKTYPE,
  86     S2_UNTRACKTYPE,
  87     S2_GETTYPESTATS,
  88 //    S2_GETSPECIALSTATS,
  89     S2_GETGLOBALSTATS,
  90     S2_ONEVENT,
  91     S2_READORPHAN,
  92     S2_ONLINE,
  93     S2_OFFLINE,
  94     NSCMD_DEVICEQUERY,
  95     S2_ADDMULTICASTADDRESSES,
  96     S2_DELMULTICASTADDRESSES,
  97     0
  98 };
  99
 100 void handle_request(LIBBASETYPEPTR LIBBASE, struct IOSana2Req *request)
 101 {
 102     BOOL complete;
 103
 104     switch(request->ios2_Req.io_Command)
 105     {
 106         case CMD_READ:
 107             complete = CmdRead(LIBBASE, request);
 108             break;
 109
 110         case CMD_WRITE:
 111         case S2_MULTICAST:
 112             complete = CmdWrite(LIBBASE, request);
 113             break;
 114
 115         case CMD_FLUSH:
 116             complete = CmdFlush(LIBBASE, (struct IORequest *)request);
 117             break;
 118
 119         case S2_DEVICEQUERY:
 120             complete = CmdS2DeviceQuery(LIBBASE, request);
 121             break;
 122
 123         case S2_GETSTATIONADDRESS:
 124             complete = CmdGetStationAddress(LIBBASE, request);
 125             break;
 126
 127         case S2_CONFIGINTERFACE:
 128             complete = CmdConfigInterface(LIBBASE, request);
 129             break;
 130
 131         case S2_BROADCAST:
 132             complete = CmdBroadcast(LIBBASE, request);
 133             break;
 134
 135         case S2_TRACKTYPE:
 136             complete = CmdTrackType(LIBBASE, request);
 137             break;
 138
 139         case S2_UNTRACKTYPE:
 140             complete = CmdUntrackType(LIBBASE, request);
 141             break;
 142
 143         case S2_GETTYPESTATS:
 144             complete = CmdGetTypeStats(LIBBASE, request);
 145             break;
 146
 147         case S2_GETGLOBALSTATS:
 148             complete = CmdGetGlobalStats(LIBBASE, request);
 149             break;
 150
 151         case S2_ONEVENT:
 152             complete = CmdOnEvent(LIBBASE, request);
 153             break;
 154
 155         case S2_READORPHAN:
 156             complete = CmdReadOrphan(LIBBASE, request);
 157             break;
 158
 159         case S2_ONLINE:
 160             complete = CmdOnline(LIBBASE, request);
 161             break;
 162
 163         case S2_OFFLINE:
 164             complete = CmdOffline(LIBBASE, request);
 165             break;
 166
 167         case S2_ADDMULTICASTADDRESS:
 168         case S2_ADDMULTICASTADDRESSES:
 169             complete = CmdAddMulticastAddresses(LIBBASE, request);
 170             break;
 171
 172         case S2_DELMULTICASTADDRESS:
 173         case S2_DELMULTICASTADDRESSES:
 174             complete = CmdDelMulticastAddresses(LIBBASE, request);
 175             break;
 176
 177         case NSCMD_DEVICEQUERY:
 178             complete = CmdDeviceQuery(LIBBASE, (struct IOStdReq *)request);
 179             break;
 180
 181         default:
 182             complete = CmdInvalid(LIBBASE, request);
 183     }
 184
 185     if(complete && (request->ios2_Req.io_Flags & IOF_QUICK) == 0)
 186         ReplyMsg((APTR)request);
 187
 188     ReleaseSemaphore(&((struct e1000Unit *)request->ios2_Req.io_Unit)->e1ku_unit_lock);
 189 }
 190
 191 static BOOL CmdInvalid(LIBBASETYPEPTR LIBBASE, struct IOSana2Req *request)
 192 {
 193     request->ios2_Req.io_Error = IOERR_NOCMD;
 194     request->ios2_WireError = S2WERR_GENERIC_ERROR;
 195
 196     return TRUE;
 197 }
 198
 199 static BOOL CmdRead(LIBBASETYPEPTR LIBBASE, struct IOSana2Req *request)
 200 {
 201     struct e1000Unit *unit;
 202     struct Opener *opener;
 203     BOOL complete = FALSE;
 204
 205     unit = (APTR)request->ios2_Req.io_Unit;
 206
 207 D(bug("[%s]: CmdRead()\n", unit->e1ku_name));
 208
 209     if((unit->e1ku_ifflags & IFF_UP) != 0)
 210     {
 211         opener = request->ios2_BufferManagement;
 212         request->ios2_Req.io_Flags &= ~IOF_QUICK;
 213         PutMsg(&opener->read_port, (struct Message *)request);
 214     }
 215     else
 216     {
 217         request->ios2_Req.io_Error = S2ERR_OUTOFSERVICE;
 218         request->ios2_WireError = S2WERR_UNIT_OFFLINE;
 219         complete = TRUE;
 220     }
 221
 222     /* Return */
 223
 224     return complete;
 225 }
 226
 227 static BOOL CmdWrite(LIBBASETYPEPTR LIBBASE, struct IOSana2Req *request)
 228 {
 229     struct e1000Unit *unit;
 230     BYTE error = 0;
 231     ULONG wire_error = S2WERR_GENERIC_ERROR;
 232     BOOL complete = FALSE;
 233
 234     /* Check request is valid */
 235
 236     unit = (APTR)request->ios2_Req.io_Unit;
 237
 238 D(bug("[%s]: CmdWrite()\n", unit->e1ku_name));
 239
 240     if((unit->e1ku_ifflags & IFF_UP) == 0)
 241     {
 242         error = S2ERR_OUTOFSERVICE;
 243         wire_error = S2WERR_UNIT_OFFLINE;
 244     }
 245     else if((request->ios2_Req.io_Command == S2_MULTICAST) &&
 246             ((request->ios2_DstAddr[0] & 0x1) == 0))
 247     {
 248         error = S2ERR_BAD_ADDRESS;
 249         wire_error = S2WERR_BAD_MULTICAST;
 250     }
 251
 252     /* Queue request for sending */
 253
 254     if(error == 0) {
 255         request->ios2_Req.io_Flags &= ~IOF_QUICK;
 256         PutMsg(unit->e1ku_request_ports[WRITE_QUEUE], (APTR)request);
 257     }
 258     else
 259     {
 260         request->ios2_Req.io_Error = error;
 261         request->ios2_WireError = wire_error;
 262         complete = TRUE;
 263     }
 264
 265     /* Return */
 266
 267     return complete;
 268 }
 269
 270 static BOOL CmdFlush(LIBBASETYPEPTR LIBBASE, struct IORequest *request)
 271 {
 272     FlushUnit(LIBBASE, (APTR)request->io_Unit, EVENT_QUEUE, IOERR_ABORTED);
 273     return TRUE;
 274 }
 275
 276 static BOOL CmdS2DeviceQuery(LIBBASETYPEPTR LIBBASE, struct IOSana2Req *request)
 277 {
 278     struct e1000Unit *unit = (APTR)request->ios2_Req.io_Unit;
 279     struct Sana2DeviceQuery *info;
 280     ULONG size_available, size;
 281     UWORD lnk_speed = 0, lnk_duplex = 0;
 282 D(bug("[%s]: CmdS2DeviceQuery()\n", unit->e1ku_name));
 283
 284     /* Copy device info */
 285     info = request->ios2_StatData;
 286     size = size_available = info->SizeAvailable;
 287     if(size > sizeof(struct Sana2DeviceQuery))
 288         size = sizeof(struct Sana2DeviceQuery);
 289
 290     CopyMem(&unit->e1ku_Sana2Info, info, size);
 291
 292     e1000_get_speed_and_duplex((struct e1000_hw *)unit->e1ku_Private00, &lnk_speed, &lnk_duplex);
 293
 294     info->BPS = (1000000 * lnk_speed);
 295     info->MTU = unit->e1ku_mtu;
 296     info->HardwareType = S2WireType_Ethernet;
 297     info->SizeAvailable = size_available;
 298     info->SizeSupplied = size;
 299
 300     /* Return */
 301
 302     return TRUE;
 303 }
 304
 305 static BOOL CmdGetStationAddress(LIBBASETYPEPTR LIBBASE, struct IOSana2Req *request)
 306 {
 307     struct e1000Unit *unit;
 308
 309     /* Copy addresses */
 310
 311     unit = (APTR)request->ios2_Req.io_Unit;
 312
 313 D(bug("[%s]: CmdGetStationAddress()\n", unit->e1ku_name));
 314
 315     CopyMem(unit->e1ku_dev_addr, request->ios2_SrcAddr, ETH_ADDRESSSIZE);
 316     CopyMem(unit->e1ku_org_addr, request->ios2_DstAddr, ETH_ADDRESSSIZE);
 317
 318     /* Return */
 319
 320     return TRUE;
 321 }
 322
 323 static BOOL CmdConfigInterface(LIBBASETYPEPTR LIBBASE, struct IOSana2Req *request)
 324 {
 325     struct e1000Unit *unit;
 326
 327     /* Configure adapter */
 328
 329     unit = (APTR)request->ios2_Req.io_Unit;
 330
 331 D(bug("[%s]: CmdConfigInterface()\n", unit->e1ku_name));
 332
 333     if((unit->e1ku_ifflags & IFF_CONFIGURED) == 0)
 334     {
 335         CopyMem(request->ios2_SrcAddr, unit->e1ku_dev_addr, ETH_ADDRESSSIZE);
 336         e1000func_set_mac(unit);
 337         unit->e1ku_ifflags |= IFF_CONFIGURED;
 338     }
 339     else
 340     {
 341         request->ios2_Req.io_Error = S2ERR_BAD_STATE;
 342         request->ios2_WireError = S2WERR_IS_CONFIGURED;
 343     }
 344
 345     /* Return */
 346
 347     return TRUE;
 348 }
 349
 350 static BOOL CmdBroadcast(LIBBASETYPEPTR LIBBASE, struct IOSana2Req *request)
 351 {
 352     /* Fill in the broadcast address as destination */
 353
 354     *((ULONG *)request->ios2_DstAddr) = 0xffffffff;
 355     *((UWORD *)(request->ios2_DstAddr + 4)) = 0xffff;
 356
 357     /* Queue the write as normal */
 358
 359     return CmdWrite(LIBBASE, request);
 360 }
 361
 362 static BOOL CmdTrackType(LIBBASETYPEPTR LIBBASE, struct IOSana2Req *request)
 363 {
 364     struct e1000Unit *unit;
 365     struct Opener *opener;
 366     ULONG packet_type, wire_error=0;
 367     struct TypeTracker *tracker;
 368     struct TypeStats *initial_stats;
 369     BYTE error = 0;
 370
 371     unit = (APTR)request->ios2_Req.io_Unit;
 372
 373 D(bug("[%s]: CmdTrackType()\n", unit->e1ku_name));
 374
 375     packet_type = request->ios2_PacketType;
 376
 377     /* Get global tracker */
 378
 379     tracker = (struct TypeTracker *)
 380         FindTypeStats(LIBBASE, unit, &unit->e1ku_type_trackers, packet_type);
 381
 382     if(tracker != NULL)
 383         tracker->user_count++;
 384     else
 385     {
 386         tracker =
 387             AllocMem(sizeof(struct TypeTracker), MEMF_PUBLIC|MEMF_CLEAR);
 388         if(tracker != NULL)
 389         {
 390             tracker->packet_type = packet_type;
 391             tracker->user_count = 1;
 392
 393             Disable();
 394             AddTail((APTR)&unit->e1ku_type_trackers, (APTR)tracker);
 395             Enable();
 396         }
 397    }
 398
 399     /* Store initial figures for this opener */
 400
 401     opener = request->ios2_BufferManagement;
 402     initial_stats = FindTypeStats(LIBBASE, unit, &opener->initial_stats, packet_type);
 403
 404     if(initial_stats != NULL)
 405     {
 406         error = S2ERR_BAD_STATE;
 407         wire_error = S2WERR_ALREADY_TRACKED;
 408     }
 409
 410     if(error == 0)
 411     {
 412         initial_stats = AllocMem(sizeof(struct TypeStats), MEMF_PUBLIC);
 413         if(initial_stats == NULL)
 414         {
 415             error = S2ERR_NO_RESOURCES;
 416             wire_error = S2WERR_GENERIC_ERROR;
 417         }
 418     }
 419
 420     if(error == 0)
 421     {
 422         CopyMem(tracker, initial_stats, sizeof(struct TypeStats));
 423         AddTail((APTR)&opener->initial_stats, (APTR)initial_stats);
 424     }
 425
 426     /* Return */
 427
 428     request->ios2_Req.io_Error = error;
 429     request->ios2_WireError = wire_error;
 430     return TRUE;
 431 }
 432
 433 static BOOL CmdUntrackType(LIBBASETYPEPTR LIBBASE, struct IOSana2Req *request)
 434 {
 435     struct e1000Unit *unit;
 436     struct Opener *opener;
 437     ULONG packet_type;
 438     struct TypeTracker *tracker;
 439     struct TypeStats *initial_stats;
 440
 441     unit = (APTR)request->ios2_Req.io_Unit;
 442
 443 D(bug("[%s]: CmdUntrackType()\n", unit->e1ku_name));
 444
 445     packet_type = request->ios2_PacketType;
 446
 447     /* Get global tracker and initial figures */
 448
 449     tracker = (struct TypeTracker *)
 450         FindTypeStats(LIBBASE, unit, &unit->e1ku_type_trackers, packet_type);
 451     opener = request->ios2_BufferManagement;
 452     initial_stats = FindTypeStats(LIBBASE, unit, &opener->initial_stats, packet_type);
 453
 454     /* Decrement tracker usage and free unused structures */
 455
 456     if(initial_stats != NULL)
 457     {
 458         if((--tracker->user_count) == 0)
 459         {
 460             Disable();
 461             Remove((APTR)tracker);
 462             Enable();
 463             FreeMem(tracker, sizeof(struct TypeTracker));
 464         }
 465
 466         Remove((APTR)initial_stats);
 467         FreeMem(initial_stats, sizeof(struct TypeStats));
 468     }
 469     else
 470     {
 471         request->ios2_Req.io_Error = S2ERR_BAD_STATE;
 472         request->ios2_WireError = S2WERR_NOT_TRACKED;
 473     }
 474
 475     /* Return */
 476
 477     return TRUE;
 478 }
 479
 480 static BOOL CmdGetTypeStats(LIBBASETYPEPTR LIBBASE, struct IOSana2Req *request)
 481 {
 482     struct e1000Unit *unit;
 483     struct Opener *opener;
 484     ULONG packet_type;
 485     struct TypeStats *initial_stats, *tracker;
 486     struct Sana2PacketTypeStats *stats;
 487
 488     unit = (APTR)request->ios2_Req.io_Unit;
 489
 490 D(bug("[%s]: CmdGetTypeStats()\n", unit->e1ku_name));
 491
 492     packet_type = request->ios2_PacketType;
 493
 494     /* Get global tracker and initial figures */
 495
 496     tracker = FindTypeStats(LIBBASE, unit, &unit->e1ku_type_trackers, packet_type);
 497     opener = request->ios2_BufferManagement;
 498     initial_stats = FindTypeStats(LIBBASE, unit, &opener->initial_stats, packet_type);
 499
 500     /* Copy and adjust figures */
 501     if(initial_stats != NULL)
 502     {
 503         stats = request->ios2_StatData;
 504         CopyMem(&tracker->stats, stats, sizeof(struct Sana2PacketTypeStats));
 505         stats->PacketsSent -= initial_stats->stats.PacketsSent;
 506         stats->PacketsReceived -= initial_stats->stats.PacketsReceived;
 507         stats->BytesSent -= initial_stats->stats.BytesSent;
 508         stats->BytesReceived -= initial_stats->stats.BytesReceived;
 509         stats->PacketsDropped -= initial_stats->stats.PacketsDropped;
 510     }
 511     else
 512     {
 513         request->ios2_Req.io_Error = S2ERR_BAD_STATE;
 514         request->ios2_WireError = S2WERR_NOT_TRACKED;
 515     }
 516
 517     /* Return */
 518
 519     return TRUE;
 520 }
 521
 522 static BOOL CmdGetGlobalStats(LIBBASETYPEPTR LIBBASE, struct IOSana2Req *request)
 523 {
 524     struct e1000Unit *unit;
 525
 526     /* Update and copy stats */
 527
 528     unit = (APTR)request->ios2_Req.io_Unit;
 529
 530 D(bug("[%s]: CmdGetGlobalStats()\n", unit->e1ku_name));
 531
 532     CopyMem(&unit->e1ku_stats, request->ios2_StatData,
 533         sizeof(struct Sana2DeviceStats));
 534
 535     /* Return */
 536
 537     return TRUE;
 538 }
 539
 540 static BOOL CmdDeviceQuery(LIBBASETYPEPTR LIBBASE, struct IOStdReq *request)
 541 {
 542     struct NSDeviceQueryResult *info;
 543
 544     /* Set structure size twice */
 545
 546     info = request->io_Data;
 547     request->io_Actual = info->SizeAvailable =
 548         offsetof(struct NSDeviceQueryResult, SupportedCommands) + sizeof(APTR);
 549
 550     /* Report device details */
 551
 552     info->DeviceType = NSDEVTYPE_SANA2;
 553     info->DeviceSubType = 0;
 554
 555     info->SupportedCommands = (APTR)supported_commands;
 556
 557     /* Return */
 558
 559     return TRUE;
 560 }
 561
 562 static BOOL CmdOnEvent(LIBBASETYPEPTR LIBBASE, struct IOSana2Req *request)
 563 {
 564     struct e1000Unit *unit;
 565     ULONG events, wanted_events;
 566     BOOL complete = FALSE;
 567
 568     /* Check if we understand the event types */
 569
 570     unit = (APTR)request->ios2_Req.io_Unit;
 571
 572 D(bug("[%s]: CmdOnEvent()\n", unit->e1ku_name));
 573
 574     wanted_events = request->ios2_WireError;
 575     if((wanted_events & ~KNOWN_EVENTS) != 0)
 576     {
 577         request->ios2_Req.io_Error = S2ERR_NOT_SUPPORTED;
 578         events = S2WERR_BAD_EVENT;
 579     }
 580     else
 581     {
 582         if((unit->e1ku_ifflags & IFF_UP) != 0)
 583             events = S2EVENT_ONLINE;
 584         else
 585             events = S2EVENT_OFFLINE;
 586
 587         events &= wanted_events;
 588     }
 589
 590     /* Reply request if a wanted event has already occurred */
 591
 592     if(events != 0)
 593     {
 594         request->ios2_WireError = events;
 595         complete = TRUE;
 596     }
 597     else
 598     {
 599         request->ios2_Req.io_Flags &= ~IOF_QUICK;
 600         PutMsg(unit->e1ku_request_ports[EVENT_QUEUE], (APTR)request);
 601     }
 602
 603     /* Return */
 604
 605     return complete;
 606 }
 607
 608 static BOOL CmdReadOrphan(LIBBASETYPEPTR LIBBASE, struct IOSana2Req *request)
 609 {
 610     struct e1000Unit *unit;
 611     BYTE error = 0;
 612     ULONG wire_error;
 613     BOOL complete = FALSE;
 614
 615     /* Check request is valid */
 616
 617     unit = (APTR)request->ios2_Req.io_Unit;
 618 D(bug("[%s]: CmdReadOrphan()\n", unit->e1ku_name));
 619
 620     if((unit->e1ku_ifflags & IFF_UP) == 0)
 621     {
 622         error = S2ERR_OUTOFSERVICE;
 623         wire_error = S2WERR_UNIT_OFFLINE;
 624     }
 625
 626     /* Queue request */
 627
 628     if(error == 0)
 629     {
 630         request->ios2_Req.io_Flags &= ~IOF_QUICK;
 631         PutMsg(unit->e1ku_request_ports[ADOPT_QUEUE], (struct Message *)request);
 632     }
 633     else
 634     {
 635         request->ios2_Req.io_Error = error;
 636         request->ios2_WireError = wire_error;
 637         complete = TRUE;
 638     }
 639
 640     /* Return */
 641
 642     return complete;
 643 }
 644
 645 static BOOL CmdOnline(LIBBASETYPEPTR LIBBASE, struct IOSana2Req *request)
 646 {
 647     struct e1000Unit *unit = (struct e1000Unit *)request->ios2_Req.io_Unit;
 648     ULONG wire_error = 0, rctl, tctl;
 649     int i;
 650     BYTE error = 0;
 651
 652 D(bug("[%s]: CmdOnline()\n", unit->e1ku_name));
 653
 654     /* Check request is valid */
 655     if((unit->e1ku_ifflags & IFF_CONFIGURED) == 0)
 656     {
 657         error = S2ERR_BAD_STATE;
 658         wire_error = S2WERR_NOT_CONFIGURED;
 659     }
 660
 661     /* Clear global and special stats and put adapter back online */
 662
 663     if((error == 0) && ((unit->e1ku_ifflags & IFF_UP) == 0))
 664     {
 665         unit->e1ku_stats.PacketsReceived = 0;
 666         unit->e1ku_stats.PacketsSent = 0;
 667         unit->e1ku_stats.BadData = 0;
 668         unit->e1ku_stats.Overruns = 0;
 669         unit->e1ku_stats.UnknownTypesReceived = 0;
 670         unit->e1ku_stats.Reconfigurations = 0;
 671
 672         for(i = 0; i < SANA2_SPECIAL_STAT_COUNT; i++)
 673             unit->e1ku_special_stats[i] = 0;
 674
 675         tctl = E1000_READ_REG((struct e1000_hw *)unit->e1ku_Private00, E1000_TCTL);
 676         tctl |= E1000_TCTL_EN;
 677         E1000_WRITE_REG((struct e1000_hw *)unit->e1ku_Private00, E1000_TCTL, tctl);
 678
 679         rctl = E1000_READ_REG((struct e1000_hw *)unit->e1ku_Private00, E1000_RCTL);
 680         rctl |= E1000_RCTL_EN;
 681         E1000_WRITE_REG((struct e1000_hw *)unit->e1ku_Private00, E1000_RCTL, rctl);
 682
 683         e1000func_irq_enable(unit);
 684
 685         /* fire a link status change interrupt to start the watchdog */
 686         E1000_WRITE_REG((struct e1000_hw *)unit->e1ku_Private00, E1000_ICS, E1000_ICS_LSC);
 687
 688         unit->e1ku_ifflags |= IFF_UP;
 689         ReportEvents(LIBBASE, unit, S2EVENT_ONLINE);
 690     }
 691
 692     /* Return */
 693
 694     request->ios2_Req.io_Error = error;
 695     request->ios2_WireError = wire_error;
 696     return TRUE;
 697 }
 698
 699 static BOOL CmdOffline(LIBBASETYPEPTR LIBBASE, struct IOSana2Req *request)
 700 {
 701     struct e1000Unit *unit;
 702         ULONG rctl, tctl;
 703     /* Put adapter offline */
 704
 705     unit = (APTR)request->ios2_Req.io_Unit;
 706
 707 D(bug("[%s]: CmdOffline()\n", unit->e1ku_name));
 708
 709     if((unit->e1ku_ifflags & IFF_UP) != 0)
 710     {
 711         unit->e1ku_ifflags &= ~IFF_UP;
 712
 713         tctl = E1000_READ_REG((struct e1000_hw *)unit->e1ku_Private00, E1000_TCTL);
 714         tctl &= ~E1000_TCTL_EN;
 715         E1000_WRITE_REG((struct e1000_hw *)unit->e1ku_Private00, E1000_TCTL, tctl);
 716
 717         rctl = E1000_READ_REG((struct e1000_hw *)unit->e1ku_Private00, E1000_RCTL);
 718         rctl &= ~E1000_RCTL_EN;
 719         E1000_WRITE_REG((struct e1000_hw *)unit->e1ku_Private00, E1000_RCTL, rctl);
 720
 721         e1000func_irq_disable(unit);
 722
 723         ReportEvents(LIBBASE, unit, S2EVENT_OFFLINE);
 724     }
 725
 726     /* Return */
 727     return TRUE;
 728 }
 729
 730 static BOOL CmdAddMulticastAddresses(LIBBASETYPEPTR LIBBASE, struct IOSana2Req *request)
 731 {
 732     struct e1000Unit *unit;
 733     UBYTE *lower_bound, *upper_bound;
 734
 735     unit = (APTR)request->ios2_Req.io_Unit;
 736
 737 D(bug("[%s]: CmdAddMulticastAddresses()\n", unit->e1ku_name));
 738
 739     lower_bound = request->ios2_SrcAddr;
 740     if(request->ios2_Req.io_Command == S2_ADDMULTICASTADDRESS)
 741         upper_bound = lower_bound;
 742     else
 743         upper_bound = request->ios2_DstAddr;
 744
 745     if(!AddMulticastRange(LIBBASE, unit, lower_bound, upper_bound))
 746     {
 747         request->ios2_Req.io_Error = S2ERR_NO_RESOURCES;
 748         request->ios2_WireError = S2WERR_GENERIC_ERROR;
 749     }
 750
 751     /* Return */
 752
 753     return TRUE;
 754 }
 755
 756 static BOOL CmdDelMulticastAddresses(LIBBASETYPEPTR LIBBASE, struct IOSana2Req *request)
 757 {
 758     struct e1000Unit *unit;
 759     UBYTE *lower_bound, *upper_bound;
 760
 761     unit = (APTR)request->ios2_Req.io_Unit;
 762
 763 D(bug("[%s]: CmdDelMulticastAddresses()\n", unit->e1ku_name));
 764
 765     lower_bound = request->ios2_SrcAddr;
 766     if(request->ios2_Req.io_Command == S2_DELMULTICASTADDRESS)
 767         upper_bound = lower_bound;
 768     else
 769         upper_bound = request->ios2_DstAddr;
 770
 771     if(!RemMulticastRange(LIBBASE, unit, lower_bound, upper_bound))
 772     {
 773         request->ios2_Req.io_Error = S2ERR_BAD_STATE;
 774         request->ios2_WireError = S2WERR_BAD_MULTICAST;
 775     }
 776
 777     /* Return */
 778
 779     return TRUE;
 780 }