Remove blocking timeout parameter for compatibility
This commit is contained in:
parent
3d67b098ef
commit
df8cffbe1a
|
@ -97,7 +97,7 @@ namespace gr
|
||||||
d_produced = 0;
|
d_produced = 0;
|
||||||
|
|
||||||
/* Block waiting from a new message from users */
|
/* Block waiting from a new message from users */
|
||||||
msg = delete_head_blocking (pmt::mp ("info"), 0);
|
msg = delete_head_blocking (pmt::mp ("info"));
|
||||||
info = (const uint8_t *)pmt::blob_data(msg);
|
info = (const uint8_t *)pmt::blob_data(msg);
|
||||||
info_len = pmt::blob_length(msg);
|
info_len = pmt::blob_length(msg);
|
||||||
|
|
||||||
|
|
|
@ -74,7 +74,7 @@ namespace gr {
|
||||||
size_t length;
|
size_t length;
|
||||||
|
|
||||||
while(is_running){
|
while(is_running){
|
||||||
message = delete_head_blocking(d_in_port,0);
|
message = delete_head_blocking(d_in_port);
|
||||||
length = blob_length(message);
|
length = blob_length(message);
|
||||||
d_buf = (uint8_t*)blob_data(message);
|
d_buf = (uint8_t*)blob_data(message);
|
||||||
std::istringstream ss(std::string(d_buf, d_buf + length));
|
std::istringstream ss(std::string(d_buf, d_buf + length));
|
||||||
|
|
Loading…
Reference in New Issue