test/timeport.c

   1 #include <exec/types.h>
   2 #include <exec/ports.h>
   3 #include <dos/dosextens.h>
   4 #include <dos/dostags.h>
   5 #include <aros/libcall.h>
   6 #include <proto/exec.h>
   7 #include <proto/dos.h>
   8 #include <stdio.h>
   9 #include <sys/time.h>
  10 #include <time.h>
  11
  12 #define NUM_MESSAGES (1000000)
  13
  14 AROS_UFH3(void, taskentry,
  15           AROS_UFHA(STRPTR,            argPtr,  A0),
  16           AROS_UFHA(ULONG,             argSize, D0),
  17           AROS_UFHA(struct ExecBase *, SysBase, A6)) {
  18     AROS_USERFUNC_INIT
  19
  20     int i;
  21     struct MsgPort *port = (struct MsgPort *) FindTask(NULL)->tc_UserData;
  22
  23     for (i = 0; i < NUM_MESSAGES; i++) {
  24         WaitPort(port);
  25         ReplyMsg(GetMsg(port));
  26     }
  27
  28     AROS_USERFUNC_EXIT
  29 }
  30
  31 AROS_UFH3(void, intentry,
  32           AROS_UFHA(APTR,              data,    A1),
  33           AROS_UFHA(APTR,              code,    A5),
  34           AROS_UFHA(struct ExecBase *, SysBase, A6)) {
  35     AROS_USERFUNC_INIT
  36
  37     struct MsgPort *port = (struct MsgPort *) data;
  38
  39     WaitPort(port);
  40     ReplyMsg(GetMsg(port));
  41
  42     AROS_USERFUNC_EXIT
  43 }
  44
  45 AROS_UFH4(void, fastentry,
  46           AROS_UFHA(APTR,              data,    A1),
  47           AROS_UFHA(APTR,              code,    A5),
  48           AROS_UFHA(struct Message *,  msg,     D0),
  49           AROS_UFHA(struct ExecBase *, SysBase, A6)) {
  50     AROS_USERFUNC_INIT
  51
  52     ReplyMsg(msg);
  53
  54     AROS_USERFUNC_EXIT
  55 }
  56
  57 AROS_UFH2(void, callentry,
  58           AROS_UFHA(struct MsgPort *,  port,    D0),
  59           AROS_UFHA(struct ExecBase *, SysBase, A6)) {
  60     AROS_USERFUNC_INIT
  61
  62     WaitPort(port);
  63     ReplyMsg(GetMsg(port));
  64
  65     AROS_USERFUNC_EXIT
  66 }
  67
  68 int main(int argc, char **argv) {
  69     struct MsgPort *port, *reply;
  70     struct Message *msg;
  71     struct Process *proc;
  72     int i;
  73     struct timeval start, end;
  74     struct Interrupt *intr;
  75
  76     printf("testing with %d messages\n", NUM_MESSAGES);
  77
  78     port = CreateMsgPort();
  79     reply = CreateMsgPort();
  80
  81     msg = AllocVec(sizeof(struct Message), MEMF_PUBLIC | MEMF_CLEAR);
  82     msg->mn_Length = sizeof(struct Message);
  83     msg->mn_ReplyPort = reply;
  84
  85     proc = CreateNewProcTags(NP_Entry,    (IPTR) taskentry,
  86                              NP_Name,     "timeport task",
  87                              NP_UserData, (IPTR) port,
  88                              TAG_DONE);
  89
  90     port->mp_Flags = PA_SIGNAL;
  91     port->mp_SigTask = (struct Task *) proc;
  92
  93     gettimeofday(&start, NULL);
  94
  95     for (i = 0; i < NUM_MESSAGES; i++) {
  96         PutMsg(port, msg);
  97         WaitPort(reply);
  98         GetMsg(reply);
  99     }
 100
 101     gettimeofday(&end, NULL);
 102
 103     while (end.tv_usec < start.tv_usec) {
 104         end.tv_sec--;
 105         end.tv_usec += 1000000;
 106     }
 107
 108     printf("PA_SIGNAL: %ld.%lds\n", end.tv_sec - start.tv_sec, (end.tv_usec - start.tv_usec) / 1000);
 109
 110     intr = AllocVec(sizeof(struct Interrupt), MEMF_PUBLIC | MEMF_CLEAR);
 111     intr->is_Code = intentry;
 112     intr->is_Data = port;
 113
 114     port->mp_Flags = PA_SOFTINT;
 115     port->mp_SoftInt = intr;
 116
 117     gettimeofday(&start, NULL);
 118
 119     for (i = 0; i < NUM_MESSAGES; i++) {
 120         PutMsg(port, msg);
 121         WaitPort(reply);
 122         GetMsg(reply);
 123     }
 124
 125     gettimeofday(&end, NULL);
 126
 127     while (end.tv_usec < start.tv_usec) {
 128         end.tv_sec--;
 129         end.tv_usec += 1000000;
 130     }
 131
 132     printf("PA_SOFTINT: %ld.%lds\n", end.tv_sec - start.tv_sec, (end.tv_usec - start.tv_usec) / 1000);
 133
 134     port->mp_Flags = PA_CALL;
 135     port->mp_SigTask = callentry;
 136
 137     gettimeofday(&start, NULL);
 138
 139     for (i = 0; i < NUM_MESSAGES; i++) {
 140         PutMsg(port, msg);
 141         WaitPort(reply);
 142         GetMsg(reply);
 143     }
 144
 145     gettimeofday(&end, NULL);
 146
 147     while (end.tv_usec < start.tv_usec) {
 148         end.tv_sec--;
 149         end.tv_usec += 1000000;
 150     }
 151
 152     printf("PA_CALL: %ld.%lds\n", end.tv_sec - start.tv_sec, (end.tv_usec - start.tv_usec) / 1000);
 153
 154     intr->is_Code = fastentry;
 155
 156     port->mp_Flags = PA_FASTCALL;
 157     port->mp_SoftInt = intr;
 158
 159     gettimeofday(&start, NULL);
 160
 161     for (i = 0; i < NUM_MESSAGES; i++) {
 162         PutMsg(port, msg);
 163         WaitPort(reply);
 164         GetMsg(reply);
 165     }
 166
 167     gettimeofday(&end, NULL);
 168
 169     while (end.tv_usec < start.tv_usec) {
 170         end.tv_sec--;
 171         end.tv_usec += 1000000;
 172     }
 173
 174     printf("PA_FASTCALL: %ld.%lds\n", end.tv_sec - start.tv_sec, (end.tv_usec - start.tv_usec) / 1000);
 175
 176     FreeVec(intr);
 177
 178     FreeVec(msg);
 179
 180     DeleteMsgPort(reply);
 181     DeleteMsgPort(port);
 182
 183     return 0;
 184 }