send
struct ifreq_stream_stats send;
ssize_t send(int socket, const void *buffer, size_t length, int flags);
#define ksend send
#define ksend send
#define ksend (gSocket->send)
} send, recv;
ssize_t (*send)(net_socket* socket, struct msghdr* , const void* data,
} send, receive;
ssize_t (*send)(net_socket* socket, const void* data, size_t length,
int (*send)(struct fuse_chan *ch, const struct iovec iov[],
int (*send)(struct fuse_chan *ch, const struct iovec iov[],
dp_aux_speak(uint32 connectorIndex, uint8* send, int sendBytes,
memcpy(base, send, sendBytes);
fw_dump_hdr(&xfer->send.hdr, "send");
if((uint)xfer->send.hdr.mode.hdr.dst == (uint)node) {
req = xfer->send.hdr.mode.hdr.tcode;
xfer->send.pay_len = send_len;
xfer->send.payArea = alloc_mem(&send_virt, &send_phy,
if (xfer->send.payArea < B_OK){
xfer->send.payload = (uint32_t *)send_virt;
xfer->send.bus_addr = (bus_addr_t)(addr_t)send_phy;
if (xfer->send.payArea > B_OK){
delete_area(xfer->send.payArea);
xfer->send.payArea = -1;
if (xfer->send.payArea > B_OK){
delete_area(xfer->send.payArea);
xfer->send.payArea = -1;
fp = &xfer->send.hdr;
fp = &xfer->send.hdr;
if (xfer->send.pay_len > MAXREC(fc->maxrec)) {
if (len != xfer->send.pay_len){
dst = xfer->send.hdr.mode.hdr.dst & 0x3f;
if ((txfer->send.hdr.mode.hdr.dst & 0x3f) == dst)
xfer->send.hdr.mode.hdr.tlrt = new_tlabel << 2;
len, xfer->send.pay_len, tcode_str[tcode], tcode);
rb->xfer->send.spd = rb->spd;
rb->xfer->send.pay_len = 0;
resfp = &rb->xfer->send.hdr;
xfer->send.spd = 0;
fp = &xfer->send.hdr;
xfer->send.payload[0] = htonl(0x3f);
xfer->send.payload[1] = htonl(fc->nodeid);
xfer->send.buf = malloc(12, M_FW, M_NOWAIT);
xfer->send.len = 12;
sfp = (struct fw_pkt *)xfer->send.buf;
xfer->send.buf = malloc(12, M_FW, M_NOWAIT);
xfer->send.len = 12;
xfer->send.buf = malloc(16 + rfp->mode.rreqb.len, M_FW, M_NOWAIT);
xfer->send.len = 16 + ntohs(rfp->mode.rreqb.len);
sfp = (struct fw_pkt *)xfer->send.buf;
xfer->send.buf = malloc(16, M_FW, M_NOWAIT);
xfer->send.len = 16;
sfp = (struct fw_pkt *)xfer->send.buf;
fw_dump_hdr(&xfer->send.hdr, "send");
xfer->send.payload = NULL;
fp = &xfer->send.hdr;
xfer->send.payload = xfer->recv.payload = NULL;
fp = &xfer->send.hdr;
xfer->send.payload = NULL;
fp = &xfer->send.hdr;
xfer->send.payload = (uint32_t*)data;
xfer->send.hdr.mode.hdr.dst = FWLOCALBUS | fwdev->dst;
xfer->send.spd = fwdev->speed;
xfer->send.spd = min_c(spd, fwdev->speed);
xfer->send.pay_len = slen;
fp = &xfer->send.hdr;
fp = &xfer->send.hdr;
ohcifp->mode.common.spd = xfer->send.spd & 0x7;
if (xfer->send.pay_len > 0) {
fwohci_execute_db(db_tr, &xfer->send);
&xfer->send.payload[0], xfer->send.pay_len,
bcopy(&pkt, &xfer->send.hdr, sizeof(struct fw_pkt));
xfer->send.pay_len = pbytes;
err = user_memcpy((void*)&xfer->send.payload[0],
xfer->send.spd = 2 /* XXX */;
bcopy(fp, (void *)&xfer->send.hdr, tinfo->hdr_len);
(void *)xfer->send.payload, pay_len);
xfer->send.spd = asyreq->req.sped;
goto send;
send:
cmd.ucode.once.send = htole32(0xffffffff);
uint32_t send;
int32 bytesSent = send(fSocket, buffer, size, 0);
#define ksend send
#define ksend (gSocket->send)
#define ksend (gSocket->send)
result = send(fSocket, buf + sent, size + sizeof(uint32) - sent, 0);
status_t result = send(fSocket, buffer, size, 0);
int dend, send; /* Last index into @[ds]rl. */
for (send = si; srl[send].length; send++)
if (srl[send].lcn == (LCN)LCN_ENOENT)
marker_vcn = srl[marker = send].vcn;
for (sfinal = send; sfinal >= 0 && srl[sfinal].lcn < LCN_HOLE; sfinal--)
(srl[send - 1].vcn + srl[send - 1].length)));
if (marker && (drl[dins].vcn + drl[dins].length > srl[send - 1].vcn))
ntfs_log_debug("sstart = %i, sfinal = %i, send = %i\n", sstart, sfinal, send);
#define ksend send
#define ksend send
#define ksend (gSocket->send)
device->stats.send.errors++;
bigtime_t timeout = absolute_timeout(socket->send.timeout);
fSendQueue(socket->send.buffer_size),
bigtime_t timeout = min_c(socket->send.timeout, TCP_CONNECTION_TIMEOUT);
timeout = absolute_timeout(socket->send.timeout);
while (fSendQueue.Free() < socket->send.low_water_mark) {
ssize_t bytes = fSocket->send.buffer_size;
timeout = absolute_timeout(socket->send.timeout);
UnixFifo* peerFifo = new(nothrow) UnixFifo(socket->send.buffer_size, type);
timeout = absolute_timeout(socket->send.timeout);
atomic_add((int32*)&device->stats.send.packets, 1);
atomic_add64((int64*)&device->stats.send.bytes, packetSize);
atomic_add((int32*)&device->stats.send.errors, 1);
stats.send = deviceStats.send;
return protocol->socket->send.buffer_size;
*size = socket->send.buffer_size;
*size = socket->send.low_water_mark;
send.buffer_size = 65535;
send.low_water_mark = 1;
timeout = socket->send.timeout;
send.timeout = B_INFINITE_TIMEOUT;
*_set = socket->receive.timeout == 0 && socket->send.timeout == 0;
if (atomic && bytesLeft > socket->send.buffer_size)
while (buffer->size < socket->send.buffer_size
if (buffer->size + bytes > socket->send.buffer_size)
bytes = socket->send.buffer_size - buffer->size;
socket->send.buffer_size = *(const uint32*)value;
socket->send.low_water_mark = *(const uint32*)value;
socket->send.timeout = timeout;
socket->send.timeout = 0;
socket->send.timeout = B_INFINITE_TIMEOUT;
socket->send = parent->send;
if ((ssize_t)socket->send.low_water_mark <= available
if ((ssize_t)socket->send.low_water_mark > value
return gNetSocketModule.send(socket, NULL, data, length, flags);
return gNetSocketModule.send(socket, &message, data, length, flags);
return gNetSocketModule.send(socket, (msghdr*)message, buffer, length,
err = send(fSocket, &cmd, sizeof(cmd), 0);
err = send(fSocket, obuf, olen, 0);
size = ::send(__sock, buffer, size, flags);
fBytesSent += stats.send.bytes;
if (send(hc->conn_fd, hc->response, hc->responselen, 0) < 0) {
if (send(hc->conn_fd, (void*)buf, bytesRead, 0) < 0) {
int retval = send(hc->conn_fd, hc->response, hc->responselen, 0);
Syscall *send = get_syscall("_kern_send");
send->GetParameter("flags")->SetHandler(new FlagsTypeHandler(kRecvFlags));
"dropped\n", stats.send.packets, stats.send.errors,
stats.send.bytes, stats.send.multicast_packets, stats.send.dropped);
i = send(ssend, (char *)packet, cc, 0);
n = send(net, (char *)netoring.consume, n, 0); /* normal write */
n = send(net, (char *)netoring.consume, 1, MSG_OOB);/* URGENT data */
n = send(net, nbackp, n-1, 0); /* send URGENT all by itself */
n = send(net, nbackp, n, MSG_OOB); /* URGENT data */
cc = send(sndsock, (char *)outip, packlen, 0);
PortLink::PortLink(port_id send, port_id receive)
fSender = new LinkSender(send);
bytesSent = send(Socket(), buffer, size, 0);
ssize_t bytesSent = send(fSocket, (const char *) buffer, length, flags);
ssize_t bytesSent = send(Socket(), buffer, size, 0);
stats.send.packets = ifp->if_data.ifi_opackets;
stats.send.errors = ifp->if_data.ifi_oerrors;
stats.send.bytes = ifp->if_data.ifi_obytes;
stats.send.multicast_packets = ifp->if_data.ifi_omcasts;
stats.send.dropped = ifp->if_data.ifi_oqdrops;
if (ap && ap->send) {
if ((*ap->send)(ap)) {
int (*send)(struct XauthP *);
string_for_size(stats.send.bytes, buffer, sizeof(buffer));
ssize_t bytesWritten = sStackInterface->send(FD_SOCKET(descriptor), buffer,
return sStackInterface->send(FD_SOCKET(descriptor), data, length, flags);
} else if (send(s, buf, buflen, 0) != (ssize_t)buflen) {
int ret = send(fd, buffer, len, 0);
int status = send(fd, buffer, length, 0);
if (send(sock, buffer, red + 1, 0) < 0)
if (send(fd, buf, len, 0) < 0)
if (send(fd, buf, len, 0) < 0)
if ((send(sockfd, buffer, strlen(buffer), 0)) == -1) {
if (send(new_fd, buf, strlen(buf), 0) == -1) {
gClientSocket->send.timeout = 0;
socket->send.buffer_size = 65535;
socket->send.low_water_mark = 1;
socket->send.timeout = B_INFINITE_TIMEOUT;
socket->send = parent->send;
if ((ssize_t)socket->send.low_water_mark > value && value >= B_OK)
send(ctx->sock, ptr, bytes, 0);
send(fd, argv[2], strlen(argv[2]), 0);
send(fd, buffer, strlen(buffer), 0);
status = send(sock, "test", 4, 0);
status = send(sock, "test2", 5, 0);
status = send(sock, "test4", 4, 0);
status = send(sock, "test5", 5, 0);
status = send(sock, "test6", 5, 0);
ret = send(fds[0], &buf[0], bufLen, MSG_DONTWAIT);