HP Rp7410 BSD Sockets Interface Programmer's Guide - Page 143

msec = 1000*floatsecs

Get HP Rp7410 - Server - 0 MB RAM PDF manuals and user guides View all HP Rp7410 manuals
Add to My Manuals
Save this manual to your list of manuals

Page 143 highlights

Using UNIX Domain Stream Sockets Example Using UNIX Domain Stream Sockets */ send_data(ns, &bullet, sizeof(struct bullet)); cc = 0; if (counter_pid) kill(counter_pid, SIGUSR1); if (gettimeofday(&tp1, &tzp) == -1) { perror("catch time of day failed"); exit(0); } /* * Receive data from the client */ total = 0; i = bytes; while (i > 0) { cc = recvsize < i ? recvsize : i; recv_data(ns, buffer, cc); total += cc; i -= cc; } /* * Calculate throughput */ if (gettimeofday(&tp2, &tzp) == -1) { perror("catch time of day failed"); exit(0); } if (counter_pid) kill(counter_pid, SIGUSR2); secs = tp2.tv_sec - tp1.tv_sec; usec = tp2.tv_usec - tp1.tv_usec; if (usec < 0) { secs ; usec += 1000000; } msec = 1000*(float)secs; msec += (float)usec/1000; bullet.throughput = bytes/msec; /* * Send back the bullet with throughput info, then close the * server socket */ if ((cc = send(ns, &bullet, sizeof(struct bullet), 0)) == -1) { perror("catch - send end bullet failed"); exit(0); } close(ns); } timeout() { printf( "alarm went off -- stopping the catch process\n"); fprintf(stderr, "stopping the catch process\n"); unlink(SOCKNAME); close(s); exit(6); } /* * Sample Program : AF_UNIX stream sockets, client process * Chapter 6 143

  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30
  • 31
  • 32
  • 33
  • 34
  • 35
  • 36
  • 37
  • 38
  • 39
  • 40
  • 41
  • 42
  • 43
  • 44
  • 45
  • 46
  • 47
  • 48
  • 49
  • 50
  • 51
  • 52
  • 53
  • 54
  • 55
  • 56
  • 57
  • 58
  • 59
  • 60
  • 61
  • 62
  • 63
  • 64
  • 65
  • 66
  • 67
  • 68
  • 69
  • 70
  • 71
  • 72
  • 73
  • 74
  • 75
  • 76
  • 77
  • 78
  • 79
  • 80
  • 81
  • 82
  • 83
  • 84
  • 85
  • 86
  • 87
  • 88
  • 89
  • 90
  • 91
  • 92
  • 93
  • 94
  • 95
  • 96
  • 97
  • 98
  • 99
  • 100
  • 101
  • 102
  • 103
  • 104
  • 105
  • 106
  • 107
  • 108
  • 109
  • 110
  • 111
  • 112
  • 113
  • 114
  • 115
  • 116
  • 117
  • 118
  • 119
  • 120
  • 121
  • 122
  • 123
  • 124
  • 125
  • 126
  • 127
  • 128
  • 129
  • 130
  • 131
  • 132
  • 133
  • 134
  • 135
  • 136
  • 137
  • 138
  • 139
  • 140
  • 141
  • 142
  • 143
  • 144
  • 145
  • 146
  • 147
  • 148
  • 149
  • 150
  • 151
  • 152
  • 153
  • 154
  • 155
  • 156
  • 157
  • 158
  • 159
  • 160
  • 161
  • 162
  • 163
  • 164
  • 165
  • 166
  • 167
  • 168
  • 169
  • 170
  • 171
  • 172
  • 173
  • 174
  • 175
  • 176
  • 177
  • 178
  • 179
  • 180
  • 181
  • 182
  • 183
  • 184
  • 185
  • 186
  • 187
  • 188
  • 189
  • 190
  • 191
  • 192
  • 193
  • 194
  • 195
  • 196
Chapter 6
143
Using UNIX Domain Stream Sockets
Example Using UNIX Domain Stream Sockets
*/
send_data(ns, &bullet, sizeof(struct bullet));
cc = 0;
if (counter_pid)
kill(counter_pid, SIGUSR1);
if (gettimeofday(&tp1, &tzp) == -1) {
perror(”catch time of day failed”);
exit(0);
}
/*
* Receive data from the client
*/
total = 0;
i = bytes;
while (i > 0) {
cc = recvsize < i ? recvsize : i;
recv_data(ns, buffer, cc);
total += cc;
i -= cc;
}
/*
* Calculate throughput
*/
if (gettimeofday(&tp2, &tzp) == -1) {
perror(”catch time of day failed”);
exit(0);
}
if (counter_pid)
kill(counter_pid, SIGUSR2);
secs = tp2.tv_sec - tp1.tv_sec;
usec = tp2.tv_usec - tp1.tv_usec;
if (usec < 0) {
secs ;
usec += 1000000;
}
msec = 1000*(float)secs;
msec += (float)usec/1000;
bullet.throughput = bytes/msec;
/*
* Send back the bullet with throughput info, then close the
* server socket
*/
if ((cc = send(ns, &bullet, sizeof(struct bullet), 0)) == -1)
{
perror(”catch - send end bullet failed”);
exit(0);
}
close(ns);
}
timeout()
{
printf( ”alarm went off -- stopping the catch process\n”);
fprintf(stderr, ”stopping the catch process\n”);
unlink(SOCKNAME);
close(s);
exit(6);
}
/*
*
Sample Program : AF_UNIX stream sockets, client process
*